Merge remote-tracking branch 'origin/master'

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java

@@ -671,4 +671,8 @@ public class LoanHomevisitFileexamineService extends MybatisBaseService<LoanHome
         }
         return rb.success();
     }
+
+    public String selectByOrderSid(String saleOrderSid) {
+        return baseMapper.selectByOrderSid(saleOrderSid);
+    }
 }

anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitinvestigate/LoanHomevisitInvestigateService.java

@@ -1203,6 +1203,34 @@ public class LoanHomevisitInvestigateService extends MybatisBaseService<LoanHome
         loanHomevisitFileexamineDto.setSaleOrderSid(loanHomevisitInvestigate.getSaleOrderSid());
         loanHomevisitFileexamineService.saveOrUpdateDto(loanHomevisitFileexamineDto);
         busSalesOrderBorrowerFeign.updateBusNo("303",loanHomevisitInvestigate.getSaleOrderBorrowerSid());
+        if("通过".equals(jg)){
+            //销售专员消息推送
+            String orderCreateBySid = loanHomevisitFileexamineService.selectByOrderSid(loanHomevisitInvestigate.getSaleOrderSid());
+            List<String> receIveUserSidList = new ArrayList<>();
+            receIveUserSidList.add(orderCreateBySid);
+            String loanName = baseMapper.selectName(sid);
+            //==================================添加线程
+            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(loanName+"家访考察已通过");
+                    pushMessageQuery.setApp_type("2");
+                    pushMessageQuery.setModuleSid("fec4e243-491a-11ec-94cd-fa163e0cb33c");
+                    pushMessageQuery.setMsgTitle("家访考察通过提醒");
+                    // 消息推送
+                    messageFeign.pushNoUriMessage(pushMessageQuery);
+                });
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
         return rb.success();
     }