From 7791957685b2630fb0fd4a8c2b73e1867519a4f1 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 07 五月 2025 10:04:32 +0800
Subject: [PATCH] #pda组托+物料组托

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |   34 +++++++++++++++-------------------
 1 files changed, 15 insertions(+), 19 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 6ad7541..33219e4 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
@@ -449,18 +449,19 @@
     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();
-        }
+        Object asnCode = params.get("asnCode");
+        Object batch = params.get("batch");
+
         //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(!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.list(queryWrapper));
+        LambdaQueryWrapper<WarehouseAreasItem> queryWrapper = new LambdaQueryWrapper<WarehouseAreasItem>()
+                .eq(!Cools.isEmpty(code), WarehouseAreasItem::getTrackCode, code)
+                .eq(!Cools.isEmpty(batch), WarehouseAreasItem::getSplrBatch, batch)
+                .eq(!Cools.isEmpty(matnrCode), WarehouseAreasItem::getMatnrCode, matnrCode)
+                .eq(!Cools.isEmpty(asnCode), WarehouseAreasItem::getAsnCode, asnCode)
+                ;
+        List<WarehouseAreasItem> list = warehouseAreasItemService.list(queryWrapper);
+        list.removeIf(e -> e.getAnfme() <= e.getWorkQty());
+        return R.ok(list);
     }
 
     /**
@@ -474,11 +475,6 @@
     @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);
     }
 
     /**
@@ -841,9 +837,9 @@
      */
     @Override
     public R getItemByContainer(Map<String, Object> params) {
-        if (Objects.isNull(params.get("code"))) {
-            throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
-        }
+//        if (Objects.isNull(params.get("code"))) {
+//            throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
+//        }
         //鑾峰彇缁勬嫋鏈敓鎴愪换鍔$殑缁勬嫋妗�
         List<Short> asList = Arrays.asList(Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val), Short.valueOf(PakinIOStatus.PAKIN_IO_STATUS_DONE.val));
         Short flagDefect = 0;

--
Gitblit v1.9.1