Skip to content

Y
yd-communication
Commit a50e6eba by zhangxingmin
Options

push

parent 0a453475
Showing with 2 additions and 1 deletions
yd-communication-api/src/main/java/com/yd/communication/api/service/impl/ApiCoSessionServiceImpl.java
...@@ -3,6 +3,7 @@ package com.yd.communication.api.service.impl; ...@@ -3,6 +3,7 @@ package com.yd.communication.api.service.impl;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.yd.common.enums.CommonEnum; import com.yd.common.enums.CommonEnum;
import com.yd.common.enums.ResultCode;
import com.yd.common.exception.BusinessException; import com.yd.common.exception.BusinessException;
import com.yd.common.result.JsonResult; import com.yd.common.result.JsonResult;
import com.yd.common.result.Result; import com.yd.common.result.Result;
...@@ -371,7 +372,7 @@ public class ApiCoSessionServiceImpl implements ApiCoSessionService { ...@@ -371,7 +372,7 @@ public class ApiCoSessionServiceImpl implements ApiCoSessionService {
//校验房间链接是否失效 //校验房间链接是否失效
String roomLink = redisUtil.getCacheObject(RedisEnum.ROOM_LINK.getPrefix() + roomId + ":" + roomPwd); String roomLink = redisUtil.getCacheObject(RedisEnum.ROOM_LINK.getPrefix() + roomId + ":" + roomPwd);
if (StringUtils.isBlank(roomLink)) { if (StringUtils.isBlank(roomLink)) {
throw new BusinessException("访问链接已失效，请重新生成"); throw new BusinessException(ResultCode.LINK_INVALID.getCode(),"访问链接已失效，请重新生成");
} }
LambdaQueryWrapper<CoSession> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<CoSession> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(CoSession::getRoomId, roomId) wrapper.eq(CoSession::getRoomId, roomId)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment