| | |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Objects; |
| | | import java.util.stream.Collectors; |
| | | |
| | | @Slf4j |
| | | @RestController |
| | |
| | | throw new CoolException("当前站点不存在!!"); |
| | | } |
| | | |
| | | WaveSeed waveSeed = waveSeedService.getOne(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getSiteNo, request.get("tagCode").toString())); |
| | | WaveSeed waveSeed = waveSeedService.getOne(new LambdaQueryWrapper<WaveSeed>() |
| | | .eq(WaveSeed::getExceStatus, 1) |
| | | .eq(WaveSeed::getSiteNo, request.get("tagCode").toString())); |
| | | if (Objects.isNull(waveSeed)) { |
| | | throw new CoolException("播种墙地标未绑定!!"); |
| | | } |
| | | |
| | | // 根据播种站点信息条码,查任务 |
| | | Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getId, waveSeed.getTaskId())); |
| | | if (Objects.isNull(task)) { |
| | |
| | | Map<String, Object> param = new HashMap<>(); |
| | | param.put("taskNo", task.getTaskNo()); |
| | | param.put("siteNo", cacheSite.getSiteNo()); |
| | | param.put("weedId", waveSeed.getId()); |
| | | param.put("orderNo",cacheSite.getOrderNo()); |
| | | |
| | | waveSeed.setExceStatus(0); |
| | | if (!waveSeedService.updateById(waveSeed)) { |
| | | throw new CoolException("播种状态修改失败!!"); |
| | | } |
| | | |
| | | return wcsApiService.slapLightLogic(param); |
| | | } |
| | | |