| | |
| | | } else if (task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_OUT.type)) { |
| | | List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().in(TaskItem::getTaskId, Arrays.asList(ids))); |
| | | if (!taskItems.isEmpty()) { |
| | | taskItems.forEach(taskItem -> { |
| | | checkDiffItemService.remove(new LambdaQueryWrapper<CheckDiffItem>().eq(CheckDiffItem::getTaskItemId, taskItem.getId())); |
| | | |
| | | checkDiffService.removeById(taskItem.getSourceId()); |
| | | taskItems.forEach(taskItem -> { |
| | | if (!checkOrderItemService.update(new LambdaUpdateWrapper<WkOrderItem>() |
| | | .eq(WkOrderItem::getId, taskItem.getOrderItemId()) |
| | | .setSql("work_qty = work_qty - " + taskItem.getAnfme()))) { |
| | | throw new CoolException("明细数量修改失败!!"); |
| | | } |
| | | |
| | | if (!checkOrderService.update(new LambdaUpdateWrapper<WkOrder>() |
| | | .eq(WkOrder::getId, taskItem.getOrderId()) |
| | | .setSql("work_qty = work_qty - " + taskItem.getAnfme()))) { |
| | | throw new CoolException("盘点单执行数量修改失败!!"); |
| | | } |
| | | |
| | | CheckDiffItem serviceOne = checkDiffItemService.getOne(new LambdaQueryWrapper<CheckDiffItem>().eq(CheckDiffItem::getTaskItemId, taskItem.getId())); |
| | | |
| | | checkDiffItemService.remove(new LambdaQueryWrapper<CheckDiffItem>().eq(CheckDiffItem::getTaskItemId, taskItem.getId())); |
| | | if (!Objects.isNull(serviceOne)) { |
| | | CheckDiff checkDiff = checkDiffService.getById(serviceOne.getCheckId()); |
| | | if (!Objects.isNull(checkDiff)) { |
| | | checkDiffService.removeById(checkDiff.getId()); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | |