From 67682249e2ce54f1aecf3006b39313693ce21af2 Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrt@163.com>
Date: Mon, 26 Apr 2021 14:54:40 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=9D=E9=A2=98=E8=BD=AC=E8=AE=AE=E9=A2=98?=
 =?UTF-8?q?=E7=A7=AF=E5=88=86=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/ResiTopicServiceImpl.java    | 42 +++++++++++++------
 1 file changed, 29 insertions(+), 13 deletions(-)

diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
index e497e699c4..bda5e7ebe1 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java
@@ -1782,11 +1782,19 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
                                         .replaceFirst("题议为转被","")).reverse()
                         ).append("转为议题").toString());
                 pointEventMsgList.add(pointEventMsg2);
-
-                mqBaseMsgDTO.setMsg(JSON.toJSONString(pointEventMsgList));
-                if(!SendMqMsgUtils.sendMsg(mqBaseMsgDTO).success()){
-                    log.error("话题转议题事件发送失败，参数：{}",JSON.toJSONString(topicTurnIssueFromDTO));
-                }
+                pointEventMsgList.forEach(item -> {
+                    MqBaseMsgDTO msgDTO = new MqBaseMsgDTO();
+                    msgDTO.setEventClass("resi_group");
+                    //事件code  因为楼院小组的事件回调统一入口，外层的EventTag不能够判断具体的事件
+                    //因为可能会一次发送多个事件集合，需要对集合里的对象逐个判断
+                    msgDTO.setEventTag(EventEnum.SHIFT_TOPIC_TO_ISSUE.getEventTag());
+                    List<BasePointEventMsg> msgList = new ArrayList<>();
+                    msgList.add(item);
+                    msgDTO.setMsg(JSON.toJSONString(msgList));
+                    if(!SendMqMsgUtils.sendMsg(msgDTO).success()){
+                        log.error("话题转议题事件发送失败，参数：{}",JSON.toJSONString(topicTurnIssueFromDTO));
+                    }
+                });
                 //发送小组成就消息
                 TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
                     @Override
@@ -1903,11 +1911,11 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             //发送积分
 
             //mq的事件类型
-            MqBaseMsgDTO mqBaseMsgDTO = new MqBaseMsgDTO();
-            mqBaseMsgDTO.setEventClass("resi_group");
+//            MqBaseMsgDTO mqBaseMsgDTO = new MqBaseMsgDTO();
+//            mqBaseMsgDTO.setEventClass("resi_group");
             //事件code  因为楼院小组的事件回调统一入口，外层的EventTag不能够判断具体的事件
             //因为可能会一次发送多个事件集合，需要对集合里的对象逐个判断
-            mqBaseMsgDTO.setEventTag(EventEnum.SHIFT_TOPIC_TO_ISSUE.getEventTag());
+//            mqBaseMsgDTO.setEventTag(EventEnum.SHIFT_TOPIC_TO_ISSUE.getEventTag());
             List<BasePointEventMsg> pointEventMsgList = new ArrayList<>();
             //1.话题被转为议题  组内成员
 
@@ -1956,11 +1964,19 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
                                  .toString().replaceFirst("题议为转被","")).reverse()
                     ).append("转为议题").toString());
             pointEventMsgList.add(pointEventMsg2);
-
-            mqBaseMsgDTO.setMsg(JSON.toJSONString(pointEventMsgList));
-            if(!SendMqMsgUtils.sendMsg(mqBaseMsgDTO).success()){
-                log.error("话题转议题事件发送失败，参数：{}",JSON.toJSONString(param));
-            }
+            pointEventMsgList.forEach(item -> {
+                MqBaseMsgDTO msgDTO = new MqBaseMsgDTO();
+                msgDTO.setEventClass("resi_group");
+                //事件code  因为楼院小组的事件回调统一入口，外层的EventTag不能够判断具体的事件
+                //因为可能会一次发送多个事件集合，需要对集合里的对象逐个判断
+                msgDTO.setEventTag(EventEnum.SHIFT_TOPIC_TO_ISSUE.getEventTag());
+                List<BasePointEventMsg> msgList = new ArrayList<>();
+                msgList.add(item);
+                msgDTO.setMsg(JSON.toJSONString(msgList));
+                if(!SendMqMsgUtils.sendMsg(msgDTO).success()){
+                    log.error("话题转议题事件发送失败，参数：{}",JSON.toJSONString(param));
+                }
+            });
     }
         return issueInfo;
     }