yinmeng-ios/xplan-ios/Main/Room/View/MessageContainerView/XPRoomMessageContainerView.m

//
//  XPRoomMessageView.m
//  xplan-ios
//
//  Created by 冯硕 on 2021/10/11.
//

#import "XPRoomMessageContainerView.h"
///Third
#import <Masonry/Masonry.h>
#import <NIMSDK/NIMSDK.h>
#import <YYText/YYText.h>
///Tool
#import "ThemeColor.h"
#import "XPMacro.h"
#import "XPRoomMessageConstant.h"
#import "XPRoomMessageParser.h"
#import "AccountInfoStorage.h"
#import "XPRoomMiniManager.h"
#import "PLTimeUtil.h"
#import "ClientConfig.h"
#import <POP.h>
#import "ThemeColor+Room.h"
///Model
#import "RoomInfoModel.h"
#import "AttachmentModel.h"
#import "RoomFaceSendInfoModel.h"
#import "XPMessageRemoteExtModel.h"
#import "RoomPKChooseUserModel.h"
#import "CandyTreeResultModel.h"
#import "RoomSailingPrizeModel.h"
#import "UserInfoModel.h"
///View
#import "XPRoomMessageTableViewCell.h"
#import "XPRoomMessageHeaderView.h"
#import "View/XPRoomMessageHeaderView.h"

NSString * const kRoomShowTopicKey = @"kRoomShowTopicKey";

@interface XPRoomMessageContainerView ()<UITableViewDelegate, UITableViewDataSource, XPRoomMessageTableViewCellDelegate, UIGestureRecognizerDelegate>
///房间的代理
@property (nonatomic,weak) id<RoomHostDelegate> hostDelegate;

///列表
@property (nonatomic,strong) UITableView *messageTableView;
///头部
@property (nonatomic,strong) XPRoomMessageHeaderView *headerView;
///底部有新的消息
@property (nonatomic,strong) UIButton *messageTipsBtn;
///有人at你
@property (nonatomic, strong) UIButton *atTipBtn;
///是否处于正在爬楼
@property (nonatomic,assign) BOOL isPending;
///是否是最小化进房的
@property (nonatomic,assign) BOOL isMiniEnter;
///数据源
@property (nonatomic,strong) NSMutableArray<NSAttributedString *> *datasource;
///临时存放消息的数组
@property (nonatomic,strong) NSMutableArray<NIMMessage *> *incomingMessages;
///气泡数组
@property (nonatomic, strong) NSMutableArray *messageBubbles;
///有多少人at我
@property (nonatomic, assign) NSInteger atCount;
///@我的消息位置集合
@property (nonatomic, strong) NSMutableArray *locationArray;
///messageView 持有这个工具类 进行数据的分发操作 TODO:  有需要在改
@property (nonatomic,strong) XPRoomMessageParser *messageParser;
///是否是大的  只有在小游戏的时候有用
@property (nonatomic,assign) BOOL isLarge;
@end


@implementation XPRoomMessageContainerView

- (void)dealloc {
	[[NSNotificationCenter defaultCenter] removeObserver:self];
}

- (instancetype)initWithDelegate:(id<RoomHostDelegate>)delegate {
	self = [super init];
	if (self) {
		self.hostDelegate = delegate;
		[self initSubViews];
		[self initSubViewConstraints];
	}
	return self;
}

#pragma mark - Response
- (void)messageTipsBtnAction:(UIButton *)sender {
    self.isPending = NO;
    self.messageTipsBtn.hidden = YES;
    [self appendAndScrollToBottom];
}

- (void)atTipsBtnAction:(UIButton *)sender {
    self.isPending = YES;
    [self appendAndScrollToAtUser];
}

///追加数据源
- (void)appendAndScrollToAtUser {
    if (self.incomingMessages.count < 1) {
        NSInteger rows = self.datasource.count;
        if (!self.locationArray.count) {
            [self.messageTableView scrollToRowAtIndexPath:[NSIndexPath indexPathForRow:(rows-1) inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];
            self.messageTipsBtn.hidden = YES;
            self.isPending = NO;
            self.atCount = 0;
            self.atTipBtn.hidden = YES;
            return;
        }
        int index = [self.locationArray[0] intValue];
        NSIndexPath *indexPath = [NSIndexPath indexPathForRow:index inSection:0];
        if (rows > indexPath.row) {
            [self.messageTableView scrollToRowAtIndexPath:indexPath atScrollPosition:UITableViewScrollPositionBottom animated:YES];
            if (rows == indexPath.row + 1) {
                self.messageTipsBtn.hidden = YES;
                self.isPending = NO;
            }
        } else {
            [self.messageTableView scrollToRowAtIndexPath:[NSIndexPath indexPathForRow:(rows-1) inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];
            //滚动到底部时隐藏@提示
            self.messageTipsBtn.hidden = YES;
        }
        if (self.locationArray.count) {
            [self.locationArray removeObjectAtIndex:0];
            self.atCount -= 1;
            [self.atTipBtn setTitle:[NSString stringWithFormat:@"有%lu人@你", (unsigned long)self.locationArray.count] forState:UIControlStateNormal];
            if (self.locationArray.count == 0) {
                self.atTipBtn.hidden = YES;
            }
        } else {
            self.atTipBtn.hidden = YES;
        }
    } else {
        if (self.datasource.count > kRoomMessageMaxLength) {
            NSIndexSet *set = [NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, kRoomMessageMaxLength/2)];
            NSArray *needRemoveMsgArray = [self.datasource objectsAtIndexes:set];
            [self.datasource removeObjectsInArray:needRemoveMsgArray];
            [self.messageBubbles removeObjectsAtIndexes:set];
            NSMutableIndexSet *indexSet = [NSMutableIndexSet indexSet];
            for (int i = 0; i<self.locationArray.count; i++) {///移除掉前面消息的数据后，前面如果有at我的消息，也一并移除掉
                NSNumber *number = self.locationArray[i];
                if (number.integerValue < kRoomMessageMaxLength / 2) {
                    self.atCount--;
                    [indexSet addIndex:i];
                }
            }
            [self.locationArray removeObjectsAtIndexes:indexSet];
            for (int i = 0; i<self.locationArray.count; i++) {//移除前面的at消息后,后面的at消息需要更新索引
                NSNumber *number = self.locationArray[i];
                number = @(number.integerValue - kRoomMessageMaxLength / 2);
                [self.locationArray replaceObjectAtIndex:i withObject:number];
            }
        }
        
        // 执行插入
        NSMutableArray *indexPaths = [NSMutableArray array];
        for (NIMMessage *item in self.incomingMessages) {
            [self.datasource addObject:[self.messageParser parseMessageAttribute:item]];
            [self.messageBubbles addObject:[self.messageParser parseMessageBubble:item]];
            [indexPaths addObject:[NSIndexPath indexPathForRow:self.datasource.count - 1 inSection:0]];
            id nickNameNifo = item.remoteExt[@"atUids"];
            if ([nickNameNifo isKindOfClass:[NSArray class]]) {
                for (NSString *nick in nickNameNifo) {
                    if ([nick isEqualToString:[AccountInfoStorage instance].getUid]) {
                        [self.locationArray addObject:@(self.datasource.count-1)];
                    }
                }
            }
        }
        [self.incomingMessages removeAllObjects];
        [self.messageTableView reloadData];
        
        NSInteger rows = self.datasource.count;
        if (!self.locationArray.count) {
            [self.messageTableView scrollToRowAtIndexPath:[NSIndexPath indexPathForRow:(rows-1) inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];
            self.messageTipsBtn.hidden = YES;
            self.isPending = NO;
            self.atCount = 0;
            self.atTipBtn.hidden = YES;
            return;
        }
        int index = [self.locationArray[0] intValue];
        NSIndexPath *indexPath = [NSIndexPath indexPathForRow:index inSection:0];
        if (rows > indexPath.row) {
            [self.messageTableView scrollToRowAtIndexPath:indexPath atScrollPosition:UITableViewScrollPositionBottom animated:YES];
            if (rows == indexPath.row + 1) {
                self.messageTipsBtn.hidden = YES;
                self.isPending = NO;
            }
        } else {
            [self.messageTableView scrollToRowAtIndexPath:[NSIndexPath indexPathForRow:(rows-1) inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];
            //滚动到底部时隐藏@提示
            self.messageTipsBtn.hidden = YES;
        }
        if (self.locationArray.count) {
            [self.locationArray removeObjectAtIndex:0];
            self.atCount -= 1;
            [self.atTipBtn setTitle:[NSString stringWithFormat:@"有%lu人@你", (unsigned long)self.locationArray.count] forState:UIControlStateNormal];
            if (self.locationArray.count == 0) {
                self.atTipBtn.hidden = YES;
            }
        } else {
            self.atTipBtn.hidden = YES;
        }
    }
}

#pragma mark - @我
///查找有多少人@我
- (void)findAtMeNumber {
    if (self.incomingMessages.count) {
        NIMMessage *message = self.incomingMessages.lastObject;
        id nickNameNifo = message.remoteExt[@"atUids"];
        if ([nickNameNifo isKindOfClass:[NSArray class]]) {
            for (NSString *nick in nickNameNifo) {
                if ([nick isEqualToString:[AccountInfoStorage instance].getUid]) {
                    self.atCount += 1;
                }
            }
        }
        if (self.atCount > 0) {
            self.atTipBtn.hidden = NO;
            [self.atTipBtn setTitle:[NSString stringWithFormat:@"有%zd人@你", self.atCount] forState:UIControlStateNormal];
        } else {
            self.atTipBtn.hidden = YES;
        }
    }
}

#pragma mark - Private Method
- (void)initSubViews {
	[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(addCustomMessage:) name:@"message" object:nil];
	[self addSubview:self.messageTableView];
	[self addSubview:self.messageTipsBtn];
    [self addSubview:self.atTipBtn];
	self.messageTableView.tableHeaderView = self.headerView;
}

- (void)initSubViewConstraints {
	[self.messageTableView mas_makeConstraints:^(MASConstraintMaker *make) {
		make.left.mas_equalTo(self).offset(15);
		make.bottom.right.mas_equalTo(self);
        make.top.mas_equalTo(self);
	}];
	
	[self.messageTipsBtn mas_makeConstraints:^(MASConstraintMaker *make) {
		make.width.mas_equalTo(100);
		make.height.mas_equalTo(30);
		make.bottom.mas_equalTo(self.mas_bottom).offset(-5);
		make.left.mas_equalTo(self);
	}];
    [self.atTipBtn mas_makeConstraints:^(MASConstraintMaker *make) {
        make.width.mas_equalTo(100);
        make.height.mas_equalTo(30);
        make.bottom.mas_equalTo(self.mas_bottom).offset(-5);
        make.left.mas_equalTo(self);
    }];
}

///是否是当前房间
- (BOOL)isCurrentRoom:(NSString *)sessionId {
	if ([sessionId isEqualToString:[NSString stringWithFormat:@"%ld", self.hostDelegate.getRoomInfo.roomId]]) {
		return YES;
	}
	return NO;
}

///判断是否隐身进房
- (BOOL)handleHideEnter:(NIMMessage *)message {
    NIMMessageChatroomExtension * messageExt = (NIMMessageChatroomExtension *)message.messageExt;
    NSDictionary * dic = [(NSDictionary *)messageExt.roomExt.toJSONObject objectForKey:message.from];
    XPMessageRemoteExtModel * extModel = [XPMessageRemoteExtModel modelWithJSON:dic];
    return extModel.enterHide;
}

#pragma mark - 添加数据并且做自动滚动
///添加信息
- (void)addRoomMessage:(NIMMessage *)message {
	[self.incomingMessages addObject:message];
	if (!self.isMiniEnter) {/// 最小化进房的话 不需要重新保存
		if (self.hostDelegate.getRoomInfo.isCloseScreen) {
			NIMCustomObject *obj = (NIMCustomObject *)message.messageObject;
			if (obj.attachment != nil && [obj.attachment isKindOfClass:[AttachmentModel class]]) {
				AttachmentModel *attachment = (AttachmentModel *)obj.attachment;
				if (attachment.first == CustomMessageType_Update_RoomInfo && attachment.second == Custom_Message_Sub_Update_RoomInfo_MessageState){
					[[XPRoomMiniManager shareManager] saveRoomMessage:message];
				}
			}
		} else {
			[[XPRoomMiniManager shareManager] saveRoomMessage:message];
		}
	}
    if (self.isPending) {
        self.messageTipsBtn.hidden = NO;
        [self findAtMeNumber];
    } else {
        [self appendAndScrollToBottom];
    }
}

///追加数据源
- (void)appendAndScrollToBottom {
	if (self.incomingMessages.count < 1) {
        ///滚动到底部（如果有人at自己后，income消息在点击at按钮处做了拼接处理，因为点击at按钮跳转到的是对应的at人消息，如果后面有其他消息时，点有更多按钮时需要滚动到最底部）
        [self scrollToBottom:YES];
		return;
	}
	
	if (self.datasource.count > kRoomMessageMaxLength) {
		NSIndexSet *set = [NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, kRoomMessageMaxLength/2)];
		NSArray *needRemoveMsgArray = [self.datasource objectsAtIndexes:set];
		[self.datasource removeObjectsInArray:needRemoveMsgArray];
        [self.messageBubbles removeObjectsAtIndexes:set];
	}
	
	// 执行插入
	NSMutableArray *indexPaths = [NSMutableArray array];
	for (NIMMessage *item in self.incomingMessages) {
		[self.datasource addObject:[self.messageParser parseMessageAttribute:item]];
        [self.messageBubbles addObject:[self.messageParser parseMessageBubble:item]];
		[indexPaths addObject:[NSIndexPath indexPathForRow:self.datasource.count - 1 inSection:0]];
	}
    [self.incomingMessages removeAllObjects];
	[self.messageTableView reloadData];
	
	//执行插入动画并滚动
	[self scrollToBottom:YES];
}

///执行插入动画并滚动
- (void)scrollToBottom:(BOOL)animated {
	NSInteger s = [self.messageTableView numberOfSections];  //有多少组
	if (s<1) return;
	NSInteger r = [self.messageTableView numberOfRowsInSection:s-1]; //最后一组行
	if (r<1) return;
	NSIndexPath *ip = [NSIndexPath indexPathForRow:r-1 inSection:s-1];  //取最后一行数据
	[self.messageTableView scrollToRowAtIndexPath:ip atScrollPosition:UITableViewScrollPositionBottom animated:animated]; //滚动到最后一行
    self.atCount = 0;
    self.atTipBtn.hidden = YES;
    [self.locationArray removeAllObjects];
}

///自定义消息 是否可以加到 公屏 需要自己维护
- (BOOL)isCanDisplayMessage:(NIMMessage *)message {
	NIMCustomObject *obj = (NIMCustomObject *)message.messageObject;
	if (obj.attachment != nil && [obj.attachment isKindOfClass:[AttachmentModel class]]) {
		AttachmentModel *attachment = (AttachmentModel *)obj.attachment;
		if (attachment.first == CustomMessageType_Face && attachment.second == Custom_Message_Sub_Face_Send) {
			if ([attachment.data[@"data"] isKindOfClass:[NSArray class]]) {
				NSArray * array = [RoomFaceSendInfoModel modelsWithArray:attachment.data[@"data"]];
				for (int i = 0; i< array.count; i++) {
					RoomFaceSendInfoModel * sendInfo = [array objectAtIndex:i];
					if (sendInfo.resultIndexes.count <=0) {
						return NO;
					}
				}
			}
		}else if (attachment.first == CustomMessageType_Room_PK && attachment.second == Custom_Message_Sub_Room_PK_Manager_Up_Mic) {
			if (attachment.data && [attachment.data allKeys].count > 0) {
				for (NSDictionary * dic in [attachment.data allValues]) {
					RoomPKChooseUserModel * userModel = [RoomPKChooseUserModel modelWithDictionary:dic];
					if (userModel.groupType == GroupType_Red || userModel.groupType == GroupType_Blue) {
						return YES;
					}
				}
			}
			return NO;
		} else if(attachment.first == CustomMessageType_Room_Sailing && (attachment.second == Custom_Message_Sub_Sailing_AllRoom_Notify ||  attachment.second == Custom_Message_Sub_Sailing_InRoom_NeedAllMicSend)) {
			RoomSailingPrizeModel * prizeModel = [RoomSailingPrizeModel modelWithDictionary:attachment.data];
			if (self.hostDelegate.getUserInfo.userLevelVo.experLevelSeq > prizeModel.userLevelLimit) {
				return YES;
			}
		}
		return  [[[self supportMessageDic] objectForKey:@(attachment.first)] containsObject:@(attachment.second)];
	}
	return NO;
}

- (NSDictionary *)supportMessageDic {
	return @{
		@(CustomMessageType_AllMicroSend):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_AllMicroSend),
			 @(Custom_Message_Sub_AllMicroLuckySend),
			 @(Custom_Message_Sub_AllBatchSend),
			 @(Custom_Message_Sub_AllBatchMicroLuckySend),
			 nil],
		@(CustomMessageType_Gift):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Gift_Send),
			 @(Custom_Message_Sub_Gift_LuckySend),
			 nil],
		@(CustomMessageType_Room_Tip):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Room_Tip_ShareRoom),
			 @(Custom_Message_Sub_Room_Tip_Attention_Owner),
			 nil],
		@(CustomMessageType_Kick_User):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Kick_BeKicked),
			 @(Custom_Message_Sub_Kick_BlackList),
			 nil],
		@(CustomMessageType_Queue):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Queue_Kick),
			 nil],
		@(CustomMessageType_Candy_Tree):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Candy_Tree_Me),
			 @(Custom_Message_Sub_Candy_Tree_InRoom),
			 @(Custom_Message_Sub_Candy_Tree_AllRoom),
			 @(Custom_Message_Sub_Candy_Tree_AllRoom_Notify),
			 @(Custom_Message_Sub_Candy_Tree_InRoom_NeedAllMicSend),
			 nil],
		@(CustomMessageType_Arrange_Mic):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Arrange_Mic_Mode_Open),
			 @(Custom_Message_Sub_Arrange_Mic_Mode_Close),
			 @(Custom_Message_Sub_Arrange_Mic_Free_Mic_Open),
			 @(Custom_Message_Sub_Arrange_Mic_Free_Mic_Close),
			 nil],
		@(CustomMessageType_Update_RoomInfo):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Update_RoomInfo_MessageState),
			 @(Custom_Message_Sub_Update_RoomInfo_AnimateEffect),
			 nil],
		@(CustomMessageType_Collection_Room):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Collect_Room_Tips),
			 nil],
		@(CustomMessageType_RoomPlay_Dating):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Room_Play_Dating_Pick_Heart),
			 @(Custom_Message_Sub_Room_Play_Dating_Result_Mutual),
			 @(Custom_Message_Sub_Room_Play_Dating_Result_Not_Mutual),
			 nil],
        @(CustomMessageType_Noble_VIP):
            [NSSet setWithObjects:
             @(Custom_Message_Sub_Room_Open_Noble_VIP),
             @(Custom_Message_Sub_Room_Noble_LevelUp),
             @(Custom_Message_Sub_AllRoom_Noble_LevelUp_Suspend),
             nil],
		@(CustomMessageType_Face):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Face_Send),
			 nil],
       @(CustomMessageType_Anchor_FansTeam):
           [NSSet setWithObjects:
            @(Custom_Message_Sub_FansTeam_Open_Success),
            @(Custom_Message_Sub_FansTeam_Open_Fail),
            @(Custom_Message_Sub_FansTeam_Join_Success),
            @(Custom_Message_Sub_FansTeam_Out_Success),
           nil],
		@(CustomMessageType_Hall_Super_Admin):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Hall_Super_Admin_Kick_Manager_Out_Room),
			 nil],
		@(CustomMessageType_Room_PK):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Room_PK_Manager_Up_Mic),
			 @(Custom_Message_Sub_Room_PK_Mode_Close),
			 @(Custom_Message_Sub_Room_PK_Result),
			 @(Custom_Message_Sub_Room_PK_Mode_Open),
			 @(Custom_Message_Sub_Room_PK_Start),
			 @(Custom_Message_Sub_Room_PK_Re_Start),
			 nil],
		@(CustomMessageType_LuckyBag):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Room_Gift_LuckBag_Server),
			 nil],
        @(CustomMessageType_Gift_Compound):
            [NSSet setWithObjects:@(Custom_Message_Sub_Gift_Compound),
             nil],
		@(CustomMessageType_Room_Sailing):
			[NSSet setWithObjects:
			 @(Custom_Message_Sub_Sailing_Me),
			 @(Custom_Message_Sub_Sailing_InRoom),
			 @(Custom_Message_Sub_Sailing_AllRoom),
			 @(Custom_Message_Sub_Sailing_AllRoom_Notify),
			 @(Custom_Message_Sub_Sailing_InRoom_NeedAllMicSend),
			 nil]
	};
}

- (void)addCustomMessage:(NSNotification *)notification {
	self.isMiniEnter = NO;
	if (self.hostDelegate.getRoomInfo.isCloseScreen) {return;}
	NIMMessage * message = notification.object;
	[self addRoomMessage:message];
}

///用户进入房间显示 房间话题
- (void)createUserEnterRoomAddRoomtopicMessage {
	if ([ClientConfig shareConfig].configInfo.appStoreAuditNoticeVersion == YES) {
		return;
	}
	RoomInfoModel * roomInfo = self.hostDelegate.getRoomInfo;
	if (roomInfo.uid == [AccountInfoStorage instance].getUid.integerValue) {return;}
	NSString * key = [NSString stringWithFormat:@"%@_%@_%ld", kRoomShowTopicKey, [AccountInfoStorage instance].getUid, roomInfo.uid];
	NSDate * oldDate = [[NSUserDefaults standardUserDefaults] valueForKey:key];
	NSDate * date = [NSDate date];
	if (roomInfo.introduction.length > 0) {
		if (oldDate) {
			NSDateComponents *compons = [PLTimeUtil compareTwoDate:date secondDate:[NSDate date]];
			if (ABS(compons.year) > 0 || ABS(compons.month) > 0 || ABS(compons.day) > 0) {
				NIMMessage * message = [[NIMMessage alloc] init];
				NSString * content = [NSString stringWithFormat:@"[房间公告] \n %@", roomInfo.introduction];
				message.text = content;
				message.localExt = @{@"isRoomTopic": @(NO)};
				[message setValue:@(NIMMessageTypeTip) forKey:@"messageType"];
				[message setValue:[NIMSession session:[NSString stringWithFormat:@"%ld", roomInfo.roomId] type:NIMSessionTypeChatroom] forKey:@"session"];
				[self addRoomMessage:message];
				
				[[NSUserDefaults standardUserDefaults] setValue:@(YES) forKey:key];
				[[NSUserDefaults standardUserDefaults] synchronize];
			}
		} else {
			NIMMessage * message = [[NIMMessage alloc] init];
			NSString * content = [NSString stringWithFormat:@"[房间公告] \n %@", roomInfo.introduction];
			message.text = content;
			message.localExt = @{@"isRoomTopic": @(NO)};
			[message setValue:@(NIMMessageTypeTip) forKey:@"messageType"];
			[message setValue:[NIMSession session:[NSString stringWithFormat:@"%ld", roomInfo.roomId] type:NIMSessionTypeChatroom] forKey:@"session"];
			[self addRoomMessage:message];
			
			[[NSUserDefaults standardUserDefaults] setValue:@(YES) forKey:key];
			[[NSUserDefaults standardUserDefaults] synchronize];
		}
	}
	
	NIMMessage * message = [[NIMMessage alloc] init];
	message.text = @"可点击查看本房间公告";
	message.localExt = @{@"isRoomTopic": @(YES)};
	[message setValue:@(NIMMessageTypeTip) forKey:@"messageType"];
	[message setValue:[NIMSession session:[NSString stringWithFormat:@"%ld", roomInfo.roomId] type:NIMSessionTypeChatroom] forKey:@"session"];
	[self addRoomMessage:message];
}

#pragma mark - RoomGuestDelegate
- (void)handleNIMCustomMessage:(NIMMessage *)message {
	self.isMiniEnter = NO;
	NIMCustomObject *obj = (NIMCustomObject *)message.messageObject;
	if (obj.attachment != nil && [obj.attachment isKindOfClass:[AttachmentModel class]]) {
		AttachmentModel *attachment = (AttachmentModel *)obj.attachment;
		NSLog(@"当前的second:%d", attachment.second);
		if (attachment.first == CustomMessageType_Update_RoomInfo && attachment.second == Custom_Message_Sub_Update_RoomInfo_MessageState) {
			[self.datasource removeAllObjects];
			[self.incomingMessages removeAllObjects];
            [self.messageBubbles removeAllObjects];
            [self.locationArray removeAllObjects];
            self.atCount = 0;
            self.atTipBtn.hidden = YES;
            self.messageTipsBtn.hidden = YES;
            self.isPending = NO;
            [[XPRoomMiniManager shareManager] resetLocalMessage];
			[self addRoomMessage:message];
			return;
        } else if (attachment.first == CustomMessageType_Update_RoomInfo && attachment.second == Custom_Message_Sub_Update_RoomInfo_CleanScreen) {
            [self.datasource removeAllObjects];
            [self.incomingMessages removeAllObjects];
            [self.messageBubbles removeAllObjects];
            [self.locationArray removeAllObjects];
            self.atCount = 0;
            self.atTipBtn.hidden = YES;
            self.messageTipsBtn.hidden = YES;
            self.isPending = NO;
            [[XPRoomMiniManager shareManager] resetLocalMessage];
            [self addRoomMessage:message];
            return;
		} else if(attachment.first == CustomMessageType_Candy_Tree && attachment.second == Custom_Message_Sub_Candy_Tree_Me) {
			CandyTreeGiftInfoModel * model = [CandyTreeGiftInfoModel modelWithDictionary:attachment.data];
			if (model.uid.integerValue != [AccountInfoStorage instance].getUid.integerValue) {
				return;
			}
		}
	}
	if (self.hostDelegate.getRoomInfo.isCloseScreen) {
		return;
	}
	if ([self isCanDisplayMessage:message]) {
		[self addRoomMessage:message];
	}
}

- (void)handleNIMNotificationMessage:(NIMMessage *)message {
	self.isMiniEnter = NO;
	NIMNotificationObject *notiMsg = (NIMNotificationObject *)message.messageObject;
	NIMChatroomNotificationContent *content = (NIMChatroomNotificationContent *)notiMsg.content;
	RoomInfoModel * roomInfo = self.hostDelegate.getRoomInfo;
	if (content.eventType == NIMChatroomEventTypeEnter) {
		if (roomInfo.isCloseScreen) {
			AttachmentModel *attachement = [[AttachmentModel alloc]init];
			attachement.first = CustomMessageType_Update_RoomInfo;
			attachement.second = Custom_Message_Sub_Update_RoomInfo_MessageState;
			attachement.data = @{@"roomInfo":self.hostDelegate.getRoomInfo.model2dictionary};
			NIMMessage *message = [[NIMMessage alloc]init];
			NIMCustomObject *object = [[NIMCustomObject alloc] init];
			object.attachment = attachement;
			message.messageObject = object;
			[self addRoomMessage:message];
			return;
		} else {
			NIMChatroomNotificationMember *member = content.targets[0];
			if (member.userId.integerValue == [AccountInfoStorage instance].getUid.integerValue) {
                ///自己进房成功后拉取历史消息
                [self handleFetchHistoryMessage:message];
            } else {
                BOOL hideEnter = [self handleHideEnter:message];
                if (!hideEnter) {
                    ///插入进房消息及房间公告提示
                    [self addRoomMessage:message];
                }
            }
		}
	} else if(content.eventType == NIMChatroomEventTypeInfoUpdated) {
		if (roomInfo.isCloseScreen) {return;}
		if (roomInfo.datingState == RoomDatingStateChangeType_Open) {
            NSString * uid = [AccountInfoStorage instance].getUid;
            NSString * roomId = [NSString stringWithFormat:@"%ld", roomInfo.roomId];
            NIMChatroomMembersByIdsRequest *request = [[NIMChatroomMembersByIdsRequest alloc]init];
            request.roomId = roomId;
            request.userIds = @[uid];
            [[NIMSDK sharedSDK].chatroomManager fetchChatroomMembersByIds:request completion:^(NSError * _Nullable error, NSArray<NIMChatroomMember *> * _Nullable members) {
                if (error == nil) {
                    NIMChatroomMember * member = members.firstObject;
                    BOOL isCreator = member.type == NIMChatroomMemberTypeCreator;
                    BOOL isManager = member.type == NIMChatroomMemberTypeManager;
                    if (isCreator || isManager) {
                        [self addRoomMessage:message];
                    }
                }
            }];
		}
	}
}

- (void)handleFetchHistoryMessage:(NIMMessage *)message {
    RoomInfoModel * roomInfo = self.hostDelegate.getRoomInfo;
    NSString *roomId = [NSString stringWithFormat:@"%ld", self.hostDelegate.getRoomInfo.roomId];
    NIMHistoryMessageSearchOption *option = [[NIMHistoryMessageSearchOption alloc] init];
    option.limit = [ClientConfig shareConfig].configInfo.roomMessageCount;
    option.startTime = self.hostDelegate.getRoomInfo.clearScreenTime / 1000.0;
    option.order = NIMMessageSearchOrderAsc;
    option.messageTypes = @[@(NIMMessageTypeText)];
    [[NIMSDK sharedSDK].chatroomManager fetchMessageHistory:roomId option:option result:^(NSError * _Nullable error, NSArray<NIMMessage *> * _Nullable messages) {
        if (messages.count) {
            //如果拉取的数量等于请求的数量，说明这个时间点以后的消息数量大于等于需要拉取的数量，直接拉取最新的50条
            if (messages.count == [ClientConfig shareConfig].configInfo.roomMessageCount) {
                NIMHistoryMessageSearchOption *option = [[NIMHistoryMessageSearchOption alloc] init];
                option.limit = [ClientConfig shareConfig].configInfo.roomMessageCount;
                option.order = NIMMessageSearchOrderDesc;
                option.messageTypes = @[@(NIMMessageTypeText)];
                [[NIMSDK sharedSDK].chatroomManager fetchMessageHistory:roomId option:option result:^(NSError * _Nullable error, NSArray<NIMMessage *> * _Nullable messages) {
                    if (self.datasource.count > kRoomMessageMaxLength) {
                        NSIndexSet *set = [NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, kRoomMessageMaxLength/2)];
                        NSArray *needRemoveMsgArray = [self.datasource objectsAtIndexes:set];
                        [self.datasource removeObjectsInArray:needRemoveMsgArray];
                        [self.messageBubbles removeObjectsAtIndexes:set];
                    }
                    // 执行插入
                    for (NIMMessage *item in messages.reverseObjectEnumerator) {
                        [self.datasource addObject:[self.messageParser parseMessageAttribute:item]];
                        [self.messageBubbles addObject:[self.messageParser parseMessageBubble:item]];
                        if (!self.isMiniEnter) {/// 最小化进房的话 不需要重新保存
                            if (self.hostDelegate.getRoomInfo.isCloseScreen) {
                                NIMCustomObject *obj = (NIMCustomObject *)item.messageObject;
                                if (obj.attachment != nil && [obj.attachment isKindOfClass:[AttachmentModel class]]) {
                                    AttachmentModel *attachment = (AttachmentModel *)obj.attachment;
                                    if (attachment.first == CustomMessageType_Update_RoomInfo && attachment.second == Custom_Message_Sub_Update_RoomInfo_MessageState){
                                        [[XPRoomMiniManager shareManager] saveRoomMessage:item];
                                    }
                                }
                            } else {
                                [[XPRoomMiniManager shareManager] saveRoomMessage:item];
                            }
                        }
                    }
                    [self.messageTableView reloadData];
                    //执行插入动画并滚动
                    [self scrollToBottom:YES];
                    BOOL hideEnter = [self handleHideEnter:message];
                    if (!hideEnter) {
                        ///插入进房消息及房间公告提示
                        [self addRoomMessage:message];
                    }
                    if (!roomInfo.hasAnimationEffect) {
                        [self roomInfoNoGiftAnimationMessage:message];
                    }
                    [self createUserEnterRoomAddRoomtopicMessage];
                }];
                return;
            }
            if (self.datasource.count > kRoomMessageMaxLength) {
                NSIndexSet *set = [NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, kRoomMessageMaxLength/2)];
                NSArray *needRemoveMsgArray = [self.datasource objectsAtIndexes:set];
                [self.datasource removeObjectsInArray:needRemoveMsgArray];
                [self.messageBubbles removeObjectsAtIndexes:set];
            }
            // 执行插入
            for (NIMMessage *item in messages) {
                [self.datasource addObject:[self.messageParser parseMessageAttribute:item]];
                [self.messageBubbles addObject:[self.messageParser parseMessageBubble:item]];
                if (!self.isMiniEnter) {/// 最小化进房的话 不需要重新保存
                    if (self.hostDelegate.getRoomInfo.isCloseScreen) {
                        NIMCustomObject *obj = (NIMCustomObject *)item.messageObject;
                        if (obj.attachment != nil && [obj.attachment isKindOfClass:[AttachmentModel class]]) {
                            AttachmentModel *attachment = (AttachmentModel *)obj.attachment;
                            if (attachment.first == CustomMessageType_Update_RoomInfo && attachment.second == Custom_Message_Sub_Update_RoomInfo_MessageState){
                                [[XPRoomMiniManager shareManager] saveRoomMessage:item];
                            }
                        }
                    } else {
                        [[XPRoomMiniManager shareManager] saveRoomMessage:item];
                    }
                }
            }
            [self.messageTableView reloadData];
            //执行插入动画并滚动
            [self scrollToBottom:YES];
        }
        BOOL hideEnter = [self handleHideEnter:message];
        if (!hideEnter) {
            ///插入进房消息及房间公告提示
            [self addRoomMessage:message];
        }
        if (!roomInfo.hasAnimationEffect) {
            [self roomInfoNoGiftAnimationMessage:message];
        }
        [self createUserEnterRoomAddRoomtopicMessage];
    }];
}

- (void)handleNIMTextMessage:(NIMMessage *)message {
	self.isMiniEnter = NO;
	if (self.hostDelegate.getRoomInfo.isCloseScreen) {return;}
	[self addRoomMessage:message];
}

- (void)roomInfoNoGiftAnimationMessage:(NIMMessage *)message {
	self.isMiniEnter = NO;
	AttachmentModel *attachement = [[AttachmentModel alloc]init];
	attachement.first = CustomMessageType_Update_RoomInfo;
	attachement.second = Custom_Message_Sub_Update_RoomInfo_AnimateEffect;
	NIMMessage *tempMessage = [[NIMMessage alloc]init];
	NIMCustomObject *customObject = [[NIMCustomObject alloc]init];
	customObject.attachment = attachement;
	tempMessage.messageObject = customObject;
	[self addRoomMessage:tempMessage];
}

- (void)onRoomMiniEntered {
	self.isMiniEnter = YES;
	///最小化进房  不需要请求任何接口 但是如果不加延迟的话 无法滚动到底部  原因还不知道
	dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.2 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
		NSArray * temArray = [XPRoomMiniManager shareManager].getLocalCurrentRoomMessage;
		// 执行插入
		for (NIMMessage *item in temArray) {
			[self.datasource addObject:[self.messageParser parseMessageAttribute:item]];
			[self.messageBubbles addObject:[self.messageParser parseMessageBubble:item]];
		}
		[self.messageTableView reloadData];
		//执行插入动画并滚动
		[self scrollToBottom:YES];
	});
}

- (void)onRoomEntered {
	[[XPRoomMiniManager shareManager]  resetLocalMessage];
	self.headerView.bubbleColor = self.hostDelegate.getRoomInfo.type == RoomType_MiniGame ? [UIColor colorWithWhite:1 alpha:0.2] : [ThemeColor messageBubbleColor];
}

- (void)onRoomUpdate {
	///改变公屏的背景样式
	if (self.hostDelegate.getRoomInfo.hadChangeRoomType) {
		self.headerView.bubbleColor = self.hostDelegate.getRoomInfo.type == RoomType_MiniGame ? [UIColor colorWithWhite:1 alpha:0.2] : [ThemeColor messageBubbleColor];
		[self.messageTableView reloadData];
	}
}

#pragma mark - ScrollViewDelegate
- (void)scrollViewWillBeginDragging:(UIScrollView *)scrollView {
	// 手动拖拽开始
	self.isPending = YES;
}
- (void)scrollViewDidEndDragging:(UIScrollView *)scrollView willDecelerate:(BOOL)decelerate {
	// 手动拖拽结束（decelerate：0松手时静止；1松手时还在运动,会触发DidEndDecelerating方法）
	if (!decelerate) {
		[self finishDraggingWith:scrollView];
	}
}
- (void)scrollViewDidEndDecelerating:(UIScrollView *)scrollView {
	// 静止后触发（手动）
	[self finishDraggingWith:scrollView];
}
- (void)scrollViewDidEndScrollingAnimation:(UIScrollView *)scrollView {
    if (!self.isPending && self.incomingMessages.count <= 0) {
        [self scrollToBottom:YES];
    }
}

/**
 手动拖拽动作彻底完成(减速到零)
 */
- (void)finishDraggingWith:(UIScrollView *)scrollView {
	CGFloat contentSizeH = scrollView.contentSize.height;
	CGFloat contentOffsetY = scrollView.contentOffset.y;
	CGFloat sizeH = scrollView.frame.size.height;
	self.isPending = contentSizeH - contentOffsetY - sizeH > 20.0;
    if (!self.isPending) {
        self.messageTipsBtn.hidden = YES;
        self.atTipBtn.hidden = YES;
        self.atCount = 0;
        [self.locationArray removeAllObjects];
        if (self.incomingMessages.count > 0) {
            [self appendAndScrollToBottom];
        }
    }
    [[NSNotificationCenter defaultCenter] postNotificationName:@"roomMessageTabelViewStopScroll" object:nil];
}


#pragma mark - UITableViewDelegate And UITableViewDataSource
- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
	return self.datasource.count;
}

- (CGFloat)tableView:(UITableView *)tableView heightForRowAtIndexPath:(NSIndexPath *)indexPath {
    NSAttributedString* attr = [self.datasource objectAtIndex:indexPath.row];
    CGSize maxSize = CGSizeMake(kRoomMessageMaxWidth - 24, MAXFLOAT);
	YYTextContainer *container = [YYTextContainer containerWithSize:maxSize];
	container.maximumNumberOfRows = 0;
	YYTextLayout *layout = [YYTextLayout layoutWithContainer:container text:attr];
    return layout.textBoundingSize.height + kRoomMessageTextSpaceHeight * 2 + 10;
}

- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {
	XPRoomMessageTableViewCell * cell = [tableView dequeueReusableCellWithIdentifier:NSStringFromClass([XPRoomMessageTableViewCell class])];
	cell.delegate = self;
    NSAttributedString* attr = [self.datasource objectAtIndex:indexPath.row];
    NSString *bubbleStr = [self.messageBubbles objectAtIndex:indexPath.row];
    cell.bubbleImageUrl = bubbleStr;
	cell.roomType = self.hostDelegate.getRoomInfo.type;
	cell.attributedString = attr;
	return cell;
}


#pragma mark - XPRoomMessageTableViewCellDelegate
- (void)xPRoomMessageTableViewCellDidTapEmpty:(XPRoomMessageTableViewCell *)view {
	if (self.hostDelegate.getRoomInfo.type == RoomType_MiniGame) {
		self.isLarge = !self.isLarge;
		CGFloat height = self.isLarge ? 200 : 80;
		[self mas_updateConstraints:^(MASConstraintMaker *make) {
			make.height.mas_equalTo(height);
		}];
	}
}

#pragma mark - Getters And Setters
- (UITableView *)messageTableView {
	if (!_messageTableView) {
		_messageTableView = [[UITableView alloc] initWithFrame:CGRectZero style:UITableViewStylePlain];
		_messageTableView.delegate = self;
		_messageTableView.dataSource = self;
		_messageTableView.tableFooterView = [UIView new];
		_messageTableView.separatorStyle = UITableViewCellSeparatorStyleNone;
		_messageTableView.backgroundColor = [UIColor clearColor];
		_messageTableView.showsVerticalScrollIndicator = NO;
        _messageTableView.tag = 666;
		if (@available(iOS 11.0, *)) {
			_messageTableView.contentInsetAdjustmentBehavior = UIScrollViewContentInsetAdjustmentNever;
		}
		[_messageTableView registerClass:[XPRoomMessageTableViewCell class] forCellReuseIdentifier:NSStringFromClass([XPRoomMessageTableViewCell class])];
	}
	return _messageTableView;
}

- (XPRoomMessageHeaderView *)headerView {
	if (!_headerView) {
		_headerView = [[XPRoomMessageHeaderView alloc] init];
	}
	return _headerView;
}

- (UIButton *)messageTipsBtn {
	if (!_messageTipsBtn) {
		_messageTipsBtn = [UIButton buttonWithType:UIButtonTypeCustom];
		[_messageTipsBtn setTitle:@"底部有新消息" forState:UIControlStateNormal];
		[_messageTipsBtn setTitleColor:[ThemeColor appMainColor] forState:UIControlStateNormal];
		_messageTipsBtn.layer.cornerRadius = 15.0;
		_messageTipsBtn.layer.masksToBounds = YES;
		_messageTipsBtn.titleLabel.font = [UIFont systemFontOfSize:12.0];
		_messageTipsBtn.backgroundColor = [UIColor whiteColor];
		[_messageTipsBtn addTarget:self action:@selector(messageTipsBtnAction:) forControlEvents:UIControlEventTouchUpInside];
		_messageTipsBtn.hidden = YES;
	}
	return _messageTipsBtn;
}

- (UIButton *)atTipBtn {
    if (!_atTipBtn) {
        _atTipBtn = [UIButton buttonWithType:UIButtonTypeCustom];
        [_atTipBtn setTitle:@"有人@你" forState:UIControlStateNormal];
        [_atTipBtn setTitleColor:[ThemeColor appMainColor] forState:UIControlStateNormal];
        _atTipBtn.layer.cornerRadius = 15.0;
        _atTipBtn.layer.masksToBounds = YES;
        _atTipBtn.titleLabel.font = [UIFont systemFontOfSize:12.0];
        _atTipBtn.backgroundColor = [UIColor whiteColor];
        [_atTipBtn addTarget:self action:@selector(atTipsBtnAction:) forControlEvents:UIControlEventTouchUpInside];
        _atTipBtn.hidden = YES;
    }
    return _atTipBtn;
}

- (NSMutableArray<NSAttributedString *> *)datasource {
	if (!_datasource) {
		_datasource = [NSMutableArray array];
	}
	return _datasource;
}

- (NSMutableArray<NIMMessage *> *)incomingMessages {
	if (!_incomingMessages) {
		_incomingMessages = [NSMutableArray array];
	}
	return _incomingMessages;
}

- (NSMutableArray *)messageBubbles {
    if (!_messageBubbles) {
        _messageBubbles = [NSMutableArray array];
    }
    return _messageBubbles;
}

- (NSMutableArray *)locationArray {
    if (!_locationArray) {
        _locationArray = [NSMutableArray array];
    }
    return _locationArray;
}

- (XPRoomMessageParser *)messageParser {
	if (!_messageParser) {
		_messageParser = [[XPRoomMessageParser alloc] init];
		_messageParser.hostDelegate =  self.hostDelegate;
	}
	return _messageParser;
}

@end