出库优先先进先出

skyouc

2025-07-03 9219e85f544780fa955945fc6c0c63e08d862ce3

 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskLogTimer.java

@@ -48,6 +48,13 @@
    @Autowired

    private WaveService waveService;





    /**

     * @author Ryan

     * @date 2025/6/20

     * @description: 入库任务已完成

     * @version 1.0

     */

    @Scheduled(cron = "0/15 * * * * ? ")

    @Transactional(rollbackFor = Exception.class)

    public void inExecute() {

@@ -116,6 +123,7 @@
                for (TaskDetl taskDetl : taskDetls) {

                    TaskDetlLog taskDetlLog = new TaskDetlLog();

                    taskDetlLog.sync(taskDetl);

                    taskDetlLog.setOrderId(taskDetl.getOrderId());

                    taskDetlLog.setId(null);

                    taskDetlLog.setTaskId(taskLog.getId());

                    if (!taskDetlLogService.save(taskDetlLog)) {

@@ -158,7 +166,14 @@
        }

    }



    @Scheduled(cron = "0/10 * * * * ? ")



    /**

     * @author Ryan

     * @date 2025/6/20

     * @description: 出库任务完成

     * @version 1.0

     */

    @Scheduled(cron = "0/35 * * * * ? ")

    @Transactional(rollbackFor = Exception.class)

    public void outExecute() {

        InterceptorIgnoreHelper.handle(IgnoreStrategy.builder().tenantLine(true).build());

@@ -171,43 +186,27 @@
                return;

            }



//            Dict dict = dictService.getOne(new LambdaQueryWrapper<Dict>().eq(Dict::getFlag, "taskLogDiffDays").eq(Dict::getStatus, 1));

//            if (dict == null) {

//                return;

//            }

            for (Task task : list) {

//                int diff = DateUtils.diff(task.getCreateTime(), new Date());

//                int taskLogDiffDays = Integer.parseInt(dict.getValue());

//                if (diff < taskLogDiffDays) {

//                    continue;

//                }



                Long hostId = task.getHostId();



                //保存任务明细历史档

                List<TaskDetl> taskDetls = taskDetlService.getTaskDetlByTaskId(task.getId());

                if (taskDetls.isEmpty()) {

                    throw new CoolException("任务明细不存在");

                }



                boolean flag = false;

                for (TaskDetl taskDetl : taskDetls) {

                    if (taskDetl.getWaveId() == null) {

                        continue;

                    }



                    Wave wave = waveService.getById(taskDetl.getWaveId());

                    if (wave != null) {

                        flag = true;//波次未完成

                        break;

                    }

                }



                if (flag) {

                    continue;

                }





                //保存任务历史档

                TaskLog taskLog = new TaskLog();

                taskLog.sync(task);