From b06857e8c81e3610213f76c0aa7844ab721870df Mon Sep 17 00:00:00 2001
From: dataprince <dataprince@163.com>
Date: Wed, 17 Jan 2024 20:24:48 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=9A=E7=9F=A5=E5=85=AC=E5=91=8A=E6=A8=A1?=
 =?UTF-8?q?=E5=9D=97=E4=BD=BF=E7=94=A8websocket=E6=8E=A8=E9=80=81=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ruoyi-modules/ruoyi-system/pom.xml                          | 5 +++++
 .../ruoyi/system/controller/system/SysNoticeController.java | 6 ++++++
 2 files changed, 11 insertions(+)

diff --git a/ruoyi-modules/ruoyi-system/pom.xml b/ruoyi-modules/ruoyi-system/pom.xml
index 1fb3887..3deb66b 100644
--- a/ruoyi-modules/ruoyi-system/pom.xml
+++ b/ruoyi-modules/ruoyi-system/pom.xml
@@ -85,6 +85,11 @@
             <artifactId>ruoyi-common-web</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.ruoyi</groupId>
+            <artifactId>ruoyi-common-websocket</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/system/SysNoticeController.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/system/SysNoticeController.java
index 22263cc..beeb93a 100644
--- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/system/SysNoticeController.java
+++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/system/SysNoticeController.java
@@ -3,10 +3,12 @@ package com.ruoyi.system.controller.system;
 
 import cn.dev33.satoken.annotation.SaCheckPermission;
 import com.ruoyi.common.core.core.domain.R;
+import com.ruoyi.common.core.service.DictService;
 import com.ruoyi.common.log.annotation.Log;
 import com.ruoyi.common.log.enums.BusinessType;
 import com.ruoyi.common.orm.core.page.TableDataInfo;
 import com.ruoyi.common.web.annotation.RepeatSubmit;
+import com.ruoyi.common.websocket.utils.WebSocketUtils;
 import com.ruoyi.system.domain.bo.SysNoticeBo;
 import com.ruoyi.system.domain.vo.SysNoticeVo;
 import jakarta.annotation.Resource;
@@ -36,6 +38,8 @@ public class SysNoticeController extends BaseController
 {
     @Resource
     private ISysNoticeService noticeService;
+    @Resource
+    private DictService dictService;
 
     /**
      * 获取通知公告列表
@@ -70,6 +74,8 @@ public class SysNoticeController extends BaseController
         if (!inserted) {
             return R.fail("新增通知公告记录失败！");
         }
+        String type = dictService.getDictLabel("sys_notice_type", noticeBo.getNoticeType());
+        WebSocketUtils.publishAll("[" + type + "] " + noticeBo.getNoticeTitle());
         return R.ok();
     }