| | |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public synchronized R wavePickItems(WavePickItemsParams params) { |
| | | if (Objects.isNull(params.getBarcode())) { |
| | | return R.error("托盘码不能为空!!"); |
| | | return R.error("料箱码不能为空!!"); |
| | | } |
| | | if (Objects.isNull(params.getOrderId())) { |
| | | return R.error("订单ID不能为空!!"); |
| | |
| | | .orderByDesc(Task::getId) |
| | | .last("limit 1")); |
| | | if (null == task) { |
| | | return R.error("未找到托盘对应的任务"); |
| | | return R.error("未找到料箱对应的任务"); |
| | | } |
| | | if (!task.getTaskStatus().equals(TaskStsType.WAVE_SEED.id)) { |
| | | return R.error("任务状态不是揀料狀態"); |
| | |
| | | .in(Task::getTaskType, integers) |
| | | .eq(Task::getBarcode, params.get("barcode")), false); |
| | | if (Objects.isNull(task)) { |
| | | return R.error("托盘所在任务不存在!!"); |
| | | return R.error("料箱所在任务不存在!!"); |
| | | } |
| | | List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId())); |
| | | taskItems.forEach(taskItem -> { |
| | |
| | | .orderByDesc(Task::getId) |
| | | .last("limit 1")); |
| | | if (null == task) { |
| | | return R.error("未找到托盘对应的任务"); |
| | | return R.error("未找到料箱对应的任务"); |
| | | } |
| | | if (!task.getTaskStatus().equals(TaskStsType.WAVE_SEED.id)) { |
| | | return R.error("任务状态不是待揀狀態"); |