楚江ERP:撤销单审核通过消息通知

@@ -3,8 +3,11 @@ package com.lframework.xingyun.sc.handlers;
 import com.lframework.starter.bpm.dto.FlowInstanceExtDto;
 import com.lframework.starter.bpm.enums.FlowInstanceStatus;
 import com.lframework.starter.bpm.service.BusinessDataHandlerService;
+import com.lframework.starter.mq.core.service.MqProducerService;
 import com.lframework.starter.web.core.components.redis.RedisHandler;
+import com.lframework.starter.web.core.utils.IdUtil;
 import com.lframework.starter.web.core.utils.JsonUtil;
+import com.lframework.starter.web.inner.dto.message.SysSiteMessageDto;
 import com.lframework.xingyun.sc.entity.CorePersonnelHistory;
 import com.lframework.xingyun.sc.entity.PurchaseOrderLine;
 import com.lframework.xingyun.sc.entity.PurchaseOrderRevoke;
@@ -62,6 +65,10 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private PurchaseOrderRevokeLineService purchaseOrderRevokeLineService;
     @Resource
     private OrderSpecificationChangeRecordService orderSpecificationChangeRecordService;
+    @Resource
+    private MqProducerService mqProducerService;
+    @Resource
+    private TransactorHandler transactorHandler;
 
 
     /**
@@ -229,6 +236,50 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
                     purchaseOrderInfoService.updateRevokeStatus(revoke.getPurchaseOrderId(), "PARTIAL");
                 }
             }
+            //todo 消息通知（站内信）
+            List<String> userIdList = new ArrayList<>();
+            //发起人
+            String createById = revoke.getCreateById();
+            userIdList.add(createById);
+            //综合内勤
+            List<String> list1 = transactorHandler.listTransactorsByRoleCode("zhnq", createById);
+            if (CollectionUtils.isNotEmpty(list1)) {
+                userIdList.addAll(list1);
+            }
+            //办事处主管
+            List<String> list2 = transactorHandler.listTransactorsByRoleCode("bsczg", createById);
+            if (CollectionUtils.isNotEmpty(list2)) {
+                userIdList.addAll(list2);
+            }
+            //经营办计划员
+            List<String> list3 = transactorHandler.listTransactorsByRoleCode("jybjhy", createById);
+            if (CollectionUtils.isNotEmpty(list3)) {
+                userIdList.addAll(list3);
+            }
+            //经营办主管
+            List<String> list4 = transactorHandler.listTransactorsByRoleCode("jybzg", createById);
+            if (CollectionUtils.isNotEmpty(list4)) {
+                userIdList.addAll(list4);
+            }
+            //生产科计划员
+            List<String> list5 = transactorHandler.listTransactorsByRoleCode("sckjhy", createById);
+            if (CollectionUtils.isNotEmpty(list5)) {
+                userIdList.addAll(list5);
+            }
+            //
+            //营销管理科统计员
+            List<String> list6 = transactorHandler.listTransactorsByRoleCode("yxglktjy", createById);
+            if (CollectionUtils.isNotEmpty(list6)) {
+                userIdList.addAll(list6);
+            }
+            SysSiteMessageDto messageDto = new SysSiteMessageDto();
+            messageDto.setUserIdList(userIdList);
+            messageDto.setTitle("订货单撤销通过通知");
+            messageDto.setContent("订货单撤销审核流程已通过！");
+            messageDto.setBizKey(IdUtil.getId());
+            //如果是空表示由系统自动发起
+            messageDto.setCreateUserId(null);
+            mqProducerService.createSysSiteMessage(messageDto);
         } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {