播种流程优化

skyouc

2025-07-09 875a183c5d5a12a4ba5c8d37559295ac1ce6cce3

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

@@ -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;

                    }

@@ -207,10 +210,12 @@
                            waveSeed.setOrderNo(orderDetl.getOrderNo());

                            waveSeed.setOrderId(orderDetl.getOrderId());

                            waveSeed.setOrderDetlId(orderDetl.getId());

                            waveSeed.setTaskId(taskDetl.getTaskId());

                            waveSeed.setTaskNo(taskDetl.getTaskNo());

                            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());