diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/mapper/WcsCallbackPalletScanMapper.java b/src/main/java/com/gaotao/modules/automatedWarehouse/mapper/WcsCallbackPalletScanMapper.java index 0690081..78b922c 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/mapper/WcsCallbackPalletScanMapper.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/mapper/WcsCallbackPalletScanMapper.java @@ -23,7 +23,7 @@ public interface WcsCallbackPalletScanMapper extends BaseMapper getPendingCallbacks(@Param("site") String site, @Param("maxRetryCount") int maxRetryCount); - List getPendingCallbacksForAutoSort(@Param("site") String site, @Param("maxRetryCount") int maxRetryCount); + // List getPendingCallbacksForAutoSort(@Param("site") String site, @Param("maxRetryCount") int maxRetryCount); /** * @Description 更新处理状态 - rqrq diff --git a/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java b/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java index 03aa799..92e8f8d 100644 --- a/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java +++ b/src/main/java/com/gaotao/modules/automatedWarehouse/task/WcsTaskScheduler.java @@ -162,8 +162,12 @@ public class WcsTaskScheduler { for (WcsCallbackPalletScan callback : list) { try { - // 委托给业务服务处理 - rqrq - inventoryDiscrepancyService.processCallbackScan(callback); + if("被分拣回传".equals(callback.getActionType())){ + inventoryDiscrepancyService.processCallbackScan(callback); + } + if("自动分拣".equals(callback.getActionType())){ + autoSortService.processAutoSortCallback(callback); + } successCount++; } catch (Exception e) { log.error("处理WCS栈板RFID扫描对账失败 - rqrq:palletId={}, error={}", @@ -190,49 +194,49 @@ public class WcsTaskScheduler { * 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 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); - } - } + // @Scheduled(cron = "7/10 * * * * ?") + // public void scheduleAutoSortProcessing() { + // // 检查定时任务开关 - rqrq + // if (!enabled) { + // return; + // } + // + // log.info("=== 开始处理WCS自动拣选回调数据 - rqrq ==="); + // + // try { + // // 获取待处理的自动拣选回调记录(只查询拣选站点J1-J4,重试次数<3)- rqrq + // List 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 diff --git a/src/main/resources/mapper/automatedWarehouse/WcsCallbackPalletScanMapper.xml b/src/main/resources/mapper/automatedWarehouse/WcsCallbackPalletScanMapper.xml index fcb91e6..c7b165e 100644 --- a/src/main/resources/mapper/automatedWarehouse/WcsCallbackPalletScanMapper.xml +++ b/src/main/resources/mapper/automatedWarehouse/WcsCallbackPalletScanMapper.xml @@ -13,22 +13,22 @@ WHERE a.site = #{site} AND process_status IN ('PENDING', 'FAILED') AND #{maxRetryCount} >retry_count - AND a.action_type=N'被分拣回传' + ORDER BY created_at - + + + + + +