From 1aee8276516bdf1c849973b8853504bc9b9a13df Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrt@163.com>
Date: Fri, 23 Apr 2021 17:19:45 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=A8=E6=88=B7=E7=A7=AF=E5=88=86=E8=A1=8C?=
 =?UTF-8?q?=E4=B8=BA=E8=AE=B0=E5=BD=95=E6=95=B0=E6=8D=AE=E4=BF=AE=E6=94=B9?=
 =?UTF-8?q?=EF=BC=8C=E6=B7=BB=E5=8A=A0sourceType=EF=BC=8C=E5=A1=AB?=
 =?UTF-8?q?=E5=85=85sourceId?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../form/mq/eventmsg/BasePointEventMsg.java   | 10 +++++++
 .../service/impl/ActLiveRecServiceImpl.java   |  1 +
 .../impl/VolunteerInfoServiceImpl.java        |  2 ++
 .../service/impl/WorkActServiceImpl.java      |  2 ++
 .../com/epmet/dto/UserPointActionLogDTO.java  |  2 ++
 .../entity/UserPointActionLogEntity.java      |  2 ++
 .../impl/UserPointActionLogServiceImpl.java   |  9 +++---
 .../GroupMemeberOperationServiceImpl.java     |  4 ++-
 .../impl/ResiGroupMemberServiceImpl.java      |  4 ++-
 .../impl/ResiTopicCommentServiceImpl.java     |  4 ++-
 .../service/impl/ResiTopicServiceImpl.java    | 30 ++++++++++++++-----
 .../service/impl/TopicDraftServiceImpl.java   |  9 +++---
 12 files changed, 60 insertions(+), 19 deletions(-)

diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/dto/form/mq/eventmsg/BasePointEventMsg.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/dto/form/mq/eventmsg/BasePointEventMsg.java
index 6c9044b499..9235fe77a7 100644
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/dto/form/mq/eventmsg/BasePointEventMsg.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/dto/form/mq/eventmsg/BasePointEventMsg.java
@@ -40,6 +40,11 @@ public class BasePointEventMsg implements Serializable {
 	 */
 	private String gridId;
 
+	/**
+	 * 小组ID
+	 */
+	private String groupId;
+
 	/**
 	 * 被操作用户id
 	 */
@@ -65,6 +70,11 @@ public class BasePointEventMsg implements Serializable {
 	 */
 	private String remark;
 
+	/**
+	 * 业务类型 eg：活动id
+	 */
+	private String sourceType;
+
 	/**
 	 * 业务id eg：活动id
 	 */
diff --git a/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/ActLiveRecServiceImpl.java b/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/ActLiveRecServiceImpl.java
index aeb67a2314..15ff440c80 100644
--- a/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/ActLiveRecServiceImpl.java
+++ b/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/ActLiveRecServiceImpl.java
@@ -239,6 +239,7 @@ public class ActLiveRecServiceImpl extends BaseServiceImpl<ActLiveRecDao, ActLiv
         actPointEventMsg.setActionFlag(MqConstant.PLUS);
         actPointEventMsg.setIsCommon(false);
         actPointEventMsg.setRemark(actInfoDTO.getTitle());
+        actPointEventMsg.setSourceType("activity");
         actPointEventMsg.setSourceId(formDTO.getActId());
         actPointEventMsgList.add(actPointEventMsg);
 
diff --git a/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/VolunteerInfoServiceImpl.java b/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/VolunteerInfoServiceImpl.java
index ef2da6193b..6949505c9f 100644
--- a/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/VolunteerInfoServiceImpl.java
+++ b/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/VolunteerInfoServiceImpl.java
@@ -127,6 +127,8 @@ public class VolunteerInfoServiceImpl extends BaseServiceImpl<VolunteerInfoDao,
         BasePointEventMsg actPointEventMsg=new BasePointEventMsg();
         actPointEventMsg.setCustomerId(formDTO.getCustomerId());
         actPointEventMsg.setUserId(formDTO.getUserId());
+        actPointEventMsg.setSourceType("volunteer");
+        actPointEventMsg.setSourceId(formDTO.getUserId());
         actPointEventMsg.setActionFlag(MqConstant.PLUS);
         actPointEventMsg.setIsCommon(false);
         actPointEventMsgList.add(actPointEventMsg);
diff --git a/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/WorkActServiceImpl.java b/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/WorkActServiceImpl.java
index 95b1afaa41..15f6ee311f 100644
--- a/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/WorkActServiceImpl.java
+++ b/epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/WorkActServiceImpl.java
@@ -927,6 +927,7 @@ public class WorkActServiceImpl implements WorkActService {
             basePointEventMsg.setPoint(actInfoDTO.getReward());
             basePointEventMsg.setIsCommon(true);
             basePointEventMsg.setRemark(remark);
+            basePointEventMsg.setSourceType("activity");
             basePointEventMsg.setSourceId(actInfoDTO.getId());
             basePointEventMsg.setOperatorId(loginUserUtil.getLoginUserId());
             basePointEventMsgArrayList.add(basePointEventMsg);
@@ -966,6 +967,7 @@ public class WorkActServiceImpl implements WorkActService {
         basePointEventMsg.setPoint(formDTO.getReward());
         basePointEventMsg.setIsCommon(true);
         basePointEventMsg.setRemark(formDTO.getRemark());
+        basePointEventMsg.setSourceType("activity");
         basePointEventMsg.setSourceId(formDTO.getSourceId());
         basePointEventMsg.setOperatorId(loginUserUtil.getLoginUserId());
         basePointEventMsgArrayList.add(basePointEventMsg);
diff --git a/epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/UserPointActionLogDTO.java b/epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/UserPointActionLogDTO.java
index 113572b051..0141538298 100644
--- a/epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/UserPointActionLogDTO.java
+++ b/epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/UserPointActionLogDTO.java
@@ -53,6 +53,8 @@ public class UserPointActionLogDTO implements Serializable {
      */
 	private String actionFlag;
 
+	private String sourceType;
+
     /**
      * 来源Id，可以是活动Id
      * */
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/entity/UserPointActionLogEntity.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/entity/UserPointActionLogEntity.java
index b52ed79b2f..2a1a33d61e 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/entity/UserPointActionLogEntity.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/entity/UserPointActionLogEntity.java
@@ -58,6 +58,8 @@ public class UserPointActionLogEntity extends BaseEpmetEntity {
      */
 	private String eventId;
 
+	private String sourceType;
+
 	/**
 	 * 来源Id，可以是活动Id
 	 * */
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
index 326a9515b2..c82bc9da79 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
@@ -323,6 +323,7 @@ public class UserPointActionLogServiceImpl extends BaseServiceImpl<UserPointActi
             action.setUserId(event.getUserId());
             action.setCreatedBy(StringUtils.isBlank(event.getOperatorId()) ? ModuleConstant.CREATED_BY_SYSTEM : event.getOperatorId());
             action.setUpdatedBy(StringUtils.isBlank(event.getOperatorId()) ? ModuleConstant.CREATED_BY_SYSTEM : event.getOperatorId());
+            action.setSourceType(event.getSourceType());
             action.setSourceId(event.getSourceId());
             action.setOperatorAgencyId(event.getOpAgencyId());
             baseDao.insert(action);
@@ -361,7 +362,7 @@ public class UserPointActionLogServiceImpl extends BaseServiceImpl<UserPointActi
                     userTotalDetailDTO.setGridId(event.getGridId());
                     userTotalDetailDTO.setUserId(event.getUserId());
                     userTotalDetailDTO.setBizType("group");
-                    userTotalDetailDTO.setObjectId(event.getSourceId());
+                    userTotalDetailDTO.setObjectId(event.getGroupId());
                     userTotalDetailDTO.setTotalPoint(event.getPoint());
                     bizPointUserTotalDetailService.save(userTotalDetailDTO);
                 } else {
@@ -379,13 +380,13 @@ public class UserPointActionLogServiceImpl extends BaseServiceImpl<UserPointActi
                     totalDetailDTO.setAgencyId(event.getAgencyId());
                     totalDetailDTO.setGridId(event.getGridId());
                     totalDetailDTO.setBizType("group");
-                    totalDetailDTO.setObjectId(event.getSourceId());
+                    totalDetailDTO.setObjectId(event.getGroupId());
                     totalDetailDTO.setTotalPoint(total);
-                    bizPointUserTotalDetailService.save(userTotalDetailDTO);
+                    bizPointTotalDetailService.save(totalDetailDTO);
                 } else {
                     totalDetailDTO.setTotalPoint(total);
                     totalDetailDTO.setUpdatedTime(new Date());
-                    bizPointUserTotalDetailService.update(userTotalDetailDTO);
+                    bizPointTotalDetailService.update(totalDetailDTO);
                 }
 
             }
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupMemeberOperationServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupMemeberOperationServiceImpl.java
index 2adeef419e..d5edcde398 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupMemeberOperationServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/GroupMemeberOperationServiceImpl.java
@@ -348,7 +348,9 @@ public class GroupMemeberOperationServiceImpl extends BaseServiceImpl<GroupMemeb
             pointEventMsg.setCustomerId(resiGroupDTO.getCustomerId());
             pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
             pointEventMsg.setGridId(resiGroupDTO.getGridId());
-            pointEventMsg.setSourceId(groupId);
+            pointEventMsg.setGroupId(groupId);
+            pointEventMsg.setSourceType("invite");
+            pointEventMsg.setSourceId(param.getUserId());
             pointEventMsg.setUserId(inviter);
             pointEventMsg.setActionFlag(MqConstant.PLUS);
             pointEventMsg.setIsCommon(false);
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
index 4222b1b982..04efadbc21 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java
@@ -588,7 +588,9 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl<ResiGroupMemberD
 			pointEventMsg.setCustomerId(groupCache.getCustomerId());
 			pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
 			pointEventMsg.setGridId(groupCache.getGridId());
-			pointEventMsg.setSourceId(groupCache.getGroupId());
+			pointEventMsg.setGroupId(groupCache.getGroupId());
+			pointEventMsg.setSourceType("invite");
+			pointEventMsg.setSourceId(agreeApplyFormDTO.getUserId());
 			pointEventMsg.setUserId(inviter);
 			pointEventMsg.setActionFlag(MqConstant.PLUS);
 			pointEventMsg.setIsCommon(false);
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicCommentServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicCommentServiceImpl.java
index 68bfea53f2..ea563f041f 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicCommentServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicCommentServiceImpl.java
@@ -272,7 +272,9 @@ public class ResiTopicCommentServiceImpl extends BaseServiceImpl<ResiTopicCommen
                 pointEventMsg.setCustomerId(customerId);
                 pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
                 pointEventMsg.setGridId(groupCache.getGridId());
-                pointEventMsg.setSourceId(topic.getGroupId());
+                pointEventMsg.setGroupId(topic.getGroupId());
+                pointEventMsg.setSourceType("topic");
+                pointEventMsg.setSourceId(topic.getId());
                 pointEventMsg.setUserId(tokenDto.getUserId());
                 // 加分
                 pointEventMsg.setActionFlag(MqConstant.PLUS);
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 c27843fab7..dcffc24d99 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
@@ -412,12 +412,14 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
                 }
                 pointEventMsg.setCustomerId(resiGroupEntity.getCustomerId());
                 pointEventMsg.setGridId(resiGroupEntity.getGridId());
-                pointEventMsg.setSourceId(resiGroupEntity.getId());
+                pointEventMsg.setGroupId(resiGroupEntity.getId());
             } else {
                 pointEventMsg.setCustomerId(resiGroupInfoRedisDTO.getCustomerId());
                 pointEventMsg.setGridId(resiGroupInfoRedisDTO.getGridId());
-                pointEventMsg.setSourceId(resiGroupInfoRedisDTO.getGroupId());
+                pointEventMsg.setGroupId(resiGroupInfoRedisDTO.getGroupId());
             }
+            pointEventMsg.setSourceType("topic");
+            pointEventMsg.setSourceId(topic.getId());
 
             CommonGridIdFormDTO dataFilterParam = new CommonGridIdFormDTO();
             dataFilterParam.setGridId(pointEventMsg.getGridId());
@@ -750,7 +752,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             pointEventMsg.setCustomerId(tokenDto.getCustomerId());
             pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
             pointEventMsg.setGridId(groupCache.getGridId());
-            pointEventMsg.setSourceId(groupCache.getGroupId());
+            pointEventMsg.setGroupId(groupCache.getGroupId());
+            pointEventMsg.setSourceType("topic");
+            pointEventMsg.setSourceId(closeFormDTO.getTopicId());
             pointEventMsg.setUserId(tokenDto.getUserId());
             pointEventMsg.setActionFlag(MqConstant.PLUS);
             pointEventMsg.setIsCommon(false);
@@ -1725,7 +1729,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
                 pointEventMsg.setCustomerId(groupCache.getCustomerId());
                 pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
                 pointEventMsg.setGridId(group.getGridId());
-                pointEventMsg.setSourceId(group.getGroupId());
+                pointEventMsg.setGroupId(group.getGroupId());
+                pointEventMsg.setSourceType("issue");
+                pointEventMsg.setSourceId(issueResult.getData().getIssueId());
                 pointEventMsg.setUserId(group.getTopicAuthorId());
                 pointEventMsg.setActionFlag(MqConstant.PLUS);
                 pointEventMsg.setIsCommon(false);
@@ -1749,7 +1755,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
                 pointEventMsg2.setCustomerId(groupCache.getCustomerId());
                 pointEventMsg2.setAgencyId(dataFilterResult.getData().getAgencyId());
                 pointEventMsg2.setGridId(group.getGridId());
-                pointEventMsg.setSourceId(group.getGroupId());
+                pointEventMsg2.setGroupId(group.getGroupId());
+                pointEventMsg2.setSourceType("issue");
+                pointEventMsg2.setSourceId(issueResult.getData().getIssueId());
                 pointEventMsg2.setUserId(topicTurnIssueFromDTO.getUserId());
                 pointEventMsg2.setActionFlag(MqConstant.PLUS);
                 pointEventMsg2.setIsCommon(false);
@@ -1887,7 +1895,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             pointEventMsg.setCustomerId(groupCache.getCustomerId());
             pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
             pointEventMsg.setGridId(group.getGridId());
-            pointEventMsg.setSourceId(group.getGroupId());
+            pointEventMsg.setGroupId(group.getGroupId());
+            pointEventMsg.setSourceType("issue");
+            pointEventMsg.setSourceId(param.getIssueId());
             pointEventMsg.setUserId(group.getTopicAuthorId());
             pointEventMsg.setActionFlag(MqConstant.PLUS);
             pointEventMsg.setIsCommon(false);
@@ -1911,7 +1921,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
             pointEventMsg2.setCustomerId(groupCache.getCustomerId());
             pointEventMsg2.setAgencyId(dataFilterResult.getData().getAgencyId());
             pointEventMsg2.setGridId(group.getGridId());
-            pointEventMsg2.setSourceId(group.getGroupId());
+            pointEventMsg2.setGroupId(group.getGroupId());
+            pointEventMsg2.setSourceType("issue");
+            pointEventMsg2.setSourceId(param.getIssueId());
             pointEventMsg2.setUserId(param.getUserId());
             pointEventMsg2.setActionFlag(MqConstant.PLUS);
             pointEventMsg2.setIsCommon(false);
@@ -2281,7 +2293,9 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
 			pointEventMsg.setCustomerId(group.getCustomerId());
             pointEventMsg.setAgencyId(dataFilterResult.getData().getAgencyId());
             pointEventMsg.setGridId(group.getGridId());
-            pointEventMsg.setSourceId(topic.getGroupId());
+            pointEventMsg.setGroupId(topic.getGroupId());
+            pointEventMsg.setSourceType("project");
+            pointEventMsg.setSourceId(param.getTopicId());
 			pointEventMsg.setUserId(topic.getCreatedBy());
 			pointEventMsg.setActionFlag(MqConstant.PLUS);
 			pointEventMsg.setIsCommon(false);
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftServiceImpl.java
index 7e31db6891..65303449a2 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftServiceImpl.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/TopicDraftServiceImpl.java
@@ -797,7 +797,7 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
             }
 
             sendMqMsg(draft.getCreatedBy(), draft.getCustomerId(), draft.getCreatedTime(),resiGroupRedis.get(draft.getGroupId()).getGroupName(),
-                    breviary.toString(), dataFilterResult.getData().getAgencyId(), draft.getGridId(), draft.getGroupId());
+                    breviary.toString(), dataFilterResult.getData().getAgencyId(), draft.getGridId(), draft.getGroupId(), resiTopic.getId());
         }
         //记录操作记录
         entity = baseDao.selectById(formDTO.getTopicDraftId());
@@ -934,7 +934,7 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
             throw new RenException(dataFilterResult.getMsg());
         }
         sendMqMsg(tokenDto.getUserId(), formDTO.getCustomerId(), draft.getCreatedTime(), resiGroupRedis.get(draft.getGroupId()).getGroupName(),
-                breviary.toString(), dataFilterResult.getData().getAgencyId(), formDTO.getGridId(), formDTO.getGroupId());
+                breviary.toString(), dataFilterResult.getData().getAgencyId(), formDTO.getGridId(), formDTO.getGroupId(), topic.getId());
 
     }
 
@@ -950,7 +950,7 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
      * @date 2020.12.25 15:45
     */
     private void sendMqMsg(String userId, String customerId, Date targetDate, String groupName, String topicBreviary, String agencyId,
-                           String gridId, String groupId) {
+                           String gridId, String groupId, String topicId) {
         //6.发送积分
         MqBaseMsgDTO mqBaseMsgDTO=new MqBaseMsgDTO();
         //mq的事件类型
@@ -962,7 +962,8 @@ public class TopicDraftServiceImpl extends BaseServiceImpl<TopicDraftDao, TopicD
         actPointEventMsg.setCustomerId(customerId);
         actPointEventMsg.setAgencyId(agencyId);
         actPointEventMsg.setGridId(gridId);
-        actPointEventMsg.setSourceId(groupId);
+        actPointEventMsg.setGroupId(groupId);
+        actPointEventMsg.setSourceId(topicId);
         actPointEventMsg.setUserId(userId);
         actPointEventMsg.setActionFlag(MqConstant.PLUS);
         actPointEventMsg.setIsCommon(false);