#import "PrivateMessages.h"

#include "Login.h"

@interface PrivateMessages ()

@property (strong, nonatomic) NSNumber *p_lastId;

@implementation PrivateMessages

- (instancetype)init

{

self = [super init];

if (self) {

_propertyArrayMap = [NSDictionary dictionaryWithObjectsAndKeys:

@"PrivateMessage", @"list", nil];

_canLoadMore = YES;

_isLoading = _willLoadMore = _isPolling = NO;

_page = [NSNumber numberWithInteger:1];

_pageSize = [NSNumber numberWithInteger:20];

_curFriend = nil;

}

return self;

}

- (NSMutableArray *)list{

if (!_list) {

_list = [[NSMutableArray alloc] init];

}

return _list;

}

- (NSMutableArray *)nextMessages{

if (!_nextMessages) {

_nextMessages = [[NSMutableArray alloc] init];

}

return _nextMessages;

}

- (NSMutableArray *)dataList{

if (!_dataList) {

_dataList = [[NSMutableArray alloc] init];

}

return _dataList;

}

- (NSMutableArray *)reset_dataList{

[self.dataList removeAllObjects];

if (_list.count > 0) {

self.dataList = [_list mutableCopy];

}

if (_nextMessages.count > 0) {

[self.dataList insertObjects:_nextMessages atIndexes:[NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, _nextMessages.count)]];

}

return _dataList;

}

+ (PrivateMessages *)priMsgsWithUser:(User *)user{

PrivateMessages *priMsgs = [[PrivateMessages alloc] init];

priMsgs.curFriend = user;

return priMsgs;

}

+ (id)analyzeResponseData:(NSDictionary *)responseData{

id data = [responseData valueForKeyPath:@"data"];

if (!data) {//旧数据直接保存的data属性

data = responseData;

}

id resultA = nil;

if ([data isKindOfClass:[NSArray class]]) {

resultA = [NSObject arrayFromJSON:data ofObjects:@"PrivateMessage"];

}else if (data){

resultA = [NSObject objectOfClass:@"PrivateMessages" fromJSON:data];

}

return resultA;

}

- (NSString *)localPrivateMessagesPath{

NSString *path;

if (_curFriend) {

path = [NSString stringWithFormat:@"conversations_%@", _curFriend.global_key];

}else{

path = @"conversations";

}

return path;

}

- (NSString *)toPath{

NSString *path;

if (_curFriend) {

path = [NSString stringWithFormat:@"api/message/conversations/%@/prev", _curFriend.global_key];

}else{

path = @"api/message/conversations";

}

return path;

}

- (NSDictionary *)toParams{

NSDictionary *params = nil;

if (_curFriend) {

NSNumber *prevId = kDefaultLastId;

if (_willLoadMore && _list.count > 0) {

PrivateMessage *prev_Msg = [_list lastObject];

prevId = prev_Msg.id;

}

params = @{@"id" : prevId,

@"pageSize" : _pageSize};

}else{

params = @{@"page" : _willLoadMore? [NSNumber numberWithInt:_page.intValue +1]: [NSNumber numberWithInt:1],

@"pageSize" : _pageSize};

}

return params;

}

- (NSString *)toPollPath{

return [NSString stringWithFormat:@"api/message/conversations/%@/last", _curFriend.global_key];

}

- (NSDictionary *)toPollParams{

return @{@"id" : self.p_lastId};

}

- (void)freshLastId:(NSNumber *)last_id{

self.p_lastId = last_id;

}

- (NSNumber *)p_lastId{

if (!_p_lastId) {

_p_lastId = @0;

[_list enumerateObjectsUsingBlock:^(PrivateMessage *obj, NSUInteger idx, BOOL *stop) {

if (obj.id.integerValue > 0) {

_p_lastId = obj.id;

*stop = YES;

}

}];

}

return _p_lastId;

}

- (BOOL)p_addMsg:(PrivateMessage *)aMsg{

NSInteger curId = aMsg.id.integerValue;

__block NSInteger add_index;

__block BOOL needToAdd = NO;

if (self.list.count > 0) {

[self.list enumerateObjectsUsingBlock:^(PrivateMessage *obj, NSUInteger idx, BOOL *stop) {

if (curId == obj.id.integerValue) {

needToAdd = NO;

*stop = YES;

}else if (curId > obj.id.integerValue){

needToAdd = YES;

add_index = idx;

*stop = YES;

}

}];

if (needToAdd) {

[self.list insertObject:aMsg atIndex:add_index];

}

}else{

needToAdd = YES;

[self.list addObject:aMsg];

}

return needToAdd;

}

- (void)configWithObj:(id)anObj{

if ([anObj isKindOfClass:[PrivateMessages class]]) {

PrivateMessages *priMsgs = (PrivateMessages *)anObj;

self.page = priMsgs.page;

self.pageSize = priMsgs.pageSize;

self.totalPage = priMsgs.totalPage;

if (!_willLoadMore) {

[self.list removeAllObjects];

}

[self.list addObjectsFromArray:priMsgs.list];

self.canLoadMore = _page.intValue < _totalPage.intValue;

}else if ([anObj isKindOfClass:[NSArray class]]){

NSArray *list = (NSArray *)anObj;

if (!_willLoadMore) {

[self.list removeAllObjects];

}

[self.list addObjectsFromArray:list];

self.canLoadMore = list.count > 0;

}

[self reset_dataList];

}

- (void)configWithPollArray:(NSArray *)pollList{

if (pollList.count <= 0) {

return;

}

__block BOOL hasNewData = NO;

__weak typeof(self) weakSelf = self;

[pollList enumerateObjectsWithOptions:NSEnumerationReverse usingBlock:^(PrivateMessage *obj, NSUInteger idx, BOOL *stop) {

if ([weakSelf p_addMsg:obj]) {

hasNewData = YES;

}

}];

if (hasNewData) {

[self reset_dataList];

}

}

- (void)sendNewMessage:(PrivateMessage *)nextMsg{

[self p_addObj:nextMsg toArray:self.nextMessages];

[self reset_dataList];

}

- (void)p_addObj:(id)anObj toArray:(NSMutableArray *)list{

if (!anObj || !list) {

return;

}

NSUInteger index = [list indexOfObject:anObj];

if (index == NSNotFound) {

[list insertObject:anObj atIndex:0];

}else if (index != 0){

[list exchangeObjectAtIndex:index withObjectAtIndex:0];

}

}

- (void)sendSuccessMessage:(PrivateMessage *)sucessMsg andOldMessage:(PrivateMessage *)oldMsg{

if (!sucessMsg || !oldMsg) {

DebugLog(@"sucessMsg and oldMsg should not be nil");

return;

}

[self.nextMessages removeObject:oldMsg];

[self p_addMsg:sucessMsg];

[self reset_dataList];

}

- (void)deleteMessage:(PrivateMessage *)msg{

[self.list removeObject:msg];

[self.nextMessages removeObject:msg];

[self reset_dataList];

}