From b3234808d609961c86fc2dca8f762c81eb7fa623 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期六, 23 五月 2026 15:09:34 +0800
Subject: [PATCH] refactor(approve): 重构审批业务状态同步逻辑

---
 src/main/java/com/ruoyi/approve/service/impl/ApproveNodeServiceImpl.java |  128 +-----------------------------------------
 1 files changed, 4 insertions(+), 124 deletions(-)

diff --git a/src/main/java/com/ruoyi/approve/service/impl/ApproveNodeServiceImpl.java b/src/main/java/com/ruoyi/approve/service/impl/ApproveNodeServiceImpl.java
index 0b1a854..964be23 100644
--- a/src/main/java/com/ruoyi/approve/service/impl/ApproveNodeServiceImpl.java
+++ b/src/main/java/com/ruoyi/approve/service/impl/ApproveNodeServiceImpl.java
@@ -1,7 +1,6 @@
 package com.ruoyi.approve.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -14,26 +13,12 @@
 import com.ruoyi.basic.enums.RecordTypeEnum;
 import com.ruoyi.basic.utils.FileUtil;
 import com.ruoyi.common.enums.FileNameType;
-import com.ruoyi.common.enums.StockInQualifiedRecordTypeEnum;
-import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
 import com.ruoyi.common.utils.SecurityUtils;
-import com.ruoyi.device.mapper.DeviceRepairMapper;
-import com.ruoyi.procurementrecord.utils.StockUtils;
 import com.ruoyi.project.system.domain.SysUser;
 import com.ruoyi.project.system.mapper.SysUserMapper;
 import com.ruoyi.project.system.service.ISysNoticeService;
-import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;
-import com.ruoyi.purchase.pojo.PurchaseLedger;
-import com.ruoyi.quality.mapper.QualityInspectMapper;
-import com.ruoyi.quality.mapper.QualityInspectParamMapper;
-import com.ruoyi.quality.mapper.QualityTestStandardMapper;
-import com.ruoyi.quality.mapper.QualityTestStandardParamMapper;
-import com.ruoyi.quality.pojo.QualityInspect;
-import com.ruoyi.quality.pojo.QualityInspectParam;
-import com.ruoyi.quality.pojo.QualityTestStandard;
-import com.ruoyi.quality.pojo.QualityTestStandardParam;
-import com.ruoyi.sales.mapper.*;
-import com.ruoyi.sales.pojo.*;
+import com.ruoyi.sales.mapper.CommonFileMapper;
+import com.ruoyi.sales.pojo.CommonFile;
 import com.ruoyi.sales.service.impl.CommonFileServiceImpl;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
@@ -55,18 +40,8 @@
     private final SysUserMapper sysUserMapper;
     private final ISysNoticeService sysNoticeService;
     private final CommonFileMapper fileMapper;
-    private final DeviceRepairMapper deviceRepairMapper;
-    private final PurchaseLedgerMapper purchaseLedgerMapper;
-    private final SalesQuotationMapper salesQuotationMapper;
-    private final ShippingInfoMapper shippingInfoMapper;
-    private final ShippingProductDetailMapper shippingProductDetailMapper;
     private final CommonFileServiceImpl commonFileService;
-    private final StockUtils stockUtils;
-    private final SalesLedgerProductMapper salesLedgerProductMapper;
-    private final QualityInspectMapper qualityInspectMapper;
-    private final QualityTestStandardMapper qualityTestStandardMapper;
-    private final QualityTestStandardParamMapper qualityTestStandardParamMapper;
-    private final QualityInspectParamMapper qualityInspectParamMapper;
+    private final ApproveBusinessStatusService approveBusinessStatusService;
     private final FileUtil fileUtil;
 
 
@@ -162,74 +137,7 @@
         }
         approveProcessMapper.updateById(approveProcess);
 
-        //閲囪喘瀹℃牳
-        if (approveProcess.getApproveType().equals(5)) {
-            PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectOne(new LambdaQueryWrapper<PurchaseLedger>()
-                    .eq(PurchaseLedger::getPurchaseContractNumber, approveProcess.getApproveReason())
-                    .last("limit 1"));
-            if (purchaseLedger != null) {
-                if (status.equals(2)) {
-                    // 鍚屾剰
-                    purchaseLedger.setApprovalStatus(3);
-                    List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectList(new QueryWrapper<SalesLedgerProduct>()
-                            .lambda().eq(SalesLedgerProduct::getSalesLedgerId, purchaseLedger.getId()).eq(SalesLedgerProduct::getType, 2));
-                    for (SalesLedgerProduct salesLedgerProduct : salesLedgerProducts) {
-                        // 璐ㄦ
-                        if (salesLedgerProduct.getIsChecked()) {
-                            addQualityInspect(purchaseLedger, salesLedgerProduct);
-                        } else {
-                            //鐩存帴鍏ュ簱
-                            stockUtils.addStockWithBatchNo(salesLedgerProduct.getProductModelId(), salesLedgerProduct.getQuantity(), StockInQualifiedRecordTypeEnum.PURCHASE_STOCK_IN.getCode(), purchaseLedger.getId(), purchaseLedger.getPurchaseContractNumber() + "-" + salesLedgerProduct.getId());
-                        }
-                    }
-                } else if (status.equals(3)) {
-                    // 鎷掔粷
-                    purchaseLedger.setApprovalStatus(4);
-                } else if (status.equals(1)) {
-                    // 瀹℃牳涓�
-                    purchaseLedger.setApprovalStatus(2);
-                }
-                purchaseLedgerMapper.updateById(purchaseLedger);
-            }
-        }
-        // 閿�鍞姤浠风姸鎬佷慨鏀�
-        if (approveProcess.getApproveType().equals(6)) {
-            SalesQuotation salesQuote = salesQuotationMapper.selectOne(new LambdaQueryWrapper<SalesQuotation>()
-                    .eq(SalesQuotation::getQuotationNo, approveProcess.getApproveReason())
-                    .last("limit 1"));
-            // 鍚屾剰
-            if (status.equals(2) && salesQuote != null) {
-                salesQuote.setStatus("閫氳繃");
-            } else if (status.equals(3) && salesQuote != null) {
-                salesQuote.setStatus("鎷掔粷");
-            } else if (status.equals(1) && salesQuote != null) {
-                salesQuote.setStatus("瀹℃牳涓�");
-            }
-            salesQuotationMapper.updateById(salesQuote);
-        }
-        // 鍑哄簱瀹℃壒淇敼=鍙戣揣瀹℃壒
-        if (approveProcess.getApproveType().equals(7)) {
-            ShippingInfo shippingInfo = shippingInfoMapper.selectOne(new LambdaQueryWrapper<ShippingInfo>()
-                    .eq(ShippingInfo::getShippingNo, approveProcess.getApproveReason())
-                    .orderByDesc(ShippingInfo::getCreateTime)
-                    .last("limit 1"));
-            if (shippingInfo != null) {
-                if (status.equals(2)) {
-                    shippingInfo.setStatus("瀹℃牳閫氳繃");
-                    shippingInfo.setShippingDate(new Date());
-                    //鏇存敼鍑哄簱瀹℃牳鐘舵�侊紙寰呯‘璁ゆ敼鎴愬緟瀹℃牳锛�
-                    stockUtils.shipmentStatus(StockOutQualifiedRecordTypeEnum.SALE_SHIP_STOCK_OUT.getCode(), shippingInfo.getId());
-                } else if (status.equals(3)) {
-                    //鍒犻櫎鍘熸湰锛堝緟纭锛夌殑鍑哄簱瀹℃牳鐘舵��
-                    stockUtils.deleteStockOutRecord(shippingInfo.getId(), StockOutQualifiedRecordTypeEnum.SALE_SHIP_STOCK_OUT.getCode());
-                    shippingInfo.setStatus("瀹℃牳鎷掔粷");
-                } else if (status.equals(1)) {
-                    shippingInfo.setStatus("瀹℃牳涓�");
-                }
-                shippingInfoMapper.updateById(shippingInfo);
-            }
-
-        }
+        approveBusinessStatusService.syncBusinessStatus(approveProcess.getApproveType(), approveProcess.getApproveReason(), status);
         fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.APPROVE_NODE, approveNode.getId(), approveNode.getStorageBlobDTOS());
     }
 
@@ -305,34 +213,6 @@
                 return "鍔炲叕鐢ㄥ搧瀹℃壒";
         }
         return null;
-    }
-
-    private void addQualityInspect(PurchaseLedger purchaseLedger, SalesLedgerProduct saleProduct) {
-        QualityInspect qualityInspect = new QualityInspect();
-        qualityInspect.setInspectType(0);
-        qualityInspect.setSupplier(purchaseLedger.getSupplierName());
-        qualityInspect.setPurchaseLedgerId(purchaseLedger.getId());
-        qualityInspect.setProductId(saleProduct.getProductId());
-        qualityInspect.setProductName(saleProduct.getProductCategory());
-        qualityInspect.setModel(saleProduct.getSpecificationModel());
-        qualityInspect.setProductModelId(saleProduct.getProductModelId());
-        qualityInspect.setUnit(saleProduct.getUnit());
-        qualityInspect.setQuantity(saleProduct.getQuantity());
-        qualityInspectMapper.insert(qualityInspect);
-        List<QualityTestStandard> qualityTestStandard = qualityTestStandardMapper.getQualityTestStandardByProductId(saleProduct.getProductId(), 0, null);
-        if (qualityTestStandard.size() > 0) {
-            qualityInspect.setTestStandardId(qualityTestStandard.get(0).getId());
-            qualityInspectMapper.updateById(qualityInspect);
-            qualityTestStandardParamMapper.selectList(Wrappers.<QualityTestStandardParam>lambdaQuery()
-                            .eq(QualityTestStandardParam::getTestStandardId, qualityTestStandard.get(0).getId()))
-                    .forEach(qualityTestStandardParam -> {
-                        QualityInspectParam param = new QualityInspectParam();
-                        com.ruoyi.common.utils.bean.BeanUtils.copyProperties(qualityTestStandardParam, param);
-                        param.setId(null);
-                        param.setInspectId(qualityInspect.getId());
-                        qualityInspectParamMapper.insert(param);
-                    });
-        }
     }
 
 }

--
Gitblit v1.9.3