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