|
@@ -10,10 +10,13 @@ import com.auth0.jwt.JWT;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
+import com.fdkankan.redis.constant.RedisKey;
|
|
|
+import com.fdkankan.redis.util.RedisUtil;
|
|
|
import com.fdkankan.tk.common.FilePath;
|
|
|
import com.fdkankan.tk.common.PageInfo;
|
|
|
import com.fdkankan.tk.common.ResultCode;
|
|
|
import com.fdkankan.tk.common.util.JwtUtil;
|
|
|
+import com.fdkankan.tk.common.util.RedisKeyUtil;
|
|
|
import com.fdkankan.tk.common.util.UploadToOssUtil;
|
|
|
import com.fdkankan.tk.entity.Room;
|
|
|
import com.fdkankan.tk.exception.BusinessException;
|
|
@@ -54,13 +57,23 @@ public class RoomServiceImpl extends ServiceImpl<IRoomMapper, Room> implements I
|
|
|
IWxService wxService;
|
|
|
@Value("${upload.query-path}")
|
|
|
private String queryPath;
|
|
|
+ @Autowired
|
|
|
+ RedisUtil redisUtil;
|
|
|
|
|
|
@Override
|
|
|
public PageInfo pageList(RoomListParam param, String token) {
|
|
|
- String userName = JwtUtil.getUserName(token);
|
|
|
+
|
|
|
|
|
|
LambdaQueryWrapper<Room> wrapper = new LambdaQueryWrapper<>();
|
|
|
- wrapper.eq(Room::getRoomUserName,userName);
|
|
|
+ if(StringUtils.isNotBlank(token)){
|
|
|
+ String fdToken = String.format(RedisKey.TOKEN_V3,token);
|
|
|
+ if(! redisUtil.hasKey(fdToken)){
|
|
|
+ throw new BusinessException(ResultCode.USER_NOT_LOGIN);
|
|
|
+ }
|
|
|
+ redisUtil.expire(fdToken,6 * 60 * 60);
|
|
|
+ String userName = JwtUtil.getUserName(token);
|
|
|
+ wrapper.eq(Room::getRoomUserName,userName);
|
|
|
+ }
|
|
|
if (StringUtils.isNotBlank(param.getRoomTitle()) ) {
|
|
|
wrapper.like(Room::getRoomTitle,param.getRoomTitle());
|
|
|
}
|