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