异步获取群聊列表逻辑调整

daojian
1 parent 6727a581
Showing 4 changed files with 182 additions and 166 deletions
CNLiveNewIMAManagerKit.podspec
CNLiveNewIMAManagerKit/Classes/Playform/IMAContactManager+Group.h
CNLiveNewIMAManagerKit/Classes/Playform/IMAContactManager+Group.m
CNLiveNewIMAManagerKit/Classes/Playform/IMAContactManager.m
@@ -8,7 +8,7 @@
 Pod::Spec.new do |s|
   s.name             = 'CNLiveNewIMAManagerKit'
-  s.version          = '0.5.5'
+  s.version          = '0.5.6'
   s.summary          = 'A short description of CNLiveNewIMAManagerKit.'
 #s.description      = <<-DESC
@@ -12,7 +12,7 @@
 @interface IMAContactManager (Group)
-/// 异步获取最新群列表
+/// 异步获取最新群列表,并缓存群聊类别 和 所有群id,群详情信息
 - (void)asyncGroupList;
 /// 同步获取IM本地缓存的群列表
@@ -60,18 +60,57 @@
-// 群列表
+/// 异步获取最新群列表,并缓存群聊类别 和 所有群id,群详情信息
 - (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__);
+    
+    [[TIMGroupManager sharedInstance] getGroupList:^(NSArray<TIMGroupInfoResult *> *allGroupArr) {
+        
+        dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
+            
+            [[CNGroupIDFMDBManager manager] deleteAllGroupId];
+            
+            /**存放所有群的id*/
+            NSMutableArray *groupIdArray = [NSMutableArray array];
+            
+            for (int i = 0; i < allGroupArr.count; i ++) {
+                
+                TIMGroupInfo *info = allGroupArr[i];
+                [groupIdArray addObject:info.group];
+                /**把群id保存到数据库*/
+                [[CNGroupIDFMDBManager manager] insertGroupId:info.group];
+                
+                /**缓存群列表*/
+                IMAGroup *group = [[IMAPlatform sharedInstance].contactMgr getUserByGroupId:info.group];
+                if (group == nil) {
+                    [[IMAPlatform sharedInstance].contactMgr onAddGroup:group];
+                }
+                group.groupInfo.selfInfo = info.selfInfo;
+                group.groupInfo.allShutup = info.allShutup;
+                
+                /**把群免打扰设置保存到数据库*/
+                [self saveGroupReceiveMsgStatusWithGroupInfo:info];
+            }
+            
+            /**缓存所有群id*/
+            self.groupIdsList = groupIdArray.mutableCopy;
+            
+            /**刷新会话列表*/
+            dispatch_async(dispatch_get_main_queue(), ^{
+                [[IMAPlatform sharedInstance].conversationMgr asyncConversationList];
+            });
+           
+            /**同步群聊信息到本地*/
+            [self syncGroupInfoWithGroupIdArray:groupIdArray];
+        });
+        
+        
+    } fail:^(int code, NSString *msg) {
+        
     }];
 }
+/// 同步获取IM本地缓存的群列表
 - (void)syncGroupList
 {
     if (self.groupIdsList == nil) {
@@ -81,179 +120,152 @@
     NSArray *array = [[CNGroupListAvaterUtil sharedCNGroupListAvaterUtil] requestTIMGroupInfoForChangeType:CNLiveGroupMemberChangeTypeAppFinishLaunch GroupID:nil];
     [self asyncDetailGroupInfo:array];
 }
-
+/// 获取本地缓存的 某个群的群详情
 - (TIMGroupInfo *)syncGetGroupInfo:(NSString *)groupId
 {
     return [[TIMGroupManager sharedInstance] queryGroupInfo:groupId];
 }
-- (void)saveGroupIdList:(BOOL)reloadLoclGrouoInfo
+//- (void)saveGroupIdList:(BOOL)reloadLoclGrouoInfo
+//{
+//
+//    [[TIMGroupManager sharedInstance] getGroupList:^(NSArray<TIMGroupInfoResult *> *allGroupArr) {
+//        
+//        dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
+//            
+//            [[CNGroupIDFMDBManager manager] deleteAllGroupId];
+//            
+//            /**存放所有群的id*/
+//            NSMutableArray *groupIdArray = [NSMutableArray array];
+//            
+//            for (int i = 0; i < allGroupArr.count; i ++) {
+//                
+//                TIMGroupInfo *info = allGroupArr[i];
+//                [groupIdArray addObject:info.group];
+//                /**把群id保存到数据库*/
+//                [[CNGroupIDFMDBManager manager] insertGroupId:info.group];
+//                
+//                /**缓存群列表*/
+//                IMAGroup *group = [[IMAPlatform sharedInstance].contactMgr getUserByGroupId:info.group];
+//                if (group == nil) {
+//                    [[IMAPlatform sharedInstance].contactMgr onAddGroup:group];
+//                }
+//                group.groupInfo.selfInfo = info.selfInfo;
+//                group.groupInfo.allShutup = info.allShutup;
+//                
+//                /**把群免打扰设置保存到数据库*/
+//                [self saveGroupReceiveMsgStatusWithGroupInfo:info];
+//            }
+//            
+//            /**缓存群id到内存*/
+//            self.groupIdsList = groupIdArray.mutableCopy;
+//            
+//            /**是否需要刷新会话列表*/
+//            if (reloadLoclGrouoInfo) {
+//                dispatch_async(dispatch_get_main_queue(), ^{
+//                    [[IMAPlatform sharedInstance].conversationMgr asyncConversationList];
+//                });
+//            }
+//           
+//            [self syncGroupInfoWithGroupIdArray:groupIdArray];
+//        });
+//        
+//        
+//    } fail:^(int code, NSString *msg) {
+//        
+//    }];
+//}
+
+/// 同步群聊信息到本地
+/// @param groupIdArray 要同步的所有群id
+- (void)syncGroupInfoWithGroupIdArray:(NSArray *)groupIdArray
 {
-
-    [[TIMGroupManager sharedInstance] getGroupList:^(NSArray<TIMGroupInfoResult *> *allGroupArr) {
+    //调 getGroupInfo 方法可以让 IM把 群组信息 存到本地，然后通过 queryGroupInfo 获取本地群组信息. 每次最多只请求50个群的群详情数据,请求太多会失败
+    
+    ///通过线程组来监听所有的同步群信息 操作已完成
+    dispatch_group_t gcd_group = dispatch_group_create();
+    
+    if (groupIdArray.count <= 50) {
+        dispatch_group_enter(gcd_group);
+        [[TIMGroupManager sharedInstance] getGroupInfo:groupIdArray succ:^(NSArray<TIMGroupInfoResult *> *arr) {
+            dispatch_group_leave(gcd_group);
+        } fail:^(int code, NSString *msg) {
+            dispatch_group_leave(gcd_group);
+        }];
+    }
+    else
+    {
+        //分段请求，每段请求 50 个
+        NSInteger count = groupIdArray.count/50;     //50的倍数
+        NSInteger remainder = groupIdArray.count%50; //50的 余数
+        for (int i = 0; i < count; i++) {
+            //每50 个请求一次
+            NSArray *subArray = [groupIdArray subarrayWithRange:NSMakeRange(i*50, 50)];
+            dispatch_group_enter(gcd_group);
+            [[TIMGroupManager sharedInstance] getGroupInfo:subArray succ:^(NSArray<TIMGroupInfoResult *> *arr) {
+                dispatch_group_leave(gcd_group);
+            } fail:^(int code, NSString *msg) {
+                dispatch_group_leave(gcd_group);
+            }];;
+        }
-        dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
-            [[CNGroupIDFMDBManager manager] deleteAllGroupId];
-            NSMutableArray *groupIdArray = [NSMutableArray array];
-            for (int i = 0; i < allGroupArr.count; i ++) {
-                TIMGroupInfo *info = allGroupArr[i];
-                [groupIdArray addObject:info.group];
-                [[CNGroupIDFMDBManager manager] insertGroupId:info.group];
-            }
-            self.groupIdsList = groupIdArray;
-            NSArray *copyGroupIdArray = groupIdArray.copy;
+        // 50 的余数请求
+        if (remainder > 0) {
-            if (reloadLoclGrouoInfo) {
-                dispatch_async(dispatch_get_main_queue(), ^{
-                    [[IMAPlatform sharedInstance].conversationMgr asyncConversationList];
-                });
-            }
-            //当前会话列表id
-            NSMutableArray *currentConversationListID = [[NSMutableArray alloc] init];
-            for (TIMConversation *conv in [[TIMManager sharedInstance] getConversationList]) {
-                if ([conv getReceiver]) {
-                    [currentConversationListID addObject:[conv getReceiver]];
-                }
-            }
-            //调 getGroupInfo 方法可以让 IM把 群组信息 存到本地，然后通过 queryGroupInfo 获取本地群组信息
-            dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
-                                
-                if (copyGroupIdArray.count > 50) {
-                    //分段请求，每段请求 50 个
-                    NSInteger count = copyGroupIdArray.count/50;     //50的倍数
-                    NSInteger remainder = copyGroupIdArray.count%50; //50的 余数
-                    for (int i = 0; i < count; i++) {
-                        //每50 个请求一次
-                        NSArray *subArray = [copyGroupIdArray subarrayWithRange:NSMakeRange(i*50, 50)];
-                        [[TIMGroupManager sharedInstance] getGroupInfo:subArray succ:^(NSArray<TIMGroupInfoResult *> *arr) {
-                            NSLog(@"111");
-                            for ( int j = 0; j < arr.count; j++) {
-                                if ((i*50 + j) < allGroupArr.count) {
-                                    TIMGroupInfo *info = [allGroupArr objectAtIndex:(i*50 + j)];
-//                                    TIMGroupInfoResult *groupInfoResult = arr[j];
-                                    IMAGroup *group = [[IMAPlatform sharedInstance].contactMgr getUserByGroupId:info.group];
-//                                    [group changeGroupInfo:groupInfoResult];
-                                    group.groupInfo.selfInfo = info.selfInfo;
-                                    group.groupInfo.allShutup = info.allShutup;
-                                    if (group.groupId) {
-                                        if ([currentConversationListID containsObject:group.groupId]) {
-                                            [self saveGroupReceiveMsgStatus:group.groupId groupInfo:info];
-                                        }
-                                    }
-                                    
-                                    //判断该群是否存在当前展示的会话列表中
-                                    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
-                                        
-                                    });
-                                    
-                                    
-                                }
-                            }
-                            //                        if (i == (count-1)) {
-                            //                            [self asyncConfigGroup];
-                            //                        }
-                            [self asyncConfigGroup];
-                        } fail:^(int code, NSString *msg) {
-                            
-                        }];;
-                    }
-                    
-                    // 50 的余数请求
-                    NSArray *subArray = [copyGroupIdArray subarrayWithRange:NSMakeRange(count*50, remainder)];
-                    [[TIMGroupManager sharedInstance] getGroupInfo:subArray succ:^(NSArray<TIMGroupInfoResult *> *arr) {
-                        
-                        for ( int j = 0; j < arr.count; j++) {
-                            if ((count*50 + j) < allGroupArr.count) {
-                                TIMGroupInfo *info = [allGroupArr objectAtIndex:(count*50 + j)];
-//                                TIMGroupInfoResult *groupInfoResult = arr[j];
-                                IMAGroup *group = [[IMAPlatform sharedInstance].contactMgr getUserByGroupId:info.group];
-//                                [group changeGroupInfo:groupInfoResult];
-                                group.groupInfo.selfInfo = info.selfInfo;
-                                group.groupInfo.allShutup = info.allShutup;
-                                if (group.groupId) {
-                                    if ([currentConversationListID containsObject:group.groupId]) {
-                                        [self saveGroupReceiveMsgStatus:group.groupId groupInfo:info];
-                                    }
-                                }
-                                //判断该群是否存在当前展示的会话列表中
-                                dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
-                                    
-                                });
-                            }
-                        }
-                        [self asyncConfigGroup];
-                    } fail:^(int code, NSString *msg) {
-                        
-                    }];
-                    
-                }
-                else
-                {
-                    [[TIMGroupManager sharedInstance] getGroupInfo:copyGroupIdArray succ:^(NSArray<TIMGroupInfoResult *> *arr) {
-                        NSLog(@"22222");
-                        for (int i = 0; i < allGroupArr.count; i ++) {
-                            TIMGroupInfo *info = allGroupArr[i];
-//                            TIMGroupInfoResult *groupInfoResult = arr[i];
-                            IMAGroup *group = [[IMAPlatform sharedInstance].contactMgr getUserByGroupId:info.group];
-//                            [group changeGroupInfo:groupInfoResult];
-                            group.groupInfo.selfInfo = info.selfInfo;
-                            group.groupInfo.allShutup = info.allShutup;
-                            //判断该群是否存在当前展示的会话列表中
-                            if (group.groupId) {
-                                if ([currentConversationListID containsObject:group.groupId]) {
-                                    [self saveGroupReceiveMsgStatus:group.groupId groupInfo:info];
-                                }
-                            }
-                            dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
-                                
-                            });
-                        }
-                        [self asyncConfigGroup];
-                    } fail:^(int code, NSString *msg) {
-                        NSLog(@"1111");
-                    }];
-                }
-                
-                
-            });
-        });
-        
-        
-    } fail:^(int code, NSString *msg) {
+            NSArray *subArray = [groupIdArray subarrayWithRange:NSMakeRange(count*50, remainder)];
+            dispatch_group_enter(gcd_group);
+
+            [[TIMGroupManager sharedInstance] getGroupInfo:subArray succ:^(NSArray<TIMGroupInfoResult *> *arr) {
+                dispatch_group_leave(gcd_group);
+            } fail:^(int code, NSString *msg) {
+                dispatch_group_leave(gcd_group);
+            }];
+            
+        }
-    }];
+    }
+    
+    //群聊信息都同步完成
+    dispatch_group_notify(gcd_group, dispatch_get_main_queue(), ^{
+        [self asyncConfigGroup];
+    });
+    
+    
+    
 }
-//存储当前聊天会话群的消息免打扰状态
-- (void)saveGroupReceiveMsgStatus:(NSString *)groupId groupInfo:(TIMGroupInfo *)info
+/// 存储群聊的消息免打扰状态
+- (void)saveGroupReceiveMsgStatusWithGroupInfo:(TIMGroupInfo *)groupInfo
 {
-    //存储扩展的群资料字段
-    CNGroupInfoExtendModel *groupInfoExtendModel = [[CNGroupInfoExtendFMDBManager manager] searchByGroupId:groupId];
-    if (groupInfoExtendModel) {
-        //存在更新
-        if (info.selfInfo.recvOpt == TIM_GROUP_RECEIVE_NOT_NOTIFY_MESSAGE) {
-            if (groupInfoExtendModel.receiveMsg) {
-                if (![groupInfoExtendModel.receiveMsg isEqualToString:@"1"]) {
-                    groupInfoExtendModel.receiveMsg = @"1";
-                    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
+    
+    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
+        
+        //存储扩展的群资料字段
+        CNGroupInfoExtendModel *groupInfoExtendModel = [[CNGroupInfoExtendFMDBManager manager] searchByGroupId:groupInfo.group];
+        
+        if (groupInfoExtendModel) {
+            //存在更新
+            if (groupInfo.selfInfo.recvOpt == TIM_GROUP_RECEIVE_NOT_NOTIFY_MESSAGE) {
+                if (groupInfoExtendModel.receiveMsg) {
+                    if (![groupInfoExtendModel.receiveMsg isEqualToString:@"1"]) {
+                        groupInfoExtendModel.receiveMsg = @"1";
                         [[CNGroupInfoExtendFMDBManager manager] updateData:groupInfoExtendModel succ:nil fail:nil];
-                    });
+                    }
                 }
+               
             }
-           
-        }
-    }
-    else
-    {
-        //不存在插入
-        CNGroupInfoExtendModel *groupInfoExtendModel = [[CNGroupInfoExtendModel alloc] init];
-        groupInfoExtendModel.groupId = groupId;
-        if (info.selfInfo.recvOpt == TIM_GROUP_RECEIVE_NOT_NOTIFY_MESSAGE) {
-            groupInfoExtendModel.receiveMsg = @"1";
         }
-        dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
+        else
+        {
+            //不存在插入
+            CNGroupInfoExtendModel *groupInfoExtendModel = [[CNGroupInfoExtendModel alloc] init];
+            groupInfoExtendModel.groupId = groupInfo.group;
+            if (groupInfo.selfInfo.recvOpt == TIM_GROUP_RECEIVE_NOT_NOTIFY_MESSAGE) {
+                groupInfoExtendModel.receiveMsg = @"1";
+            }
             [[CNGroupInfoExtendFMDBManager manager] insterData:groupInfoExtendModel succ:nil fail:nil];
-        });
-    }
+        }
+    });
+    
 }
 // 获取公开群
 - (NSMutableDictionary *)publicGroups
@@ -642,6 +642,10 @@
 {
     if (group)
     {
+        if(_groupList == nil)
+        {
+            _groupList = [[CLSafeMutableArray alloc] init];
+        }
         [_groupList addObject:group];
     }
 }