|
|
@ -118,7 +118,6 @@ import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
import org.springframework.util.CollectionUtils; |
|
|
|
|
|
|
|
import javax.validation.constraints.NotBlank; |
|
|
|
import java.text.SimpleDateFormat; |
|
|
|
import java.util.*; |
|
|
|
import java.util.stream.Collectors; |
|
|
@ -797,28 +796,26 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
content |
|
|
|
.substring(NumConstant.ZERO, content.length() < NumConstant.TEN ? content.length() : NumConstant.TEN) |
|
|
|
+ (NumConstant.TEN > content.length() ? "\"" : "…\"")) + |
|
|
|
"已被解决"); |
|
|
|
"已被解决"); |
|
|
|
pointEventMsgList.add(pointEventMsg); |
|
|
|
|
|
|
|
mqBaseMsgDTO.setMsg(JSON.toJSONString(pointEventMsgList)); |
|
|
|
if(!SendMqMsgUtils.sendMsg(mqBaseMsgDTO).success()){ |
|
|
|
log.error("组长解决话题事件发送失败,参数:{}",JSON.toJSONString(closeFormDTO)); |
|
|
|
if (!SendMqMsgUtils.sendMsg(mqBaseMsgDTO).success()) { |
|
|
|
log.error("组长解决话题事件发送失败,参数:{}", JSON.toJSONString(closeFormDTO)); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
//2021.4.22 start sun 因业务调整,新增组内消息记录表,话题状态变化时相应的修改数据状态
|
|
|
|
GroupMessageEntity groupMessage = groupMessageDao.selectByMessageId(closeFormDTO.getTopicId()); |
|
|
|
if(null != groupMessage){ |
|
|
|
if (null != groupMessage) { |
|
|
|
groupMessage.setStatus(TopicConstant.CLOSED); |
|
|
|
groupMessageDao.updateById(groupMessage); |
|
|
|
} |
|
|
|
//2021.4.22 end sun
|
|
|
|
// 发送小组成就消息
|
|
|
|
boolean flag = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendGroupAchievementMqMsg(new GroupAchievementMQMsg(topic.getCustomerId(), topic.getGroupId(), AchievementTypeEnum.RESOVLE_TOPIC.getCode())); |
|
|
|
if (!flag) { |
|
|
|
log.error("发送(小组成就)系统消息到message服务失败"); |
|
|
|
} |
|
|
|
boolean flag = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendGroupAchievementMqMsg(new GroupAchievementMQMsg(topic.getCustomerId(), topic.getGroupId(), AchievementTypeEnum.RESOVLE_TOPIC.getCode())); |
|
|
|
if (!flag) { |
|
|
|
log.error("发送(小组成就)系统消息到message服务失败"); |
|
|
|
} |
|
|
|
return new Result(); |
|
|
|
} |
|
|
|
|
|
|
|