| | |
|---|
| | | throw new CoolException("原单据清除失败！！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new QueryWrapper<WarehouseAreasItem>() |
|---|
| | | .select("SUM(anfme) as anfme, track_code, asn_code, id, splr_batch, ispt_result, plat_item_id, batch, qty, work_qty, matnr_code, matnr_id, maktx") |
|---|
| | | .lambda() |
|---|
| | | .in(WarehouseAreasItem::getTrackCode, tracks) |
|---|
| | | .groupBy(WarehouseAreasItem::getSplrBatch, |
|---|
| | | WarehouseAreasItem::getTrackCode); |
|---|
| | | List<WarehouseAreasItem> warehouseAreasItems = warehouseAreasItemService.list(queryWrapper); |
|---|
| | | if (Objects.isNull(warehouseAreasItems) || warehouseAreasItems.isEmpty()) { |
|---|
| | | throw new CoolException("物料未送至收货区！！"); |
|---|
| | | } |
|---|
| | | List<WaitPakinItem> items = new ArrayList<>(); |
|---|
| | | for (WarehouseAreasItem item : warehouseAreasItems) { |
|---|
| | | WaitPakinItem pakinItem = new WaitPakinItem(); |
|---|
| | | pakinItem.setAnfme(item.getAnfme()) |
|---|
| | | .setPakinId(waitPakin1.getId()) |
|---|
| | | .setAsnId(item.getAsnId()) |
|---|
| | | .setAsnCode(item.getAsnCode()) |
|---|
| | | .setAsnItemId(item.getId()) |
|---|
| | | .setBatch(item.getSplrBatch()) |
|---|
| | | .setUnit(item.getStockUnit()) |
|---|
| | | .setFieldsIndex(item.getFieldsIndex()) |
|---|
| | | .setMatnrId(item.getMatnrId()) |
|---|
| | | .setMaktx(item.getMaktx()) |
|---|
| | | .setMatnrCode(item.getMatnrCode()); |
|---|
| | | for (PakinItem waitPakinItem : waitPakin.getItems()) { |
|---|
| | | if (waitPakinItem.getTrackCode().equals(item.getTrackCode())) { |
|---|
| | | if (waitPakinItem.getReceiptQty() > item.getAnfme()) { |
|---|
| | | throw new CoolException("组拖数量不能大于收货数量！！"); |
|---|
| | | } |
|---|
| | | pakinItem |
|---|
| | | .setAnfme(waitPakinItem.getReceiptQty()) |
|---|
| | | .setTrackCode(waitPakinItem.getTrackCode()); |
|---|
| | | /**更新单据执行中库存*/ |
|---|
| | | // if (v.compareTo(item.getAnfme()) > 0) {throw new CoolException("执行中数量大于收货数量！！");} |
|---|
| | | // if (!asnOrderItemService.update(new LambdaUpdateWrapper<AsnOrderItem>() |
|---|
| | | // .eq(AsnOrderItem::getTrackCode, waitPakinItem.getTrackCode()).set(AsnOrderItem::getWorkQty, v))) { |
|---|
| | | // throw new CoolException("执行中库存更新失败！！"); |
|---|
| | | // } |
|---|
| | | } |
|---|
| | | if (!Objects.isNull(waitPakin.getType()) && waitPakin.getType().equals("defective")) { |
|---|
| | | List<AsnOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<AsnOrderItem>().in(AsnOrderItem::getTrackCode, tracks)); |
|---|
| | | if (Objects.isNull(orderItems) || orderItems.isEmpty()) { |
|---|
| | | throw new CoolException("单据不存在！！"); |
|---|
| | | } |
|---|
| | | items.add(pakinItem); |
|---|
| | | for (AsnOrderItem item : orderItems) { |
|---|
| | | WaitPakinItem pakinItem = new WaitPakinItem(); |
|---|
| | | pakinItem.setAnfme(item.getAnfme()) |
|---|
| | | .setPakinId(waitPakin1.getId()) |
|---|
| | | .setAsnId(item.getAsnId()) |
|---|
| | | .setAsnCode(item.getAsnCode()) |
|---|
| | | .setAsnItemId(item.getId()) |
|---|
| | | .setBatch(item.getSplrBatch()) |
|---|
| | | .setUnit(item.getStockUnit()) |
|---|
| | | .setFieldsIndex(item.getFieldsIndex()) |
|---|
| | | .setMatnrId(item.getMatnrId()) |
|---|
| | | .setMaktx(item.getMaktx()) |
|---|
| | | .setMatnrCode(item.getMatnrCode()); |
|---|
| | | for (PakinItem waitPakinItem : waitPakin.getItems()) { |
|---|
| | | if (waitPakinItem.getTrackCode().equals(item.getTrackCode())) { |
|---|
| | | if (waitPakinItem.getReceiptQty() > item.getAnfme()) { |
|---|
| | | throw new CoolException("组拖数量不能大于收货数量！！"); |
|---|
| | | } |
|---|
| | | pakinItem.setAnfme(waitPakinItem.getReceiptQty()).setTrackCode(waitPakinItem.getTrackCode()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | items.add(pakinItem); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new QueryWrapper<WarehouseAreasItem>() |
|---|
| | | .select("SUM(anfme) as anfme, track_code, asn_code, id, splr_batch, ispt_result, plat_item_id, batch, qty, work_qty, matnr_code, matnr_id, maktx") |
|---|
| | | .lambda() |
|---|
| | | .in(WarehouseAreasItem::getTrackCode, tracks) |
|---|
| | | .groupBy(WarehouseAreasItem::getSplrBatch, |
|---|
| | | WarehouseAreasItem::getTrackCode); |
|---|
| | | List<WarehouseAreasItem> warehouseAreasItems = warehouseAreasItemService.list(queryWrapper); |
|---|
| | | if (Objects.isNull(warehouseAreasItems) || warehouseAreasItems.isEmpty()) { |
|---|
| | | throw new CoolException("物料未送至收货区！！"); |
|---|
| | | } |
|---|
| | | for (WarehouseAreasItem item : warehouseAreasItems) { |
|---|
| | | WaitPakinItem pakinItem = new WaitPakinItem(); |
|---|
| | | pakinItem.setAnfme(item.getAnfme()) |
|---|
| | | .setPakinId(waitPakin1.getId()) |
|---|
| | | .setAsnId(item.getAsnId()) |
|---|
| | | .setAsnCode(item.getAsnCode()) |
|---|
| | | .setAsnItemId(item.getId()) |
|---|
| | | .setBatch(item.getSplrBatch()) |
|---|
| | | .setUnit(item.getStockUnit()) |
|---|
| | | .setFieldsIndex(item.getFieldsIndex()) |
|---|
| | | .setMatnrId(item.getMatnrId()) |
|---|
| | | .setMaktx(item.getMaktx()) |
|---|
| | | .setMatnrCode(item.getMatnrCode()); |
|---|
| | | for (PakinItem waitPakinItem : waitPakin.getItems()) { |
|---|
| | | if (waitPakinItem.getTrackCode().equals(item.getTrackCode())) { |
|---|
| | | if (waitPakinItem.getReceiptQty() > item.getAnfme()) { |
|---|
| | | throw new CoolException("组拖数量不能大于收货数量！！"); |
|---|
| | | } |
|---|
| | | pakinItem.setAnfme(waitPakinItem.getReceiptQty()).setTrackCode(waitPakinItem.getTrackCode()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | items.add(pakinItem); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | double sum1 = items.stream().mapToDouble(WaitPakinItem::getAnfme).sum(); |
|---|
| | | if (!waitPakinItemService.saveBatch(items)) { |
|---|
