From 880fc56d1342d873a8ed17de3a61afcb194c365e Mon Sep 17 00:00:00 2001
From: wujianwei <wjw@11.com>
Date: 星期二, 23 十二月 2025 10:41:13 +0800
Subject: [PATCH] 新增作废

---
 service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java |  329 ++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 312 insertions(+), 17 deletions(-)

diff --git a/service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java b/service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java
index 73ced5b..5484a48 100644
--- a/service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java
+++ b/service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java
@@ -1,9 +1,23 @@
 package com.ruoyi.cwgl.service.impl;
 
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 
+import com.ruoyi.common.enums.SystemDataNoEnum;
+import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.DateUtils;
-import javax.annotation.Resource;
+import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.cwgl.domain.ReceivableFeeDetail;
+import com.ruoyi.cwgl.domain.ReceivableFeeManagementLog;
+import com.ruoyi.cwgl.domain.vo.ReceivableFeeStatisticsVo;
+import com.ruoyi.cwgl.service.*;
+import com.ruoyi.system.domain.SysConfig;
+import com.ruoyi.system.mapper.SysConfigMapper;
+import com.ruoyi.system.service.ISystemDataNoService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.stereotype.Service;
 import org.springframework.scheduling.annotation.Async;
@@ -17,8 +31,12 @@
 
 import com.ruoyi.cwgl.mapper.ReceivableFeeManagementMapper;
 import com.ruoyi.cwgl.domain.ReceivableFeeManagement;
-import com.ruoyi.cwgl.service.IReceivableFeeManagementService;
+import com.ruoyi.cwgl.domain.ReceivableBillManagement;
+import com.ruoyi.cwgl.domain.ReceivableBillSettlementDetail;
+import com.ruoyi.cwgl.domain.vo.ReceivableBillCreateVo;
 import com.ruoyi.common.core.text.Convert;
+
+import javax.annotation.Resource;
 
 /**
  * 搴旀敹璐圭敤绠$悊Service涓氬姟灞傚鐞�
@@ -33,7 +51,23 @@
     protected final Logger logger = LoggerFactory.getLogger(getClass());
     @Resource
     private ReceivableFeeManagementMapper receivableFeeManagementMapper;
+    
+    @Autowired
+    private IReceivableFeeDetailService receivableFeeDetailService;
 
+    @Resource
+    private SysConfigMapper sysConfigMapper;
+
+    @Autowired
+    private IReceivableBillManagementService receivableBillManagementService;
+
+
+
+    @Autowired
+    ISystemDataNoService systemDataNoService;
+
+    @Autowired
+    private IReceivableFeeManagementLogService logService;
 
     /**
      * 鏌ヨ搴旀敹璐圭敤绠$悊
@@ -45,7 +79,15 @@
     @Override
     public ReceivableFeeManagement selectReceivableFeeManagementById(Integer id)
     {
-        return receivableFeeManagementMapper.selectReceivableFeeManagementById(id);
+        ReceivableFeeManagement receivableFeeManagement = receivableFeeManagementMapper.selectReceivableFeeManagementById(id);
+        if (receivableFeeManagement != null) {
+            // 鏌ヨ瀵瑰簲鐨勮垂鐢ㄦ槑缁�
+            ReceivableFeeDetail detail = new ReceivableFeeDetail();
+            detail.setReceivableFeeId(id);
+            List<ReceivableFeeDetail> detailList = receivableFeeDetailService.selectReceivableFeeDetailList(detail);
+            receivableFeeManagement.setReceivableFeeDetailList(detailList);
+        }
+        return receivableFeeManagement;
     }
 
     /**
@@ -103,20 +145,39 @@
     public int insertReceivableFeeManagement(ReceivableFeeManagement receivableFeeManagement)
     {
         receivableFeeManagement.setCreateTime(DateUtils.getNowDate());
-        return receivableFeeManagementMapper.insertReceivableFeeManagement(receivableFeeManagement);
-    }
+        String noByKey = systemDataNoService.getNoByKey(SystemDataNoEnum.YS);
+        receivableFeeManagement.setSystemNo(noByKey);
 
-    /**
-     * 鏂板搴旀敹璐圭敤绠$悊[鎵归噺]
-     *
-     * @param receivableFeeManagements 搴旀敹璐圭敤绠$悊
-     * @return 缁撴灉
-     */
-    @Override
-    public int insertReceivableFeeManagementBatch(List<ReceivableFeeManagement> receivableFeeManagements)
-    {
-        int rows = receivableFeeManagementMapper.insertReceivableFeeManagementBatch(receivableFeeManagements);
-        return rows;
+        // 淇濆瓨涓昏〃淇℃伅
+        int result = receivableFeeManagementMapper.insertReceivableFeeManagement(receivableFeeManagement);
+        
+        // 鑾峰彇涓昏〃ID
+        Integer receivableFeeId = receivableFeeManagement.getId();
+        
+        // 鎵归噺淇濆瓨鏄庣粏鍒楄〃
+        if (receivableFeeManagement.getReceivableFeeDetailList() != null && !receivableFeeManagement.getReceivableFeeDetailList().isEmpty()) {
+            // 璁剧疆姣忎釜鏄庣粏鐨勫簲鏀惰垂鐢ㄧ鐞咺D
+            receivableFeeManagement.getReceivableFeeDetailList().forEach(detail -> {
+                detail.setReceivableFeeId(receivableFeeId);
+                detail.setCreateTime(DateUtils.getNowDate()); // 璁剧疆鍒涘缓鏃堕棿
+            });
+            
+            // 璋冪敤鎵归噺鎻掑叆鏂规硶
+            receivableFeeDetailService.insertReceivableFeeDetailBatch(receivableFeeManagement.getReceivableFeeDetailList());
+        }
+        
+        // 璁板綍鎿嶄綔鏃ュ織
+        if (result > 0) {
+            ReceivableFeeManagementLog log = new ReceivableFeeManagementLog();
+            log.setReceivableFeeId(receivableFeeId);
+            log.setOperator(SecurityUtils.getUsername());
+            log.setOperationTime(DateUtils.getNowDate());
+            log.setOperationDesc("鏂板搴旀敹璐圭敤绠$悊璁板綍锛岀郴缁熺紪鍙凤細" + receivableFeeManagement.getSystemNo());
+            log.setCreateTime(DateUtils.getNowDate());
+            logService.insertReceivableFeeManagementLog(log);
+        }
+        
+        return result;
     }
 
     /**
@@ -129,7 +190,95 @@
     public int updateReceivableFeeManagement(ReceivableFeeManagement receivableFeeManagement)
     {
         receivableFeeManagement.setUpdateTime(DateUtils.getNowDate());
-        return receivableFeeManagementMapper.updateReceivableFeeManagement(receivableFeeManagement);
+        
+        // 1. 鏇存柊涓昏〃淇℃伅
+        int result = receivableFeeManagementMapper.updateReceivableFeeManagement(receivableFeeManagement);
+        
+        // 2. 鑾峰彇涓昏〃ID
+        Integer receivableFeeId = receivableFeeManagement.getId();
+        
+        // 3. 鍒犻櫎璇ュ簲鏀惰垂鐢ㄤ笅鐨勬墍鏈夌幇鏈夋槑缁�
+        receivableFeeDetailService.deleteReceivableFeeDetailByReceivableFeeId(receivableFeeId);
+        
+        // 4. 鎵归噺淇濆瓨鏂扮殑鏄庣粏鍒楄〃
+        if (receivableFeeManagement.getReceivableFeeDetailList() != null && !receivableFeeManagement.getReceivableFeeDetailList().isEmpty()) {
+            // 璁剧疆姣忎釜鏄庣粏鐨勫簲鏀惰垂鐢ㄧ鐞咺D
+            receivableFeeManagement.getReceivableFeeDetailList().forEach(detail -> {
+                detail.setReceivableFeeId(receivableFeeId);
+                detail.setUpdateTime(DateUtils.getNowDate()); // 璁剧疆鏇存柊鏃堕棿
+            });
+            
+            // 璋冪敤鎵归噺鎻掑叆鏂规硶
+            receivableFeeDetailService.insertReceivableFeeDetailBatch(receivableFeeManagement.getReceivableFeeDetailList());
+        }
+        
+        // 璁板綍鎿嶄綔鏃ュ織
+        if (result > 0) {
+            ReceivableFeeManagementLog log = new ReceivableFeeManagementLog();
+            log.setReceivableFeeId(receivableFeeId);
+            log.setOperator(SecurityUtils.getUsername());
+            log.setOperationTime(DateUtils.getNowDate());
+            log.setOperationDesc("淇敼搴旀敹璐圭敤绠$悊璁板綍锛岀郴缁熺紪鍙凤細" + receivableFeeManagement.getSystemNo());
+            log.setCreateTime(DateUtils.getNowDate());
+            logService.insertReceivableFeeManagementLog(log);
+        }
+        
+        return result;
+    }
+
+    /**
+     * 浣滃簾搴旀敹璐圭敤绠$悊璁板綍
+     *
+     * @param id 搴旀敹璐圭敤绠$悊ID
+     * @return 缁撴灉
+     */
+    @Override
+    public int voidReceivableFeeManagement(Integer id) {
+        // 鏌ヨ璐圭敤绠$悊璁板綍
+        ReceivableFeeManagement feeManagement = receivableFeeManagementMapper.selectReceivableFeeManagementById(id);
+        if (feeManagement == null) {
+            throw new ServiceException("璐圭敤绠$悊璁板綍涓嶅瓨鍦�");
+        }
+        
+        // 鍒ゆ柇鐘舵�佹槸鍚︿负0锛堝緟鐢熸垚璐﹀崟锛夛紝鍙湁鐘舵�佷负0鎵嶈兘浣滃簾
+        if (!"0".equals(feeManagement.getStatus())) {
+            throw new ServiceException("鍙湁鐘舵�佷负寰呯敓鎴愯处鍗曠殑璁板綍鎵嶈兘浣滃簾");
+        }
+        
+        // 璁剧疆鐘舵�佷负浣滃簾锛堝亣璁剧敤"2"琛ㄧず浣滃簾鐘舵�侊級
+        feeManagement.setStatus("2");
+        feeManagement.setUpdateTime(DateUtils.getNowDate());
+        
+        // 鏇存柊璁板綍
+        int result = receivableFeeManagementMapper.updateReceivableFeeManagement(feeManagement);
+        
+        // 璁板綍鎿嶄綔鏃ュ織
+        if (result > 0) {
+            ReceivableFeeManagementLog log = new ReceivableFeeManagementLog();
+            log.setReceivableFeeId(id);
+            log.setOperator(SecurityUtils.getUsername());
+            log.setOperationTime(DateUtils.getNowDate());
+            log.setOperationDesc("浣滃簾搴旀敹璐圭敤绠$悊璁板綍锛岀郴缁熺紪鍙凤細" + feeManagement.getSystemNo());
+            log.setCreateTime(DateUtils.getNowDate());
+            logService.insertReceivableFeeManagementLog(log);
+        }
+        
+        return result;
+    }
+
+
+
+    /**
+     * 鏂板搴旀敹璐圭敤绠$悊[鎵归噺]
+     *
+     * @param receivableFeeManagements 搴旀敹璐圭敤绠$悊
+     * @return 缁撴灉
+     */
+    @Override
+    public int insertReceivableFeeManagementBatch(List<ReceivableFeeManagement> receivableFeeManagements)
+    {
+        int rows = receivableFeeManagementMapper.insertReceivableFeeManagementBatch(receivableFeeManagements);
+        return rows;
     }
 
     /**
@@ -179,4 +328,150 @@
     {
         return receivableFeeManagementMapper.deleteReceivableFeeManagementById(id);
     }
+
+    /**
+     * 鏍规嵁搴旀敹璐圭敤ID鏁扮粍鏌ヨ缁熻淇℃伅鍜屾槑缁�
+     *
+     * @param ids 搴旀敹璐圭敤ID鏁扮粍
+     * @return 鍖呭惈缁熻淇℃伅鍜屾槑缁嗙殑缁撴灉
+     */
+    @DataSource(DataSourceType.SLAVE)
+    @Override
+    public ReceivableFeeStatisticsVo getReceivableFeeStatistics(Integer[] ids)
+    {
+        // 鏌ヨ搴旀敹璐圭敤涓昏〃璁板綍
+        List<ReceivableFeeManagement> receivableFeeList = receivableFeeManagementMapper.selectReceivableFeeManagementByIds(ids);
+        
+        // 妫�鏌ユ墍鏈夎褰曟槸鍚﹀睘浜庡悓涓�涓鎴�
+        if (!receivableFeeList.isEmpty()) {
+            Integer firstCustomerId = receivableFeeList.get(0).getCustomerId();
+            boolean allSameCustomer = receivableFeeList.stream()
+                    .allMatch(item -> Objects.equals(item.getCustomerId(), firstCustomerId));
+            
+            if (!allSameCustomer) {
+                throw new ServiceException("鎵�閫夎褰曞寘鍚笉鍚屽鎴风殑鏁版嵁锛屾棤娉曡繘琛岀粺璁�");
+            }
+        }
+        
+        // 璁$畻鍗曟嵁鏁伴噺
+        int documentCount = receivableFeeList.size();
+        SysConfig sysConfig = sysConfigMapper.selectConfig(new SysConfig() {{
+            setConfigKey("sys.hk.rmb.rate");
+        }});
+        // 璁$畻鎬诲簲鏀堕噾棰�
+        BigDecimal totalReceivableAmount = receivableFeeList.stream()
+                .map(ReceivableFeeManagement::getReceivableAmount)
+                .reduce(BigDecimal.ZERO, BigDecimal::add);
+        
+
+        BigDecimal exchangeRate = new BigDecimal(sysConfig.getConfigValue());
+        BigDecimal totalAmountHkd = totalReceivableAmount.divide(exchangeRate, 2, RoundingMode.HALF_UP);
+        
+
+        // 缁勮杩斿洖缁撴灉
+        ReceivableFeeStatisticsVo result = new ReceivableFeeStatisticsVo();
+        result.setDocumentCount(documentCount);
+        result.setRate(exchangeRate);
+        result.setTotalReceivableAmount(totalReceivableAmount);
+        result.setTotalAmountRmb(totalReceivableAmount);
+        result.setTotalAmountHkd(totalAmountHkd);
+        result.setIds(ids);
+        
+        return result;
+    }
+
+    /**
+     * 鏍规嵁缁熻鏁版嵁鍒涘缓搴旀敹璐﹀崟
+     *
+     * @param billCreateVo 鍖呭惈缁熻鏁版嵁鍜岃处鍗曠被鍨嬬殑璇锋眰瀵硅薄
+     * @return 鍒涘缓鐨勫簲鏀惰处鍗旾D
+     */
+    @Override
+    public Integer createReceivableBill(ReceivableBillCreateVo billCreateVo) {
+        // 1. 鍑嗗鏁版嵁
+        ReceivableFeeStatisticsVo statisticsVo = billCreateVo.getStatisticsData();
+        
+        // 妫�鏌ヨ垂鐢ㄧ鐞嗚〃鐨勭姸鎬侊紝鍙湁鐘舵�佷负0鎵嶈兘鍒涘缓璐﹀崟
+        Integer[] feeIds = statisticsVo.getIds();
+        if (feeIds != null && feeIds.length > 0) {
+            for (Integer feeId : feeIds) {
+                ReceivableFeeManagement feeManagement = receivableFeeManagementMapper.selectReceivableFeeManagementById(feeId);
+                if (feeManagement != null && !"0".equals(feeManagement.getStatus())) {
+                    throw new ServiceException("璐圭敤璁板綍ID涓�" + feeId + "鐨勭姸鎬佷笉鏄緟鐢熸垚璐﹀崟锛屾棤娉曞垱寤鸿处鍗�");
+                }
+            }
+        }
+        
+        Integer billType = billCreateVo.getBillType();
+
+        // 2. 鍒涘缓搴旀敹璐﹀崟涓昏褰�
+        ReceivableBillManagement billManagement = new ReceivableBillManagement();
+        billManagement.setDocumentCount(statisticsVo.getDocumentCount());
+        billManagement.setExchangeRate(statisticsVo.getRate());
+        billManagement.setStatus("0"); // 榛樿鑽夌鐘舵��
+        billManagement.setCreateTime(DateUtils.getNowDate());
+        billManagement.setBillName(billCreateVo.getBillName());
+        billManagement.setCustomerName(billCreateVo.getCustomerName());
+        billManagement.setIsInternalSettlement(billCreateVo.getIsInternalSettlement());
+        billManagement.setInternalSettlementUnit(billCreateVo.getInternalSettlementUnit());
+        // 3. 鏍规嵁璐﹀崟绫诲瀷璁剧疆甯佺鍜屾�婚噾棰�
+        if (billType == 0) {
+            // 浜烘皯甯佽处鍗�
+            billManagement.setCurrency("CNY");
+            billManagement.setTotalAmount(statisticsVo.getTotalAmountRmb());
+        } else if (billType == 1) {
+            // 娓竵璐﹀崟
+            billManagement.setCurrency("HKD");
+            billManagement.setTotalAmount(statisticsVo.getTotalAmountHkd());
+        } else {
+            throw new IllegalArgumentException("鏃犳晥鐨勮处鍗曠被鍨嬶細" + billType);
+        }
+        String noByKey = systemDataNoService.getNoByKey(SystemDataNoEnum.YSZD);
+        billManagement.setSystemNo(noByKey);
+        // 4. 淇濆瓨涓昏处鍗曡褰�
+        int i = receivableBillManagementService.insertReceivableBillManagement(billManagement);
+
+        // 5. 鏇存柊搴旀敹璐圭敤涓昏〃鐨勫叧鑱旇处鍗曠紪鍙�
+        if (statisticsVo.getIds() != null && statisticsVo.getIds().length > 0) {
+            // 鑾峰彇鐢熸垚鐨勮处鍗曠郴缁熺紪鍙�
+            String billSystemNo = billManagement.getSystemNo();
+            
+            // 鎵归噺鏇存柊搴旀敹璐圭敤涓昏〃鐨勫叧鑱旇处鍗曠紪鍙�
+            for (Integer feeId : statisticsVo.getIds()) {
+                ReceivableFeeManagement feeManagement = new ReceivableFeeManagement();
+                feeManagement.setId(feeId);
+                feeManagement.setRelatedBillNo(billSystemNo);
+                feeManagement.setStatus("1");
+                receivableFeeManagementMapper.updateReceivableFeeManagement(feeManagement);
+                
+                // 璁板綍鎿嶄綔鏃ュ織
+                ReceivableFeeManagementLog log = new ReceivableFeeManagementLog();
+                log.setReceivableFeeId(feeId);
+                log.setOperator(SecurityUtils.getUsername());
+                log.setOperationTime(DateUtils.getNowDate());
+                log.setOperationDesc("鐢熸垚搴旀敹璐﹀崟锛岃处鍗曠紪鍙凤細" + billSystemNo);
+                log.setCreateTime(DateUtils.getNowDate());
+                logService.insertReceivableFeeManagementLog(log);
+            }
+            
+            // 璋冪敤鎵归噺鏇存柊鏂规硶
+
+        }
+
+        return i;
+    }
+
 }
+    
+    /**
+     * 鏍规嵁鍏宠仈璐﹀崟缂栧彿鎵归噺鏇存柊搴旀敹璐圭敤绠$悊璁板綍
+     * 娓呴櫎鍏宠仈璐﹀崟缂栧彿骞跺皢鐘舵�佹敼涓�0锛堝緟鐢熸垚璐﹀崟锛�
+     * 
+     * @param relatedBillNo 鍏宠仈璐﹀崟缂栧彿
+     * @return 缁撴灉
+     */
+    @Override
+    public int updateReceivableFeeManagementByRelatedBillNo(String relatedBillNo) {
+        return receivableFeeManagementMapper.updateReceivableFeeManagementByRelatedBillNo(relatedBillNo);
+    }
+}
\ No newline at end of file

--
Gitblit v1.8.0