From 5e2d67a0ceb54e408aeb34f64031f4b7f349c862 Mon Sep 17 00:00:00 2001
From: dimengzhe <dimengzhe>
Date: Mon, 28 Apr 2025 16:58:10 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../loanbuckleapply/LoanBuckleApplyService.java  | 16 ++++++++++++++--
 1 file changed, 14 insertions(+), 2 deletions(-)

diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbuckleapply/LoanBuckleApplyService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbuckleapply/LoanBuckleApplyService.java
index 0e7494035c..1749b8eb80 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbuckleapply/LoanBuckleApplyService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanbuckleapply/LoanBuckleApplyService.java
@@ -666,8 +666,20 @@ public class LoanBuckleApplyService extends MybatisBaseService<LoanBuckleApplyMa
                         }
                     }
                 }
-                //推送划扣凭证
-                pushBuckleVoucher(businessSid);
+
+                try {
+                    ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                            .setNameFormat("demo-pool-%d").build();
+                    ExecutorService pool = new ThreadPoolExecutor(2, 100,
+                            0L, TimeUnit.MILLISECONDS,
+                            new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+                    Future future1 = pool.submit(() -> {
+                        //推送划扣凭证
+                        pushBuckleVoucher(businessSid);
+                    });
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
                 //推送转累欠凭证
                 pushLaterBuckleVoucher(businessSid);
             } else {