From c2c02122386e133c2dbcf79b7a3598adbd428fb6 Mon Sep 17 00:00:00 2001 From: "Ray.Hao" <1490493387@qq.com> Date: Mon, 17 Nov 2025 21:59:35 +0800 Subject: [PATCH] fix(config): update database credentials in application-dev.yml --- .../ai/controller/AiCommandController.java | 3 + .../platform/ai/service/AiCommandService.java | 3 + .../controller/UserOnlineController.java | 55 ------------ .../WebSocketMessageController.java | 83 ------------------- .../controller/WebSocketTestController.java | 54 ------------ src/main/resources/application-dev.yml | 4 +- 6 files changed, 8 insertions(+), 194 deletions(-) delete mode 100644 src/main/java/com/youlai/boot/system/controller/UserOnlineController.java delete mode 100644 src/main/java/com/youlai/boot/system/controller/WebSocketMessageController.java delete mode 100644 src/main/java/com/youlai/boot/system/controller/WebSocketTestController.java diff --git a/src/main/java/com/youlai/boot/platform/ai/controller/AiCommandController.java b/src/main/java/com/youlai/boot/platform/ai/controller/AiCommandController.java index 7a11f0b7..464dfc19 100644 --- a/src/main/java/com/youlai/boot/platform/ai/controller/AiCommandController.java +++ b/src/main/java/com/youlai/boot/platform/ai/controller/AiCommandController.java @@ -88,3 +88,6 @@ public class AiCommandController { } + + + diff --git a/src/main/java/com/youlai/boot/platform/ai/service/AiCommandService.java b/src/main/java/com/youlai/boot/platform/ai/service/AiCommandService.java index 28d972ba..1f5011bf 100644 --- a/src/main/java/com/youlai/boot/platform/ai/service/AiCommandService.java +++ b/src/main/java/com/youlai/boot/platform/ai/service/AiCommandService.java @@ -27,3 +27,6 @@ public interface AiCommandService { } + + + diff --git a/src/main/java/com/youlai/boot/system/controller/UserOnlineController.java b/src/main/java/com/youlai/boot/system/controller/UserOnlineController.java deleted file mode 100644 index 91bf1a0c..00000000 --- a/src/main/java/com/youlai/boot/system/controller/UserOnlineController.java +++ /dev/null @@ -1,55 +0,0 @@ -package com.youlai.boot.system.controller; - -import com.youlai.boot.core.web.Result; -import com.youlai.boot.system.service.UserOnlineService; -import io.swagger.v3.oas.annotations.Operation; -import io.swagger.v3.oas.annotations.tags.Tag; -import lombok.RequiredArgsConstructor; -import org.springframework.security.access.prepost.PreAuthorize; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -import java.util.List; -import java.util.Map; - -/** - * 在线用户控制器 - * - * @author You Lai - * @since 3.0.0 - */ -@Tag(name = "13.在线用户接口") -@RestController -@RequestMapping("/api/v1/users/online") -@RequiredArgsConstructor -public class UserOnlineController { - - private final UserOnlineService userOnlineService; - - /** - * 获取在线用户列表 - * - * @return 在线用户列表 - */ - @Operation(summary = "获取在线用户列表") - @GetMapping - @PreAuthorize("@ss.hasPerm('sys:monitor:online')") - public Result> getOnlineUsers() { - return Result.success(userOnlineService.getOnlineUsers()); - } - - /** - * 获取在线用户统计信息 - * - * @return 在线用户统计 - */ - @Operation(summary = "获取在线用户统计") - @GetMapping("/stats") - @PreAuthorize("@ss.hasPerm('sys:monitor:online')") - public Result> getOnlineStats() { - return Result.success(Map.of( - "count", userOnlineService.getOnlineUserCount() - )); - } -} diff --git a/src/main/java/com/youlai/boot/system/controller/WebSocketMessageController.java b/src/main/java/com/youlai/boot/system/controller/WebSocketMessageController.java deleted file mode 100644 index 46a6f212..00000000 --- a/src/main/java/com/youlai/boot/system/controller/WebSocketMessageController.java +++ /dev/null @@ -1,83 +0,0 @@ -package com.youlai.boot.system.controller; - -import com.youlai.boot.core.security.model.SysUserDetails; -import com.youlai.boot.system.service.WebSocketMessageService; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.messaging.handler.annotation.MessageMapping; -import org.springframework.messaging.handler.annotation.Payload; -import org.springframework.messaging.simp.SimpMessageHeaderAccessor; -import org.springframework.security.core.Authentication; -import org.springframework.stereotype.Controller; - -import java.util.Map; - -/** - * WebSocket消息控制器 - * 用于处理WebSocket客户端发送的消息 - * - * @author You Lai - * @since 3.0.0 - */ -@Controller -@RequiredArgsConstructor -@Slf4j -public class WebSocketMessageController { - - private final WebSocketMessageService webSocketMessageService; - - /** - * 处理发送到指定用户的消息 - * 客户端发送消息到 /app/sendToUser/{username} - * - * @param message 消息内容 - * @param headerAccessor 消息头访问器 - * @param username 接收消息的用户名 - */ - @MessageMapping("/sendToUser/{username}") - public void sendToUser(@Payload String message, SimpMessageHeaderAccessor headerAccessor, String username) { - Authentication authentication = (Authentication) headerAccessor.getUser(); - if (authentication != null) { - SysUserDetails userDetails = (SysUserDetails) authentication.getPrincipal(); - String sender = userDetails.getUsername(); - - // 构建消息 - Map messageData = Map.of( - "sender", sender, - "content", message, - "timestamp", System.currentTimeMillis() - ); - - // 发送点对点消息 - webSocketMessageService.sendPrivateMessage(username, messageData); - log.info("用户[{}]向用户[{}]发送消息: {}", sender, username, message); - } - } - - /** - * 处理广播消息 - * 客户端发送消息到 /app/broadcast - * - * @param message 消息内容 - * @param headerAccessor 消息头访问器 - */ - @MessageMapping("/broadcast") - public void broadcast(@Payload String message, SimpMessageHeaderAccessor headerAccessor) { - Authentication authentication = (Authentication) headerAccessor.getUser(); - if (authentication != null) { - SysUserDetails userDetails = (SysUserDetails) authentication.getPrincipal(); - String sender = userDetails.getUsername(); - - // 构建消息 - Map messageData = Map.of( - "sender", sender, - "content", message, - "timestamp", System.currentTimeMillis() - ); - - // 发送广播消息 - webSocketMessageService.broadcastMessage(messageData); - log.info("用户[{}]发送广播消息: {}", sender, message); - } - } -} \ No newline at end of file diff --git a/src/main/java/com/youlai/boot/system/controller/WebSocketTestController.java b/src/main/java/com/youlai/boot/system/controller/WebSocketTestController.java deleted file mode 100644 index d857b6ae..00000000 --- a/src/main/java/com/youlai/boot/system/controller/WebSocketTestController.java +++ /dev/null @@ -1,54 +0,0 @@ -package com.youlai.boot.system.controller; - -import com.youlai.boot.common.result.Result; -import com.youlai.boot.system.service.WebSocketMessageService; -import io.swagger.v3.oas.annotations.Operation; -import io.swagger.v3.oas.annotations.Parameter; -import io.swagger.v3.oas.annotations.tags.Tag; -import lombok.RequiredArgsConstructor; -import org.springframework.web.bind.annotation.*; - -/** - * WebSocket测试控制器 - * - * @author You Lai - * @since 3.0.0 - */ -@Tag(name = "12.WebSocket接口") -@RestController -@RequestMapping("/api/v1/websocket") -@RequiredArgsConstructor -public class WebSocketTestController { - - private final WebSocketMessageService webSocketMessageService; - - /** - * 发送字典更新事件 - * - * @param dictCode 字典编码 - * @return 操作结果 - */ - @Operation(summary = "发送字典更新事件") - @PostMapping("/dict/{dictCode}/updated") - public Result sendDictUpdatedEvent( - @Parameter(description = "字典编码") @PathVariable String dictCode - ) { - webSocketMessageService.sendDictUpdatedEvent(dictCode); - return Result.success(); - } - - /** - * 发送字典删除事件 - * - * @param dictCode 字典编码 - * @return 操作结果 - */ - @Operation(summary = "发送字典删除事件") - @PostMapping("/dict/{dictCode}/deleted") - public Result sendDictDeletedEvent( - @Parameter(description = "字典编码") @PathVariable String dictCode - ) { - webSocketMessageService.sendDictDeletedEvent(dictCode); - return Result.success(); - } -} \ No newline at end of file diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index 2cc866f7..8af66727 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -6,8 +6,8 @@ spring: type: com.alibaba.druid.pool.DruidDataSource driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://www.youlai.tech:3306/youlai_boot?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true&allowMultiQueries=true - username: root - password: Youlai@2025 + username: youlai + password: 123456 data: redis: database: 0