From f9281b83739ceb938687264dcabd9e2e12acfd56 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期二, 25 三月 2025 15:20:00 +0800
Subject: [PATCH] 修改 # 优化物料分组搜索功能

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/MobileServiceImpl.java |   63 +++++++++++++++++++++++++++++++
 1 files changed, 62 insertions(+), 1 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 494d4d6..a00a0ec 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
@@ -17,6 +17,8 @@
 import com.vincent.rsf.server.common.utils.JwtUtil;
 import com.vincent.rsf.server.manager.entity.*;
 import com.vincent.rsf.server.manager.mapper.*;
+import com.vincent.rsf.server.manager.service.AsnOrderItemLogService;
+import com.vincent.rsf.server.manager.service.AsnOrderLogService;
 import com.vincent.rsf.server.manager.service.WarehouseAreasItemService;
 import com.vincent.rsf.server.manager.service.WarehouseAreasService;
 import com.vincent.rsf.server.system.constant.CodeRes;
@@ -32,13 +34,16 @@
 import com.vincent.rsf.server.system.service.UserLoginService;
 import com.vincent.rsf.server.system.utils.SerialRuleUtils;
 import org.apache.tika.utils.StringUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import java.math.BigDecimal;
 import java.util.*;
 
 /**
@@ -79,6 +84,12 @@
     private PurchaseItemMapper purchaseItemMapper;
     @Resource
     private FieldsMapper fieldsMapper;
+
+    @Autowired
+    private AsnOrderLogService asnOrderLogService;
+
+    @Autowired
+    private AsnOrderItemLogService asnOrderItemLogService;
 
     @Autowired
     private FieldsItemService fieldsItemService;
@@ -172,6 +183,9 @@
         String asnCode = receipts.stream().findFirst().get().getAsnCode();
 
         AsnOrder asnOrder = asnOrderMapper.selectOne(new LambdaQueryWrapper<AsnOrder>().eq(AsnOrder::getCode, asnCode));
+        if (Objects.isNull(asnOrder)) {
+            throw new CoolException("鏁版嵁閿欒锛氫富鍗曚笉瀛樺湪锛侊紒");
+        }
         asnOrder.setQty(receiptQty);
 
         if (asnOrderMapper.updateById(asnOrder) < 1) {
@@ -248,18 +262,65 @@
                 }
             }
             allOrders.add(item);
-
         });
 
         if (!warehouseAreasItemService.saveBatch(allOrders)) {
             throw new CoolException("鏀惰揣澶辫触锛侊紒");
         }
 
+        //鑾峰彇閲囪喘鏁伴噺
+        double purQty = receipts.stream().mapToDouble(ReceiptDetlsDto::getPurQty).sum();
+
+        BigDecimal subtract = BigDecimal.valueOf(receiptQty).subtract(BigDecimal.valueOf(purQty));
+        //鍒ゆ柇宸叉敹璐ф暟閲忔槸鍚﹀皬浜庣瓑浜庨噰璐暟閲�
+        if (subtract.compareTo(new BigDecimal("0.0")) <= 0) {
+            asnOrder.setRleStatus(Short.valueOf("1"));
+            //鏃ュ織琛ㄦ搷浣�
+            operateOrderLogs(asnOrder);
+        }
+
         return R.ok("鎿嶄綔鎴愬姛");
     }
 
     /**
      * @author Ryan
+     * @description 鍒犻櫎鍘熶富鍗曞強鏄庣粏锛屽姞鍏ュ巻鍙叉。
+     * @param
+     * @return
+     * @time 2025/3/19 19:53
+     */
+    private void operateOrderLogs(AsnOrder asnOrder) {
+        if (asnOrderMapper.deleteById(asnOrder.getId()) < 1) {
+            throw new CoolException("鍘熷崟鎹垹闄ゅけ璐ワ紒锛�");
+        }
+
+        AsnOrderLog orderLog = new AsnOrderLog();
+        BeanUtils.copyProperties(asnOrder, orderLog);
+
+        if (!asnOrderLogService.save(orderLog)) {
+            throw new CoolException("涓诲崟鍘嗗彶妗f坊鍔犲け璐ワ紒锛�");
+        }
+
+        List<AsnOrderItemLog> logs = new ArrayList<>();
+        List<AsnOrderItem> items = asnOrderItemMapper.selectList(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getAsnId, asnOrder.getId()));
+        items.forEach(item -> {
+            AsnOrderItemLog itemLog = new AsnOrderItemLog();
+            BeanUtils.copyProperties(item, itemLog);
+            logs.add(itemLog);
+        });
+
+        if (!asnOrderItemLogService.saveBatch(logs)) {
+            throw new CoolException("閫氱煡鍗曟槑缁嗗巻鍙叉。淇濆瓨澶辫触锛侊紒");
+        }
+
+        if (asnOrderItemMapper.delete(new LambdaQueryWrapper<AsnOrderItem>().eq(AsnOrderItem::getAsnId, asnOrder.getId())) < 1) {
+            throw new CoolException("鍘熷崟鎹槑缁嗗垹闄ゅけ璐ワ紒锛�");
+        }
+    }
+
+
+    /**
+     * @author Ryan
      * @description 鍏跺畠鏀惰揣
      * @param params
      * @return

--
Gitblit v1.9.1