From 66c6ab9883ecb5e0595f02fec6b66e962d1fbf67 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期三, 03 六月 2026 10:12:23 +0800
Subject: [PATCH] Merge branch 'dev_New_pro' into dev_宁夏_英泽防锈

---
 src/main/java/com/ruoyi/approve/service/impl/ApprovalInstanceServiceImpl.java |  155 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 154 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/ruoyi/approve/service/impl/ApprovalInstanceServiceImpl.java b/src/main/java/com/ruoyi/approve/service/impl/ApprovalInstanceServiceImpl.java
index 5c5e540..931159e 100644
--- a/src/main/java/com/ruoyi/approve/service/impl/ApprovalInstanceServiceImpl.java
+++ b/src/main/java/com/ruoyi/approve/service/impl/ApprovalInstanceServiceImpl.java
@@ -12,6 +12,8 @@
 import com.ruoyi.approve.mapper.ApprovalInstanceMapper;
 import com.ruoyi.approve.mapper.ApprovalTemplateNodeApproverMapper;
 import com.ruoyi.approve.mapper.FinReimbursementMapper;
+import com.ruoyi.approve.mapper.VehicleBorrowRecordMapper;
+import com.ruoyi.approve.mapper.VehicleMapper;
 import com.ruoyi.approve.pojo.*;
 import com.ruoyi.approve.service.*;
 import com.ruoyi.approve.utils.ApproveProcessConfigNodeUtils;
@@ -86,6 +88,8 @@
     private final SalesQuotationMapper salesQuotationMapper;
     private final ShippingInfoMapper shippingInfoMapper;
     private final QualityInspectHelper qualityInspectHelper;
+    private final VehicleBorrowRecordMapper vehicleBorrowRecordMapper;
+    private final VehicleMapper vehicleMapper;
     private final EnterpriseNewsScopeUserMapper enterpriseNewsScopeUserMapper;
     private final SysUserMapper sysUserMapper;
     private final SysUserDeptMapper sysUserDeptMapper;
@@ -105,6 +109,30 @@
         }
         records.forEach(vo -> {
             vo.setBusinessName(TypeEnums.getLabelByValue(vo.getBusinessType()));
+
+            // 鏍规嵁涓氬姟绫诲瀷鏌ヨ瀵瑰簲鐨勫崟鍙�
+            if (vo.getBusinessType() != null && vo.getBusinessId() != null) {
+                if (TypeEnums.PURCHASE_APPROVAL.getCode().equals(vo.getBusinessType())) {
+                    // 閲囪喘瀹℃壒 - 鏌ヨ閲囪喘鍗曞彿
+                    PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(vo.getBusinessId());
+                    System.out.println("涓氬姟绫诲瀷锛�" + purchaseLedger.getPurchaseContractNumber());
+                    if (purchaseLedger != null) {
+                        vo.setPurchaseContractNumber(purchaseLedger.getPurchaseContractNumber());
+                    }
+                } else if (TypeEnums.QUOTATION_APPROVAL.getCode().equals(vo.getBusinessType())) {
+                    // 鎶ヤ环瀹℃壒 - 鏌ヨ鎶ヤ环鍗曞彿
+                    SalesQuotation salesQuotation = salesQuotationMapper.selectById(vo.getBusinessId());
+                    if (salesQuotation != null) {
+                        vo.setQuotationNo(salesQuotation.getQuotationNo());
+                    }
+                } else if (TypeEnums.SHIPPING_APPROVAL.getCode().equals(vo.getBusinessType())) {
+                    // 鍙戣揣瀹℃壒 - 鏌ヨ鍙戣揣鍗曞彿
+                    ShippingInfo shippingInfo = shippingInfoMapper.selectById(vo.getBusinessId());
+                    if (shippingInfo != null) {
+                        vo.setShippingNo(shippingInfo.getShippingNo());
+                    }
+                }
+            }
         });
         Long currentUserId = SecurityUtils.getUserId();
 
@@ -396,6 +424,8 @@
         instance.setStatus("REJECTED");
         instance.setFinishTime(now);
         this.updateById(instance);
+        // 缁熶竴澶勭悊涓氬姟鐘舵�佹洿鏂�
+        handleBusinessAfterApprovalFinished(instance);
         // 椹冲洖瀵瑰簲鐨勪紒涓氭柊闂伙紝 宸梾鎶ラ攢
         if (instance.getBusinessType().equals(TypeEnums.ENTERPRISE_NEWS_APPROVAL.getCode())) {
             enterpriseNewsMapper.update(
@@ -408,6 +438,26 @@
                     new LambdaUpdateWrapper<FinReimbursement>()
                             .eq(FinReimbursement::getId, instance.getBusinessId())
                             .set(FinReimbursement::getBillStatus, "REJECTED")
+            );
+        } else if (TypeEnums.VEHICLE_BORROW_APPROVAL.getCode().equals(instance.getBusinessType())) {
+            vehicleBorrowRecordMapper.update(
+                    null,
+                    new LambdaUpdateWrapper<VehicleBorrowRecord>()
+                            .eq(VehicleBorrowRecord::getId, instance.getBusinessId())
+                            .set(VehicleBorrowRecord::getBorrowStatus, "REJECTED")
+                            .set(VehicleBorrowRecord::getApprovalInstanceId, instance.getId())
+            );
+            VehicleBorrowRecord borrowRecord = vehicleBorrowRecordMapper.selectById(instance.getBusinessId());
+            if (borrowRecord != null) {
+                syncVehicleBorrowStatus(borrowRecord.getVehicleId());
+            }
+        } else if (TypeEnums.VEHICLE_DELAY_APPROVAL.getCode().equals(instance.getBusinessType())) {
+            vehicleBorrowRecordMapper.update(
+                    null,
+                    new LambdaUpdateWrapper<VehicleBorrowRecord>()
+                            .eq(VehicleBorrowRecord::getId, instance.getBusinessId())
+                            .set(VehicleBorrowRecord::getExtendStatus, "REJECTED")
+                            .set(VehicleBorrowRecord::getExtendApprovalInstanceId, null)
             );
         }
         return R.ok("瀹℃壒宸查┏鍥�");
@@ -538,6 +588,11 @@
         }
         if (TypeEnums.ENTERPRISE_NEWS_APPROVAL.getCode().equals(businessType)) {
             handleNewsApprovalFinished(instance, status);
+            return;
+        }
+        if (TypeEnums.VEHICLE_BORROW_APPROVAL.getCode().equals(businessType)
+                || TypeEnums.VEHICLE_DELAY_APPROVAL.getCode().equals(businessType)) {
+            handleVehicleBorrowApprovalFinished(instance, status);
         }
     }
 
@@ -658,7 +713,7 @@
     private void handleShippingApprovalFinished(ApprovalInstance instance, String status) {
         ShippingInfo shippingInfo = shippingInfoMapper.selectOne(
                 new LambdaQueryWrapper<ShippingInfo>()
-                        .eq(ShippingInfo::getId, instance.getTitle())
+                        .eq(ShippingInfo::getShippingNo, instance.getTitle())
                         .orderByDesc(ShippingInfo::getCreateTime)
                         .last("limit 1")
         );
@@ -679,6 +734,104 @@
         shippingInfoMapper.updateById(shippingInfo);
     }
 
+    private void handleVehicleBorrowApprovalFinished(ApprovalInstance instance, String status) {
+        if (instance == null || instance.getBusinessId() == null) {
+            return;
+        }
+
+        VehicleBorrowRecord record = vehicleBorrowRecordMapper.selectById(instance.getBusinessId());
+        if (record == null || Integer.valueOf(1).equals(record.getDeleted())) {
+            return;
+        }
+
+        if (TypeEnums.VEHICLE_BORROW_APPROVAL.getCode().equals(instance.getBusinessType())) {
+            if ("APPROVED".equals(status)) {
+                Vehicle vehicle = vehicleMapper.selectById(record.getVehicleId());
+                if (vehicle == null) {
+                    throw new ServiceException("杞﹁締涓嶅瓨鍦�");
+                }
+                VehicleBorrowRecord update = new VehicleBorrowRecord();
+                update.setId(record.getId());
+                update.setBorrowStatus("BORROWING");
+                update.setApprovedTime(instance.getFinishTime());
+                update.setApprovalInstanceId(instance.getId());
+                vehicleBorrowRecordMapper.updateById(update);
+                syncVehicleBorrowStatus(vehicle.getId());
+                return;
+            }
+            if ("REJECTED".equals(status)) {
+                VehicleBorrowRecord update = new VehicleBorrowRecord();
+                update.setId(record.getId());
+                update.setBorrowStatus("REJECTED");
+                update.setApprovalInstanceId(instance.getId());
+                vehicleBorrowRecordMapper.updateById(update);
+                syncVehicleBorrowStatus(record.getVehicleId());
+                return;
+            }
+            if ("PENDING".equals(status)) {
+                VehicleBorrowRecord update = new VehicleBorrowRecord();
+                update.setId(record.getId());
+                update.setBorrowStatus("IN_APPROVAL");
+                update.setApprovalInstanceId(instance.getId());
+                vehicleBorrowRecordMapper.updateById(update);
+            }
+            return;
+        }
+
+        if (TypeEnums.VEHICLE_DELAY_APPROVAL.getCode().equals(instance.getBusinessType())) {
+            if ("APPROVED".equals(status)) {
+                vehicleBorrowRecordMapper.update(
+                        null,
+                        new LambdaUpdateWrapper<VehicleBorrowRecord>()
+                                .eq(VehicleBorrowRecord::getId, record.getId())
+                                .set(VehicleBorrowRecord::getBorrowStatus, "BORROWING")
+                                .set(VehicleBorrowRecord::getExtendStatus, "APPROVED")
+                                .set(VehicleBorrowRecord::getExtendApprovedTime, instance.getFinishTime())
+                                .set(VehicleBorrowRecord::getPlannedReturnTime, record.getExtendTargetReturnTime())
+                                .set(VehicleBorrowRecord::getExtendApprovalInstanceId, null)
+                );
+                return;
+            }
+            if ("REJECTED".equals(status)) {
+                vehicleBorrowRecordMapper.update(
+                        null,
+                        new LambdaUpdateWrapper<VehicleBorrowRecord>()
+                                .eq(VehicleBorrowRecord::getId, record.getId())
+                                .set(VehicleBorrowRecord::getExtendStatus, "REJECTED")
+                                .set(VehicleBorrowRecord::getExtendApprovalInstanceId, null)
+                );
+                return;
+            }
+            if ("PENDING".equals(status)) {
+                VehicleBorrowRecord update = new VehicleBorrowRecord();
+                update.setId(record.getId());
+                update.setExtendStatus("PENDING");
+                update.setExtendApprovalInstanceId(instance.getId());
+                vehicleBorrowRecordMapper.updateById(update);
+            }
+        }
+    }
+
+    private void syncVehicleBorrowStatus(Long vehicleId) {
+        if (vehicleId == null) {
+            return;
+        }
+        long activeBorrowCount = vehicleBorrowRecordMapper.selectCount(
+                new LambdaQueryWrapper<VehicleBorrowRecord>()
+                        .eq(VehicleBorrowRecord::getVehicleId, vehicleId)
+                        .eq(VehicleBorrowRecord::getDeleted, 0)
+                        .in(VehicleBorrowRecord::getBorrowStatus, "IN_APPROVAL", "BORROWING")
+        );
+        Vehicle vehicle = vehicleMapper.selectById(vehicleId);
+        if (vehicle == null) {
+            throw new ServiceException("杞﹁締涓嶅瓨鍦�");
+        }
+        Vehicle vehicleUpdate = new Vehicle();
+        vehicleUpdate.setId(vehicleId);
+        vehicleUpdate.setStatus(activeBorrowCount > 0 ? "IN_USE" : "IDLE");
+        vehicleMapper.updateById(vehicleUpdate);
+    }
+
     private List<ApprovalTask> createNodeAndTasks(ApprovalInstance instance, ApprovalTemplateNode templateNode) {
         List<ApprovalTemplateNodeApprover> approvers = approvalTemplateNodeApproverMapper.selectList(
                 new LambdaQueryWrapper<ApprovalTemplateNodeApprover>()

--
Gitblit v1.9.3