//
//  RemoteResponse.m
//  codeChallengeDemo
//
//  Created by Scar on 14-8-21.
//  Copyright (c) 2014年 scar1900. All rights reserved.
//

#import "RemoteResponse.h"
#import "AppDelegate.h"

@implementation Remote(Response)

//- (void)request:(ASIHTTPRequest *)request didReceiveResponseHeaders:(NSDictionary *)responseHeaders {
//
//    TPLOG(@"header %@ %@ %@ ", [responseHeaders objectForKey:@"Content-Length"], [responseHeaders objectForKey:@"Content-Type"],
//          [responseHeaders objectForKey:@"Server"]);
//}

-(void) jsonFinished: (ASIHTTPRequest *) request {
    @synchronized(self) {
        __weak id<RemoteDelegate> delegate = [[request userInfo] objectForKey:@"delegate"];
        int actionTag = [[[request userInfo] objectForKey:@"actionTag"] intValue];
        @try {
            NSString *responseString = [NSString stringWithFormat:@"%@", [request responseString]];
            responseString = [self dealResponseStringBeforeChange:responseString];
            NSData *preJsonData = [responseString dataUsingEncoding:NSUTF8StringEncoding];
            //解析返回的json报文
            NSDictionary *resDic = [self toArrayOrNSDictionary:preJsonData];
            if (!resDic) {
                TPLOG(@"返回数据为空!");
                if ([delegate respondsToSelector:@selector(remoteResponsFailed:withMessage:resultCode:)]) {
                    [delegate remoteResponsFailed:actionTag withMessage:@"服务器连接异常，请检查网络。" resultCode:@""];
                }
                [self performSelector:@selector(stopWaitCursor:)
                           withObject:request.userInfo];
                request.userInfo = nil;
                return;
            }
            
            if ([resDic[@"resultCode"] intValue] != 1) {
                TPLOG(@"%@",resDic[@"resultMsg"]);
                NSString *url = [NSString stringWithFormat:@"%@",request.url];
                if (![url isMatchedByRegex:@"getuuid"]) {
                    if ([delegate respondsToSelector:@selector(remoteResponsFailed:withMessage:resultCode:)]) {
                        [delegate remoteResponsFailed:actionTag withMessage:resDic[@"resultMsg"] resultCode:resDic[@"resultCode"]];
                        if ([resDic[@"resultCode"] intValue] == 4) {
                            NSString *uuid = resDic[@"uuid"];
                            if (uuid && !isBlankString(uuid)) {
                                [TPUserDefault instance].uuid = uuid;
                            }
                        }
                    }
                    return;
                }
            }
            if ([delegate respondsToSelector:@selector(remoteResponsSuccess:withResponsData:)]) {
                [delegate remoteResponsSuccess:actionTag withResponsData:resDic];
            }
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            [self performSelector:@selector(stopWaitCursor:)
                       withObject:request.userInfo];
            request.userInfo = nil;
        }
    }
}

- (void)jsonFinishedWithBlock: (ASIHTTPRequest *) request {
    @synchronized(self) {
        @try {
            NSString *responseString = [NSString stringWithFormat:@"%@", [request responseString]];
            responseString = [self dealResponseStringBeforeChange:responseString];
            NSData *preJsonData = [responseString dataUsingEncoding:NSUTF8StringEncoding];
            
            //解析返回的json报文
            NSDictionary *resDic = [self toArrayOrNSDictionary:preJsonData];
            //            int (^square)(int);
            void(^completeHandler)(BOOL success,NSString *message,id responseData);
            
            completeHandler = [[request userInfo] objectForKey:@"completeHandler"];
            
            if (!resDic) {
                TPLOG(@"返回数据为空!");
                if (completeHandler) {
                    completeHandler(NO,@"服务器连接异常，请检查网络。",nil);
                    completeHandler = nil;
                }
                [self performSelector:@selector(stopWaitCursor:)
                           withObject:request.userInfo];
                request.userInfo = nil;
                return;
            }
            
            if ([resDic[@"resultCode"] intValue] != 1) {
                TPLOG(@"%@",resDic[@"resultMsg"]);
                NSString *url = [NSString stringWithFormat:@"%@",request.url];
                if (![url isMatchedByRegex:@"getuuid"]) {
                    if (completeHandler) {
                        completeHandler(NO,resDic[@"resultMsg"],resDic[@"resultCode"]);
                        completeHandler = nil;
                        if ([resDic[@"resultCode"] intValue] == 4) {
                            NSString *uuid = resDic[@"uuid"];
                            if (uuid && !isBlankString(uuid)) {
                                [TPUserDefault instance].uuid = uuid;
                            }
                        }
                    }
                    return;
                }
            }
            if (completeHandler) {
                completeHandler(YES,nil,resDic);
                completeHandler = nil;
            }
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            [self performSelector:@selector(stopWaitCursor:)
                       withObject:request.userInfo];
            request.userInfo = nil;
        }
    }
}

- (void)noneJsonFinishedWithBlock: (ASIHTTPRequest *) request {
    @synchronized(self) {
        @try {
            NSString *responseString = [NSString stringWithFormat:@"%@", [request responseString]];
            
            
            void(^completeHandler)(BOOL success,NSString *message,id responseData);
            
            completeHandler = [[request userInfo] objectForKey:@"completeHandler"];
            
            if ([responseString isMatchedByRegex:@"success"]) {
                if (completeHandler) {
                    completeHandler(YES,nil,responseString);
                    completeHandler = nil;
                }
            }else {
                if (completeHandler) {
                    completeHandler(NO,nil,responseString);
                    completeHandler = nil;
                }
            }
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            [self performSelector:@selector(stopWaitCursor:)
                       withObject:request.userInfo];
            request.userInfo = nil;
        }
    }
}

- (void)DownloadFinish:(ASIHTTPRequest *)request {
    @synchronized(self) {
        @try {
            id<RemoteDelegate> delegate = [[request userInfo] objectForKey:@"delegate"];
            int commandTag = [[[request userInfo] objectForKey:@"actionTag"] intValue];
            NSString* fileName = [[request userInfo] objectForKey:@"fileName"];
            
            //通知已成功下载消息给相关代理
            if ([delegate respondsToSelector:@selector(remoteResponsSuccess:withResponsData:)]) {
                [delegate remoteResponsSuccess:commandTag withResponsData:fileName];
            }
            //停止等待光标
            //            [self performSelector:@selector(stopWaitCursor:)
            //                       withObject:[request userInfo]];
            //            request.userInfo = nil;
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            [self performSelector:@selector(stopWaitCursor:) withObject:request.userInfo];
            request.userInfo = nil;
        }
    }
}

- (void)DownloadFinishWithBlock:(ASIHTTPRequest *)request  {
    @synchronized(self) {
        @try {
            NSString* fileName = [[request userInfo] objectForKey:@"fileName"];
            
            if (self.downloadFinishHanlder) {
                self.downloadFinishHanlder(YES,nil,fileName);
                self.downloadFinishHanlder = nil;
            }
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            request.userInfo = nil;
        }
    }
}


- (void)requestFailed:(ASIHTTPRequest*)request {
    @synchronized(self) {
        @try {
            NSError *error = [request error];
            //通知错误消息
            [self performSelector:@selector(onNsError:userInfo:)
                       withObject:error
                       withObject:[request userInfo]];
        }
        @catch (NSException *e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            [self performSelector:@selector(stopWaitCursor:)
                       withObject:request.userInfo];
            request.userInfo = nil;
        }
    }
}

- (void)offlineDownloadFinished:(ASIHTTPRequest*)request {
    TPLOG(@"requestFinished");
    id<RemoteDelegate> delegate = [[request userInfo] objectForKey:@"delegate"];
    int commandTag = [[[request userInfo] objectForKey:@"actionTag"] intValue];
    NSString* fileName = [[request userInfo] objectForKey:@"fileName"];
    
    //通知已成功下载消息给相关代理
    if ([delegate respondsToSelector:@selector(remoteResponsSuccess:withResponsData:)]) {
        [delegate remoteResponsSuccess:commandTag withResponsData:fileName];
    }
}

- (void)imageUpLoadFinished:(ASIHTTPRequest*)request {
    @synchronized(self) {
        @try {
            self.xmlFinishHandler = nil;
            __block void(^completeHandler)(BOOL success,NSString *message,id responseData);
            __weak typeof(self) Self = self;
            [self parseXMLData:[request responseData] comlete:^(BOOL success, id responseData) {
                completeHandler = [[request userInfo] objectForKey:@"completeHandler"];
                NSDictionary *dic = responseData;
                if (dic.allKeys.count == 0) {
                    TPLOG(@"返回数据为空!");
                    dispatch_async(dispatch_get_main_queue(), ^{
                        if (completeHandler) {
                            completeHandler(NO,@"服务器连接异常，请检查网络。",nil);
                            completeHandler = nil;
                        }
                        [Self performSelector:@selector(stopWaitCursor:)
                                   withObject:request.userInfo];
                        request.userInfo = nil;
                    });
                    return;
                }
                
                dispatch_async(dispatch_get_main_queue(), ^{
                    if (completeHandler) {
                        completeHandler(YES,nil,dic);
                        completeHandler = nil;
                    }
                    [Self performSelector:@selector(stopWaitCursor:)
                               withObject:request.userInfo];
                    request.userInfo = nil;
                });
            }];
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            [self performSelector:@selector(stopWaitCursor:)
                       withObject:request.userInfo];
            request.userInfo = nil;
        }
    }
}

- (void)xmlRequestFinished:(ASIHTTPRequest*)request  {
    @synchronized(self) {
        @try {
            self.xmlFinishHandler = nil;
            __block void(^completeHandler)(BOOL success,NSString *message,id responseData);
            [self parseXMLData:[request responseData] comlete:^(BOOL success, id responseData) {
                completeHandler = [[request userInfo] objectForKey:@"completeHandler"];
                if (success) {
                    NSDictionary *dic = responseData;
                    if (dic.allKeys.count == 0) {
                        TPLOG(@"返回数据为空!");
                        dispatch_async(dispatch_get_main_queue(), ^{
                            if (completeHandler) {
                                completeHandler(NO,@"服务器连接异常，请检查网络。",nil);
                                completeHandler = nil;
                            }
                            request.userInfo = nil;
                        });
                        return;
                    }
                    
                    dispatch_async(dispatch_get_main_queue(), ^{
                        if (completeHandler) {
                            completeHandler(YES,nil,dic);
                            completeHandler = nil;
                        }
                        request.userInfo = nil;
                    });
                }else {
                    if (completeHandler) {
                        completeHandler(NO,nil,nil);
                        completeHandler = nil;
                    }
                    request.userInfo = nil;
                }
            }];
        }
        @catch (NSException * e) {
            [self performSelector:@selector(onError:userInfo:)
                       withObject:[e reason]
                       withObject:[request userInfo]];
        }
        @finally {
            request.userInfo = nil;
        }
    }
}



- (void)request:(ASIHTTPRequest *)request didReceiveBytes:(long long)bytes {
    int commandTag = [[[request userInfo] objectForKey:@"actionTag"] intValue];
    
    NSArray *tmpArray = [NSArray arrayWithArray:[TPUserDefault instance].offlineStatusList];
    NSMutableArray *list = [NSMutableArray arrayWithArray:[TPUserDefault instance].offlineStatusList];
    [tmpArray enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
        if ([obj[@"nodeId"] intValue] == commandTag) {
            float currentByte = [obj[@"currentByte"] floatValue];
            currentByte = currentByte + bytes;
            NSMutableDictionary *dic = [NSMutableDictionary dictionaryWithDictionary:obj];
            [dic setValue:[NSString stringWithFormat:@"%f",currentByte] forKey:@"currentByte"];
            [list replaceObjectAtIndex:idx withObject:dic];
        }
    }];
    
    [TPUserDefault instance].offlineStatusList = list;
}

- (void)queDidFinish {
    [[NSNotificationCenter defaultCenter] postNotificationName:QUEDIDFINISH object:nil];
}

#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wobjc-protocol-method-implementation"

- (void)URLSession:(NSURLSession *)session
      downloadTask:(NSURLSessionDownloadTask *)downloadTask
didFinishDownloadingToURL:(NSURL *)location {
    //    TPLOG(@"Download success for URL: %@",location.description);
    [ASIHTTPRequest hideNetworkActivityIndicator];
    
    __block NSString *fileName = @"";
    __block NSNumber *actionTag = nil;
    __block id<RemoteDelegate> delegate = nil;
    __block BOOL isAllTaskFinish = YES;
    [self.sessionTaskList enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
        NSURLSessionDownloadTask *task = obj[@"task"];
        if (task.taskIdentifier == downloadTask.taskIdentifier) {
            fileName = obj[@"fileName"];
            actionTag = obj[@"actionTag"];
            delegate = obj[@"delegate"];
            [obj setValue:@"1" forKey:@"finish"];
            
        }
        
        [[TPUserDefault instance].offlineStatusList enumerateObjectsUsingBlock:^(id item, NSUInteger index, BOOL *stop1) {
            if ([item[@"nodeId"] intValue] == [obj[@"actionTag"] intValue]) {
                if ([item[@"isSelected"] intValue] == 1) {
                    NSString *finish = obj[@"finish"];
                    if (!finish || isBlankString(finish) || [finish intValue] != 1) {
                        isAllTaskFinish = NO;
                    }
                }
            }
        }];
    }];
    
    //通知已成功下载消息给相关代理
    
    if (!isBlankString(fileName)) {
        NSURL *destination = [NSURL URLWithString:[@"file://" stringByAppendingString:ConfigPath(fileName)]];
        TPLOG(@"%@",ConfigPath(fileName));
        if ([self copyTempFileAtURL:location toDestination:destination]) {
            dispatch_async(dispatch_get_main_queue(), ^{
                if ([delegate respondsToSelector:@selector(remoteResponsSuccess:withResponsData:)]) {
                    [delegate remoteResponsSuccess:[actionTag intValue] withResponsData:fileName];
                }
                
                if (isAllTaskFinish) {
                    [[NSNotificationCenter defaultCenter] postNotificationName:QUEDIDFINISH object:nil];
                    ShowTextMessage(@"离线下载完成");
                }
            });
        }
    }else {
        TPLOG(@"文件名不存在，无法完成下载！！！");
    }
}

- (void)URLSession:(NSURLSession *)session
      downloadTask:(NSURLSessionDownloadTask *)downloadTask
      didWriteData:(int64_t)bytesWritten
 totalBytesWritten:(int64_t)totalBytesWritten
totalBytesExpectedToWrite:(int64_t)totalBytesExpectedToWrite {
    if (![UIApplication sharedApplication].networkActivityIndicatorVisible) {
        [ASIHTTPRequest showNetworkActivityIndicator];
    }
    //    double currentProgress = totalBytesWritten/(double)totalBytesExpectedToWrite;
    //    TPLOG(@"%f",currentProgress);
    
    
    __block NSNumber *actionTag = nil;
    [self.sessionTaskList enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
        NSURLSessionDownloadTask *task = obj[@"task"];
        if (task.taskIdentifier == downloadTask.taskIdentifier) {
            actionTag = obj[@"actionTag"];
        }
    }];
    int commandTag = [actionTag intValue];
    
    NSArray *tmpArray = [NSArray arrayWithArray:[TPUserDefault instance].offlineStatusList];
    NSMutableArray *list = [NSMutableArray arrayWithArray:[TPUserDefault instance].offlineStatusList];
    [tmpArray enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
        if ([obj[@"nodeId"] intValue] == commandTag) {
            NSMutableDictionary *dic = [NSMutableDictionary dictionaryWithDictionary:obj];
            float currentByte =  totalBytesWritten;
            [dic setValue:[NSString stringWithFormat:@"%f",currentByte] forKey:@"currentByte"];
            [list replaceObjectAtIndex:idx withObject:dic];
        }
    }];
    
    [TPUserDefault instance].offlineStatusList = list;
}

- (void)URLSession:(NSURLSession *)session downloadTask:(NSURLSessionDownloadTask *)downloadTask
 didResumeAtOffset:(int64_t)fileOffset
expectedTotalBytes:(int64_t)expectedTotalBytes {
    if (![UIApplication sharedApplication].networkActivityIndicatorVisible) {
        [ASIHTTPRequest showNetworkActivityIndicator];
    }
    //    double currentProgress = totalBytesWritten/(double)totalBytesExpectedToWrite;
    //    TPLOG(@"%f",currentProgress);
    
    
    __block NSNumber *actionTag = nil;
    [self.sessionTaskList enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
        NSURLSessionDownloadTask *task = obj[@"task"];
        if (task.taskIdentifier == downloadTask.taskIdentifier) {
            actionTag = obj[@"actionTag"];
        }
    }];
    int commandTag = [actionTag intValue];
    
    NSArray *tmpArray = [NSArray arrayWithArray:[TPUserDefault instance].offlineStatusList];
    NSMutableArray *list = [NSMutableArray arrayWithArray:[TPUserDefault instance].offlineStatusList];
    [tmpArray enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
        if ([obj[@"nodeId"] intValue] == commandTag) {
            NSMutableDictionary *dic = [NSMutableDictionary dictionaryWithDictionary:obj];
            float currentByte =  fileOffset;
            [dic setValue:[NSString stringWithFormat:@"%f",currentByte] forKey:@"currentByte"];
            [list replaceObjectAtIndex:idx withObject:dic];
        }
    }];
    
    [TPUserDefault instance].offlineStatusList = list;
}

//后台回调给前台应用代码
- (void)URLSessionDidFinishEventsForBackgroundURLSession:(NSURLSession *)session {
    AppDelegate *appDelegate = (AppDelegate*)[[UIApplication sharedApplication] delegate];
    
    if (appDelegate.backgroundSessionCompletionHandler) {
        void (^completionHandler)() = appDelegate.backgroundSessionCompletionHandler;
        appDelegate.backgroundSessionCompletionHandler = nil;
        completionHandler();
    }
    NSLog(@"所有任务已完成!");
    [ASIHTTPRequest hideNetworkActivityIndicator];
}

//下载终止回调（成功or失败）
- (void)URLSession:(NSURLSession *)session task:(NSURLSessionTask *)task didCompleteWithError:(NSError *)error {
    if (error == nil) {
        NSLog(@"任务: %@ 成功完成", task);
    }else {
        NSLog(@"任务: %@ 发生错误: %@", task, [error localizedDescription]);
    }
    double progress = (double)task.countOfBytesReceived / (double)task.countOfBytesExpectedToReceive;
    NSLog(@"completeProgress:%f",progress);
    
    [ASIHTTPRequest hideNetworkActivityIndicator];
}

#pragma clang diagnostic pop
// 将JSON串转化为字典或者数组
- (id)toArrayOrNSDictionary:(NSData *)jsonData{
    NSError *error = nil;
    id jsonObject = [NSJSONSerialization JSONObjectWithData:jsonData
                                                    options:NSJSONReadingAllowFragments
                                                      error:&error];
    
    if (jsonObject != nil && error == nil){
        return jsonObject;
    }else{
        // 解析错误
        return nil;
    }
}

//json容错处理
- (NSString*)dealResponseStringBeforeChange:(NSString*)responseString {
    responseString = [responseString stringByReplacingOccurrencesOfString:@"\\'" withString:@"'"];
    if (![responseString isMatchedByRegex:@"\\\""]) {
        responseString = [responseString stringByReplacingOccurrencesOfString:@"\\\\" withString:@"\\"];
    }
    /**
     * bug:5328(224有个话题，进入后提示“服务器连接异常，请检查网络”)
     */
    responseString = [responseString stringByReplacingOccurrencesOfString:@"\\'́" withString:@"'́"];
    /**
     * bug:5208(话题详情页，有一个话题，加载不了)
     */
    return responseString;
}

#pragma mark - 解析xml
-(void)parseXMLData:(NSData *)data comlete:(void(^)(BOOL success,id responseData))completion{
    
    dispatch_queue_t reentrantAvoidanceQueue = dispatch_queue_create("reentrantAvoidanceQueue", DISPATCH_QUEUE_SERIAL);
    dispatch_async(reentrantAvoidanceQueue, ^{
        self.xmlFinishHandler = completion;
        //1.创建解析器
        NSXMLParser *parser=[[NSXMLParser alloc]initWithData:data];
        //2.设置代理
        parser.delegate=self;
        //3.开始解析
        if (![parser parse]) {
            if (self.xmlFinishHandler) {
                self.xmlFinishHandler(NO,nil);
                self.xmlFinishHandler = nil;
            }
        }
    });
    dispatch_sync(reentrantAvoidanceQueue, ^{ });
}

- (void)parserDidStartDocument:(NSXMLParser *)parser {
    self.xmlDic = [NSMutableDictionary dictionary];
}

- (void)parserDidEndDocument:(NSXMLParser *)parser {
    if (self.xmlFinishHandler) {
        self.xmlFinishHandler(YES,self.xmlDic);
        self.xmlFinishHandler = nil;
    }
}

- (void)parser:(NSXMLParser *)parser didStartElement:(NSString *)elementName namespaceURI:(NSString *)namespaceURI qualifiedName:(NSString *)qName attributes:(NSDictionary *)attributeDict {
    self.lastXMLStr = elementName;
}

- (void)parser:(NSXMLParser *)parser foundCharacters:(NSString *)string
{
    if (![string isMatchedByRegex:@"http"] && [string isMatchedByRegex:@"="]) {
        NSArray *list = [string componentsSeparatedByRegex:@"="];
        if (list.count < 2) {
            return;
        }
        [self.xmlDic setValue:list[1] forKey:list[0]];
    }else {
        if (isBlankString([self.xmlDic valueForKey:self.lastXMLStr])) {
            [self.xmlDic setValue:string forKey:self.lastXMLStr];
        }
    }
}

- (void)parser:(NSXMLParser *)parser didEndElement:(NSString *)elementName namespaceURI:(NSString *)namespaceURI qualifiedName:(NSString *)qName {
    
}

@end