[feat]修改ai实时流预警推送

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<SysDictDataVo> data = dictTypeService.selectDictDataByType("ai_push");
         List<Long> 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);
     }
 }