From 8deb6a14fea8fcd6cc0a41471e1c6845ce9762f1 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Mon, 1 Mar 2021 12:21:43 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=88=E5=B9=B6=E4=BB=A3=E7=A0=81=E5=86=B2?=
 =?UTF-8?q?=E7=AA=81=E8=A7=A3=E5=86=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../topic/service/ResiTopicService.java       |  8 ---
 .../service/impl/ResiTopicServiceImpl.java    | 54 -------------------
 2 files changed, 62 deletions(-)

diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java
index bd0ee09762..822b4c631a 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/ResiTopicService.java
@@ -352,14 +352,6 @@ public interface ResiTopicService extends BaseService<ResiTopicEntity> {
      */
     void sendWxmpUpdateSubscribe(TokenDto tokenDto, String id, String type);
 
-    /**
-     * @Description 根据事件枚举发送积分事件
-     * @param param
-     * @return void
-     * @author wangc
-     * @date 2021.01.04 16:41
-    */
-    void sendTopicPointEventByEventType(TopicEventFormDTO param);
 
     ResiTopicDTO queryTopicInfoByIssueId(String issueId);
 }
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 19268d3411..4f0190f4ab 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
@@ -2176,60 +2176,6 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi
         return resultDTO;
     }
 
-	/**
-	 * @Description 根据事件枚举发送积分事件
-	 * @param param
-	 * @return void
-	 * @author wangc
-	 * @date 2021.01.04 16:41
-	 */
-	@Override
-	public void sendTopicPointEventByEventType(TopicEventFormDTO param) {
-		ResiTopicEntity topic = baseDao.selectById(param.getTopicId());
-		if(null == topic){
-			log.error("com.epmet.modules.topic.service.impl.ResiTopicServiceImpl.sendTopicPointEventByEventType，根据话题Id没有找到对应的话题信息，参数：{}",JSON.toJSONString(param
-			));
-			return;
-		}
-		ResiGroupInfoRedisDTO group = resiGroupRedis.get(topic.getGroupId());
-		if(null == group){
-			log.error("com.epmet.modules.topic.service.impl.ResiTopicServiceImpl.sendTopicPointEventByEventType，根据组Id没有找到对应的小组信息，组Id：{}",topic.getGroupId());
-			return;
-		}
-		//某某小组中发布的话题“某某某…” （前十个字后面省略号） 被转为项目
-		if(EventEnum.TOPIC_SHIFTED_TO_PROJECT == param.getEvent()){
-
-			MqBaseMsgDTO mqBaseMsgDTO = new MqBaseMsgDTO();
-			mqBaseMsgDTO.setEventClass("resi_group");
-
-			mqBaseMsgDTO.setEventTag(EventEnum.TOPIC_SHIFTED_TO_PROJECT.getEventTag());
-			List<BasePointEventMsg> pointEventMsgList = new ArrayList<>();
-			//话题被转为项目 话题作者
-
-			BasePointEventMsg pointEventMsg = new BasePointEventMsg();
-			pointEventMsg.setCustomerId(group.getCustomerId());
-			pointEventMsg.setUserId(topic.getCreatedBy());
-			pointEventMsg.setActionFlag(MqConstant.PLUS);
-			pointEventMsg.setIsCommon(false);
-			pointEventMsg.setEventTag(EventEnum.TOPIC_SHIFTED_TO_PROJECT.getEventTag());
-			//某某小组中发布的话题“某某某…” （前十个字后面省略号） 被转为议题
-			String content = CharMatcher.WHITESPACE.trimFrom(topic.getTopicContent());
-			pointEventMsg.setRemark(new StringBuilder(group.getGroupName()).append("小组中发布的")
-					.append(
-							StringUtils.isBlank(content) ||
-                                    StringUtils.equals("语音话题",content) ? "语音话题" :
-									"话题\"" +
-											content
-													.substring(NumConstant.ZERO,content.length() < NumConstant.TEN ? content.length() : NumConstant.TEN)
-											+ (NumConstant.TEN > content.length() ? "\"" : "…\"")
-					).append("被转为项目").toString());
-			pointEventMsgList.add(pointEventMsg);
-			mqBaseMsgDTO.setMsg(JSON.toJSONString(pointEventMsgList));
-			if(!SendMqMsgUtils.sendMsg(mqBaseMsgDTO).success()){
-				log.error("话题转议题事件发送失败，参数：{}",JSON.toJSONString(param));
-			}
-		}
-	}
 
     @Override
     public ResiTopicDTO queryTopicInfoByIssueId(String issueId) {