From 721be5e1c2c6b929883b15a79768122b3401a999 Mon Sep 17 00:00:00 2001
From: God <10745413@qq.com>
Date: Thu, 23 Nov 2023 09:36:27 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E9=80=81=E4=BB=B7=E5=80=BC=E5=AE=A2?=
 =?UTF-8?q?=E6=88=B7=E5=A4=87=E6=A1=88=E5=BE=85=E5=8A=9E=E5=90=8C=E6=97=B6?=
 =?UTF-8?q?=EF=BC=8C=E6=8E=A8=E9=80=81=E9=94=80=E5=94=AE=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E6=8F=90=E9=86=92=EF=BC=8C=E6=8F=90=E9=86=92=EF=BC=9A=E8=AF=B7?=
 =?UTF-8?q?=E5=AF=B9**=EF=BC=88=E5=90=88=E5=90=8C=E5=8F=B7=EF=BC=89?=
 =?UTF-8?q?=E7=9A=84=E5=BC=80=E7=A5=A8=E7=94=B3=E8=AF=B7=E8=BF=9B=E8=A1=8C?=
 =?UTF-8?q?=E4=BB=B7=E5=80=BC=E5=AE=A2=E6=88=B7=E5=A4=87=E6=A1=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../FinBillApplicationService.java            | 50 +++++++++++++++++++
 1 file changed, 50 insertions(+)

diff --git a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/finbillapplication/FinBillApplicationService.java b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/finbillapplication/FinBillApplicationService.java
index 9f2c2b0a5b..8f57671878 100644
--- a/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/finbillapplication/FinBillApplicationService.java
+++ b/anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/finbillapplication/FinBillApplicationService.java
@@ -926,6 +926,31 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica
                     busValcustFilingDto.setBusSid(finBillApplication.getSid());
                     busValcustFilingDto.setBusSource("0");
                     busValcustFilingFeign.save(busValcustFilingDto);
+                    //获取销售专员userSid
+                    List<String> receIveUserSidList = new ArrayList<>();
+                    SysUserVo sysUserVo = sysUserFeign.selectByStaffsid(busSalesOrder.getStaffSid()).getData();
+                    receIveUserSidList.add(sysUserVo.getSid());
+                    //发送通知给销售专员
+                    try {
+                        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                                .setNameFormat("demo-pool-%d").build();
+                        ExecutorService pool = new ThreadPoolExecutor(1, 10,
+                                1000, TimeUnit.MILLISECONDS,
+                                new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+                        Future future1 = pool.submit(() -> {
+                            PushMessageQuery pushMessageQuery = new PushMessageQuery();
+                            pushMessageQuery.setReceivedSids(receIveUserSidList);
+                            pushMessageQuery.setModuleName("业务");
+                            pushMessageQuery.setMsgContent("提醒：请对" + busSalesOrder.getContractNo() + "的开票申请进行价值客户备案。");
+                            pushMessageQuery.setApp_type("2");
+                            pushMessageQuery.setModuleSid("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028");
+                            pushMessageQuery.setMsgTitle("价值客户备案提醒");
+                            // 消息推送
+                            messageFeign.pushNoUriMessage(pushMessageQuery);
+                        });
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
                 } else {//不是高低开
                     for (FinBillVehicleVo finBillVehicleVo : finBillVehicleVos) {
                         int count = finVehicleInvoiceService.selectCountByVinSid(finBillVehicleVo.getVehSid());
@@ -2666,6 +2691,31 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica
                             busValcustFilingDto.setBusSid(finBillApplication.getSid());
                             busValcustFilingDto.setBusSource("0");
                             busValcustFilingFeign.save(busValcustFilingDto);
+                            //获取销售专员userSid
+                            List<String> receIveUserSidList = new ArrayList<>();
+                            SysUserVo sysUserVo = sysUserFeign.selectByStaffsid(busSalesOrder.getStaffSid()).getData();
+                            receIveUserSidList.add(sysUserVo.getSid());
+                            //发送通知给销售专员
+                            try {
+                                ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                                        .setNameFormat("demo-pool-%d").build();
+                                ExecutorService pool = new ThreadPoolExecutor(1, 10,
+                                        1000, TimeUnit.MILLISECONDS,
+                                        new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
+                                Future future1 = pool.submit(() -> {
+                                    PushMessageQuery pushMessageQuery = new PushMessageQuery();
+                                    pushMessageQuery.setReceivedSids(receIveUserSidList);
+                                    pushMessageQuery.setModuleName("业务");
+                                    pushMessageQuery.setMsgContent("提醒：请对" + busSalesOrder.getContractNo() + "的开票申请进行价值客户备案。");
+                                    pushMessageQuery.setApp_type("2");
+                                    pushMessageQuery.setModuleSid("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028");
+                                    pushMessageQuery.setMsgTitle("价值客户备案提醒");
+                                    // 消息推送
+                                    messageFeign.pushNoUriMessage(pushMessageQuery);
+                                });
+                            } catch (Exception e) {
+                                e.printStackTrace();
+                            }
                         }else{
                             int count = finVehicleInvoiceService.selectCountByVinSid(finBillVehicleVo.getVehSid());
                             if (count == 0) {