消息通知模板

start/src/main/resources/sdk.yml

@@ -49,3 +49,8 @@ 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,6 +7,7 @@ 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;
@@ -53,6 +54,7 @@ public class FireCheckListAddExe {
     private final UserRepository userRepository;
     @DubboReference
     private MessageFacade messageFacade;
+    private MessageConfig messageConfig;
     @Transactional(rollbackFor = Exception.class)
     public boolean execute(FireCheckListAddCmd cmd) {
         //可以是多个负责人
@@ -91,7 +93,7 @@ public class FireCheckListAddExe {
                     MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                     messageTargetCmd.setUserId(userId);
                     messageSendCmd.setTargetCmd(messageTargetCmd);
-                    messageSendCmd.setSourceCode("MS000103");
+                    messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
                     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,6 +6,7 @@ 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;
@@ -54,6 +55,7 @@ public class FireCheckListUpdateExe {
     private final TodoListEventPusherUtil todoListEventPusherUtil;
     @DubboReference
     private MessageFacade messageFacade;
+    private MessageConfig messageConfig;
     @Transactional(rollbackFor = Exception.class)
     public void execute(FireCheckListUpdateCmd fireCheckListUpdateCmd) {
         //数据是否存在
@@ -119,7 +121,7 @@ public class FireCheckListUpdateExe {
                 MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                 messageTargetCmd.setUserId(userId);
                 messageSendCmd.setTargetCmd(messageTargetCmd);
-                messageSendCmd.setSourceCode("MS000103");
+                messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
                 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,6 +12,7 @@ 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.*;
@@ -73,6 +74,7 @@ public class FireCheckListQueryExe {
     private ZcloudHiddenFacade zcloudHiddenFacade;
     @DubboReference
     private MessageFacade messageFacade;
+    private MessageConfig messageConfig;
 
     /**
      * 分页
@@ -571,7 +573,7 @@ public class FireCheckListQueryExe {
                     MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                     messageTargetCmd.setUserId(userId);
                     messageSendCmd.setTargetCmd(messageTargetCmd);
-                    messageSendCmd.setSourceCode("MS000104");
+                    messageSendCmd.setSourceCode(messageConfig.getFireCheckOverdue());
                     messageSendCmd.setNeedTokenEnum(false);
                     Map<String, Object> sendParams = new HashMap<String, Object>();
                     sendParams.put("FirefightinglistName", info.getFireCheckName());
@@ -622,7 +624,7 @@ public class FireCheckListQueryExe {
                     MessageTargetCmd messageTargetCmd = new MessageTargetCmd();
                     messageTargetCmd.setUserId(userId);
                     messageSendCmd.setTargetCmd(messageTargetCmd);
-                    messageSendCmd.setSourceCode("MS000103");
+                    messageSendCmd.setSourceCode(messageConfig.getFireCheckPending());
                     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

@@ -0,0 +1,17 @@
+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;
+}