From 0094b18942db6518f8ac4a76f3e674d72bbfbc82 Mon Sep 17 00:00:00 2001
From: syc <asda>
Date: Fri, 19 Aug 2022 14:41:18 +0800
Subject: [PATCH] =?UTF-8?q?mq=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../messages/PartyMeetingMessageMQMsg.java    |  3 ++-
 .../java/com/epmet/send/SendMqMsgUtil.java    | 24 -------------------
 2 files changed, 2 insertions(+), 25 deletions(-)

diff --git a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/PartyMeetingMessageMQMsg.java b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/PartyMeetingMessageMQMsg.java
index 9ca6c76c5d..c41ae46729 100644
--- a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/PartyMeetingMessageMQMsg.java
+++ b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/messages/PartyMeetingMessageMQMsg.java
@@ -1,5 +1,6 @@
 package com.epmet.commons.rocketmq.messages;
 
+import com.epmet.commons.tools.dto.form.mq.MqBaseFormDTO;
 import lombok.Data;
 
 import java.io.Serializable;
@@ -9,7 +10,7 @@ import java.io.Serializable;
  * @author sun
  */
 @Data
-public class PartyMeetingMessageMQMsg implements Serializable {
+public class PartyMeetingMessageMQMsg extends MqBaseFormDTO implements Serializable {
 
     //客户Id
     private String customerId;
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 7b9d1d877b..debd15686f 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,28 +243,4 @@ 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;
-    }
-
 }