// // BGTLiveController.m // BuguLive // // Created by xfg on 16/12/5. // Copyright © 2016年 xfg. All rights reserved. // 腾讯云直播，只处理与SDK有关的业务 #import "BGVoiceController.h" #import "BGMD5UTils.h" #import "TLiveMickListModel.h" #import "YunMusicPlayVC.h" #import "HostCheckMickAlertView.h" #import "TCShowLiveView.h" #import "BogoRoomUIViewController.h" #import "RoomModel.h" #import "BGRoomAnnouncementView.h" #import "ReactiveObjC.h" #define kPlayContrainerHeight 30 /////////////////// TiFaceSDK 添加 开始 /////////////////// #import "TiSDKInterface.h" //#import "TiUIView.h" #import "BeautySettingPanel.h" /////////////////// TiFaceSDK 添加 结束 /////////////////// #import "BGOtherPushPopView.h" #import "BGRoomBGImageViewController.h" #import "RoomBGImageModel.h" #import "DownloadHelper.h" #import "RoomSetViewController.h" @interface BGVoiceController () { BeautySettingPanel *_beautyPanel; // 美颜控件 } ///////////// TiSDK 添加 开始 ///////////// @property(nonatomic, strong) TiSDKManager *tiSDKManager; //@property(nonatomic, strong) TiUIView *tiUIView; ///////////// TiSDK 添加 结束 ///////////// @property (nonatomic, strong) UIView *liveView; @property(nonatomic, strong) BGOtherPushPopView *otherPushPopView; @property(nonatomic, strong) BogoRoomUIViewController *voiceRoomVC; @property(nonatomic, strong) BGRoomAnnouncementView *announcementView; @property (nonatomic,strong) TRTCCloud * trtcCloud; //获取声网播放音乐的时长定时器 //@property (nonatomic, strong) NSTimer *agoraPlayTime; //@property (strong, nonatomic) NSString *agora_token; @end @implementation BGVoiceController #pragma mark - ----------------------- 添加UI ----------------------- - (void)addSubViews { if (self.liveType == FW_LIVE_TYPE_HOST) { _beautyView = [[BGTLiveBeautyView alloc]initWithFrame:CGRectMake(0, 0, kScreenW, kScreenH)]; [self.liveServiceController.liveUIViewController.liveView addSubview:_beautyView]; _beautyView.delegate = self; _beautyView.hidden = YES; } if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { self.backVerticalBtn = [[UIButton alloc]initWithFrame:CGRectMake(15, 15, 35, 35)]; [self.backVerticalBtn setImage:[UIImage imageNamed:@"com_arrow_vc_back_2"] forState:UIControlStateNormal]; [self.backVerticalBtn addTarget:self action:@selector(goVerticalScreen) forControlEvents:UIControlEventTouchUpInside]; [self.view addSubview:self.backVerticalBtn]; self.backVerticalBtn.hidden = YES; } } #pragma mark 添加视频 - (void)initLive { // 付费直播控制云直播声音 [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(voiceNotice:) name:@"closeAndOpenVoice" object:nil]; // 音量监听 [[UIApplication sharedApplication] beginReceivingRemoteControlEvents]; [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(volumeChanged:) name:@"AVSystemController_SystemVolumeDidChangeNotification" object:nil]; // 屏幕旋转监听 [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(deviceOrientationDidChange) name:UIDeviceOrientationDidChangeNotification object:nil]; //监听 stopMusic 与 playMusic [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(playMusicClicked:) name:@"playMusic" object:nil]; [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(stopMusic) name:@"stopMusic" object:nil]; [self initializeAgoraEngine]; // [self.view sendSubviewToBack:_voiceRoomVC.view]; if (self.liveType == FW_LIVE_TYPE_HOST) { /* _publishController = [[BGTLinkMicPublishController alloc] init]; _publishController.delegate = self; _publishController.linkMicPublishDelegate = self; _publishController.roomIDStr = _roomIDStr; [self addChild:_publishController inRect:self.view.bounds]; [self.view sendSubviewToBack:_publishController.view]; [_publishController.txLivePublisher setMirror:NO];* */ } else if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { /* _linkMicPlayController = [[BGTLinkMicPlayController alloc] init]; _linkMicPlayController.liveType = [self.liveItem liveType]; _linkMicPlayController.delegate = self; _linkMicPlayController.linkMicPlayDelegate = self; [self addChild:_linkMicPlayController inRect:self.view.bounds]; [self.view sendSubviewToBack:_linkMicPlayController.view]; _linkSecondMicPlayController = [[BGTLinkMicPlayController alloc] init]; _linkSecondMicPlayController.liveType = [self.liveItem liveType]; _linkSecondMicPlayController.delegate = self; _linkSecondMicPlayController.linkMicPlayDelegate = self; [self addChild:_linkSecondMicPlayController inRect:self.view.bounds]; [self.view sendSubviewToBack:_linkSecondMicPlayController.view]; _firstImgView = [UIImageView new]; _firstImgView.frame = self.view.bounds; _firstImgView.top = kScreenH; _firstImgView.userInteractionEnabled = YES; [self.view addSubview:_firstImgView]; _secondImgView = [UIImageView new]; _secondImgView.frame = self.view.bounds; _secondImgView.top = kScreenH * 2; _secondImgView.userInteractionEnabled = YES; [self.view addSubview:_secondImgView]; */ } } -(void)protocolDidScrollView:(BGTLiveScrollView *)scrollView isRefreshLive:(BOOL)isRefresh{ NSInteger currentIndex = 1; for (int i = 0; i < self.modelArr.count; i++) { LivingModel *model = self.modelArr[i]; NSString *roomID = [NSString stringWithFormat:@"%d",model.room_id]; if ([roomID isEqualToString:scrollView.roomID]) { currentIndex = i; } } scrollView.nowIndex = currentIndex; if ((self.now_LiveIndex == 0 && scrollView.isFromeTop)|| (self.now_LiveIndex == self.modelArr.count - 1 && !scrollView.isFromeTop)){ _linkMicPlayController.videoContrainerView.top = 0; _liveServiceController.liveUIViewController.liveScrollView.top = 0; _firstImgView.top = _linkMicPlayController.videoContrainerView.bottom; _secondImgView.top = _firstImgView.bottom; return; } LivingModel *first_Model; LivingModel *second_Model; //只有一个直播间时 不滑动 if (self.modelArr.count < 2) { _liveServiceController.liveUIViewController.liveScrollView.top = 0; return; } NSLog(@"BGTLiveScrollView%@",scrollView); if (self.modelArr.count == 2) { //只有两个直播时 if (currentIndex == 1) {//进入的是第二个直播间时 first_Model = self.modelArr[1]; second_Model = self.modelArr[0]; }else{//进入的是第一个直播间时 first_Model = self.modelArr[0]; second_Model = self.modelArr[1]; } }else{ if (currentIndex == self.modelArr.count - 1) { first_Model = self.modelArr[self.modelArr.count - 2]; second_Model = self.modelArr[self.modelArr.count - 1]; } if (currentIndex == 0) {//进入第一个直播间 first_Model = self.modelArr[1]; second_Model = self.modelArr[2]; }else if (currentIndex == self.modelArr.count - 1) { first_Model = self.modelArr[self.modelArr.count - 2]; second_Model = self.modelArr[self.modelArr.count - 1]; }else{//进入中间的直播间 first_Model = self.modelArr[currentIndex + 1]; second_Model = self.modelArr[currentIndex - 1]; } } LivingModel *model = [LivingModel new]; _linkMicPlayController.videoContrainerView.top = scrollView.y; _firstImgView.bottom = _linkMicPlayController.videoContrainerView.top; _secondImgView.top = _linkMicPlayController.videoContrainerView.bottom; //5-7 回播点击问题 [_firstImgView sd_setImageWithURL:[NSURL URLWithString:first_Model.live_image]placeholderImage:[UIImage imageNamed:@"DefaultImg"]]; [_secondImgView sd_setImageWithURL:[NSURL URLWithString:second_Model.live_image]placeholderImage:[UIImage imageNamed:@"DefaultImg"]]; if (!isRefresh) return; if (scrollView.isFromeTop) { model = second_Model; }else{ model = first_Model; } if (model.live_in != FW_LIVE_STATE_ING) { // [FanweMessage alert:ASLocalizedString(@"主播不在直播")]; return; } NSLog(@"%d",model.room_id); NSLog(@"%d",model.room_id); if (scrollView.y == kScreenH || scrollView.y == 0) { // if (scrollView.y == 0) { // model = first_Model; // }else if (scrollView.y == kScreenH){ // model = second_Model; // } self.nowModel = model; for (int i = 0; i < self.modelArr.count; i++) { LivingModel *model = self.modelArr[i]; if (model.room_id == self.nowModel.room_id) { self.now_LiveIndex = i; } } FWWeakify(self) NSString *roomID = [NSString stringWithFormat:@"%d",model.room_id]; [_liveServiceController getVideo:^(CurrentLiveInfo *liveInfo) { TCShowUser *user = [[TCShowUser alloc] init]; user.avatar = liveInfo.podcast.user.head_image; user.uid = liveInfo.user_id; user.username = liveInfo.podcast.user.nick_name; TCShowLiveListItem *liveRoom = [[TCShowLiveListItem alloc] init]; liveRoom.host = user; liveRoom.avRoomId = [liveInfo.room_id intValue]; liveRoom.title = [NSString stringWithFormat:@"%d",liveRoom.avRoomId]; liveRoom.vagueImgUrl = liveInfo.podcast.user.head_image; //SUS_WINDOW 去记录直播间类型 这是不是观众 liveRoom.liveType = SUS_WINDOW.liveType; liveRoom.isHost = NO; // TCShowLiveView *liveView = [[TCShowLiveView alloc]initWith:liveRoom liveController:self]; // _liveServiceController.liveUIViewController.liveView = liveView; _liveServiceController.liveUIViewController.liveScrollView.roomID = liveInfo.room_id; [_liveServiceController.liveUIViewController.liveView refreshLiveItem:liveRoom liveInfo:liveInfo]; [_liveServiceController.liveUIViewController.liveView.msgView.liveMessages removeAllObjects]; FWStrongify(self) self.liveInfo = liveInfo; [self beginPlayVideo:liveInfo]; self.hasVideoControl = liveInfo.has_video_control ? YES : NO; _linkMicPlayController.videoContrainerView.top = 0; _liveServiceController.liveUIViewController.liveScrollView.top = 0; _firstImgView.top = _linkMicPlayController.videoContrainerView.bottom; _secondImgView.top = _firstImgView.bottom; NSLog(@"_liveServiceControlle.scrollview%@",_liveServiceController.liveUIViewController.liveScrollView); [super startEnterChatGroup:liveInfo.group_id succ:nil failed:nil]; } roomID:roomID failed:^(int errId, NSString *errMsg) { }]; } } -(void)clickVoiceMic:(TCShowLiveView *)showLiveView { [self.voiceRoomVC showMicView]; } -(void)clickVoiceMore:(TCShowLiveView *)showLiveView { FDActionSheet *actionSheet = [[FDActionSheet alloc] initWithTitle:@"" message:@""]; [actionSheet addAction:[FDAction actionWithTitle:ASLocalizedString(@"房间背景图片设置") type:FDActionTypeDefault CallBack:^{ BGRoomBGImageViewController *vc = [BGRoomBGImageViewController new]; vc.editRoomBGChangedCallBack = ^(RoomBGImageModel *selectModel) { UIImageView *iv = [self.vagueImgView viewWithTag:9998]; [iv setImageURL:[NSURL URLWithString:selectModel.image]]; }; vc.room_id = self.liveInfo.room_id; [self.navigationController pushViewController:vc animated:NO]; }]]; [actionSheet addAction:[FDAction actionWithTitle:ASLocalizedString(@"取消") type:FDActionTypeCancel CallBack:^{ }]]; [actionSheet show:self.view]; } -(void)clickRightContrainerView:(NSString *)roomID{ FWWeakify(self) [_liveServiceController getVideo:^(CurrentLiveInfo *liveInfo) { TCShowUser *user = [[TCShowUser alloc] init]; user.avatar = liveInfo.podcast.user.head_image; user.uid = liveInfo.user_id; user.username = liveInfo.podcast.user.nick_name; TCShowLiveListItem *liveRoom = [[TCShowLiveListItem alloc] init]; liveRoom.host = user; liveRoom.avRoomId = [liveInfo.room_id intValue]; liveRoom.title = [NSString stringWithFormat:@"%d",liveRoom.avRoomId]; liveRoom.vagueImgUrl = liveInfo.podcast.user.head_image; //SUS_WINDOW 去记录直播间类型 这是不是观众 liveRoom.liveType = SUS_WINDOW.liveType; liveRoom.isHost = NO; // TCShowLiveView *liveView = [[TCShowLiveView alloc]initWith:liveRoom liveController:self]; // _liveServiceController.liveUIViewController.liveView = liveView; _liveServiceController.liveUIViewController.liveScrollView.roomID = liveInfo.room_id; [_liveServiceController.liveUIViewController.liveView refreshLiveItem:liveRoom liveInfo:liveInfo]; FWStrongify(self) self.liveInfo = liveInfo; [self beginPlayVideo:liveInfo]; self.hasVideoControl = liveInfo.has_video_control ? YES : NO; _linkMicPlayController.videoContrainerView.top = 0; _liveServiceController.liveUIViewController.liveScrollView.top = 0; _firstImgView.top = _linkMicPlayController.videoContrainerView.bottom; _secondImgView.top = _firstImgView.bottom; NSLog(@"_liveServiceControlle.scrollview%@",_liveServiceController.liveUIViewController.liveScrollView); [super startEnterChatGroup:liveInfo.group_id succ:nil failed:nil]; } roomID:roomID failed:^(int errId, NSString *errMsg) { }]; } - (void)closeVoiceRoom { [self.trtcCloud exitRoom]; [TRTCCloud destroySharedInstance]; } //显示公告 - (void)showAnnouncement { NSMutableDictionary *dict = [[NSMutableDictionary alloc]init]; [dict setValue:@"voice" forKey:@"ctl"]; [dict setValue:@"get_notice" forKey:@"act"]; [dict setValue:self.liveInfo.room_id forKey:@"room_id"]; [[NetHttpsManager manager] POSTWithParameters:dict SuccessBlock:^(NSDictionary *responseJson) { self.liveInfo.announcement = responseJson[@"data"][@"announcement"]; [self.announcementView show:self.view]; } FailureBlock:^(NSError *error) { }]; } - (BGRoomAnnouncementView *)announcementView{ _announcementView.textView.text = self.liveInfo.announcement; if (!_announcementView) { _announcementView = [[BGRoomAnnouncementView alloc]initWithFrame:CGRectMake(0, kScreenW - 300 - (IPHONE_X ? 34 : 0), self.view.width, 300 + (IPHONE_X ? 34 : 0))]; _announcementView.delegate = self; if(self.liveItem.isHost) { _announcementView.editBtn.hidden = NO; } else { _announcementView.editBtn.hidden = YES; } } return _announcementView; } - (void)announcementView:(BGRoomAnnouncementView *)announcementView didClickEditBtn:(UIButton *)sender { __weak __typeof(self)weakSelf = self; [FanweMessage alertInput:nil message:@"请输入公告" placeholder:@"" keyboardType:UIKeyboardTypeDefault destructiveTitle:@"确认" destructiveAction:^(NSString *text) { NSMutableDictionary *dict = [[NSMutableDictionary alloc]init]; [dict setValue:@"voice" forKey:@"ctl"]; [dict setValue:@"save_notice" forKey:@"act"]; [dict setValue:self.liveInfo.room_id forKey:@"room_id"]; [dict setValue:text forKey:@"announcement"]; [[NetHttpsManager manager] POSTWithParameters:dict SuccessBlock:^(NSDictionary *responseJson) { NSLog(@"104responseJson%@",responseJson); // block(responseJson); [self showError:responseJson]; } FailureBlock:^(NSError *error) { }]; } cancelTitle:@"取消" cancelAction:^{ }]; } - (void)showError:(NSDictionary *)res { if (![res[@"error"] isEqualToString:@""]) { [[BGHUDHelper sharedInstance] tipMessage:res[@"error"]]; } } - (void)clickUser:(UserModel *)model { [self.liveServiceController getUserInfo:model]; } #pragma mark 添加直播间逻辑、视图 - (void)addServiceController { if (!_liveServiceController) { _liveServiceController = [[BGLiveServiceController alloc]initWith:self.liveItem liveController:self]; _liveServiceController.isVoice = YES; _liveServiceController.liveUIViewController.isVoice = YES; _liveServiceController.delegate = self; @weakify(self); [[RACObserve(_liveServiceController.liveUIViewController.liveView.topView.timeView.liveAudience, text) ignore:nil] subscribeNext:^(NSString *_Nullable text) { @strongify(self); NSLog(@"number --- %@",text); [self_weak_.voiceRoomVC.roomTopView.btnAnnouncement setTitle:[NSString stringWithFormat:ASLocalizedString(@"在线:%@"),text] forState:UIControlStateNormal]; // [self_weak_.voiceRoomVC.micView.numBtn setTitle:[NSString stringWithFormat:@"%@在线",text] forState:UIControlStateNormal]; }]; for (int i=0; i<_liveServiceController.liveUIViewController.liveView.topView.subviews.count; i++) { UIView *subView = _liveServiceController.liveUIViewController.liveView.topView.subviews[i]; subView.hidden = YES; } // @property (nonatomic, readonly) MenuButton *hostHeadBtn; // 主播头像 // @property (nonatomic, readonly) UIImageView *hostVImgView; // 主播认证图标 // @property (nonatomic, readonly) UILabel *liveTitle; // 直播Live // @property (nonatomic, readonly) UILabel *liveAudience; // 观众数 // @property (nonatomic, strong) UIButton *liveFollow; // 关注按钮 // @property (nonatomic, assign) NSInteger watchNumber; // 观众数量 // _liveServiceController.liveUIViewController.liveView.topView.userInteractionEnabled = NO; _liveServiceController.liveUIViewController.liveView.topView.collectionView.hidden = YES; _liveServiceController.liveUIViewController.liveView.topView.timeView.hidden = NO; _liveServiceController.liveUIViewController.liveView.topView.width = 200; _liveServiceController.liveUIViewController.liveView.topView.height = 50; _liveServiceController.liveUIViewController.liveView.closeLiveBtn.hidden = YES; _liveServiceController.liveUIViewController.liveView.topView.timeView.userInteractionEnabled = YES; _liveServiceController.pluginCenterView.toolsView.toSDKdelegate = self; _liveServiceController.liveUIViewController.liveView.sdkDelegate = self; _liveServiceController.liveUIViewController.liveView.topView.toSDKDelegate = self; _liveServiceController.liveUIViewController.liveScrollView.hidden = YES; _liveServiceController.liveUIViewController.liveView.bottomView.hidden = YES; [_liveServiceController.liveUIViewController.liveView.bottomView removeFromSuperview]; _liveServiceController.liveUIViewController.liveView.voicebottomView.hidden = NO; //_liveServiceController.liveUIViewController.liveView.topView.userArray __weak __typeof(self)weakSelf = self; // [RACObserve(_liveServiceController.liveUIViewController.liveView.topView.userArray, count) subscribeNext:^(id x) { // [weakSelf.voiceRoomVC.micView.numBtn setTitle:[NSString stringWithFormat:@"%d在线",x] forState:UIControlStateNormal]; // }]; [self addChild:_liveServiceController inRect:self.view.bounds]; _voiceRoomVC = [[BogoRoomUIViewController alloc] init]; _voiceRoomVC.supperView = self.view; _voiceRoomVC.delegate = self; // __weak __typeof(self)weakSelf = self; _voiceRoomVC.roomTopView.btnClickBlok = ^(BGVoiceRoomTopViewClickType type) { if(type == BGVoiceRoomTopViewClickTypeAnnouncement) { [_voiceRoomVC micView:nil didClickNumberBtn:nil]; // [weakSelf showAnnouncement]; } else if(type == BGVoiceRoomTopViewClickTypeShare) { [weakSelf.liveServiceController clickShareBtn:nil]; } else if(type == BGVoiceRoomTopViewClickTypeClose) { [weakSelf.liveServiceController clickCloseBtn:nil]; } else if(type == BGVoiceRoomTopViewClickTypeSwitch) { //切换房间 [weakSelf clickSwitchBtn:nil]; } }; // _liveServiceController.liveUIViewController.liveView [_liveServiceController.liveUIViewController addChild:_voiceRoomVC container:_liveServiceController.liveUIViewController.liveView inRect:self.view.bounds]; // [_liveServiceController.liveUIViewController.view sendSubviewToBack:_voiceRoomVC.view]; [_liveServiceController.liveUIViewController.liveView sendSubviewToBack:_voiceRoomVC.view]; } } //切换房间 - (void)clickSwitchBtn:(UIButton *)sender { //弹出切换10人房还是20人房列表 UIAlertController *alert = [UIAlertController alertControllerWithTitle:nil message:nil preferredStyle:UIAlertControllerStyleActionSheet]; [alert addAction:[UIAlertAction actionWithTitle:ASLocalizedString(@"5人房") style:UIAlertActionStyleDefault handler:^(UIAlertAction * _Nonnull action) { [self switchPeople:@"5"]; }]]; [alert addAction:[UIAlertAction actionWithTitle:ASLocalizedString(@"10人房") style:UIAlertActionStyleDefault handler:^(UIAlertAction * _Nonnull action) { [self switchPeople:@"10"]; }]]; [alert addAction:[UIAlertAction actionWithTitle:ASLocalizedString(@"15人房") style:UIAlertActionStyleDefault handler:^(UIAlertAction * _Nonnull action) { [self switchPeople:@"15"]; }]]; [alert addAction:[UIAlertAction actionWithTitle:ASLocalizedString(@"20人房") style:UIAlertActionStyleDefault handler:^(UIAlertAction * _Nonnull action) { [self switchPeople:@"20"]; }]]; [alert addAction:[UIAlertAction actionWithTitle:ASLocalizedString(@"取消") style:UIAlertActionStyleCancel handler:nil]]; [self presentViewController:alert animated:YES completion:nil]; } //切换几人位 - (void)switchPeople:(NSString *)people { NSMutableDictionary *dict = [[NSMutableDictionary alloc]init]; [dict setValue:@"voice" forKey:@"ctl"]; [dict setValue:@"change_room_mic_people" forKey:@"act"]; [dict setValue:self.roomIDStr forKey:@"room_id"]; [dict setValue:people forKey:@"people_count"]; [[NetHttpsManager manager] POSTWithParameters:dict SuccessBlock:^(NSDictionary *responseJson) { } FailureBlock:^(NSError *error) { }]; } //顶部公告代理方法，跟麦位在一起的代理方法 - (void)micView:(RoomLiveMicView *)micView didClickAnnouncementBtn:(UIButton *)sender { [self showAnnouncement]; } #pragma mark - ----------------------- 重写父方法 ----------------------- - (void)viewWillAppear:(BOOL)animated { [super viewWillAppear:animated]; } - (void)viewWillDisappear:(BOOL)animated { [super viewWillDisappear:animated]; } - (instancetype)initWith:(id)liveItem modelArr:(NSArray *)modelArr { if (self = [super initWith:liveItem modelArr:modelArr]) { self.modelArr = [NSMutableArray arrayWithArray:modelArr]; for (int i = 0; i < modelArr.count; i++) { LivingModel *model = modelArr[i]; if (model.room_id == liveItem.liveAVRoomId) { self.nowModel = model; self.now_LiveIndex = i; } } [self addServiceController]; [self addSubViews]; } return self; } #pragma mark - //麦位刷新 -(void)refreshVoice:(id)liveItem liveInfo:(CustomMessageModel *)customMessageModel { NSArray *list = [NSArray modelArrayWithClass:Wheat_Type_List.class json:customMessageModel.dicData[@"wheat_type_list"]]; self.liveInfo.wheat_type_list = list; self.liveServiceController.currentLiveInfo.wheat_type_list = list; self.voiceRoomVC.roomModel.wheat_type_list = list; [self.voiceRoomVC setRoomModel:self.voiceRoomVC.roomModel]; NSLog(@"<><><<><><>%@",customMessageModel.dicData); [self reloadStopOrStartLocalAudio]; } - (void)reloadStopOrStartLocalAudio { BOOL openAudio = NO; BOOL muteAudio = NO; for (int i=0; i)liveItem liveInfo:(CurrentLiveInfo *)liveInfo { [super refreshLiveItem:liveItem liveInfo:liveInfo]; [_liveServiceController refreshLiveItem:liveItem liveInfo:liveInfo]; self.voiceRoomVC.live_info = liveInfo; RoomModel *model = [[RoomModel alloc] init]; model.wheat_type_list = liveInfo.wheat_type_list; self.voiceRoomVC.roomModel = model; self.agora_token = liveInfo.agora_token; [self joinChannel:liveInfo.room_id]; } - (void)viewDidLoad { [super viewDidLoad]; // dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2.0 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{ // // 需要延迟执行的代码 // [self clickRoomManage]; // }); ///////////// TiSDK 添加 开始 //////////// ///////////// TiSDK 添加 结束 ///////////// if (self.BuguLive.appModel.mic_max_num >= 3 || self.BuguLive.appModel.mic_max_num == 0) { _micMaxNum = 3; } else { _micMaxNum = self.BuguLive.appModel.mic_max_num; } //初始化直播 [self initLive]; //#error TiSDK Key, 与包名对应，请联系商务获取 NSString* key = [GlobalVariables sharedInstance].appModel.bogo_beauty_key; if([BGUtils isBlankString:key]) { //这里写上那个key key = @"517a990947274dd8b51e1525feb0fb79"; // [[BGHUDHelper sharedInstance] tipMessage:ASLocalizedString(@"美颜key为空，请尝试重新打开app获取！")]; } else { // [TiSDK init:key]; // // //在这里创建好像会被覆盖掉 你看看这里 // // // dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(10 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{ // if([[GlobalVariables sharedInstance].appModel.spear_live isEqualToString:@"1"]) // { // ///////////// TiSDK 添加 开始 //////////// // // // [[TiUIManager shareManager] loadToSuperview:self.view]; // [TiUIManager shareManager].showsDefaultUI = NO; // [[TiUIManager shareManager]loadToWindowDelegate:nil]; // // //// self.tiSDKManager = [[TiSDKManager alloc]init]; ////// self.tiUIView = [[TiUIView alloc]initTiUIViewWith:self.tiSDKManager delegate:self superView:self.liveServiceController.liveUIViewController.view]; ////// self.tiUIView.isClearOldUI = NO; ////// [self.tiUIView createTiUIView]; // // 美颜控件 // NSUInteger controlHeight = [BeautySettingPanel getHeight]; // _beautyPanel = [[BeautySettingPanel alloc] initWithFrame:CGRectMake(0, self.view.frame.size.height - controlHeight - MG_BOTTOM_MARGIN, self.view.frame.size.width, controlHeight + MG_BOTTOM_MARGIN)]; // _beautyPanel.hidden = YES; // _beautyPanel.delegate = self; // _beautyPanel.pituDelegate = self; // [self.liveServiceController.liveUIViewController.view addSubview:_beautyPanel]; // [_beautyPanel resetValues]; // 美颜设置初始值 // } } UIImageView *iv = [[UIImageView alloc] initWithImage:[UIImage imageNamed:@"语音房间背景"]]; iv.tag = 9998; iv.frame = self.vagueImgView.bounds; [self.vagueImgView setImage:[UIImage imageNamed:@"语音房间背景"]]; [self.vagueImgView addSubview:iv]; } #pragma mark - ******************* 腾讯TRTC 代理方法 ******************* // 离开房间事件回调 - (void)onExitRoom:(NSInteger)reason { if (reason == 0) { NSLog(@"主动调用 exitRoom 退出房间"); } else if (reason == 1) { NSLog(@"被服务器踢出当前房间"); } else if (reason == 2) { NSLog(@"当前房间整个被解散"); } AppDelegate.sharedAppDelegate.isEnterLiveVC = NO; } - (void) onEnterRoom:(NSInteger ) result { NSLog(@"onEnterRoom"); if(result > 0) { } else { // [BGHUDHelper alert:[NSString stringWithFormat:@"进入直播间直播-%ld",result]]; } AppDelegate.sharedAppDelegate.isEnterLiveVC = YES; } //功能描述：音量大小的反馈回调 - (void)onUserVoiceVolume:(NSArray *)userVolumes totalVolume:(NSInteger)totalVolume { /*bug：当a用户在麦上正在说话时，切换到无网状态，此时虽然还显示在麦上（im还没下线）， 但观众席听不到声音，光圈还在闪烁 原因： 这时观众席speakers 里面找不到a，就不会进入for循环，就不会更新a的声音为0 解决： 1先找到 麦上的用户 2去判断有无声音 */ NSMutableArray *wheat_type_list = [NSMutableArray arrayWithArray:self.voiceRoomVC.roomModel.wheat_type_list]; for (int i = 0; i < wheat_type_list.count; i ++) { Wheat_Type_List *info = wheat_type_list[i]; if (info.even_wheat.user_id) { BOOL online = NO; // for (AgoraRtcAudioVolumeInfo *speaker in speakers) { for (TRTCVolumeInfo * volumeInfo in userVolumes) { NSString *uid = @""; if (volumeInfo.userId.intValue == 0) { uid = [IMAPlatform sharedInstance].host.userId; online = YES; }else if (info.even_wheat.user_id == volumeInfo.userId.intValue){ uid = [NSString stringWithFormat:@"%@",volumeInfo.userId]; online = YES; } if (online) { info.totalVolume = volumeInfo.volume; // [self.users updateUser:uid volume:speaker.volume]; } } wheat_type_list[i] = info; // if (!online) { // [self.users updateUser:info.user_id volume:0]; // } } } self.voiceRoomVC.roomModel.wheat_type_list = wheat_type_list; [self.voiceRoomVC setRoomModel:self.voiceRoomVC.roomModel]; // [self.uiController.micView setUsers:self.users]; } #pragma mark - ******************* 腾讯TRTC 代理方法 end ******************* #pragma mark ---------美颜增加------------- - (GLuint)onPreProcessTexture:(GLuint)texture width:(CGFloat)width height:(CGFloat)height{ if (self.tiSDKManager && [self.tiSDKManager renderTexture2D:texture Width:width Height:height Rotation:CLOCKWISE_0 Mirror:NO]) { /////////////////// TiFaceSDK 添加 开始 /////////////////// return [self.tiSDKManager renderTexture2D:texture Width:width Height:height Rotation:CLOCKWISE_0 Mirror:NO]; /////////////////// TiFaceSDK 添加 结束 /////////////////// } return texture; } #pragma mark 腾讯云直播开始进入直播间：根据是否传入了聊天组ID选择对应的进入直播间的方案 - (void)startEnterChatGroup:(NSString *)chatGroupID succ:(FWVoidBlock)succ failed:(FWErrorBlock)failed { __weak typeof(self) ws = self; [_liveServiceController getVideo:^(CurrentLiveInfo *liveInfo) { if (liveInfo) { ws.liveInfo = liveInfo; if(self.liveInfo.voice_bg_image.length > 0) { UIImageView *iv = [self.vagueImgView viewWithTag:9998]; [iv setImageURL:[NSURL URLWithString:self.liveInfo.voice_bg_image]]; // [self.vagueImgView setImageURL:[NSURL URLWithString:self.liveInfo.voice_bg_image]]; } ws.hasVideoControl = liveInfo.has_video_control ? YES : NO; if (liveInfo.has_video_control) { _reLiveProgressView.hidden = NO; } else { _reLiveProgressView.hidden = YES; } ws.liveServiceController.liveUIViewController.livePay.payDelegate = self; if (![BGUtils isBlankString:liveInfo.push_rtmp] || ![BGUtils isBlankString:liveInfo.play_url]) { [ws beginPlayVideo:liveInfo]; } if (liveInfo.is_live_pay == 1 && liveInfo.is_pay_over == 0 && ![liveInfo.podcast.user.user_id isEqualToString:[[IMAPlatform sharedInstance].host imUserId]]) { if (succ) { succ(); } } else { [super startEnterChatGroup:liveInfo.group_id succ:^{ [ws getVideoState:1]; if (succ) { succ(); } } failed:^(int errId, NSString *errMsg) { [ws getVideoState:0]; if (failed) { failed(errId, errMsg); } }]; } } else { [ws setGetVideoFailed:nil]; if (failed) { failed(FWCode_Net_Error, ASLocalizedString(@"获取到的liveInfo为空")); } } }roomID:@"" failed:^(int errId, NSString *errMsg) { [ws setGetVideoFailed:errMsg]; if (failed) { failed(errId, errMsg); } DebugLog(@"=========加载get_video接口出错 code: %d , msg = %@", errId, errMsg); }]; } #pragma mark 加入聊天组成功 - (void)enterChatGroupSucc:(CurrentLiveInfo *)liveInfo { [super enterChatGroupSucc:liveInfo]; if (!_isHost && (_liveInfo.join_room_prompt == 1 || [[IMAPlatform sharedInstance].host getUserRank] >= self.BuguLive.appModel.jr_user_level)) { _liveServiceController.liveUIViewController.liveView.canShowLightMessage = YES; } } #pragma mark 重写父方法： 业务上退出直播：退出的时候分SDK退出和业务退出，减少退出等待时间 - (void)onServiceExitLive:(BOOL)isDirectCloseLive succ:(FWVoidBlock)succ failed:(FWErrorBlock)failed { [_liveServiceController endLive]; if (self.liveType == FW_LIVE_TYPE_HOST) // 主播 { [_publishController endLive]; // [_liveServiceController showHostFinishView:@"" andVote:@"" andHasDel:NO]; __weak typeof(self) ws = self; [_liveServiceController hostExitLive:^{ if(isDirectCloseLive) { [ws onExitLiveUI]; } if (succ) { succ(); } } failed:^(int errId, NSString *errMsg) { if(isDirectCloseLive) { [ws onExitLiveUI]; } if (failed) { failed(errId, errMsg); } }]; [_publishController stopRtmp]; } else { if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController endVideo]; [self cancelMickingAlert]; if ([_linkMicPlayController.linkMemeberSet containsObject:[[IMAPlatform sharedInstance].host imUserId]]) { [BGLiveSDKViewModel tLiveStopMick:_roomIDStr toUserId:@""]; } } if(isDirectCloseLive) { [self onExitLiveUI]; } if (succ) { succ(); } } } #pragma mark 是否需要打断视频 - (void)interruptionLiveIng:(BOOL)interruptioning { if (interruptioning) { [_liveServiceController pauseLive]; if ([self.liveItem liveType] == FW_LIVE_TYPE_HOST) { [_publishController.txLivePublisher pausePush]; } else if([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController onAppDidEnterBackGround]; } } else { [_liveServiceController resumeLive]; if ([self.liveItem liveType] == FW_LIVE_TYPE_HOST) // 直播的主播 { [_publishController.txLivePublisher resumePush]; } else if([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController onAppWillEnterForeground]; } } } #pragma mark 是否正在被电话打断 - (void)phoneInterruptioning:(BOOL)interruptioning { // [super phoneInterruptioning:interruptioning]; [self interruptionLiveIng:interruptioning]; } #pragma mark app进入前台 - (void)onAppEnterForeground { // [super onAppEnterForeground]; if (_isHost) { // [super onAppEnterForeground]; [_publishController.txLivePublisher resumePush]; } else { if (_isMickAudiencePushing) { _isMickAudiencePushing = NO; [_linkMicPlayController.txLivePush resumePush]; } } } #pragma mark app进入后台 - (void)onAppEnterBackground { //语音房间不用发 // [super onAppEnterBackground]; if (_isHost) { // [super onAppEnterBackground]; [_publishController.txLivePublisher pausePush]; } else { if (_linkMicPlayController.txLivePush.isPublishing) { _isMickAudiencePushing = YES; [_linkMicPlayController.txLivePush pausePush]; } } if (_toolsView) { // 关闭LED [BGUtils turnOnFlash:NO]; ToolsCollectionViewCell *cell = (ToolsCollectionViewCell *)[_toolsView.toolsCollectionView cellForItemAtIndexPath:[NSIndexPath indexPathForRow:4 inSection:0]]; if (cell) { cell.toolImgView.image = [UIImage imageNamed:@"lr_plugin_flash_unsel"]; } } } #pragma mark 重写退出方法 - (void)onExitLiveUI { [super onExitLiveUI]; // 执行下 悬浮参数退出 if (SUS_WINDOW.isSusWindow &&SUS_WINDOW.isDirectCloseLive == YES) { [[LiveCenterManager sharedInstance]resetSuswindowPramaComple:^(BOOL finished) { }]; } [_liveServiceController endLive]; [_liveServiceController.view removeFromSuperview]; // _liveServiceController = nil; if (_publishController) { _publishController = nil; } if (_playController) { _playController = nil; } if (_linkMicPlayController) { _linkMicPlayController = nil; } // [self.agoraKit leaveChannel:^(AgoraChannelStats * _Nonnull stat) { // // }]; [self closeVoiceRoom]; // [self.voiceRtc onExitLiveClicked]; //请求退出房间 NSMutableDictionary *dict = [[NSMutableDictionary alloc]init]; [dict setValue:@"voice" forKey:@"ctl"]; [dict setValue:@"end_voice" forKey:@"act"]; [dict setValue:self.roomIDStr forKey:@"room_id"]; [[NetHttpsManager manager] POSTWithParameters:dict SuccessBlock:^(NSDictionary *responseJson) { } FailureBlock:^(NSError *error) { }]; if (!SUS_WINDOW.isSusWindow) { self.navigationController.navigationBarHidden = NO; [self.navigationController popViewControllerAnimated:YES]; } } #pragma mark 重写声音打断监听 - (void)onAudioInterruption:(NSNotification *)notification { [super onAudioInterruption:notification]; if(self.liveType == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController onAudioInterruption:notification]; } } #pragma mark 监听耳机插入和拔出 - (void)audioRouteChangeListenerCallback:(NSNotification *)notification { [super audioRouteChangeListenerCallback:notification]; NSDictionary *interuptionDict = notification.userInfo; NSInteger routeChangeReason = [[interuptionDict valueForKey:AVAudioSessionRouteChangeReasonKey] integerValue]; switch (routeChangeReason) { case AVAudioSessionRouteChangeReasonNewDeviceAvailable: // 耳机插入 // 开启耳返功能 _publishController.txLivePushonfig.enableAudioPreview = YES; [_publishController.txLivePublisher setConfig:_publishController.txLivePushonfig]; break; case AVAudioSessionRouteChangeReasonOldDeviceUnavailable: // 耳机拔出，停止播放操作 // 关闭耳返功能 _publishController.txLivePushonfig.enableAudioPreview = NO; [_publishController.txLivePublisher setConfig:_publishController.txLivePushonfig]; break; case AVAudioSessionRouteChangeReasonCategoryChange: // called at start - also when other audio wants to play NSLog(@"AVAudioSessionRouteChangeReasonCategoryChange"); break; } } #pragma mark 重写弹出退出或直接退出 /** 重写 弹出退出或直接退出 @param isDirectCloseLive 该参数针对主播、观众，表示是否直播关闭直播，而不显示结束界面 @param isHostShowAlert 该参数针对主播，表示主播是否需要弹出“您当前正在直播，是否退出直播？”，正常情况都需要弹出这个，不需要弹出的情况：1、当前直播被后台系统关闭了的情况 2、SDK结束了直播 @param succ 成功回调 @param failed 失败回调 */ - (void)alertExitLive:(BOOL)isDirectCloseLive isHostShowAlert:(BOOL)isHostShowAlert succ:(FWVoidBlock)succ failed:(FWErrorBlock)failed { //在后面退出 基础类需要 这个判断 需不需要 Finish界面 self.isDirectCloseLive = isDirectCloseLive; [self.liveServiceController.liveUIViewController.liveView.livewWishView.rotateTimer invalidate]; self.liveServiceController.liveUIViewController.liveView.livewWishView.rotateTimer = nil; LiveCenterManager *liveCenterManager = [LiveCenterManager sharedInstance]; NSLog(@"%ld",_liveInfo.is_live_pay); if (self.isHost || !isDirectCloseLive || _liveInfo.is_live_pay == 1) { [liveCenterManager closeLiveOfPramaOfLiveViewController:self paiTimeNum:nil alertExitLive:isDirectCloseLive isHostShowAlert:isHostShowAlert colseLivecomplete:^(BOOL finished) { if (finished) { if (succ) { succ(); } } else { if (failed) { failed(FWCode_Normal_Error, @""); } } }]; }else{ // [self.navigationController popViewControllerAnimated:YES]; // if (isHostShowAlert) { [liveCenterManager closeLiveOfPramaOfLiveViewController:self paiTimeNum:nil alertExitLive:isDirectCloseLive isHostShowAlert:isHostShowAlert colseLivecomplete:^(BOOL finished) { if (isHostShowAlert) { [FanweMessage alert:ASLocalizedString(@"您被主播踢出直播间")]; } if (finished) { if (succ) { succ(); } } else { if (failed) { failed(FWCode_Normal_Error, @""); } } }]; //悬浮小弹窗 // }else{ // [self showHoverViewWithAlert:isHostShowAlert]; // } } } //悬浮view -(void)showHoverViewWithAlert:(BOOL)isHostShowAlert{ NSLog(@"%@",self.liveServiceController); NSLog(@"%@",self.linkMicPlayController); //6-23 退出直播时关闭pk [self.liveServiceController.liveUIViewController pkVivewHidden]; __weak __typeof(self)weakSelf = self; self.liveServiceController.clickCloseBlock = ^(BOOL isReresh) { [weakSelf.hoverView removeFromSuperview]; weakSelf.hoverView = nil; [weakSelf.linkMicPlayController.view removeFromSuperview]; weakSelf.linkMicPlayController.view = nil; }; if (!self.hoverView) { self.hoverView = [[WMDragView alloc]init]; self.hoverView.backgroundColor = kClearColor; self.hoverView.button.titleLabel.font = [UIFont systemFontOfSize:15.0]; [self.hoverView.button setTitle:ASLocalizedString(@"可拖曳")forState:UIControlStateNormal]; self.hoverView.button.hidden = YES; //2020-1-7 小直播变大 self.hoverView.clickDragViewBlock = ^(WMDragView *dragView){ [weakSelf.hoverView removeFromSuperview]; weakSelf.hoverView = nil; [weakSelf.linkMicPlayController.view removeFromSuperview]; weakSelf.linkMicPlayController.view = nil; [[LiveCenterManager sharedInstance] closeLiveOfPramaOfLiveViewController:self paiTimeNum:nil alertExitLive:YES isHostShowAlert:YES colseLivecomplete:^(BOOL finished) { weakSelf.linkMicPlayController.view = nil; weakSelf.linkMicPlayController = nil; // 直播管理中心开启观众直播 BOOL isSusWindow = [[LiveCenterManager sharedInstance] judgeIsSusWindow]; [[LiveCenterManager sharedInstance] showLiveOfAudienceLiveofTCShowLiveListItem: [LiveCenterManager sharedInstance].itemModel modelArr:nil isSusWindow:isSusWindow isSmallScreen:NO block:^(BOOL isFinished) { }]; }]; }; //__weak __typeof(self)weakSelf = self; self.hoverView.duringDragBlock = ^(WMDragView *dragView) { weakSelf.linkMicPlayController.videoContrainerView.frame = dragView.frame; }; self.hoverView.endDragBlock = ^(WMDragView *dragView) { CGContextRef context = UIGraphicsGetCurrentContext(); [UIView beginAnimations:@"rightMove" context:context]; [UIView setAnimationCurve:UIViewAnimationCurveEaseInOut]; [UIView setAnimationDuration:0.5]; weakSelf.linkMicPlayController.videoContrainerView.frame = dragView.frame; [UIView commitAnimations]; }; } CGRect frame = CGRectMake(kScreenW * 0.7, kScreenH / 2, kScreenW * 0.3, kScreenH * 0.25); UIButton *btn = [UIButton buttonWithType:UIButtonTypeCustom]; // [btn setTitle:ASLocalizedString(@"关闭")forState:UIControlStateNormal]; [btn setImage:[UIImage imageNamed:@"lr_top_close"] forState:UIControlStateNormal]; [btn addTarget:self action:@selector(clickLive:) forControlEvents:UIControlEventTouchUpInside]; btn.frame = CGRectMake(frame.size.width - 40, 0, 40, 40); [self.hoverView addSubview:btn]; //直播界面vc的view _linkMicPlayController.view.frame = frame; _linkMicPlayController.view.backgroundColor = kClearColor; //5-7 悬浮小窗口的阴影 _linkMicPlayController.pkBgView.hidden=YES; [_linkMicPlayController.pkBgView removeAllSubViews]; _linkMicPlayController.pkBgView=nil; //hoverView，拖拽的view self.hoverView.frame = _linkMicPlayController.view.bounds; //在直播VC上放置视频的view _linkMicPlayController.videoContrainerView.frame = _linkMicPlayController.view.bounds; [[BGBaseAppDelegate sharedAppDelegate].window addSubview:_linkMicPlayController.view]; [_linkMicPlayController.view addSubview:self.hoverView]; [[NSNotificationCenter defaultCenter]addObserver:self selector:@selector(clickLive:) name:@"clickLiveRoomNotification" object:nil]; } - (void)touchesMoved:(NSSet *)touches withEvent:(UIEvent *)event { NSLog(@"%@", touches); UITouch *touch = [touches anyObject]; //当前的point CGPoint currentP = [touch locationInView:self.hoverView]; //以前的point CGPoint preP = [touch previousLocationInView:self.hoverView]; //x轴偏移的量 CGFloat offsetX = currentP.x - preP.x; //Y轴偏移的量 CGFloat offsetY = currentP.y - preP.y; self.hoverView.transform = CGAffineTransformTranslate(self.hoverView.transform, offsetX, offsetY); } - (void)touchesBegan:(NSSet *)touches withEvent:(UIEvent *)event { } //观众关闭直播走的方法 -(void)clickLive:(UIButton *)sender{ self.hoverView.hidden = self.linkMicPlayController.view.hidden = YES; dispatch_async(dispatch_get_global_queue(0, 0), ^{ dispatch_async(dispatch_get_main_queue(), ^{ [self.hoverView removeFromSuperview]; self.hoverView = nil; [self.linkMicPlayController.view removeFromSuperview]; self.liveView = nil; [self clickEndLive]; }); }); } -(void)clickEndLive{ LiveCenterManager *liveCenterManager = [LiveCenterManager sharedInstance]; __weak __typeof(self)weakSelf = self; //4-16 1.苹果端打字不显示直播间自带的发送，手机上面的发送可以用，我手机是苹果11 [liveCenterManager closeLiveOfPramaOfLiveViewController:self paiTimeNum:nil alertExitLive:YES isHostShowAlert:YES colseLivecomplete:^(BOOL finished) { weakSelf.linkMicPlayController.view = nil; weakSelf.linkMicPlayController = nil; weakSelf.linkMicPlayController.view = nil; }]; } #pragma mark - ----------------------- 部分业务逻辑 ----------------------- #pragma mark 请求get_video接口失败的情况 - (void)setGetVideoFailed:(NSString *)errMsg { NSString *errStr = errMsg; if ([BGUtils isBlankString:errStr]) { errStr = ASLocalizedString(@"获取聊天室信息失败，请稍候尝试"); } [self getVideoState:0]; __weak typeof(self) ws = self; [BGHUDHelper alert:errStr action:^{ [ws onExitLiveUI]; }]; } #pragma mark 真正开始播放 - (void)beginPlayVideo:(CurrentLiveInfo *)liveInfo { _iMMsgHandler.isEnterRooming = NO; __weak typeof(self) ws = self; if (self.liveType == FW_LIVE_TYPE_HOST) { if (liveInfo.push_rtmp && ![liveInfo.push_rtmp isEqualToString:@""]) { _publishController.pushUrlStr = liveInfo.push_rtmp; if (![GlobalVariables sharedInstance].isOtherPush) { [_publishController startPushRtmpLiveMethod]; } } else { [BGHUDHelper alert:ASLocalizedString(@"抱歉，推流地址为空，请稍后尝试")action:^{ [ws alertExitLive:YES isHostShowAlert:NO succ:nil failed:nil]; }]; } } else if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { if (liveInfo.play_url && ![liveInfo.play_url isEqualToString:@""]) { // if (!([self.BuguLive.appModel.open_vip intValue] == 1 && liveInfo.is_vip == 0)) // { _linkMicPlayController.playUrlStr = liveInfo.play_url; [_linkMicPlayController startRtmp:liveInfo.create_type]; // } } else { // [BGHUDHelper alert:ASLocalizedString(@"抱歉，播放地址为空，请稍后尝试")action:^{ // [ws alertExitLive:YES isHostShowAlert:NO succ:nil failed:nil]; // }]; } } if (_isHost) { [_liveServiceController startLiveTimer]; } } #pragma mark 请求video_cstatus接口来获取直播间信息 - (void)getVideoState:(NSInteger)state { NSMutableDictionary *mDict = [NSMutableDictionary dictionary]; [mDict setObject:@"video" forKey:@"ctl"]; [mDict setObject:@"video_cstatus" forKey:@"act"]; [mDict setObject:[NSString stringWithFormat:@"%d",[self.liveItem liveAVRoomId]] forKey:@"room_id"]; [mDict setObject:StringFromInteger(state) forKey:@"status"]; if ([self.liveItem liveIMChatRoomId] && ![[self.liveItem liveIMChatRoomId] isEqualToString:@""]) { [mDict setObject:[self.liveItem liveIMChatRoomId] forKey:@"group_id"]; } [_liveServiceController getVideoState:mDict]; } #pragma mark - ----------------------- 回放相关界面事件操作 ----------------------- #pragma mark 进度条事件 - (void)onClickPlay { [_playController clickPlay:_btnPlay create_type:self.liveInfo.create_type]; } - (void)onSeek { [_playController onSeek:_playProgress]; } - (void)onSeekBegin { [_playController onSeekBegin:_playProgress]; } - (void)onDrag { [_playController onDrag:_playProgress]; } - (void)dragSliderDidEnd:(UISlider *)slider { [_playController dragSliderDidEnd:_playProgress]; } #pragma mark - ----------------------- 连麦 ----------------------- #pragma mark 观众检查是否有连麦权限（主播不需要此操作） - (void)audienceCheckMick { //检查是否有连麦权限 NSMutableDictionary *mDict = [NSMutableDictionary dictionary]; [mDict setObject:@"video" forKey:@"ctl"]; [mDict setObject:@"check_lianmai" forKey:@"act"]; [mDict setObject:_roomIDStr forKey:@"room_id"]; [SVProgressHUD show]; [self.httpsManager POSTWithParameters:mDict SuccessBlock:^(NSDictionary *responseJson) { [SVProgressHUD dismiss]; if ([responseJson toInt:@"status"] == 1) { __weak BGIMMsgHandler *wd = _iMMsgHandler; FWWeakify(self) [FanweMessage alert:nil message:ASLocalizedString(@"是否请求与主播连麦？")destructiveAction:^{ FWStrongify(self) SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_APPLY_MIKE; sendCustomMsgModel.msgReceiver = [self.liveItem liveHost]; [wd sendCustomC2CMsg:sendCustomMsgModel succ:^{ [self performSelector:@selector(alertLinkMicking) withObject:nil afterDelay:0.2]; } fail:^(int code, NSString *msg) { [FanweMessage alertHUD:ASLocalizedString(@"您的连麦申请发送失败")]; }]; } cancelAction:^{ }]; } } FailureBlock:^(NSError *error) { }]; } #pragma mark 主播判断某个观众是否互动观众 - (BOOL)isInteractUser:(NSString *)userId { if (userId) { for (NSString *tmpUserId in _linkMicPlayController.linkMemeberSet) { if ([userId isEqualToString:tmpUserId]) { return YES; } } } return NO; } #pragma mark 观众发起连麦，关闭连麦 - (void)openOrCloseMike:(BGLiveServiceController *)liveServiceController { if (_linkMicPlayController.isWaitingResponse) { [FanweMessage alertHUD:ASLocalizedString(@"连麦申请中...")]; return; } if ([self isInteractUser:[[IMAPlatform sharedInstance].host imUserId]]) { FWWeakify(self) [FanweMessage alert:nil message:ASLocalizedString(@"是否结束与主播的互动连麦？")destructiveAction:^{ FWStrongify(self) [self.linkMicPlayController stopLinkMic]; [self.linkMicPlayController startRtmp:self.liveInfo.create_type]; } cancelAction:^{ }]; } else { [self audienceCheckMick]; } } - (void)refreshUserListVoice { } #pragma mark 申请连麦中，等待对方应答... - (void)alertLinkMicking { _isApplyMicking = YES; FWWeakify(self) _applyMickingAlert = [FanweMessage alert:ASLocalizedString(@"提示")message:ASLocalizedString(@"申请连麦中，等待对方应答...")isHideTitle:NO destructiveTitle:ASLocalizedString(@"取消连麦")destructiveAction:^{ FWStrongify(self) self.isApplyMicking = NO; [self performSelector:@selector(releaseMickingAlert) withObject:nil afterDelay:0.5]; SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_BREAK_MIKE; sendCustomMsgModel.msgReceiver = [self.liveItem liveHost]; [self.iMMsgHandler sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; }]; } #pragma mark 关闭申请连麦中的提示 - (void)cancelMickingAlert { if (_applyMickingAlert) { _isApplyMicking = NO; [_applyMickingAlert hide]; [self performSelector:@selector(releaseMickingAlert) withObject:nil afterDelay:0.5]; } } - (void)releaseMickingAlert { if (_applyMickingAlert) { _applyMickingAlert = nil; } } - (void)releaseHostMickingAlert { if (_hostMickingAlert) { _hostMickingAlert = nil; } } #pragma mark 主播获取连麦参数 - (void)getMickPara:(CustomMessageModel *)customMessageModel { _isResponseMicking = YES; //检查是否有连麦权限 NSMutableDictionary *mDict = [NSMutableDictionary dictionary]; [mDict setObject:@"video" forKey:@"ctl"]; [mDict setObject:@"start_lianmai" forKey:@"act"]; [mDict setObject:_roomIDStr forKey:@"room_id"]; [mDict setObject:customMessageModel.sender.user_id forKey:@"to_user_id"]; __weak typeof(self) ws = self; __weak BGIMMsgHandler *wm = (BGIMMsgHandler *)_iMMsgHandler; [self.httpsManager POSTWithParameters:mDict SuccessBlock:^(NSDictionary *responseJson) { if ([responseJson toInt:@"status"] == 1) { NSString *push_rtmp2 = [responseJson toString:@"push_rtmp2"]; NSString *play_rtmp_acc = [responseJson toString:@"play_rtmp_acc"]; if (![BGUtils isBlankString:push_rtmp2] && ![BGUtils isBlankString:play_rtmp_acc]) { SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_RECEIVE_MIKE; sendCustomMsgModel.push_rtmp2 = push_rtmp2; sendCustomMsgModel.play_rtmp_acc = play_rtmp_acc; sendCustomMsgModel.msgReceiver = customMessageModel.sender; [wm sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; [ws.publishController agreeLinkMick:[responseJson toString:@"play_rtmp2_acc"] applicant:customMessageModel.sender.user_id]; } else { ws.isResponseMicking = NO; [FanweMessage alertHUD:ASLocalizedString(@"获取连麦参数失败")]; } } else { ws.isResponseMicking = NO; } } FailureBlock:^(NSError *error) { ws.isResponseMicking = NO; }]; } #pragma mark 主播收到观众连麦请求 - (void)onRecvGuestApply:(CustomMessageModel *)customMessageModel { SenderModel *sender = customMessageModel.sender; if ([_publishController.linkMemeberSet count] >= _micMaxNum || _hostMickingAlert || _isResponseMicking) { SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_REFUSE_MIKE; sendCustomMsgModel.msgReceiver = customMessageModel.sender; if (_hostMickingAlert || _isResponseMicking) { sendCustomMsgModel.msg = ASLocalizedString(@"主播有未处理的连麦请求，请稍候再试"); [_iMMsgHandler sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; } else { DebugLog(@"已达到请求上限，不能再请求"); sendCustomMsgModel.msg = ASLocalizedString(@"当前主播连麦数已上限，请稍后尝试"); [_iMMsgHandler sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; } } else { __weak BGIMMsgHandler *wm = (BGIMMsgHandler *)_iMMsgHandler; NSString *text = [NSString stringWithFormat:ASLocalizedString(@"%@向你发来连麦请求"), [sender imUserName]]; FWWeakify(self) _hostMickingAlert = [FanweMessage alert:ASLocalizedString(@"提示")message:text destructiveTitle:ASLocalizedString(@"同意")destructiveAction:^{ FWStrongify(self) // 同意 [self getMickPara:customMessageModel]; [self performSelector:@selector(releaseHostMickingAlert) withObject:nil afterDelay:0.2]; } cancelTitle:ASLocalizedString(@"拒绝")cancelAction:^{ FWStrongify(self) // 拒绝 SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_REFUSE_MIKE; sendCustomMsgModel.msgReceiver = customMessageModel.sender; [wm sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; [self performSelector:@selector(releaseHostMickingAlert) withObject:nil afterDelay:0.2]; }]; } } #pragma mark 主播未处理连麦申请时，kApplyMikeTime秒后关闭申请连麦弹出框 - (void)closeAlertView { if (_hostMickingAlert) { [_hostMickingAlert hide]; [self performSelector:@selector(releaseHostMickingAlert) withObject:nil afterDelay:0.2]; } } - (void)showRefuseHud:(NSString *)refuseStr { [FanweMessage alert:refuseStr]; } #pragma mark FWTLinkMicPlayControllerDelegate /* * 观众端连麦结果 * isSucc：是否上麦 * userID：当前用户ID */ - (void)pushMickResult:(BOOL)isSucc userID:(NSString *)userID { if (![BGUtils isBlankString:userID]) { if (isSucc) { if ([[[IMAPlatform sharedInstance].host imUserId] isEqualToString:userID]) { // [BGLiveSDKViewModel tLiveMixStream:_roomIDStr toUserId:@""]; } } else { if ([[[IMAPlatform sharedInstance].host imUserId] isEqualToString:userID]) { [BGLiveSDKViewModel tLiveStopMick:_roomIDStr toUserId:@""]; } SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_BREAK_MIKE; sendCustomMsgModel.msgReceiver = [self.liveItem liveHost]; [_iMMsgHandler sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; } } } #pragma mark FWTLinkMicPublishControllerDelegate /* * 主播端连麦结果 * isSucc：是否拉取观众连麦加速流成功 * userID：拉取的连麦观众对应的ID */ - (void)playMickResult:(BOOL)isSucc userID:(NSString *)userID { _isResponseMicking = NO; if (![BGUtils isBlankString:userID]) { if (isSucc) { [BGLiveSDKViewModel tLiveMixStream:_roomIDStr toUserId:userID]; } } } #pragma mark 主播点击屏幕时，判断是否点击了连麦窗口 - (void)hostReceiveTouch:(UITouch *)touch { if ([_publishController.linkMemeberSet count]) { for (NSString *user in _publishController.linkMemeberSet) { BGTLinkMicPlayItem *playItem = [self.publishController getPlayItemByUserID:user]; if (playItem) { if(CGRectContainsPoint(playItem.videoView.frame, [touch locationInView:self.publishController.view])) { UserModel *userModel; for (UserModel *tmpModel in _liveServiceController.liveUIViewController.liveView.topView.userArray) { if ([tmpModel.user_id isEqualToString:user]) { userModel = tmpModel; break; } } if (!userModel) { userModel = [[UserModel alloc]init]; userModel.user_id = user; } MMPopupCompletionBlock completeBlock = ^(MMPopupView *popupView, BOOL finished){ NSLog(@"animation complete"); }; HostCheckMickAlertView *view = [[HostCheckMickAlertView alloc] initAlertView:userModel closeMickBlock:^(UserModel *userModel) { SendCustomMsgModel *sendCustomMsgModel = [[SendCustomMsgModel alloc] init]; sendCustomMsgModel.msgType = MSG_BREAK_MIKE; sendCustomMsgModel.msgReceiver = userModel; [[BGIMMsgHandler sharedInstance] sendCustomC2CMsg:sendCustomMsgModel succ:nil fail:nil]; [BGLiveSDKViewModel tLiveStopMick:_roomIDStr toUserId:userModel.user_id]; }]; [view showWithBlock:completeBlock]; } } } } } #pragma mark - ----------------------- 横竖屏 ----------------------- - (void)goVerticalScreen { [self interfaceOrientation:UIInterfaceOrientationPortrait]; } #pragma mark PC直播或者PC回播，观众端的点击全屏事件 - (void)clickFullScreen { [self interfaceOrientation:UIInterfaceOrientationLandscapeRight]; } - (void)interfaceOrientation:(UIInterfaceOrientation)orientation { if ([[UIDevice currentDevice] respondsToSelector:@selector(setOrientation:)]) { SEL selector = NSSelectorFromString(@"setOrientation:"); NSInvocation *invocation = [NSInvocation invocationWithMethodSignature:[UIDevice instanceMethodSignatureForSelector:selector]]; [invocation setSelector:selector]; [invocation setTarget:[UIDevice currentDevice]]; int val = orientation; [invocation setArgument:&val atIndex:2]; [invocation invoke]; } } - (void)deviceOrientationDidChange { if (self.liveInfo.create_type == 1) { NSLog(@"deviceOrientationDidChange:%ld",(long)[UIDevice currentDevice].orientation); if([UIDevice currentDevice].orientation == UIDeviceOrientationPortrait) { [[UIApplication sharedApplication] setStatusBarOrientation:UIInterfaceOrientationPortrait]; [self orientationChange:kDirectionTypeDefault]; } else if ([UIDevice currentDevice].orientation == UIDeviceOrientationLandscapeLeft) { [[UIApplication sharedApplication] setStatusBarOrientation:UIInterfaceOrientationLandscapeRight]; [self orientationChange:kDirectionTypeLeft]; } } } - (void)orientationChange:(kDirectionType)landscape { if (landscape == kDirectionTypeDefault) { [[UIApplication sharedApplication] setStatusBarHidden:NO]; _liveServiceController.liveUIViewController.liveView.hidden = NO; _liveServiceController.closeBtn.hidden = NO; [UIView animateWithDuration:0.2f animations:^{ self.view.transform = CGAffineTransformMakeRotation(0); self.view.bounds = CGRectMake(0, 0, kScreenW, kScreenH); if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { _linkMicPlayController.videoContrainerView.frame = CGRectMake(0, 0, kScreenW, kScreenH); self.backVerticalBtn.hidden = YES; } }]; } else if (landscape == kDirectionTypeLeft) { [[UIApplication sharedApplication] setStatusBarHidden:YES]; _liveServiceController.liveUIViewController.liveView.hidden = YES; _liveServiceController.closeBtn.hidden = YES; [UIView animateWithDuration:0.2f animations:^{ self.view.transform = CGAffineTransformMakeRotation(M_PI_2); self.view.bounds = CGRectMake(0, 0, kScreenW, kScreenH); if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { _linkMicPlayController.videoContrainerView.frame = CGRectMake(0, 0, kScreenW, kScreenH); self.backVerticalBtn.hidden = NO; } }]; } } #pragma mark - ----------------------- 代理方法 ----------------------- #pragma mark FWLiveServiceControllerDelegate #pragma mark 收到自定义C2C消息 - (void)recvCustomC2C:(id)msg { if (![msg isKindOfClass:[CustomMessageModel class]]) { return; } CustomMessageModel *customMessageModel = (CustomMessageModel *)msg; switch (customMessageModel.type) { case MSG_APPLY_MIKE: // 观众申请连麦（主播收到观众连麦请求消息） { // 关闭键盘 [BGUtils closeKeyboard]; _linkMicPlayController.isWaitingResponse = YES; [self onRecvGuestApply:customMessageModel]; // [_publishController breakLinkMick:customMessageModel.sender.user_id]; } break; case MSG_RECEIVE_MIKE: // 主播接受连麦（观众收到主播接受连麦消息） { if (_isApplyMicking) { // 关闭键盘 [BGUtils closeKeyboard]; if (![BGUtils isBlankString:customMessageModel.push_rtmp2] && ![BGUtils isBlankString:customMessageModel.play_rtmp_acc]) { [_linkMicPlayController stopRtmp]; //开始连麦，启动推流 _linkMicPlayController.push_rtmp2 = customMessageModel.push_rtmp2; _linkMicPlayController.play_rtmp_acc = customMessageModel.play_rtmp_acc; _linkMicPlayController.isWaitingResponse = NO; [_linkMicPlayController startVideoLiveLinkMic]; [self cancelMickingAlert]; } else { [FanweMessage alertHUD:ASLocalizedString(@"获取连麦参数失败")]; } } } break; case MSG_REFUSE_MIKE: // 主播拒绝连麦（观众收到主播拒绝连麦消息） { [self cancelMickingAlert]; _linkMicPlayController.isWaitingResponse = NO; NSString *refuseStr = ASLocalizedString(@"主播拒绝了您的连麦请求"); if (![BGUtils isBlankString:customMessageModel.msg]) { refuseStr = customMessageModel.msg; } [self showRefuseHud:refuseStr]; } break; case MSG_BREAK_MIKE: // 断开连麦（观众收到主播断开连麦消息 或者 主播收到观众主动断开连麦消息） { if (_isHost) // 主播收到观众主动断开连麦消息 { [self closeAlertView]; [_publishController breakLinkMick:customMessageModel.sender.user_id]; } else { [_linkMicPlayController stopLinkMic]; [_linkMicPlayController startRtmp:self.liveInfo.create_type]; } } break; case MSG_ACCEPT_PK: { // if (_isApplyMicking) // { // 关闭键盘 [BGUtils closeKeyboard]; //接受pk!! // } } break; case MSG_END_PK: { // if (_isApplyMicking) // { // 关闭键盘 [BGUtils closeKeyboard]; //接受pk!! // } } break; default: break; } } #pragma mark 收到自定义的Group消息 - (void)recvCustomGroup:(id)msg { if (![msg isKindOfClass:[CustomMessageModel class]]) { return; } CustomMessageModel *customMessageModel = (CustomMessageModel *)msg; switch (customMessageModel.type) { case MSG_REFRESH_AUDIENCE_LIST: // 主播、所有连麦观众收到的定时连麦消息 { // 当 data_type == 1，主播、所有连麦观众收到的定时连麦消息 if (customMessageModel.data_type == 1) { TLiveMickListModel *mickListModel = [TLiveMickListModel mj_objectWithKeyValues:customMessageModel.data]; if (self.liveType == FW_LIVE_TYPE_HOST) { [_publishController adjustPlayItem:mickListModel]; } else if(self.liveType == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController adjustPlayItem:mickListModel]; } } } break; case MSG_REFRESH_SEAT_LIST: { NSMutableArray *list = [NSMutableArray array]; //如果customMessageModel.dicData是字典 if (![customMessageModel.dicData[@"data"] isKindOfClass:[NSDictionary class]]) { break; } for (NSDictionary *dic in customMessageModel.dicData[@"data"]) { Wheat_Type_List *model = [Wheat_Type_List mj_objectWithKeyValues:dic]; [list addObject:model]; } self.liveInfo.wheat_type_list = list; [_liveServiceController refreshLiveItem:self.liveItem liveInfo:self.liveInfo]; self.voiceRoomVC.live_info = self.liveInfo; RoomModel *model = [[RoomModel alloc] init]; model.wheat_type_list = self.liveInfo.wheat_type_list; self.voiceRoomVC.roomModel = model; NSLog(@"进入更新座位"); break; } case MSG_SEND_EMOTION: { NSLog(@"接收到表情消息%@",customMessageModel.dicData); //遍历麦位找到对应cell NSMutableArray *list = [NSMutableArray array]; for (Wheat_Type_List *model in self.liveInfo.wheat_type_list) { if (customMessageModel.sender.user_id.intValue == model.even_wheat.user_id) { model.face_img = customMessageModel.faceUrl; } [list addObject:model]; } self.liveInfo.wheat_type_list = list; [_liveServiceController refreshLiveItem:self.liveItem liveInfo:self.liveInfo]; self.voiceRoomVC.live_info = self.liveInfo; RoomModel *model = [[RoomModel alloc] init]; model.wheat_type_list = self.liveInfo.wheat_type_list; self.voiceRoomVC.roomModel = model; } break; default: break; } } #pragma mark 请求完接口后，刷新直播间相关信息 - (void)refreshCurrentLiveItem:(id)liveItem liveInfo:(CurrentLiveInfo *)liveInfo { [self refreshLiveItem:liveItem liveInfo:liveInfo]; } #pragma mark 点击飞屏模式，切换直播间（因切换房间涉及到比较多的逻辑，比如：付费、游戏，所以该方法暂时不用） - (void)switchLiveRoom { [self stopLiveRtmp]; [self startEnterChatGroup:nil succ:^{ NSLog(@"11111"); } failed:^(int errId, NSString *errMsg) { NSLog(@"22222"); }]; } #pragma mark 关闭直播间代理事件 - (void)clickCloseLive:(BOOL)isDirectCloseLive isHostShowAlert:(BOOL)isHostShowAlert { [self alertExitLive:isDirectCloseLive isHostShowAlert:isHostShowAlert succ:nil failed:nil]; } #pragma mark 结束界面点击“返回首页” - (void)finishViewClose:(BGLiveServiceController *)liveServiceController { UITabBarController *tabBars = [BGTabBarController sharedInstance]; tabBars.selectedIndex = 0; // 已经走到这里了 必然更改记录 SUS_WINDOW.isDirectCloseLive = YES; [self onExitLiveUI]; } #pragma mark PlayControllerDelegate 结束回播，用来判断是否还有下一段回播 - (void)stopReLive { // 暂时不用做什么操作 } #pragma mark ToolsViewDelegate - (void)selectToolsItemWith:(ToolsView *)toolsView selectIndex:(NSInteger)index isSelected:(BOOL)isSelected { _toolsView = toolsView; if (index == 0) { // 音乐 if ([GlobalVariables sharedInstance].isOtherPush) { self.otherPushPopView.liveInfo = self.liveInfo; [self.otherPushPopView show:self.view type:FDPopTypeCenter]; }else{ [[[YunMusicPlayVC alloc] init] showYunMusicPlayInVC:self inview:self.liveServiceController.liveUIViewController.liveView showframe:CGRectMake(0,200, self.view.bounds.size.width,130) myPlayType:0]; } } else if (index == 1) { // 美颜 // 如果key不为空就调用笑脸点击后出现的美颜控制台 NSString* key = [GlobalVariables sharedInstance].appModel.bogo_beauty_key; if([BGUtils isBlankString:key]) { _beautyView.hidden = NO; }else{ KPostNotification(@"onMainSwitchButtonClick", nil); // [self.tiUIView onMainSwitchButtonClick:nil]; // _beautyPanel.hidden = NO; // [[TiUIManager shareManager]showMainMenuView]; } } else if (index == 2) { // 麦克风 if (isSelected == YES) { _isMuted = NO; [[BGHUDHelper sharedInstance] tipMessage:ASLocalizedString(@"已打开麦克风")]; } else { _isMuted = YES; [[BGHUDHelper sharedInstance] tipMessage:ASLocalizedString(@"已关闭麦克风")]; } [_publishController.txLivePublisher setMute:!isSelected]; } else if (index == 3) { // 切换摄像 if (!_publishController.txLivePublisher.frontCamera) { // 关闭LED [BGUtils turnOnFlash:NO]; [toolsView.toolsCollectionView deselectItemAtIndexPath:[NSIndexPath indexPathWithIndex:4] animated:NO]; } [_publishController clickCamera:nil]; } else if (index == 4) { // 关闭闪光 if (_publishController.txLivePublisher.frontCamera) { [FanweMessage alert:ASLocalizedString(@"前置摄像头下暂时不能打开闪光灯")]; return; } // 打开、关闭LED [_publishController clickTorch:isSelected]; } else if (index == 5) { if (isSelected == YES) { [FanweMessage alert:ASLocalizedString(@"已打开镜像")]; } else { [FanweMessage alert:ASLocalizedString(@"已关闭镜像")]; } [_publishController.txLivePublisher setMirror:isSelected]; } //音效 } #pragma mark TCShowLiveTopViewToSDKDelegate #pragma mark 推拉流请求所的码率 - (void)refreshKBPS:(TCShowLiveTopView *)topView { NSDictionary *tmpDict; if ([self.liveItem liveType] == 0) { tmpDict = _publishController.qualityDict; } else if ([self.liveItem liveType] == 1) { tmpDict = _playController.qualityDict; } else if ([self.liveItem liveType] == 2) { tmpDict = _linkMicPlayController.qualityDict; } int totalkb = ([tmpDict toInt:NET_STATUS_VIDEO_BITRATE] + [tmpDict toInt:NET_STATUS_AUDIO_BITRATE])/8; if (totalkb) { topView.kbpsSendLabel.hidden = NO; topView.kbpsRecvLabel.hidden = YES; CGRect newFrame = topView.kbpsSendLabel.frame; newFrame.origin.y = CGRectGetHeight(topView.kbpsContainerView.frame)/4; topView.kbpsSendLabel.frame = newFrame; } else { topView.kbpsSendLabel.hidden = YES; topView.kbpsRecvLabel.hidden = YES; } topView.kbpsSendLabel.text = [NSString stringWithFormat:@"%@%dk",[self.liveItem liveType] == 0 ? @"↑" : @"↓" ,totalkb]; } #pragma mark FWTPublishControllerDelegate #pragma mark 腾讯云直播的主播首帧回调 - (void)firstIFrame:(BGTPublishController*)publishVC { if (!_hasShowVagueImg) { [self hideVagueImgView]; // 设置默认美颜 [self setCurrentBeautyValue:self.BuguLive.appModel.beauty_ios whiteValue:0]; SUS_WINDOW.isPushStreamIng = YES; } } #pragma mark 推流时，网络断连,且经多次重连抢救无效后退出app - (void)exitPublishAndApp:(BGTPublishController *)publishVC { [self alertExitLive:NO isHostShowAlert:NO succ:nil failed:nil]; } #pragma mark FWTPlayControllerDelegate #pragma mark 腾讯云直播的观众、回播首帧回调 - (void)firstFrame:(BGTPlayController*)playVC { [self hideVagueImgView]; } #pragma mark 拉流时，网络断连,重连 - (void)playAgain:(BGTPlayController *)publishVC isHideLeaveTip:(BOOL)isHideLeaveTip { if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController startRtmp:self.liveInfo.create_type]; } if (!_liveServiceController.anchorLeaveTipLabel.isHidden && isHideLeaveTip) { _liveServiceController.anchorLeaveTipLabel.hidden = YES; } } #pragma mark 拉流时，网络断连,且经多次重连抢救无效后退出app - (void)exitPlayAndApp:(BGTPlayController *)publishVC { [self alertExitLive:YES isHostShowAlert:NO succ:nil failed:nil]; } #pragma mark livePayDelegate #pragma mark 付费直播是否加载直播间视频的代理 - (void)livePayLoadVedioIsComfirm:(BOOL)isComfirm { if (isComfirm) { if (!self.hasEnterChatGroup) { [self.linkMicPlayController stopRtmp]; if (self.liveType == FW_LIVE_TYPE_AUDIENCE) { [self.linkMicPlayController.txLivePlayer setMute:NO]; } [self.liveServiceController.liveUIViewController dealLivepayTComfirm]; FWWeakify(self) [self.liveServiceController getVideo:^(CurrentLiveInfo *liveInfo) { FWStrongify(self) self.liveInfo = liveInfo; [self beginPlayVideo:liveInfo]; self.hasVideoControl = liveInfo.has_video_control ? YES : NO; [super startEnterChatGroup:_liveInfo.group_id succ:nil failed:nil]; } roomID:@"" failed:^(int errId, NSString *errMsg){ }]; } } else { [self alertExitLive:YES isHostShowAlert:NO succ:nil failed:nil]; } } -(void)protocolGetVideoWithRoomID:(NSString *)roomID{ FWWeakify(self) [self.liveServiceController getVideo:^(CurrentLiveInfo *liveInfo) { TCShowUser *user = [[TCShowUser alloc] init]; user.avatar = liveInfo.podcast.user.head_image; user.uid = liveInfo.user_id; user.username = liveInfo.podcast.user.nick_name; TCShowLiveListItem *liveRoom = [[TCShowLiveListItem alloc] init]; liveRoom.host = user; liveRoom.avRoomId = [liveInfo.room_id intValue]; liveRoom.title = [NSString stringWithFormat:@"%d",liveRoom.avRoomId]; liveRoom.vagueImgUrl = liveInfo.podcast.user.head_image; //SUS_WINDOW 去记录直播间类型 这是不是观众 liveRoom.liveType = SUS_WINDOW.liveType; liveRoom.isHost = NO; // TCShowLiveView *liveView = [[TCShowLiveView alloc]initWith:liveRoom liveController:self]; // _liveServiceController.liveUIViewController.liveView = liveView; _liveServiceController.liveUIViewController.liveScrollView.roomID = liveInfo.room_id; [_liveServiceController.liveUIViewController.liveView refreshLiveItem:liveRoom liveInfo:liveInfo]; FWStrongify(self) self.liveInfo = liveInfo; [self beginPlayVideo:liveInfo]; self.hasVideoControl = liveInfo.has_video_control ? YES : NO; _linkMicPlayController.videoContrainerView.top = 0; _liveServiceController.liveUIViewController.liveScrollView.top = 0; _firstImgView.top = _linkMicPlayController.videoContrainerView.bottom; _secondImgView.top = _firstImgView.bottom; NSLog(@"_liveServiceControlle.scrollview%@",_liveServiceController.liveUIViewController.liveScrollView); [FanweMessage alert:ASLocalizedString(@"切换直播间成功!")]; [super startEnterChatGroup:liveInfo.group_id succ:nil failed:nil]; } roomID:roomID failed:^(int errId, NSString *errMsg) { }]; } #pragma mark 付费直播关闭直播间的声音 - (void)voiceNotice:(NSNotification*)notification { NSMutableDictionary *dictM = [notification object]; if ([dictM toInt:@"type"] == 0)//关闭声音 { [self setSDKMute:YES]; } else if ([dictM toInt:@"type"] == 1)//打开声音 { [self setSDKMute:NO]; } } #pragma mark ------------------------ 实现FWLiveControllerAble协议 ----------------------- #pragma mark 开始推流、拉流 - (void)startLiveRtmp:(NSString *)playUrlStr { if (![BGUtils isBlankString:playUrlStr]) { if ([self.liveItem liveType] == FW_LIVE_TYPE_HOST) { _publishController.pushUrlStr = playUrlStr; if (![GlobalVariables sharedInstance].isOtherPush) { [_publishController startPushRtmpLiveMethod]; } } else if ([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { _linkMicPlayController.playUrlStr = playUrlStr; [_linkMicPlayController startRtmp:self.liveInfo.create_type]; } } } #pragma mark 结束推流、拉流 - (void)stopLiveRtmp { if ([self.liveItem liveType] == FW_LIVE_TYPE_HOST) { [_publishController stopRtmp]; } else if ([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { [_linkMicPlayController stopRtmp]; } } //#pragma mark 按时付费剩余时间的倒计时 //- (void)livePayLeftTimeGo //{ // _liveServiceController.liveUIViewController.livePayLeftCount --; // if (_liveServiceController.liveUIViewController.livePayLeftCount == 0) // { // [_liveServiceController.liveUIViewController.livePayLeftTimer invalidate]; // _liveServiceController.liveUIViewController.livePayLeftTimer =nil; // }else // { // _liveServiceController.liveUIViewController.livePayLabel.text = [NSString stringWithFormat:ASLocalizedString(@"亲,大约%d秒后进入直播间"),_liveServiceController.liveUIViewController.livePayLeftCount]; // } //} #pragma mark TCShowLiveViewToSDKDelegate - (void)hideReLiveSlide:(BOOL)isHided { if (isHided) { _reLiveProgressView.hidden = YES; } else { if (self.hasVideoControl) { _reLiveProgressView.hidden = NO; } } } #pragma mark - ----------------------- 美颜 ----------------------- #pragma mark 设置美颜类型（FWTLiveBeautyViewDelegate） - (void)setBeauty:(BGTLiveBeautyView *)beautyView withBeautyName:(NSString *)beautyName { if (_publishController.txLivePublisher) { if (![BGUtils isBlankString:beautyName]) { NSString * path = [[NSBundle mainBundle] pathForResource:@"FilterResource" ofType:@"bundle"]; if(path && ![beautyName isEqualToString:ASLocalizedString(@"普通美颜")]) { path = [path stringByAppendingPathComponent:beautyName]; UIImage *image = [UIImage imageWithContentsOfFile:path]; [_publishController.txLivePublisher setFilter:image]; } else if ([beautyName isEqualToString:ASLocalizedString(@"普通美颜")]) { [_publishController.txLivePublisher setFilter:nil]; } } else { [_publishController.txLivePublisher setFilter:nil]; [self setCurrentBeautyValue:0 whiteValue:0]; } } } #pragma mark 设置美颜的值 - (void)setBeautyValue:(BGTLiveBeautyView *)beautyView { if (_publishController.txLivePublisher) { [_publishController.txLivePublisher setBeautyStyle:0 beautyLevel:beautyView.filterParam1.slider.value/10 whitenessLevel:beautyView.filterParam2.slider.value/10 ruddinessLevel:0]; } } - (void)setCurrentBeautyValue:(float)beautyDepth whiteValue:(float)whiteDepth { _beautyView.filterParam1.slider.value = beautyDepth; _beautyView.filterParam2.slider.value = whiteDepth; [_beautyView.filterParam1 updateValue]; [_beautyView.filterParam2 updateValue]; [self setBeautyValue:_beautyView]; } #pragma mark - ----------------------- 其他 ----------------------- #pragma mark 获取当前直播质量 - (NSString *)getLiveQuality { NSDictionary *tmpDict; if ([self.liveItem liveType] == 0) { tmpDict = _publishController.qualityDict; } else { tmpDict = _playController.qualityDict; } NSMutableDictionary *mDict = [NSMutableDictionary dictionary]; // 设备类型 [mDict setObject:@"Ios" forKey:@"device"]; // app占用CPU if ([tmpDict toFloat:NET_STATUS_CPU_USAGE_D]) { [mDict setObject:[NSString stringWithFormat:@"%f",[tmpDict toFloat:NET_STATUS_CPU_USAGE_D]*100] forKey:@"appCPURate"]; } // 系统占用CPU if ([tmpDict toFloat:NET_STATUS_CPU_USAGE]) { [mDict setObject:[NSString stringWithFormat:@"%f",[tmpDict toFloat:NET_STATUS_CPU_USAGE]*100] forKey:@"sysCPURate"]; } // 画面帧率，如：25 if ([tmpDict toString:NET_STATUS_VIDEO_FPS]) { [mDict setObject:[tmpDict toString:NET_STATUS_VIDEO_FPS] forKey:@"fps"]; } // 发送、接收码率（每秒钟发送、接收的数据量） int totalkbps = [tmpDict toInt:NET_STATUS_VIDEO_BITRATE] + [tmpDict toInt:NET_STATUS_AUDIO_BITRATE]; int totalkb = totalkbps/8; if (totalkb) { if ([self.liveItem liveType] == 0) { [mDict setObject:StringFromInt(totalkb) forKey:@"sendKBps"]; } else { [mDict setObject:StringFromInt(totalkb) forKey:@"recvKBps"]; } } // 显示网络差的提示 int netSpeed = [tmpDict toInt:NET_STATUS_NET_SPEED]; if(netSpeed == 0) {netSpeed = 1;} float loss_rate_send = (netSpeed-totalkbps)/netSpeed; if ([self.liveItem liveType] == 0) { [mDict setObject:[NSString stringWithFormat:@"%f",loss_rate_send] forKey:@"sendLossRate"]; } else { [mDict setObject:[NSString stringWithFormat:@"%f",loss_rate_send] forKey:@"recvLossRate"]; } if (loss_rate_send <= 0.2) { _lossRateSendTipLabel.hidden = YES; } else if(loss_rate_send > 0.2 && loss_rate_send < 0.3) { _lossRateSendTipLabel.hidden = NO; _lossRateSendTipLabel.text = kHostNetLowTip1; _lossRateSendTipLabel.textColor = kYellowColor; } else { _lossRateSendTipLabel.hidden = NO; _lossRateSendTipLabel.text = kHostNetLowTip2; _lossRateSendTipLabel.textColor = kRedColor; } NSString *sendMessage = [BGUtils dataTOjsonString:mDict]; if (sendMessage) { return sendMessage; } else { return @""; } } #pragma mark 获取当前视频容器视图的父视图 - (UIView *)getPlayViewBottomView { if ([self.liveItem liveType] == FW_LIVE_TYPE_HOST) { return _publishController.view; } else if ([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { return _linkMicPlayController.view; } return nil; } #pragma mark 设置静音 YES：设置为静音 - (void)setSDKMute:(BOOL)bEnable { if (bEnable) // 关闭声音 { if ([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { [self.linkMicPlayController.txLivePlayer setMute:YES]; } } else // 打开声音 { if ([self.liveItem liveType] == FW_LIVE_TYPE_AUDIENCE) { [self.linkMicPlayController.txLivePlayer setMute:NO]; } } } #pragma mark - ----------------------- 其他 ----------------------- #pragma mark 解决不能调为最小音量问题 - (void)volumeChanged:(NSNotification *)noti { NSDictionary *tmpDict = noti.userInfo; if (tmpDict && [tmpDict isKindOfClass:[NSDictionary class]]) { if ([[tmpDict toString:@"AVSystemController_AudioVolumeChangeReasonNotificationParameter"] isEqualToString:@"ExplicitVolumeChange"] && !_isMuted) { float volume = [[tmpDict objectForKey:@"AVSystemController_AudioVolumeNotificationParameter"] floatValue]; if (volume <= 0.062500) { [_publishController.txLivePublisher setMute:YES]; } else { [_publishController.txLivePublisher setMute:NO]; } } } } - (BGOtherPushPopView *)otherPushPopView{ if (!_otherPushPopView) { _otherPushPopView = [[NSBundle mainBundle] loadNibNamed:@"BGOtherPushPopView" owner:nil options:nil].lastObject; } return _otherPushPopView; } - (void)dealloc { [[NSNotificationCenter defaultCenter]removeObserver:self]; } #pragma mark - 初始化声网dev - (void)initializeAgoraEngine { self.trtcCloud = [TRTCCloud sharedInstance]; [[TRTCCloud sharedInstance] addDelegate: self]; // 主播： TRTCRoleAnchor // 观众： TRTCRoleAudience [self.trtcCloud switchRole:TRTCRoleAudience]; } - (void)joinChannel:(NSString *)room_id { TRTCParams *params = [[TRTCParams alloc] init]; // 以字符串房间号为例 params.roomId = room_id.intValue; params.userId = [IMAPlatform sharedInstance].host.userId; // 从业务后台获取到的 UserSig params.userSig = [IMALoginParam loadFromLocal].userSig; // 替换成您的 SDKAppID params.sdkAppId = TXSDKAppID; // 根据需要指定用户角色，以观众为例 params.role = TRTCRoleAudience; // 根据需要指定场景，以语聊房为例 [self.trtcCloud enterRoom:params appScene:TRTCAppSceneVoiceChatRoom]; TRTCAudioVolumeEvaluateParams * audioVolumeEvaluateParams = [[TRTCAudioVolumeEvaluateParams alloc] init]; //【推荐取值】推荐值：300，单位为毫秒。 audioVolumeEvaluateParams.interval = 300; /// 【字段含义】是否开启本地人声检测。 /// 【请您注意】在 startLocalAudio 之前调用才可以生效。 audioVolumeEvaluateParams.enableVadDetection = YES; /// 【字段含义】是否开启本地人声频率计算 audioVolumeEvaluateParams.enablePitchCalculation = YES; /// 【字段含义】是否开启声音频谱计算。 audioVolumeEvaluateParams.enableSpectrumCalculation = YES; [self.trtcCloud enableAudioVolumeEvaluation:YES withParams:audioVolumeEvaluateParams]; [self reloadStopOrStartLocalAudio]; } #pragma mark - MusicPlayerDelegate - (void)playMusicClicked:(NSNotification *)nofit { // //_agoraPlayTime 定时器1秒一次 // if (_agoraPlayTime) { // [_agoraPlayTime invalidate]; // _agoraPlayTime = nil; // } // _agoraPlayTime = [NSTimer scheduledTimerWithTimeInterval:1 target:self selector:@selector(getAgoraTimer) userInfo:nil repeats:YES]; musiceModel *model = nofit.object; if(!model) { return; } NSLog(@"点击了播放 %@ \n %d",model.url,model.id); TXAudioMusicParam * musicParam = [[TXAudioMusicParam alloc] init]; musicParam.ID = model.id.intValue; musicParam.endTimeMS = 0; musicParam.isShortFile = NO; //【字段含义】音乐循环播放的次数。 【推荐取值】取值范围为0 - 任意正整数，默认值：0。0 表示播放音乐一次；1 表示播放音乐两次；以此类推。 musicParam.loopCount = 0; musicParam.path = model.url; musicParam.publish = YES; musicParam.startTimeMS = 0; WeakSelf [[self.trtcCloud getAudioEffectManager] startPlayMusic:musicParam onStart:^(NSInteger errCode) { NSString * str = @"音乐播放成功"; if (errCode < 0) { str = @"播放失败"; } NSLog(@"%@ === %ld",str,errCode); } onProgress:^(NSInteger progressMs, NSInteger durationMs) { float duration = durationMs; float position = progressMs; //获取百分比 float perct = position / duration; weakSelf.liveServiceController.liveUIViewController.musicVC.playerView.songSlider.value = perct; //把duration转为00:00:13时间格式 position = position/1000; NSString *time = [NSString stringWithFormat:@"%02d:%02d:%02d", (int)position / 3600, (int)position % 3600 / 60, (int)position % 60]; weakSelf.liveServiceController.liveUIViewController.musicVC.playerView.songTimeLabel.text = time; weakSelf.liveServiceController.liveUIViewController.musicVC.playerView.playPauseButton.selected = YES; } onComplete:^(NSInteger errCode) { [weakSelf stopMusic]; }]; } //停止音乐 - (void)stopMusic { NSLog(@"停止成功"); //TRTC中提供 musicID 用于指定需要停止播放的音乐 TXAudioEffectManager * audioEffectManager = [self.trtcCloud getAudioEffectManager]; [audioEffectManager stopPlayMusic:self.liveServiceController.liveUIViewController.musicVC.playMusicId.intValue]; // [self releaseTimer]; self.liveServiceController.liveUIViewController.musicVC.playMusicId = @""; [self.liveServiceController.liveUIViewController.musicVC.mtableview reloadData]; self.liveServiceController.liveUIViewController.musicVC.playerView.songSlider.value = 0; self.liveServiceController.liveUIViewController.musicVC.playerView.songTimeLabel.text = @"00:00:00"; self.liveServiceController.liveUIViewController.musicVC.playerView.playPauseButton.selected = NO; NSLog(@"播放已经结束"); } - (void)clickRoomManage { RoomSetViewController *vc = [[RoomSetViewController alloc] init]; vc.model = self.liveInfo; vc.modalPresentationStyle = UIModalPresentationFullScreen; [self presentViewController:vc animated:YES completion:nil]; } @end