// // boxDownloadFileManager.m // 双子星云手机 // // Created by xd h on 2024/5/24. // #import "boxDownloadFileManager.h" @implementation boxDownloadFileManager static boxDownloadFileManager * cur_boxDownloadFileShareInstance = nil; +(boxDownloadFileManager *)shareInstance; { static dispatch_once_t onceToken; dispatch_once(&onceToken, ^{ cur_boxDownloadFileShareInstance = [[boxDownloadFileManager alloc] init]; }); return cur_boxDownloadFileShareInstance; } - (id)init { self = [super init]; if (self) { //[self initManager]; [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(downloadTaskExeEnd:) name:SGDownloadTaskExeEnd object:nil]; [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(downloadTaskExeError:) name:SGDownloadTaskExeError object:nil]; } return self; } //添加保存记录 - (void)addBoxDownloadRecordFunBy:(NSArray*)arr complete:(custom_complete_B)complete{ if(arr && arr.count >0 ){ for (ShareFileDataModel*model in arr) { model.bg_tableName = share_box_download_tableName; } KWeakSelf //[ShareFileDataModel bg_saveOrUpdateArray:arr]; [ShareFileDataModel bg_saveOrUpdateArrayAsync:arr complete:^(BOOL isSuccess) { [weakSelf beginDownloadFilesByUrls:arr]; complete(isSuccess); }]; } } #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]; [ShareFileDataModel bg_findAsync:share_box_download_tableName limit:0 orderBy:nil desc:YES complete:^(NSArray * _Nullable array) { NSMutableArray *failArr = [NSMutableArray new]; NSMutableArray *doneArr = [NSMutableArray new]; NSMutableArray *otherArr = [NSMutableArray new]; if(array && array.count >0){ for (ShareFileDataModel * curModel in array) { if(curModel.downloadBoxStateType == downloadBoxStateFail){ [failArr addObject:curModel]; } else if(curModel.downloadBoxStateType == downloadBoxStateDone){ [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]; //}); } - (void)handleDatabaseArrByDelete:(ShareFileDataModel*)delModel { if(_databaseArr && _databaseArr.count == 3 ){ if(delModel.downloadBoxStateType == downloadBoxStateDone) { NSMutableArray *arr = _databaseArr[1]; [self deteleModel:delModel inArr:arr]; } else if(delModel.downloadBoxStateType == downloadBoxStateFail){ NSMutableArray *arr = _databaseArr[2]; [self deteleModel:delModel inArr:arr]; } else{ NSMutableArray *arr = _databaseArr[0]; [self deteleModel:delModel inArr:arr]; } } } #pragma mark 处理删除内存数据 - (void)deteleModel:(ShareFileDataModel*)delModel inArr:(NSMutableArray*)delArr{ for (ShareFileDataModel *dataModel in delArr) { if(delModel.bg_id.integerValue == dataModel.bg_id.integerValue){ [delArr removeObject:dataModel]; break;; } } } #pragma mark 删除本地数据库记录 - (void)deleteBoxSaveFileRecordBy:(NSMutableArray *)delArr{ NSMutableArray *curDelArr = [NSMutableArray arrayWithArray:delArr]; for (ShareFileDataModel *dataModel in curDelArr) { //1.内存数据删除 [self handleDatabaseArrByDelete:dataModel]; //2.删除数据量 NSMutableString* where = [[NSMutableString alloc] initWithString:@"where "]; NSString *curStr = [NSString stringWithFormat:@"%@=%@ ",bg_sqlKey(@"bg_id"),bg_sqlValue(dataModel.bg_id)]; [where appendString:curStr]; [ShareFileDataModel bg_deleteAsync:share_box_download_tableName where:where complete:^(BOOL isSuccess) { if(isSuccess){ } }]; //3.取消下载 NSString *urlString = dataModel.fileUrl; NSString *requestURLEncodedString = [urlString stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]; [[SGDownloadManager shareManager] cancelDownloadWithUrl:requestURLEncodedString]; } } #pragma mark 更新本地数据库记录 - (void)updataBoxSaveDataInFailBy:(ShareFileDataModel*)dataModel { //1.修改数据库 if(_databaseArr.count == 3){ NSMutableArray *failArr = _databaseArr[2]; NSMutableArray *ingArr = _databaseArr[0]; for (ShareFileDataModel* model in failArr) { if (dataModel.bg_id.integerValue == model.bg_id.integerValue) { [failArr removeObject:model]; [ingArr addObject:dataModel]; } } } [dataModel bg_saveOrUpdateAsync:^(BOOL isSuccess) { }]; } #pragma mark 开始下载文件 - (void)beginDownloadFilesByUrls:(NSArray *)urlArr{ // NSMutableArray*arr = [[SGDownloadManager shareManager] getAllOperation]; // if(arr && arr.count > 0){ // HLog(@"有任务正在下载"); // [[SGDownloadManager shareManager] startAllDownloadTask]; // return; // } for (ShareFileDataModel *fileModel in urlArr) { NSString *urlString = fileModel.fileUrl; NSString *requestURLEncodedString = [urlString stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]; NSURL *curUrl = [NSURL URLWithString:requestURLEncodedString]; // 创建下载任务 // [[SGDownloadManager shareManager] downloadWithURL:curUrl // complete:^(NSDictionary *respose, NSError *error) { // HLog(@"%@---%@",respose, error); // }]; [[SGDownloadManager shareManager] downloadWithURL:curUrl fileType:1 fileSize:0 complete:^(NSDictionary *respose, NSError *error) { HLog(@"%@---%@",respose, error); }]; //测试 每次只跑一个 //break; } } - (void)downloadTaskExeIng:(NSNotification *)notification { SGDownloadOperation *model = notification.userInfo.allValues.firstObject; [self handldDownloadingDataBy:model]; } - (void)downloadTaskExeEnd:(NSNotification *)notification { SGDownloadOperation *model = notification.userInfo.allValues.firstObject; [self handldDownloadDoneDataBy:model]; HLog(@"下载成功"); } - (void)downloadTaskExeError:(NSNotification *)notification { SGDownloadOperation *model = notification.userInfo.allValues.firstObject; [self handldDownloadFailDataBy:model]; HLog(@"下载失败"); } #pragma mark 下载中数据回调处理 - (void)handldDownloadingDataBy:(SGDownloadOperation*)model { //解码 NSString * urlString = [model.url stringByReplacingPercentEscapesUsingEncoding:NSUTF8StringEncoding]; if(_databaseArr && _databaseArr.count == 3 ){ NSMutableArray *ingArr = _databaseArr[0]; for (ShareFileDataModel*dataModel in ingArr) { //HLog(@"22222222 %@\n%@",urlString,dataModel.fileUrl); if([urlString isEqualToString:dataModel.fileUrl]){ dataModel.downloadBoxStateType = downloadBoxStateDownloadloading; dataModel.totalSize = model.totalSize; dataModel.currentSize = model.currentSize; //更新数据库 [dataModel bg_saveOrUpdateAsync:^(BOOL isSuccess) { }]; break; } } } } #pragma mark 下载完成数据回调处理 - (void)handldDownloadDoneDataBy:(SGDownloadOperation*)model { //解码 NSString * urlString = [model.url stringByReplacingPercentEscapesUsingEncoding:NSUTF8StringEncoding]; if(_databaseArr && _databaseArr.count == 3 ){ NSMutableArray *ingArr = _databaseArr[0]; for (ShareFileDataModel*dataModel in ingArr) { //HLog(@"22222222 %@\n%@",urlString,dataModel.fileUrl); if([urlString isEqualToString:dataModel.fileUrl]){ [self handleDatabaseArrByDelete:dataModel]; dataModel.downloadBoxStateType = downloadBoxStateDone; NSMutableArray *doneArr = _databaseArr[1]; [doneArr insertObject:dataModel atIndex:0]; //更新数据库 [dataModel bg_saveOrUpdateAsync:^(BOOL isSuccess) { }]; break; } } } } #pragma mark 下载失败数据回调处理 - (void)handldDownloadFailDataBy:(SGDownloadOperation*)model { //解码 NSString * urlString = [model.url stringByReplacingPercentEscapesUsingEncoding:NSUTF8StringEncoding]; if(_databaseArr && _databaseArr.count == 3 ){ NSMutableArray *ingArr = _databaseArr[0]; for (ShareFileDataModel*dataModel in ingArr) { //HLog(@"22222222 %@\n%@",urlString,dataModel.fileUrl); if([urlString isEqualToString:dataModel.fileUrl]){ [self handleDatabaseArrByDelete:dataModel]; dataModel.downloadBoxStateType = downloadBoxStateFail; NSMutableArray *failArr = _databaseArr[2]; [failArr insertObject:dataModel atIndex:0]; //更新数据库 [dataModel bg_saveOrUpdateAsync:^(BOOL isSuccess) { }]; break; } } } } @end