PrivateBoxiOS/创维盒子/双子星云手机/NAS/nasUploadManager/nasUploadFileManager.m

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

#import "nasUploadFileManager.h"
#import "nasUploadManager.h"

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

- (id)init
{
    self = [super init];
    if (self) {
        [self initManager];
    }
    return self;
}

- (void)initManager
{
    _maxUploadingNumber = 1;
    _uploadingModelArr = [NSMutableArray new];
}

#pragma mark 读取数据库数据
- (void)getDataInDatabaseFun:(BOOL)isReGet complete:(custom_complete_Arr)complete
{
    if(_databaseArr && _databaseArr.count == 3 && !isReGet){
        complete(_databaseArr);
        return;
    }
    
    if(!_databaseArr)
    {
        _databaseArr = [NSMutableArray new];
    }
    
    //KWeakSelf
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{
//        NSLock *lock = [NSLock new];
//        [lock lock];
        [uploadFileDataModel bg_findAsync:nasUpLoadFile_tableName limit:0 orderBy:nil desc:YES complete:^(NSArray * _Nullable array) {
            NSMutableArray *failArr = [NSMutableArray new];
            NSMutableArray *doneArr = [NSMutableArray new];
            NSMutableArray *otherArr = [NSMutableArray new];
            
                for (uploadFileDataModel * curModel in array) {
                    
                    //图片 和视频 还原
                    if(curModel.curUploadFileType == uploadFileTypeImage){

                    }
                    else if(curModel.curUploadFileType == uploadFileTypeVideo){

                        if(curModel.curUploadStateType != uploadStateDone){
                    
                        }
                    }
                    
                    if(curModel.curUploadStateType == uploadStateFail){
                        [failArr addObject:curModel];
                    }
                    else if(curModel.curUploadStateType == uploadStateDone){
                        [doneArr addObject:curModel];
                    }
                    else{
                        [otherArr addObject:curModel];
                    }
                }
            
            NSLock *lock = [NSLock new];
            [lock lock];
            
            NSMutableArray *newArr = [NSMutableArray new];
            [newArr addObject:otherArr];
            [newArr addObject:doneArr];
            [newArr addObject:failArr];
            self->_databaseArr = newArr;
            
            [lock unlock];
            
            complete(self->_databaseArr);
        }];
//        [lock unlock];
    });

}

//把TZAssetModel 转成 我们需要上传的model
- (void)handlTZAssetModelToUploadFileDataFunBy:(NSMutableArray*)indexPathsForSelectedItems complete:(custom_complete_Arr)complete
{
    if(!indexPathsForSelectedItems && indexPathsForSelectedItems.count == 0){
        complete(_databaseArr);
        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];
        }
        
        complete(_databaseArr);
        return;
    }
    
    if(!_fileModelDataArr){
        _fileModelDataArr = [NSMutableArray new];
    }
    
    _isNewAddTaskType = YES;
    
    self.curUploadModelNumbers = indexPathsForSelectedItems.count;
    
    NSMutableArray *newUploadTaskArr = [NSMutableArray new];
    
    NSLock *lock = [NSLock new];
    
    for (TZAssetModel * model in indexPathsForSelectedItems) {
        uploadFileDataModel * curModel = [uploadFileDataModel new];
        curModel.asset = model.asset;
        curModel.localIdentifier = model.asset.localIdentifier;
        
        BOOL isRepeatingTasksType = NO;
        [lock lock];
        //查询上传任务是否存在
        if(_databaseArr && _databaseArr.count == 3 ){
            NSMutableArray *uploadingArr = [[NSMutableArray alloc] initWithArray:_databaseArr[0]];
            for (uploadFileDataModel *preModel in uploadingArr) {
                if([preModel.localIdentifier isEqualToString:curModel.localIdentifier]){
                    isRepeatingTasksType = YES;
                    break;
                }
            }
        }
        [lock unlock];
        
        if(isRepeatingTasksType){
            continue;
        }
        
        NSString * uploadDefaultPath = [HWDataManager getStringWithKey:stringKeyAddSn(Const_photo_upload_default_path)];
        if(!uploadDefaultPath || uploadDefaultPath.length == 0){
            [HWDataManager setStringWithKey:stringKeyAddSn(Const_photo_upload_default_path) value:Const_default_upload_path];
            uploadDefaultPath = Const_default_upload_path;
        }
        
        //判断最后一个是否是/
        NSString *lastStr= [uploadDefaultPath substringFromIndex:uploadDefaultPath.length-1];
        if(![lastStr isEqualToString:@"/"]){
            uploadDefaultPath = [[NSString alloc] initWithFormat:@"%@/",uploadDefaultPath];
        }
        
        //NSString*savePath = [[NSString alloc] initWithFormat:@"%@%@",uploadDefaultPath,filePath];
        curModel.savePath = uploadDefaultPath;
        
//        curModel.imageData = model.imageData;
//        curModel.videoData = model.videoData;
        curModel.filename = [model.asset valueForKey:@"filename"];
        //curModel.curUploadStateType = uploadStateWait;
        curModel.curUploadStateType = uploadStateUploading;
        
        if(model.type == TZAssetModelMediaTypeVideo){
            curModel.curUploadFileType = uploadFileTypeVideo;
            [cachesFileManager getFileNameWithContent:curModel.videoData fileName:curModel.filename type:uploadFileTypeVideo];
            
            
            //curModel.totalBytes = [model.videoData length];
            curModel.totalBytes = model.totalBytes;
            curModel.videoData = [NSData new];//视频文件存储到文件后内存清空
            
            NSString *imgName1 = [curModel.filename stringByReplacingOccurrencesOfString:@"." withString:@"_"];
            curModel.videoFirstImageName = [[NSString alloc] initWithFormat:@"%@.png",imgName1];
           
            //第一帧图片
            [[PHImageManager defaultManager] requestImageDataForAsset:curModel.asset options:nil resultHandler:^(NSData * _Nullable imageData, NSString * _Nullable dataUTI, UIImageOrientation orientation, NSDictionary * _Nullable info) {
                    // 直接得到最终的 NSData 数据
                    if (imageData) {
                        curModel.imageData = imageData;
                        [cachesFileManager getFileNameWithContent:curModel.imageData fileName:curModel.videoFirstImageName type:uploadFileTypeImage];
                    }
            }];

        }
        else{
            curModel.curUploadFileType = uploadFileTypeImage;
            curModel.totalBytes = model.totalBytes;
            
            if(curModel.imageData)
            {
                [cachesFileManager getFileNameWithContent:curModel.imageData fileName:curModel.filename type:uploadFileTypeImage];
                curModel.imageData = nil;
            }
            else{
                
            }
           
        }
        
        //保存到数据库
        curModel.bg_tableName = nasUpLoadFile_tableName;
        [newUploadTaskArr addObject:curModel];
        
    }
    
    KWeakSelf
    if(newUploadTaskArr.count == 0){
        [self getDataInDatabaseFun:YES complete:^(NSMutableArray * _Nonnull Arr) {
            complete(Arr);
            [weakSelf handleUploadFileModelBg_idFun:Arr];
        }];
    }
    else{
        [uploadFileDataModel bg_saveOrUpdateArrayAsync:newUploadTaskArr complete:^(BOOL isSuccess) {
            [weakSelf getDataInDatabaseFun:YES complete:^(NSMutableArray * _Nonnull Arr) {
                complete(Arr);
                [weakSelf handleUploadFileModelBg_idFun:Arr];
            }];
        }];
    }
}

#pragma mark 处理当前的model 加上bg_id
- (void)handleUploadFileModelBg_idFun:(NSMutableArray*)totalArr
{
    if(!totalArr || totalArr.count != 3){
        return;
    }
    
    _fileModelDataArr = [NSMutableArray arrayWithArray:totalArr[0]];
    
    [self beginUploadFileFun];
}

- (void)beginUploadFileFun
{
//    if(_isUploadIngType && _reUploadIngSelectIndex <= 0){
//        return;
//    }
    
    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;
    }
    
    if(_isSuspendType)
    {
        return;
    }
    
    _isUploadIngType = YES;
    
    
    if(_uploadingModelArr.count >= _maxUploadingNumber){
        return;
    }
    
    _curUploadFileDataModel.imageData = nil;
    _curUploadFileDataModel.videoData = nil;
    _curUploadFileDataModel = nil;
    
    if(_fileModelDataArr.count == 0 && _uploadingModelArr.count == 0){
        [self didUploadAllTaskDoneFun];
        return;
    }
    
    if(_reUploadIngSelectIndex > 0 && _reUploadIngSelectIndex < _fileModelDataArr.count){
        _curUploadFileDataModel = _fileModelDataArr[_reUploadIngSelectIndex];
    }
    else
    {
        _curUploadFileDataModel = _fileModelDataArr.firstObject;
    }
    
    //做个异常处理
    if(_databaseArr.count == 3 && _isNewAddTaskType){
        NSMutableArray *uploadIngArr = _databaseArr[0];
        if(_fileModelDataArr.count != uploadIngArr.count){
            _databaseArr[0] = [NSMutableArray arrayWithArray:_fileModelDataArr];
        }
    }
    
    if(!_curUploadFileDataModel){
        return;
    }
    
    if(_curUploadFileDataModel.curUploadFileType == uploadFileTypeImage){
        NSString*pathStr = [cachesFileManager getFilePathWithName:_curUploadFileDataModel.filename type:_curUploadFileDataModel.curUploadFileType];
        _curUploadFileDataModel.imageData = [NSData dataWithContentsOfFile:pathStr];
        
        if(_curUploadFileDataModel.imageData && _curUploadFileDataModel.imageData.length >0){
            if(_curUploadFileDataModel.totalBytes == 0){
                _curUploadFileDataModel.totalBytes = _curUploadFileDataModel.imageData.length;
            }
            
            [self beginGotoUploadDataFun];
            return;
        }
    }
    else{
        if([cachesFileManager checkFileIsSaveState:_curUploadFileDataModel.filename withType:uploadFileTypeVideo]){
            [self beginGotoUploadDataFun];
            return;
        }
    }
    
    if(!_curUploadFileDataModel.asset){
        NSString *curLocalIdentifier = _curUploadFileDataModel.localIdentifier;
        PHFetchResult *fetchResult = [PHAsset fetchAssetsWithLocalIdentifiers:@[curLocalIdentifier] options:nil];
        PHAsset *asset = fetchResult.firstObject;
        _curUploadFileDataModel.asset = asset;
    }
    
    if(!_curUploadFileDataModel.asset){
        self.curUploadFileDataModel.curUploadStateType = uploadStateFail;
        [self nasUploadFileChangeingOneFileFunBy:self.curUploadFileDataModel];
        return;
    }
    
    KWeakSelf
    if(_curUploadFileDataModel.curUploadFileType == uploadFileTypeImage)
    {
        if(!_curUploadFileDataModel.imageData || _curUploadFileDataModel.imageData.length == 0){
            [[PHImageManager defaultManager] requestImageDataForAsset:_curUploadFileDataModel.asset options:nil resultHandler:^(NSData * _Nullable imageData, NSString * _Nullable dataUTI, UIImageOrientation orientation, NSDictionary * _Nullable info) {
                    // 直接得到最终的 NSData 数据
                    if (imageData) {
                        self->_curUploadFileDataModel.imageData = imageData;
                        [weakSelf  afterGetImageDataFun];
                    }
                    else{
                        weakSelf.curUploadFileDataModel.curUploadStateType = uploadStateFail;
                        [weakSelf nasUploadFileChangeingOneFileFunBy:weakSelf.curUploadFileDataModel];
                    }
            }];
        }
    }
    else if(_curUploadFileDataModel.curUploadFileType == uploadFileTypeVideo){
        
        //第一帧图片
        [[PHImageManager defaultManager] requestImageDataForAsset:_curUploadFileDataModel.asset options:nil resultHandler:^(NSData * _Nullable imageData, NSString * _Nullable dataUTI, UIImageOrientation orientation, NSDictionary * _Nullable info) {
                // 直接得到最终的 NSData 数据
                if (imageData) {
                    weakSelf.curUploadFileDataModel.imageData = imageData;
                    [weakSelf  afterGetImageDataInVideoFun];
                }
        }];

        //真正的视频数据
        PHVideoRequestOptions *options = [[PHVideoRequestOptions alloc] init];
        options.version = PHVideoRequestOptionsVersionOriginal;
        [[PHImageManager defaultManager] requestAVAssetForVideo:_curUploadFileDataModel.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:self->_curUploadFileDataModel.filename error:nil];
                
                if (isSuc) {
                    [weakSelf  afterGetVideoDataFun];
                }
                else{
                    self->_curUploadFileDataModel.curUploadStateType = uploadStateFail;
                    [weakSelf nasUploadFileChangeingOneFileFunBy:self->_curUploadFileDataModel];
                }
            }
            else{
                weakSelf.curUploadFileDataModel.curUploadStateType = uploadStateFail;
                [weakSelf nasUploadFileChangeingOneFileFunBy:weakSelf.curUploadFileDataModel];
            }
        }];
    }
}

#pragma mark 根据 asset 获取到图片数据
- (void)afterGetImageDataFun
{
    [cachesFileManager getFileNameWithContent:_curUploadFileDataModel.imageData fileName:_curUploadFileDataModel.filename type:uploadFileTypeImage];
    
    [self beginGotoUploadDataFun];
}

#pragma mark 处理视频第一帧
- (void)afterGetImageDataInVideoFun
{
    [cachesFileManager getFileNameWithContent:_curUploadFileDataModel.imageData fileName:_curUploadFileDataModel.videoFirstImageName type:uploadFileTypeImage];
}

#pragma mark 处理视频数据
- (void)afterGetVideoDataFun
{
    [self beginGotoUploadDataFun];
}


#pragma mark 开始上传
- (void)beginGotoUploadDataFun{
    
    [self checkFileUploadStateFun];
}


#pragma mark 检测文件是否上传过 或者云机里存在文件了
- (void)checkFileUploadStateFun
{
    NSMutableDictionary*paraDict = [NSMutableDictionary new];
    
    if(_curUploadFileDataModel.savePath){
        NSString *absPath = [[NSString alloc] initWithFormat:@"%@%@",_curUploadFileDataModel.savePath,_curUploadFileDataModel.filename];
        [paraDict setValue:absPath forKey:@"absPath"];
        
        NSNumber *totalBytesNumber = [NSNumber numberWithLong:_curUploadFileDataModel.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];
        }
        else{
            [weakSelf checkFileUploadStateFunAfterNetWith:nil];
        }
    } failure:^(NSError * _Nonnull error) {
        HLog(@"%@",error)
        [weakSelf checkFileUploadStateFunAfterNetWith:nil];
    }];
    
    
}

- (void)checkFileUploadStateFunAfterNetWith:(frpFileExistModel*)model
{
    if(!model){
        [self beginUploadFileFun];
        return;
    }
    
    _curUploadFileDataModel.didUploadBytes = 0;
    _curUploadFileDataModel.taskId = model.data.taskId;
    
    if(!model.data.exist){//未上传过
        [self realUploadAfterCheckFileUploadStateFun];
    }
    else if(model.data.isComplete){//上传过了 并且文件上传完了
        //判断下文件创建长度是否一致 一致则是上传完了 不一致 重新上传一个 可能是同名的文件而已
//        if(model.data.size >= _curUploadFileDataModel.totalBytes){//上传完了
//            HLog(@"222");
//        }
//        else{
//
//        }
        
        [self handleTaskDidUploadWith:_curUploadFileDataModel];
        
    }
    else{//上传过了 未上传完成
        _curUploadFileDataModel.didUploadBytes = model.data.size;
        [self realUploadAfterCheckFileUploadStateFun];
    }
}

#pragma mark 文件上传在云机已经存在
- (void)handleTaskDidUploadWith:(uploadFileDataModel*)didUploadModel
{
    mainBlock(^{
        [[iToast makeText:NSLocalizedString(@"File_upload_file_already_exists",nil)] show];
    });
    
    NSMutableArray *delArr = [NSMutableArray new];
    [delArr addObject:didUploadModel];
    
    [[nasUploadFileManager shareInstance] deleteUploadFileRecordBy:delArr withDelCache:NO complete:^(BOOL isSuccess) {
        if (isSuccess) {
            
        }
    }];
}

#pragma mark 检测文件是否上传过 或者云机里存在文件了
- (void)realUploadAfterCheckFileUploadStateFun
{
    
    BOOL isNewTask = YES;
    for (uploadFileDataModel *preModel in _uploadingModelArr) {
        if(preModel.bg_id.integerValue == _curUploadFileDataModel.bg_id.integerValue){
            isNewTask = NO;
            break;
        }
    }
    
    [_fileModelDataArr removeObject:_curUploadFileDataModel];
    if(isNewTask){
        [_uploadingModelArr addObject:_curUploadFileDataModel];
    }
    else{
        [self beginUploadFileFun];
        return;
    }
    
    __block uploadFileDataModel *curUploadModel = [_curUploadFileDataModel copy];
    _curUploadFileDataModel = nil;
    
    KWeakSelf
    [[nasUploadManager shareInstance] beginUploadDataBy:curUploadModel success:^(id  _Nonnull responseObject) {
        HLog(@"beginGotoUploadDataFun 接收到上传完成")
        frpUploadModel *model = [[frpUploadModel alloc] initWithDictionary:responseObject error:nil];
        if(model && model.position == curUploadModel.totalBytes){
            curUploadModel.curUploadStateType = uploadStateDone;
            [weakSelf nasUploadFileChangeingOneFileFunBy:curUploadModel];
            [weakSelf uploadFileDoneOneFunWith:curUploadModel];
            [weakSelf deleteCacheDataBy:curUploadModel];
        }
        
    } faild:^(NSError * _Nonnull error) {
        curUploadModel.curUploadStateType = uploadStateFail;
        [weakSelf nasUploadFileChangeingOneFileFunBy:curUploadModel];
        [weakSelf uploadFileFailOneFunWith:curUploadModel];
        [weakSelf deleteCacheDataBy:curUploadModel];
    }];
    
    [self beginUploadFileFun];
}


#pragma mark 上传完成 清理缓存
- (void)deleteCacheDataBy:(uploadFileDataModel*)uploadFileDataMod
{
    uploadFileDataMod.imageData = nil;
    uploadFileDataMod.videoData = nil;
    
    if(uploadFileDataMod.curUploadFileType == uploadFileTypeVideo){
        [cachesFileManager removeItemAtPath:uploadFileDataMod.filename type:uploadFileTypeVideo error:nil];
    }
    
    uploadFileDataMod = nil;
}



#pragma mark 更新数据状态
- (void)nasUploadFileChangeingOneFileFunBy:(uploadFileDataModel*)dataModel
{
    
    if(dataModel.curUploadStateType == uploadStateDone){
        //[_fileModelDataArr removeObject:dataModel];
        [self handleDatabaseArrDeleteObjectInUploading:dataModel];
        [self handleDatabaseArrAddObjectInDone:dataModel];
    }
    else if(dataModel.curUploadStateType == uploadStateFail){
        //[_fileModelDataArr removeObject:dataModel];
        
        //删除操作导致的失败
        NSMutableArray *ingArr = _databaseArr[0];
        NSInteger count = ingArr.count;
        if(count == 0){
            return;
        }
        
        [self handleDatabaseArrDeleteObjectInUploading:dataModel];
        [self handleDatabaseArrAddObjectInFail:dataModel];
    }

    dataModel.bg_tableName = nasUpLoadFile_tableName;
    [dataModel bg_saveOrUpdateAsync:^(BOOL isSuccess) {
        HLog(@"%@ 写入 %@", dataModel.filename, isSuccess ? @"成功":@"失败");
    }];
        
    
    if(!_isSuspendType || dataModel.curUploadStateType != uploadStateSuspend){
        [[NSNotificationCenter defaultCenter] postNotificationName:uploadFileRefreshNotification object:dataModel];
    }
    
}

#pragma mark 删除上传中的任务
- (void)handleDatabaseArrDeleteObjectInUploading:(uploadFileDataModel*)model
{
    NSLock *lock = [NSLock new];
    [lock lock];
    if(_databaseArr && _databaseArr.count == 3 ){
        
        NSMutableArray *ingArr = _databaseArr[0];
        NSInteger count = ingArr.count;
        [ingArr removeObject:model];
        
        NSInteger atferDelCount = ingArr.count;
        
        if(count == atferDelCount){
            for (couldPhoneFileModel*preModel in ingArr) {
                if(preModel.bg_id.integerValue == model.bg_id.integerValue){
                    [ingArr removeObject:preModel];
                    break;
                }
            }
        }
    }
    [lock unlock];
}

#pragma mark 添加任务到上传完成
- (void)handleDatabaseArrAddObjectInDone:(uploadFileDataModel*)model
{
    NSLock *lock = [NSLock new];
    [lock lock];
    if(_databaseArr && _databaseArr.count == 3 ){
        NSMutableArray *doneArr = _databaseArr[1];
        if(model){
            [doneArr insertObject:model atIndex:0];
        }
    }
    [lock unlock];
}

#pragma mark 添加任务到上传失败
- (void)handleDatabaseArrAddObjectInFail:(uploadFileDataModel*)model
{
    NSLock *lock = [NSLock new];
    [lock lock];
    if(_databaseArr && _databaseArr.count == 3 ){
        NSMutableArray *failArr = _databaseArr[2];
        if(model){
            [failArr insertObject:model atIndex:0];
        }

    }
    [lock unlock];
}

#pragma mark 上传完成一个任务
- (void)uploadFileDoneOneFunWith:(uploadFileDataModel*)dataModel
{
    @synchronized (self) {
        for (uploadFileDataModel*uploadingModel in _uploadingModelArr) {
            if(uploadingModel.bg_id.intValue == dataModel.bg_id.intValue
               && [uploadingModel.filename isEqualToString:dataModel.filename]){
                [_uploadingModelArr removeObject:uploadingModel];
                break;
            }
        }
    }
    
    [self beginUploadFileFun];
}

#pragma mark 上传失败一个任务
- (void)uploadFileFailOneFunWith:(uploadFileDataModel*)dataModel
{
    @synchronized (self) {
        for (uploadFileDataModel*uploadingModel in _uploadingModelArr) {
            if(uploadingModel.bg_id.intValue == dataModel.bg_id.intValue
               && [uploadingModel.filename isEqualToString:dataModel.filename]){
                [_uploadingModelArr removeObject:uploadingModel];
                break;
            }
        }
    }
    [self beginUploadFileFun];
}

#pragma mark 上传完成所有任务
- (void)didUploadAllTaskDoneFun
{
    self->_isUploadIngType = NO;
    self->_curUploadFileDataModel = nil;
    [[NSNotificationCenter defaultCenter] postNotificationName:uploadFileAllTaskDoneNotification object:nil];
}


#pragma mark 删除内存数据记录
- (void)handleDatabaseArrByDelete:(uploadFileDataModel*)delModel
{
    if(_databaseArr && _databaseArr.count == 3 ){
        
        NSMutableArray *uploadingArr = nil;
        
        if(delModel.curUploadStateType == uploadStateUploading
           ||delModel.curUploadStateType == uploadStateSuspend
           ||delModel.curUploadStateType == uploadStateWait){
            uploadingArr = _databaseArr[0];
        }
        else if(delModel.curUploadStateType == uploadStateDone)
        {
            uploadingArr = _databaseArr[1];
        }
        else{
            uploadingArr = _databaseArr[2];
        }
        
        [uploadingArr removeObject:delModel];
    }
}

#pragma mark 删除本地数据库记录
- (void)deleteUploadFileRecordBy:(NSMutableArray *)delArr withDelCache:(BOOL)isDelCache complete:(custom_complete_B)complete
{
    //
    BOOL isDelUploadingModel = NO;
    
    NSMutableArray *curDelArr = [NSMutableArray arrayWithArray:delArr];
    for (uploadFileDataModel *uploadFileDataMod in curDelArr) {
        
        //1.删除数据库
        NSMutableString* where = [[NSMutableString alloc] initWithString:@"where "];
        NSString *curStr =  [NSString stringWithFormat:@"%@=%@ ",bg_sqlKey(@"bg_id"),bg_sqlValue(uploadFileDataMod.bg_id)];
        [where appendString:curStr];
        //isSuc = [uploadFileDataModel bg_delete:nasUpLoadFile_tableName where:where];
        [uploadFileDataModel bg_deleteAsync:nasUpLoadFile_tableName where:where complete:^(BOOL isSuccess) {
            if(isSuccess){
            }
        }];
        
        // 2.删除内存数据
        [self handleDatabaseArrByDelete:uploadFileDataMod];

        //3.删除缓存的本地数据
        if(isDelCache){
            //判断是否可以删除本地缓存
            if(_databaseArr && _databaseArr.count == 3 ){
                NSMutableArray *uploadingArr = _databaseArr[0];
                NSMutableArray *uploadDoneArr = _databaseArr[1];
                NSMutableArray *uploadFailArr = _databaseArr[2];
                
                
                BOOL isNeedDel = YES;
                for (uploadFileDataModel *baseUploadFileDataMod in uploadingArr) {
                    if([uploadFileDataMod.filename isEqualToString:baseUploadFileDataMod.filename] ){
                        isNeedDel = NO;
                        break;
                    }
                }
                
                if(isNeedDel){
                    for (uploadFileDataModel *baseUploadFileDataMod in uploadDoneArr) {
                        if([uploadFileDataMod.filename isEqualToString:baseUploadFileDataMod.filename] ){
                            isNeedDel = NO;
                            break;
                        }
                    }
                }
                
                if(isNeedDel){
                    for (uploadFileDataModel *baseUploadFileDataMod in uploadFailArr) {
                        if([uploadFileDataMod.filename isEqualToString:baseUploadFileDataMod.filename] ){
                            isNeedDel = NO;
                            break;
                        }
                    }
                }
                
                if(isNeedDel){
                    if(uploadFileDataMod.curUploadFileType == uploadFileTypeVideo){
                        [cachesFileManager removeItemAtPath:uploadFileDataMod.videoFirstImageName type:uploadFileTypeImage error:nil];
                        
                        [cachesFileManager removeItemAtPath:uploadFileDataMod.filename type:uploadFileTypeVideo error:nil];
                    }
                    else{
                        [cachesFileManager removeItemAtPath:uploadFileDataMod.filename type:uploadFileTypeImage error:nil];
                    }
                }
            }
        }
        
        if(!isDelCache){//上传报云机已经存在文件了 查询本地是否有任务记录
            [self handleRetryUploadAndDelRecordFun:uploadFileDataMod];
        }
        
        //是否在删除上传中的任务
       if(_fileModelDataArr && _fileModelDataArr.count >0)
       {
           for (uploadFileDataModel *curUploadFileDataMod in _fileModelDataArr)
           {
               if(curUploadFileDataMod.bg_id.integerValue == uploadFileDataMod.bg_id.integerValue){
                   [_fileModelDataArr removeObject:curUploadFileDataMod];
                   break;
               }
           }
       }
        
        if(!isDelUploadingModel){
            if(_uploadingModelArr && _uploadingModelArr.count >0)
            {
                for (uploadFileDataModel *curUploadFileDataMod in _uploadingModelArr)
                {
                    if(curUploadFileDataMod.bg_id.integerValue == uploadFileDataMod.bg_id.integerValue){
                        isDelUploadingModel = YES;
                        [[nasUploadManager shareInstance] cancelUploadTaskFun];
                        break;
                    }
                }
            }
        }
    }
    
    if(isDelUploadingModel){
        if(!_uploadingModelArr || _uploadingModelArr.count ==0){
            _isUploadIngType = NO;
        }
        
        if(_fileModelDataArr.count >=1){
            [self beginUploadFileFun];
        }
        else{
            _curUploadFileDataModel = nil;
            _isSuspendType = NO;
        }
    }
        
    uploadFileDataModel *RefreshUploadFileDataMod = nil;
    if(delArr.count >=  1){
        RefreshUploadFileDataMod = delArr.firstObject;
    }
    [[NSNotificationCenter defaultCenter] postNotificationName:uploadFileRefreshNotification object:RefreshUploadFileDataMod];
    
    complete(YES);
    
}

#pragma mark 处理重复上传文件的问题
- (void)handleRetryUploadAndDelRecordFun:(uploadFileDataModel *)uploadFileDataMod
{
    NSLock *lock = [NSLock new];
    [lock lock];
    
    if(!_databaseArr && _databaseArr.count != 3){
        return;
    }
    
    NSMutableArray * doneArr = _databaseArr[1];
    NSMutableArray * failArr = _databaseArr[2];
    
    BOOL isNeedDelType = YES;
    
    for (uploadFileDataModel *doneModel in doneArr) {
        if([doneModel.localIdentifier isEqualToString:uploadFileDataMod.localIdentifier]){
            isNeedDelType = NO;
            break;
        }
    }
    
    if(isNeedDelType){
        for (uploadFileDataModel *failModel in failArr) {
            if([failModel.localIdentifier isEqualToString:uploadFileDataMod.localIdentifier]){
                isNeedDelType = NO;
                break;
            }
        }
    }
    
    if(isNeedDelType){
        if(uploadFileDataMod.curUploadFileType == uploadFileTypeVideo){
            [cachesFileManager removeItemAtPath:uploadFileDataMod.videoFirstImageName type:uploadFileTypeImage error:nil];
            
            [cachesFileManager removeItemAtPath:uploadFileDataMod.filename type:uploadFileTypeVideo error:nil];
        }
        else{
            [cachesFileManager removeItemAtPath:uploadFileDataMod.filename type:uploadFileTypeImage error:nil];
        }
    }
    else{//视频文件是要删除的
        if(uploadFileDataMod.curUploadFileType == uploadFileTypeVideo){
            [cachesFileManager removeItemAtPath:uploadFileDataMod.filename type:uploadFileTypeVideo error:nil];
        }
    }
    
    [lock unlock];
}

- (void)checkHadUploadTaskWithComplete:(custom_complete_B)complete
{
    [self getDataInDatabaseFun:NO complete:^(NSMutableArray * _Nonnull Arr) {
        mainBlock(^{
            if(!Arr || Arr.count != 3){
                complete(NO);
            }
            else{
                NSArray *firstArr = Arr[0];
                if(firstArr.count >0){
                    complete(YES);
                }
                else{
                    complete(NO);
                }
            }
        });
        
    }];
}

//文件重新上传
- (void)reUploadFileFunBy:(NSMutableArray*)Arr withAll:(BOOL)isAllType
{
    if(!Arr || Arr.count == 0){
        return;
    }
    
    if(!_fileModelDataArr){
        _fileModelDataArr = [NSMutableArray new];
    }
    
    //1.修改状态从失败改为上传中
    for (uploadFileDataModel * model in Arr) {
        model.curUploadStateType = uploadStateUploading;
        
        //修改已经读取的内存数据
        NSMutableArray * failArr = _databaseArr[2];
        for (uploadFileDataModel * failModel in failArr) {
            if(model.bg_id.integerValue == failModel.bg_id.integerValue){
                [failArr removeObject:failModel];
                break;
            }
        }
        
        //判断是否是新任务
        BOOL isNewTask = YES;
        for (uploadFileDataModel *preModel in _fileModelDataArr) {
            if(preModel.bg_id.integerValue == model.bg_id.integerValue){
                isNewTask = NO;
                break;
            }
        }
        
        //添加到等待上传列表
        if(isNewTask){
            [_fileModelDataArr insertObject:model atIndex:0];
        }
    }
    
    //2、保存到数控库
    [uploadFileDataModel bg_saveOrUpdateArrayAsync:Arr complete:^(BOOL isSuccess) {
        
    }];
    
    
    //开始上传
    [self beginUploadFileFun];
   
}

//暂停上传 当 isSuspendAll为NO时候 传指定暂停哪一个
- (void)suspendUploadFileFun:(BOOL)isSuspendAll withModel:(uploadFileDataModel*)model
{
    [[nasUploadManager shareInstance] cancelUploadTaskFun];
    
    [self deleteUploadingTaskBy:isSuspendAll withModel:model];
}

#pragma mark 删除任务
- (void)deleteUploadingTaskBy:(BOOL)isDeleteAll withModel:(uploadFileDataModel*)model
{
    if(isDeleteAll){
        [_fileModelDataArr removeAllObjects];
        [_uploadingModelArr removeAllObjects];
    }
    else{
        
        //更新数据库
        [uploadFileDataModel bg_saveOrUpdateArrayAsync:@[model] complete:^(BOOL isSuccess) {
            
        }];
        
        
        for (uploadFileDataModel *preModel in _fileModelDataArr) {
            if(preModel.bg_id.integerValue == model.bg_id.integerValue){
                [_fileModelDataArr removeObject:preModel];
                break;
            }
        }
        
        for (uploadFileDataModel *preModel in _uploadingModelArr) {
            if(preModel.bg_id.integerValue == model.bg_id.integerValue){
                [_uploadingModelArr removeObject:preModel];
                break;
            }
        }
        
        [self beginUploadFileFun];
    }
}
@end