补充提交IotMq常量

src/main/java/com/yunfeiyun/agmp/iot/common/constant/mq/IotActionEnums.java

@@ -0,0 +1,60 @@
+package com.yunfeiyun.agmp.iot.common.constant.mq;
+
+
+
+/**
+ * MQ 相关常量定义
+ */
+public enum IotActionEnums {
+    CMD_TASK("CMD_TASK", "控制指令"),
+    CMD_TASK_RESULT("CMD_TASK_RESULT", "控制指令结果"),
+    IOT_DEVICE_CREATE("DEVICE_CREATE", "设备创建"),
+    IOT_DEVICE_UPDATE("IOT_DEVICE_UPDATE","设备更新"),
+    IOT_DEVICE_DELETE("DEVICE_DELETE", "设备删除"),
+    DEVICE_COON_CREATE("DEVICE_COON_CREATE", "设备连接信息创建"),
+    DEVICE_COON_UPDATE("DEVICE_COON_UPDATE", "设备连接信息更新"),
+    DEVICE_COON_DELETE("DEVICE_COON_DELETE", "设备连接信息删除"),
+    DEVICE_ALL_SYN("DEVICE_ALL_SYN", "更新所有设备信息"),
+    ;
+
+
+
+    private final String code;
+    private final String message;
+
+    private IotActionEnums(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+    
+
+    public String getCode() {
+        return code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public static String valueOfCode(String code) {
+        for (IotActionEnums stockChangeBizType : IotActionEnums.values()) {
+            if (stockChangeBizType.equal(code)) {
+                return stockChangeBizType.getMessage();
+            }
+        }
+        return "";
+    }
+
+    public static IotActionEnums getAction(String code) {
+        for (IotActionEnums stockChangeBizType : IotActionEnums.values()) {
+            if (stockChangeBizType.equal(code)) {
+                return stockChangeBizType;
+            }
+        }
+        return null;
+    }
+
+    public boolean equal(String code) {
+        return this.code.equals(code);
+    }
+}

src/main/java/com/yunfeiyun/agmp/iot/common/constant/mq/IotMqConstant.java

@@ -1,59 +0,0 @@
-package com.yunfeiyun.agmp.iot.common.constant.mq;
-
-/**
- * MQ 相关常量定义
- */
-public class IotMqConstant {
-
-    /**
-     * topic：下发指令集任务
-     */
-
-    public final static String TOPIC_TASK = "TOPIC_TASK";
-
-    /**
-     * topic：上报任务执行状态
-     */
-    public final static String TOPIC_TASK_STATUS = "TOPIC_TASK_STATUS";
-
-    /**
-     * topic: 下发设备创建响应
-     */
-    public final static String DEVICE_CREATE = "DEVICE_CREATE";
-
-    /**
-     * topic: 下发设备删除响应
-     */
-    public final static String DEVICE_DELETE = "DEVICE_DELETE";
-    /**
-     * topic: 下发所有设备数据更新指令
-     * */
-    public static final String DEVICE_ALL_SYN = "DEVICE_ALL_SYN";
-    /**
-     * topic: 下发海康云眸多光谱消息通道拉取任务
-     * */
-    public final static String TOPIC_HIK_SPD_RECOG_QUEUE = "TOPIC_HIK_SPD_RECOG_QUEUE";
-
-    /**
-     * topic: 下发设备创建响应 版本2，之前的默认都是mqtt
-     */
-    public final static String DEVICE_CREATE_V2 = "DEVICE_CREATE_V2";
-
-    public final static String DEVICE_REFRESH_TO_IOTM = "DEVICE_REFRESH_TO_IOTM";
-
-    /**
-     * ”预警检查“消息
-     */
-    public final static String TOPIC_WARNCHECK = "TOPIC_WARNCHECK";
-
-    public final static String CBD_IMAGE_AGAIN_RECOGE = "CBD_IMAGE_AGAIN_RECOGE";
-    /**
-     * 延时指令执行
-     * */
-    public static final String TOPIC_AUTO_CMD = "TOPIC_AUTO_CMD";
-    /**
-     * 异步指令执行
-     * */
-    public static final String TOPIC_ASYNC_CMD = "TOPIC_ASYNC_CMD";
-
-}

src/main/java/com/yunfeiyun/agmp/iot/common/constant/mq/IotMqExchange.java

@@ -0,0 +1,6 @@
+package com.yunfeiyun.agmp.iot.common.constant.mq;
+
+public class IotMqExchange {
+    public static final String IOTM_TO_IOTS_EXCHANGE = "IOTM_TO_IOTS_EXCHANGE";
+    public static final String IOTS_TO_IOTM_EXCHANGE = "IOTS_TO_IOTM_EXCHANGE";
+}

src/main/java/com/yunfeiyun/agmp/iot/common/constant/mq/IotMqQueue.java

@@ -0,0 +1,5 @@
+package com.yunfeiyun.agmp.iot.common.constant.mq;
+
+public class IotMqQueue {
+    public static final String IOTM_TO_IOTS_CMD_QUEUE = "IOTM_TO_IOTS_CMD_QUEUE";
+}