From 3828da2dcf04946847af5099f20e443766663003 Mon Sep 17 00:00:00 2001 From: songyuanlun Date: Wed, 22 Nov 2023 17:55:46 +0800 Subject: [PATCH 1/2] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E5=8F=91im?= =?UTF-8?q?=E6=B6=88=E6=81=AF=EF=BC=8C=E6=9C=AA=E6=8C=89=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E8=BF=87=E6=BB=A4=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center/message/service/impl/GeneralMessageServiceImpl.java | 1 + 1 file changed, 1 insertion(+) 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 0ab4e86a..f079e955 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 @@ -175,6 +175,7 @@ public class GeneralMessageServiceImpl implements GeneralMessageService { return Collections.emptyList(); } return result.getData().stream() + .filter(MessageDispatchResp::sendSuccess) .map(SendImMessageDTO::from) .collect(Collectors.toList()); } From eef5c9b8543df571520bdee92dec442c9f107a7f Mon Sep 17 00:00:00 2001 From: songyuanlun Date: Wed, 22 Nov 2023 17:57:36 +0800 Subject: [PATCH 2/2] =?UTF-8?q?fix:=20=E5=8F=91=E9=80=81im=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E9=9C=80=E8=A6=81=E8=BF=87=E6=BB=A4=20personId=3D0=20?= =?UTF-8?q?=E7=9A=84=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/GeneralMessageMapperServiceImpl.java | 8 ++++++++ 1 file changed, 8 insertions(+) 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.");