From 4336d99906953517399187638925817d969c4e10 Mon Sep 17 00:00:00 2001
From: liyong <18434998025@163.com>
Date: 星期四, 14 五月 2026 14:18:14 +0800
Subject: [PATCH] refactor(stock): 优化库存管理和产品模型查询功能

---
 src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java |   51 ++++++++++++++++++++++++++++++++-------------------
 1 files changed, 32 insertions(+), 19 deletions(-)

diff --git a/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java b/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java
index c4cb6eb..1652d8c 100644
--- a/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java
+++ b/src/main/java/com/ruoyi/stock/service/impl/StockOutRecordServiceImpl.java
@@ -84,13 +84,11 @@
         for (Long id : ids) {
             StockOutRecord stockOutRecord = stockOutRecordMapper.selectById(id);
             if (stockOutRecord.getType().equals("0")) {
-                LambdaQueryWrapper<StockInventory> wrapper = new LambdaQueryWrapper<StockInventory>()
-                    .eq(StockInventory::getProductModelId, stockOutRecord.getProductModelId());
-                if (StringUtils.isEmpty(stockOutRecord.getBatchNo())) {
-                    wrapper.isNull(StockInventory::getBatchNo);
-                } else {
-                    wrapper.eq(StockInventory::getBatchNo, stockOutRecord.getBatchNo());
-                }
+                LambdaQueryWrapper<StockInventory> wrapper = buildQualifiedInventoryQuery(
+                        stockOutRecord.getProductModelId(),
+                        stockOutRecord.getBatchNo(),
+                        stockOutRecord.getWarehouseInfoId()
+                );
                 StockInventory stockInventory = stockInventoryMapper.selectOne(wrapper);
                 if (stockInventory == null) {
                     throw new BaseException("搴撳瓨璁板綍涓病鏈夊搴旂殑浜у搧,鏃犳硶鍒犻櫎!!!");
@@ -99,6 +97,7 @@
                     stockInRecordDto.setProductModelId(stockInventory.getProductModelId());
                     stockInRecordDto.setQualitity(stockOutRecord.getStockOutNum());
                     stockInRecordDto.setBatchNo(stockInventory.getBatchNo());
+                    stockInRecordDto.setWarehouseInfoId(stockInventory.getWarehouseInfoId());
                     stockInventoryMapper.updateAddStockInventory(stockInRecordDto);
                 }
             }else if (stockOutRecord.getType().equals("1")) {
@@ -150,12 +149,12 @@
                 throw new BaseException("鍙湁寰呭鎵圭姸鎬佺殑璁板綍鎵嶈兘鍒犻櫎,鍑哄簱鎵规:" + stockOutRecord.getOutboundBatches());
             }
         }
-        return stockOutRecordMapper.deleteBatchIds(ids);
+        return stockOutRecordMapper.deleteByIds(ids);
     }
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public int batchApprove(List<Long> ids, Integer approvalStatus) {
+    public int batchApprove(List<Long> ids, Integer approvalStatus,Long warehouseInfoId) {
         if (CollectionUtils.isEmpty(ids)) {
             throw new BaseException("璇烽�夋嫨鑷冲皯涓�鏉℃暟鎹�");
         }
@@ -176,7 +175,11 @@
             if (ReviewStatusEnum.APPROVED.getCode().equals(approvalStatus)) {
                 if ("0".equals(stockOutRecord.getType())) {
                     // 鍚堟牸鍑哄簱 -> 鍏堟煡搴撳瓨鏄惁瀛樺湪锛屽瓨鍦ㄦ墠鎵e噺
-                    StockInventory stockInventory = getStockInventory(stockOutRecord.getProductModelId(), stockOutRecord.getBatchNo());
+                    StockInventory stockInventory = getStockInventory(
+                            stockOutRecord.getProductModelId(),
+                            stockOutRecord.getBatchNo(),
+                            stockOutRecord.getWarehouseInfoId()
+                    );
                     if (stockInventory == null) {
                         throw new BaseException("鍚堟牸搴撳瓨璁板綍涓嶅瓨鍦�,鍑哄簱鎵规:" + stockOutRecord.getOutboundBatches());
                     }
@@ -186,6 +189,7 @@
                     StockInventoryDto stockInventoryDto = new StockInventoryDto();
                     stockInventoryDto.setProductModelId(stockOutRecord.getProductModelId());
                     stockInventoryDto.setBatchNo(stockOutRecord.getBatchNo());
+                    stockInventoryDto.setWarehouseInfoId(stockOutRecord.getWarehouseInfoId());
                     stockInventoryDto.setQualitity(stockOutRecord.getStockOutNum());
                     stockInventoryMapper.updateSubtractStockInventory(stockInventoryDto);
                 } else if ("1".equals(stockOutRecord.getType())) {
@@ -205,15 +209,8 @@
         return ids.size();
     }
 
-    private StockInventory getStockInventory(Long productModelId, String batchNo) {
-        LambdaQueryWrapper<StockInventory> eq = new LambdaQueryWrapper<>();
-        eq.eq(StockInventory::getProductModelId, productModelId);
-        if (StringUtils.isEmpty(batchNo)) {
-            eq.isNull(StockInventory::getBatchNo);
-        } else {
-            eq.eq(StockInventory::getBatchNo, batchNo);
-        }
-        return stockInventoryMapper.selectOne(eq);
+    private StockInventory getStockInventory(Long productModelId, String batchNo, Long warehouseInfoId) {
+        return stockInventoryMapper.selectOne(buildQualifiedInventoryQuery(productModelId, batchNo, warehouseInfoId));
     }
 
     private StockUninventory getStockUninventory(Long productModelId, String batchNo) {
@@ -226,4 +223,20 @@
         }
         return stockUninventoryMapper.selectOne(eq);
     }
+
+    private LambdaQueryWrapper<StockInventory> buildQualifiedInventoryQuery(Long productModelId, String batchNo, Long warehouseInfoId) {
+        LambdaQueryWrapper<StockInventory> wrapper = new LambdaQueryWrapper<StockInventory>()
+                .eq(StockInventory::getProductModelId, productModelId);
+        if (warehouseInfoId == null) {
+            wrapper.isNull(StockInventory::getWarehouseInfoId);
+        } else {
+            wrapper.eq(StockInventory::getWarehouseInfoId, warehouseInfoId);
+        }
+        if (StringUtils.isEmpty(batchNo)) {
+            wrapper.isNull(StockInventory::getBatchNo);
+        } else {
+            wrapper.eq(StockInventory::getBatchNo, batchNo);
+        }
+        return wrapper;
+    }
 }

--
Gitblit v1.9.3