楚江erp：订货单确认变更逻辑调整（增加消息通知）

@@ -3,6 +3,7 @@ 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.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.utils.CollectionUtil;
 import com.lframework.starter.mq.core.service.MqProducerService;
 import com.lframework.starter.web.core.components.redis.RedisHandler;
@@ -10,6 +11,8 @@ import com.lframework.starter.web.core.components.security.SecurityUtil;
 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.basedata.entity.Workshop;
+import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
@@ -94,7 +97,10 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private DelayedShipmentDetailService delayedShipmentDetailService;
     @Resource
     private CarRequestPlanService carRequestPlanService;
-
+    @Resource
+    private WorkshopService workshopService;
+    @Resource
+    private MessageHandler messageHandler;
 
 
     /**
@@ -145,7 +151,7 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
                 break;
             case "SPEC_CHANGE_SUBMIT":
             case "SPEC_CHANGE_CONFIRM":
-                handleOrderSpecChangeData(flowStatus, businessId);
+                handleOrderSpecChangeData(flowStatus, businessId, businessType);
                 break;
             case "SPEC_LOCK_DELAY":
                 handleSpecLockDelayAuditData(flowStatus, businessId);
@@ -429,10 +435,14 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
      * @param flowStatus 审核结果
      * @param businessId 业务ID
      */
-    private void handleOrderSpecChangeData(String flowStatus, String businessId) {
+    private void handleOrderSpecChangeData(String flowStatus, String businessId, String businessType) {
         if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
                 || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
             orderChangeRecordService.reviewPass(businessId);
+            if ("SPEC_CHANGE_CONFIRM".equals(businessType)) {
+                // 通知生产科计划员
+                noticeProductDept(businessId, businessType);
+            }
         } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
                 || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
@@ -557,4 +567,34 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             delayedShipmentService.updateStatus(businessId, "REFUSE");
         }
     }
+
+
+    /**
+     * 通知生产科计划员
+     *
+     * @param businessId    业务数据ID
+     * @param businessType  业务数据类型
+     */
+    private void noticeProductDept(String businessId, String businessType) {
+        OrderInfoChangeRecord record = orderChangeRecordService.findById(businessId);
+        if (record == null) {
+            throw new DefaultClientException("订货单变更记录不存在！");
+        }
+        String workshopId = record.getWorkshopId();
+        Workshop workshop = workshopService.findById(workshopId);
+        if (workshop != null) {
+            log.info("===================== noticeProductDept 所属分厂编号：{}", workshop.getCode());
+            List<String> roleCodes = new ArrayList<>();
+            if ("yfc".equals(workshop.getCode())) {
+                roleCodes.add("yfcsckjhy");
+            } else if ("efc".equals(workshop.getCode())) {
+                roleCodes.add("efcsckjhy");
+            } else if ("sfc".equals(workshop.getCode())) {
+                roleCodes.add("sfcsckjhy");
+            } else if ("ztfc".equals(workshop.getCode())) {
+                roleCodes.add("ztfcsckjhy");
+            }
+            messageHandler.sendMsg(null, roleCodes, businessType, businessId, null);
+        }
+    }
 }

@@ -32,7 +32,7 @@ public class MessageHandler {
      * @param roleCodes 角色编号集合
      * @param userId    人员ID
      */
-    public void sendMsg(String userId, List<String> roleCodes, String businessType, String sendUserId) {
+    public void sendMsg(String userId, List<String> roleCodes, String businessType, String businessId, String sendUserId) {
         log.info("================== MessageHandler sendMsg invoke start, userId:{}, roleCodes:{}", userId, JsonUtil.toJsonString(roleCodes));
         List<String> receiveUserIds = new ArrayList<>();
         if (StringUtils.isNotBlank(userId)) {
@@ -58,7 +58,11 @@ public class MessageHandler {
         if ("SPEC_CHANGE_SUBMIT".equals(businessType)) {
             title = "已产出，有损消息通知";
             content = "已产出，有损消息通知";
-            bizKey = IdUtil.getUUID();
+            bizKey = businessId;
+        } else if ("SPEC_CHANGE_CONFIRM".equals(businessType)) {
+            title = "确认变更消息通知";
+            content = "已确认需要变更，请及时执行变更计划！";
+            bizKey = businessId;
         }
         sendMsg(receiveUserIds, title, content, bizKey, sendUserId);
         log.info("================== MessageHandler sendMsg invoke end!");
@@ -75,6 +79,7 @@ public class MessageHandler {
      */
     public void sendMsg(List<String> userIds, String title, String content, String bizKey, String sendUserId) {
         if (CollectionUtils.isEmpty(userIds)) {
+            log.info("====================== MessageHandler sendMsg userIds is empty!");
             return;
         }
         SysSiteMessageDto siteMessageDto = new SysSiteMessageDto();

@@ -419,7 +419,7 @@ public class OrderChangeRecordServiceImpl extends BaseMpServiceImpl<OrderChangeR
             }
         }
         // 消息通知
-        messageHandler.sendMsg(record.getCreateById(), roleCodes, "SPEC_CHANGE_SUBMIT", null);
+        messageHandler.sendMsg(record.getCreateById(), roleCodes, "SPEC_CHANGE_SUBMIT", id, null);
     }
 
     @Override