711/BuguLive/Class/General/Helper/NetHttpsManager/NetHttpsManager.m

//
//  NetHttpsManager.m
//  BuguLive
//
//  Created by xfg on 2017/3/13.
//  Copyright © 2017年 xfg. All rights reserved.
//

#import "NetHttpsManager.h"
#import "AFNetworking.h"
#import "ApiLinkModel.h"
#import "GTMBase64.h"
#import "AFHTTPSessionManager+Singlton.h"

#define kOvertime 180     // 请求超时时间

@implementation NetHttpsManager

+ (instancetype)manager
{
    return [[NetHttpsManager alloc] init];
}



#pragma mark - ----------------------- 请求网络方法 -----------------------
/**
 POST异步请求方法一
 
 @param paramDict 请求参数
 @param PostSuccess 成功回调
 @param PostFailure 失败回调
 */
- (void)POSTWithParameters:(NSMutableDictionary *)paramDict SuccessBlock:(SuccessBlock)PostSuccess FailureBlock:(FailureBlock)PostFailure
{
    [self POSTWithUrl:[NetWorkManager getUrlStr:paramDict] paramDict:paramDict SuccessBlock:PostSuccess FailureBlock:PostFailure];
}

/**
 POST异步请求方法二
 
 @param urlStr 接口基本地址
 @param paramDict 请求参数
 @param PostSuccess 成功回调
 @param PostFailure 失败回调
 */
- (void)POSTWithUrl:(NSString *)urlStr paramDict:(NSMutableDictionary *)paramDict SuccessBlock:(SuccessBlock)PostSuccess FailureBlock:(FailureBlock)PostFailure
{
    paramDict = [NetWorkManager getLocalParm:paramDict url:urlStr];
    
    if (![NetWorkManager isExistenceNetwork])
    {
        NSLog(ASLocalizedString(@"请检查当前网络"));
    }
    else
    {
        [NetWorkManager myCookieStorage];
        
        AFHTTPSessionManager *manager = [AFHTTPSessionManager defaultNetManager];
        manager.requestSerializer.timeoutInterval = kOvertime;

        [manager POST:urlStr parameters:paramDict headers:nil progress:^(NSProgress * _Nonnull uploadProgress) {
            
        } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
//            NSLog(@"responseObject");
//            NSLog(@"%@",responseObject);
            [NetWorkManager doResult:responseObject url:urlStr paramDict:paramDict successBlock:PostSuccess successBlock2:nil failureBlock:PostFailure failureBlock2:nil];
            
        } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
            
            [NetWorkManager updateErrorToServiceWithUrl:urlStr paramDict:paramDict errorString:[NSString stringWithFormat:@"%@",error]];
            if (PostFailure)
            {
                PostFailure(error);
            }
            
        }];
    }
}

/**
 POST异步请求方法三，带文件
 
 @param parmDict 请求参数
 @param fileUrl 文件的url，流传输方式
 @param PostSuccess 成功回调
 @param PostFailure 失败回调
 */
- (void)POSTWithDict:(NSMutableDictionary *)parmDict andFileUrl:(NSURL *)fileUrl SuccessBlock:(SuccessBlock)PostSuccess FailureBlock:(FailureBlock)PostFailure
{
    NSString *urlStr = [NetWorkManager getUrlStr:parmDict];
    parmDict = [NetWorkManager getLocalParm:parmDict url:urlStr];
    
    if (![NetWorkManager isExistenceNetwork])
    {
        NSLog(ASLocalizedString(@"请检查当前网络"));
    }
    else
    {
        [NetWorkManager myCookieStorage];
        
        AFHTTPSessionManager *manager = [AFHTTPSessionManager defaultNetManager];
        
        [manager POST:urlStr parameters:parmDict headers:nil constructingBodyWithBlock:^(id<AFMultipartFormData>  _Nonnull formData){
            
            [formData appendPartWithFileURL:fileUrl name:@"file" error:nil];
            
        } progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject){
            
            [NetWorkManager doResult:responseObject url:urlStr paramDict:parmDict successBlock:PostSuccess successBlock2:nil failureBlock:PostFailure failureBlock2:nil];
            
        } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
            
            [NetWorkManager updateErrorToServiceWithUrl:urlStr paramDict:parmDict errorString:[NSString stringWithFormat:@"%@",error]];
            if (PostFailure)
            {
                PostFailure(error);
            }
            
        }];
    }
}

/**
 POST异步请求方法四，带接口名字的方式
 
 @param method act
 @param ctl ctl
 @param param 请求参数
 @param successBlock 成功回调
 @param failBlock 失败回调
 */
- (void)postMethod:(NSString*)method ctl:(NSString*)ctl param:(NSDictionary*)param successBlock:(SuccessBlock)successBlock failBlock:(FailureBlock)failBlock
{
    NSMutableDictionary* postdir = NSMutableDictionary.new;
    if(param)
    {
        [postdir setDictionary:param];
    }
    
    [postdir setObject:method forKey:@"act"];
    [postdir setObject:ctl forKey:@"ctl"];
    [self POSTWithParameters:postdir SuccessBlock:successBlock FailureBlock:failBlock];
}

/**
 GET异步请求
 
 @param urlStr 接口基本地址
 @param headers headers
 @param GetSuccess 成功回调
 @param GetFailure 失败回调
 */
- (void)GETWithUrl:(NSString *)urlStr headers:(NSMutableDictionary *)headers SuccessBlock:(SuccessBlock)GetSuccess FailureBlock:(FailureBlock)GetFailure
{
    
    if (![NetWorkManager isExistenceNetwork])
    {
        NSLog(ASLocalizedString(@"请检查当前网络"));
    }
    else
    {
        AFHTTPSessionManager *manager;
        NSURL *baseURL = [NSURL URLWithString:urlStr];
        if (headers)
        {
            //设置和加入头信息
            NSURLSessionConfiguration *config = [NSURLSessionConfiguration defaultSessionConfiguration];
            [config setHTTPAdditionalHeaders:headers];
            
            manager = [[AFHTTPSessionManager alloc] initWithBaseURL:baseURL sessionConfiguration:config];
        }
        else
        {
            manager = [[AFHTTPSessionManager alloc]initWithBaseURL:baseURL];
        }
        
        manager.requestSerializer = [AFHTTPRequestSerializer serializer];
        manager.responseSerializer =[AFHTTPResponseSerializer serializer];
        manager.requestSerializer.timeoutInterval = kOvertime;
        
        [manager GET:urlStr parameters:[NetWorkManager getLocalParm:[NSMutableDictionary dictionary] url:urlStr] headers:nil progress:^(NSProgress * _Nonnull downloadProgress) {
            
        } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
            
            [NetWorkManager doResult:responseObject url:urlStr paramDict:nil successBlock:GetSuccess successBlock2:nil failureBlock:GetFailure failureBlock2:nil];
            
        } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
            
            if (GetFailure)
            {
                GetFailure(error);
            }
            
        }];
    }
}

/**
 NSURLSession同步请求
 
 @param urlStr 接口基本地址
 @param parmDict 请求参数
 @param PostSuccess 成功回调
 @param PostFailure 失败回调
 */
- (void)syncPostWithUrl:(NSString *)urlStr parameters:(NSMutableDictionary *)parmDict SuccessBlock:(SuccessBlock)PostSuccess FailureBlock:(FailureBlock)PostFailure
{
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(10000); //创建信号量
    NSURL *url = [NSURL URLWithString:urlStr];
    
    //(1)构造Request
    NSMutableURLRequest *request = [NSMutableURLRequest requestWithURL:url];
    
    //(2)设置为POST请求
    [request setHTTPMethod:@"POST"];
    
    //(3)超时
    [request setTimeoutInterval:kOvertime];
    
    //(4)设置请求头
    //[request setAllHTTPHeaderFields:nil];
    
    //(5)设置请求体
    NSMutableString *params = nil;
    if(nil != parmDict)
    {
        params = [[NSMutableString alloc] init];
        for(id key in parmDict)
        {
            NSString *encodedkey = [key stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding];
            
            CFStringRef value = (__bridge CFStringRef)[[parmDict objectForKey:key] copy];
            CFStringRef encodedValue = CFURLCreateStringByAddingPercentEscapes(kCFAllocatorDefault, value,NULL,(CFStringRef)@";/?:@&=+$", kCFStringEncodingUTF8);
            [params appendFormat:@"%@=%@&", encodedkey, encodedValue];
            CFRelease(value);
            CFRelease(encodedValue);
        }
        [params deleteCharactersInRange:NSMakeRange([params length] - 1, 1)];
    }
    
    NSData *bodyData = [params dataUsingEncoding:NSUTF8StringEncoding];
    
    //    if (bodyData)
    //    {
    //        [request setValue:[NSString stringWithFormat:@"%ld",(long)[bodyData length]] forHTTPHeaderField:@"Content-Length"];
    //        [request setHTTPMethod:@"POST"];
    //        [request setValue:@"application/json; charset=UTF-8" forHTTPHeaderField:@"Content-Type"];
    //        [request setValue:@"gzip" forHTTPHeaderField:@"Accept-Encoding"];
    
    [request setHTTPBody:bodyData];
    //    }
    
    //(6)构造Session
    NSURLSession *session = [NSURLSession sharedSession];
    
    //(7)task
    __block NSDictionary *resposeDict = nil;
    __block NSError *tmperror = nil;
    
    NSURLSessionDataTask *task = [session dataTaskWithRequest:request completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
        
        resposeDict = [NSJSONSerialization JSONObjectWithData:data options:kNilOptions error:nil];
        NSLog(@"dict:%@",resposeDict);
        tmperror = error;
        
        dispatch_semaphore_signal(semaphore);   //发送信号
        
    }];
    
    [task resume];
    dispatch_semaphore_wait(semaphore,DISPATCH_TIME_FOREVER);  //等待
    
    if (!tmperror)
    {
        if (resposeDict)
        {
            if([resposeDict count])
            {
                if (PostSuccess!=nil) {
                    PostSuccess(resposeDict);
                }
            }
            else
            {
                if (PostFailure!=nil)
                {
                    PostFailure(tmperror);
                }
            }
        }
        else
        {
            if (PostFailure!=nil)
            {
                PostFailure(tmperror);
            }
        }
    }
    else
    {
        if (PostFailure!=nil)
        {
            PostFailure(tmperror);
        }
    }
}

/**
 同步 调用接口,不要在主线程调用
 
 @param method act
 @param ctl ctl
 @param param 请求参数
 @return 返回NSDictionary值
 */
- (NSDictionary *)postSynchMehtod:(NSString*)method ctl:(NSString*)ctl param:(NSDictionary*)param
{
    MYNSCondition* itlock = [[MYNSCondition alloc] init];//搞个事件来同步下
    
    __block NSDictionary* itret = nil;
    
    [self postMethod:method ctl:ctl param:param successBlock:^(NSDictionary *jsonData) {
        
        itret = jsonData;
        
        [itlock lock];
        
        [itlock signal];//设置事件,下面那个等待就可以收到事件返回了
        
        [itlock unlock];
        
    } failBlock:^(NSError *error) {
        
        NSLog(@"postSynchMehtod eror:%@",error);
        
        [itlock lock];
        
        [itlock signal];//设置事件,下面那个等待就可以收到事件返回了
        
        [itlock unlock];
    }];
    
    [itlock lock];//启动AFNETWORKING之后就等待事件
    
    [itlock wait];
    
    [itlock unlock];
    
    return  itret;
}

/**
 POST异步请求方法三，带文件
 
 @param parmDict 请求参数
 @param fileUrl 文件的url，流传输方式
 @param PostSuccess 成功回调
 @param PostFailure 失败回调
 */
- (void)POSTWithDict:(NSMutableDictionary *)parmDict andFileData:(NSData *)fileData AndFileName:(NSString *)fileName SuccessBlock:(SuccessBlock)PostSuccess FailureBlock:(FailureBlock)PostFailure
{
    NSString *urlStr = [NetWorkManager getUrlStr:parmDict];
    parmDict = [NetWorkManager getLocalParm:parmDict url:urlStr];
    
    if (![NetWorkManager isExistenceNetwork])
    {
        NSLog(ASLocalizedString(@"请检查当前网络"));
    }
    else
    {
        [NetWorkManager myCookieStorage];
        
        AFHTTPSessionManager *manager = [AFHTTPSessionManager defaultNetManager];
        manager.requestSerializer.timeoutInterval = 600.f;

        [manager POST:urlStr parameters:parmDict headers:nil constructingBodyWithBlock:^(id<AFMultipartFormData>  _Nonnull formData){
            
            [formData appendPartWithFileData:fileData name:@"file" fileName:fileName mimeType:@"multipart/form-data"];
            
//            [formData appendPartWithFileURL:fileUrl name:@"file" error:nil];
            
        } progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject){
            
            [NetWorkManager doResult:responseObject url:urlStr paramDict:parmDict successBlock:PostSuccess successBlock2:nil failureBlock:PostFailure failureBlock2:nil];
            
        } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
            
            [NetWorkManager updateErrorToServiceWithUrl:urlStr paramDict:parmDict errorString:[NSString stringWithFormat:@"%@",error]];
            if (PostFailure)
            {
                PostFailure(error);
            }
            
        }];
    }
}



@end


#pragma mark - ----------------------- MYNSCondition -----------------------
// 重新NSCondition,原因：如果wait类函数后于signal调用,就会一直等待,也就是说signal线程比wait快执行
@implementation MYNSCondition
{
    __volatile int _waitcounts;
}

- (void)wait
{
    _waitcounts += 1;
    if(_waitcounts <= 0)
    {
        return;     // 本来一进入应该是等于1的,如果其他地方已经有signal了,就直接返回了
    }
    [super wait];
}

- (BOOL)waitUntilDate:(NSDate *)limit
{
    _waitcounts += 1;
    if(_waitcounts <= 0)
    {
        return YES; // 本来一进入应该是等于1的,如果其他地方已经有signal了,就直接返回了
    }
    return [super waitUntilDate:limit];
}

- (void)signal
{
    [super signal];
    _waitcounts -= 1;
}

- (void)broadcast
{
    [super broadcast];
    _waitcounts = -1;
}

@end