From d187382d27a4af0428800fce4ca6af361b39e54b Mon Sep 17 00:00:00 2001
From: zhizhi wu <2377881365@qq.com>
Date: Tue, 27 Jul 2021 16:14:17 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../common/service/IMessageService.java       | 15 ++++++++++
 .../ccsens/common/service/MessageService.java | 30 +++++++++++++++++++
 pom.xml                                       |  2 +-
 3 files changed, 46 insertions(+), 1 deletion(-)
 create mode 100644 common/src/main/java/com/ccsens/common/service/IMessageService.java
 create mode 100644 common/src/main/java/com/ccsens/common/service/MessageService.java

diff --git a/common/src/main/java/com/ccsens/common/service/IMessageService.java b/common/src/main/java/com/ccsens/common/service/IMessageService.java
new file mode 100644
index 00000000..37ecd221
--- /dev/null
+++ b/common/src/main/java/com/ccsens/common/service/IMessageService.java
@@ -0,0 +1,15 @@
+package com.ccsens.common.service;
+
+import com.ccsens.util.bean.message.common.InMessage;
+
+/**
+ * @author zy
+ */
+public interface IMessageService {
+    /**
+     * 发送消息到消息系统
+     * @param inMessage 消息
+     * @throws Exception 异常
+     */
+    void sendTo(InMessage inMessage) throws Exception;
+}
diff --git a/common/src/main/java/com/ccsens/common/service/MessageService.java b/common/src/main/java/com/ccsens/common/service/MessageService.java
new file mode 100644
index 00000000..a17501de
--- /dev/null
+++ b/common/src/main/java/com/ccsens/common/service/MessageService.java
@@ -0,0 +1,30 @@
+package com.ccsens.common.service;
+
+import com.ccsens.util.JacksonUtil;
+import com.ccsens.util.bean.message.common.InMessage;
+import com.ccsens.util.config.RabbitMQConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+
+/**
+ * @author zy
+ */
+@Slf4j
+@Service
+@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
+public class MessageService implements IMessageService{
+    @Resource
+    private AmqpTemplate rabbitTemplate;
+
+    @Override
+    public void sendTo(InMessage inMessage) throws Exception{
+        log.info("向消息系统推送消息：{}", JacksonUtil.beanToJson(inMessage));
+        rabbitTemplate.convertAndSend(RabbitMQConfig.MESSAGE_QUEUE_NAME,
+                JacksonUtil.beanToJson(inMessage));
+    }
+}
diff --git a/pom.xml b/pom.xml
index a4fd6914..56c929ea 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
 <!--        <module>ht</module>-->
 <!--        <module>game</module>-->
 <!--        <module>mt</module>-->
-<!--        <module>wisdomcar</module>-->
+        <module>wisdomcar</module>
 <!--        <module>beneficiation</module>-->
 <!--        <module>form</module>-->
         <module>signin</module>