From ee5a97ac851ead8252a56bfc1ab381c0f4d0fdd9 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Thu, 17 Aug 2023 20:26:33 +0800
Subject: [PATCH] =?UTF-8?q?rocketMQ=E5=B8=B8=E9=87=8F=E5=AE=9A=E4=B9=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/mq/constant/BusinessResource.java    | 12 +++++++++++
 .../com/njcn/mq/constant/BusinessTopic.java   | 20 +++++++++++++++++--
 .../template/AppAutoDataMessageTemplate.java  |  5 +++--
 3 files changed, 33 insertions(+), 4 deletions(-)
 create mode 100644 pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessResource.java

diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessResource.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessResource.java
new file mode 100644
index 000000000..fbec6d44a
--- /dev/null
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessResource.java
@@ -0,0 +1,12 @@
+package com.njcn.mq.constant;
+
+/**
+ * @author xy
+ */
+public interface BusinessResource {
+
+    /***
+     * App
+     */
+    String APP_RESOURCE = "APP";
+}
diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
index c6525191d..555b567b4 100644
--- a/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java
@@ -15,10 +15,26 @@ public interface BusinessTopic {
     /**
      * 治理主送推送数据接收主题
      */
-    String NJCJ_APP_AUTO_DATA_TOPIC = "njcnAppAutoDataTopic";
+    String NJCN_APP_AUTO_DATA_TOPIC = "njcnAppAutoDataTopic";
 
     /**
      * 治理事件接收主题
      */
-    String NJCJ_APP_EVENT_TOPIC = "njcnAppEventTopic";
+    String NJCN_APP_EVENT_TOPIC = "njcnAppEventTopic";
+
+
+    interface AppDataTag {
+
+        /**
+         * 统计数据tag
+         */
+        String STAT_TAG = "stat";
+
+        /**
+         * 实时数据tag
+         */
+        String RT_TAG = "rt";
+    }
+
+
 }
diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/template/AppAutoDataMessageTemplate.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/template/AppAutoDataMessageTemplate.java
index 9d3323e0d..afafc79f5 100644
--- a/pqs-common/common-mq/src/main/java/com/njcn/mq/template/AppAutoDataMessageTemplate.java
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/template/AppAutoDataMessageTemplate.java
@@ -1,6 +1,7 @@
 package com.njcn.mq.template;
 
 import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
+import com.njcn.mq.constant.BusinessResource;
 import com.njcn.mq.constant.BusinessTopic;
 import com.njcn.mq.message.AppAutoDataMessage;
 import org.apache.rocketmq.client.producer.SendResult;
@@ -22,7 +23,7 @@ public class AppAutoDataMessageTemplate extends RocketMQEnhanceTemplate {
     }
 
     public SendResult sendMember(AppAutoDataMessage appAutoDataMessage) {
-        appAutoDataMessage.setSource("APP-AUTO-DATA");
-        return send(BusinessTopic.NJCJ_APP_AUTO_DATA_TOPIC, "CREATE", appAutoDataMessage);
+        appAutoDataMessage.setSource(BusinessResource.APP_RESOURCE);
+        return send(BusinessTopic.NJCN_APP_AUTO_DATA_TOPIC, BusinessTopic.AppDataTag.STAT_TAG, appAutoDataMessage);
     }
 }