711/BuguLive/Class/Live/TCAdapter/TIMAdapter/Playform/IMAContactManager+Group.m

//
//  IMAContactManager+Group.m
//  TIMChat
//
//  Created by AlexiChen on 16/3/2.
//  Copyright © 2016年 AlexiChen. All rights reserved.
//

#import "IMAContactManager+Group.h"

@implementation IMAContactManager (Group)


- (void)createGroupList:(NSArray *)array
{
    if (array.count)
    {
        NSMutableArray *gidarray = [NSMutableArray array];
        for (TIMGroupInfo *group in array)
        {
            [gidarray addObject:[group group]];
        }
        // 同步群基本信息
        
        __weak IMAContactManager *ws = self;
        [[TIMGroupManager sharedInstance] getGroupInfo:gidarray succ:^(NSArray *array) {
            [ws asyncDetailGroupInfo:array];
        } fail:^(int code, NSString *err) {
            DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
            [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
        }];
    }
    
}


- (void)asyncDetailGroupInfo:(NSArray *)array
{
    if (!_groupList)
    {
        _groupList = [[CLSafeMutableArray alloc] init];
    }
    
    for (TIMGroupInfo *group in array)
    {
        IMAGroup *sg = [[IMAGroup alloc] initWithInfo:group];
        
        [_groupList addObject:sg];
    }
    
//    [[IMAPlatform sharedInstance].conversationMgr asyncConversationList];
}



// 群列表
- (void)asyncGroupList
{
    __weak IMAContactManager *ws = self;

    [[TIMGroupManager sharedInstance] getGroupList:^(NSArray *array) {
        [ws createGroupList:array];
    } fail:^(int code, NSString *err) {
        DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
        DebugLog(@"code = %d, err = %@", code, err);
    }];
}

- (void)syncGroupList
{
    NSArray *array = [[TIMGroupManager sharedInstance] getGroupInfo:nil];
    [self asyncDetailGroupInfo:array];
}

- (TIMGroupInfo *)syncGetGroupInfo:(NSString *)groupId
{
    NSArray *infos = [[TIMGroupManager sharedInstance] getGroupInfo:@[groupId]];
    if (infos.count  > 0)
    {
        return infos[0];
    }
    return nil;
}

- (void)createBlackList:(NSArray *)array
{
    if (array.count)
    {
        NSMutableArray *ba = [NSMutableArray array];
        for (NSString *userid in array)
        {
            IMAUser *user = [[IMAUser alloc] initWith:userid];
            [ba addObject:user];
        }
        
        if (!_blackList)
        {
            _blackList = [[CLSafeMutableArray alloc] init];
        }
        [_blackList addObjectsFromArray:ba];
    }
}

// 黑名单
- (void)asyncBlackList
{
    __weak IMAContactManager *ws = self;
    [[TIMFriendshipManager sharedInstance] getBlackList:^(NSArray *array) {
        [ws createBlackList:array];
    } fail:^(int code, NSString *err) {
        DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
        DebugLog(@"code = %d, err = %@", code, err);
    }];
}


// 获取公开群
- (NSMutableDictionary *)publicGroups
{
    NSMutableArray *myOwn = [NSMutableArray array];
    NSMutableArray *myMgr = [NSMutableArray array];
    NSMutableArray *myBelongTo = [NSMutableArray array];
    
    for (NSInteger i = 0; i < _groupList.count; i++)
    {
        IMAGroup *group = [_groupList objectAtIndex:i];
        if ([group isPublicGroup])
        {
            if ([group isCreatedByMe])
            {
                [myOwn addObject:group];
            }
            else if ([group isManagedByMe])
            {
                [myMgr addObject:group];
            }
            else
            {
                [myBelongTo addObject:group];
            }
        }
    }
    
    NSMutableDictionary *dic = [NSMutableDictionary dictionary];
    if (myOwn.count > 0)
    {
        [dic setObject:myOwn forKey:ASLocalizedString(@"我创建的群")];
    }
    if (myMgr.count > 0)
    {
        [dic setObject:myMgr forKey:ASLocalizedString(@"我管理的群")];
    }
    if (myBelongTo.count > 0)
    {
        [dic setObject:myBelongTo forKey:ASLocalizedString(@"我加入的群")];
    }
    
    return dic;
}

// 获取聊天室
- (NSMutableArray *)chatRooms
{
    NSMutableArray *array = [NSMutableArray array];
    for (NSInteger i = 0; i < _groupList.count; i++)
    {
        IMAGroup *group = [_groupList objectAtIndex:i];
        if ([group isChatRoom])
        {
            [array addObject:group];
        }
    }
    return array;
    
}

// 获取讨论组
- (NSMutableArray *)chatGroup
{
    NSMutableArray *array = [NSMutableArray array];
    for (NSInteger i = 0; i < _groupList.count; i++)
    {
        IMAGroup *group = [_groupList objectAtIndex:i];
        if ([group isChatGroup])
        {
            [array addObject:group];
        }
    }
    return array;
}

// 30 字节长度
#define kMaxGroupNameLength 30

- (BOOL)checkGroupParams:(NSString *)name members:(NSArray *)array
{
    if ([name isContainsEmoji])
    {
        [BGHUDHelper alert:ASLocalizedString(@"群名称不能包含表情")];
        return NO;
    }
    
    if (array.count == 0)
    {
        [BGHUDHelper alert:ASLocalizedString(@"未选择加入群组的好友")];
        return NO;
    }
    return YES;
}

- (void)asyncGroupInfo:(NSString *)groupId onCreateSucc:(void (^)(IMAGroup *group))succ fail:(TIMFail)fail
{
    // 同步群信息
    // 添加成功
    [[TIMGroupManager sharedInstance] getGroupInfo:@[groupId] succ:^(NSArray *array) {
        
        if (array.count)
        {
            // 只会返回一个信息
            TIMGroupInfo *groupInfo = array[0];
            IMAGroup *sg = [[IMAGroup alloc] initWithInfo:groupInfo];
            [self.groupList addObject:sg];
            
            if (succ)
            {
                succ(sg);
            }
            
        }
    } fail:^(int code, NSString *err) {
        DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
        if (fail)
        {
            fail(code, err);
        }
    }];
}

typedef void (^IMACreateCompletion)(IMAGroup *group);
typedef void (^CreateGroupOperation)(NSString *groupName, NSArray *memids, IMACreateCompletion succ, TIMFail fail);

- (void)onWillCreateGroupWith:(NSString *)name members:(NSArray *)array operation:(CreateGroupOperation)op succ:(void (^)(IMAGroup *group))succ fail:(TIMFail)fail
{
    if (![self checkGroupParams:name members:array])
    {
        return;
    }
    
    size_t length = strlen([name UTF8String]);
    if( length > kMaxGroupNameLength)
    {
        name = [name cutBeyondTextInLength:kMaxGroupNameLength];
    }
    
    NSMutableArray *mems = [NSMutableArray array];
    for (IMAUser *user in array)
    {
        TIMCreateGroupMemberInfo *mem = [[TIMCreateGroupMemberInfo alloc] init];
        mem.member = [user userId];
        mem.role = TIM_GROUP_MEMBER_ROLE_MEMBER;
        [mems addObject:mem];
    }
    
    if (op)
    {
        op(name, mems, succ, fail);
    }
}


- (void)asyncCreateChatGroupWith:(NSString *)name members:(NSArray *)array succ:(void (^)(IMAGroup *group))succ fail:(TIMFail)fail
{
//    __weak IMAContactManager *ws = self;
    [self onWillCreateGroupWith:name members:array operation:^(NSString *groupName, NSArray *memids, IMACreateCompletion succ, TIMFail fail) {
        
        TIMCreateGroupInfo *cgi = [[TIMCreateGroupInfo alloc] init];
        cgi.group = nil;
        cgi.groupName = name;
        cgi.groupType = @"Private";
        cgi.maxMemberNum = 0;
        cgi.membersInfo = memids;
        
        [[TIMGroupManager sharedInstance] createGroup:cgi succ:^(NSString *groupId) {

            TIMGroupInfo *tgi = [TIMGroupInfo instanceFrom:cgi];
            tgi.group = groupId;
            tgi.owner = [[IMAPlatform sharedInstance].host userId];
            
            IMAGroup *g = [[IMAGroup alloc] initWithInfo:tgi];
            
            if (succ)
            {
                succ(g);
            }
        } fail:^(int code, NSString *err) {
            DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
            [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
            if (fail)
            {
                fail(code, err);
            }
        }];
    } succ:succ fail:fail];
    
}

- (void)asyncCreatePublicGroupWith:(NSString *)name members:(NSArray *)array succ:(void (^)(IMAGroup *group))succ fail:(TIMFail)fail
{
//    __weak IMAContactManager *ws = self;
    [self onWillCreateGroupWith:name members:array operation:^(NSString *groupName, NSArray *memids, IMACreateCompletion succ, TIMFail fail) {
        
        TIMCreateGroupInfo *cgi = [[TIMCreateGroupInfo alloc] init];
        cgi.group = nil;
        cgi.groupName = name;
        cgi.groupType = @"Public";
        cgi.addOpt = TIM_GROUP_ADD_ANY;
        cgi.maxMemberNum = 0;
        cgi.membersInfo = memids;
        
        [[TIMGroupManager sharedInstance] createGroup:cgi succ:^(NSString *groupId) {
            //注:这里成功回调时，不能调用getGroupInfo，因为群信息还没有同步下来，必须是在onGroupAdd回调之后才能回去到详细的群信息
            
            TIMGroupInfo *tgi = [TIMGroupInfo instanceFrom:cgi];
            tgi.group = groupId;
            tgi.owner = [[IMAPlatform sharedInstance].host userId];
            
            IMAGroup *g = [[IMAGroup alloc] initWithInfo:tgi];
            
            if (succ)
            {
                succ(g);
            }
        } fail:^(int code, NSString *err) {
            DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
            [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
            if (fail)
            {
                fail(code, err);
            }
        }];
    } succ:succ fail:fail];
}


- (void)asyncCreateChatRoomWith:(NSString *)name members:(NSArray *)array succ:(void (^)(IMAGroup *group))succ fail:(TIMFail)fail
{
//    __weak IMAContactManager *ws = self;
    [self onWillCreateGroupWith:name members:array operation:^(NSString *groupName, NSArray *memids, IMACreateCompletion succ, TIMFail fail) {
        
        TIMCreateGroupInfo *cgi = [[TIMCreateGroupInfo alloc] init];
        cgi.group = nil;
        cgi.groupName = name;
        cgi.groupType = @"ChatRoom";
        cgi.addOpt = TIM_GROUP_ADD_ANY;
        cgi.maxMemberNum = 0;
        cgi.membersInfo = memids;
        
        [[TIMGroupManager sharedInstance] createGroup:cgi succ:^(NSString *groupId) {
            
            TIMGroupInfo *tgi = [TIMGroupInfo instanceFrom:cgi];
            tgi.group = groupId;
            tgi.owner = [[IMAPlatform sharedInstance].host userId];
            
            IMAGroup *g = [[IMAGroup alloc] initWithInfo:tgi];
            
            if (succ)
            {
                succ(g);
            }
        } fail:^(int code, NSString *err) {
            DebugLog(@"Fail:-->code=%d,msg=%@,fun=%s", code, err,__func__);
            [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, err)];
            if (fail)
            {
                fail(code, err);
            }
        }];
    } succ:succ fail:fail];
}

- (void)asyncGetGroupPendencyList:(TIMGetGroupPendencyListSucc)succ fail:(TIMFail)fail
{
    TIMGroupPendencyOption *opt = [[TIMGroupPendencyOption alloc] init];
    opt.timestamp = 0;
    opt.numPerPage = 100;
    
    [[TIMGroupManager sharedInstance] getPendencyFromServer:opt succ:^(TIMGroupPendencyMeta *meta, NSArray *pendencies) {
        if (succ)
        {
            succ(meta, pendencies);
        }
    } fail:^(int code, NSString *msg) {
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, msg)];
        if (fail)
        {
            fail(code, msg);
        }
    }];
}

- (void)asyncGroupPendencyReport:(uint64_t)timestamp succ:(TIMSucc)succ fail:(TIMFail)fail
{
    [[TIMGroupManager sharedInstance] pendencyReport:timestamp succ:^{
        if (succ)
        {
            succ();
        }
    } fail:^(int code, NSString *msg) {
        DebugLog(@"group pendency report fail (code = %d, msg = %@)",code, msg);
        
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, msg)];
        if (fail)
        {
            fail(code, msg);
        }
    }];
}

- (void)asyncAcceptAddGroup:(NSString*)msg pendencyItem:(TIMGroupPendencyItem *)item succ:(TIMSucc)succ fail:(TIMFail)fail
{
    if (!item)
    {
        return;
    }
    
    [item accept:msg succ:^{
        if (succ)
        {
            succ();
        }
    } fail:^(int code, NSString *msg) {
        
        NSString *errInfo = [NSString stringWithFormat:@"accept fail code = %d,msg = %@", code, msg];
        DebugLog(@"%@", errInfo);
        
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, msg)];
        if (fail)
        {
            fail(code, msg);
        }
    }];
}
- (void)asyncRefuseAddGroup:(NSString*)msg pendencyItem:(TIMGroupPendencyItem *)item succ:(TIMSucc)succ fail:(TIMFail)fail
{
    if (!item)
    {
        return;
    }
    
    [item refuse:msg succ:^{
        if (succ)
        {
            succ();
        }
    } fail:^(int code, NSString *msg) {
        NSString *errInfo = [NSString stringWithFormat:@"refuse fail code = %d,msg = %@", code, msg];
        DebugLog(@"%@", errInfo);
        
        [[BGHUDHelper sharedInstance] tipMessage:IMALocalizedError(code, msg)];
        if (fail)
        {
            fail(code, msg);
        }
    }];
}
@end