1
This commit is contained in:
@@ -48,7 +48,7 @@ public class LogisticsServiceImpl implements ILogisticsService {
|
||||
private static final String REDIS_ADHOC_RECONCILE_ENQUEUE_PREFIX = "logistics:adhoc:reconcile:enqueue:";
|
||||
private static final int ADHOC_RECONCILE_ROW_LIMIT = 200;
|
||||
private static final long ADHOC_RECONCILE_ENQUEUE_LOCK_SECONDS = 8 * 60;
|
||||
/** 单次队列项最多重新入队次数(约对应多天 × 每 10 分钟一轮) */
|
||||
/** 单次队列项最多重新入队次数(约对应多天 × 每 15 分钟一轮) */
|
||||
private static final int ADHOC_MAX_REQUEUE_ATTEMPTS = 500;
|
||||
private static final String PUSH_URL = "https://wxts.van333.cn/wx/send/pdd";
|
||||
private static final String PUSH_TOKEN = "super_token_b62190c26";
|
||||
|
||||
@@ -75,7 +75,7 @@ public class WeComInboundServiceImpl implements IWeComInboundService {
|
||||
/** 备注已提交并入队 */
|
||||
private static String replyLogisticsRemarkDone() {
|
||||
return "「物流备注」已登记\n\n"
|
||||
+ "已加入查询队列,约每 10 分钟扫描并推送结果(与订单物流任务一致)。\n"
|
||||
+ "已加入查询队列,约每 15 分钟扫描并推送结果(与订单物流任务一致)。\n"
|
||||
+ "本轮录入已结束,可继续发录单、指令或新的物流链接。";
|
||||
}
|
||||
|
||||
|
||||
@@ -13,7 +13,7 @@ import java.util.List;
|
||||
|
||||
/**
|
||||
* 物流信息扫描定时任务
|
||||
* 每10分钟扫描一次分销标记为F或PDD的订单(最近30天),获取物流信息并推送;结束后处理企微分享链 adhoc 队列
|
||||
* 每15分钟扫描一次分销标记为F或PDD的订单(最近30天),获取物流信息并推送;结束后处理企微分享链 adhoc 队列
|
||||
*/
|
||||
@Component
|
||||
public class LogisticsScanTask {
|
||||
@@ -26,10 +26,10 @@ public class LogisticsScanTask {
|
||||
private ILogisticsService logisticsService;
|
||||
|
||||
/**
|
||||
* 定时任务:每10分钟执行一次(与 @Scheduled 中 cron 一致)
|
||||
* 定时任务:每15分钟执行一次(与 @Scheduled 中 cron 一致)
|
||||
* 只扫描最近30天的订单
|
||||
*/
|
||||
@Scheduled(cron = "0 */10 * * * ?")
|
||||
@Scheduled(cron = "0 */15 * * * ?")
|
||||
public void scanAndFetchLogistics() {
|
||||
long t0 = System.currentTimeMillis();
|
||||
int orderCandidates = 0;
|
||||
|
||||
Reference in New Issue
Block a user