楚江ERP-客户开发审核通过后消息通知功能开发

@@ -8,10 +8,7 @@ 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;
-import com.lframework.xingyun.sc.entity.PurchaseOrderRevokeLine;
+import com.lframework.xingyun.sc.entity.*;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.customer.CorePersonnelHistoryService;
@@ -162,6 +159,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
         if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
                 || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
             customerDevelopPlanService.updateStatus(businessId, CustomerDevelopStatus.PASS);
+            // 消息通知
+            customerDevelopPlanService.sendMsg(businessId);
         } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {

@@ -50,14 +50,31 @@ public class MessageHandler {
         // 去重
         receiveUserIds = receiveUserIds.stream().distinct().collect(Collectors.toList());
         log.info("================== MessageHandler sendMsg receiveUserIds size:{}", receiveUserIds.size());
-        SysSiteMessageDto siteMessageDto = new SysSiteMessageDto();
-        siteMessageDto.setUserIdList(receiveUserIds);
         // todo 完善消息标题、内容
         String title = "";
         String content = "";
         String bizKey = "";
         if ("SPEC_CHANGE_SUBMIT".equals(businessType)) {
         }
+        sendMsg(receiveUserIds, title, content, bizKey, null);
+        log.info("================== MessageHandler sendMsg invoke end!");
+    }
+
+
+    /**
+     * 发送消息
+     *
+     * @param userIds   人员ID集合
+     * @param title     消息标题
+     * @param content   消息内容
+     * @param bizKey    业务Key
+     */
+    public void sendMsg(List<String> userIds, String title, String content, String bizKey, String sendUserId) {
+        if (CollectionUtils.isEmpty(userIds)) {
+            return;
+        }
+        SysSiteMessageDto siteMessageDto = new SysSiteMessageDto();
+        siteMessageDto.setUserIdList(userIds);
         siteMessageDto.setTitle(title);
         siteMessageDto.setContent(content);
         siteMessageDto.setBizKey(bizKey);
@@ -67,8 +84,6 @@ public class MessageHandler {
         } else {
             siteMessageDto.setCreateUserId(sendUserId);
         }
-
         mqProducerService.createSysSiteMessage(siteMessageDto);
-        log.info("================== MessageHandler sendMsg invoke end!");
     }
 }

@@ -8,6 +8,7 @@ import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.bpm.service.FlowTaskWrapperService;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.core.utils.*;
+import com.lframework.starter.web.inner.service.system.SysUserRoleService;
 import com.lframework.xingyun.basedata.entity.Workshop;
 import com.lframework.xingyun.basedata.service.customer.CustomerService;
 import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
@@ -22,6 +23,7 @@ import com.lframework.starter.web.core.annotations.oplog.OpLog;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
+import com.lframework.xingyun.sc.handlers.MessageHandler;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -53,6 +55,10 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
     private FlowTaskWrapperService flowTaskWrapperService;
     @Resource
     private WorkshopService workshopService;
+    @Resource
+    private MessageHandler messageHandler;
+    @Resource
+    private SysUserRoleService sysUserRoleService;
 
 
     @Override
@@ -341,4 +347,35 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
 
         return getBaseMapper().selectList(queryWrapper);
     }
+
+    @Override
+    public void sendMsg(String id) {
+        CustomerDevelopPlan plan = findById(id);
+        if (plan == null) {
+            log.error("=================== customerDevelopApprovedNotice plan is null!");
+            return;
+        }
+        String userId = plan.getCreateById();
+        List<String> receiveUserIds = new ArrayList<>();
+        receiveUserIds.add(userId);
+
+        List<String> roleCodeList = new ArrayList<>();
+        // 综合内勤
+        roleCodeList.add("zhnq");
+        // 办事处经理
+        roleCodeList.add("bscjl");
+        List<String> userIds = sysUserRoleService.listUserIdByRoleCodes(roleCodeList, userId);
+        if (CollectionUtils.isNotEmpty(userIds)) {
+            receiveUserIds.addAll(userIds);
+        }
+        roleCodeList.clear();
+        // 营销部分管
+        roleCodeList.add("ssyxbfg");
+        // 市场科统计员
+        roleCodeList.add("scktjy");
+        // 运作科主管
+        roleCodeList.add("yzkzg");
+
+        messageHandler.sendMsg(receiveUserIds, "", "", "", null);
+    }
 }

@@ -92,4 +92,11 @@ public interface CustomerDevelopPlanService extends BaseMpService<CustomerDevelo
      * @return              List<CustomerDevelopPlan>
      */
     List<CustomerDevelopPlan> listByCustomerId(String customerId);
+
+    /**
+     * 发送消息
+     *
+     * @param id    主键ID
+     */
+    void sendMsg(String id);
 }