From 2aba676712d5ce77814d045c3f97d039ff2548df Mon Sep 17 00:00:00 2001
From: syc <asda>
Date: Fri, 19 Aug 2022 10:16:58 +0800
Subject: [PATCH] =?UTF-8?q?mq=E9=85=8D=E7=BD=AE=E9=81=97=E6=BC=8F=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/epmet/send/SendMqMsgUtil.java    | 24 +++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/send/SendMqMsgUtil.java b/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/send/SendMqMsgUtil.java
index debd15686f..7b9d1d877b 100644
--- a/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/send/SendMqMsgUtil.java
+++ b/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/send/SendMqMsgUtil.java
@@ -243,4 +243,28 @@ public class SendMqMsgUtil {
         return false;
     }
 
+    /**
+     * @Description 党建小助手消息同步Mq
+     * @author sun
+     */
+    public boolean partyMeetingMQMsg(String msgType, PartyMeetingMessageMQMsg msgContent) {
+        try {
+            SystemMsgFormDTO form = new SystemMsgFormDTO(msgType,msgContent);
+            Result sendMsgResult;
+            log.info("partyMeetingMQMsg param:{}",msgContent);
+            int retryTime = 0;
+            do {
+                sendMsgResult = epmetMessageOpenFeignClient.sendSystemMsgByMQ(form);
+            } while ((sendMsgResult == null || !sendMsgResult.success()) && retryTime++ < NumConstant.TWO);
+
+            if (sendMsgResult != null && sendMsgResult.success()) {
+                return true;
+            }
+            log.error("发送党建小助手系统消息到message服务失败:{},msg:{}", JSON.toJSONString(sendMsgResult), JSON.toJSONString(form));
+        } catch (Exception e) {
+            log.error("partyMeetingMQMsg exception", e);
+        }
+        return false;
+    }
+
 }