start/src/main/resources/sdk-prod.yml

@@ -64,8 +64,3 @@ openapi:
 point:
   url:
     prefix: https://gbs-gateway.qhdsafety.com/fireCheck-h5
-message:
-  code:
-    # 新增消防检查类消息编码
-    fire-check-overdue: MS000104         # 消防检查-已超期
-    fire-check-pending: MS000103         # 消防检查-待排查

start/src/main/resources/sdk.yml

@@ -49,8 +49,3 @@ openapi:
       apiCode: test:01
       #多个可以逗号隔开，可以为空
       tenantIds: 1838408702262321152
-message:
-  code:
-    # 新增消防检查类消息编码
-    fire-check-overdue: MS000104         # 消防检查-已超期
-    fire-check-pending: MS000103         # 消防检查-待排查

web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListAddExe.java

@@ -7,7 +7,6 @@ import com.alibaba.fastjson.JSONObject;
 import com.jjb.saas.message.client.message.facede.MessageFacade;
 import com.jjb.saas.message.client.message.request.MessageSendCmd;
 import com.jjb.saas.message.client.message.request.MessageTargetCmd;
-import com.zcloud.fire.check.domain.config.MessageConfig;
 import com.zcloud.fire.check.domain.gateway.FireCheckListGateway;
 import com.zcloud.fire.check.domain.gateway.FireCheckListItemGateway;
 import com.zcloud.fire.check.domain.gateway.FireCheckListUserGateway;
@@ -54,7 +53,6 @@ public class FireCheckListAddExe {
     private final UserRepository userRepository;
     @DubboReference
     private MessageFacade messageFacade;
-    private MessageConfig messageConfig;
     @Transactional(rollbackFor = Exception.class)
     public boolean execute(FireCheckListAddCmd cmd) {
         //可以是多个负责人
@@ -93,7 +91,7 @@ public class FireCheckListAddExe {
                     MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                     messageTargetCmd.setUserId(userId);
                     messageSendCmd.setTargetCmd(messageTargetCmd);
-                    messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
+                    messageSendCmd.setSourceCode("MS000103");
                     messageSendCmd.setNeedTokenEnum(false);
                     Map<String, Object> sendParams = new HashMap<String, Object>();
                     sendParams.put("FirefightinglistName", cmd.getFireCheckName());

web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListUpdateExe.java

@@ -6,7 +6,6 @@ import com.alibaba.cola.exception.BizException;
 import com.jjb.saas.message.client.message.facede.MessageFacade;
 import com.jjb.saas.message.client.message.request.MessageSendCmd;
 import com.jjb.saas.message.client.message.request.MessageTargetCmd;
-import com.zcloud.fire.check.domain.config.MessageConfig;
 import com.zcloud.fire.check.domain.gateway.FireCheckListGateway;
 import com.zcloud.fire.check.domain.gateway.FireCheckListItemGateway;
 import com.zcloud.fire.check.domain.gateway.FireCheckListUserGateway;
@@ -55,7 +54,6 @@ public class FireCheckListUpdateExe {
     private final TodoListEventPusherUtil todoListEventPusherUtil;
     @DubboReference
     private MessageFacade messageFacade;
-    private MessageConfig messageConfig;
     @Transactional(rollbackFor = Exception.class)
     public void execute(FireCheckListUpdateCmd fireCheckListUpdateCmd) {
         //数据是否存在
@@ -121,7 +119,7 @@ public class FireCheckListUpdateExe {
                 MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                 messageTargetCmd.setUserId(userId);
                 messageSendCmd.setTargetCmd(messageTargetCmd);
-                messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
+                messageSendCmd.setSourceCode("MS000103");
                 messageSendCmd.setNeedTokenEnum(false);
                 Map<String, Object> sendParams = new HashMap<String, Object>();
                 sendParams.put("FirefightinglistName", byId.getFireCheckName());

web-app/src/main/java/com/zcloud/fire/check/command/query/FireCheckListQueryExe.java

@@ -12,7 +12,6 @@ import com.jjb.saas.message.client.message.facede.MessageFacade;
 import com.jjb.saas.message.client.message.request.MessageSendCmd;
 import com.jjb.saas.message.client.message.request.MessageTargetCmd;
 import com.zcloud.fire.check.command.convertor.*;
-import com.zcloud.fire.check.domain.config.MessageConfig;
 import com.zcloud.fire.check.domain.enums.HiddenCheckTypeEnum;
 import com.zcloud.fire.check.domain.model.FireCheckListE;
 import com.zcloud.fire.check.dto.*;
@@ -74,7 +73,6 @@ public class FireCheckListQueryExe {
     private ZcloudHiddenFacade zcloudHiddenFacade;
     @DubboReference
     private MessageFacade messageFacade;
-    private MessageConfig messageConfig;
 
     /**
      * 分页
@@ -573,7 +571,7 @@ public class FireCheckListQueryExe {
                     MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                     messageTargetCmd.setUserId(userId);
                     messageSendCmd.setTargetCmd(messageTargetCmd);
-                    messageSendCmd.setSourceCode(messageConfig.getFireCheckOverdue());
+                    messageSendCmd.setSourceCode("MS000104");
                     messageSendCmd.setNeedTokenEnum(false);
                     Map<String, Object> sendParams = new HashMap<String, Object>();
                     sendParams.put("FirefightinglistName", info.getFireCheckName());
@@ -624,7 +622,7 @@ public class FireCheckListQueryExe {
                     MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                     messageTargetCmd.setUserId(userId);
                     messageSendCmd.setTargetCmd(messageTargetCmd);
-                    messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
+                    messageSendCmd.setSourceCode("MS000103");
                     messageSendCmd.setNeedTokenEnum(false);
                     Map<String, Object> sendParams = new HashMap<String, Object>();
                     sendParams.put("FirefightinglistName", info.getFireCheckName());

web-domain/src/main/java/com/zcloud/fire/check/domain/config/MessageConfig.java

@@ -1,17 +0,0 @@
-package com.zcloud.fire.check.domain.config;
-
-import lombok.Data;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.cloud.context.config.annotation.RefreshScope;
-import org.springframework.context.annotation.Configuration;
-
-@Data
-@Configuration
-@RefreshScope
-@ConfigurationProperties(prefix = "message.code")
-public class MessageConfig {
-    /** 消防检查-已超期 */
-    private String fireCheckOverdue;
-    /** 消防检查-待排查 */
-    private String fireCheckPending;
-}