diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageMapperServiceImpl.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageMapperServiceImpl.java index 46288909..b83a72be 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageMapperServiceImpl.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageMapperServiceImpl.java @@ -67,6 +67,14 @@ public class GeneralMessageMapperServiceImpl implements GeneralMessageMapperServ log.info("relation id is null."); return; } + log.info("request toldIdPersonIdMap= [{}]", JSON.toJSONString(request.getToldIdPersonIdMap())); + // IM 需要personId,过滤掉 personId = 0 的数据 + Map imToldIdPersonIdMap = request.getToldIdPersonIdMap().entrySet() + .stream() + .filter(entry -> entry.getValue() > 0) + .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); + log.info("new toldIdPersonIdMap= [{}]", JSON.toJSONString(imToldIdPersonIdMap)); + request.setToldIdPersonIdMap(imToldIdPersonIdMap); if (MapUtil.isEmpty(request.getToldIdPersonIdMap())) { // 由于IM那边是根据personId来创建账户的,所以强依赖personId log.info("toIdPersonIdMap is empty."); diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageServiceImpl.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageServiceImpl.java index e9438374..2bbc0cae 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageServiceImpl.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/GeneralMessageServiceImpl.java @@ -174,6 +174,7 @@ public class GeneralMessageServiceImpl implements GeneralMessageService { return Collections.emptyList(); } return result.getData().stream() + .filter(MessageDispatchResp::sendSuccess) .map(SendImMessageDTO::from) .collect(Collectors.toList()); }