From a88428b648cfe976ffbfddb6290f65094fd8a910 Mon Sep 17 00:00:00 2001
From: fanzongzhe <285169773@qq.com>
Date: Thu, 28 Mar 2024 16:12:13 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=8E=A8=E9=80=81=E5=87=AD?=
 =?UTF-8?q?=E8=AF=81=E5=92=8C=E5=88=92=E6=89=A3=E5=90=88=E5=B9=B6=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../FinCollectionConfirmationService.java     | 31 ++---------------
 .../LoanRepaymentHistoryMapper.java           |  2 ++
 .../LoanRepaymentHistoryMapper.xml            | 33 +++++++++++++++++++
 .../LoanRepaymentHistoryService.java          | 20 ++++++-----
 4 files changed, 49 insertions(+), 37 deletions(-)

diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fincollectionconfirmation/FinCollectionConfirmationService.java b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fincollectionconfirmation/FinCollectionConfirmationService.java
index 0b3ba5684f..0901817e2c 100644
--- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fincollectionconfirmation/FinCollectionConfirmationService.java
+++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/fincollectionconfirmation/FinCollectionConfirmationService.java
@@ -3768,37 +3768,10 @@ public class FinCollectionConfirmationService extends MybatisBaseService<FinColl
                     loanRepaymentHistoryFeign.saveHistoryByEntity(historyEntity);
                 }
                 if (v.getReceivablesName().equals("资方退还垫款")) {
-                    try {
-                        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
-                                .setNameFormat("demo-pool-%d").build();
-                        ExecutorService pool = new org.apache.tomcat.util.threads.ThreadPoolExecutor(1, 10,
-                                1000, TimeUnit.MILLISECONDS,
-                                new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new org.apache.tomcat.util.threads.ThreadPoolExecutor.AbortPolicy());
-                        //推送资方退还垫款收款凭证
-                        Future future = pool.submit(() -> {
-                            pushReturnVoucher(v, sid);
-                        });
-                    } catch (Exception e) {
-                        e.printStackTrace();
-                        log.error("推送数据失败=========================" + e.getMessage());
-                    }
+                    pushReturnVoucher(v, sid);
                 }
                 //推送间还待转付列表
                 if (v.getReceivablesName().equals("月还") || v.getReceivablesName().equals("资方逾期利息")) {
-                    try {
-                        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
-                                .setNameFormat("demo-pool-%d").build();
-                        ExecutorService pool = new org.apache.tomcat.util.threads.ThreadPoolExecutor(1, 10,
-                                1000, TimeUnit.MILLISECONDS,
-                                new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new org.apache.tomcat.util.threads.ThreadPoolExecutor.AbortPolicy());
-                        //推送间还月还收款凭证
-                        Future future = pool.submit(() -> {
-                            pushIndirectVoucher(v, sid);
-                        });
-                    } catch (Exception e) {
-                        e.printStackTrace();
-                        log.error("推送数据失败=========================" + e.getMessage());
-                    }
                     String planSid = "";
                     if (v.getReceivablesName().equals("月还")) {
                         planSid = v.getReceivablesSid();
@@ -3888,6 +3861,8 @@ public class FinCollectionConfirmationService extends MybatisBaseService<FinColl
                             }
                         }
                     }
+                    //推送间还月还收款凭证
+                    pushIndirectVoucher(v, sid);
                 }
                 //认资金占用费消减平台资金占用费
                 if (v.getReceivablesName().equals("资金占用费")) {
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.java
index ef1f1d27cd..c63a0675aa 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.java
@@ -59,4 +59,6 @@ public interface LoanRepaymentHistoryMapper extends BaseMapper<LoanRepaymentHist
     List<NoImportVo> selPlanDetailsByBank(@Param("bankSid") String bankSid, @Param("useOrgSid") String useOrgSid);
 
     int updateTimeByPlanSids(@Param("stringList") List<String> stringList, @Param("formatDate") String formatDate);
+
+    List<String> selNotRuleForBuckSids(@Param("useOrgSid") String useOrgSid);
 }
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.xml b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.xml
index 5d5ff3df3b..97e396795b 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.xml
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryMapper.xml
@@ -508,5 +508,38 @@
         WHERE a.bankSid = #{bankSid}
           AND a.useOrgSid = #{useOrgSid}
     </select>
+    <select id="selNotRuleForBuckSids" resultType="java.lang.String">
+        SELECT DISTINCT
+        b.sid
+        FROM
+        (
+        SELECT
+        his.*,
+        a.*
+        FROM
+        loan_repayment_history AS his
+        LEFT JOIN loan_repayment_plan_details as p ON his.planDetailSid = p.sid
+        LEFT JOIN (
+        SELECT
+        h.planDetailSid AS ppp,
+        IFNULL( SUM( h.actualMoney ), 0 ) AS sumActualMoney
+        FROM
+        loan_repayment_history AS h
+        WHERE
+        buckleKey != '002'
+        AND buckleKey != '003'
+        AND updateState = 1
+        GROUP BY
+        h.planDetailSid
+        ) a ON his.planDetailSid = a.ppp
+        WHERE
+        his.buckleKey != '002'
+        AND his.buckleKey != '003'
+        AND his.updateState = 1
+        AND p.useOrgSid = #{useOrgSid}
+        ) AS b
+        WHERE
+        sumActualMoney &lt;= 0
+    </select>
 
 </mapper>
\ No newline at end of file
diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryService.java
index ed5cb84abd..1d468dcb98 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymenthistory/LoanRepaymentHistoryService.java
@@ -896,18 +896,20 @@ public class LoanRepaymentHistoryService extends MybatisBaseService<LoanRepaymen
         vo.setApplyDate(sdf.format(new Date()));
         List<LoanBuckleHistoryRecord> historyRecords = new ArrayList<>();
         QueryWrapper<LoanRepaymentHistory> qw = new QueryWrapper<>();
-        //=======================
-        String orgSidPath = orgPath;
-        orgSidPath = orgSidPath + "/";
-        int i1 = orgSidPath.indexOf("/");
-        int i2 = orgSidPath.indexOf("/", i1 + 1);
-        int i3 = orgSidPath.indexOf("/", i2 + 1);
-        int i4 = orgSidPath.indexOf("/", i3 + 1);
-        orgSidPath = orgSidPath.substring(0, i3);
-        qw.like("p.orgSidPath", orgSidPath);
+        String useOrgSid = "";
+        ResultBean<String> orgSidByPath = sysStaffOrgFeign.getOrgSidByPath(orgPath);
+        if (orgSidByPath.getSuccess()) {
+            useOrgSid = orgSidByPath.getData();
+        }
+        List<String> selNotRuleForBuckSids = baseMapper.selNotRuleForBuckSids(useOrgSid);
+        if (selNotRuleForBuckSids.isEmpty()) {
+            selNotRuleForBuckSids = new ArrayList<>();
+        }
+        qw.eq("p.orgSidPath", useOrgSid);
         qw.ne("h.buckleKey", "002");
         qw.ne("h.buckleKey", "003");
         qw.eq("h.updateState", "1");
+        qw.notIn("h.sid",selNotRuleForBuckSids);
         List<RepaymentHistoryVoForBuckle> histories = baseMapper.selbuckleNewInitList(qw);
         Map<String, BigDecimal> countMoney = new HashMap<>();
         Map<String, List<String>> sids = new HashMap<>();