| | |
|---|
| | | if (success.compareAndSet(false, true)) { |
|---|
| | | Long loginUserId = SystemAuthUtils.getLoginUserId(); |
|---|
| | | for (Task task : tasks) { |
|---|
| | | if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)) { |
|---|
| | | //1.入库 |
|---|
| | | if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type) || task.getTaskType().equals(TaskType.TASK_TYPE_MERGE_IN.type)) { |
|---|
| | | //1.入库、54.并板再入库 |
|---|
| | | complateInstock(task, loginUserId); |
|---|
| | | } else if (task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type) || task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)) { |
|---|
| | | //53.拣料再入库 |
|---|
| | | //57.盘点再入库 |
|---|
| | | //53.拣料再入库、57.盘点再入库 |
|---|
| | | pickComplateInStock(task, loginUserId); |
|---|
| | | } else if (task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type)) { |
|---|
| | | //移库 |
|---|
| | | //11.库格移载 |
|---|
| | | moveInStock(task, loginUserId); |
|---|
| | | } else if (task.getTaskType().equals(TaskType.TASK_TYPE_EMPITY_IN.type)) { |
|---|
| | | //10.空板入库：与普通入库共用一个完成逻辑（若有组托则更新组托/库位并上报云仓） |
|---|
| | | complateInstock(task, loginUserId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | .set(Task::getTaskStatus, TaskStsType.UPDATED_IN.id))) { |
|---|
| | | throw new CoolException("任务状态修改失败！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 9.1 入/出库结果上报：库格移载完成后通知云仓（与定时任务闭环一致） |
|---|
| | | List<TaskItem> moveTaskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId())); |
|---|
| | | if (!moveTaskItems.isEmpty()) { |
|---|
| | | reportInOutResultToCloud(task, loc, moveTaskItems, null, true); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | if (!taskService.updateById(task)) { |
|---|
| | | throw new CoolException("任务状态修改失败！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 9.1 入/出库结果上报：拣料再入库/盘点再入库完成后通知云仓（与定时任务闭环一致） |
|---|
| | | reportInOutResultToCloud(task, loc, taskItems, null, true); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | if (Objects.isNull(waveItem)) { |
|---|
| | | throw new CoolException("波次明细不存在！！"); |
|---|
| | | } |
|---|
| | | // try { |
|---|
| | | // saveOutStockItem(maps.get(key), null, waveItem, null, loginUserId); |
|---|
| | | // } catch (Exception e) { |
|---|
| | | // throw new CoolException(e.getMessage()); |
|---|
| | | // } |
|---|
| | | try { |
|---|
| | | saveOutStockItem(maps.get(key), null, waveItem, null, loginUserId); |
|---|
| | | } catch (Exception e) { |
|---|
| | | throw new CoolException(e.getMessage()); |
|---|
| | | } |
|---|
| | | } else if (task.getResource().equals(TaskResouceType.TASK_RESOUCE_ORDER_TYPE.val)) { |
|---|
| | | WkOrderItem orderItem = asnOrderItemService.getById(key); |
|---|
| | | if (Objects.isNull(orderItem)) { |
|---|
| | |
|---|
| | | .setUpdateTime(new Date()) |
|---|
| | | .setAnfme(sum); |
|---|
| | | if (!Objects.isNull(waveItem)) { |
|---|
| | | //TODO 生成波次时需要将波次号写入单据，通过物料，批次，动态字段等唯一值反查单据信息 |
|---|
| | | // 波次出库：更新出库单完成数量及出库单明细执行数量 |
|---|
| | | stock.setSourceId(waveItem.getId()).setType(OrderType.ORDER_OUT.type); |
|---|
| | | Long orderId = waveItem.getOrderId(); |
|---|
| | | if (orderId != null) { |
|---|
| | | WkOrder wkOrder = asnOrderService.getById(orderId); |
|---|
| | | if (wkOrder != null) { |
|---|
| | | Double curQty = wkOrder.getQty() != null ? wkOrder.getQty() : 0.0; |
|---|
| | | Double newQty = QuantityUtils.roundToScale(curQty + sum); |
|---|
| | | wkOrder.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_WORKING.val).setQty(newQty); |
|---|
| | | if (!asnOrderService.updateById(wkOrder)) { |
|---|
| | | throw new CoolException("出库单完成数量更新失败！！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // 按出库单明细汇总本次任务数量，更新各明细 workQty |
|---|
| | | Map<Long, Double> sumByOrderItemId = taskItems.stream() |
|---|
| | | .filter(ti -> ti.getOrderItemId() != null) |
|---|
| | | .collect(Collectors.groupingBy(TaskItem::getOrderItemId, |
|---|
| | | Collectors.summingDouble(ti -> ti.getAnfme() != null ? ti.getAnfme() : 0.0))); |
|---|
| | | for (Map.Entry<Long, Double> e : sumByOrderItemId.entrySet()) { |
|---|
| | | WkOrderItem oi = outStockItemService.getById(e.getKey()); |
|---|
| | | if (oi != null) { |
|---|
| | | Double wq = oi.getWorkQty() != null ? oi.getWorkQty() : 0.0; |
|---|
| | | oi.setWorkQty(QuantityUtils.roundToScale(wq + e.getValue())); |
|---|
| | | if (!outStockItemService.updateById(oi)) { |
|---|
| | | throw new CoolException("出库单明细执行数量更新失败！！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else if (!Objects.isNull(orderItem) && StringUtils.isNotBlank(orderItem.getId() + "")) { |
|---|
| | | WkOrder wkOrder = asnOrderService.getById(orderItem.getOrderId()); |
|---|
| | | Double qty = Math.round((wkOrder.getQty() + sum) * 1000000) / 1000000.0; |
|---|
| | |
|---|
| | | List<TaskItem> items = orderMap.get(key); |
|---|
| | | //保存入出库明细 |
|---|
| | | saveStockItems(items, task, pakinItem.getId(), pakinItem.getAsnCode(), pakinItem.getWkType(), pakinItem.getType(), loginUserId); |
|---|
| | | //移出收货区库存， 修改组托状态（只有当source不为null时才需要移除收货区库存） |
|---|
| | | // DirectWaitPakin 启用时组托来自收货区，入库完成后移出收货区库存；未启用时 source 为 null 不执行 |
|---|
| | | if (Objects.nonNull(pakinItem.getSource())) { |
|---|
| | | removeReceiptStock(pakinItem, loginUserId); |
|---|
| | | } |
|---|
| | |
|---|
| | | Date now = new Date(); |
|---|
| | | for (TaskItem item : taskItems) { |
|---|
| | | String orderNo = isInbound ? sourceToOrderNo.get(item.getSource()) : (item.getPlatOrderCode() != null ? item.getPlatOrderCode() : item.getPlatWorkCode()); |
|---|
| | | if (orderNo == null && isInbound) { |
|---|
| | | orderNo = item.getPlatOrderCode() != null ? item.getPlatOrderCode() : item.getPlatWorkCode(); |
|---|
| | | } |
|---|
| | | if (orderNo == null || item.getMatnrCode() == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
