|
@@ -133,7 +133,7 @@ public class NoticeInfoServiceImpl extends ServiceImpl<NoticeInfoMapper, NoticeI
|
|
|
Integer messageType = noticeInfoReq.getMessageType();
|
|
|
String scopeId = noticeInfoReq.getScopeId();
|
|
|
Set<String> messageClientIds = this.getMessageClientIds(messageType, scopeId);
|
|
|
-
|
|
|
+ log.info("transferIds-scopeId-{}-{}",scopeId,messageClientIds);
|
|
|
if (CollUtil.isNotEmpty(messageClientIds)) {
|
|
|
NoticeInfoSend noticeInfoSend = this.doSaveNoticeInfo(noticeInfoReq, messageClientIds);
|
|
|
isSend = producer.send(KafkaInitialConfiguration.sseTopic + "a1", JSON.toJSONString(noticeInfoSend));
|