From 2ab9bd5cb5b91855afec01632ef07180d765487c Mon Sep 17 00:00:00 2001
From: fanzongzhe <285169773@qq.com>
Date: Fri, 29 Dec 2023 17:46:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=98=E6=AC=BE=E8=AE=A1=E5=88=92=E8=A1=A8?=
 =?UTF-8?q?=E7=94=9F=E6=88=90=E6=8E=A8=E9=80=81=E7=AB=99=E5=86=85=E4=BF=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../LoanRepaymentScheduleService.java         | 43 ++++++++++++-------
 1 file changed, 28 insertions(+), 15 deletions(-)

diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymentschedule/LoanRepaymentScheduleService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymentschedule/LoanRepaymentScheduleService.java
index 23d13b1b48..c6d64693d6 100644
--- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymentschedule/LoanRepaymentScheduleService.java
+++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanrepaymentschedule/LoanRepaymentScheduleService.java
@@ -59,6 +59,7 @@ import com.yxt.common.core.result.ResultBean;
 import com.yxt.common.core.vo.PagerVo;
 import com.yxt.messagecenter.api.message.MessageFeign;
 import com.yxt.messagecenter.api.message.MessagePushTransferDto;
+import com.yxt.messagecenter.api.message.PushMessageQuery;
 import com.yxt.messagecenter.api.messagelist.MessageListDto;
 import org.apache.tomcat.util.threads.ThreadPoolExecutor;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -1108,21 +1109,33 @@ public class LoanRepaymentScheduleService extends MybatisBaseService<LoanRepayme
                         System.out.println("还款发送短信：" + res);
                         System.out.println(contentCustomer);
                         String contentStaff = "您的贷款客户" + customer + "的还款计划表已生成";
-                        //消息推送
-                        MessagePushTransferDto messagePushTransferDto = new MessagePushTransferDto();
-                        messagePushTransferDto.setMsgTypeSid("bc59c198-2d51-458f-913e-cbd8d7ef4799");
-                        messagePushTransferDto.setMsgType("业务");
-                        messagePushTransferDto.setMsgTitle("生成还款计划表");
-                        messagePushTransferDto.setMsgContent(contentStaff);
-                        messagePushTransferDto.setMsgSource("还款计划表");
-                        messagePushTransferDto.setSenderSid(sendSid);
-                        messagePushTransferDto.setSenderName(sendName);
-                        messagePushTransferDto.setSenderDeptSid(sendDeptSid);
-                        messagePushTransferDto.setSenderDeptName(sendDept);
-                        messagePushTransferDto.setBusinessSid(schedule.getSid());
-                        messagePushTransferDto.setReceiveSids(staffSid);
-                        messagePushTransferDto.setReceiveNames(staffName);
-                        messageFeign.pushTransferMessage(messagePushTransferDto);
+//                        //消息推送
+//                        MessagePushTransferDto messagePushTransferDto = new MessagePushTransferDto();
+//                        messagePushTransferDto.setMsgTypeSid("bc59c198-2d51-458f-913e-cbd8d7ef4799");
+//                        messagePushTransferDto.setMsgType("业务");
+//                        messagePushTransferDto.setMsgTitle("生成还款计划表");
+//                        messagePushTransferDto.setMsgContent(contentStaff);
+//                        messagePushTransferDto.setMsgSource("还款计划表");
+//                        messagePushTransferDto.setSenderSid(sendSid);
+//                        messagePushTransferDto.setSenderName(sendName);
+//                        messagePushTransferDto.setSenderDeptSid(sendDeptSid);
+//                        messagePushTransferDto.setSenderDeptName(sendDept);
+//                        messagePushTransferDto.setBusinessSid(schedule.getSid());
+//                        messagePushTransferDto.setReceiveSids(staffSid);
+//                        messagePushTransferDto.setReceiveNames(staffName);
+//                        messageFeign.pushTransferMessage(messagePushTransferDto);
+                        //发送通知给销售专员
+                        List<String> receIveUserSidList = new ArrayList<>();
+                        receIveUserSidList.add(staffSid);
+                        PushMessageQuery pushMessageQuery = new PushMessageQuery();
+                        pushMessageQuery.setReceivedSids(receIveUserSidList);
+                        pushMessageQuery.setModuleName("风控");
+                        pushMessageQuery.setMsgContent(contentStaff);
+                        pushMessageQuery.setApp_type("2");
+                        pushMessageQuery.setModuleSid("fec4e243-491a-11ec-94cd-fa163e0cb33c");
+                        pushMessageQuery.setMsgTitle("还款计划提醒");
+                        // 消息推送
+                        messageFeign.pushNoUriMessage(pushMessageQuery);
                     }
                 });
             } catch (Exception e) {