From 3615d6687300a9af90c30ec35dbd63269b690378 Mon Sep 17 00:00:00 2001 From: yq183 <645046984@qq.com> Date: Tue, 20 May 2025 14:52:57 +0800 Subject: [PATCH] =?UTF-8?q?ai=E9=A2=84=E8=AD=A6=E5=B9=B3=E5=8F=B0=E6=8E=A8?= =?UTF-8?q?=E9=80=81=E7=94=A8=E6=88=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dromara/system/dubbo/RemoteNoticeServiceImpl.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/dk-modules/system/src/main/java/org/dromara/system/dubbo/RemoteNoticeServiceImpl.java b/dk-modules/system/src/main/java/org/dromara/system/dubbo/RemoteNoticeServiceImpl.java index 981c85a..e2a7c21 100644 --- a/dk-modules/system/src/main/java/org/dromara/system/dubbo/RemoteNoticeServiceImpl.java +++ b/dk-modules/system/src/main/java/org/dromara/system/dubbo/RemoteNoticeServiceImpl.java @@ -1,5 +1,6 @@ package org.dromara.system.dubbo; +import cn.hutool.core.convert.Convert; import lombok.RequiredArgsConstructor; import org.apache.dubbo.config.annotation.DubboReference; import org.apache.dubbo.config.annotation.DubboService; @@ -9,9 +10,12 @@ import org.dromara.resource.api.RemoteMessageService; import org.dromara.system.api.RemoteNoticeService; import org.dromara.system.api.domain.bo.RemoteNoticeBo; import org.dromara.system.domain.SysNotice; +import org.dromara.system.domain.vo.SysDictDataVo; import org.dromara.system.mapper.SysNoticeMapper; +import org.dromara.system.service.ISysDictTypeService; import org.springframework.stereotype.Service; +import java.util.List; /** @@ -27,12 +31,16 @@ public class RemoteNoticeServiceImpl implements RemoteNoticeService { private final SysNoticeMapper sysNoticeMapper; @DubboReference private final RemoteMessageService remoteMessageService; + private final ISysDictTypeService dictTypeService; @Override public int saveNotice(RemoteNoticeBo bo) { SysNotice notice = MapstructUtils.convert(bo, SysNotice.class); /*String type = dictService.getDictLabel("sys_notice_type", notice.getNoticeType());*/ - remoteMessageService.publishAll(bo.getParam()); + List data = dictTypeService.selectDictDataByType("ai_push"); + List list = data.stream().map(SysDictDataVo::getDictValue).distinct().toList().stream().map(Long::parseLong).toList(); + //获取字典值 + remoteMessageService.publishMessage(list,bo.getParam()); return sysNoticeMapper.insert(notice); } }