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