feat:增加ws配置

build.gradle

@@ -18,26 +18,29 @@ repositories {
 }
 
 dependencies {
+    implementation 'ch.qos.logback:logback-core:1.5.16'
+    implementation 'cn.hutool:hutool-all:5.8.35'
+    implementation 'com.baomidou:mybatis-plus-boot-starter:3.5.10.1'
+    implementation 'com.baomidou:mybatis-plus-generator:3.5.10.1'
+    implementation 'com.baomidou:mybatis-plus-jsqlparser:3.5.10.1'
+    implementation 'com.github.xiaoymin:knife4j-openapi3-jakarta-spring-boot-starter:4.5.0'
+    implementation 'jakarta.annotation:jakarta.annotation-api:2.1.1'
+    implementation 'org.freemarker:freemarker:2.3.34'
+    implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:3.0.4'
     implementation 'org.springframework.boot:spring-boot-starter'
     implementation 'org.springframework.boot:spring-boot-starter-web'
-    implementation group: 'ch.qos.logback', name: 'logback-core', version: '1.5.16'
-    implementation group: 'org.xerial', name: 'sqlite-jdbc', version: '3.48.0.0'
-    implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:3.0.4'
-    implementation group: 'org.freemarker', name: 'freemarker', version: '2.3.34'
-    implementation group: 'com.baomidou', name: 'mybatis-plus-boot-starter', version: '3.5.10.1'
-    implementation group: 'com.baomidou', name: 'mybatis-plus-jsqlparser', version: '3.5.10.1'
-    implementation group: 'com.baomidou', name: 'mybatis-plus-generator', version: '3.5.10.1'
-    implementation group: 'cn.hutool', name: 'hutool-all', version: '5.8.35'
-    implementation group: 'com.github.xiaoymin', name: 'knife4j-openapi3-jakarta-spring-boot-starter', version: '4.5.0'
-    implementation group: 'org.springframework.boot', name: 'spring-boot-starter-websocket', version: '3.4.2'
-    implementation 'jakarta.annotation:jakarta.annotation-api:2.1.1'
+    implementation 'org.springframework.boot:spring-boot-starter-websocket:3.4.2'
+    implementation 'org.springframework.statemachine:spring-statemachine-core:4.0.0'
+    implementation 'org.xerial:sqlite-jdbc:3.48.0.0'
 
     compileOnly 'org.projectlombok:lombok'
     annotationProcessor 'org.projectlombok:lombok'
+
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
 }
 
+
 tasks.named('test') {
     useJUnitPlatform()
 }

src/main/java/com/iflytop/gd/system/model/dto/WebsocketResult.java

@@ -0,0 +1,18 @@
+package com.iflytop.gd.system.model.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+@Data
+public class WebsocketResult {
+    /**
+     * 推送类型(指令 cmd,报警 warn ,状态 status)
+     */
+    @Schema(description = "推送类型(指令 cmd,报警 warn ,状态 status)")
+    private String type;
+    /**
+     * 执行结果
+     */
+    @Schema(description = "推送数据")
+    private Object data;
+}

src/main/java/com/iflytop/gd/system/service/WebSocketService.java

@@ -0,0 +1,18 @@
+package com.iflytop.gd.system.service;
+
+import cn.hutool.json.JSONUtil;
+import com.iflytop.gd.system.config.WebSocketServer;
+import com.iflytop.gd.system.model.dto.WebsocketResult;
+import org.springframework.stereotype.Service;
+
+@Service
+public class WebSocketService {
+    public void pushMsg(String type, Object result) {
+
+        WebsocketResult websocketResult = new WebsocketResult();
+        websocketResult.setType(type);
+        websocketResult.setData(result);
+        // 发送消息给客户端
+        WebSocketServer.sendMessageToClients(JSONUtil.toJsonStr(websocketResult));
+    }
+}