还款计划表生成推送站内信

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) {