From 751f8b198ef1f7988d3de17516b752aeaa7f4ea4 Mon Sep 17 00:00:00 2001
From: huminmin <mac@MacBook-Pro.local>
Date: 星期四, 30 四月 2026 10:46:04 +0800
Subject: [PATCH] 采购退货后,仓储物流生成对应的采购退货记录

---
 src/main/java/com/ruoyi/purchase/service/impl/PurchaseReturnOrdersServiceImpl.java |   68 +++++++++++++++++++++++++++++++++
 1 files changed, 67 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseReturnOrdersServiceImpl.java b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseReturnOrdersServiceImpl.java
index 6584dbb..aa25cd0 100644
--- a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseReturnOrdersServiceImpl.java
+++ b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseReturnOrdersServiceImpl.java
@@ -9,10 +9,15 @@
 import com.ruoyi.account.pojo.AccountIncome;
 import com.ruoyi.account.service.AccountIncomeService;
 import com.ruoyi.common.enums.SaleEnum;
+import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
+import com.ruoyi.common.enums.StockOutUnQualifiedRecordTypeEnum;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.framework.security.LoginUser;
 import com.ruoyi.procurementrecord.utils.StockUtils;
+import com.ruoyi.sales.pojo.SalesLedgerProduct;
+import com.ruoyi.quality.pojo.QualityInspect;
+import com.ruoyi.quality.mapper.QualityInspectMapper;
 import com.ruoyi.purchase.dto.PurchaseReturnOrderDto;
 import com.ruoyi.purchase.dto.PurchaseReturnOrderProductsDto;
 import com.ruoyi.purchase.mapper.PurchaseReturnOrderProductsMapper;
@@ -55,6 +60,12 @@
     @Resource
     private AccountIncomeService accountIncomeService;
 
+    @Resource
+    private StockUtils stockUtils;
+
+    @Resource
+    private QualityInspectMapper qualityInspectMapper;
+
     @Override
     public IPage<PurchaseReturnOrderVo> listPage(Page page, PurchaseReturnOrderDto purchaseReturnOrderDto) {
         return purchaseReturnOrdersMapper.listPage(page, purchaseReturnOrderDto);
@@ -66,6 +77,16 @@
         this.save(purchaseReturnOrderDto);
 
         if (!purchaseReturnOrderDto.getPurchaseReturnOrderProductsDtos().isEmpty()) {
+            // 鍏堟煡璇㈡墍鏈夐攢鍞彴璐︿骇鍝佷俊鎭紝鐢ㄤ簬鍚庣画搴撳瓨鎵e噺
+            List<Long> productIds = purchaseReturnOrderDto.getPurchaseReturnOrderProductsDtos().stream()
+                    .map(PurchaseReturnOrderProductsDto::getSalesLedgerProductId)
+                    .distinct()
+                    .filter(Objects::nonNull)
+                    .collect(Collectors.toList());
+            List<SalesLedgerProduct> salesLedgerProducts = salesLedgerService.getSalesLedgerProductListByIds(productIds, SaleEnum.PURCHASE);
+            Map<Long, SalesLedgerProduct> productMap = salesLedgerProducts.stream()
+                    .collect(Collectors.toMap(SalesLedgerProduct::getId, product -> product));
+
             for (PurchaseReturnOrderProductsDto purchaseReturnOrderProductsDto : purchaseReturnOrderDto.getPurchaseReturnOrderProductsDtos()) {
                 purchaseReturnOrderProductsDto.setSalesLedgerProductId(purchaseReturnOrderProductsDto.getSalesLedgerProductId());
                 purchaseReturnOrderProductsDto.setPurchaseReturnOrderId(purchaseReturnOrderDto.getId());
@@ -73,6 +94,51 @@
                 // 杩欓噷涓烘柊澧炲洜姝d涓簄ull
                 purchaseReturnOrderProductsDto.setId(null);
                 purchaseReturnOrderProductsMapper.insert(purchaseReturnOrderProductsDto);
+
+                // 鍚屾杩涜搴撳瓨鎵e噺鍜屽嚭搴撹褰�
+                SalesLedgerProduct salesLedgerProduct = productMap.get(purchaseReturnOrderProductsDto.getSalesLedgerProductId());
+                if (salesLedgerProduct != null && salesLedgerProduct.getProductModelId() != null) {
+                    // 鏍规嵁 SalesLedgerProduct 涓殑 isChecked 鍒ゆ柇鏄惁闇�瑕佽川妫�
+                    Boolean isChecked = salesLedgerProduct.getIsChecked();
+                    if (Boolean.TRUE.equals(isChecked)) {
+                        // 闇�瑕佽川妫�锛屾牴鎹川妫�缁撴灉鍒ゆ柇
+                        LambdaQueryWrapper<QualityInspect> inspectQueryWrapper = new LambdaQueryWrapper<>();
+                        inspectQueryWrapper.eq(QualityInspect::getPurchaseLedgerId, purchaseReturnOrderDto.getPurchaseLedgerId());
+                        QualityInspect inspect = qualityInspectMapper.selectOne(inspectQueryWrapper);
+                        if (inspect == null) {
+                            throw new RuntimeException("璇ラ噰璐鍗曟病鏈夎川妫�璁板綍");
+                        }
+                        // 鑾峰彇璐ㄦ璁板綍鐨勭粨鏋�
+                        String checkResult = inspect.getCheckResult();
+                        if ("鍚堟牸".equals(checkResult)) {
+                            // 璐ㄦ鍚堟牸锛屾墸鍑忓悎鏍煎簱瀛�
+                            stockUtils.substractStock(
+                                    salesLedgerProduct.getProductModelId(),
+                                    purchaseReturnOrderProductsDto.getReturnQuantity(),
+                                    StockOutQualifiedRecordTypeEnum.PURCHASE_RETURN_STOCK_OUT.getCode(),
+                                    purchaseReturnOrderDto.getId()
+                            );
+                        } else if ("涓嶅悎鏍�".equals(checkResult)) {
+                            // 璐ㄦ涓嶅悎鏍硷紝鎵e噺涓嶅悎鏍煎簱瀛�
+                            stockUtils.subtractUnStock(
+                                    salesLedgerProduct.getProductModelId(),
+                                    purchaseReturnOrderProductsDto.getReturnQuantity(),
+                                    StockOutUnQualifiedRecordTypeEnum.PURCHASE_RETURN_STOCK_OUT.getCode(),
+                                    purchaseReturnOrderDto.getId()
+                            );
+                        } else {
+                            throw new RuntimeException("璐ㄦ缁撴灉涓嶆纭�: " + checkResult);
+                        }
+                    } else {
+                        // 涓嶉渶瑕佽川妫�锛屾墸鍑忓悎鏍煎簱瀛�
+                        stockUtils.substractStock(
+                                salesLedgerProduct.getProductModelId(),
+                                purchaseReturnOrderProductsDto.getReturnQuantity(),
+                                StockOutQualifiedRecordTypeEnum.PURCHASE_RETURN_STOCK_OUT.getCode(),
+                                purchaseReturnOrderDto.getId()
+                        );
+                    }
+                }
             }
         }else {
             throw new RuntimeException("璇烽�夋嫨閫�璐у晢鍝�");
@@ -134,4 +200,4 @@
         updateWrapperAccountIncome.eq(AccountIncome::getIncomeType, 4);
         accountIncomeService.remove(updateWrapperAccountIncome);
     }
-}
+}
\ No newline at end of file

--
Gitblit v1.9.3