From bc25523bd723e92e85f3463edca27f0fe18a7a71 Mon Sep 17 00:00:00 2001
From: DESKTOP-LMJ82IJ\Eno <creaycat@gmail.com>
Date: 星期日, 13 四月 2025 16:49:19 +0800
Subject: [PATCH] #修改 收货单据界面优化修改

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |  126 ++++++++++++++++++++++++++++++++----------
 1 files changed, 96 insertions(+), 30 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 590b03a..c8cd598 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
@@ -22,6 +22,7 @@
 import com.vincent.rsf.server.manager.controller.params.WaitPakinParam;
 import com.vincent.rsf.server.manager.entity.*;
 import com.vincent.rsf.server.manager.enums.AsnExceStatus;
+import com.vincent.rsf.server.manager.enums.PakinIOStatus;
 import com.vincent.rsf.server.manager.mapper.*;
 import com.vincent.rsf.server.manager.service.*;
 import com.vincent.rsf.server.system.constant.CodeRes;
@@ -37,6 +38,7 @@
 import com.vincent.rsf.server.system.service.UserService;
 import com.vincent.rsf.server.system.utils.ExtendFieldsUtils;
 import com.vincent.rsf.server.system.utils.SerialRuleUtils;
+import net.sf.jsqlparser.statement.select.Wait;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -211,6 +213,10 @@
 
         Double receiptQty = receipts.stream().mapToDouble(ReceiptDetlsDto::getReceiptQty).sum();
 
+        if (Objects.isNull(receiptQty) || receiptQty.compareTo(0.00) <= 0) {
+            throw new CoolException("鏀惰揣鏁伴噺涓嶈兘灏忎簬鎴栫瓑浜庨浂锛侊紒");
+        }
+
         String asnCode = receipts.stream().findFirst().get().getAsnCode();
 
         AsnOrder asnOrder = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>()
@@ -246,7 +252,7 @@
                 throw new CoolException("閫氱煡鍗曟槑缁嗕笉瀛樺湪锛侊紒");
             }
             if (Objects.isNull(dto.getReceiptQty()) || Double.compare(dto.getReceiptQty(), 0.0) == 0) {
-                throw new CoolException("鏀惰揣鏁伴噺涓嶈兘涓洪浂锛侊紒");
+                throw new CoolException("鐗╂枡:" + dto.getMaktx() +  "鏀惰揣鏁伴噺涓嶈兘涓洪浂锛侊紒");
             }
             Double itemRcptQty = dto.getReceiptQty() + orderItem.getQty();
             orderItem.setQty(itemRcptQty)
@@ -289,7 +295,7 @@
                     .setWeight(dto.getWeigth())
                     .setStockUnit(dto.getStockUnit())
                     .setBatch(SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto))
-                    .setAnfme(itemRcptQty)
+                    .setAnfme(dto.getReceiptQty())
                     .setSplrBatch(dto.getSplrBatch())
                     .setMatnrCode(matnr.getCode())
                     .setMatnrId(matnr.getId())
@@ -495,36 +501,36 @@
         if (Objects.isNull(params.getIsptCode())) {
             throw new CoolException("璐ㄦ鍗曚笉鑳戒负绌�");
         }
-        if (Objects.isNull(params.getMatnrCode())) {
-            throw new CoolException("鐗╂枡缂栫爜涓嶈兘涓虹┖锛�");
-        }
         QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>().eq(QlyInspect::getCode, params.getIsptCode()));
         if (Objects.isNull(inspect)) {
             throw new CoolException("璐ㄦ鍗曟嵁涓嶅瓨鍦紒!");
         }
-        QlyIsptItem isptItem = qlyIsptItemService.getOne(new LambdaQueryWrapper<QlyIsptItem>()
-                .eq(QlyIsptItem::getMatnrCode, params.getMatnrCode())
+        List<QlyIsptItem> isptItems = qlyIsptItemService.list(new LambdaQueryWrapper<QlyIsptItem>()
+                .eq(StringUtils.isNotBlank(params.getMatnrCode()), QlyIsptItem::getMatnrCode, StringUtils.isNotBlank(params.getMatnrCode()) ? params.getMatnrCode() : null)
                 .eq(QlyIsptItem::getIspectId, inspect.getId()));
-        if (Objects.isNull(isptItem)) {
+        if (Objects.isNull(isptItems)) {
             throw new CoolException("璐ㄦ鍗曟槑缁嗕笉瀛樺湪锛侊紒");
         }
-
-        CheckObjDto objDto = new CheckObjDto();
-        objDto.setIsptCode(inspect.getCode())
-                .setAsnCode(inspect.getAsnCode())
-                .setId(isptItem.getId())
-                .setMatnrCode(isptItem.getMatnrCode())
-                .setMaktx(isptItem.getMaktx())
-                .setDisQty(isptItem.getDisQty())
-                .setDlyQty(isptItem.getDlyQty())
-                .setRcptQty(isptItem.getRcptQty())
-                .setIsptResult(isptItem.getIsptResult())
-                .setSplrBatch(isptItem.getSplrBatch())
-                .setSplrName(isptItem.getSplrName())
-                .setPicPath(isptItem.getPicPath())
-                .setMemo(isptItem.getMemo())
-                .setSafeQty(isptItem.getSafeQty());
-        return R.ok(objDto);
+        List<CheckObjDto> dtos = new ArrayList<>();
+        isptItems.forEach(isptItem -> {
+            CheckObjDto objDto = new CheckObjDto();
+            objDto.setIsptCode(inspect.getCode())
+                    .setAsnCode(inspect.getAsnCode())
+                    .setId(isptItem.getId())
+                    .setMatnrCode(isptItem.getMatnrCode())
+                    .setMaktx(isptItem.getMaktx())
+                    .setDisQty(isptItem.getDisQty())
+                    .setDlyQty(isptItem.getDlyQty())
+                    .setRcptQty(isptItem.getRcptQty())
+                    .setIsptResult(isptItem.getIsptResult())
+                    .setSplrBatch(isptItem.getSplrBatch())
+                    .setSplrName(isptItem.getSplrName())
+                    .setPicPath(isptItem.getPicPath())
+                    .setMemo(isptItem.getMemo())
+                    .setSafeQty(isptItem.getSafeQty());
+            dtos.add(objDto);
+        });
+        return R.ok(dtos);
     }
 
     /**
@@ -533,14 +539,12 @@
      * @return
      */
     @Override
-    public R checkUpdate(QlyIsptItem params) {
-        if (Objects.isNull(params.getId())) {
+    public R checkUpdate(List<QlyIsptItem> params) {
+        if (Objects.isNull(params) || params.isEmpty()) {
             throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
         }
         IsptItemsParams itemsParams = new IsptItemsParams();
-        List<QlyIsptItem> items = new ArrayList<>();
-        items.add(params);
-        itemsParams.setIsptItem(items).setType("0");
+        itemsParams.setIsptItem(params).setType("0");
         if (qlyIsptItemService.batchUpdate(itemsParams)) {
             return R.ok();
         } else {
@@ -730,6 +734,68 @@
     }
 
     /**
+     * @author Ryan
+     * @description 閫氳繃瀹瑰櫒鑾峰彇缁勬嫋鐗╂枡
+     * @param
+     * @return
+     * @time 2025/4/9 16:57
+     */
+    @Override
+    public R getItemByContainer(Map<String, Object> params) {
+        //鑾峰彇缁勬嫋鏈敓鎴愪换鍔$殑缁勬嫋妗�
+        List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val), Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
+        Short flagDefect = 0;
+        if (!Objects.isNull(params.get("type")) && params.get("type").equals("defective")) {
+            flagDefect = 1;
+        }
+        WaitPakin waitPakin = waitPakinService.getOne(new LambdaQueryWrapper<WaitPakin>()
+                .eq(WaitPakin::getBarcode, params.get("barcode").toString())
+                        .eq(WaitPakin::getFlagDefect, flagDefect)
+                .in(WaitPakin::getIoStatus, asList));
+        if (Objects.isNull(waitPakin)) {
+            return R.ok(new ArrayList<>());
+        }
+        List<WaitPakinItem> pakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>()
+                .eq(WaitPakinItem::getPakinId, waitPakin.getId()));
+        if (pakinItems.isEmpty()) {
+            return R.ok(new ArrayList<>());
+        }
+        if (!Objects.isNull(params.get("type")) && params.get("type").equals("defective")) {
+            return R.ok(pakinItems);
+        } else {
+            List<String> list = pakinItems.stream().map(WaitPakinItem::getTrackCode).collect(Collectors.toList());
+            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, list)
+                    .groupBy(WarehouseAreasItem::getSplrBatch,
+                            WarehouseAreasItem::getTrackCode);
+            List<WarehouseAreasItem> warehouseAreasItems = warehouseAreasItemService.list(queryWrapper);
+            for (int i = 0; i < warehouseAreasItems.size(); i++) {
+                for (WaitPakinItem pakinItem : pakinItems) {
+                    if (warehouseAreasItems.get(i).getTrackCode().equals(pakinItem.getTrackCode())) {
+                        warehouseAreasItems.get(i).setAnfme(pakinItem.getAnfme());
+                    }
+                }
+            }
+            return R.ok(warehouseAreasItems);
+        }
+    }
+
+    /**
+     * @author Ryan
+     * @description 涓嶈壇鏍囩
+     * @param
+     * @return
+     * @time 2025/4/12 08:12
+     */
+    @Override
+    public R defectProducts(String trackCode) {
+        AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getTrackCode, trackCode));
+        return R.ok(orderItem);
+    }
+
+    /**
      * 鑾峰彇ReceiptDetlsDtos
      */
     private R getAsnOrderItem(List<AsnOrderItem> items) {

--
Gitblit v1.9.1