消息中心整体提交

src/main/java/com/yunfeiyun/agmp/iot/common/constant/warn/MsgChannelConsts.java

@@ -0,0 +1,14 @@
+package com.yunfeiyun.agmp.iot.common.constant.warn;
+
+/**
+ * 消息通道常量类
+ * APP /短信 SMS /微信 WX /钉钉DD/站内 Web
+ */
+public class MsgChannelConsts {
+
+    public static final String APP = "APP";
+    public static final String SMS = "SMS";
+    public static final String WX = "WX";
+    public static final String DD = "DD";
+    public static final String WEB = "WEB";
+}

src/main/java/com/yunfeiyun/agmp/iot/common/domain/IotWarnlog.java

@@ -6,75 +6,132 @@ import com.yunfeiyun.agmp.common.annotation.Excel;
 
 /**
  * 告警记录对象 IotWarnrecord
- * 
+ *
  * @author 杨晓辉
  * @date 2025-03-07
  */
 @Data
-public class IotWarnlog extends IotBaseEntity{
+public class IotWarnlog extends IotBaseEntity {
     private static final long serialVersionUID = 1L;
 
-    /** 自增主键 */
+    /**
+     * 自增主键
+     */
     private Long id;
 
-    /** 告警记录标识 */
-    @Length(max = 36 , message = "告警记录标识最大长度为36")
+    /**
+     * 告警记录标识
+     */
+    @Length(max = 36, message = "告警记录标识最大长度为36")
     private String wlBid;
 
-    /** 告警名称 */
-    @Length(max = 100 , message = "告警名称最大长度为100")
+    /**
+     * 告警名称
+     */
+    @Length(max = 100, message = "告警名称最大长度为100")
     private String wlName;
 
-    /** 告警名称 */
-    @Length(max = 100 , message = "告警名称最大长度为100")
+    /**
+     * 告警名称
+     */
+    @Length(max = 100, message = "告警名称最大长度为100")
     private String wcBid;
 
-    /** 告警类型 */
-    @Length(max = 50 , message = "告警类型最大长度为50")
+    /**
+     * 告警类型
+     */
+    @Length(max = 50, message = "告警类型最大长度为50")
     private String wlType;
 
-    /** 告警内容 */
-    @Length(max = 50 , message = "告警内容最大长度为50")
+    /**
+     * 告警内容
+     */
+    @Length(max = 50, message = "告警内容最大长度为50")
     private String wlContent;
 
-    /** 告警等级《普通/重要/紧急》 */
-    @Length(max = 1 , message = "告警等级《普通/重要/紧急》最大长度为1")
+    /**
+     * 告警等级《普通/重要/紧急》
+     */
+    @Length(max = 1, message = "告警等级《普通/重要/紧急》最大长度为1")
     private String wlLevel;
 
-    /** 设备型号 */
-    @Length(max = 50 , message = "设备型号最大长度为50")
+    /**
+     * 设备型号
+     */
+    @Length(max = 50, message = "设备型号最大长度为50")
     private String devtypeBid;
 
-    /** 设备ID */
-    @Length(max = 36 , message = "设备ID最大长度为36")
+    /**
+     * 设备ID
+     */
+    @Length(max = 36, message = "设备ID最大长度为36")
     private String devBid;
 
-    /** 处理状态，表示当前告警的状态（如未处理、已处理等） */
+    /**
+     * 处理状态，表示当前告警的状态（如未处理、已处理等）
+     */
     @Excel(name = "处理状态，表示当前告警的状态", readConverterExp = "如=未处理、已处理等")
     private String status;
 
-    /** 处理人 */
-    @Length(max = 36 , message = "处理人最大长度为36")
+    /**
+     * 处理人
+     */
+    @Length(max = 36, message = "处理人最大长度为36")
     private String wlDealuserid;
 
-    /** 处理结果 */
-    @Length(max = 200 , message = "处理结果最大长度为200")
+    /**
+     * 处理结果
+     */
+    @Length(max = 200, message = "处理结果最大长度为200")
     private String wlDealresult;
 
-    /** 处理时间 */
-    @Length(max = 19 , message = "处理时间最大长度为19")
+    /**
+     * 处理时间
+     */
+    @Length(max = 19, message = "处理时间最大长度为19")
     private String wlDealtime;
 
-    /** 创建时间 */
-    @Length(max = 19 , message = "创建时间最大长度为19")
+    /**
+     * 创建时间
+     */
+    @Length(max = 19, message = "创建时间最大长度为19")
     private String wlCreateddate;
 
-    /** 上报数据冗余存储 */
-    @Length(max = 65535 , message = "上报数据冗余存储最大长度为65535")
+    /**
+     * 上报数据冗余存储
+     */
+    @Length(max = 65535, message = "上报数据冗余存储最大长度为65535")
     private String wlData;
 
-    /** 租户标识 */
-    @Length(max = 36 , message = "租户标识最大长度为36")
+    /**
+     * 租户标识
+     */
+    @Length(max = 36, message = "租户标识最大长度为36")
     private String tid;
 
+
+    /**
+     * 发送时间
+     */
+
+    private String wlSendmsgtime;
+    /**
+     * 发送状态
+     * 未发送0：比如因为不到发送时间端，导致未发送
+     * 已发送(默认)1：消息已经通过mq发送至门户
+     * 发送失败2：消息在发送至门户过程出现问题，失败
+     * 处理成功3：任务已经处理成功(预留状态，与批次表对照)
+     * 处理失败4：任务处理失败(预留状态，与批次表对照)
+     */
+    private String wlSendmsgstatus;
+
+    /**
+     * 补发状态，WarnLogReSendStatus Enum枚举类型，0：未补发；1：已补发
+     */
+
+    private String wlReSendStatus;
+    /**
+     * 补发信息，预留字段，存储补发的时间
+     */
+    private String wlSendinfo;
 }

src/main/java/com/yunfeiyun/agmp/iot/common/domain/IotWarnreceiver.java

@@ -35,5 +35,6 @@ public class IotWarnreceiver extends IotBaseEntity {
     private String tid;
     /** 接收者名称 */
     private String userName;
+    private String userMobile;
 
 }

src/main/java/com/yunfeiyun/agmp/iot/common/enums/warn/IotWarnPolicyChannel.java

@@ -1,37 +0,0 @@
-package com.yunfeiyun.agmp.iot.common.enums.warn;
-
-import com.yunfeiyun.agmp.common.utils.StringUtils;
-
-public enum IotWarnPolicyChannel {
-    APP("0","APP"),
-    SMS("1","短信"),
-    WECHAT("2","微信"),
-    DING_TALK("3","钉钉"),
-    STATION_MSG("4","站内信");
-
-    private String code;
-    private String content;
-
-    IotWarnPolicyChannel(String code,String content){
-        this.code = code;
-        this.content = content;
-    }
-    public String getContent(){
-        return this.content;
-    }
-    public String getCode(){
-        return this.code;
-    }
-
-    public static IotWarnPolicyChannel findByCode(String code){
-        if(StringUtils.isEmpty(code)){
-            return null;
-        }
-        for(IotWarnPolicyChannel iotWarnPolicyChannel : IotWarnPolicyChannel.values()){
-            if(iotWarnPolicyChannel.code.equals(code)){
-                return iotWarnPolicyChannel;
-            }
-        }
-        return null;
-    }
-}