From 40946ba6c24a0318f14cbed603f0ed9cad1da853 Mon Sep 17 00:00:00 2001
From: zss <zss@example.com>
Date: 星期五, 16 一月 2026 10:32:52 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jtwy' into jtwy

---
 src/main/java/com/ruoyi/sales/controller/SalesLedgerProductController.java |   18 +++++---
 src/main/java/com/ruoyi/sales/controller/ShipmentApprovalController.java   |   68 ++++++++++++++++++++++------------
 2 files changed, 55 insertions(+), 31 deletions(-)

diff --git a/src/main/java/com/ruoyi/sales/controller/SalesLedgerProductController.java b/src/main/java/com/ruoyi/sales/controller/SalesLedgerProductController.java
index d69d27a..0cd59f9 100644
--- a/src/main/java/com/ruoyi/sales/controller/SalesLedgerProductController.java
+++ b/src/main/java/com/ruoyi/sales/controller/SalesLedgerProductController.java
@@ -8,6 +8,7 @@
 import com.ruoyi.procurementrecord.dto.ProcurementPageDto;
 import com.ruoyi.procurementrecord.dto.ProcurementPageDtoCopy;
 import com.ruoyi.procurementrecord.service.ProcurementRecordService;
+import com.ruoyi.procurementrecord.utils.StockUtils;
 import com.ruoyi.sales.pojo.SalesLedgerProduct;
 import com.ruoyi.sales.service.ISalesLedgerProductService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -41,6 +42,8 @@
     private ISalesLedgerProductService salesLedgerProductService;
     @Autowired
     private ProcurementRecordService procurementRecordService;
+    @Autowired
+    private StockUtils stockUtils;
     /**
      * 鏌ヨ浜у搧淇℃伅鍒楄〃
      */
@@ -55,13 +58,14 @@
             if (item.getFutureTicketsAmount().compareTo(BigDecimal.ZERO) == 0) {
                 item.setFutureTicketsAmount(item.getTaxInclusiveTotalPrice());
             }
-            ProcurementPageDto procurementDto = new ProcurementPageDto();
-            procurementDto.setSalesLedgerProductId(item.getId());
-            procurementDto.setProductCategory(item.getProductCategory());
-            IPage<ProcurementPageDtoCopy> result = procurementRecordService.listPageCopyByProduction(new Page<>(1,-1), procurementDto);
-            if(result.getRecords().size()>0) {
-                ProcurementPageDtoCopy procurementDtoCopy = result.getRecords().get(0);
-                if (item.getQuantity().compareTo(procurementDtoCopy.getInboundNum0()) >= 0 && item.getApproveStatus() == 0) {
+//            ProcurementPageDto procurementDto = new ProcurementPageDto();
+//            procurementDto.setSalesLedgerProductId(item.getId());
+//            procurementDto.setProductCategory(item.getProductCategory());
+//            IPage<ProcurementPageDtoCopy> result = procurementRecordService.listPageCopyByProduction(new Page<>(1,-1), procurementDto);
+            BigDecimal stockQuantity = stockUtils.getStockQuantity(item.getProductModelId()).get("stockQuantity");
+            if(stockQuantity != null) {
+//                ProcurementPageDtoCopy procurementDtoCopy = result.getRecords().get(0);
+                if (item.getQuantity().compareTo(stockQuantity) >= 0 && item.getApproveStatus() == 0) {
                     item.setApproveStatus(1);
                     salesLedgerProductService.addOrUpdateSalesLedgerProduct(item);
                 }
diff --git a/src/main/java/com/ruoyi/sales/controller/ShipmentApprovalController.java b/src/main/java/com/ruoyi/sales/controller/ShipmentApprovalController.java
index b8fab54..a34f809 100644
--- a/src/main/java/com/ruoyi/sales/controller/ShipmentApprovalController.java
+++ b/src/main/java/com/ruoyi/sales/controller/ShipmentApprovalController.java
@@ -3,6 +3,7 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.poi.ExcelUtil;
 import com.ruoyi.framework.web.controller.BaseController;
 import com.ruoyi.framework.web.domain.AjaxResult;
@@ -60,41 +61,60 @@
     @ApiOperation("鍙戣揣瀹℃壒,鏇存柊鍙戣揣瀹℃壒鐘舵��")
     @Transactional(rollbackFor = Exception.class)
     public AjaxResult update(@RequestBody ShipmentApproval req) {
+
+        //  鏌ヨ鍙戣揣瀹℃壒
         ShipmentApproval shipmentApproval = shipmentApprovalMapper.selectById(req.getId());
         if (shipmentApproval == null) {
             return AjaxResult.error("鍙戣揣瀹℃壒涓嶅瓨鍦�");
         }
 
+        //  鏇存柊鍙戣揣瀹℃壒鐘舵��
         shipmentApproval.setApproveStatus(req.getApproveStatus());
         boolean update = shipmentApprovalService.updateById(shipmentApproval);
-        if(update){
-            SalesLedgerProduct salesLedgerProduct = salesLedgerProductService.getById(shipmentApproval.getSalesLedgerProductId());
-            salesLedgerProduct.setApproveStatus(req.getApproveStatus());
-            salesLedgerProductService.updateById(salesLedgerProduct);
-
-            if(req.getApproveStatus()==3){
-                ProcurementRecordStorage procurementRecordStorage = procurementRecordStorageService.getOne(new LambdaQueryWrapper<ProcurementRecordStorage>()
-                        .eq(ProcurementRecordStorage::getSalesLedgerProductId, req.getSalesLedgerProductId()));
-                if(procurementRecordStorage==null){
-                    return AjaxResult.error("閲囪喘璁板綍涓嶅瓨鍦�");
-                }
-                //鍙戣揣瀹℃壒閫氳繃锛岀敓浜ц璁㈠崟鍑哄簱璁板綍
-                ProcurementRecordOutAdd procurementRecordOutAdd = new ProcurementRecordOutAdd();
-                procurementRecordOutAdd.setId(procurementRecordStorage.getId());
-                procurementRecordOutAdd.setSalesLedgerProductId(Math.toIntExact(salesLedgerProduct.getId()));
-                procurementRecordOutAdd.setType(2);
-                procurementRecordOutAdd.setUserId(Math.toIntExact(getUserId()));
-                procurementRecordOutAdd.setQuantity(String.valueOf(salesLedgerProduct.getQuantity()));
-                //鑾峰彇褰撳墠鏃堕棿
-                LocalDate now = LocalDate.now();
-                procurementRecordOutAdd.setTime(now.toString());
-                procurementRecordOutService.stockout(procurementRecordOutAdd);
-            }
+        if (!update) {
+            //  浜嬪姟鍥炴粴
+            throw new ServiceException("鍙戣揣瀹℃壒鏇存柊澶辫触");
         }
-        return update ? AjaxResult.success() : AjaxResult.error();
+        //  鏌ヨ鍏宠仈鐨勯攢鍞彴璐︿骇鍝�
+        SalesLedgerProduct salesLedgerProduct = salesLedgerProductService.getById(shipmentApproval.getSalesLedgerProductId());
+        if (salesLedgerProduct == null) {
+            //  鎶涘紓甯镐簨鍔″洖婊�
+            throw new ServiceException("閿�鍞彴璐︿笉瀛樺湪锛屽鎵瑰洖婊�");
+        }
+
+        //  鍚屾鏇存柊閿�鍞彴璐︿骇鍝佺殑瀹℃壒鐘舵��
+        salesLedgerProduct.setApproveStatus(req.getApproveStatus());
+        salesLedgerProductService.updateById(salesLedgerProduct);
+
+        //  瀹℃壒閫氳繃
+        if (req.getApproveStatus() == 3) {
+            // 鏌ヨ閲囪喘鍏ュ簱璁板綍
+            LambdaQueryWrapper<ProcurementRecordStorage> lambdaQueryWrapper = new LambdaQueryWrapper<ProcurementRecordStorage>()
+                    .eq(ProcurementRecordStorage::getSalesLedgerProductId, req.getSalesLedgerProductId());
+            ProcurementRecordStorage procurementRecordStorage = procurementRecordStorageService.getOne(lambdaQueryWrapper);
+
+            if (procurementRecordStorage == null) {
+                // 淇濊瘉鍓嶉潰鐨勪慨鏀瑰叏閮ㄥ洖婊�
+                throw new ServiceException("閲囪喘璁板綍涓嶅瓨鍦紝瀹℃壒鍥炴粴");
+            }
+
+            //  鐢熸垚鍑哄簱璁板綍
+            ProcurementRecordOutAdd procurementRecordOutAdd = new ProcurementRecordOutAdd();
+            procurementRecordOutAdd.setId(procurementRecordStorage.getId());
+            procurementRecordOutAdd.setSalesLedgerProductId(Math.toIntExact(salesLedgerProduct.getId()));
+            procurementRecordOutAdd.setType(2);
+            procurementRecordOutAdd.setUserId(Math.toIntExact(getUserId()));
+            procurementRecordOutAdd.setQuantity(salesLedgerProduct.getQuantity().toPlainString());
+            procurementRecordOutAdd.setTime(LocalDate.now().toString());
+
+            procurementRecordOutService.stockout(procurementRecordOutAdd);
+        }
+
+        return AjaxResult.success();
     }
 
 
+
     /**
      * 瀵煎嚭鍙戣揣淇℃伅绠$悊
      */

--
Gitblit v1.9.3