no message

skyouc

2025-07-09 039ea2a8d16e84f524e65ec47f9352b3ef625940

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

@@ -65,7 +65,7 @@
    @Scheduled(cron = "0/30 * * * * ? ")

    @Transactional(rollbackFor = Exception.class)

    public void addWaveHistories() {

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

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

        if (tasks.isEmpty()) {

            return;

        }

@@ -143,7 +143,10 @@
                        continue;

                    }

                    // 过滤已经生成波次播种数据的任务  该任务的任务明细号不能在播种数据表里面

                    long count = waveSeedService.count(new LambdaQueryWrapper<WaveSeed>().in(WaveSeed::getTaskDetlId, taskDetls.stream().map(TaskDetl::getId).collect(Collectors.toList())).eq(WaveSeed::getHostId, hostId));

                    long count = waveSeedService.count(new LambdaQueryWrapper<WaveSeed>()

                            .in(WaveSeed::getTaskDetlId, taskDetls.stream()

                                    .map(TaskDetl::getId).collect(Collectors.toList()))

                            .eq(WaveSeed::getHostId, hostId));

                    if (count > 0) {

                        continue;

                    }

@@ -210,7 +213,7 @@
                            waveSeed.setWaveId(taskDetl.getWaveId()).setWaveNo(taskDetl.getWaveNo());

                            waveSeed.setTaskDetlId(taskDetl.getId());

                            //为满足当前需求，经确认，改成订单数量

                            waveSeed.setAnfme(orderDetl.getAnfme());

                            waveSeed.setAnfme(taskDetl.getAnfme());

                            waveSeed.setWorkQty(0D);

                            waveSeed.setMatnr(taskDetl.getMatnr());

                            waveSeed.setBatch(taskDetl.getBatch());