|
|
@ -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; |
|
|
@ -1953,7 +1952,7 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
pointEventMsgList.add(pointEventMsg); |
|
|
|
|
|
|
|
//2.转话题为议题 组长
|
|
|
|
BasePointEventMsg pointEventMsg2 = new BasePointEventMsg(); |
|
|
|
/* BasePointEventMsg pointEventMsg2 = new BasePointEventMsg(); |
|
|
|
pointEventMsg2.setCustomerId(groupCache.getCustomerId()); |
|
|
|
pointEventMsg2.setAgencyId(dataFilterResult.getData().getAgencyId()); |
|
|
|
pointEventMsg2.setGridId(group.getGridId()); |
|
|
@ -1970,7 +1969,7 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
new StringBuilder(new StringBuilder(pointEventMsg.getRemark().replaceFirst(new StringBuilder(groupCache.getGroupName()).append("小组中发布的").toString(),"")).reverse() |
|
|
|
.toString().replaceFirst("题议为转被","")).reverse() |
|
|
|
).append("转为议题").toString()); |
|
|
|
pointEventMsgList.add(pointEventMsg2); |
|
|
|
pointEventMsgList.add(pointEventMsg2);*/ |
|
|
|
|
|
|
|
mqBaseMsgDTO.setMsg(JSON.toJSONString(pointEventMsgList)); |
|
|
|
if(!SendMqMsgUtils.sendMsg(mqBaseMsgDTO).success()){ |
|
|
|