Merge branch 'feature/REQ-1677-syl' into 'dev'

Feature/req 1677 syl

See merge request universal/infrastructure/backend/msg-center-plat!70

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<Long,Long> 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.");

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());
     }