PrivateBoxiOS/创维盒子/code/NAS/nasBackupsManager/nasMixBackupsManager.m

//
//  nasMixBackupsManager.m
//  双子星云手机
//
//  Created by xd h on 2024/8/30.
//

#import "nasMixBackupsManager.h"
#import "customUploadOperation.h"
#import "nasUploadFileManager.h"
#import "frpFileExistModel.h"
#import "frpUploadModel.h"

#define Kboundary3 @"Boundaryhxd"

@interface nasMixBackupsManager ()<NSURLSessionDataDelegate>
//排队等候下载的上传地址数组
@property(nonatomic,strong) NSMutableArray *uploadWaitingUrlArr;
//正在下载的上传地址数组
@property(nonatomic,strong) NSMutableArray *uploadingOperationArr;

@property(nonatomic,assign) NSInteger speedShowCount;//内网的情况 多少次才刷新一次
@end

@implementation nasMixBackupsManager
+ (instancetype)shareManager {
    static nasMixBackupsManager *_instance;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        _instance = [[self alloc] init];
    });
    return _instance;
}

- (instancetype)init {

    if (self = [super init]) {
        _maxUploadLoadCount = 1;
        
       if ([pingManager shareManager].isPingOk)
       {
           _speedShowCount = 3;
       }
       else{
           _speedShowCount = 0;
       }
        //[self registeNotification];
    }
    return self;
}

/** 添加要上传的 模型  */
- (void)addBackupsWithModels:(NSArray *)fileModels{
    
    HLog(@"添加备份任务-- %ld",fileModels.count)
    
    for (uploadFileDataModel *model in fileModels) {
        BOOL needAddType = YES;
        
        //1. 排查上传中
        for (customUploadOperation *operationDoing in self.uploadingOperationArr) {
            if([operationDoing.fileModel.localIdentifier isEqualToString:model.localIdentifier]){
                needAddType = NO;
                break;
            }
        }
        
        //1. 排查等待下载
        for (uploadFileDataModel *waitModel in self.uploadWaitingUrlArr) {
            if([waitModel.localIdentifier isEqualToString:model.localIdentifier]){
                needAddType = NO;
                break;
            }
        }
        
        if(needAddType){
            [self.uploadWaitingUrlArr addObject:model];
        }
    }
    
    //启动上传
    [self beginUpload];
}

//在添加XX后 启动下载
- (void)beginUpload
{
    BOOL isCanUseCellular = [HWDataManager getBoolWithKey:stringKeyAddSn(Const_file_Transfe_canUse_Cellular_all)];
    if(!isCanUseCellular){//不允许流量上传
        //
        if([AFNetworkReachabilityManager sharedManager].networkReachabilityStatus == AFNetworkReachabilityStatusReachableViaWWAN){
            mainBlock(^{
                [[NSNotificationCenter defaultCenter] postNotificationName:uploadFileSuspendAllNotification object:nil];
                [[iToast makeText:NSLocalizedString(@"File_Transfer_By_Cellular_tip",nil)] show];
            });
            return;
        }
        
    }
    
    if(ksharedAppDelegate.DisabledFileTransferType){
        if(ksharedAppDelegate.isImageNewFor130){
            [[iToast makeText:NSLocalizedString(@"File_Transfer_Disable_tip",nil)] show];
        }
        else{
            [[iToast makeText:NSLocalizedString(@"File_Transfer_Disable_tip2",nil)] show];
        }
        return;
    }
    
    @synchronized (self) {
        if(self.uploadingOperationArr.count == _maxUploadLoadCount){
            HLog(@"正在上传的数量达到了最大值 %ld",_maxUploadLoadCount)
            return;
        }
        
        if(self.uploadWaitingUrlArr.count == 0){
            HLog(@"没有等待中的上传任务")
            return;
        }
        
        NSInteger canAddTaskNumber = _maxUploadLoadCount - self.uploadingOperationArr.count;
        
        for (int i=0; i<canAddTaskNumber; i++) {
            
            if(self.uploadWaitingUrlArr.count >= 1){
                //创建上传任务
                uploadFileDataModel *WaitingModel = self.uploadWaitingUrlArr.firstObject;
                
                __block customUploadOperation * operation =  [customUploadOperation new];
                operation.fileModel = WaitingModel;
                
                //等待下载中的任务
                [self.uploadWaitingUrlArr removeObjectAtIndex:0];
                //添加到下载中数组
                [self.uploadingOperationArr addObject:operation];
                
                [self checkFileUploadStateWithOperation:operation];
                
                //[weakSelf handleTaskDidUploadWith:operation withState:state];
            }
            
        }
    
    }
    
}

#pragma mark 检测文件是否上传过了
- (void)checkFileUploadStateWithOperation:(customUploadOperation*)operation
{
    NSMutableDictionary*paraDict = [NSMutableDictionary new];
    
    if(operation.fileModel.savePath){
        NSString *absPath = [[NSString alloc] initWithFormat:@"%@%@",operation.fileModel.savePath,operation.fileModel.filename];
        [paraDict setValue:absPath forKey:@"absPath"];
        
        NSNumber *totalBytesNumber = [NSNumber numberWithLong:operation.fileModel.totalBytes];
        [paraDict setValue:totalBytesNumber forKey:@"fileSize"];
    }
    
    KWeakSelf
    [[netWorkManager shareInstance] cloudPhoneGETCallBackCode:@"isFileExist" Parameters:paraDict success:^(id  _Nonnull responseObject) {
        
        frpFileExistModel *model = [[frpFileExistModel alloc] initWithDictionary:responseObject error:nil];
        if(model && model.status == 0){
            [weakSelf checkFileUploadStateFunAfterNetWith:model WithOperation:operation];
        }
        else if(model && model.status == 5){
            //备份路径
            NSString * backupsDefaultPath = [HWDataManager getStringWithKey:stringKeyAddSn(Const_photo_backups_default_path)];
            NSArray * stringArr = [backupsDefaultPath componentsSeparatedByString:@"/"];
            NSString *lastStr = stringArr.lastObject;
            NSString *repStr = [[NSString alloc] initWithFormat:@"/%@",lastStr];
            NSString *name = [backupsDefaultPath stringByReplacingOccurrencesOfString:repStr withString:@""];
            name = [iTools changePathToShowPathBy:name];
            
            NSString* showTip = [[NSString alloc] initWithFormat:@"【%@】%@",name,NSLocalizedString(@"disk_space_not_tip_for_95",nil)];
            [[iToast makeText:showTip] show];
            [weakSelf handleUploadFailOneFileBy:operation];
            
            NSString* failTip = [[NSString alloc] initWithFormat:@"【%@】%@",name,NSLocalizedString(@"disk_space_not_tip_for_95_fail_tip",nil)];
            [[nasBackupsManager shareInstance] changeBackupsFileStateToFailWith:failTip];
        }
        else{
            [weakSelf handleUploadFailOneFileBy:operation];
            //FileExistRet(-1);
        }
    } failure:^(NSError * _Nonnull error) {
        HLog(@"%@",error)
        //FileExistRet(-1);
        [weakSelf handleUploadFailOneFileBy:operation];
    }];
    
}

#pragma mark 检测分家是否存在后处理 是否要上传
- (void)checkFileUploadStateFunAfterNetWith:(frpFileExistModel*)model WithOperation:(customUploadOperation*)operation
{
    if(!model){
        [self handleUploadFailOneFileBy:operation];
        return;
    }
    
    operation.fileModel.didUploadBytes = 0;
    operation.fileModel.taskId = model.data.fileTaskId;
    
    if(!model.data.exist){//未上传过
        [self prepareToUploadFileWithOperation:operation];
    
    }
    else if(model.data.isComplete){//上传过了 并且文件上传完了
        //判断下文件创建长度是否一致 一致则是上传完了 不一致 重新上传一个 可能是同名的文件而已
        if(model.data.size >= operation.fileModel.totalBytes){//上传完了
//            mainBlock(^{
//                [[iToast makeText:NSLocalizedString(@"File_upload_file_already_exists",nil)] show];
//            });
            
            [self handleUploadDoneOneFileBy:operation];
        }
        else{//未上传完 isComplete 这个字段有问题
            operation.fileModel.didUploadBytes = model.data.size;
            [self prepareToUploadFileWithOperation:operation];
        }
        
    }
    else{//上传过了 未上传完成
        operation.fileModel.didUploadBytes = model.data.size;
        [self prepareToUploadFileWithOperation:operation];
    }
}


#pragma mark 处理任务失败


#pragma mark 准备上传文件
- (void)prepareToUploadFileWithOperation:(customUploadOperation*)operation
{
    NSMutableDictionary *paraDict = [NSMutableDictionary new];
    
    NSString* taskUid  = operation.fileModel.taskId;
    if(!taskUid || taskUid.length == 0){
        taskUid = [iTools getTaskUidStr];
        operation.fileModel.taskId = taskUid;
    }
    
    [paraDict setObject:taskUid forKey:@"taskId"];
    [paraDict setObject:@0 forKey:@"position"];
    [paraDict setObject:@"true" forKey:@"isLast"];
    if(operation.fileModel.savePath){
        [paraDict setObject:operation.fileModel.savePath forKey:@"savePath"];
    }
    else{
        HLog(@"获取保存路径失败")
        return;
    }
    
    if(operation.fileModel.filename){
        [paraDict setObject:operation.fileModel.filename forKey:@"filename"];
    }
    else{
        HLog(@"获取用户名失败")
        return;
    }
    
    KWeakSelf
    if(operation.fileModel.curUploadFileType == uploadFileTypeImage){
        [paraDict setObject:@1 forKey:@"imageType"];
        
        if(!operation.fileModel.imageData){
            
            NSString*pathStr = [cachesFileManager getFilePathWithName:operation.fileModel.filename type:operation.fileModel.curUploadFileType];
            NSData *imageData = [NSData dataWithContentsOfFile:pathStr];
            
            if (!imageData) {
                
                if(!operation.fileModel.asset){
                    NSString *curLocalIdentifier = operation.fileModel.localIdentifier;
                    PHFetchResult *fetchResult = [PHAsset fetchAssetsWithLocalIdentifiers:@[curLocalIdentifier] options:nil];
                    PHAsset *asset = fetchResult.firstObject;
                    operation.fileModel.asset = asset;
                }
                
                PHImageRequestOptions *options = [[PHImageRequestOptions alloc] init];
                options.networkAccessAllowed = YES; // Allow downloading from iCloud
                options.version = PHImageRequestOptionsVersionCurrent;
                options.deliveryMode = PHImageRequestOptionsDeliveryModeHighQualityFormat;
                
                [[PHImageManager defaultManager] requestImageDataForAsset:operation.fileModel.asset options:options resultHandler:^(NSData * _Nullable imageData, NSString * _Nullable dataUTI, UIImageOrientation orientation, NSDictionary * _Nullable info) {
                        // 直接得到最终的 NSData 数据
                        if (imageData) {
                            operation.fileModel.imageData = imageData;
                            [weakSelf  afterGetImageDataFunWithOperation:operation];
                        }
                        else{
                            [weakSelf handleUploadFailOneFileBy:operation];
                        }
                }];
                return;
            }
            
            operation.fileModel.imageData = imageData;
        }
        
        
        NSData *curData = operation.fileModel.imageData;
        operation.onceDataLengt = [curData length];
        
        [self startUpload:paraDict operation:operation data:curData success:^(id  _Nonnull responseObject) {
            frpUploadModel *model = [[frpUploadModel alloc] initWithDictionary:responseObject error:nil];
            if(model && model.position == operation.fileModel.totalBytes){
                HLog(@"%@备份完成 数据正常",operation.fileModel.filename)
                [weakSelf handleUploadDoneOneFileBy:operation];
            }
            else if(model && model.position > operation.fileModel.totalBytes){
                HLog(@"%@备份完成 数据异常 -- position:%ld -- totalBytes:%ld",operation.fileModel.filename,model.position,operation.fileModel.totalBytes)
                [weakSelf handleUploadDoneOneFileBy:operation];
            }
            else{
                HLog(@"%@备份完成一片 %ld",operation.fileModel.filename,model.position)
            }
        } faild:^(NSError * _Nonnull error) {
            HLog(@"%@备份失败",operation.fileModel.filename)
            [weakSelf handleUploadFailOneFileBy:operation];
        }];
    }
    else{
        [paraDict setObject:@1 forKey:@"videoType"];
        [paraDict setObject:@"false" forKey:@"isLast"];

        if(![cachesFileManager checkFileIsSaveState:operation.fileModel.filename withType:uploadFileTypeVideo]){
            
            if(!operation.fileModel.asset){
                NSString *curLocalIdentifier = operation.fileModel.localIdentifier;
                PHFetchResult *fetchResult = [PHAsset fetchAssetsWithLocalIdentifiers:@[curLocalIdentifier] options:nil];
                PHAsset *asset = fetchResult.firstObject;
                operation.fileModel.asset = asset;
            }
            

            //真正的视频数据
            PHVideoRequestOptions *options = [[PHVideoRequestOptions alloc] init];
            options.version = PHVideoRequestOptionsVersionOriginal;
            options.networkAccessAllowed = YES; // Allow downloading from iCloud
            [[PHImageManager defaultManager] requestAVAssetForVideo:operation.fileModel.asset options:options resultHandler:^(AVAsset *asset, AVAudioMix *audioMix, NSDictionary *info) {
                if ([asset isKindOfClass:[AVURLAsset class]]) {
                    
                    AVURLAsset* urlAsset = (AVURLAsset*)asset;
                    
                    BOOL isSuc = [cachesFileManager copyVideoItemAtPath:[urlAsset.URL path] fileName:operation.fileModel.filename error:nil];
                    
                    if (isSuc) {
                        [weakSelf  afterGetVideoDataFunWithOperation:operation];
                    }
                    else{
                        [weakSelf handleUploadFailOneFileBy:operation];
                    }
                }
                else{
                    [weakSelf handleUploadFailOneFileBy:operation];
                }
            }];
            
            return;
        }
        
        long curPosition = operation.fileModel.didUploadBytes;
        [self beginUploadVideoDataFunBy:operation with:curPosition withPara:paraDict success:^(id  _Nonnull responseObject) {
            
        } faild:^(NSError * _Nonnull error) {
            
        }];
    }
    
}

#pragma mark 视频上传
- (void)beginUploadVideoDataFunBy:(customUploadOperation*)operation with:(NSInteger)position withPara:(NSMutableDictionary*)paraDict success:(netWork_Success)success faild:(netWork_Faild)faildStr
{
    if(operation.isCancelType){
        HLog(@"防止取消不了任务生效")
        return;
    }
    
    BOOL isLastPicece = NO;
    if((operation.fileModel.totalBytes - position) <= MaxNasUploadPieceSzie){
        [paraDict setObject:@"true" forKey:@"isLast"];
        isLastPicece = YES;
    }
    else{
        [paraDict setObject:@"false" forKey:@"isLast"];
    }
    
    [paraDict setObject:[NSNumber numberWithLong:position] forKey:@"position"];
    
    //视频数据切片
    __block NSData *videoData = [self cutVideoFileFunAtIndex:position withMaxLenght:MaxNasUploadPieceSzie withModel:operation.fileModel];
    
    if(!videoData ||videoData.length ==0){
        HLog(@"视频没获取到")
        [self handleUploadFailOneFileBy:operation];
        return;
    }
        
    operation.onceDataLengt = [videoData length];
    KWeakSelf
    [self startUpload:paraDict operation:operation data:videoData success:^(id  _Nonnull responseObject) {
        frpUploadModel *model = [[frpUploadModel alloc] initWithDictionary:responseObject error:nil];
        if(model && model.position >= operation.fileModel.totalBytes){
            HLog(@"%@上传完成 000",operation.fileModel.filename)
            [weakSelf handleUploadDoneOneFileBy:operation];
        }
        else{
            HLog(@"%@上传完成一片 %ld",operation.fileModel.filename,model.position)
            
            [weakSelf beginUploadVideoDataFunBy:operation with:model.position withPara:paraDict success:^(id  _Nonnull responseObject) {
                success(responseObject);
            } faild:^(NSError * _Nonnull error) {
                NSError *err = error;
                if(error.code != -999){
                    faildStr(err);
                }
               
            }];
        }
    } faild:^(NSError * _Nonnull error) {
        HLog(@"%@上传失败",operation.fileModel.filename)
        [weakSelf handleUploadFailOneFileBy:operation];
    }];
    
}

#pragma mark 分段读视频文件
-(NSData*)cutVideoFileFunAtIndex:(NSUInteger)dataIndex withMaxLenght:(NSInteger)maxLengt withModel:(uploadFileDataModel*)dataModel{
    NSString *filePath = [cachesFileManager getFilePathWithName:dataModel.filename type:uploadFileTypeVideo]; // 文件路径
    
    NSFileManager *manager0 = [NSFileManager defaultManager];
    if(![manager0 fileExistsAtPath:filePath]) {
     
        return [NSData new];
    }
    
    NSFileHandle *fileHandle = [NSFileHandle fileHandleForReadingAtPath:filePath]; // 创建文件句柄
      
    // 设置分段读取的大小，这里以每次读取1KB为例
    const NSUInteger chunkSize = maxLengt;//cutVideoPieceSzie;//5 * 1024 *1024;
    NSMutableData *data = [NSMutableData data];
    
    if (fileHandle) {
       
        long long endOfFile = [fileHandle seekToEndOfFile];
        
        if(dataModel.totalBytes == 0
           || dataModel.totalBytes < endOfFile){//异常处理
            dataModel.totalBytes = endOfFile;
        }
        
        //异常处理
        if(endOfFile == dataIndex){
            dataModel.totalBytes = endOfFile;
            dataModel.didUploadBytes = endOfFile;
            dataModel.curUploadStateType = uploadStateDone;
            [fileHandle closeFile];
            return  data;
        }
        
        if (endOfFile >=  chunkSize) {
            
            // 读取文件的分段数据到某个位置
            [fileHandle seekToFileOffset:dataIndex];
            
            // 读取文件的分段数据
            NSData* chunk = [fileHandle readDataOfLength:chunkSize];
            if (chunk) {
                [data appendData:chunk];
            }
        }
        else{
            // 读取文件的分段数据到某个位置
            [fileHandle seekToFileOffset:dataIndex];
            
            [data appendData:[fileHandle readDataToEndOfFile]];
        }
        
        // 在这里可以对文件内容进行处理
        // ...
        
        // 关闭文件句柄
        [fileHandle closeFile];
    }
    
    HLog(@"视频切片完成 dataIndex:%ld --长度:%ld",dataIndex,[data length])
    return data;
}

#pragma mark 处理上传完成
- (void)handleUploadDoneOneFileBy:(customUploadOperation*)operation
{
    [[NSNotificationCenter defaultCenter] postNotificationName:nasBackupsTaskExeEnd object:operation.fileModel];
    [_uploadingOperationArr removeObject:operation];
    //[self beginUpload];
    [[nasBackupsManager shareInstance] backupsFileDoneFun];
}

#pragma mark 处理删除失败
- (void)handleUploadFailOneFileBy:(customUploadOperation*)operation
{
    operation.fileModel.curUploadStateType = uploadStateFail;
    [[NSNotificationCenter defaultCenter] postNotificationName:nasBackupsTaskExeError object:operation.fileModel];
    [_uploadingOperationArr removeObject:operation];
    //[self beginUpload];
    //[[nasBackupsManager shareInstance] changeBackupsFileStateToFailWith:@""];
}

#pragma mark 根据 asset 获取到图片数据
- (void)afterGetImageDataFunWithOperation:(customUploadOperation*)operation
{
    [cachesFileManager getFileNameWithContent:operation.fileModel.imageData fileName:operation.fileModel.filename type:uploadFileTypeImage];
    
    [self prepareToUploadFileWithOperation:operation];
}

#pragma mark 根据 asset 获取到视频数据
- (void)afterGetVideoDataFunWithOperation:(customUploadOperation*)operation
{
    
    [self prepareToUploadFileWithOperation:operation];
}

#pragma mark 开始上传
- (void)startUpload:(NSMutableDictionary *)params operation:(customUploadOperation*)operation data:(NSData *)data success:(netWork_Success)success faild:(netWork_Faild)faildStr {
    
    NSString *urlString = ksharedAppDelegate.NASFileByBoxService;
    urlString = [[NSString alloc] initWithFormat:@"%@uploadFile",urlString];
    NSURL *URL = [NSURL URLWithString:urlString];
    NSMutableURLRequest *request = [NSMutableURLRequest requestWithURL:URL];
    [request setHTTPMethod:@"POST"];
    
    //请求体
    NSMutableData *bodyData = [self getBodyDataWithRequest:request withModel:operation.fileModel withData:data withPara:params];
    
    //设置请求体
    [request setHTTPMethod:@"POST"];
    [request setHTTPBody:bodyData];
    
    //设置请求体长度
    NSInteger length = [bodyData length];
    [request setValue:[NSString stringWithFormat:@"%ld",length] forHTTPHeaderField:@"Content-Length"];
    //设置 POST请求文件上传
    [request setValue:[NSString stringWithFormat:@"multipart/form-data; boundary=%@",Kboundary3]  forHTTPHeaderField:@"Content-Type"];

    KWeakSelf
    //回话对象
    NSURLSession *session = [NSURLSession sessionWithConfiguration:[NSURLSessionConfiguration defaultSessionConfiguration] delegate:self delegateQueue:nil];
    operation.session = session;
    
    //请求task
    /*
     第一个参数:请求对象
     第二个参数:传递是要上传的数据(请求体)
     第三个参数:
     */
    NSURLSessionUploadTask *uploadTask = [session uploadTaskWithRequest:request fromData:nil completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
        //解析
        [weakSelf handleCustomUploadResultBy:data withResponse:response withError:error success:success faild:faildStr];
    }];
    
//    NSString *filePath = [cachesFileManager getFilePathWithName:dataModel.filename type:uploadFileTypeVideo]; // 文件路径
//    NSURL *filePathUrl = [NSURL URLWithString:filePath];
//
//    NSURLSessionUploadTask *uploadTask = [session uploadTaskWithRequest:request fromFile:filePathUrl completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
//        HLog(@"data string:%@",[[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding]);
    //[weakSelf handleCustomUploadResultBy:data withResponse:response withError:error];
//    }];
    
//    NSURLSessionDataTask *uploadTask = [session dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
//
//        HLog(@"data string:%@",[[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding]);
    //[weakSelf handleCustomUploadResultBy:data withResponse:response withError:error];
//
////           NSJSONSerialization *object = [NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingMutableLeaves error:nil];
////           NSDictionary *dict = (NSDictionary *)object;
////           NSLog(@"=====%@",[dict objectForKey:@"success"]);
//       }];

    
    //执行Task
    [uploadTask resume];
    operation.dataTask = uploadTask;
}

#pragma mark 用系统方法写的上传处理
- (void)handleCustomUploadResultBy:(NSData*)data withResponse:(NSURLResponse*)response withError:(NSError*)error success:(netWork_Success)success faild:(netWork_Faild)faildStr{
    if(error){
        HLog(@"上传错误:%@",error)
        if(error.code != -999){
            faildStr(error);
        }
        return;
    }
    
    NSJSONSerialization *object = [NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingMutableLeaves error:nil];
    NSDictionary *dict = (NSDictionary *)object;
    
    frpUploadModel *model = [[frpUploadModel alloc] initWithDictionary:dict error:nil];
    if(model && [model.msg isEqualToString:@"success"]){
        success(dict);
    }
    else{
        NSError *err = [NSError new];
        faildStr(err);
    }
}

- (NSMutableData *)getBodyDataWithRequest:(NSMutableURLRequest *)request withModel:(uploadFileDataModel*)dataModel withData:(NSData*)data  withPara:(NSMutableDictionary*)params{
    
    //1 边界符号要配置请求头里面去
    /*
     multipart/form-data 是表单格式
     charset=utf-8 是utf-8编码
     bounary 是表单开头
     */
    [request setValue:[NSString stringWithFormat:@"multipart/form-data; charset=utf-8; boundary=%@", Kboundary3] forHTTPHeaderField:@"Content-Type"];
    
    /// body
    NSMutableData *boydData = [NSMutableData data];
    // 2.1 边界符号（开始边界）
    
    //2.1.1 其它参数
    NSMutableString *paraString = [NSMutableString new];
    //[paraString appendFormat:@"--%@\r\n",Kboundary];//\n:换行 \n:切换到行首
    for (NSString *key in params) {
        NSString *value = params[key];
        [paraString appendFormat:@"--%@\r\n",Kboundary3];//\n:换行 \n:切换到行首
        [paraString appendFormat:@"Content-Disposition: form-data; name=\"%@\"",key];
        [paraString appendFormat:@"\r\n"];
        [paraString appendFormat:@"\r\n"];
        [paraString appendFormat:@"%@\r\n",value];
    }
    
    //[boydData appendData:[paraString dataUsingEncoding:NSUTF8StringEncoding]];
    
    
    // body每一个段内容以换行符作为结束标示
    NSString *fileBeginBoundary = [NSString stringWithFormat:@"--%@\r\n", Kboundary3];
    //[boydData appendData:[fileBeginBoundary dataUsingEncoding:NSUTF8StringEncoding]];
    
    [paraString appendString:fileBeginBoundary];
    
    // 2.2 属性配置 名字；key；类型
    
    NSString *serverFileKey = @"image";  //key
    //NSString *serverFileKey = @"file";
    NSString *serverContentTypes = @"image/png";  //类型
    
    if (dataModel.curUploadFileType == uploadFileTypeVideo) {
        serverFileKey = @"video";
        serverContentTypes = @"video/mp4";
    }
    
    
    NSString *serverFileName = dataModel.filename;  //name

    
    // filename已命名文件;  name相当于一个key, 这个名字和服务器保持一致
    /*
     理解key，表单发送给服务端，服务端拿到数据之后，可以将任务解析成一个字典了imageDict；图片数据会通过这个字典里面的name来获取图片（伪代码 image =  imageDict[serverFileKey]）
     */
    //2.3 拼接数据(创建一个字符串来拼装)
    NSMutableString *string = [NSMutableString new];
    [string appendFormat:@"Content-Disposition:form-data; name=\"%@\"; filename=\"%@\" ", @"file", serverFileName];
    //[string appendFormat:@"%@", KNewLine];
    [string appendFormat:@"\r\n"];
    [string appendFormat:@"Content-Type:%@", serverContentTypes];
//    [string appendFormat:@"%@", KNewLine];
//    [string appendFormat:@"%@", KNewLine];
    [string appendFormat:@"\r\n"];
    [string appendFormat:@"\r\n"];
   // [boydData appendData:[string dataUsingEncoding:NSUTF8StringEncoding]];
    
    [paraString appendString:string];
    [boydData appendData:[paraString dataUsingEncoding:NSUTF8StringEncoding]];
    
    // 2.3 拼接数据(拼接文件数据)
    [boydData appendData:data];
    
    // 2.4 边界符号 (结束边界)
    NSString *fileEndBoundary = [NSString stringWithFormat:@"\r\n--%@--", Kboundary3];
    [boydData appendData:[fileEndBoundary dataUsingEncoding:NSUTF8StringEncoding]];
    
    return boydData;
}

#pragma mark 上传的文件已存在
- (void)handleTaskDidUploadWith:(customUploadOperation*)operation withState:(NSInteger)state
{
//    if(state == 1){
//        [[iToast makeText:NSLocalizedString(@"File_upload_file_already_exists",nil)] show];
//    }
    
    
    [self.uploadingOperationArr removeObject:operation];
    
    NSMutableArray *delArr = [NSMutableArray new];
    [delArr addObject:operation.fileModel];
    
    [[nasUploadFileManager shareInstance] deleteUploadFileRecordBy:delArr withDelCache:NO complete:^(BOOL isSuccess) {
        if (isSuccess) {
            
        }
    }];
    
    [self beginUpload];
}
    

#pragma mark - <NSURLSessionDataDelegate>

// ssl 服务 证书信任
- (void)URLSession:(NSURLSession *)session
didReceiveChallenge:(NSURLAuthenticationChallenge *)challenge
 completionHandler:(void (^)(NSURLSessionAuthChallengeDisposition disposition, NSURLCredential * _Nullable credential))completionHandler{
    if(![challenge.protectionSpace.authenticationMethod isEqualToString:@"NSURLAuthenticationMethodServerTrust"]) {
        return;
    }
    
    // 信任该插件
    NSURLCredential *credential = [[NSURLCredential alloc] initWithTrust:challenge.protectionSpace.serverTrust];
    // 第一个参数 告诉系统如何处置
    completionHandler(NSURLSessionAuthChallengeUseCredential,credential);
}

//当请求协议是https的时候回调用该方法
//Challenge 挑战 质询(受保护空间)
//NSURLAuthenticationMethodServerTrust 服务器信任证书
- (void)URLSession:(NSURLSession *)session
              task:(NSURLSessionTask *)task
didReceiveChallenge:(NSURLAuthenticationChallenge *)challenge
 completionHandler:(void (^)(NSURLSessionAuthChallengeDisposition disposition, NSURLCredential * __nullable credential))completionHandler {
    
    if(![challenge.protectionSpace.authenticationMethod isEqualToString:@"NSURLAuthenticationMethodServerTrust"]) {
        return;
    }
    
    // 信任该插件
    NSURLCredential *credential = [[NSURLCredential alloc] initWithTrust:challenge.protectionSpace.serverTrust];
    // 第一个参数 告诉系统如何处置
    completionHandler(NSURLSessionAuthChallengeUseCredential,credential);
    
}


// 接受到响应调用
- (void)URLSession:(NSURLSession *)session
          dataTask:(NSURLSessionDataTask *)dataTask
didReceiveResponse:(NSURLResponse *)response
 completionHandler:(void (^)(NSURLSessionResponseDisposition disposition))completionHandler {
    
    completionHandler(NSURLSessionResponseAllow);
}

// 上传进度
- (void)URLSession:(NSURLSession *)session task:(NSURLSessionTask *)task didSendBodyData:(int64_t)bytesSent totalBytesSent:(int64_t)totalBytesSent totalBytesExpectedToSend:(int64_t)totalBytesExpectedToSend{
    
    //每包发送的大小bytesSent，totalBytesSent已经上传了多少；totalBytesExpectedToSend总共要发送多少
    // 32768 = 32KB
    HLog(@"didSendBodyData: %lld--%lld-%lld", bytesSent, totalBytesSent, totalBytesExpectedToSend);
    
    for (customUploadOperation*operation in _uploadingOperationArr) {
        if(operation.dataTask == task){
            operation.fileModel.didUploadBytes += bytesSent;
            
            //调整下大小 因为上传的数据 除了data 长度 还包含了 参数大小
            if(totalBytesSent == totalBytesExpectedToSend){
                operation.fileModel.didUploadBytes -= (totalBytesExpectedToSend - operation.onceDataLengt);
            }
            
            operation.i ++;
            if(operation.i >= _speedShowCount){
                
                [nasBackupsManager shareInstance].curPhotosBackupsTaskMod.didUploadBytes = operation.fileModel.didUploadBytes;
                
                [[nasBackupsManager shareInstance] changeBackupsFileStateFun];
                
                operation.i = 0;
            }
            
            break;
        }
    }
    
}

#pragma mark 取消单个任务
- (void)cancelUploadTaskFunWith:(uploadFileDataModel*)fileModel
{
    HLog(@"取消任务-- %@--%@",fileModel.filename,fileModel.taskId)
    @synchronized (self) {
        for (uploadFileDataModel*waitModel in _uploadWaitingUrlArr) {
            if([waitModel.localIdentifier isEqualToString:fileModel.localIdentifier]){
                [_uploadWaitingUrlArr removeObject:waitModel];
                return;
            }
        }
        
        for (customUploadOperation*operation in _uploadingOperationArr) {
            if([operation.fileModel.localIdentifier isEqualToString:fileModel.localIdentifier]){
                operation.isCancelType = YES;
                [operation.dataTask cancel];
                [_uploadingOperationArr removeObject:operation];
                [self beginUpload];
                break;
            }
        }
    }
    
}

#pragma mark 取消所有任务
- (void)cancelUploadAllTaskFun
{
    HLog(@"取消所有任务")
    @synchronized (self) {
        [_uploadWaitingUrlArr removeAllObjects];
        
        for (customUploadOperation*operation in _uploadingOperationArr) {
            operation.isCancelType = YES;
            [operation.dataTask cancel];
        }
        
        [_uploadingOperationArr removeAllObjects];
    }
}


#pragma mark 判断是否在上传中
- (BOOL)checkUploadTaskDoingFun
{
    if(_uploadWaitingUrlArr.count >0 || _uploadingOperationArr.count>0){
        return YES;
    }
    
    return NO;
}

#pragma mark - lazy load
- (NSMutableArray *)uploadWaitingUrlArr {
    
    if (!_uploadWaitingUrlArr) {
        _uploadWaitingUrlArr = [NSMutableArray array];
    }
    return _uploadWaitingUrlArr;
}

- (NSMutableArray *)uploadingOperationArr {
    
    if (!_uploadingOperationArr) {
        _uploadingOperationArr = [NSMutableArray array];
    }
    return _uploadingOperationArr;
}
@end