// // IMAConversationManager.m // TIMAdapter // // Created by AlexiChen on 16/2/18. // Copyright © 2016年 AlexiChen. All rights reserved. // #import "IMAConversationManager.h" @implementation IMAConversationChangedNotifyItem - (instancetype)initWith:(IMAConversationChangedNotifyType)type { if (self = [super init]) { _type = type; } return self; } - (NSNotification *)changedNotification { NSNotification *notify = [NSNotification notificationWithName:[self notificationName] object:self]; return notify; } - (NSString *)notificationName { return [NSString stringWithFormat:@"IMAConversationChangedNotification_%d", (int)_type]; } @end @implementation IMAConversationManager - (instancetype)init { if (self = [super init]) { _conversationList = [[CLSafeSetArray alloc] init]; } return self; } - (void)releaseChattingConversation { // [_chattingConversation releaseConversation]; _chattingConversation = nil; } - (void)asyncUpdateConversationListComplete { if (_refreshStyle == EIMARefresh_Wait) { dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{ // 说明有更新过来，再更新一次 [self asyncConversationList]; _refreshStyle = EIMARefresh_None; }); } else { _refreshStyle = EIMARefresh_None; [self updateOnLocalMsgComplete]; } } - (void)asyncUpdateConversationList { NSInteger unRead = 0; // NSMutableArray *conversationList = [NSMutableArray array]; //2.0之前的版本不支持 getConversationList 接口 NSArray *conversationList = [[TIMManager sharedInstance] getConversationList]; for (TIMConversation *conversation in conversationList) { IMAConversation *conv = nil; if ([conversation getType] == TIM_SYSTEM) { #if kSupportCustomConversation // 可能返回空 conv = [[IMACustomConversation alloc] initWith:conversation]; #else continue; #endif } else { conv = [[IMAConversation alloc] initWith:conversation]; } if (conv) { [_conversationList addObject:conv]; } if (_chattingConversation && [_chattingConversation isEqual:conv]) { [conv copyConversationInfo:_chattingConversation]; // 防止因中途在聊天时，出现onrefresh回调 _chattingConversation = conv; } else { if (conv) { unRead += [conversation getUnReadMessageNum]; } } } [self asyncUpdateConversationListComplete]; if (unRead != _unReadMessageCount) { self.unReadMessageCount = unRead; } DebugLog(@"==========>>>>>>>>>asyncUpdateConversationList Complete"); } - (void)asyncConversationList { DebugLog(@"==========>>>>>>>>>asyncConversationList"); // 因OnRefresh里面不定期有回调，能过这种处理，避免_conversationList修改导致界面Crash if (_refreshStyle == EIMARefresh_None) { _refreshStyle = EIMARefresh_ING; [self asyncUpdateConversationList]; } else { _refreshStyle = EIMARefresh_Wait; } } - (void)addConversationChangedObserver:(id)observer handler:(SEL)selector forEvent:(NSUInteger)eventID { NSUInteger op = EIMAContact_AddNewSubGroup; do { if (op & eventID) { NSString *notification = [NSString stringWithFormat:@"IMAConversationChangedNotification_%d", (int)op]; [[NSNotificationCenter defaultCenter] addObserver:observer selector:selector name:notification object:nil]; eventID -= op; } op = op << 1; } while (eventID > 0); } - (void)removeConversationChangedObser:(id)observer { [[NSNotificationCenter defaultCenter] removeObserver:observer]; } - (void)deleteConversation:(IMAConversation *)conv needUIRefresh:(BOOL)need { NSInteger index = [_conversationList indexOfObject:conv]; if (index >= 0 && index < [_conversationList count]) { [conv setReadAllMsg]; self.unReadMessageCount -= [conv unReadCount]; [_conversationList removeObject:conv]; if ([conv type] == TIM_C2C) { [[TIMManager sharedInstance] deleteConversation:[conv type] receiver:[conv receiver]]; } else if ([conv type] == TIM_GROUP) { [[TIMManager sharedInstance] deleteConversationAndMessages:[conv type] receiver:[conv receiver]]; } if (need) { [self updateOnDelete:conv atIndex:index]; } } } - (IMAConversation *)chatWith:(IMAUser *)user { TIMConversation *conv = nil; if ([user isC2CType]) { conv = [[TIMManager sharedInstance] getConversation:TIM_C2C receiver:[user userId]]; } else if([user isGroupType]) { conv = [[TIMManager sharedInstance] getConversation:TIM_GROUP receiver:[user userId]]; } else if ([user isSystemType]) { // 暂不支持System消息 return nil; } self.unReadMessageCount -= [conv getUnReadMessageNum]; // [conv setReadMessage]; [conv setReadMessage:nil succ:^{ } fail:^(int code, NSString *msg) { }]; if (conv) { IMAConversation *temp = [[IMAConversation alloc] initWith:conv]; NSInteger index = [_conversationList indexOfObject:temp]; if (index >= 0 && index < _conversationList.count) { IMAConversation *ret = [_conversationList objectAtIndex:index]; _chattingConversation = ret; // _chattingConversation.lastMessage = _chattingConversation.lastMessage; return ret; } _chattingConversation = temp; return temp; } return nil; } // 主用要于自定义类型 - (IMAConversation *)queryConversationWithType:(IMAConType)user { // for (NSInteger i = 0; i < [_conversationList count]; i++) // { // IMAConversation *conv = [_conversationList objectAtIndex:i]; // if ([conv isChatWith:user]) // { // return conv; // } // } return nil; } - (IMAConversation *)queryConversationWith:(IMAUser *)user { if (user) { for (NSInteger i = 0; i < [_conversationList count]; i++) { IMAConversation *conv = [_conversationList objectAtIndex:i]; if ([conv isChatWith:user]) { return conv; } } } return nil; } - (void)removeConversationWith:(IMAUser *)user { for (NSInteger i = 0; i < [_conversationList count]; i++) { V2TIMConversation *conv = [_conversationList objectAtIndex:i]; if ([conv.userID isEqualToString:user.userId] || [conv.groupID isEqualToString:user.userId]) { if (conv == _chattingConversation) { // TODO:通知界面 [[AppDelegate sharedAppDelegate] popToRootViewController]; } [_conversationList removeObjectAtIndex:i]; // self.unReadMessageCount -= [conv unReadCount]; self.unReadMessageCount -= [conv unreadCount]; // if ([conv type] == TIM_C2C) // { [[V2TIMManager sharedInstance] deleteConversation:conv.userID succ:^{ } fail:^(int code, NSString *desc) { }]; // [[TIMManager sharedInstance] deleteConversation:[conv type] receiver:[conv receiver]]; // } // else if ([conv type] == TIM_GROUP) // { // [[TIMManager sharedInstance] deleteConversationAndMessages:[conv type] receiver:[conv receiver]]; // } [self updateOnDelete:conv atIndex:i]; break; } } } //- (void)removeConversationWithConv:(IMAConversation *)conv //{ // if (conv == nil) // { // return; // } // [[TIMManager sharedInstance] deleteConversation:[conv type] receiver:[conv receiver]]; //} - (void)updateConversationWith:(IMAUser *)user { IMAConversation *conv = [self queryConversationWith:user]; if (conv) { [self updateOnConversationChanged:conv]; } } - (NSInteger)insertPosition { IMAPlatform *mp = [IMAPlatform sharedInstance]; if (!mp.isConnected) { return 1; } return 0; } //消息撤回通知 - (void)onRevokeMessage:(TIMMessageLocator*)locator { [[NSNotificationCenter defaultCenter] postNotificationName:kIMAMSG_RevokeNotification object:locator]; [self changeLastMsg:locator]; } //判断撤销的是不是最后一条消息，如果是，则最近回话列表中的显示，需要改成“xxx撤销了一条消息” - (void)changeLastMsg:(TIMMessageLocator*)locator { for (int i = 0; i < [_conversationList count]; i++) { IMAConversation *imaconv = [_conversationList objectAtIndex:i]; if ([imaconv.lastMessage.msg respondsToLocator:locator]) { IMAMsg *imamsg = [IMAMsg msgWithRevoked:imaconv.lastMessage.msg.sender]; imaconv.lastMessage = imamsg; } } } /** * 新消息通知 * * @param msgs 新消息列表，TIMMessage 类型数组 */ - (void)onNewMessage:(NSArray *)msgs { for (TIMMessage *msg in msgs) { IMAMsg *imamsg = [IMAMsg msgWith:msg]; TIMConversation *conv = [msg getConversation]; BOOL isSystemMsg = [conv getType] == TIM_SYSTEM; BOOL isAddGroupReq = NO; BOOL isAddFriendReq = NO; BOOL isContinue = YES; if (isSystemMsg) { int elemCount = [msg elemCount]; for (int i = 0; i < elemCount; i++) { TIMElem* elem = [msg getElem:i]; if ([elem isKindOfClass:[TIMGroupSystemElem class]]) { TIMGroupSystemElem *gse = (TIMGroupSystemElem *)elem; if (gse.type == TIM_GROUP_SYSTEM_ADD_GROUP_REQUEST_TYPE) { isContinue = NO; isAddGroupReq = YES; } } else if ([elem isKindOfClass:[TIMSNSSystemElem class]]) { TIM_SNS_SYSTEM_TYPE type = ((TIMSNSSystemElem *)elem).type; if (type == TIM_SNS_SYSTEM_ADD_FRIEND_REQ) { if (!msg.isSelf) { isContinue = NO; isAddFriendReq = YES; } } } } if (isContinue) { continue; } } BOOL updateSucc = NO; for (int i = 0; i < [_conversationList count]; i++) { IMAConversation *imaconv = [_conversationList objectAtIndex:i]; NSString *imaconvReceiver = [imaconv receiver]; if (imaconv.type == [conv getType] && ([imaconvReceiver isEqualToString:[conv getReceiver]] || [imaconvReceiver isEqualToString:[IMACustomConversation getCustomConversationID:imamsg]])) { if (imaconv == _chattingConversation) { //如果是c2c会话，则更新“对方正在输入...”状态 BOOL isInputStatus = NO; if (!msg.isSelf) { // if ([_chattingConversation imaType] == TIM_C2C) // { // int elemCount = [imamsg.msg elemCount]; // for (int i = 0; i < elemCount; i++) // { // TIMElem* elem = [msg getElem:i]; // CustomElemCmd *elemCmd = [self isOnlineMsg:elem]; // // if (elemCmd) // { // isInputStatus = YES; // //[[NSNotificationCenter defaultCenter] postNotificationName:kUserInputStatus object:elemCmd]; // } // } // } // // if (!isInputStatus) // { //// [conv setReadMessage]; // imaconv.lastMessage = imamsg; // [_chattingConversation onReceiveNewMessage:imamsg]; // } } } else { TIMElem* elem = [msg getElem:0]; CustomElemCmd *elemCmd = [self isOnlineMsg:elem]; if ([elem isKindOfClass:[TIMCustomElem class]]) { TIMCustomElem *elemcd = (TIMCustomElem *)elem; NSString *dataStr = [[NSString alloc] initWithData:elemcd.data encoding:NSUTF8StringEncoding]; NSDictionary *dic = [dataStr objectFromJSONString]; CustomMessageModel *customMessageModel = [CustomMessageModel mj_objectWithKeyValues:dic]; NSLog(@"收到广播消息%d",customMessageModel.type); BGTabBarController *tabBar = [BGTabBarController sharedInstance]; UITabBarItem *item = [tabBar .tabBar.items objectAtIndex:3]; if (customMessageModel.type == MSG_RECEIVE_GUILD_REFRESH_TYPE) { NSLog(@"收到消息"); [[NSNotificationCenter defaultCenter]postNotificationName:@"RECEIVE_GUILD_REFRESH_TYPE" object:nil]; } if (customMessageModel.type == MSG_RECEIVE_BROADCAST || customMessageModel.type == MSG_OPEN_VIP_TYPE || customMessageModel.type == MSG_OPEN_GUARD_SUCCESS) { if (customMessageModel.sender.guardian_broadcast.integerValue != 0) { [[BGIMMsgHandler sharedInstance]showGlobalViewWithModel:customMessageModel]; } }else if(customMessageModel.type == MSG_PRIVATE_TEXT ||customMessageModel.type == MSG_PRIVATE_VOICE ||customMessageModel.type == MSG_PRIVATE_IMAGE ||customMessageModel.type == MSG_PRIVATE_GIFT){ // [AppDelegate sharedAppDelegate].entertabBar. item.badgeValue = [NSString stringWithFormat:@"%d", [item.badgeValue intValue] + 1]; } } if (!elemCmd) { imaconv.lastMessage = imamsg; if (isSystemMsg) { __weak IMAConversationManager *ws = self; // 系统消息 IMACustomConversation *customConv = (IMACustomConversation *)imaconv; [customConv saveMessage:imamsg succ:^(int newUnRead) { ws.unReadMessageCount += newUnRead; [ws updateOnChat:imaconv moveFromIndex:i]; }]; } else { //如果是自己发出去的消息，一定是已读(这里判断主要是用在多终端登录的情况下) if (![imamsg isMineMsg]) { self.unReadMessageCount++; } [self updateOnChat:imaconv moveFromIndex:i]; } } } updateSucc = YES; break; } } if (!updateSucc && _refreshStyle == EIMARefresh_None) { if (isSystemMsg) { NSString *receiverid = [IMACustomConversation getCustomConversationID:imamsg]; TIMConversation *imconv = [[TIMManager sharedInstance] getConversation:TIM_SYSTEM receiver:receiverid]; [imconv setReadMessage:nil succ:^{ } fail:^(int code, NSString *msg) { }]; // 说明会话列表中没有该会话，新生建会话，并更新到 IMACustomConversation *temp = [[IMACustomConversation alloc] initWith:imconv andMsg:imamsg]; if (temp) { __weak IMAConversationManager *ws = self; [temp saveMessage:imamsg succ:^(int newUnRead) { ws.unReadMessageCount += newUnRead; }]; [_conversationList insertObject:temp atIndex:[self insertPosition]]; [self updateOnNewConversation:temp]; } } else { // 说明会话列表中没有该会话，新生建会话，并更新到 IMAConversation *temp = [[IMAConversation alloc] initWith:conv]; temp.lastMessage = imamsg; [_conversationList insertObject:temp atIndex:[self insertPosition]]; self.unReadMessageCount++; [self updateOnNewConversation:temp]; } } } } - (CustomElemCmd *)isOnlineMsg:(TIMElem *) elem { if ([elem isKindOfClass:[TIMCustomElem class]]) { CustomElemCmd *elemCmd = [CustomElemCmd parseCustom:(TIMCustomElem *)elem]; if (elemCmd) { return elemCmd; } } return nil; } //申请加群请求 - (void)onAddGroupRequest:(TIMGroupSystemElem *)item { // IMAGroup *tempGroup = [[IMAGroup alloc] initWith:item.group]; // IMAGroup *group = (IMAGroup *)[[IMAPlatform sharedInstance].contactMgr isContainUser:tempGroup]; // NSString *message = [NSString stringWithFormat:ASLocalizedString(@"%@申请加入群:%@\n申请理由:%@"), item.user, group.groupInfo.groupName, item.msg]; // // UIAlertView *alert = [UIAlertView bk_showAlertViewWithTitle:ASLocalizedString(@"加群申请")message:message cancelButtonTitle:ASLocalizedString(@"忽略")otherButtonTitles:@[ASLocalizedString(@"同意"),ASLocalizedString(@"拒绝")] handler:^(UIAlertView *alertView, NSInteger buttonIndex) { // if (buttonIndex == 1)//同意 // { // [[IMAPlatform sharedInstance] asyncAcceptAddGroup:item succ:^{ // // } fail:nil]; // } // else if (buttonIndex == 2)//拒绝 // { // [[IMAPlatform sharedInstance] asyncRefuseAddGroup:item succ:^{ // // } fail:nil]; // } // }]; // [alert show]; } - (void)onAddFreindRequest:(TIMSNSSystemElem *)elem { } @end @implementation IMAConversationManager (Protected) - (void)onConnect { // 删除 IMAConnectConversation *conv = [[IMAConnectConversation alloc] init]; NSInteger index = [_conversationList indexOfObject:conv]; if (index >= 0 && index < [_conversationList count]) { [_conversationList removeObject:conv]; [self updateOnDelete:conv atIndex:index]; } } - (void)onDisConnect { // 插入一个网络断开的fake conversation IMAConnectConversation *conv = [[IMAConnectConversation alloc] init]; NSInteger index = [_conversationList indexOfObject:conv]; if (!(index >= 0 && index < [_conversationList count])) { [_conversationList insertObject:conv atIndex:0]; [self updateOnNewConversation:conv]; } } - (void)updateOnChat:(IMAConversation *)conv moveFromIndex:(NSUInteger)index { NSInteger toindex = [self insertPosition]; if (index != toindex) { [_conversationList removeObjectAtIndex:index]; [_conversationList insertObject:conv atIndex:toindex]; // 更新界面 IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_BecomeActiveTop]; item.conversation = conv; item.index = index; item.toIndex = toindex; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } } - (void)updateOnDelete:(IMAConversation *)conv atIndex:(NSUInteger)index { // 更新界面 IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_DeleteConversation]; item.conversation = conv; item.index = index; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } - (void)updateOnAsyncLoadContactComplete { // 通知更新界面 IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_SyncLocalConversation]; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } - (void)updateOnLocalMsgComplete { // 更新界面 IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_SyncLocalConversation]; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } - (void)updateOnLastMessageChanged:(IMAConversation *)conv { if ([_chattingConversation isEqual:conv]) { NSInteger index = [_conversationList indexOfObject:conv]; NSInteger toindex = [self insertPosition]; if (index > 0 && index < [_conversationList count]) { [_conversationList removeObject:conv]; [_conversationList insertObject:conv atIndex:toindex]; [self updateOnChat:conv moveFromIndex:index toIndex:toindex]; } else if (index < 0 || index > [_conversationList count]) { [_conversationList insertObject:conv atIndex:[self insertPosition]]; [self updateOnNewConversation:conv]; } else { // index == 0 不作处理 } } } - (void)updateOnChat:(IMAConversation *)conv moveFromIndex:(NSUInteger)index toIndex:(NSInteger)toIdx { // 更新界面 IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_BecomeActiveTop]; item.conversation = conv; item.index = index; item.toIndex = toIdx; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } - (void)updateOnNewConversation:(IMAConversation *)conv { // 更新界面 IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_NewConversation]; item.conversation = conv; item.index = [_conversationList indexOfObject:conv]; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } - (void)updateOnConversationChanged:(IMAConversation *)conv { IMAConversationChangedNotifyItem *item = [[IMAConversationChangedNotifyItem alloc] initWith:EIMAConversation_ConversationChanged]; item.conversation = conv; item.index = [_conversationList indexOfObject:conv]; if (_conversationChangedCompletion) { _conversationChangedCompletion(item); } [[NSNotificationQueue defaultQueue] enqueueNotification:[item changedNotification] postingStyle:NSPostWhenIdle]; } @end