Kulexiu/KulexiuForStudent/KulexiuForStudent/Module/Live/Controller/LiveVideoRoomViewController.m

//
//  LiveVideoRoomViewController.m
//  KulexiuForTeacher
//
//  Created by Kyle on 2022/3/30.
//

#import "LiveVideoRoomViewController.h"
#import "KSChatInputBarControl.h"
#import "LiveRoomHeadView.h"
#import "LiveRoomBottomView.h"
#import "KSRCMessageModel.h"
#import "UserInfoManager.h"
#import "KSChatroomMessageCenter.h"
#import <RongIMKit/RongIMKit.h>
#import "KSChatroomTextCell.h"
#import "KSNormalAlertView.h"
#import "KSLiveStreamVideo.h"
#import "SeatContentView.h"
#import "LiveroomTimeManager.h"
#import "KSLiveEmptyView.h"
#import "KSChatVideoView.h"
#import "LiveRoomLikeLayer.h"
#import "KSDragWindowManager.h"
//#import <Lottie/Lottie.h>
#import "KSShopCardView.h"
#import "KSLiveWebViewController.h"


typedef NS_ENUM(NSInteger, MICSTATUS) {
    MICSTATUS_NOMAL,      // 正常状态
    MICSTATUS_WAITING,    // 申请中
    MICSTATUS_CONNECTING, // 连麦中
};

@interface LiveVideoRoomViewController ()<RCRTCEngineEventDelegate,RCRTCRoomEventDelegate,RCRTCStatusReportDelegate,UIGestureRecognizerDelegate,KSChatInputBarControlDelegate,UITableViewDataSource,UITableViewDelegate,LiveroomTimeManagerDelegate>

@property (nonatomic, strong) LiveroomTimeManager *timeManager;
// 音频配置
@property(strong, nonatomic) RCRTCEngine *engine;

@property (nonatomic, strong) RCRTCRoom *room;

@property (nonatomic, strong) RCRTCLiveInfo *liveInfo;

@property (nonatomic, strong) KSLiveStreamVideo *localVideo;

@property (nonatomic) NSMutableArray <KSLiveStreamVideo *>*streamVideos;

// 视频主窗口容器
@property (nonatomic, strong) UIView *videoContainerView;

@property (nonatomic, strong) KSChatVideoView *videoView;

@property (nonatomic, strong) LiveRoomHeadView *headView;

@property (nonatomic, copy) LiveRoomBottomView *bottomView;
/**
 上次点赞按钮点击时间
 */
@property(nonatomic, assign) NSTimeInterval lastClickPraiseTime;
// 连麦状态
@property (nonatomic, assign) MICSTATUS micStatus;
/// 提示窗
@property (nonatomic, strong) KSNormalAlertView *alertView;
/// 连麦的视图
@property (nonatomic, strong) SeatContentView *seatContainer;
// 聊天UI
/*!
 消息列表CollectionView和输入框都在这个view里
 */
@property(nonatomic, strong) UIView *messageContentView;

/*!
 会话页面的TableView
 */
@property (nonatomic, strong) UITableView *conversationMessageTableView;

/**
 输入工具栏
 */
@property(nonatomic,strong) KSChatInputBarControl *inputBar;
/**
 *  是否需要滚动到底部
 */
@property(nonatomic, assign) BOOL isNeedScrollToButtom;

/*!
 聊天内容的消息Cell数据模型的数据源
 
 @discussion 数据源中存放的元素为消息Cell的数据模型，即RCDLiveMessageModel对象。
 */
@property(nonatomic, strong) NSMutableArray<KSRCMessageModel *> *conversationDataRepository;

@property (nonatomic, assign) BOOL isImConnected;

// 远端连麦用户
@property (nonatomic, strong) NSMutableArray *remoteMemberArray;

/// 主讲人是否在房间
@property (nonatomic, assign) BOOL isCreaterInRoom;

@property (nonatomic, assign) BOOL isCreaterVideoEnable;

@property (nonatomic, assign) BOOL isCreaterAudioEnable;

@property (nonatomic, strong) KSLiveEmptyView *emptyView;

/// 是否在切换身份
@property (nonatomic, assign) BOOL isTransferRole;

@property (nonatomic, assign) BOOL hasSendWelcomeMessage;

@property (nonatomic, assign) BOOL hasShowSuspendView;

@property (nonatomic, assign) BOOL isPackageLostTips;

@property (nonatomic, assign) NSTimeInterval lostStartTime; // 开始丢包事件

@property (nonatomic, assign) NSTimeInterval bitErrorTime; // video bit zero start

@property (nonatomic, assign) BOOL isLostPackage; // 严重丢包

@property (nonatomic, assign) BOOL isBitError;  // bit error

//@property (nonatomic, strong) LOTAnimationView *animationView;

@property (nonatomic, assign) BOOL isCloseRoom; // 是否直播结束

@property (nonatomic, strong) KSShopCardView *cardView;

@end

//  用于记录点赞消息连续点击的次数
static int clickPraiseBtnTimes  = 0;

@implementation LiveVideoRoomViewController

- (instancetype)init {
    self = [super init];
    if (self) {
        [self defaultConfig];
    }
    return self;
}

- (void)defaultConfig {
    self.micStatus = MICSTATUS_NOMAL;
    self.isCreaterInRoom = NO; // 默认主讲人不在房间
    self.isImConnected = [USER_MANAGER checkIMConnected];
    self.isCloseRoom = NO;
}

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view.
    self.ks_prefersNavigationBarHidden = YES;
    [self registerNotification];
    [self setupUI];
    if (self.isImConnected) {
        [self connectService];
    }
    else {
        MJWeakSelf;
        [USER_MANAGER connectionIMCallback:^(BOOL isSuccess) {
            dispatch_main_async_safe(^{
                [weakSelf connectService];
            });
        }];
    }
    
    [self judgeAutoClose];
}

- (void)muteAllAudio {
    if (self.room) {
        [self.room muteAllRemoteAudio:YES];
    }
}

- (void)IMConnetedCallback {
    dispatch_main_async_safe(^{
        // IM 连接成功回调
        if (self.hasSendWelcomeMessage) { // 如果已经发送了进入消息
            // 查询是否直播间开启
            [KSNetworkingManager liveRoomJoinRoomRequest:KS_GET roomUid:self.roomId success:^(NSDictionary * _Nonnull dic) {
                if ([dic integerValueForKey:@"code"] == 200 && [dic boolValueForKey:@"status"]) {
                    // 回调信息
                    MJWeakSelf;
                    [self notiferJoinSuccessToServiceCallback:^{
                        [self MBPShow:@"IM连接成功"];
                        [weakSelf sendWelcomeMessage];
                    }];
                }
                else {
                    [self MBPShow:MESSAGEKEY];
                    [self quitRoom];
                }
            } faliure:^(NSError * _Nonnull error) {
                
            }];
        }
    });
}

- (void)sendWelcomeMessage {
    [[RCIMClient sharedRCIMClient] joinExistChatRoom:self.roomId messageCount:-1 success:^{
        KSLiveChatroomWelcome *joinChatroomMessage = [[KSLiveChatroomWelcome alloc] init];
        [joinChatroomMessage setMsgId:[RCIM sharedRCIM].currentUserInfo.userId];
        [self sendMessage:joinChatroomMessage displayMessage:YES callback:^(BOOL success) {
            
        }];
    } error:^(RCErrorCode status) {
        NSLog(@"error code %zd" ,status);
    }];
}

- (void)judgeAutoClose {
    if (self.isTempRoom == NO) {
        self.timeManager.autoCloseNetworkRoomTime = [self getCloseTime];
    }
}

- (void)liveroomLogOut {
    [self MBPShow:@"该账号在其他设备上登录"];
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.5f * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [self quitAction];
    });
}

- (void)liveroomQuit {
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.0f * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [self quitAction];
    });
}

- (void)registerNotification {
    [KSChatroomMessageCenter registerMessageTypes];
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(didReceiveMessageNotification:) name:OnReceiveChatroomMessageNotification object:nil];
    
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(liveroomLogOut) name:@"liveroomLogout" object:nil];
    
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(liveroomQuit) name:@"liveroomQuit" object:nil];
    
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(IMConnetedCallback) name:@"RongIMConnected" object:nil];
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(muteAllAudio) name:@"muteLiveAudio" object:nil];
}

- (void)setupUI {
    CGSize size = self.view.bounds.size;
    self.view.backgroundColor = HexRGB(0x25292e);
    
    // 视图主容器
    [self.view addSubview:self.videoContainerView];
    [self.videoContainerView mas_makeConstraints:^(MASConstraintMaker *make) {
        make.left.top.bottom.right.mas_equalTo(self.view);
    }];
    
    [self.videoContainerView addSubview:self.videoView];
    
    [self.videoView mas_makeConstraints:^(MASConstraintMaker *make) {
        make.left.top.bottom.right.mas_equalTo(self.view);
    }];
    
    [self.view addSubview:self.headView];
    self.headView.boardcastName.text = [NSString returnNoNullStringWithString:self.createrName];
    if (![NSString isEmptyString:self.createrAvatal]) {
        [self.headView.boardcastAvatal sd_setImageWithURL:[NSURL URLWithString:[self.createrAvatal getUrlEndcodeString]] placeholderImage:[UIImage imageNamed:@"teacher_logo"]];
    }
    [self countLikeMessageCount];
    
    [self.headView mas_makeConstraints:^(MASConstraintMaker *make) {
        make.left.right.mas_equalTo(self.view);
        make.height.mas_equalTo(90);
        if (@available(iOS 11.0, *)) {
            make.top.mas_equalTo(self.view.mas_safeAreaLayoutGuideTop).offset(10);
        } else {
            // Fallback on earlier versions
            make.top.mas_equalTo(self.view.mas_top).offset(10);
        }
    }];
    [self.view addSubview:self.messageContentView];
    [self.view addSubview:self.bottomView];
    
    [self.bottomView mas_makeConstraints:^(MASConstraintMaker *make) {
        make.left.right.mas_equalTo(self.view);
        if (@available(iOS 11.0, *)) {
            make.bottom.mas_equalTo(self.view.mas_safeAreaLayoutGuideBottom).offset(-10);
        } else {
            // Fallback on earlier versions
            make.bottom.mas_equalTo(self.view.mas_bottom).offset(-10);
        }
        make.height.mas_equalTo(44);
    }];
    
    [self.messageContentView mas_makeConstraints:^(MASConstraintMaker *make) {
        make.left.mas_equalTo(self.view.mas_left);
        make.right.mas_equalTo(self.view.mas_right);
        make.bottom.mas_equalTo(self.bottomView.mas_top).offset(-10);
        make.height.mas_equalTo(270);
    }];
    [self.view addSubview:self.inputBar];
    [_inputBar setBackgroundColor: [UIColor whiteColor]];
    
    [_inputBar setFrame:CGRectMake(0, kScreenHeight, size.width , 50)];
    [_inputBar setHidden:YES];
    
    [self.messageContentView addSubview:self.conversationMessageTableView];
    [self.conversationMessageTableView mas_makeConstraints:^(MASConstraintMaker *make) {
        make.left.top.mas_equalTo(self.messageContentView);
        make.width.mas_equalTo(240);
        make.bottom.mas_equalTo(self.messageContentView.mas_bottom);
    }];
    
    UITapGestureRecognizer *resetBottomTapGesture =[[UITapGestureRecognizer alloc]
                                                    initWithTarget:self
                                                    action:@selector(resetBottomGesture:)];
    resetBottomTapGesture.delegate = self;
    [self.view addGestureRecognizer:resetBottomTapGesture];
}

- (void)connectService {
    [self setRoleType];
    [self joinChatRoom];
}

- (void)joinChatRoom {
    [[RCIMClient sharedRCIMClient] joinChatRoom:self.roomId messageCount:-1 success:^{
        dispatch_async(dispatch_get_main_queue(), ^{
            [self addConstMessage];
        });
        KSLiveChatroomWelcome *joinChatroomMessage = [[KSLiveChatroomWelcome alloc] init];
        [joinChatroomMessage setMsgId:[RCIM sharedRCIM].currentUserInfo.userId];
        MJWeakSelf;
        [self sendMessage:joinChatroomMessage displayMessage:YES callback:^(BOOL success) {
            weakSelf.hasSendWelcomeMessage = YES;
        }];
        // 加入成功发送消息
    } error:^(RCErrorCode status) {
        if (status == RC_CHATROOM_NOT_EXIST || status == KICKED_FROM_CHATROOM || status == RC_PARAMETER_INVALID_CHATROOM) {
            dispatch_async(dispatch_get_main_queue(), ^{
                [self MBPShow:@"加入聊天室失败"];
            });
        }
    }];
}

- (void)viewWillAppear:(BOOL)animated {
    [super viewWillAppear:animated];
    [UIApplication sharedApplication].idleTimerDisabled = YES;
    [IQKeyboardManager sharedManager].enableAutoToolbar = NO;
    [IQKeyboardManager sharedManager].enable = NO;
    [UIApplication sharedApplication].statusBarStyle = UIStatusBarStyleLightContent;
    // 重新渲染view
    KSDragWindowManager *manager = [KSDragWindowManager sharedManager];
    if (manager.hasShowWindow) {
        [manager resignDragWindow];
    }
    if (self.hasShowSuspendView) {
        KSLiveStreamVideo *mainVideo = nil;
        if (self.videoView.streamId) {
            for (KSLiveStreamVideo *streamVideo in self.streamVideos) {
                if ([streamVideo.streamId isEqualToString:self.videoView.streamId]) {
                    mainVideo = streamVideo;
                    break;
                }
            }
        }
        if (mainVideo) {
            [self.videoView addSubview:mainVideo.canvesView];
            [mainVideo.canvesView mas_updateConstraints:^(MASConstraintMaker *make) {
                make.left.right.bottom.top.mas_equalTo(self.videoView);
            }];
        }
        _hasShowSuspendView = NO;
    }
    if (self.room) {
        [self.room muteAllRemoteAudio:NO];
    }
}

- (void)viewWillDisappear:(BOOL)animated {
    [super viewWillDisappear:animated];
    [UIApplication sharedApplication].idleTimerDisabled = NO;
    [IQKeyboardManager sharedManager].enableAutoToolbar = YES;
    [IQKeyboardManager sharedManager].enable = YES;
    if (@available(iOS 13.0, *)) {
        [UIApplication sharedApplication].statusBarStyle = UIStatusBarStyleDarkContent;
    } else {
        // Fallback on earlier versions
        [UIApplication sharedApplication].statusBarStyle = UIStatusBarStyleDefault;
    }
    
    // 退出房间才停止定时器
    if (_timeManager) {
        [_timeManager stopDurationTimer];
    }
}

// 刷新seatView
- (void)renderSeatView {
    
    NSMutableArray *seatArray = [NSMutableArray array];
    NSArray *remoteUserArray = [self.room.remoteUsers mutableCopy];
    for (RCRTCRemoteUser *user in remoteUserArray) {
        if (![user.userId isEqualToString:self.videoView.streamUserId] && ![user.userId isEqualToString:self.createrId]) {
            [seatArray addObject:user.userId];
        }
    }
    if (self.micStatus == MICSTATUS_CONNECTING && ![seatArray containsObject:UserDefault(UIDKey)]) {
        [seatArray addObject:UserDefault(UIDKey)];
    }
    
    if (seatArray.count) {
        if (![self.videoContainerView.subviews containsObject:self.seatContainer]) {
            [self.videoContainerView addSubview:self.seatContainer];
        }
        [self updateSeatContainerConstraint];
        
        self.seatContainer.seatMemberArray = [NSMutableArray arrayWithArray:seatArray];
        [self.seatContainer refreshSeatUI];
    }
    else {
        [self removeSeatContainer];
    }
}

- (void)updateSeatContainerConstraint {
    [self.seatContainer mas_remakeConstraints:^(MASConstraintMaker *make) {
        make.left.right.mas_equalTo(self.videoContainerView);
        make.top.mas_equalTo(self.headView.mas_bottom).offset(0);
        make.height.mas_equalTo(70);
    }];
}

// 移除连麦视图
- (void)removeSeatContainer {
    if ([self.videoContainerView.subviews containsObject:self.seatContainer]) {
        [self.seatContainer removeFromSuperview];
    }
}

- (void)countLikeMessageCount {
    NSInteger count = self.likeCount;
    NSString *desc = @"";
    if (count > 10000) {
        count = count / 10000;
        desc = [NSString stringWithFormat:@"本场点赞%zd万+",count];
    }
    else {
        desc = [NSString stringWithFormat:@"本场点赞%zd",count];
    }
    self.headView.likeCount.text = desc;
    
    if (count > 10000) {
        count = count / 10000;
        desc = [NSString stringWithFormat:@"%zd万+人",count];
    }
    else {
        desc = [NSString stringWithFormat:@"%zd人",count];
    }
}

- (void)setRoleType {
    // 1.设置切换听筒为扬声器
    [self.engine enableSpeaker:YES];
    // 2.加入RTC房间
    [self joinLiveRoom];
}

// 观众上下麦
- (void)connectHostWithStatus:(BOOL)isConnect {
    //  转换中，不再处理转换身份
    if (self.isTransferRole) {
        return;
    }
    // 如果需要切换的身份和当前身份相同 拦截
    if (isConnect && self.liveRoleType == RCRTCLiveRoleTypeBroadcaster) {
        return;
    }
    else if (isConnect == NO && self.liveRoleType == RCRTCLiveRoleTypeAudience) {
        return;
    }
    self.isTransferRole = YES;
    // 清理当前视图
    [self.seatContainer removeFromSuperview];
    if (isConnect) {
        // 开启麦克风采集
        [self.engine.defaultAudioStream setMicrophoneDisable:NO];
        NSArray *streams = @[self.engine.defaultAudioStream];
        MJWeakSelf;
        [self.room.localUser switchToBroadcaster:streams onSucceed:^(RCRTCLiveInfo * _Nonnull liveInfo) {
            weakSelf.isTransferRole = NO;
            dispatch_main_async_safe(^{
                __strong typeof(weakSelf) strongSelf = weakSelf;

                //3.切换成功, 订阅远端用户流
                strongSelf.liveRoleType = RCRTCLiveRoleTypeBroadcaster;
                NSMutableArray *streamArray = [NSMutableArray array];
                for (RCRTCRemoteUser *user in self.room.remoteUsers) {
                    if (user.remoteStreams.count) {
                        [streamArray addObjectsFromArray:user.remoteStreams];
                    }
                }
                if (streamArray.count) {
                    [strongSelf subscribeRemoteResource:streamArray];
                }
                else {
                    
                }
                
                strongSelf.micStatus = MICSTATUS_CONNECTING;
                // 刷新麦位状态
                strongSelf.remoteMemberArray = [NSMutableArray arrayWithArray:self.room.remoteUsers];
                NSLog(@"------- room member  %ld, ", strongSelf.remoteMemberArray.count);
                [strongSelf renderSeatView];
            });
            
        } onFailed:^(RCRTCCode code) {
            NSLog(@"------- up error code %ld", code);
            weakSelf.isTransferRole = NO;
            dispatch_main_async_safe(^{
                // 失败
                [weakSelf MBPShow:@"上麦失败"];
                weakSelf.micStatus = MICSTATUS_NOMAL;
            });
            
        } onKicked:^{
            weakSelf.isTransferRole = NO;
            dispatch_main_async_safe(^{
                // 被踢出
                [weakSelf kickOutLiveRoom];
            });
            
        }];
    }
    else { // 观众下麦
        MJWeakSelf;
        [self.room.localUser switchToAudienceOnSucceed:^{
            weakSelf.isTransferRole = NO;
            dispatch_main_async_safe(^{
                __strong typeof(weakSelf) strongSelf = weakSelf;
                strongSelf.liveRoleType = RCRTCLiveRoleTypeAudience;
                [strongSelf.engine.defaultAudioStream setMicrophoneDisable:YES];
                if (strongSelf.room.remoteUsers.count) {
                    NSMutableArray *streamArray = [NSMutableArray array];
                    for (RCRTCRemoteUser *user in self.room.remoteUsers) {
                        if (user.remoteStreams.count) {
                            [streamArray addObjectsFromArray:user.remoteStreams];
                            [strongSelf subscribeRemoteResource:streamArray];
                        }
                    }
                }
                else {
                    
                }
                strongSelf.micStatus = MICSTATUS_NOMAL;
                strongSelf.remoteMemberArray = [NSMutableArray arrayWithArray:self.room.remoteUsers];
                // 刷新麦位状态
                [strongSelf renderSeatView];
                // 发送下麦消息
                [weakSelf sendDownSeatMessage];
            });
            
        } onFailed:^(RCRTCCode code) {
            weakSelf.isTransferRole = NO;
            NSLog(@"------- down error code %ld", code);
            dispatch_main_async_safe(^{
                // 失败
                [weakSelf MBPShow:@"下麦失败"];
                weakSelf.micStatus = MICSTATUS_CONNECTING;
            });
            
        } onKicked:^{
            weakSelf.isTransferRole = NO;
            dispatch_main_async_safe(^{
                // 被踢出
                [weakSelf kickOutLiveRoom];
            });
        }];
    }
}

- (void)kickOutLiveRoom {
    [self MBPShow:@"您已被踢出直播间"];
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.5f * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [self quitAction];
    });
    
}

- (void)countMemberCount {
    NSInteger count = self.totalCount;
    NSString *desc = @"";
    if (count > 10000) {
        count = count / 10000;
        desc = [NSString stringWithFormat:@"%zd万+人",count];
    }
    else {
        desc = [NSString stringWithFormat:@"%zd人",count];
    }
    self.headView.roomMemberCount.text = desc;
}

// 清空视图
- (void)clearRemoteContainer {
    [self.streamVideos removeAllObjects];
    for (UIView *subview in self.videoView.subviews) {
        [subview removeFromSuperview];
    }
    self.videoView.streamUserId = @"";
    [self.seatContainer removeFromSuperview];
}

// 更新视图
- (void)updateVideoViewContainer {
    
    if (self.streamVideos.count > 0) {
        KSLiveStreamVideo *firstVideo = [self.streamVideos lastObject];
        if ([self.videoView.streamUserId isEqualToString:firstVideo.userId]) {
            return;
        }
        else {
            [self removeViewSubViews:self.videoView];
            self.videoView.streamUserId = firstVideo.userId;
            [self.videoView addSubview:firstVideo.canvesView];
            [firstVideo.canvesView mas_makeConstraints:^(MASConstraintMaker *make) {
                make.left.right.bottom.top.mas_equalTo(self.videoView);
            }];
        }
    }
    [self changeEmptyStatusView];
    
    [self renderSeatView];
}

- (void)removeViewSubViews:(UIView *)container {
    while (container.subviews.count) {
        [container.subviews.lastObject removeFromSuperview];
    }
}

- (void)changeEmptyStatusView {
    if (self.isCreaterInRoom) {
        if (self.isCreaterVideoEnable) {
            self.emptyView.hidden = YES;
        }
        else if (self.isCreaterVideoEnable == NO && self.isCreaterAudioEnable == YES) {
            // 主播关闭了摄像头
            [self showEmptyViewDisplay:YES];
        }
        else { // 休息一下
            [self showEmptyViewDisplay:NO];
        }
    }
    else  {
        // 无主播
        [self showEmptyViewDisplay:NO];
    }

}

#pragma mark ---- RCRTCRoomEventDelegate
// 远端发布流
- (void)didPublishStreams:(NSArray<RCRTCInputStream *> *)streams {
    [self subscribeRemoteResource:streams];
    NSLog(@"didPublishStreams --------");
}

// 订阅远端流
- (void)subscribeRemoteResource:(NSArray<RCRTCInputStream *> *)streams {
    [self subscribeRemoteResource:streams isTiny:NO];
}

- (void)subscribeRemoteResource:(NSArray<RCRTCInputStream *> *)streams isTiny:(BOOL)isTiny {
    // 订阅房间中远端用户音视频流资源
    NSArray *tinyStream = isTiny ? streams : @[];
    NSArray *ordinaryStream = isTiny ? @[] : streams;
    [self.room.localUser subscribeStream:ordinaryStream
                             tinyStreams:tinyStream
                              completion:^(BOOL isSuccess, RCRTCCode desc) {
        if (desc != RCRTCCodeSuccess) {
            NSString *errorStr = [NSString stringWithFormat:@"订阅远端流失败:%ld", (long) desc];
            [self MBPShow:errorStr];
            return;
        }
        
        // 创建并设置远端视频预览视图
        for (RCRTCInputStream *stream in streams) {
            if (stream.mediaType == RTCMediaTypeVideo) {
                if ([stream.userId isEqualToString:self.createrId]) { // 只渲染主讲人的流
                    self.isCreaterVideoEnable = YES;
                    [self setupRemoteViewWithStream:stream];
                }
            }
            if (stream.mediaType == RTCMediaTypeAudio && [stream.userId isEqualToString:self.createrId]) {
                self.isCreaterAudioEnable = YES;
            }
        }
        
        [self updateVideoViewContainer];
    }];
}

// 创建并设置远端视频预览视图
- (KSLiveStreamVideo *)setupRemoteViewWithStream:(RCRTCInputStream *)stream {
    
    KSLiveStreamVideo *sVideo = [self creatStreamVideoWithStreamId:stream.streamId];
    sVideo.userId = stream.userId;
    RCRTCVideoView *remoteView = (RCRTCVideoView *) sVideo.canvesView;

    //设置视频流的渲染视图
    [(RCRTCVideoInputStream *) stream setVideoView:remoteView];
    return sVideo;
}

//  远端用户取消发布资源
- (void)didUnpublishStreams:(NSArray<RCRTCInputStream *> *)streams {
    [self unsubscribeRemoteResource:streams orStreamId:nil];
}

- (void)stream:(RCRTCInputStream *)stream didVideoEnable:(BOOL)enable {
    NSLog(@"----- video --- staus %d", enable);
}

- (void)stream:(RCRTCInputStream *)stream didAudioMute:(BOOL)mute {
    NSLog(@"----- audio --- staus %d", mute);
    if ([stream.userId isEqualToString:self.createrId]) {
        if (mute) {
            self.isCreaterAudioEnable = NO;
        }
        else {
            self.isCreaterAudioEnable = YES;
        }
        [self changeEmptyStatusView];
    }
}

- (void)didOfflineUser:(RCRTCRemoteUser *)user {
    [self unsubscribeRemoteResource:user.remoteStreams orStreamId:nil];
}

// 判断是否已有预览视图
- (KSLiveStreamVideo *)creatStreamVideoWithStreamId:(NSString *)streamId {
    KSLiveStreamVideo *sVideo = [self fetchStreamVideoWithStreamId:streamId];
    if (!sVideo) {
        sVideo = [[KSLiveStreamVideo alloc] initWithStreamId:streamId];
        [self.streamVideos insertObject:sVideo atIndex:0];
    }
    return sVideo;
}

// 根据 streamId 确认唯一的音视频流
- (KSLiveStreamVideo *)fetchStreamVideoWithStreamId:(NSString *)streamId {
    for (KSLiveStreamVideo *sVideo in self.streamVideos) {
        if ([streamId isEqualToString:sVideo.streamId]) {
            return sVideo;
        }
    }
    return nil;
}

// 远端掉线/离开回掉调用，删除远端用户的所有音视频流
- (void)fetchStreamVideoOffLineWithStreamId:(NSString *)streamId {
    
    NSArray *arr = [NSArray arrayWithArray:self.streamVideos];
    for (KSLiveStreamVideo *sVideo in arr) {
        if ([streamId isEqualToString:sVideo.streamId]) {
            if (sVideo) {
                [sVideo.canvesView removeFromSuperview];
                [self.streamVideos removeObject:sVideo];
            }
        }
    }
    [self updateVideoViewContainer];
}
// 远端用户切换身份(主播接收)
- (void)didSwitchRoleWithUser:(RCRTCRemoteUser *)user roleType:(RCRTCLiveRoleType)roleType {
    if (roleType == RCRTCLiveRoleTypeBroadcaster) {
        if ([self judgeContainUser:user.userId] == NO) {
            [self.remoteMemberArray addObject:user];
        }
    }
    else {
        [self removeMemberUserId:user.userId];
        
    }
    [self renderSeatView];
    
    NSLog(@"didSwitchRoleWithUser --------");
}

- (BOOL)judgeContainUser:(NSString *)userId {
    BOOL containUser = NO;
    for (RCRTCRemoteUser *remoteUser in self.remoteMemberArray) {
        if ([remoteUser.userId isEqualToString:userId]) {
            containUser = YES;
        }
    }
    return containUser;
}

- (void)removeMemberUserId:(NSString *)userId {
    for (RCRTCRemoteUser *remoteUser in self.remoteMemberArray) {
        if ([remoteUser.userId isEqualToString:userId]) {
            [self.remoteMemberArray removeObject:remoteUser];
            return;
        }
    }
}

// 主播加入房间 (观众接收)
- (void)didJoinUser:(RCRTCRemoteUser *)user {
    if ([user.userId isEqualToString:self.createrId]) { // 当主播重新进入房间需要重置连麦状态
        self.isCreaterInRoom = YES;
        // 重置连麦状态
        [self resetConnectionStatus];
    }
    if ([self judgeContainUser:user.userId] == NO) {
        [self.remoteMemberArray addObject:user];
        [self renderSeatView];
    }
    NSLog(@"didJoinUser --------");
}

// 主播离开房间 (观众接收)
- (void)didLeaveUser:(RCRTCRemoteUser *)user {
    [self removeMemberUserId:user.userId];
    if (self.remoteMemberArray.count <= 0 && self.liveRoleType != RCRTCLiveRoleTypeBroadcaster) {
        [self remoteUserIsNull];
    }
    [self unsubscribeRemoteResource:user.remoteStreams orStreamId:nil];
    
    if ([user.userId isEqualToString:self.createrId]) { //
        self.isCreaterInRoom = NO;
        [self resetConnectionStatus];
    }
    else {
        [self renderSeatView];
    }
}

- (void)resetConnectionStatus {
    if (self.micStatus == MICSTATUS_CONNECTING) {
        [self connectHostWithStatus:NO];
    }
    self.micStatus = MICSTATUS_NOMAL;
    [self.seatContainer removeFromSuperview];
}

- (void)remoteUserIsNull {
    [self MBPShow:@"主讲人已离开房间"];
}

#pragma mark - KSChatInputBarControlDelegate
//  根据inputBar 回调来修改页面布局
- (void)onInputBarControlContentSizeChanged:(CGRect)frame withAnimationDuration:(CGFloat)duration andAnimationCurve:(UIViewAnimationCurve)curve {
    CGRect originFrame = _inputBar.frame;
    __weak __typeof(&*self)weakSelf = self;
    //  目前只使用y值即可 -- 只修改messageContentView高度，让展示消息view和输入框随之移动
    [UIView animateWithDuration:duration animations:^{
        [UIView setAnimationCurve:curve];
        [weakSelf.inputBar setFrame:CGRectMake(0, frame.origin.y - originFrame.size.height, originFrame.size.width, originFrame.size.height)];
        [UIView commitAnimations];
    }];
}

//  发送消息
- (void)onTouchSendButton:(NSString *)text {
    [self touristSendMessage:text];
}

- (void)touristSendMessage:(NSString *)text {
    
    RCTextMessage *rcTextMessage = [RCTextMessage messageWithContent:text];
    MJWeakSelf;
    [self sendMessage:rcTextMessage displayMessage:YES callback:^(BOOL success) {
        [weakSelf setDefaultBottomViewStatus];
    }];
}

#pragma mark ---- RTC
- (void)joinLiveRoom {
    // 1.配置房间
    RCRTCRoomConfig *config = [[RCRTCRoomConfig alloc] init];
    config.roomType = RCRTCRoomTypeLive;
    config.liveType = RCRTCLiveTypeAudioVideo;
    config.roleType = RCRTCLiveRoleTypeAudience;
    __weak typeof(self) weakSelf = self;
    [self.engine joinRoom:self.roomId config:config completion:^(RCRTCRoom * _Nullable room, RCRTCCode code) {
        dispatch_main_async_safe(^{
            __strong typeof(weakSelf) strongSelf = weakSelf;
            if (code == RCRTCCodeSignalServerNotConnect || code == RCRTCCodeParameterError || code == RCRTCCodeNotInRTCRoom || code == RCRTCCodeRTCTokenIsNull || code == RCRTCCodeHttpTimeoutError || code == RCRTCCodeHttpError || code == RCRTCCodeVoIPNotAvailable) {
                NSLog(@"%@",[NSString stringWithFormat:@"加入失败 code %ld",code]);
                [strongSelf MBPShow:@"加入直播间失败"];
                [strongSelf.navigationController dismissViewControllerAnimated:YES completion:nil];
            }
            else { // 加入直播间成功
                strongSelf.room = room;
                strongSelf.room.delegate = self;
                [strongSelf countMemberCount];
                
                // 刷新视图
                strongSelf.remoteMemberArray = [NSMutableArray arrayWithArray:room.remoteUsers];
                if (room.remoteUsers.count) {
                    NSMutableArray *streamArray = [NSMutableArray array];
                    for (RCRTCRemoteUser *user in room.remoteUsers) {
                        if ([user.userId isEqualToString:strongSelf.createrId]) {
                            strongSelf.isCreaterInRoom = YES;
                        }
                        if (user.remoteStreams.count) {
                            [streamArray addObjectsFromArray:user.remoteStreams];
                            [strongSelf subscribeRemoteResource:streamArray];
                        }
                    }
                }
                [self changeEmptyStatusView];
            }
        });
    }];
}

- (void)showEmptyViewDisplay:(BOOL)isPublish {
    NSString *imageName = @"";
    NSString *descMessage = @"";
    if (isPublish) {
        imageName = @"liveVideo_close";
        descMessage = @"主讲人已关闭画面！";
    }
    else {
        imageName = @"liveroom_empty";
        descMessage = @"休息一下，马上回来！";
    }
    [self.emptyView configViewWithImageName:imageName desc:descMessage];
    self.emptyView.hidden = NO;
}

- (void)exitRoom {
    __weak typeof(self) weakSelf = self;
    [self.engine leaveRoom:^(BOOL isSuccess, RCRTCCode code) {
        dispatch_main_async_safe(^{
            __strong typeof(weakSelf) strongSelf = weakSelf;
            [strongSelf sendLeaveMessageCallback:^(BOOL success) {
                // quit 接口
                [weakSelf quitNotiferService];
                [weakSelf quitChatRoom];
            }];
        });
    }];
}

// 取消订阅流 Id 所对应的 View
- (void)unsubscribeRemoteResource:(NSArray<RCRTCInputStream *> *)streams orStreamId:(NSString *)streamId {
    for (RCRTCInputStream *stream in streams) {
        if (stream.mediaType == RTCMediaTypeVideo) {
            streamId = stream.streamId;
            if ([stream.userId isEqualToString:self.createrId]) {
                self.videoView.streamUserId = @"";
                self.isCreaterVideoEnable = NO;
                // 主讲老师停止发布视频流
                NSLog(@"----- 停止发布视频流");
            }
            [self fetchStreamVideoOffLineWithStreamId:streamId];
        }
        else if (stream.mediaType == RTCMediaTypeAudio && [stream.userId isEqualToString:self.createrId]) {
            // 主讲老师停止发布音频流
            NSLog(@"----- 停止发布音频流");
            self.isCreaterAudioEnable = NO;
        }
    }
}

#pragma mark -- 加入直播间和退出直播间回到服务
- (void)notiferJoinSuccessToServiceCallback:(void(^)(void))callback {
    callback();
//    [KSNetworkingManager LiveroomJoinRequest:KS_GET roomId:self.roomId userId:UserDefault(UIDKey) success:^(NSDictionary * _Nonnull dic) {
//        callback();
//    } faliure:^(NSError * _Nonnull error) {
//        callback();
//    }];
}

#pragma mark -- 退出直播间回掉服务
- (void)quitNotiferService {
    [KSNetworkingManager LiveroomQuit:KS_POST success:^(NSDictionary * _Nonnull dic) {
        if ([dic integerValueForKey:@"errCode"] == 0) {
            NSLog(@"success");
        }
        else {
            NSLog(@"----- error %@", [dic stringValueForKey:@"errMsg"]);
        }
    } faliure:^(NSError * _Nonnull error) {
        
    }];
}

- (void)sendLeaveMessageCallback:(void(^)(BOOL success))callback {
    
    RCUserInfo *currentUserInfo = [RCIM sharedRCIM].currentUserInfo;
    KSLiveChatroomLeave *leaveMessage = [[KSLiveChatroomLeave alloc] init];
    leaveMessage.userId = currentUserInfo.userId;
    leaveMessage.userName = currentUserInfo.name;
    [self sendMessage:leaveMessage displayMessage:NO callback:^(BOOL success) {
        callback(success);
    }];
}

- (void)quitChatRoom {
    [[RCIMClient sharedRCIMClient] quitChatRoom:self.roomId success:^{
        NSLog(@"sucess log out--");
    } error:^(RCErrorCode status) {
        NSLog(@"RCErrorCode------%ld ", (long)status);
    }];
}

- (void)addConstMessage { // 固定欢迎词语
    RCTextMessage *statement = [RCTextMessage messageWithContent:@"欢迎进入直播课堂，请遵守相关法规，禁止传播低俗、暴力等不良信息。为孩子创造健康绿色的学习环境。"];
    statement.extra = @"statement";
    RCMessage *constMessage = [[RCMessage alloc] initWithType:ConversationType_CHATROOM targetId:self.roomId direction:MessageDirection_SEND content:statement];
    constMessage.content.senderUserInfo = [RCIM sharedRCIM].currentUserInfo;
    [self appendAndDisplayMessage:constMessage];
}
#pragma mark - views init
/**
 *  接收到消息的回调
 */
- (void)didReceiveMessageNotification:(NSNotification *)notification {
    NSDictionary *dic = notification.object;
    __block RCMessage *rcMessage = dic[@"message"];
    KSRCMessageModel *model = [[KSRCMessageModel alloc] initWithMessage:rcMessage];
    model.userInfo = rcMessage.content.senderUserInfo;
    if (model.conversationType == ConversationType_CHATROOM && [model.targetId isEqualToString:self.roomId]) {
        __weak typeof(&*self) __blockSelf = self;
        dispatch_main_async_safe(^{
            // 对赞消息拦截 ，展示动画，不插入数据源 ，对于seat消息 和踢出消息，弹出alert
            if (rcMessage) {
                // 👍🏻消息
                if ([rcMessage.content isMemberOfClass:[KSLiveChatroomLike class]]) {
                    KSLiveChatroomLike *likeMessage = (KSLiveChatroomLike *)rcMessage.content;
                    // 统计点赞数量
                    __blockSelf.likeCount += likeMessage.counts;
                    [__blockSelf countLikeMessageCount];
                }
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomWelcome class]]) {
                    //  过滤自己发送的欢迎消息
                    if ([rcMessage.senderUserId isEqualToString:UserDefault(UIDKey)]) {
                        return;
                    }
                    if ([rcMessage.senderUserId isEqual:self.createrId]) { // 如果是老师 重置连麦状态
                        [__blockSelf resetConnectionStatus];
                    }
                }
                // 用户退出消息
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomLeave class]]) {
                    return;
                }
                // 用户退出消息
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomUserQuit class]]) {
                    return;
                }
                // 人数同步
//                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomMemberCount class]]) {
//                    KSLiveChatroomMemberCount *member = (KSLiveChatroomMemberCount *)rcMessage.content;
//                    __blockSelf.totalCount = member.count;
//                    [__blockSelf countMemberCount];
//                    return;
//                }
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomMemberUp class]]) {
                    KSLiveChatroomMemberUp *member = (KSLiveChatroomMemberUp *)rcMessage.content;
                    __blockSelf.totalCount = member.count;
                    [__blockSelf countMemberCount];
                    return;
                }
                // 连麦申请消息
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomSeatApply class]]) {
                    KSLiveChatroomSeatApply *seatApplyMessage = (KSLiveChatroomSeatApply *)rcMessage.content;
                    // 只处理和自己相关的消息
                    if (![seatApplyMessage.audienceId isEqualToString:UserDefault(UIDKey)]) {
                        // 刷新麦序
                        return;
                    }
                    if (seatApplyMessage.type == SEATHANDLE_KICKSEAT) { // 主讲人将麦上观众报下麦
                        [__blockSelf kickSeatWithMessage:@"您已被报下麦"];
                    }
                    return;
                }
                // 连麦回复消息(暂不处理)
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomSeatResponse class]]) {
                    KSLiveChatroomSeatResponse *seatResponseMessage = (KSLiveChatroomSeatResponse *)rcMessage.content;
                    if (![seatResponseMessage.audienceId isEqualToString:UserDefault(UIDKey)]) { // 只处理和自己相关的消息
                        return;
                    }
                    if (seatResponseMessage.type == SEATRESPONSE_TEACHERAPPROVE) { //
                        [__blockSelf connectHostWithStatus:YES];
                    }
                    else if (seatResponseMessage.type == SEATRESPONSE_TEACHERREJECT) {
                        [__blockSelf MBPShow:@"主讲人拒绝了您的连麦申请"];
                        __blockSelf.micStatus = MICSTATUS_NOMAL;
                    }
                }
                else if ([rcMessage.content isMemberOfClass:[KSLiveChatroomDownSeat class]]) { // 成员下麦消息
                    return;
                }
                
                // left
                NSDictionary *leftDic = notification.userInfo;
                if (leftDic && [leftDic[@"left"] isEqual:@(0)]) {
                    __blockSelf.isNeedScrollToButtom = YES;
                }
                [__blockSelf appendAndDisplayMessage:rcMessage];
            }
            
        });
    }
}

- (void)kickSeatWithMessage:(NSString *)message {
    [self MBPShow:message];
    [self connectHostWithStatus:NO];
}

// 发送人数同步消息
- (void)sendMemberCountMessage {
    KSLiveChatroomMemberCount *syncMessage = [[KSLiveChatroomMemberCount alloc] init];
    syncMessage.count = self.totalCount;
    
    [self sendMessage:syncMessage displayMessage:NO callback:^(BOOL success) {
            
    }];
}

#pragma mark ----- time manager delegate
- (void)quitClassroomNotifer {
    [self MBPShow:@"直播课已结束!"];
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.5f * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [self quitAction];
    });
}

#pragma mark - gesture and button action
- (void)resetBottomGesture:(UIGestureRecognizer *)gestureRecognizer {
    if (gestureRecognizer.state == UIGestureRecognizerStateEnded) {
        [self setDefaultBottomViewStatus];
    }
}
- (void)setDefaultBottomViewStatus {
    [self.inputBar setInputBarStatus:KSBottomBarStatusDefault];
    [self.inputBar setHidden:YES];
}


#pragma mark ---- sendMessage/showMessage
- (void)sendMessage:(RCMessageContent *)messageContent displayMessage:(BOOL)displayMessage callback:(void(^)(BOOL success))callback {
    if (_roomId == nil) {
        return;
    }
    messageContent.senderUserInfo = [RCIM sharedRCIM].currentUserInfo;
    if (messageContent == nil) {
        return;
    }
    __weak typeof(&*self) __weakself = self;
    [KSChatroomMessageCenter sendChatMessage:self.roomId content:messageContent success:^(long messageId) {
        dispatch_async(dispatch_get_main_queue(), ^{
            RCMessage *message = [[RCMessage alloc] initWithType:ConversationType_CHATROOM targetId:__weakself.roomId direction:MessageDirection_SEND content:messageContent];
            message.content.senderUserInfo = [RCIM sharedRCIM].currentUserInfo;
            
            message.senderUserId = UserDefault(UIDKey);
            if (displayMessage) {
                [__weakself appendAndDisplayMessage:message];
            }
            [__weakself.inputBar clearInputView];
            callback(YES);
        });
        
    } error:^(RCErrorCode errorCode, long messageId) {
        if (errorCode == RC_CHATROOM_NOT_EXIST) {
            dispatch_async(dispatch_get_main_queue(), ^{
                [self MBPShow:@"聊天已被解散，请退出后重进。"];
            });
        }
        dispatch_async(dispatch_get_main_queue(), ^{
            [__weakself.inputBar clearInputView];
            NSLog(@"发送失败，errorcode is: %ld",(long)errorCode);
            callback(NO);
        });
    }];
}

/**
 *  将消息加入本地数组
 */
- (void)appendAndDisplayMessage:(RCMessage *)rcMessage {
    if (!rcMessage) {
        return;
    }
    
    KSRCMessageModel *model = [[KSRCMessageModel alloc] initWithMessage:rcMessage];
    model.userInfo = rcMessage.content.senderUserInfo;
    if (!model.userInfo) {
        model.userInfo = [RCIMClient sharedRCIMClient].currentUserInfo;
    }
    
    if ([self appendMessageModel:model]) {
        NSIndexPath *indexPath =
        [NSIndexPath indexPathForItem:self.conversationDataRepository.count - 1
                            inSection:0];
        if ([self.conversationMessageTableView numberOfRowsInSection:0] !=
            self.conversationDataRepository.count - 1) {
            return;
        }
        //  view刷新
        [self.conversationMessageTableView insertRowsAtIndexPaths:[NSArray arrayWithObject:indexPath] withRowAnimation:UITableViewRowAnimationNone];
        if ([self isAtTheBottomOfTableView] || self.isNeedScrollToButtom) {
            [self scrollToBottomAnimated:YES];
            self.isNeedScrollToButtom=NO;
        }
    }
    return;
}

/**
 *  如果当前会话没有这个消息id，把消息加入本地数组
 */
- (BOOL)appendMessageModel:(KSRCMessageModel *)model {
    
    if (!model.content) {
        return NO;
    }
    //这里可以根据消息类型来决定是否显示，如果不希望显示直接return NO
    
    //数量不可能无限制的大，这里限制收到消息过多时，就对显示消息数量进行限制。
    //用户可以手动下拉更多消息，查看更多历史消息。
    if (self.conversationDataRepository.count>100) {
        //                NSRange range = NSMakeRange(0, 1);
        KSRCMessageModel *message = self.conversationDataRepository[0];
        [[RCIMClient sharedRCIMClient]deleteMessages:@[@(message.messageId)]];
        [self.conversationDataRepository removeObjectAtIndex:0];
        [self.conversationMessageTableView reloadData];
    }
    
    [self.conversationDataRepository addObject:model];
    return YES;
}

/**
 *  判断消息是否在collectionView的底部
 *
 *  @return 是否在底部
 */
- (BOOL)isAtTheBottomOfTableView {
    if (self.conversationMessageTableView.contentSize.height <= self.conversationMessageTableView.frame.size.height) {
        return YES;
    }
    if(self.conversationMessageTableView.contentOffset.y +200 >= (self.conversationMessageTableView.contentSize.height - self.conversationMessageTableView.frame.size.height)) {
        return YES;
    }else{
        return NO;
    }
}

/**
 *  消息滚动到底部
 *
 *  @param animated 是否开启动画效果
 */
- (void)scrollToBottomAnimated:(BOOL)animated {
    if ([self.conversationMessageTableView numberOfSections] == 0) {
        return;
    }
    NSUInteger finalRow = MAX(0, [self.conversationMessageTableView numberOfRowsInSection:0] - 1);
    if (0 == finalRow) {
        return;
    }
    NSIndexPath *finalIndexPath =
    [NSIndexPath indexPathForItem:finalRow inSection:0];
    [self.conversationMessageTableView scrollToRowAtIndexPath:finalIndexPath atScrollPosition:UITableViewScrollPositionTop animated:animated];
}
/*
#pragma mark - Navigation

// In a storyboard-based application, you will often want to do a little preparation before navigation
- (void)prepareForSegue:(UIStoryboardSegue *)segue sender:(id)sender {
    // Get the new view controller using [segue destinationViewController].
    // Pass the selected object to the new view controller.
}
*/

#pragma mark ----- table data source
- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
    return self.conversationDataRepository.count;
}

- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {
    KSRCMessageModel *model = [self.conversationDataRepository objectAtIndex:indexPath.row];
    RCMessageContent *messageContent = model.content;
    KSChatroomTextCell *cell = [tableView dequeueReusableCellWithIdentifier:@"KSChatroomTextCell"];
    if(!cell){
        cell = [[KSChatroomTextCell alloc] initWithStyle:UITableViewCellStyleDefault reuseIdentifier:@"KSChatroomTextCell"];
    }
    if ([messageContent isMemberOfClass:[RCTextMessage class]] || [messageContent isMemberOfClass:[KSLiveChatroomWelcome class]] || [messageContent isMemberOfClass:[KSLiveChatroomLike class]] || [messageContent isMemberOfClass:[KSLiveChatroomSeatApply class]] || [messageContent isMemberOfClass:[KSLiveChatroomSeatResponse class]]){
        [cell setDataModel:model createrId:self.createrId];
    }
    return cell;
}


- (void)sendSeatMessageApply:(BOOL)isApply {
    SEATHANDLE type = isApply ? SEATHANDLE_APPLY : SEATHANDLE_CANCELAPPLY;
    KSLiveChatroomSeatApply *applyMessage = [[KSLiveChatroomSeatApply alloc] init];
    applyMessage.type = type;
    applyMessage.audienceId = UserDefault(UIDKey);
    applyMessage.audienceName = UserDefault(NicknameKey);
    applyMessage.audienceAvatar = UserDefault(AvatarUrlKey);
    MJWeakSelf;
    [self sendMessage:applyMessage displayMessage:YES callback:^(BOOL success) {
        if (success) {
            weakSelf.micStatus = isApply ? MICSTATUS_WAITING : MICSTATUS_NOMAL;
        }
    }];
}

/**
 点赞
 */
- (void)praiseBtnPressed {
    NSTimeInterval currentTime =  [[NSDate date] timeIntervalSince1970];
    __weak __typeof(&*self)weakSelf = self;
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.21 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        if ([[NSDate date] timeIntervalSince1970] - self.lastClickPraiseTime >= 0.2) {
            
            KSLiveChatroomLike *praiseSendMessage = [[KSLiveChatroomLike alloc] init];
            praiseSendMessage.counts = clickPraiseBtnTimes;
            [weakSelf sendMessage:praiseSendMessage displayMessage:YES callback:^(BOOL success) {
                
            }];
            clickPraiseBtnTimes = 0;
            
            self.likeCount += praiseSendMessage.counts;
            [self countLikeMessageCount];
        }
    });
    KSLiveChatroomLike *praiseMessage = [[KSLiveChatroomLike alloc] init];
    clickPraiseBtnTimes++;
    self.lastClickPraiseTime = currentTime;
    [self presentLikeMessageAnimation:praiseMessage];
    
}

/**
 赞动画
 
 @param likeMessage 赞消息
 */
- (void)presentLikeMessageAnimation:(KSLiveChatroomLike *)likeMessage {
    LiveRoomLikeLayer *layer = [[LiveRoomLikeLayer alloc] initWithName:@"Like"];
    [self.view.layer addSublayer:layer];
    CGRect tempFrame = [self.view convertRect:self.bottomView.likeButton.frame fromView:self.bottomView];
    CGFloat width = tempFrame.size.width;
    CGFloat height = tempFrame.size.height;

    CGFloat dx = CGRectGetMidX(tempFrame) - width *0.5;
    CGFloat dy = CGRectGetMidY(tempFrame) - 8 - height;
    layer.frame = CGRectMake(dx, dy, width, height);
    [layer startAnimation];
}


#pragma mark - setter & getter
- (void)setMicStatus:(MICSTATUS)micStatus {
    _micStatus = micStatus;
    if (self.bottomView) {
        switch (micStatus) {
            case MICSTATUS_NOMAL:
            {
                [self.bottomView.seatButton setImage:[UIImage imageNamed:@"seat_nomal"] forState:UIControlStateNormal];
            }
                break;
            case MICSTATUS_WAITING:
            case MICSTATUS_CONNECTING:
            {
                [self.bottomView.seatButton setImage:[UIImage imageNamed:@"seat_image"] forState:UIControlStateNormal];
            }
                break;
            default:
                break;
        }
    }
}

#pragma mark ----- RCRTCEngineEventDelegate
- (void)didRTCConnectionStateChanged:(RCRTCConnectionState)state {
    if (state == RCRTCConnectionStateConnecting) {
        NSLog(@"--------RCRTCConnectionStateConnecting");
    }
    else if (state == RCRTCConnectionStateConnected) {
        NSLog(@"--------RCRTCConnectionStateConnected");
    }
}

#pragma mark ----- RCRTCStatusReportDelegate
- (void)didReportStatusForm:(RCRTCStatusForm *)form {
    NSLog(@"%@",form.description);
}
#pragma mark --- lazying

- (KSChatVideoView *)videoView {
    if (!_videoView) {
        _videoView = [[KSChatVideoView alloc] initWithFrame:self.view.bounds];
        _videoView.backgroundColor = [UIColor clearColor];
    }
    return _videoView;
}

- (UIView *)videoContainerView {
    if (!_videoContainerView) {
        _videoContainerView = [[UIView alloc] initWithFrame:CGRectZero];
        _videoContainerView.backgroundColor = [UIColor clearColor];
    }
    return _videoContainerView;
}

- (LiveRoomHeadView *)headView {
    if (!_headView) {
        _headView = [LiveRoomHeadView shareInstance];
        MJWeakSelf;
        [_headView quitAction:^{
            [weakSelf quitAction];
        }];
    }
    return _headView;
}

- (LiveRoomBottomView *)bottomView {
    if (!_bottomView) {
        _bottomView = [LiveRoomBottomView shareInstance];
        MJWeakSelf;
        [_bottomView bottomClickAction:^(LIVEROOMACTION action) {
            [weakSelf bottomViewAction:action];
        }];
    }
    return _bottomView;
}

- (void)bottomViewAction:(LIVEROOMACTION)action {
    switch (action) {
        case LIVEROOMACTION_CHAT: // 聊天
        {
            [_inputBar setHidden:NO];
            [_inputBar setInputBarStatus:KSBottomBarStatusKeyboard];
        }
            break;
        case LIVEROOMACTION_SEAT: // // 连麦按钮
        { // 连麦按钮
            // 判断是否是连麦状态
            if (self.micStatus == MICSTATUS_CONNECTING) { // 连麦中
                // 是否取消连麦
                MJWeakSelf;
                self.alertView = [KSNormalAlertView ks_showAlertWithTitle:@"连麦中，确认取消连麦吗？" leftTitle:@"取消" rightTitle:@"确定" inView:self.view cancel:^{
                    
                } confirm:^{
                    [weakSelf connectHostWithStatus:NO];
                }];
            }
            else if (self.micStatus == MICSTATUS_WAITING) { // 连麦申请中
                // 弹窗取消申请
                MJWeakSelf;
                self.alertView = [KSNormalAlertView ks_showAlertWithTitle:@"连麦申请中，确认取消连麦申请吗？" leftTitle:@"取消" rightTitle:@"确定" inView:self.view cancel:^{
                    
                } confirm:^{
                    [weakSelf sendSeatMessageApply:NO];
                }];
            }
            else {
                if (self.isCreaterInRoom == NO) {
                    [self MBPShow:@"主讲人不在直播间"];
                    return;
                }
                else if (self.isCreaterVideoEnable == NO && self.isCreaterAudioEnable == NO) {
                    [self MBPShow:@"主讲人未开始直播"];
                    return;
                }
                [self MBPShow:@"已发起连麦申请"];
                [self sendSeatMessageApply:YES];
            }
        }
            break;
        case LIVEROOMACTION_SHOP:
        {
            [self showCartAlert];
        }
            break;
        case LIVEROOMACTION_LIKE:
        {
            if (self.isCreaterInRoom) {
                [self praiseBtnPressed];
            }
            else {
                [self MBPShow:@"主讲人不在直播间"];
            }
        }
            break;
        default:
            break;
    }
}

- (void)showCartAlert {
    [self.cardView showViewInView:self.view];
}

- (void)quitAction {
    if (self.micStatus == MICSTATUS_CONNECTING) {
        MJWeakSelf;
        self.alertView = [KSNormalAlertView ks_showAlertWithTitle:@"连麦中，是否退出房间？" leftTitle:@"取消" rightTitle:@"确定" inView:self.view cancel:^{
            
        } confirm:^{
            [weakSelf quitRoom];
        }];
    }
    else {
        [self quitRoom];
    }
    
}

- (void)quitRoom {
    // 清理视图
    [self clearRemoteContainer];
    // 退出房间
    [self exitRoom];
    [self.navigationController dismissViewControllerAnimated:YES completion:nil];
}

- (RCRTCEngine *)engine {
    if (!_engine) {
        _engine = [RCRTCEngine sharedInstance];
        [_engine setStatusReportDelegate:self];
        [_engine setDelegate:self];
    }
    return _engine;
}

- (NSMutableArray<KSLiveStreamVideo *> *)streamVideos {
    if (!_streamVideos) {
        _streamVideos = [NSMutableArray array];
    }
    return _streamVideos;
}

- (KSLiveStreamVideo *)localVideo {
    if (!_localVideo) {
        _localVideo = [KSLiveStreamVideo LocalStreamVideo];
    }
    return _localVideo;
}


- (NSMutableArray *)remoteMemberArray {
    if (!_remoteMemberArray) {
        _remoteMemberArray = [NSMutableArray array];
    }
    return _remoteMemberArray;
}

- (UIView *)messageContentView {
    if (!_messageContentView) {
        _messageContentView = [[UIView alloc] init];
        [_messageContentView setBackgroundColor: [UIColor clearColor]];
    }
    return _messageContentView;
}

- (NSMutableArray<KSRCMessageModel *> *)conversationDataRepository {
    if (!_conversationDataRepository) {
        _conversationDataRepository = [NSMutableArray array];
    }
    return _conversationDataRepository;
}
- (KSChatInputBarControl *)inputBar {
    if (!_inputBar) {
        _inputBar = [[KSChatInputBarControl alloc] initWithStatus:KSBottomBarStatusDefault];
        [_inputBar setDelegate:self];
    }
    return _inputBar;
}

- (UITableView *)conversationMessageTableView {
    if (!_conversationMessageTableView) {
        _conversationMessageTableView = [[UITableView alloc] initWithFrame:CGRectZero style:UITableViewStylePlain];
        _conversationMessageTableView.backgroundColor = [UIColor clearColor];
        _conversationMessageTableView.separatorStyle = UITableViewCellSeparatorStyleNone;
        _conversationMessageTableView.dataSource = self;
        _conversationMessageTableView.delegate = self;
        _conversationMessageTableView.rowHeight = UITableViewAutomaticDimension;
        _conversationMessageTableView.estimatedRowHeight = 40.0f;
        _conversationMessageTableView.showsVerticalScrollIndicator = NO;
        [_conversationMessageTableView registerClass:[KSChatroomTextCell class] forCellReuseIdentifier:@"KSChatroomTextCell"];
    }
    return _conversationMessageTableView;
}

- (SeatContentView *)seatContainer {
    if (!_seatContainer) {
        _seatContainer = [[SeatContentView alloc] init];
    }
    return _seatContainer;
}



- (void)sendDownSeatMessage {
    KSLiveChatroomDownSeat *downSeatMessage = [[KSLiveChatroomDownSeat alloc] init];
    downSeatMessage.audienceId = UserDefault(UIDKey);
    downSeatMessage.audienceName = UserDefault(NicknameKey);
    MJWeakSelf;
    [self sendMessage:downSeatMessage displayMessage:NO callback:^(BOOL success) {
        weakSelf.micStatus = MICSTATUS_NOMAL;
    }];
}


- (LiveroomTimeManager *)timeManager {
    if (!_timeManager) {
        _timeManager = [[LiveroomTimeManager alloc] initWithDelegate:self];
    }
    return _timeManager;
}

- (NSInteger)getCloseTime {
    NSDateFormatter *formatter = [[NSDateFormatter alloc] init];
    [formatter setDateFormat:@"yyyy-MM-dd HH:mm:ss"];
    formatter.timeZone = [NSTimeZone systemTimeZone];
    NSDate *currentDate = [NSDate date];
    NSDate *expireDate = [formatter dateFromString:self.liveEndTime];
    NSTimeInterval timeInterval = [expireDate timeIntervalSinceDate:currentDate];
    return self.expiredMinute * 60 + timeInterval;
}

- (KSShopCardView *)cardView {
    if (!_cardView) {
        _cardView = [KSShopCardView shareInstance];
        MJWeakSelf;
        [_cardView clickAction:^(CART_TYPE type) {
            [weakSelf displayTeacherInfo:type];
        }];
    }
    return _cardView;
}
// tabs=  practice | 陪练课 live | 直播课 video | 视频课 music | 乐谱 跳转到对应tab页

- (void)displayTeacherInfo:(CART_TYPE)type {
    
    RCRTCVideoView *videoView = nil;
    for (UIView *view in self.videoView.subviews) {
        if ([view isKindOfClass:[RCRTCVideoView class]]) {
            videoView = (RCRTCVideoView *)view;
        }
    }
    if (videoView) {
        _hasShowSuspendView = YES;
        KSDragWindowManager *manager = [KSDragWindowManager sharedManager];
        [manager initDragWindow];
        manager.rootVC = (CustomNavViewController *)self.navigationController;
        
        [videoView removeFromSuperview];
        [manager.dragWindow.containerView addSubview:videoView];
        [videoView mas_updateConstraints:^(MASConstraintMaker *make) {
            make.left.right.top.bottom.mas_equalTo(manager.dragWindow.containerView);
        }];
        [manager.dragWindow bringSubviewToFront:manager.dragWindow.cancelButton];
    }
    
    NSString *tabs = @"";
    switch (type) {
        case CART_TYPE_ACCOMPANY:
        {
            tabs = @"practice";
        }
            break;
        case CART_TYPE_LIVE:
        {
            tabs = @"live";
        }
            break;
        case CART_TYPE_VIDEO:
        {
            tabs = @"video";
        }
            break;
        case CART_TYPE_MUSIC:
        {
            tabs = @"music";
        }
            break;
        default:
            break;
    }
    NSString *url = [NSString stringWithFormat:@"%@%@%@&tabs=%@", WEBHOST,@"/#/teacherHome?teacherId=",self.createrId,tabs];
    KSLiveWebViewController *ctrl = [[KSLiveWebViewController alloc] init];
    ctrl.url = url;
    [self.navigationController pushViewController:ctrl animated:YES];
}

- (void)dealloc {
    [[NSNotificationCenter defaultCenter] removeObserver:self];
}

@end