From 32d0aa7ac0034561d3b8b5a9d35a54ba1cace6a6 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期二, 06 五月 2025 17:00:08 +0800
Subject: [PATCH] #pda物料组托

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |  153 +++++++++++++++++++++++++++++++-------------------
 1 files changed, 95 insertions(+), 58 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 537556c..3edd8e4 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
@@ -23,6 +23,7 @@
 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.enums.QlyIsptResult;
 import com.vincent.rsf.server.manager.enums.QlyIsptStatus;
 import com.vincent.rsf.server.manager.mapper.*;
 import com.vincent.rsf.server.manager.service.*;
@@ -254,10 +255,14 @@
 //            if (dto.getReceiptQty().compareTo(dto.getAnfme()) > 0) {
 //                throw new CoolException("鏀惰揣鏁伴噺涓嶈兘澶т簬閲囪喘鏁伴噺锛侊紒");
 //            }
-            AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>()
-                    .eq(AsnOrderItem::getAsnCode, asnCode)
-                    .eq(AsnOrderItem::getTrackCode, dto.getBarcode())
-                    .eq(AsnOrderItem::getMatnrId, dto.getMatnrId()));
+//            AsnOrderItem orderItem = asnOrderItemMapper.selectOne(new LambdaQueryWrapper<AsnOrderItem>()
+//                    .eq(AsnOrderItem::getAsnCode, asnCode)
+//                    .eq(AsnOrderItem::getId, dto.getId())
+//                    .eq(AsnOrderItem::getTrackCode, dto.getBarcode())
+//                    .eq(AsnOrderItem::getSplrBatch, dto.getSplrBatch()));
+
+            AsnOrderItem orderItem = asnOrderItemMapper.resultById(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getId, dto.getId()));
+
             if (Objects.isNull(orderItem)) {
                 throw new CoolException("閫氱煡鍗曟槑缁嗕笉瀛樺湪锛侊紒");
             }
@@ -289,49 +294,9 @@
             if (asnOrderItemMapper.updateById(orderItem) < 1) {
                 throw new CoolException("閫氱煡鍗曟槑缁嗘暟閲忎慨鏀瑰け璐ワ紒锛�");
             }
+            /**淇濆瓨鏄庣粏鑷虫敹璐у尯**/
+            extracted(loginUserId, dto, areasItem, orderItem, asnOrder, matnr);
 
-            WarehouseAreasItem item = new WarehouseAreasItem();
-//            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-//            String format = null;
-//            if (Objects.isNull(dto.getProdTime())) {
-//                 format = dateFormat.format(dto.getProdTime());
-//            }
-            item.setTrackCode(dto.getBarcode())
-                    .setAreaName(areasItem.getName())
-                    .setAreaId(areasItem.getId())
-                    .setAsnItemId(orderItem.getId())
-                    .setAsnCode(asnOrder.getCode())
-                    .setAsnId(asnOrder.getId())
-                    .setProdTime(dto.getProdTime())
-                    .setWeight(dto.getWeigth())
-                    //搴撳瓨鍗曚綅涓烘渶灏忓崟浣�
-                    .setUnit(orderItem.getStockUnit())
-                    .setStockUnit(orderItem.getStockUnit())
-                    .setBatch(StringUtils.isBlank(orderItem.getBatch()) ? SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto) : orderItem.getBatch())
-                    .setAnfme(dto.getReceiptQty())
-                    .setSplrBatch(dto.getSplrBatch())
-                    .setMatnrCode(matnr.getCode())
-                    .setUpdateBy(loginUserId)
-                    .setCreateBy(loginUserId)
-                    .setMatnrId(matnr.getId())
-                    .setMaktx(matnr.getName())
-                    .setWeight(matnr.getWeight())
-                    .setFieldsIndex(orderItem.getFieldsIndex())
-                    .setShipperId(matnr.getShipperId());
-            //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲
-
-            WarehouseAreasItem serviceOne = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>()
-                    .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId())
-                    .eq(WarehouseAreasItem::getTrackCode, item.getTrackCode())
-                    .eq(StringUtils.isNotBlank(item.getSplrBatch()), WarehouseAreasItem::getSplrBatch, item.getSplrBatch()));
-            if (!Objects.isNull(serviceOne)) {
-                item.setAnfme(item.getAnfme() + serviceOne.getAnfme());
-                item.setId(serviceOne.getId());
-            }
-
-            if (!warehouseAreasItemService.saveOrUpdate(item)) {
-                throw new CoolException("鏀惰揣澶辫触锛侊紒");
-            }
         }
 
         AsnOrder order = asnOrderMapper.getOne(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getCode, asnCode));
@@ -343,6 +308,65 @@
         }
 
         return R.ok("鏀惰揣鎴愬姛锛侊紒");
+    }
+
+    private void extracted(Long loginUserId, ReceiptDetlsDto dto, WarehouseAreas areasItem, AsnOrderItem orderItem, AsnOrder asnOrder, Matnr matnr) {
+        WarehouseAreasItem item = new WarehouseAreasItem();
+        item.setTrackCode(dto.getBarcode())
+                .setAreaName(areasItem.getName())
+                .setAreaId(areasItem.getId())
+                .setAsnItemId(orderItem.getId())
+                .setAsnCode(asnOrder.getCode())
+                .setAsnId(asnOrder.getId())
+                .setProdTime(dto.getProdTime())
+                .setWeight(dto.getWeigth())
+                //搴撳瓨鍗曚綅涓烘渶灏忓崟浣�
+                .setUnit(orderItem.getStockUnit())
+                .setStockUnit(orderItem.getStockUnit())
+                .setBatch(StringUtils.isBlank(orderItem.getBatch()) ? SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_RECEIPT_BATCH, dto) : orderItem.getBatch())
+                .setAnfme(dto.getReceiptQty())
+                .setSplrBatch(dto.getSplrBatch())
+                .setMatnrCode(matnr.getCode())
+                .setUpdateBy(loginUserId)
+                .setCreateBy(loginUserId)
+                .setMatnrId(matnr.getId())
+                .setMaktx(matnr.getName())
+                .setWeight(matnr.getWeight())
+                .setFieldsIndex(orderItem.getFieldsIndex())
+                .setShipperId(matnr.getShipperId());
+        //TODO 渚涘簲鍟嗘爣璇嗘湭璁剧疆锛屾爣璇嗙敱PO鍗曚緵搴斿晢缂栫爜杞崲
+        WarehouseAreasItem serviceOne = warehouseAreasItemService.getOne(new LambdaQueryWrapper<WarehouseAreasItem>()
+                .eq(WarehouseAreasItem::getAsnItemId, item.getAsnItemId())
+                .eq(WarehouseAreasItem::getTrackCode, item.getTrackCode())
+                .eq(StringUtils.isNotBlank(item.getSplrBatch()), WarehouseAreasItem::getSplrBatch, item.getSplrBatch()));
+        if (!Objects.isNull(serviceOne)) {
+            item.setAnfme(item.getAnfme() + serviceOne.getAnfme());
+        }
+
+        //鏈川妫�
+        if (!warehouseAreasItemService.saveOrUpdate(item)) {
+            throw new CoolException("鏀惰揣澶辫触锛侊紒");
+        }
+
+//        if (null != orderItem.getSafeQty() || null != orderItem.getDisQty() ) {
+//
+//        }
+//        else {
+//            //涓嶅悎鏍兼暟閲�
+//            if (orderItem.getDisQty().compareTo(0.00) > 0) {
+//                item.setIsptQty(orderItem.getDisQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_DEFECT.val);
+//                if (!warehouseAreasItemService.saveOrUpdate(item)) {
+//                    throw new CoolException("鏀惰揣澶辫触锛侊紒");
+//                }
+//            }
+//
+//            item.setIsptQty(orderItem.getSafeQty()).setFlagNorm(QlyIsptResult.QLY_ISPT_RESULT_EXCELLENT.val);
+//            if (!warehouseAreasItemService.saveOrUpdate(item)) {
+//                throw new CoolException("鏀惰揣澶辫触锛侊紒");
+//            }
+//        }
+
+
     }
 
     /**
@@ -358,7 +382,9 @@
         }
         List<AsnOrderItem> asnOrderItem = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>()
                 .eq(AsnOrderItem::getAsnCode, params.getAsnCode())
-                .eq(!Objects.isNull(params.getTrackCode()), AsnOrderItem::getTrackCode, params.getTrackCode()));
+                .eq(!Objects.isNull(params.getTrackCode()), AsnOrderItem::getTrackCode, params.getTrackCode())
+                .eq(!Cools.isEmpty(params.getMatnrCode()), AsnOrderItem::getMatnrCode, params.getMatnrCode())
+        );
 
         if (Objects.isNull(asnOrderItem)) {
             throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
@@ -420,8 +446,9 @@
      * @time 2025/4/7 16:58
      */
     @Override
-    public R getDeltByCode(Map<String, Object> params ) {
-        String code = params.get("code").toString();
+    public R getDeltByCode(Map<String, Object> params) {
+        Object code = params.get("code");
+        Object matnrCode = params.get("matnrCode");
         String batch = null;
         if (!Objects.isNull(params.get("batch"))) {
             batch = params.get("batch").toString();
@@ -429,10 +456,11 @@
         //TODO 鍚庣画闇�鏍规嵁绛栫暐閰嶇疆锛岃幏鍙栫粍鎷栨暟鎹�傚锛氭贩瑁咃紝鎸夋壒娆℃贩瑁呯瓑
         LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new QueryWrapper<WarehouseAreasItem>()
                 .select("SUM(anfme) as anfme, track_code, asn_code, id, splr_batch, ispt_result, plat_item_id, batch,unit, stock_unit,  qty, work_qty, matnr_code, matnr_id, maktx").lambda()
-                .eq(StringUtils.isNotBlank(code), WarehouseAreasItem::getTrackCode, code)
+                .eq(!Objects.isNull(code), WarehouseAreasItem::getTrackCode, code)
                 .eq(StringUtils.isNotBlank(batch), WarehouseAreasItem::getSplrBatch, batch)
+                .eq(!Objects.isNull(matnrCode), WarehouseAreasItem::getMatnrCode, matnrCode)
                 .groupBy(WarehouseAreasItem::getSplrBatch, WarehouseAreasItem::getAsnId, WarehouseAreasItem::getAreaId, WarehouseAreasItem::getMatnrId);
-        return R.ok(warehouseAreasItemService.getOne(queryWrapper, false));
+        return R.ok(warehouseAreasItemService.list(queryWrapper));
     }
 
     /**
@@ -446,6 +474,11 @@
     @Override
     public WaitPakin mergeItems(WaitPakinParam waitPakin, Long userId) {
         return waitPakinService.mergeItems(waitPakin, userId);
+    }
+
+    @Override
+    public WaitPakin mergeMatnrItems(WaitPakinParam waitPakin, Long userId) {
+        return waitPakinService.mergeMatnrItems(waitPakin, userId);
     }
 
     /**
@@ -938,6 +971,7 @@
             ReceiptDetlsDto detlsDto = new ReceiptDetlsDto();
 
             detlsDto.setAsnCode(asnOrderItem.getAsnCode())
+                    .setId(asnOrderItem.getId())
                     .setMaktx(asnOrderItem.getMaktx())
                     .setFieldsIndex(asnOrderItem.getFieldsIndex())
                     .setBarcode(asnOrderItem.getTrackCode())
@@ -947,7 +981,10 @@
                     .setPoCode(asnOrderItem.getPoCode())
                     .setAnfme(asnOrderItem.getAnfme())
                     .setPurQty(asnOrderItem.getPurQty())
-                    .setSplrBatch(asnOrderItem.getSplrBatch());
+                    .setSplrBatch(asnOrderItem.getSplrBatch())
+                    .setMatnr(asnOrderItem.getMatnrCode())
+                    .setInspect(asnOrderItem.getIsptResult$()) //璐ㄦ缁撴灉
+            ;
 
             Matnr matnr = matnrMapper.selectById(asnOrderItem.getMatnrId());
             if (Objects.isNull(matnr)) {
@@ -956,12 +993,12 @@
             //SET 鐗╂枡鏈�澶у瓨鏀炬暟閲�
             detlsDto.setMaxQty(matnr.getMaxQty())
                     .setMatnrId(matnr.getId());
-            QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>()
-                    .eq(QlyInspect::getAsnId, asnOrderItem.getAsnId()));
-            if (!Objects.isNull(inspect)) {
-                //set 璐ㄦ缁撴灉
-                detlsDto.setInspect(inspect.getStatus$());
-            }
+//            QlyInspect inspect = qlyInspectMapper.selectOne(new LambdaQueryWrapper<QlyInspect>()
+//                    .eq(QlyInspect::getAsnId, asnOrderItem.getAsnId()));
+//            if (!Objects.isNull(inspect)) {
+//                //set 璐ㄦ缁撴灉
+//                detlsDto.setInspect(inspect.getStatus$());
+//            }
             //鑾峰彇褰撳墠搴撳瓨淇℃伅
             LocItem stockItem = locItemService.getOne(new LambdaQueryWrapper<LocItem>()
 //                    .eq(LocItem::getOrderItemId, asnOrderItem.getId())

--
Gitblit v1.9.1