|
|
|
@ -185,58 +185,6 @@ public class WcsTaskScheduler { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 定时任务：每分钟处理WCS自动拣选回调数据 - rqrq action_type=N'自动分拣' |
|
|
|
* @Title scheduleAutoSortProcessing |
|
|
|
* @author rqrq |
|
|
|
* @date 2025/10/09 |
|
|
|
* |
|
|
|
* cron表达式：0 * * * * ? 表示每分钟的第0秒执行 |
|
|
|
* 配置说明：通过 scheduler.wcs.enabled 控制是否启用 |
|
|
|
*/ |
|
|
|
// @Scheduled(cron = "7/10 * * * * ?") |
|
|
|
// public void scheduleAutoSortProcessing() { |
|
|
|
// // 检查定时任务开关 - rqrq |
|
|
|
// if (!enabled) { |
|
|
|
// return; |
|
|
|
// } |
|
|
|
// |
|
|
|
// log.info("=== 开始处理WCS自动拣选回调数据 - rqrq ==="); |
|
|
|
// |
|
|
|
// try { |
|
|
|
// // 获取待处理的自动拣选回调记录（只查询拣选站点J1-J4，重试次数<3）- rqrq |
|
|
|
// List<WcsCallbackPalletScan> list = wcsCallbackPalletScanMapper.getPendingCallbacksForAutoSort("55", 3); |
|
|
|
// |
|
|
|
// if (list.isEmpty()) { |
|
|
|
// log.info("无待处理的WCS自动拣选回调数据 - rqrq"); |
|
|
|
// return; |
|
|
|
// } |
|
|
|
// |
|
|
|
// log.info("获取到 {} 个待处理的自动拣选任务 - rqrq", list.size()); |
|
|
|
// |
|
|
|
// int successCount = 0; |
|
|
|
// int failCount = 0; |
|
|
|
// |
|
|
|
// for (WcsCallbackPalletScan callback : list) { |
|
|
|
// try { |
|
|
|
// // 委托给业务服务处理 - rqrq |
|
|
|
// autoSortService.processAutoSortCallback(callback); |
|
|
|
// successCount++; |
|
|
|
// } catch (Exception e) { |
|
|
|
// log.error("处理WCS自动拣选回调失败 - rqrq：palletId={}, error={}", |
|
|
|
// callback.getPalletId(), e.getMessage()); |
|
|
|
// failCount++; |
|
|
|
// // 继续处理下一个数据 - rqrq |
|
|
|
// } |
|
|
|
// } |
|
|
|
// |
|
|
|
// log.info("=== WCS自动拣选回调处理完成 - rqrq：总数={}, 成功={}, 失败={} ===", |
|
|
|
// list.size(), successCount, failCount); |
|
|
|
// |
|
|
|
// } catch (Exception e) { |
|
|
|
// log.error("=== WCS自动拣选回调定时任务执行失败 - rqrq ===", e); |
|
|
|
// } |
|
|
|
// } |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 定时任务：每10秒执行一次齐套运输检查 - rqrq |
|
|
|
|
