|
@@ -107,6 +107,7 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
Integer liveState = WrapperUtil.toInt(param, "liveState");
|
|
Integer liveState = WrapperUtil.toInt(param, "liveState");
|
|
Long userId = this.getSysUser().getId();
|
|
Long userId = this.getSysUser().getId();
|
|
Page<LiveRoom> pageInfo = PageUtil.getPageInfo(param);
|
|
Page<LiveRoom> pageInfo = PageUtil.getPageInfo(param);
|
|
|
|
+ pageInfo.setDesc("id_");
|
|
IPage<LiveRoom> page = this.page(pageInfo, Wrappers.<LiveRoom>lambdaQuery()
|
|
IPage<LiveRoom> page = this.page(pageInfo, Wrappers.<LiveRoom>lambdaQuery()
|
|
.eq(WrapperUtil.StrPredicate.test(roomType), LiveRoom::getType, roomType)
|
|
.eq(WrapperUtil.StrPredicate.test(roomType), LiveRoom::getType, roomType)
|
|
.eq(WrapperUtil.ObjPredicate.test(liveState), LiveRoom::getLiveState, liveState)
|
|
.eq(WrapperUtil.ObjPredicate.test(liveState), LiveRoom::getLiveState, liveState)
|
|
@@ -301,8 +302,6 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
log.info("createTempLiveRoom>>>>>>room:{}", room.getRoomUid());
|
|
log.info("createTempLiveRoom>>>>>>room:{}", room.getRoomUid());
|
|
//去融云创建房间及创建房间缓存信息
|
|
//去融云创建房间及创建房间缓存信息
|
|
this.createLiveRoomInfo(room, sysUser);
|
|
this.createLiveRoomInfo(room, sysUser);
|
|
- //临时
|
|
|
|
- this.pushLiveCreateRoom(room);
|
|
|
|
//写入临时直播间列表
|
|
//写入临时直播间列表
|
|
RMap<Long, String> map = redissonClient.getMap(TEACHER_TEMP_LIVE_ROOM);
|
|
RMap<Long, String> map = redissonClient.getMap(TEACHER_TEMP_LIVE_ROOM);
|
|
map.put(teacherId, roomUid);
|
|
map.put(teacherId, roomUid);
|
|
@@ -337,6 +336,8 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
roomCache.setSpeakerPic(sysUser.getAvatar());
|
|
roomCache.setSpeakerPic(sysUser.getAvatar());
|
|
roomCache.setSpeakerState(1);
|
|
roomCache.setSpeakerState(1);
|
|
roomCache.setRoomUid(room.getRoomUid());
|
|
roomCache.setRoomUid(room.getRoomUid());
|
|
|
|
+ roomCache.setRoomTitle(room.getRoomTitle());
|
|
|
|
+ roomCache.setLiveRemark(room.getLiveRemark());
|
|
roomCache.setLiveStartTime(room.getLiveStartTime());
|
|
roomCache.setLiveStartTime(room.getLiveStartTime());
|
|
roomCache.setLiveEndTime(room.getLiveEndTime());
|
|
roomCache.setLiveEndTime(room.getLiveEndTime());
|
|
roomCache.setCreateRoomTime(new Date());
|
|
roomCache.setCreateRoomTime(new Date());
|
|
@@ -621,8 +622,6 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
|
|
|
/**
|
|
/**
|
|
* 主讲人
|
|
* 主讲人
|
|
- *
|
|
|
|
- * @return true 是主讲人 false 不是主讲人
|
|
|
|
*/
|
|
*/
|
|
private void opsSpeaker(RBucket<RoomInfoCache> roomInfoCache, ImUserStateSync user, Date now, String userIdStr) {
|
|
private void opsSpeaker(RBucket<RoomInfoCache> roomInfoCache, ImUserStateSync user, Date now, String userIdStr) {
|
|
RoomInfoCache roomInfo = roomInfoCache.get();
|
|
RoomInfoCache roomInfo = roomInfoCache.get();
|