// // 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 () //排队等候下载的上传地址数组 @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= 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 - // 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