yinmeng-ios/xplan-ios/Main/Room/Presenter/XPRoomPresenter.m

//
//  XPRoomPresenter.m
//  xplan-ios
//
//  Created by 冯硕 on 2021/10/18.
//

#import "XPRoomPresenter.h"
///API
#import "Api+Room.h"
#import "UserInfoModel.h"
///Tool
#import "AccountInfoStorage.h"
#import "NSObject+MJExtension.h"
///P
#import "XPRoomProtocol.h"

#import <NIMSDK/NIMSDK.h>
#import <ReactiveObjC/ReactiveObjC.h>


@implementation XPRoomPresenter

- (void)initEnterRoom:(NSString *)roomUid user:(NSString *)uid {
    RACSubject* room = [RACSubject subject];
    RACSubject* user = [RACSubject subject];
    
    [[RACSignal combineLatest:@[room, user] reduce:^id(RoomInfoModel* room, UserInfoModel* user){
        [[self getView] initEnterRoomSuccess:room user:user];
        return nil;
    }] subscribeError:^(NSError * _Nullable error) {
        [[self getView] enterRoomFail];
    }];
    
    [Api getUserInfo:[self createHttpCompletion:^(BaseModel * _Nonnull data) {
        UserInfoModel * infoModel = [UserInfoModel modelWithJSON:data.data];
        [user sendNext:infoModel];
        [user sendCompleted];
    } fail:^(NSInteger code, NSString * _Nullable msg) {
        [user sendError:nil];
    } showLoading:NO errorToast:NO] uid:uid];
    
    [Api getRoomInfo:[self createHttpCompletion:^(BaseModel * _Nonnull data) {
        RoomInfoModel * model = [RoomInfoModel modelWithJSON:data.data];
        [room sendNext:model];
        [room sendCompleted];
    } fail:^(NSInteger code, NSString * _Nullable msg) {
        [user sendError:nil];
    } showLoading:NO errorToast:NO] uid:roomUid intoUid:uid];
}

- (void)enterNIMRoom:(NSString *)roomId user:(UserInfoModel *)userInfo {
    NIMChatroomEnterRequest *request = [[NIMChatroomEnterRequest alloc] init];
    request.roomId = roomId;
    //设置ext
    NSMutableDictionary *extSource = [NSMutableDictionary dictionary];
    //defUser
    if (userInfo) {
        [extSource setObject:@(userInfo.defUser) forKey:@"defUser"];
        [extSource setObject:@(userInfo.erbanNo) forKey:@"erbanNo"];
    }
    
    NSMutableDictionary *ext = [NSMutableDictionary dictionaryWithObject:extSource forKey:[NSString stringWithFormat:@"%ld", userInfo.uid]];
    request.roomExt = [ext toJSONString];
    
    [[NIMSDK sharedSDK].chatroomManager enterChatroom:request completion:^(NSError * _Nullable error, NIMChatroom * _Nullable chatroom, NIMChatroomMember * _Nullable me) {
        if (error) {
            [[self getView] enterRoomFail];
        } else {
            [[self getView] enterRoomSuccess];
        }
    }];
}

- (void)exitNIMRoom:(NSString *)roomId {
    [[NIMSDK sharedSDK].chatroomManager exitChatroom:roomId completion:nil];
}

/// 开启用户自己的房间
/// @param title 房间标题
/// @param type 房间类型
/// @param roomPwd 房间密码
/// @param roomDesc 房间介绍
/// @param backPic 房间背景
- (void)openRoom:(NSString *)title
            type:(RoomType)type
         roomPwd:(NSString *)roomPwd
        roomDesc:(NSString *)roomDesc
         backPic:(NSString *)backPic {
    NSString * uid = [AccountInfoStorage instance].getUid;
    NSString * ticket = [AccountInfoStorage instance].getTicket;
    if (title.length <= 0) {
        title = @"";
    }
    
    if (roomPwd.length <= 0) {
        roomPwd = @"";
    }
    
    if (roomDesc.length <= 0) {
        roomDesc = @"";
    }
    
    if (backPic.length <= 0) {
        backPic = @"";
    }
    
    [Api openRoom:[self createHttpCompletion:^(BaseModel * _Nonnull data) {
        RoomInfoModel * infoModel = [RoomInfoModel modelWithJSON:data.data];
        [[self getView] openRoomSuccess:infoModel];
    } fail:^(NSInteger code, NSString * _Nullable msg) {
        [[self getView] enterRoomFail];
    } showLoading:YES] title:title type:type roomPwd:roomPwd roomDesc:roomDesc backPic:backPic uid:uid ticket:ticket];
}

@end