From 9cf47e2bc4667097f46600328f3dcc6218a9b0ca Mon Sep 17 00:00:00 2001 From: skyouc Date: 星期三, 30 七月 2025 17:02:40 +0800 Subject: [PATCH] 调拔单功能优化 --- rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java | 47 +++++++++++++++++++++++++++++------------------ 1 files changed, 29 insertions(+), 18 deletions(-) diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java index 3a06b70..c8b78f0 100644 --- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java +++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java @@ -91,13 +91,10 @@ private FieldsMapper fieldsMapper; @Autowired private IsptHistoriesMapper isptHistoriesMapper; - @Autowired private AsnOrderLogService asnOrderLogService; - @Autowired private WaitPakinService waitPakinService; - @Autowired private WaitPakinItemService waitPakinItemService; @Autowired @@ -128,6 +125,8 @@ private ConfigService configService; @Autowired private CompanysService companysService; + @Autowired + private OutStockService outStockService; /** * @return @@ -233,19 +232,31 @@ WkOrder wkOrder = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>() .eq(WkOrder::getCode, asnCode)); + + //鍒ゆ柇璋冩嫈鍗曞嚭搴撴槸鍚﹀畬鎴� + if (wkOrder.getWkType().equals(OrderWorkType.ORDER_WORK_TYPE_OTHER_TERANSFER.type)) { + WkOrder one = outStockService.getOne(new LambdaQueryWrapper<WkOrder>() + .eq(WkOrder::getPoId, wkOrder.getPoId()) + .eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_STOCK_TERANSFER.type) + .eq(WkOrder::getType, OrderType.ORDER_OUT.type)); + if (Objects.isNull(one)) { + throw new CoolException("鏁版嵁閿欒锛侊紒"); + } + if (!one.getExceStatus().equals(AsnExceStatus.OUT_STOCK_STATUS_TASK_DONE.val)) { + throw new CoolException("璋冩嫈鍑哄簱鍗曟湭瀹屾垚锛屼笉鍙墽琛屾敹璐ф搷浣滐紒锛�"); + } + } + if (Objects.isNull(wkOrder)) { throw new CoolException("鏁版嵁閿欒锛氫富鍗曚笉瀛樺湪锛侊紒"); } //TODO /**鏀惰揣鏁伴噺绱姞锛�1. 浼氬嚭瓒呮敹鎯呭喌 2. 浼氭湁鏀惰揣涓嶈冻鎯呭喌*/ Double rcptedQty = Math.round((wkOrder.getQty() + receiptQty) * 10000) / 10000.0; - wkOrder.setQty(rcptedQty).setExceStatus(AsnExceStatus.ASN_EXCE_STATUS_EXCE_ING.val); if (!asnOrderMapper.updateById(wkOrder)) { throw new CoolException("宸叉敹璐ф暟閲忎慨鏀瑰け璐ワ紒锛�"); } - Config config = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ALLOW_OVER_CHANGE)); - List<Map<String, Object>> receipts1 = (List<Map<String, Object>>) params.get("receipts"); for (Map<String, Object> rcpt : receipts1) { @@ -352,7 +363,7 @@ Companys companys = new Companys(); if (StringUtils.isNoneBlank(orderItem.getSplrCode())) { - companys = companysService.getOne(new LambdaQueryWrapper<Companys>().eq(Companys::getCode, orderItem.getSplrCode())); + companys = companysService.getOne(new LambdaQueryWrapper<Companys>().eq(Companys::getCode, orderItem.getSplrCode())); } WarehouseAreasItem item = new WarehouseAreasItem(); @@ -453,7 +464,7 @@ } List<WkOrderItem> wkOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<WkOrderItem>() - .eq(WkOrderItem::getAsnCode, params.getAsnCode()) + .eq(WkOrderItem::getOrderCode, params.getAsnCode()) .eq(!Objects.isNull(params.getTrackCode()), WkOrderItem::getTrackCode, params.getTrackCode()) .eq(!Cools.isEmpty(params.getMatnrCode()), WkOrderItem::getMatnrCode, params.getMatnrCode()) ); @@ -578,7 +589,7 @@ } InspectDetlDto detlDto = new InspectDetlDto(); detlDto.setCode(wkOrders.getCode()).setId(wkOrders.getId()).setPoCode(wkOrders.getPoCode()); - List<WkOrderItem> orderItems = asnOrderItemMapper.selectList(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getAsnCode, code)); + List<WkOrderItem> orderItems = asnOrderItemMapper.selectList(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderCode, code)); if (orderItems.isEmpty()) { detlDto.setItems(new ArrayList<>()); } else { @@ -711,13 +722,13 @@ } WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>() .eq(WaitPakin::getBarcode, params.getBarcode()) - .eq(WaitPakin::getIoStatus,PakinIOStatus.PAKIN_IO_STATUS_DONE.val) + .eq(WaitPakin::getIoStatus, PakinIOStatus.PAKIN_IO_STATUS_DONE.val) ); - if (Cools.isEmpty(waitPakin)){ + if (Cools.isEmpty(waitPakin)) { throw new CoolException("鏈壘鍒扮粍鎵樻暟鎹�,璇锋鏌ョ姸鎬�"); } List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, waitPakin.getId())); - if (Cools.isEmpty(waitPakinItems)){ + if (Cools.isEmpty(waitPakinItems)) { throw new CoolException("鏁版嵁閿欒锛屾湭鎵惧埌缁勬墭鏄庣粏"); } @@ -741,11 +752,11 @@ if (Objects.isNull(params.getItemList()) || params.getItemList().isEmpty()) { throw new CoolException("鍗曟嵁鏄庣粏涓嶈兘涓虹┖锛侊紒"); } - Long OrderId = params.getItemList().stream().findFirst().get().getAsnId(); + Long OrderId = params.getItemList().stream().findFirst().get().getOrderId(); /**鑾峰彇骞冲簱璁㈠崟*/ WkOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<WkOrder>() .eq(WkOrder::getId, OrderId) - .eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type) + .eq(WkOrder::getWkType, OrderWorkType.ORDER_WORK_TYPE_OTHER_IN.type) .eq(WkOrder::getType, OrderType.ORDER_IN.type)); if (Objects.isNull(order)) { throw new CoolException("闈炲钩搴撳崟鎹笉鍙墽琛屼汉宸ヤ笂鏋讹紒锛�"); @@ -937,15 +948,15 @@ */ @Override public R getUnItemByContainer(Map<String, Object> params) { - if (Cools.isEmpty(params.get("barcode")) && Cools.isEmpty(params.get("code"))){ + if (Cools.isEmpty(params.get("barcode")) && Cools.isEmpty(params.get("code"))) { throw new CoolException("瀹瑰櫒鍙蜂笌缁勬墭妗g紪鐮佷笉鑳藉叏涓虹┖"); } //鑾峰彇缁勬嫋鏈敓鎴愪换鍔$殑缁勬嫋妗� // List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val), Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val)); WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>() - .eq(!Cools.isEmpty(params.get("barcode")),WaitPakin::getBarcode, params.get("barcode")) - .eq(!Cools.isEmpty(params.get("code")),WaitPakin::getCode, params.get("code")) + .eq(!Cools.isEmpty(params.get("barcode")), WaitPakin::getBarcode, params.get("barcode")) + .eq(!Cools.isEmpty(params.get("code")), WaitPakin::getCode, params.get("code")) .eq(WaitPakin::getIoStatus, PakinIOStatus.PAKIN_IO_STATUS_DONE.val)); if (Objects.isNull(waitPakin)) { return R.error("鏈壘鍒拌瀹瑰櫒鐮佺殑缁勬墭鏄庣粏锛岃妫�鏌ョ粍鎵樼姸鎬�"); @@ -1055,7 +1066,7 @@ items.forEach(asnOrderItem -> { ReceiptDetlsDto detlsDto = new ReceiptDetlsDto(); - detlsDto.setAsnCode(asnOrderItem.getAsnCode()) + detlsDto.setAsnCode(asnOrderItem.getOrderCode()) .setId(asnOrderItem.getId()) .setMaktx(asnOrderItem.getMaktx()) .setFieldsIndex(asnOrderItem.getFieldsIndex()) -- Gitblit v1.9.1