mq调整

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;

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;
-    }
-
 }