#容器到达后流程修改

skyouc

2025-01-02 43fb93554a1b530bd3ade363adc0a3aad7b1daf5

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

@@ -45,6 +45,11 @@
    @Autowired

    private DictService dictService;



    /**

     * modifty：

     * original : fetch datasource of task type on WAVE_SEED

     * now: Fetch datasource of task type  on WCS_EXECUTE_OUT_ARRIVED, After completing the task and for setting  the task type equal to WAVE_SEED

     */

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

    @Transactional(rollbackFor = Exception.class)

    public void taskWave() {

@@ -58,8 +63,9 @@
            if (!autoCreateWaveSeed.equals("true")) {

                return;

            }



            List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id));

            //查询状态为容器到达状态所有任务单据

//            List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id));

            List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT_ARRIVED.id));

            if (taskList.isEmpty()) {

//                throw new CoolException("没有可播种任务！！");

            } else {

@@ -121,7 +127,8 @@
                            waveSeed.setOrderDetlId(orderDetl.getId());

                            waveSeed.setWaveId(taskDetl.getWaveId()).setWaveNo(taskDetl.getWaveNo());

                            waveSeed.setTaskDetlId(taskDetl.getId());

                            waveSeed.setAnfme(taskDetl.getAnfme());

                            //fixme 确认是否使用订单明细数量

                            waveSeed.setAnfme(orderDetl.getAnfme());

                            waveSeed.setWorkQty(0D);

                            waveSeed.setMatnr(taskDetl.getMatnr());

                            waveSeed.setBatch(taskDetl.getBatch());

@@ -143,7 +150,7 @@


                    }



                    task.setTaskSts(TaskStsType.COMPLETE_OUT.id);

                    task.setTaskSts(TaskStsType.WAVE_SEED.id);

                    task.setUpdateTime(new Date());

                    if (!taskService.updateById(task)) {

                        throw new CoolException("任务更新失败");