shayu/cai-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

init

Browse Source
This commit is contained in:
dute7liang
2024-01-11 22:10:29 +08:00
parent 2043169ff3
commit f7485b9066
3 changed files with 44 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
ruoyi-cai/src/main/java/com/ruoyi/cai/chat/ChatManager.java
View File

@@ -52,10 +52,11 @@ public class ChatManager {
@Autowired
private StringRedisTemplate redisTemplate;
private String setWsToken(Long roomId,Long fromUid,Long toUid){
private String setWsToken(Long roomId,Long fromUid,Long toUid,Long userId){
String token = IdManager.nextIdStr();
String tokenKey = String.format(RedisConstant.WS_TOKEN, token);
Map<String,Object> map = new HashMap<>();
map.put("userId",userId);
map.put("roomId",roomId);
map.put("fromUid",fromUid);
map.put("toUid",toUid);
@@ -84,7 +85,7 @@ public class ChatManager {
roomId = webSocketManager.createRoom(call.getId());
}
String wsSocketUrlFormat = systemConfigManager.getSystemConfig(SystemConfigEnum.WS_SOCKET_URL);
String token = setWsToken(roomId, fromUser.getId(), toUser.getId());
String token = setWsToken(roomId, fromUser.getId(), toUser.getId(),userId);
String weSocketUrl = String.format(wsSocketUrlFormat,token,roomId);
Long guardPrice = systemConfigManager.getSystemConfigOfLong(SystemConfigEnum.GUARD_PRICE);
// 获取鉴黄规则 TODO
@@ -125,7 +126,9 @@ public class ChatManager {
User fromUser = userMap.get(userCall.getFromUid());
User toUser = userMap.get(userCall.getToUid());
Anchor anchor = anchorService.getByUserId(toUser.getId());
String weSocketUrl = String.format(properties.getWebSocketUrl(),"token",roomId);
String wsSocketUrlFormat = systemConfigManager.getSystemConfig(SystemConfigEnum.WS_SOCKET_URL);
String token = setWsToken(userCall.getId(), fromUser.getId(), toUser.getId(), userId);
String weSocketUrl = String.format(wsSocketUrlFormat,token,roomId);
GetRoomResp getRoomResp = new GetRoomResp();
getRoomResp.setRoomId(userCall.getId()+"");
getRoomResp.setFromUid(userCall.getFromUid());