From 5324e088ae4e7b76673d830493a4a98878ce203a Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Thu, 10 Aug 2023 19:03:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0mq=E6=A8=A1=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pqs-common/common-core/pom.xml                |  4 --
 pqs-common/common-mq/pom.xml                  | 32 ++++++++++++++++
 .../main/java/com/njcn/mq/constant/Topic.java | 15 ++++++++
 .../java/com/njcn/mq/message/UserMessage.java | 23 ++++++++++++
 .../njcn/mq/template/UserMessageTemplate.java | 37 +++++++++++++++++++
 pqs-common/pom.xml                            |  1 +
 6 files changed, 108 insertions(+), 4 deletions(-)
 create mode 100644 pqs-common/common-mq/pom.xml
 create mode 100644 pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java
 create mode 100644 pqs-common/common-mq/src/main/java/com/njcn/mq/message/UserMessage.java
 create mode 100644 pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java

diff --git a/pqs-common/common-core/pom.xml b/pqs-common/common-core/pom.xml
index 8411d6dcc..850547f92 100644
--- a/pqs-common/common-core/pom.xml
+++ b/pqs-common/common-core/pom.xml
@@ -70,10 +70,6 @@
             <groupId>commons-codec</groupId>
             <artifactId>commons-codec</artifactId>
         </dependency>
-        <!--        <dependency>-->
-        <!--            <groupId>com.alibaba</groupId>-->
-        <!--            <artifactId>easyexcel</artifactId>-->
-        <!--        </dependency>-->
         <!--API接口文档-->
         <dependency>
             <groupId>com.github.xiaoymin</groupId>
diff --git a/pqs-common/common-mq/pom.xml b/pqs-common/common-mq/pom.xml
new file mode 100644
index 000000000..ce5726d29
--- /dev/null
+++ b/pqs-common/common-mq/pom.xml
@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>pqs-common</artifactId>
+        <groupId>com.njcn</groupId>
+        <version>1.0.0</version>
+    </parent>
+    <artifactId>common-mq</artifactId>
+    <name>rocketmq公共代码模块</name>
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <java.version>8</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>common-core</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.njcn</groupId>
+            <artifactId>rocket-mq-springboot-starter</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+    </dependencies>
+
+
+</project>
diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java
new file mode 100644
index 000000000..9de9875fe
--- /dev/null
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/constant/Topic.java
@@ -0,0 +1,15 @@
+package com.njcn.mq.constant;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2023年08月10日 15:30
+ */
+public interface Topic {
+
+    /***
+     * 测试阶段用的用户主题
+     */
+    String NJCJ_USER_TOPIC = "njcnUserTopic";
+
+}
diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/message/UserMessage.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/message/UserMessage.java
new file mode 100644
index 000000000..1cf46a44d
--- /dev/null
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/message/UserMessage.java
@@ -0,0 +1,23 @@
+package com.njcn.mq.message;
+
+import com.njcn.middle.rocket.domain.BaseMessage;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2023年08月10日 14:45
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AllArgsConstructor
+@NoArgsConstructor
+public class UserMessage extends BaseMessage {
+    private String userName;
+    private LocalDate birthday;
+}
diff --git a/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java b/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
new file mode 100644
index 000000000..1d8e263b1
--- /dev/null
+++ b/pqs-common/common-mq/src/main/java/com/njcn/mq/template/UserMessageTemplate.java
@@ -0,0 +1,37 @@
+package com.njcn.mq.template;
+
+import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
+import com.njcn.mq.message.UserMessage;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.util.UUID;
+
+/**
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2023年08月10日 14:44
+ */
+@Component
+public class UserMessageTemplate extends RocketMQEnhanceTemplate {
+
+
+    public UserMessageTemplate(RocketMQTemplate template) {
+        super(template);
+    }
+
+    /**
+     * 入参只需要传入是哪个订单号和业务体消息即可，其他操作根据需要处理
+     * 这样对于调用者而言，可以更加简化调用
+     */
+    public SendResult sendMember(String userName, LocalDate birthday) {
+        UserMessage message = new UserMessage();
+        message.setKey(UUID.randomUUID().toString());
+        message.setUserName(userName);
+        message.setBirthday(birthday);
+        return send("member_enhance", "CREATE", message);
+    }
+
+}
\ No newline at end of file
diff --git a/pqs-common/pom.xml b/pqs-common/pom.xml
index d59a856b1..a6a99b498 100644
--- a/pqs-common/pom.xml
+++ b/pqs-common/pom.xml
@@ -24,6 +24,7 @@
         <module>common-echarts</module>
         <module>common-huawei</module>
         <module>common-oss</module>
+        <module>common-mq</module>
     </modules>
 
     <properties>