From 188fa5595d33bc926dca07512c81bed66048d765 Mon Sep 17 00:00:00 2001 From: yangwei <867012372@qq.com> Date: Tue, 20 May 2025 18:16:45 +0800 Subject: [PATCH] =?UTF-8?q?[feat]=E4=BF=AE=E6=94=B9ai=E5=AE=9E=E6=97=B6?= =?UTF-8?q?=E6=B5=81=E9=A2=84=E8=AD=A6=E6=8E=A8=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dromara/system/dubbo/RemoteNoticeServiceImpl.java | 9 ++++++++- 1 file changed, 8 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 e2a7c21..12f890d 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 @@ -16,6 +16,8 @@ import org.dromara.system.service.ISysDictTypeService; import org.springframework.stereotype.Service; import java.util.List; +import java.util.concurrent.ScheduledExecutorService; +import java.util.concurrent.TimeUnit; /** @@ -33,6 +35,8 @@ public class RemoteNoticeServiceImpl implements RemoteNoticeService { private final RemoteMessageService remoteMessageService; private final ISysDictTypeService dictTypeService; + private final ScheduledExecutorService scheduledExecutorService; + @Override public int saveNotice(RemoteNoticeBo bo) { SysNotice notice = MapstructUtils.convert(bo, SysNotice.class); @@ -40,7 +44,10 @@ public class RemoteNoticeServiceImpl implements RemoteNoticeService { 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()); + scheduledExecutorService.schedule(() -> { + remoteMessageService.publishMessage(list, bo.getParam()); + }, 3, TimeUnit.SECONDS); + return sysNoticeMapper.insert(notice); } }