opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-19 01:48:47 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

添加测试接口

Browse Source
This commit is contained in:
zzc 2024-11-09 17:29:02 +08:00
parent 61e15be833
commit 231ece98e5
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
ruoyi-admin/src/main/java/org/dromara/web/controller/app/EqHomeController.java
View File

@ -17,6 +17,8 @@ import org.dromara.common.mybatis.core.page.PageQuery;
import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.satoken.utils.LoginHelper; import org.dromara.common.satoken.utils.LoginHelper;
import org.dromara.common.web.core.BaseController; import org.dromara.common.web.core.BaseController;
import org.dromara.common.websocket.dto.WebSocketMessageDto;
import org.dromara.common.websocket.utils.WebSocketUtils;
import org.dromara.system.domain.vo.SysUserVo; import org.dromara.system.domain.vo.SysUserVo;
import org.dromara.system.service.ISysUserService; import org.dromara.system.service.ISysUserService;
import org.dromara.web.domain.bo.*; import org.dromara.web.domain.bo.*;
@ -31,6 +33,8 @@ import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@ -412,8 +416,24 @@ public class EqHomeController extends BaseController {
return R.ok(BCrypt.checkpw(bo.getPassword(), sysUserVo.getPassword())); return R.ok(BCrypt.checkpw(bo.getPassword(), sysUserVo.getPassword()));
} }
private final ScheduledExecutorService scheduledExecutorService;
/**
* 发送websocket消息
* @param msg
* @return
*/
@GetMapping("/sendWebSocketMsg")
public R<Void> sendWebSocketMsg(String msg){
Long userId = LoginHelper.getUserId();
scheduledExecutorService.schedule(() -> {
WebSocketMessageDto dto = new WebSocketMessageDto();
dto.setMessage(msg);
dto.setSessionKeys(List.of(userId));
WebSocketUtils.publishMessage(dto);
}, 3, TimeUnit.SECONDS);
return R.ok();
}
} }