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