live接口改造

cooleshow-common/src/main/java/com/yonge/cooleshow/common/enums/live/ELiveViewMode.java

@@ -0,0 +1,32 @@
+package com.yonge.cooleshow.common.enums.live;
+
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.yonge.toolset.base.enums.BaseEnum;
+import lombok.Getter;
+
+/**
+ * 直播观看模式
+ */
+@Getter
+public enum ELiveViewMode implements BaseEnum<String, ELiveViewMode> {
+
+    LOGIN("登陆"),
+    VISITOR("游客"),
+    ;
+
+    private final String describe;
+
+    @EnumValue
+    private final String code;
+
+    ELiveViewMode(String describe) {
+        this.describe = describe;
+
+        this.code = this.name();
+    }
+
+    @Override
+    public String getCode() {
+        return code;
+    }
+}

cooleshow-common/src/main/java/com/yonge/cooleshow/common/enums/live/EUseScene.java

@@ -0,0 +1,40 @@
+package com.yonge.cooleshow.common.enums.live;
+
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.yonge.toolset.base.enums.BaseEnum;
+
+public enum EUseScene implements BaseEnum<String, EUseScene> {
+
+    /**
+     * 正常
+     */
+    NORMAL( "正常"),
+
+    /**
+     * 音乐
+     */
+    MUSIC( "音乐"),
+
+    ;
+
+    @EnumValue
+    private String code;
+
+    private String msg;
+
+    EUseScene(String msg) {
+        this.code = this.name();
+        this.msg = msg;
+    }
+
+
+    /**
+     * 获取枚举类的code值
+     *
+     * @return
+     */
+    @Override
+    public String getCode() {
+        return this.code;
+    }
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/constant/LiveRoomConstant.java

@@ -37,5 +37,7 @@ public interface LiveRoomConstant {
 
     //正在临时直播间的房间列表
     String TEACHER_TEMP_LIVE_ROOM = String.join(":", COOLESHOW, "TEACHER_TEMP_LIVE_ROOM");
+    //主讲人信息
+    String LIVE_SPEAKER_INFO = String.join(":", "IM:LIVE_SPEAKER_INFO", ROOM_UID, USER_ID);
 
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/dao/LiveBroadcastRoomMemberDao.java

@@ -4,6 +4,7 @@ import java.util.List;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
 import org.apache.ibatis.annotations.Param;
 import com.yonge.cooleshow.biz.dal.entity.LiveBroadcastRoomMember;
 import com.yonge.cooleshow.biz.dal.vo.LiveBroadcastRoomMemberVo;
@@ -26,5 +27,5 @@ public interface LiveBroadcastRoomMemberDao extends BaseMapper<LiveBroadcastRoom
      * @return: com.yonge.cooleshow.biz.dal.vo.LiveBroadcastRoomMemberVo
 	 */
 	List<LiveBroadcastRoomMemberVo> selectPage(@Param("page") IPage page, @Param("param") LiveBroadcastRoomMemberSearch liveBroadcastRoomMember);
-	
+
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/entity/ImLiveBroadcastRoomMember.java

@@ -0,0 +1,77 @@
+package com.yonge.cooleshow.biz.dal.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.IdType;
+import lombok.Data;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+import java.util.Date;
+
+
+/**
+ * 直播间人员关系表
+ * 2023-08-15 15:50:17
+ */
+@Data
+@ApiModel(" ImLiveBroadcastRoomMember-直播间人员关系表")
+@TableName("im_live_broadcast_room_member")
+public class ImLiveBroadcastRoomMember implements Serializable {
+
+    @ApiModelProperty("主键") 
+	    @TableId(value = "id_", type = IdType.AUTO)
+        private Integer id;
+
+    @ApiModelProperty("房间编号") 
+	@TableField(value = "room_uid_")
+    private String roomUid;
+
+    @ApiModelProperty("进入房间的人员id/学生id") 
+	@TableField(value = "user_id_")
+    private Integer userId;
+
+    @ApiModelProperty("进入房间时间") 
+	@TableField(value = "join_time_")
+    private Date joinTime;
+
+    @ApiModelProperty("累计观看时间/以分钟为单位") 
+	@TableField(value = "total_time_")
+    private Integer totalTime;
+
+    @ApiModelProperty("在线状态;0离线；1在线") 
+	@TableField(value = "online_status_")
+    private Integer onlineStatus;
+
+    @ApiModelProperty("禁言状态:0取消；1禁言") 
+	@TableField(value = "ban_status_")
+    private Integer banStatus;
+
+    @ApiModelProperty("直播状态: 0离开;1观看") 
+	@TableField(value = "live_room_status_")
+    private Integer liveRoomStatus;
+
+    @ApiModelProperty("连麦状态 0:未申请1:申请连麦中2:连麦中") 
+	@TableField(value = "whether_mic_status_")
+    private Integer whetherMicStatus;
+
+    @ApiModelProperty("是否能上麦:0否；1是") 
+	@TableField(value = "microphone_flag_")
+    private Boolean microphoneFlag;
+
+    @ApiModelProperty("游客凭据") 
+	@TableField(value = "fingerprint_")
+    private String fingerprint;
+
+    @ApiModelProperty("游客名称") 
+	@TableField(value = "visitor_name_")
+    private String visitorName;
+
+    @ApiModelProperty("创建时间") 
+	@TableField(value = "create_time_")
+    private Date createTime;
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/entity/LiveBroadcastRoomData.java

@@ -0,0 +1,53 @@
+package com.yonge.cooleshow.biz.dal.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.IdType;
+import lombok.Data;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+import java.util.Date;
+
+
+/**
+ * 直播房间数据表
+ * 2023-08-15 15:50:17
+ */
+@Data
+@ApiModel(" LiveBroadcastRoomData-直播房间数据表")
+@TableName("live_broadcast_room_data")
+public class LiveBroadcastRoomData implements Serializable {
+
+    @ApiModelProperty("主键") 
+	    @TableId(value = "id_", type = IdType.AUTO)
+        private Integer id;
+
+    @ApiModelProperty("房间uid") 
+	@TableField(value = "room_uid_")
+    private String roomUid;
+
+    @ApiModelProperty("直播时长") 
+	@TableField(value = "live_time_")
+    private Integer liveTime;
+
+    @ApiModelProperty("累计点赞数") 
+	@TableField(value = "like_num_")
+    private Integer likeNum;
+
+    @ApiModelProperty("即时观看人员数") 
+	@TableField(value = "look_user_num_")
+    private Integer lookUserNum;
+
+    @ApiModelProperty("累计观看总人员数") 
+	@TableField(value = "total_user_num_")
+    private Integer totalUserNum;
+
+    @ApiModelProperty("更新时间") 
+	@TableField(value = "updated_time_")
+    private Date updatedTime;
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/entity/LiveRoom.java

@@ -4,6 +4,8 @@ package com.yonge.cooleshow.biz.dal.entity;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
+import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
+import com.yonge.cooleshow.common.enums.live.ELiveViewMode;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -36,6 +38,12 @@ public class LiveRoom implements Serializable {
     @ApiModelProperty(value = "主讲人id/老师id")
     private Long speakerId;
 
+
+
+    @TableField("client_type_")
+    @ApiModelProperty("用户类型 TEACHER 老师 ")
+    private ClientEnum clientType;
+
     @TableField("room_uid_")
     @ApiModelProperty(value = "房间编号")
     private String roomUid;
@@ -76,6 +84,30 @@ public class LiveRoom implements Serializable {
     @ApiModelProperty(value = "房间类型 live直播课  temp临时直播间")
     private String type;
 
+    @TableField("pre_template_")
+    @ApiModelProperty(value = "预热模版")
+    private String preTemplate;
+
+    @TableField("os_")
+    @ApiModelProperty(value = "播出端-  pc网页端 移动端mobile")
+    private String os;
+
+    @TableField("speaker_status_")
+    @ApiModelProperty(value = "主播状态: 0离开;1在播")
+    private Integer speakerStatus;
+
+    @TableField("push_status_")
+    @ApiModelProperty(value = "推流状态: 0 暂停; 1在播")
+    private Integer pushStatus;
+
+    @TableField("ban_status_")
+    @ApiModelProperty(value = "禁言状态: 0 取消；1禁言")
+    private Integer banStatus;
+
+    @TableField("view_mode_")
+    @ApiModelProperty("直播观看模式")
+    private ELiveViewMode viewMode;
+
     @TableField("cover_pic_")
     @ApiModelProperty(value = "封面图片")
     private String coverPic;

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/enums/RoomTypeEnum.java

@@ -7,7 +7,7 @@ import java.util.stream.Collectors;
 public enum RoomTypeEnum {
 
     LIVE("直播课"),
-//    PRACTICE("陪练课"),
+    PRACTICE("陪练课"),
     TEMP("临时直播间");
 
     private final String code;

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/mapper/ImLiveBroadcastRoomMemberMapper.java

@@ -0,0 +1,55 @@
+package com.yonge.cooleshow.biz.dal.mapper;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+import com.yonge.cooleshow.biz.dal.entity.ImLiveBroadcastRoomMember;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
+
+/**
+ * 直播间人员关系表
+ * 2023-08-15 15:50:17
+ */
+@Repository
+public interface ImLiveBroadcastRoomMemberMapper extends BaseMapper<ImLiveBroadcastRoomMember> {
+
+	/**
+	 * 分页查询
+	 * @param page IPage<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember>
+	 * @param param ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMemberQuery
+	 * @return List<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember>
+	 */
+	List<ImLiveBroadcastRoomMember> selectPage(@Param("page") IPage<ImLiveBroadcastRoomMember> page, @Param("param") ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMemberQuery param);
+
+    /**
+     * 查询房间人数
+     *
+     * @param roomUid 房间id
+     */
+    ImLiveBroadcastRoomMemberWrapper.RoomMemberNumDto queryMemberNum(@Param("roomUid") String roomUid);
+
+    /**
+     * 修改用户连麦状态
+     *
+     * @param roomUid          直播房间id
+     * @param userId           用户id
+     * @param whetherMicStatus 连麦状态
+     */
+    void userWhetherMic(@Param("roomUid") String roomUid, @Param("userId") Long userId, @Param(
+            "whetherMicStatus") Integer whetherMicStatus);
+
+    /**
+     * 学生声部
+     * @param studentIds 学生编号
+     * @return List<ImLiveBroadcastRoomMemberVo>
+     */
+    List<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> selectStudentSubject(@Param("studentIds") List<Integer> studentIds);
+
+    IPage<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> queryMemberPage(Page<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> pageInfo, @Param("param") Map<String, Object> param);
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/mapper/LiveBroadcastRoomDataMapper.java

@@ -0,0 +1,27 @@
+package com.yonge.cooleshow.biz.dal.mapper;
+
+import java.util.List;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+import com.yonge.cooleshow.biz.dal.entity.LiveBroadcastRoomData;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.LiveBroadcastRoomDataWrapper;
+
+/**
+ * 直播房间数据表
+ * 2023-08-15 15:50:17
+ */
+@Repository
+public interface LiveBroadcastRoomDataMapper extends BaseMapper<LiveBroadcastRoomData> {
+
+	/**
+	 * 分页查询
+	 * @param page IPage<LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData>
+	 * @param param LiveBroadcastRoomDataWrapper.LiveBroadcastRoomDataQuery
+	 * @return List<LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData>
+	 */
+	List<LiveBroadcastRoomData> selectPage(@Param("page") IPage<LiveBroadcastRoomData> page, @Param("param") LiveBroadcastRoomDataWrapper.LiveBroadcastRoomDataQuery param);
+	
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/ImLiveBroadcastRoomMemberService.java

@@ -0,0 +1,51 @@
+package com.yonge.cooleshow.biz.dal.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
+import com.yonge.cooleshow.biz.dal.entity.ImLiveBroadcastRoomMember;
+import com.yonge.toolset.base.page.PageInfo;
+
+import java.util.Map;
+
+/**
+ * 直播间人员关系表
+ * 2023-08-15 15:50:17
+ */
+public interface ImLiveBroadcastRoomMemberService extends IService<ImLiveBroadcastRoomMember>  {
+
+	/**
+     * 查询详情
+     * @param id 详情ID
+     * @return ImLiveBroadcastRoomMember
+     */
+	ImLiveBroadcastRoomMember detail(Long id);
+
+    /**
+     * 分页查询
+     * @param page IPage<ImLiveBroadcastRoomMember>
+     * @param query ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMemberQuery
+     * @return IPage<ImLiveBroadcastRoomMember>
+     */
+    IPage<ImLiveBroadcastRoomMember> selectPage(IPage<ImLiveBroadcastRoomMember> page, ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMemberQuery query);
+	
+    /**
+     * 添加
+     * @param imLiveBroadcastRoomMember ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember
+     * @return Boolean
+     */
+     Boolean add(ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember imLiveBroadcastRoomMember);   
+
+    /**
+     * 更新
+     * @param imLiveBroadcastRoomMember ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember
+     * @return Boolean
+     */
+     Boolean update(ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember imLiveBroadcastRoomMember);
+
+
+    /**
+     * 查询房间观看人员详情
+     */
+    PageInfo<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> queryRoomMember(Map<String, Object> param);
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/LiveBroadcastRoomDataService.java

@@ -0,0 +1,43 @@
+package com.yonge.cooleshow.biz.dal.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.LiveBroadcastRoomDataWrapper;
+import com.yonge.cooleshow.biz.dal.entity.LiveBroadcastRoomData;
+
+/**
+ * 直播房间数据表
+ * 2023-08-15 15:50:17
+ */
+public interface LiveBroadcastRoomDataService extends IService<LiveBroadcastRoomData>  {
+
+	/**
+     * 查询详情
+     * @param id 详情ID
+     * @return LiveBroadcastRoomData
+     */
+	LiveBroadcastRoomData detail(Long id);
+
+    /**
+     * 分页查询
+     * @param page IPage<LiveBroadcastRoomData>
+     * @param query LiveBroadcastRoomDataWrapper.LiveBroadcastRoomDataQuery
+     * @return IPage<LiveBroadcastRoomData>
+     */
+    IPage<LiveBroadcastRoomData> selectPage(IPage<LiveBroadcastRoomData> page, LiveBroadcastRoomDataWrapper.LiveBroadcastRoomDataQuery query);
+	
+    /**
+     * 添加
+     * @param liveBroadcastRoomData LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData
+     * @return Boolean
+     */
+     Boolean add(LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData liveBroadcastRoomData);   
+
+    /**
+     * 更新
+     * @param liveBroadcastRoomData LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData
+     * @return Boolean
+     */
+     Boolean update(LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData liveBroadcastRoomData);
+     
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/LiveRoomService.java

@@ -5,6 +5,7 @@ import java.util.List;
 import java.util.Map;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.microsvc.toolkit.middleware.live.message.TencentWrapper;
 import com.yonge.cooleshow.biz.dal.dao.LiveRoomDao;
 import com.yonge.cooleshow.biz.dal.dto.LiveRoomStatus;
 import com.yonge.cooleshow.biz.dal.dto.TencentData;
@@ -13,7 +14,6 @@ import com.yonge.cooleshow.biz.dal.enums.RoomTypeEnum;
 import com.yonge.cooleshow.biz.dal.vo.TeacherLivingInfoVo;
 import com.yonge.cooleshow.biz.dal.wrapper.liveroom.LiveRoomWrapper;
 import com.yonge.toolset.base.page.PageInfo;
-import org.springframework.transaction.annotation.Transactional;
 
 /**
  * 直播房间与课程的关系表表(LiveRoom)表服务接口
@@ -43,14 +43,14 @@ public interface LiveRoomService extends IService<LiveRoom> {
      */
     RoomInfoCache studentCheckRoomInfo(String roomUid);
 
+
     /**
      * 主讲人查询并校验房间信息
      *
      * @param roomUid 房间uid
-     * @param userId  主讲人id
      * @return
      */
-    RoomInfoCache speakerCheckRoomInfo(String roomUid);
+    LiveRoomWrapper.LiveRoomVo speakerCheckRoomInfo(String roomUid);
 
     /**
      * 定时任务创建直播间
@@ -92,13 +92,6 @@ public interface LiveRoomService extends IService<LiveRoom> {
      */
     void syncLike(String roomUid, Integer likeNum);
 
-    /**
-     * 主讲人-进入房间
-     *
-     * @param roomUid 房间uid
-     * @param userId  主讲人id
-     */
-    RoomInfoCache speakerJoinRoom(String roomUid);
 
     /**
      * 观看者-进入房间
@@ -182,5 +175,49 @@ public interface LiveRoomService extends IService<LiveRoom> {
      */
     Boolean updateRoomStatus(LiveRoomStatus status);
 
+    /**
+     * 进入直播间检查数据
+     *
+     * @param roomUid 房间uid
+     * @param userId  用户id
+     * @param osType  默认学生端  0:pc端 1:学生端 2:老师端
+     */
+    LiveRoomWrapper.LiveRoomVo queryRoomAndCheck(String roomUid, Long userId, int osType);
+
+    /**
+     * 直播间推流状态查询
+     *
+     * @param roomUid 房间号
+     */
+    TencentWrapper.LiveStreamState roomLiveStreamStatus(String roomUid);
+
+
+    /**
+     * 查询直播间信息
+     *
+     * @param roomUid 直播间uid
+     */
+    LiveRoomWrapper.LiveRoomVo queryRoomInfo(String roomUid);
+
+    /**
+     * 同步直播间点赞数
+     *
+     * @param roomUid 直播间uid
+     * @return int
+     */
+    int syncLikeCount(String roomUid);
+
+
+    List<LiveRoomWrapper.BaseRoomUserVo> queryRoomLimitOnlineUserInfo(String roomUid);
+
+
+    /**
+     * 修改用户连麦状态
+     *
+     * @param roomUid 直播房间id
+     * @param userId 用户id
+     * @param whetherMicStatus 连麦状态
+     */
+    void userWhetherMic(String roomUid, Long userId, Integer whetherMicStatus);
 }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImLiveBroadcastRoomMemberServiceImpl.java

@@ -0,0 +1,164 @@
+package com.yonge.cooleshow.biz.dal.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import com.yonge.cooleshow.auth.api.client.SysUserFeignService;
+import com.yonge.cooleshow.auth.api.entity.SysUser;
+import com.yonge.cooleshow.biz.dal.entity.LiveRoom;
+import com.yonge.cooleshow.biz.dal.service.LiveRoomService;
+import com.yonge.toolset.base.exception.BizException;
+import com.yonge.toolset.base.page.PageInfo;
+import com.yonge.toolset.mybatis.support.PageUtil;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.collections.MapUtils;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.BeanUtils;
+import lombok.extern.slf4j.Slf4j;
+import com.yonge.cooleshow.biz.dal.entity.ImLiveBroadcastRoomMember;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
+import com.yonge.cooleshow.biz.dal.mapper.ImLiveBroadcastRoomMemberMapper;
+import com.yonge.cooleshow.biz.dal.service.ImLiveBroadcastRoomMemberService;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+/**
+ * 直播间人员关系表
+ * 2023-08-15 15:50:17
+ */
+@Slf4j
+@Service
+public class ImLiveBroadcastRoomMemberServiceImpl extends ServiceImpl<ImLiveBroadcastRoomMemberMapper, ImLiveBroadcastRoomMember> implements ImLiveBroadcastRoomMemberService {
+
+    @Autowired
+    private LiveRoomService liveRoomService;
+
+    @Autowired
+    private SysUserFeignService sysUserFeignService;
+
+	/**
+     * 查询详情
+     * @param id 详情ID
+     * @return ImLiveBroadcastRoomMember
+     */
+	@Override
+    public ImLiveBroadcastRoomMember detail(Long id) {
+        
+        return baseMapper.selectById(id);
+    }
+    
+    /**
+     * 分页查询
+     * @param page IPage<ImLiveBroadcastRoomMember>
+     * @param query ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMemberQuery
+     * @return IPage<ImLiveBroadcastRoomMember>
+     */
+    @Override
+    public IPage<ImLiveBroadcastRoomMember> selectPage(IPage<ImLiveBroadcastRoomMember> page, ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMemberQuery query) {
+        
+        return page.setRecords(baseMapper.selectPage(page, query));
+    }
+	
+    /**
+     * 添加
+     * @param imLiveBroadcastRoomMember ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember
+     * @return Boolean
+     */
+    @Override
+    public Boolean add(ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember imLiveBroadcastRoomMember) {    	
+        
+        return this.save(JSON.parseObject(imLiveBroadcastRoomMember.jsonString(), ImLiveBroadcastRoomMember.class));
+    }
+
+    /**
+     * 更新
+     * @param imLiveBroadcastRoomMember ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember
+     * @return Boolean
+     */
+    @Override
+    public Boolean update(ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember imLiveBroadcastRoomMember){
+
+        return this.updateById(JSON.parseObject(imLiveBroadcastRoomMember.jsonString(), ImLiveBroadcastRoomMember.class));       
+    }
+
+    @Override
+    public PageInfo<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> queryRoomMember(Map<String, Object> param) {
+        Page<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> pageInfo = PageUtil.getPageInfo(param);
+
+        IPage<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> page = baseMapper.queryMemberPage(pageInfo, param);
+
+        List<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> records = page.getRecords();
+
+        if (CollectionUtils.isNotEmpty(records)) {
+
+            // 游客默认头像
+
+            String roomUid = MapUtils.getString(param, "roomUid", RandomStringUtils.random(5));
+            // 直播间信息
+            LiveRoom room =liveRoomService.lambdaQuery()
+                    .eq(LiveRoom::getRoomUid, roomUid)
+                    .last("LIMIT 1")
+                    .one();
+            if (Objects.isNull(room)) {
+                throw new BizException("直播间不存在");
+            }
+            // 直播间主讲老师
+            SysUser speaker = sysUserFeignService.queryUserById(room.getSpeakerId());
+
+
+            List<Integer> studentIds = records.stream()
+                    .filter(x -> StringUtils.isBlank(x.getFingerprint()))
+                    .map(ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember::getStudentId)
+                    .filter(Objects::nonNull)
+                    .distinct().collect(Collectors.toList());
+
+            // 学生报名乐团
+            Map<Integer, String> musicGroupMap = Maps.newConcurrentMap();
+            // 学生声部名称
+            Map<Integer, String> subjectMap = Maps.newConcurrentMap();
+
+            // 直播客户端查询在线用户信息时，忽略学生相关信息查询
+            if (MapUtils.getIntValue(param, "rows", 10) < 100) {
+
+                for (List<Integer> item : Lists.partition(studentIds, 500)) {
+                    // 并发查询学生信息
+                    Lists.partition(item, 50).parallelStream().forEach(data -> {
+
+                        // 学生声部名称
+                        Map<Integer, String> collect = baseMapper.selectStudentSubject(studentIds).stream()
+                                .filter(x -> Objects.nonNull(x) && Objects.nonNull(x.getStudentId()))
+                                .collect(Collectors.toMap(ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember::getStudentId, x -> Optional.ofNullable(x.getSubName()).orElse(""), (o, n) -> n));
+                        if (MapUtils.isNotEmpty(collect)) {
+                            subjectMap.putAll(collect);
+                        }
+                    });
+                }
+            }
+
+            for (ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember item : records) {
+
+                if (StringUtils.isNotEmpty(item.getFingerprint())) {
+
+                } else {
+                    // 设置默认数据
+                    item.setSubName(subjectMap.getOrDefault(item.getStudentId(), ""));
+                    item.setRoomTitle(room.getRoomTitle());
+                    item.setSpeakerName(speaker.getRealName());
+                }
+
+            }
+        }
+
+        return PageUtil.pageInfo(page);
+    }
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/LiveBroadcastRoomDataServiceImpl.java

@@ -0,0 +1,66 @@
+package com.yonge.cooleshow.biz.dal.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.BeanUtils;
+import lombok.extern.slf4j.Slf4j;
+import com.yonge.cooleshow.biz.dal.entity.LiveBroadcastRoomData;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.LiveBroadcastRoomDataWrapper;
+import com.yonge.cooleshow.biz.dal.mapper.LiveBroadcastRoomDataMapper;
+import com.yonge.cooleshow.biz.dal.service.LiveBroadcastRoomDataService;
+
+/**
+ * 直播房间数据表
+ * 2023-08-15 15:50:17
+ */
+@Slf4j
+@Service
+public class LiveBroadcastRoomDataServiceImpl extends ServiceImpl<LiveBroadcastRoomDataMapper, LiveBroadcastRoomData> implements LiveBroadcastRoomDataService {
+
+	/**
+     * 查询详情
+     * @param id 详情ID
+     * @return LiveBroadcastRoomData
+     */
+	@Override
+    public LiveBroadcastRoomData detail(Long id) {
+        
+        return baseMapper.selectById(id);
+    }
+    
+    /**
+     * 分页查询
+     * @param page IPage<LiveBroadcastRoomData>
+     * @param query LiveBroadcastRoomDataWrapper.LiveBroadcastRoomDataQuery
+     * @return IPage<LiveBroadcastRoomData>
+     */
+    @Override
+    public IPage<LiveBroadcastRoomData> selectPage(IPage<LiveBroadcastRoomData> page, LiveBroadcastRoomDataWrapper.LiveBroadcastRoomDataQuery query) {
+        
+        return page.setRecords(baseMapper.selectPage(page, query));
+    }
+	
+    /**
+     * 添加
+     * @param liveBroadcastRoomData LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData
+     * @return Boolean
+     */
+    @Override
+    public Boolean add(LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData liveBroadcastRoomData) {    	
+        
+        return this.save(JSON.parseObject(liveBroadcastRoomData.jsonString(), LiveBroadcastRoomData.class));
+    }
+
+    /**
+     * 更新
+     * @param liveBroadcastRoomData LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData
+     * @return Boolean
+     */
+    @Override
+    public Boolean update(LiveBroadcastRoomDataWrapper.LiveBroadcastRoomData liveBroadcastRoomData){
+
+        return this.updateById(JSON.parseObject(liveBroadcastRoomData.jsonString(), LiveBroadcastRoomData.class));       
+    }
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/LiveRoomServiceImpl.java

@@ -1,19 +1,10 @@
 package com.yonge.cooleshow.biz.dal.service.impl;
 
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_ROOM_HEART_BEAT;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_ROOM_INFO;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_ROOM_LIKE;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_ROOM_ONLINE_USER_LIST;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_ROOM_TOTAL_USER_LIST;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_USER_LAST_CLIENT_IP;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_USER_LAST_TIME;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.LIVE_USER_ROOM;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.ROOM_UID;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.TEACHER_TEMP_LIVE_ROOM;
-import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.USER_ID;
+import static com.yonge.cooleshow.biz.dal.constant.LiveRoomConstant.*;
 import static com.yonge.cooleshow.common.constant.SysConfigConstant.DESTROY_EXPIRED_LIVE_ROOM_MINUTE;
 import static com.yonge.cooleshow.common.constant.SysConfigConstant.PRE_CREATE_LIVE_ROOM_MINUTE;
 
+import java.io.Serializable;
 import java.text.MessageFormat;
 import java.time.LocalDate;
 import java.time.ZoneId;
@@ -26,6 +17,7 @@ import java.util.function.Function;
 import java.util.stream.Collectors;
 
 import com.alibaba.fastjson.JSON;
+import com.fasterxml.jackson.annotation.JsonFormat;
 import com.microsvc.toolkit.middleware.live.LivePluginContext;
 import com.microsvc.toolkit.middleware.live.LivePluginService;
 import com.microsvc.toolkit.middleware.live.impl.RongCloudLivePlugin;
@@ -36,10 +28,13 @@ import com.yonge.cooleshow.biz.dal.dto.TencentData;
 import com.yonge.cooleshow.biz.dal.entity.*;
 import com.yonge.cooleshow.biz.dal.enums.live.EAnchorStatus;
 import com.yonge.cooleshow.biz.dal.enums.live.EOnOffStatus;
+import com.yonge.cooleshow.biz.dal.mapper.ImLiveBroadcastRoomMemberMapper;
 import com.yonge.cooleshow.biz.dal.mapper.SysUserMapper;
 import com.yonge.cooleshow.biz.dal.service.*;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
 import com.yonge.cooleshow.biz.dal.wrapper.liveroom.LiveRoomWrapper;
 import com.yonge.cooleshow.common.enums.EGroupDefinedDataType;
+import lombok.Data;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.joda.time.DateTime;
@@ -125,6 +120,15 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
 
     @Autowired
     private LiveRoomVideoService liveRoomVideoService;
+
+    @Autowired
+    private LiveBroadcastRoomDataService liveBroadcastRoomDataService;
+
+    @Autowired
+    private ImLiveBroadcastRoomMemberMapper imLiveBroadcastRoomMemberMapper;
+
+    @Autowired
+    private ImGroupService imGroupService;
     /**
      * 生成房间UID
      *
@@ -181,10 +185,13 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
      * @return
      */
     @Override
-    public RoomInfoCache speakerCheckRoomInfo(String roomUid) {
-        Long userId = this.getSysUser().getId();
-        LiveRoom liveRoom = this.getOne(Wrappers.<LiveRoom>lambdaQuery()
-                .eq(LiveRoom::getRoomUid, roomUid));
+    @Transactional(rollbackFor = Exception.class)
+    public LiveRoomWrapper.LiveRoomVo speakerCheckRoomInfo(String roomUid) {
+
+        SysUser sysUser = getSysUser();
+        Long userId = sysUser.getId();
+        LiveRoomWrapper.LiveRoomVo liveRoom = queryRoomInfo(roomUid);
+        LiveRoom room = getByRoomUid(roomUid);
         if (Objects.isNull(liveRoom)) {
             log.error("teacherCheckRoomInfo>>>live not start  roomUid: {} userId:{}", roomUid, userId);
             throw new BizException("直播还未开始!");
@@ -198,17 +205,83 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
             log.error("teacherCheckRoomInfo>>>live not start  roomUid: {} userId:{}", roomUid, userId);
             throw new BizException("直播还未开始!");
         }
-        RoomInfoCache roomInfo = roomInfoCache.get();
+        Date now = new Date();
         //校验进入房间的是否是该直播间的主讲人
-        if (!roomInfo.getSpeakerId().equals(userId)) {
+        if (!liveRoom.getSpeakerId().equals(userId)) {
             log.error("teacherCheckRoomInfo>>>not speaker  roomUid: {} userId:{}", roomUid, userId);
             throw new BizException("您不是该直播间的主讲人!");
         }
-        roomInfo.setLikeNum(getLike(roomUid));
-        roomInfo.setLookNum(getNum.apply(this::getOnlineUserCache, roomUid));
-        return roomInfo;
+        //获取直播间信息
+        RBucket<RoomSpeakerInfo> speakerCache = getRoomSpeakerInfoCache(roomUid, userId.toString());
+        if (!speakerCache.isExists()) {
+
+            //没有主讲人信息则生成一个
+            createSpeakerInfo(this.getById(liveRoom.getId()), sysUser);
+
+            // 查询主播缓存信息
+            speakerCache = getRoomSpeakerInfoCache(roomUid, userId.toString());
+        }
+        RoomSpeakerInfo speakerInfo = speakerCache.get();
+        speakerInfo.setJoinRoomTime(now);
+        speakerCache.set(speakerInfo);
+
+        //记录用户当前房间uid
+        redissonClient.getBucket(LIVE_USER_ROOM.replace(USER_ID, userId.toString())).set(roomUid, 12L, TimeUnit.HOURS);
+
+        // 更新直播间主播状态
+        lambdaUpdate()
+                .eq(LiveRoom::getRoomUid, roomUid)
+                .eq(LiveRoom::getSpeakerId, userId)
+                .set(LiveRoom::getSpeakerStatus, 1)
+                .update();
+
+        // 设置直播群组自定义数据
+        setGroupDefinedData(room,EGroupDefinedDataType.ANCHOR_STATUS,EAnchorStatus.ONLINE.getCode());
+        return liveRoom;
+    }
+
+    /**
+     * 获取房间主讲人消息
+     *
+     * @param roomUid 房间uid
+     * @param userId  用户id
+     */
+    private RBucket<RoomSpeakerInfo> getRoomSpeakerInfoCache(String roomUid, String userId) {
+        return redissonClient.getBucket(LIVE_SPEAKER_INFO.replace(USER_ID, userId).replace(ROOM_UID, roomUid));
     }
 
+
+    //生成主讲人信息
+    private void createSpeakerInfo(LiveRoom room, SysUser sysUser) {
+        Date now = new Date();
+        RoomSpeakerInfo speakerInfo = new RoomSpeakerInfo();
+        speakerInfo.setSpeakerId(sysUser.getId());
+        speakerInfo.setSpeakerName(sysUser.getRealName());
+        speakerInfo.setCreateRoomTime(now);
+        speakerInfo.setRoomUid(room.getRoomUid());
+        speakerInfo.setTotalLiveTime(0);
+
+        //可以录制视频
+        speakerInfo.setWhetherVideo(0);
+        // 设置模板
+        speakerInfo.setVideoTemplate(1);
+
+        speakerInfo.setOs(room.getOs());
+        //写入主讲人信息
+        getRoomSpeakerInfoCache(room.getRoomUid(), room.getSpeakerId().toString()).set(speakerInfo);
+
+        //生成0点赞
+        redissonClient.getBucket(LIVE_ROOM_LIKE.replace(ROOM_UID, room.getRoomUid())).set(0);
+
+        //修改房间状态为开始
+        LiveRoom liveRoomUpdate = new LiveRoom();
+        liveRoomUpdate.setId(room.getId());
+        liveRoomUpdate.setLiveState(1);
+        liveRoomUpdate.setUpdatedTime(now);
+        liveRoomUpdate.setUpdatedBy(-2L);
+        liveRoomUpdate.setSpeakerStatus(1);
+        baseMapper.updateById(liveRoomUpdate);
+    }
     /**
      * 定时任务创建直播间
      */
@@ -939,25 +1012,6 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
         redissonClient.getBucket(LIVE_ROOM_HEART_BEAT.replace(ROOM_UID, roomUid)).set(new Date());
     }
 
-    /**
-     * 主讲人-进入房间
-     *
-     * @param roomUid 房间uid
-     */
-    public RoomInfoCache speakerJoinRoom(String roomUid) {
-        RoomInfoCache roomInfo = this.speakerCheckRoomInfo(roomUid);
-
-        CourseSchedule schedule = getCourseScheduleByRoomUid(roomUid);
-        Date now = new Date();
-        roomInfo.setSpeakerState(0);
-        roomInfo.setJoinRoomTime(now);
-        liveBroadcastRoomMemberService.saveRecord(roomUid, roomInfo.getSpeakerId(), InOrOutEnum.IN, YesOrNoEnum.NO);
-        //查询老师是否有进入过，没有则写老师考勤表的进入时间
-        this.setTeacherAttendance(roomInfo.getSpeakerId(), schedule.getCourseGroupId(), schedule.getId());
-        //记录当前用户对应的房间uid
-        redissonClient.getBucket(LIVE_USER_ROOM.replace(USER_ID, roomInfo.getSpeakerId().toString())).set(roomUid, 2L, TimeUnit.DAYS);
-        return roomInfo;
-    }
 
     /**
      * 观看者-进入房间
@@ -1689,5 +1743,291 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
         return true;
     }
 
+    /**
+     * 进入直播间检查数据
+     *
+     * @param roomUid 房间uid
+     * @param userId  用户id
+     * @param osType  默认学生端  0:pc端 1:学生端 2:老师端
+     */
+    @Override
+    public LiveRoomWrapper.LiveRoomVo queryRoomAndCheck(String roomUid, Long userId, int osType) {
+
+        SysUser sysUser = Optional.ofNullable(userId)
+                .map(this::getSysUser)
+                .orElseGet(this::getSysUser);
+
+        // 默认学生端查询
+        osType = Optional.ofNullable(osType).orElse(1);
+        ClientEnum clientEnum = ClientEnum.TEACHER;
+
+        // 移动端-学生端
+        if (osType == 1) {
+            clientEnum = ClientEnum.STUDENT;
+            //学生端
+            this.checkStudentRoom(roomUid, sysUser);
+        }
+        // 移动端-老师端
+        if (osType == 2) {
+            //老师端
+//            return teacherQueryRoomAndCheck(roomUid, sysUser);
+        }
+        // PC端-直播助手
+        if (osType == 3) {
+            // 校验直播间是否存在
+            LiveRoomWrapper.LiveRoomVo vo = Optional.ofNullable(roomUid).map(this::queryRoomInfo)
+                    .orElseThrow(() -> new BizException("直播间不存在"));
+
+            if (vo.getOs().equals("mobile")) {
+                throw new BizException("该直播间仅可在手机端直播");
+            }
+        }
+
+        return this.queryRoomAndCheck(queryRoomInfo(roomUid), sysUser,clientEnum);
+    }
+
+
+    public LiveRoomWrapper.LiveRoomVo queryRoomAndCheck(LiveRoomWrapper.LiveRoomVo room, SysUser sysUser,ClientEnum clientType) {
+
+
+        if (room.getLiveState() == 2) {
+            //如果直播结束了还是推广状态则将推广修改为取消
+            throw new BizException("直播已结束！");
+        }
+
+        if (room.getRoomState() == 1) {
+            throw new BizException("直播间不存在");
+        }
+
+
+        room.setBlacklistFlag(0);
+
+        LivePluginService pluginService = livePluginContext.getPluginService(room.getServiceProvider());
+        // 直播房间配置信息
+        String userSig = "";
+        try {
+            userSig = pluginService.register(imGroupService.getImUserId(sysUser.getId().toString(),clientType.getCode()), sysUser.getUsername(),
+                    sysUser.getAvatar());
+        } catch (Exception e) {
+            log.error("直播房间用户注册失败: userId={}", sysUser.getId(), e);
+        }
+
+        // 直播房间统计信息
+        getRoomData(room);
+        room.setUserSig(userSig);
+        room.setLiveRoomConfig(pluginService.getLiveRoomConfig());
+
+        // 直播间配置信息
+        return room;
+    }
+
+
+    /**
+     * 直播间推流状态查询
+     *
+     * @param roomUid 直播间ID
+     * @return TencentWrapper.LiveStreamState
+     */
+    @Override
+    public TencentWrapper.LiveStreamState roomLiveStreamStatus(String roomUid) {
+
+        // 直播间信息
+        LiveRoomWrapper.LiveRoomVo roomVo = queryRoomInfo(roomUid);
+        if (Objects.isNull(roomVo)) {
+            throw new BizException("无效的直播间ID");
+        }
+
+        TencentWrapper.LiveStreamState liveStreamState = TencentWrapper.LiveStreamState
+                .builder()
+                .streamState("inactive")
+                .requestId("")
+                .build();
+        // 直播间推流状态
+        try {
+            LivePluginService pluginService = livePluginContext.getPluginService(roomVo.getServiceProvider());
+
+            liveStreamState = pluginService.liveStreamState(getStreamId(roomUid, roomVo.getSpeakerId()));
+        } catch (Exception e) {
+            log.error("roomLiveStreamStatus roomUid={}", roomUid, e);
+        }
+
+        return liveStreamState;
+    }
+
+
+    /**
+     * 查询直播间信息
+     *
+     * @param roomUid 直播间uid
+     */
+    @Override
+    public LiveRoomWrapper.LiveRoomVo queryRoomInfo(String roomUid) {
+        LiveRoom liveRoom = getByRoomUid(roomUid);
+        if (Objects.isNull(liveRoom)) {
+            throw new BizException("直播间不存在");
+        }
+        LiveRoomWrapper.LiveRoomVo liveRoomVo = JSON.parseObject(JSON.toJSONString(liveRoom), LiveRoomWrapper.LiveRoomVo.class);
+        return getRoomData(liveRoomVo);
+    }
+
+    private LiveRoomWrapper.LiveRoomVo getRoomData(LiveRoomWrapper.LiveRoomVo roomVo) {
+
+        // 同步点赞数
+        int likeNums = syncLikeCount(roomVo.getRoomUid());
+
+        roomVo.setLikeNum(likeNums);
+        roomVo.setTotalLookNum(0);
+        roomVo.setLookNum(0);
+
+        ImLiveBroadcastRoomMemberWrapper.RoomMemberNumDto roomMemberNumDto = imLiveBroadcastRoomMemberMapper.queryMemberNum(roomVo.getRoomUid());
+        if (roomMemberNumDto == null) {
+            roomMemberNumDto = new ImLiveBroadcastRoomMemberWrapper.RoomMemberNumDto();
+            roomMemberNumDto.setTotalNum(0);
+            roomMemberNumDto.setOnlineNum(0);
+        }
+        roomVo.setTotalLookNum(roomMemberNumDto.getTotalNum() == null? 0 : roomMemberNumDto.getTotalNum());
+        roomVo.setLookNum(roomMemberNumDto.getOnlineNum() == null? 0 : roomMemberNumDto.getOnlineNum());
+
+        // 直播视频数
+        List<LiveRoomVideo> imLiveRoomVideoVos = liveRoomVideoService.queryVideo(roomVo.getRoomUid());
+        if (CollectionUtils.isNotEmpty(imLiveRoomVideoVos)) {
+            roomVo.setVideoNum(imLiveRoomVideoVos.size());
+        } else {
+            roomVo.setVideoNum(0);
+        }
+        return roomVo;
+    }
+
+
+    /**
+     * 同步直播间点赞数
+     *
+     * @param roomUid 直播间uid
+     * @return int
+     */
+    @Override
+    public int syncLikeCount(String roomUid) {
+
+        // 直播间信息
+        LiveRoom room = getByRoomUid(roomUid);
+        if (room == null) {
+            return 0;
+        }
+
+        // 融云直播间
+        if (room.getServiceProvider().equals(RongCloudLivePlugin.PLUGIN_NAME)) {
+            //点赞数
+            return (int) Optional.ofNullable(redissonClient.getBucket(LIVE_ROOM_LIKE.replace(ROOM_UID, roomUid)).get()).orElse(0);
+        }
+
+
+        // 腾讯云直播
+        LivePluginService pluginService = livePluginContext.getPluginService(room.getServiceProvider());
+        List<TencentWrapper.ChatRoomGroupCounter> chatRoomGroupCounters = null;
+        try {
+            chatRoomGroupCounters = pluginService.chatRoomGroupCounterDataList(
+                    room.getRoomUid());
+        } catch (Exception e) {
+            log.error("同步直播间点赞数失败", e);
+        }
+        if (CollectionUtils.isEmpty(chatRoomGroupCounters)) {
+            return 0;
+        }
+        Optional<TencentWrapper.ChatRoomGroupCounter> first = chatRoomGroupCounters.stream()
+                .filter(a -> a.getKey()
+                        .equals(
+                                EGroupDefinedDataType.LIKES.getCode()))
+                .findFirst();
+
+        if (first.isPresent()) {
+            int i = Integer.parseInt(first.get().getValue());
+
+            LiveBroadcastRoomData one = liveBroadcastRoomDataService.lambdaQuery()
+                    .eq(LiveBroadcastRoomData::getRoomUid, roomUid)
+                    .last("limit 1")
+                    .one();
+            // 同步点赞数
+            if (one != null) {
+                LiveBroadcastRoomData imLiveBroadcastRoomData = new LiveBroadcastRoomData();
+                imLiveBroadcastRoomData.setId(one.getId());
+                imLiveBroadcastRoomData.setLikeNum(i);
+                liveBroadcastRoomDataService.updateById(imLiveBroadcastRoomData);
+            }
+
+            return i;
+        }
+        return 0;
+    }
+
+
+    /**
+     * 查询直播间在线的用户
+     *
+     * @param roomUid 直播间uid
+     */
+    @Override
+    public List<LiveRoomWrapper.BaseRoomUserVo> queryRoomLimitOnlineUserInfo(String roomUid) {
+        RMap<Long, String> onlineUserCache = getOnlineUserCache(roomUid);
+        return onlineUserCache.values().parallelStream()
+                .map(a -> JSONObject.toJavaObject(JSONObject.parseObject(a), LiveRoomWrapper.BaseRoomUserVo.class))
+                .limit(200)
+                .collect(Collectors.toList());
+    }
+
+    /**
+     * 修改用户连麦状态
+     *
+     * @param roomUid          直播房间id
+     * @param userId           用户id
+     * @param whetherMicStatus 连麦状态
+     */
+    @Override
+    public void userWhetherMic(String roomUid, Long userId, Integer whetherMicStatus) {
+        imLiveBroadcastRoomMemberMapper.userWhetherMic(roomUid, userId, whetherMicStatus);
+    }
+
+    /**
+     * 主讲人信息
+     */
+    @Data
+    public static class RoomSpeakerInfo implements Serializable {
+        //主讲人id
+        private Long speakerId;
+        //主讲人名称
+        private String speakerName;
+        //直播状态 0 直播中 1关闭直播
+        private Integer state;
+        //房间uid
+        private String roomUid;
+        // 直播流sequence
+        private String sequence;
+
+        //房间创建时间
+        private Date createRoomTime;
+        //进入房间时间
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+        private Date joinRoomTime;
+        //开始直播时间
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+        private Date startLiveTime;
+        //开始直播时间
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+        private Date endLiveTime;
+        //退出房间时间
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+        private Date exitRoomTime;
+        //总直播时间
+        private Integer totalLiveTime = 0;
+        //是否录像 0允许 1不允许
+        private Integer whetherVideo;
+        //机构
+        private Integer tenantId;
+        //播出端-  pc网页端 移动端mobile
+        private String os = "pc";
+
+        // 腾讯视频模板 0: 没有 1：有
+        private Integer videoTemplate;
+
+    }
 }
 

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/wrapper/liveroom/ImLiveBroadcastRoomMemberWrapper.java

@@ -0,0 +1,121 @@
+package com.yonge.cooleshow.biz.dal.wrapper.liveroom;
+
+import com.alibaba.fastjson.JSON;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.util.Date;
+import java.util.Optional;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+
+/**
+ * 直播间人员关系表
+ * 2023-08-15 15:50:17
+ */
+@ApiModel(value = "ImLiveBroadcastRoomMemberWrapper对象", description = "直播间人员关系表查询对象")
+public class ImLiveBroadcastRoomMemberWrapper {
+
+    @Data
+	@Builder
+    @NoArgsConstructor
+    @AllArgsConstructor
+    @ApiModel(" ImLiveBroadcastRoomMemberQuery-直播间人员关系表")
+    public static class ImLiveBroadcastRoomMemberQuery implements QueryInfo {
+    
+    	@ApiModelProperty("当前页")
+        private Integer page;
+        
+        @ApiModelProperty("分页行数")
+        private Integer rows;
+        
+        @ApiModelProperty("关键字匹配")
+		private String keyword;
+        
+        public String getKeyword() {
+            return Optional.ofNullable(keyword).filter(StringUtils::isNotBlank).orElse(null);
+        }
+        
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static ImLiveBroadcastRoomMemberQuery from(String json) {
+            return JSON.parseObject(json, ImLiveBroadcastRoomMemberQuery.class);
+        }
+    }  
+
+    @Data
+	@ApiModel(" ImLiveBroadcastRoomMember-直播间人员关系表")
+    public static class ImLiveBroadcastRoomMember {
+
+
+        @ApiModelProperty(value = "房间编号")
+        private String roomUid;
+
+        @ApiModelProperty(value = "房间标题")
+        private String roomTitle;
+
+        @ApiModelProperty(value = "主讲人")
+        private String speakerName;
+
+        @ApiModelProperty(value = "学生编号")
+        private Integer studentId;
+
+        @ApiModelProperty(value = "学生姓名")
+        private String studentName;
+
+        @ApiModelProperty(value = "学生头像")
+        private String avatar;
+
+        @ApiModelProperty(value = "手机号")
+        private String phone;
+
+        @ApiModelProperty(value = "声部名称")
+        private String subName;
+
+        @ApiModelProperty(value = "进入房间时间")
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        private Date joinTime;
+
+        @ApiModelProperty(value = "累计观看时长")
+        private Integer totalViewTime;
+
+        @ApiModelProperty(value = "连麦状态 0:未申请1:申请连麦中2:连麦中")
+        private Integer whetherMicStatus;
+
+        @ApiModelProperty(value = "是否黑名单")
+        private boolean blackFlag;
+
+        @ApiModelProperty("游客凭据")
+        private String fingerprint;
+
+        @ApiModelProperty(value = "是否能上麦:false否；true是")
+        private boolean microphoneFlag;
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static ImLiveBroadcastRoomMember from(String json) {
+            return JSON.parseObject(json, ImLiveBroadcastRoomMember.class);
+        }
+	}
+
+    @Data
+    public static class RoomMemberNumDto {
+
+        private String roomUid;
+
+        private Integer onlineNum;
+
+        private Integer totalNum;
+    }
+
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/wrapper/liveroom/LiveBroadcastRoomDataWrapper.java

@@ -0,0 +1,63 @@
+package com.yonge.cooleshow.biz.dal.wrapper.liveroom;
+
+import com.alibaba.fastjson.JSON;
+import com.microsvc.toolkit.common.response.paging.QueryInfo;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.Optional;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+
+/**
+ * 直播房间数据表
+ * 2023-08-15 15:50:17
+ */
+@ApiModel(value = "LiveBroadcastRoomDataWrapper对象", description = "直播房间数据表查询对象")
+public class LiveBroadcastRoomDataWrapper {
+
+    @Data
+	@Builder
+    @NoArgsConstructor
+    @AllArgsConstructor
+    @ApiModel(" LiveBroadcastRoomDataQuery-直播房间数据表")
+    public static class LiveBroadcastRoomDataQuery implements QueryInfo {
+    
+    	@ApiModelProperty("当前页")
+        private Integer page;
+        
+        @ApiModelProperty("分页行数")
+        private Integer rows;
+        
+        @ApiModelProperty("关键字匹配")
+		private String keyword;
+        
+        public String getKeyword() {
+            return Optional.ofNullable(keyword).filter(StringUtils::isNotBlank).orElse(null);
+        }
+        
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static LiveBroadcastRoomDataQuery from(String json) {
+            return JSON.parseObject(json, LiveBroadcastRoomDataQuery.class);
+        }
+    }  
+
+	@ApiModel(" LiveBroadcastRoomData-直播房间数据表")
+    public static class LiveBroadcastRoomData {
+        
+        public String jsonString() {
+            return JSON.toJSONString(this);
+        }
+
+        public static LiveBroadcastRoomData from(String json) {
+            return JSON.parseObject(json, LiveBroadcastRoomData.class);
+        }
+	}
+
+}

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/wrapper/liveroom/LiveRoomWrapper.java

@@ -1,6 +1,13 @@
 package com.yonge.cooleshow.biz.dal.wrapper.liveroom;
 
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.microsvc.toolkit.middleware.live.message.LiveRoomConfig;
+import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
+import com.yonge.cooleshow.common.enums.live.ELiveViewMode;
+import com.yonge.cooleshow.common.enums.live.EUseScene;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
@@ -74,4 +81,158 @@ public class LiveRoomWrapper implements Serializable {
         private String avatar;
         private String realName;
     }
+
+
+    /**
+     * 直播间老师信息
+     */
+    @Data
+    @NoArgsConstructor
+    @AllArgsConstructor
+    public static class LiveRoomVo implements Serializable {
+        @ApiModelProperty(value = "主键")
+        private Integer id;
+
+        @ApiModelProperty(value = "房间编号")
+        private String roomUid;
+
+        @ApiModelProperty(value = "房间标题/最多12个字")
+        private String roomTitle;
+
+        @ApiModelProperty(value = "直播内容/最多200个字")
+        private String liveRemark;
+
+        @ApiModelProperty(value = "主讲人id/老师id")
+        private Long speakerId;
+
+        @ApiModelProperty("用户类型 TEACHER 老师")
+        private ClientEnum clientType;
+
+        @ApiModelProperty(value = "主讲人名称")
+        private String speakerName;
+
+        @ApiModelProperty(value = "主讲人头像")
+        private String speakerPic;
+
+        @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+        @ApiModelProperty(value = "直播开始时间")
+        private Date liveStartTime;
+
+        @ApiModelProperty(value = "直播状态 0未开始 1开始 2结束")
+        private Integer liveState;
+
+        @ApiModelProperty(value = "直播时长")
+        private Integer liveTotalTime;
+
+        @ApiModelProperty(value = "房间状态 0正常 1已删除")
+        private Integer roomState;
+
+        @ApiModelProperty(value = "创建人")
+        private String createdByName;
+
+        @ApiModelProperty(value = "预热模版")
+        private String preTemplate;
+
+        @ApiModelProperty(value = "房间配置json格式-是否允许点赞-是否允许聊天互动-是否允许保存直播回放")
+        private String roomConfig;
+
+        @ApiModelProperty(value = "imToken")
+        private String imToken;
+
+        @ApiModelProperty(value = "播出端-  pc网页端 移动端mobile")
+        private String os;
+
+        @ApiModelProperty(value = "是否在首页推广 0否 1是 - 每个机构只能有一个直播间在首页推广")
+        private Integer popularize;
+
+        @ApiModelProperty(value = "是否预约过该直播间 0否 1是")
+        private Integer reserve;
+
+        @ApiModelProperty(value = "当前登录人是否是黑名单用户 0否 1是")
+        private Integer blacklistFlag = 0;
+
+        @ApiModelProperty(value = "直播间可见类型-全部可见 ALL / 部分可见 PRIVATE")
+        private String popularizeType;
+
+        @ApiModelProperty(value = "点赞数")
+        private Integer likeNum;
+        @ApiModelProperty(value = "当前观看人数")
+        private Integer lookNum;
+        @ApiModelProperty(value = "累计观看人数")
+        private Integer totalLookNum;
+
+        @ApiModelProperty("预约人数")
+        private Integer roomReservationNum;
+
+        @ApiModelProperty("直播间用户签名")
+        private String userSig;
+
+
+        @ApiModelProperty(value = "服务提供方 ")
+        private String serviceProvider;
+
+        @ApiModelProperty("直播配置")
+        private LiveRoomConfig liveRoomConfig;
+
+        @ApiModelProperty(value = "主播状态: 0离开;1在播")
+        private Integer speakerStatus;
+
+        @ApiModelProperty(value = "推流状态: 0 暂停; 1在播")
+        private Integer pushStatus;
+
+        @ApiModelProperty(value = "禁言状态: 0 取消；1禁言")
+        private Integer banStatus;
+
+        @ApiModelProperty("视频数量")
+        private Integer videoNum;
+
+        @ApiModelProperty("直播观看模式")
+        private ELiveViewMode viewMode;
+
+        @ApiModelProperty("购物车标题")
+        private String shoppingTitle;
+
+        @ApiModelProperty("使用场景 正常：NORMAL 音乐：MUSIC")
+        private EUseScene useScene;
+
+        @ApiModelProperty("课程结束后多少分钟关闭网络教室")
+        private String autoCloseNetworkRoomTime;
+
+        @ApiModelProperty("剩余时长")
+        private int surplusTime;
+
+        @ApiModelProperty("声部ID")
+        private Integer subjectId;
+
+
+        @ApiModelProperty("直播类型 NORMAL:普通直播  LIVE:直播课直播")
+        private String  groupType;
+
+
+        @TableField("video_record_")
+        @ApiModelProperty(value = "录制记录")
+        private String videoRecord;
+
+
+        @TableField("live_end_time_")
+        @ApiModelProperty(value = "直播结束时间")
+        private Date liveEndTime;
+
+        @TableField("type_")
+        @ApiModelProperty(value = "房间类型 live直播课  temp临时直播间")
+        private String type;
+
+
+        @ApiModelProperty(value = "封面图片")
+        private String coverPic;
+
+    }
+
+    @Data
+    public static class BaseRoomUserVo implements Serializable {
+
+        private Integer userId;
+
+        private String userName;
+    }
 }

cooleshow-user/user-biz/src/main/resources/config/mybatis/ImLiveBroadcastRoomMemberMapper.xml

@@ -0,0 +1,101 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE  mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.yonge.cooleshow.biz.dal.mapper.ImLiveBroadcastRoomMemberMapper">
+
+	 
+    
+    <!-- 表字段 -->
+    <sql id="baseColumns">
+         t.id_ AS id
+        , t.room_uid_ AS roomUid
+        , t.user_id_ AS userId
+        , t.join_time_ AS joinTime
+        , t.total_time_ AS totalTime
+        , t.online_status_ AS onlineStatus
+        , t.ban_status_ AS banStatus
+        , t.live_room_status_ AS liveRoomStatus
+        , t.whether_mic_status_ AS whetherMicStatus
+        , t.microphone_flag_ AS microphoneFlag
+        , t.fingerprint_ AS fingerprint
+        , t.visitor_name_ AS visitorName
+        , t.create_time_ AS createTime
+        </sql> 
+    
+    <select id="selectPage" resultType="com.yonge.cooleshow.biz.dal.entity.ImLiveBroadcastRoomMember">
+		SELECT         
+        	<include refid="baseColumns" />
+		FROM im_live_broadcast_room_member t
+	</select>
+
+
+    <select id="queryMemberNum"
+            resultType="com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper$RoomMemberNumDto">
+        select room_uid_ as roomUid,
+        count(1) as totalNum ,
+        sum(if(online_status_ = 1 and live_room_status_ = 1,1,0)) as onlineNum
+        from im_live_broadcast_room_member
+        where room_uid_ = #{roomUid}
+        group by room_uid_
+    </select>
+
+
+    <update id="userWhetherMic">
+        update im_live_broadcast_room_member
+        set whether_mic_status_ = #{whetherMicStatus}
+        where room_uid_ = #{roomUid} and user_id_ = #{userId}
+    </update>
+
+
+    <!--学生声部信息-->
+    <select id="selectStudentSubject"
+            resultType="com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper$ImLiveBroadcastRoomMember">
+        SELECT
+        st.user_id_ as studentId, b.name_ as subName
+        FROM
+        student st left join subject as b on st.subject_id_ = b.id_
+        WHERE st.user_id_ IN (<foreach collection="studentIds" separator="," item="item">#{item}</foreach>)
+    </select>
+
+    <select id="queryMemberPage"
+            resultType="com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper$ImLiveBroadcastRoomMember">
+
+        select
+        a.room_uid_ as roomUid,
+        a.user_id_ as studentId,
+        a.whether_mic_status_ as whetherMicStatus,
+        a.fingerprint_ as fingerprint,
+        IFNULL(su.username_, a.visitor_name_) as studentName,
+        su.avatar_ as avatar,
+        su.phone_ as phone,
+        a.join_time_ as joinTime,
+        a.total_time_ as totalViewTime,
+        a.microphone_flag_ as microphoneFlag
+        from
+        im_live_broadcast_room_member as a
+        left join sys_user as su on su.id_ = a.user_id_
+        where a.room_uid_ = #{param.roomUid}
+        <if test="param.search != null ">
+            AND (
+            a.user_id_ LIKE CONCAT('%', #{param.search},'%')
+            OR a.visitor_name_ LIKE CONCAT('%', #{param.search},'%')
+            OR su.username_ LIKE CONCAT('%', #{param.search},'%')
+            )
+        </if>
+        <if test="param.onlineStatus != null">
+            AND (a.online_status_ = #{param.onlineStatus} and a.live_room_status_ = 1)
+        </if>
+        <if test="param.whetherMicStatus != null">
+            and a.whether_mic_status_ = #{param.whetherMicStatus}
+        </if>
+        <if test="param.visitorQuery != null">
+            <if test="param.visitorQuery == 1">
+                AND a.fingerprint_ IS NOT NULL
+            </if>
+            <if test="param.visitorQuery == 0">
+                AND a.fingerprint_ IS NULL
+            </if>
+        </if>
+        group by a.user_id_
+        ORDER BY a.join_time_
+    </select>
+</mapper>

cooleshow-user/user-biz/src/main/resources/config/mybatis/LiveBroadcastRoomDataMapper.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE  mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.yonge.cooleshow.biz.dal.mapper.LiveBroadcastRoomDataMapper">
+
+	 
+    
+    <!-- 表字段 -->
+    <sql id="baseColumns">
+         t.id_ AS id
+        , t.room_uid_ AS roomUid
+        , t.live_time_ AS liveTime
+        , t.like_num_ AS likeNum
+        , t.look_user_num_ AS lookUserNum
+        , t.total_user_num_ AS totalUserNum
+        , t.updated_time_ AS updatedTime
+        </sql> 
+    
+    <select id="selectPage" resultType="com.yonge.cooleshow.biz.dal.entity.LiveBroadcastRoomData">
+		SELECT         
+        	<include refid="baseColumns" />
+		FROM live_broadcast_room_data t
+	</select>
+    
+</mapper>

cooleshow-user/user-teacher/src/main/java/com/yonge/cooleshow/teacher/controller/TeacherImLiveBroadcastRoomController.java

@@ -0,0 +1,142 @@
+package com.yonge.cooleshow.teacher.controller;
+
+import com.microsvc.toolkit.middleware.live.message.TencentWrapper;
+import com.yonge.cooleshow.biz.dal.dto.LiveRoomStatus;
+import com.yonge.cooleshow.biz.dal.service.ImLiveBroadcastRoomMemberService;
+import com.yonge.cooleshow.biz.dal.service.LiveBroadcastRoomMemberService;
+import com.yonge.cooleshow.biz.dal.service.LiveRoomService;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
+import com.yonge.cooleshow.biz.dal.wrapper.liveroom.LiveRoomWrapper;
+import com.yonge.cooleshow.common.controller.BaseController;
+import com.yonge.cooleshow.common.entity.HttpResponseResult;
+import com.yonge.toolset.base.page.PageInfo;
+import io.swagger.annotations.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import javax.validation.Valid;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+/**
+ * 直播房间管理表(ImLiveBroadcastRoom)表控制层
+ *
+ * @author hgw
+ * @since 2022-02-17 20:52:04
+ */
+@Api(tags = "直播房间管理表")
+@RestController
+@RequestMapping("/imLiveBroadcastRoom")
+public class TeacherImLiveBroadcastRoomController extends BaseController {
+    /**
+     * 服务对象
+     */
+    @Resource
+    private LiveRoomService liveRoomService;
+    @Autowired
+    private LiveBroadcastRoomMemberService liveBroadcastRoomMemberService;
+
+    @Autowired
+    private ImLiveBroadcastRoomMemberService imLiveBroadcastRoomMemberService;
+
+
+    @ApiOperation("查询房间信息并校验房间是否合规")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "roomUid", dataType = "String", value = "房间uid", required = true),
+            @ApiImplicitParam(name = "userId", dataType = "Integer", value = "用户id", required = true),
+            @ApiImplicitParam(name = "liveAssistant", dataType = "Boolean", value = "直播助手"),
+    })
+    @GetMapping("/queryRoom")
+    public HttpResponseResult<LiveRoomWrapper.LiveRoomVo> queryRoomAndCheck(@ApiParam(value = "房间uid", required = true) String roomUid,
+                                                                 @ApiParam(value = "用户id", required = true) Long userId,
+                                                                 @RequestParam(defaultValue = "false") Boolean liveAssistant) {
+
+        // 请求来源业源
+        int osType = 2; // 老师端
+        if (Optional.ofNullable(liveAssistant).orElse(false)) {
+            osType = 3; // 直播助手
+        }
+
+        return succeed(liveRoomService.queryRoomAndCheck(roomUid, userId, osType));
+    }
+
+    @ApiOperation("关闭直播间")
+    @GetMapping(value = "/roomDestroy")
+    public HttpResponseResult<Object> roomDestroy(@ApiParam(value = "房间Uid", required = true) String roomUid) {
+        liveRoomService.destroyLiveRoom(roomUid);
+        return succeed();
+    }
+
+    @ApiOperation("同步点赞数量")
+    @GetMapping("/syncLike")
+    public HttpResponseResult<Object> syncLike(@ApiParam(value = "房间uid", required = true) String roomUid,
+                                               @ApiParam(value = "点赞数", required = true) Integer likeNum) {
+        liveRoomService.syncLike(roomUid, likeNum);
+        return succeed();
+    }
+
+    @ApiOperation("主讲人进入房间")
+    @GetMapping("/speakerJoinRoom")
+    public HttpResponseResult<LiveRoomWrapper.LiveRoomVo> speakerJoinRoom(String roomUid) {
+        return succeed(liveRoomService.speakerCheckRoomInfo(roomUid));
+    }
+
+    @ApiOperation("获取房间人员")
+    @GetMapping("/queryRoomUserInfo")
+    public HttpResponseResult<List<LiveRoomWrapper.BaseRoomUserVo>> queryRoomUserInfo(@ApiParam(value = "房间uid", required = true) String roomUid) {
+        return succeed(liveRoomService.queryRoomLimitOnlineUserInfo(roomUid));
+    }
+
+    @ApiOperation("设置是否允许连麦")
+    @GetMapping("/whetherMic")
+    public HttpResponseResult<Object> whetherMic(@ApiParam(value = "房间uid", required = true) String roomUid,
+                                                 @ApiParam(value = "是否连麦 0：是 1否", required = true) Integer whetherMic) {
+        liveRoomService.whetherMic(roomUid,whetherMic);
+        return succeed();
+    }
+
+
+    @ApiOperation("设置连麦状态")
+    @PutMapping("/userWhetherMic")
+    public HttpResponseResult<Object> userWhetherMic(@ApiParam(value = "房间uid", required = true) String roomUid,
+                                                 @ApiParam(value = "用户id", required = true) Long userId,
+                                                 @ApiParam(value = "连麦状态 0:未申请1:申请连麦中2:连麦中", required = true) Integer whetherMicStatus) {
+        liveRoomService.userWhetherMic(roomUid,userId,whetherMicStatus);
+        return succeed();
+    }
+
+    @ApiOperation("分页查询直播间人员列表")
+    @ApiImplicitParams({
+      @ApiImplicitParam(name = "search", dataType = "String", value = "模糊搜索 学员编号姓名"),
+      @ApiImplicitParam(name = "roomUid", dataType = "String", value = "房间uid"),
+      @ApiImplicitParam(name = "onlineStatus", dataType = "String ", value = "0:离线 1：在线  不传是全部"),
+      @ApiImplicitParam(name = "whetherMicStatus", dataType = "String", value = "连麦状态 0:未申请1:申请连麦中2:连麦中"),
+      @ApiImplicitParam(name = "page", dataType = "Integer", value = "页数"),
+      @ApiImplicitParam(name = "rows", dataType = "Integer", value = "每页数量"),
+    })
+    @PostMapping("/queryRoomMember")
+    public HttpResponseResult<PageInfo<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember>> queryRoomMember(@RequestBody Map<String, Object> param) {
+        return succeed(imLiveBroadcastRoomMemberService.queryRoomMember(param));
+    }
+
+
+    @ApiOperation("更新直播间状态")
+    @PostMapping("/updateRoomStatus")
+    public HttpResponseResult<Boolean> updateRoomStatus(@RequestBody @Valid LiveRoomStatus status ) {
+        return succeed(liveRoomService.updateRoomStatus(status));
+    }
+
+    @ApiOperation("直播间推流状态")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "roomUid", dataType = "String", value = "房间Uid", required = true),
+    })
+    @GetMapping(value = "/liveStreamStatus")
+    public HttpResponseResult<TencentWrapper.LiveStreamState> roomLiveStream(String roomUid) {
+
+        // 直播间推流状态查询
+        return succeed(liveRoomService.roomLiveStreamStatus(roomUid));
+    }
+}
+

cooleshow-user/user-teacher/src/main/java/com/yonge/cooleshow/teacher/controller/TeacherLiveRoomController.java

@@ -48,15 +48,15 @@ public class TeacherLiveRoomController extends BaseController {
         return succeed(liveRoomService.queryPageRoom(param));
     }
 
-    /**
-     * 根据房间uid查询房间信息
-     *
-     * @param roomUid 房间uid
-     */
-    @GetMapping("/speakerCheckRoomInfo")
-    public HttpResponseResult<RoomInfoCache> speakerCheckRoomInfo(@RequestParam("roomUid") String roomUid) {
-        return succeed(liveRoomService.speakerCheckRoomInfo(roomUid));
-    }
+//    /**
+//     * 根据房间uid查询房间信息
+//     *
+//     * @param roomUid 房间uid
+//     */
+//    @GetMapping("/speakerCheckRoomInfo")
+//    public HttpResponseResult<RoomInfoCache> speakerCheckRoomInfo(@RequestParam("roomUid") String roomUid) {
+//        return succeed(liveRoomService.speakerCheckRoomInfo(roomUid));
+//    }
 
     @ApiImplicitParams({
             @ApiImplicitParam(name = "roomTitle", dataType = "String", value = "房间标题"),