+ (instancetype)manager {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
_instance = [[self alloc] init];
});
return _instance;
}
- (instancetype)init {
if (self = [super init]) {
[self getDownloadItems];
[self initOSSClient];
if(!self.allUplaodReceipts) self.allUplaodReceipts = [NSMutableDictionary dictionary];
[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(saveUploadItems) name:kYCUploadSessionSaveUploadStatus object:nil];
}
return self;
}
简单上传
- (OSSPutObject *)uploadReceiptForModel:(DiskCloudDiskModel *)model withCell:(MyDiskFileCell *)cell IndexPath:(NSIndexPath *)indexPath{
if (model.urlOutputPath == nil) return nil;
DiskCloudDiskModel * oldModel = self.allUplaodReceipts[[NSString stringWithFormat:@"%@",model.Oid]];
OSSPutObject *receipt = oldModel.putObject;
if (receipt && oldModel.isShowPress) return receipt;
receipt = [OSSPutObject new];
model.putObject = receipt;
receipt.bucketName = bucketNames;
receipt.objectKey = [NSString stringWithFormat:@"%@%@",[HSInstance shareInstance].userInfo.SessionID,[NSString timeStampAtNow]];
NSLog(@"%@",receipt.objectKey);
receipt.uploadingFileURL = model.urlOutputPath;
receipt.contentType = @"";
receipt.contentMd5 = @"";
receipt.contentEncoding = @"";
receipt.contentDisposition = @"";
AaronUploadItem * item = [AaronUploadItem new];
receipt.uploadProgress = ^(int64_t bytesSent, int64_t totalByteSent, int64_t totalBytesExpectedToSend) {
NSLog(@"%lld, %lld, %lld", bytesSent, totalByteSent, totalBytesExpectedToSend);
CGFloat progress = (CGFloat)totalByteSent/totalBytesExpectedToSend;
dispatch_async(dispatch_get_main_queue(), ^{
model.passValue = progress;
cell.progress = progress;
});
};
OSSTask *putTask = [clients putObject:receipt];
[putTask continueWithBlock:^id(OSSTask *task) {
if (!task.error) {
model.isShowPress = NO;
model.isUpload = NO;
[item uploadReceiptForcomplete];
if ([self.delegate respondsToSelector:@selector(uploadItemStatusChanged:)]) {
[self.delegate uploadItemStatusChanged:model];
}
NSLog(@"upload object success!");
} else {
NSLog(@"upload object failed, error: %@" , task.error);
}
return nil;
}];
[self.allUplaodReceipts setObject:model forKey:[NSString stringWithFormat:@"%@",model.Oid]];
[self saveUploadItems];
return receipt;
}
// 断点续传
- (void)resumableUploadModel:(DiskCloudDiskModel *)model withCell:(MyDiskFileCell *)cell IndexPath:(NSIndexPath *)indexPath {
__block NSString * recordKey;
// NSString * docDir = [self getDocumentDirectory];
// NSString * filePath = [docDir stringByAppendingPathComponent:@"file10m"];
NSString * bucketName = bucketNames;
NSString * objectKey = [NSString stringWithFormat:@"%@%@",[HSInstance shareInstance].userInfo.SessionID,[NSString timeStampAtNow]];
[[[[[[OSSTask taskWithResult:nil] continueWithBlock:^id(OSSTask *task) {
// 为该文件构造一个唯一的记录键
NSURL * fileURL = model.urlOutputPath;
NSDate * lastModified;
NSError * error;
[fileURL getResourceValue:&lastModified forKey:NSURLContentModificationDateKey error:&error];
if (error) {
return [OSSTask taskWithError:error];
}
recordKey = [NSString stringWithFormat:@"%@-%@-%@-%@", bucketName, objectKey, [OSSUtil getRelativePath:model.urlOutputPath.absoluteString], lastModified];
// 通过记录键查看本地是否保存有未完成的UploadId
NSUserDefaults * userDefault = [NSUserDefaults standardUserDefaults];
return [OSSTask taskWithResult:[userDefault objectForKey:recordKey]];
}] continueWithSuccessBlock:^id(OSSTask *task) {
if (!task.result) {
// 如果本地尚无记录，调用初始化UploadId接口获取
OSSInitMultipartUploadRequest * initMultipart = [OSSInitMultipartUploadRequest new];
initMultipart.bucketName = bucketName;
initMultipart.objectKey = objectKey;
initMultipart.contentType = @"application/octet-stream";
return [clients multipartUploadInit:initMultipart];
}
OSSLogVerbose(@"An resumable task for uploadid: %@", task.result);
return task;
}] continueWithSuccessBlock:^id(OSSTask *task) {
NSString * uploadId = nil;
if (task.error) {
return task;
}
if ([task.result isKindOfClass:[OSSInitMultipartUploadResult class]]) {
uploadId = ((OSSInitMultipartUploadResult *)task.result).uploadId;
} else {
uploadId = task.result;
}
if (!uploadId) {
return [OSSTask taskWithError:[NSError errorWithDomain:OSSClientErrorDomain
code:OSSClientErrorCodeNilUploadid
userInfo:@{OSSErrorMessageTOKEN: @"Can't get an upload id"}]];
}
// 将“记录键：UploadId”持久化到本地存储
NSUserDefaults * userDefault = [NSUserDefaults standardUserDefaults];
[userDefault setObject:uploadId forKey:recordKey];
[userDefault synchronize];
return [OSSTask taskWithResult:uploadId];
}] continueWithSuccessBlock:^id(OSSTask *task) {
// 持有UploadId上传文件
OSSResumableUploadRequest * resumableUpload = [OSSResumableUploadRequest new];
resumableUpload.bucketName = bucketName;
resumableUpload.objectKey = objectKey;
resumableUpload.uploadId = task.result;
model.resumableUpload = resumableUpload;
resumableUpload.uploadingFileURL = model.urlOutputPath;
resumableUpload.uploadProgress = ^(int64_t bytesSent, int64_t totalBytesSent, int64_t totalBytesExpectedToSend) {
NSLog(@"%lld %lld %lld", bytesSent, totalBytesSent, totalBytesExpectedToSend);
CGFloat progress = (CGFloat)totalBytesSent/totalBytesExpectedToSend;
dispatch_async(dispatch_get_main_queue(), ^{
model.passValue = progress;
cell.progress = progress;
});
};
return [clients resumableUpload:resumableUpload];
}] continueWithBlock:^id(OSSTask *task) {
if (task.error) {
if ([task.error.domain isEqualToString:OSSClientErrorDomain] && task.error.code == OSSClientErrorCodeCannotResumeUpload) {
// 如果续传失败且无法恢复，需要删除本地记录的UploadId，然后重启任务
[[NSUserDefaults standardUserDefaults] removeObjectForKey:recordKey];
}
} else {
NSLog(@"upload completed!");
// 上传成功，删除本地保存的UploadId
[[NSUserDefaults standardUserDefaults] removeObjectForKey:recordKey];
}
return nil;
}];
}
#pragma mark- OSS Method/* STS */
- (void)initOSSClient {
idcredential2 = [[OSSFederationCredentialProvider alloc] initWithFederationTokenGetter:^OSSFederationToken * {
OSSTaskCompletionSource * tcs = [OSSTaskCompletionSource taskCompletionSource];
NSString * urlString = [BASE_URL(loginToken) stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding];
NSMutableDictionary *dict = [NSMutableDictionary dictionary];
[dict setValue:@"c432626a-1754-4874-8c1d-2fa4356188a8" forKey:@"SessionID"];
// 设置 指示器 无蒙板效果
AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
manager.requestSerializer = [AFJSONRequestSerializer serializer];
manager.responseSerializer = [AFJSONResponseSerializer serializer];
[manager.requestSerializer setValue:@"c432626a-1754-4874-8c1d-2fa4356188a8" forHTTPHeaderField:@"SessionID"];
[manager POST:urlString parameters:dict progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {
NSLog(@"OSSTaskCompletionSource responseObject = %@",responseObject);
self.responseObject = responseObject[@"token"];
[tcs setResult:responseObject];
} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
NSLog(@"%@",error);
if (error) {
[tcs setError:error];
return;
}
}];
//同步
[tcs.task waitUntilFinished];
if (tcs.task.error) {
NSLog(@"get token error: %@", tcs.task.error);
return nil;
}
else {
//获取token返回的参数
OSSFederationToken * token = [OSSFederationToken new];
NSDictionary * dict = self.responseObject[@"Credentials"];
token.tAccessKey = [dict objectForKey:@"AccessKeyId"];
token.tSecretKey = [dict objectForKey:@"AccessKeySecret"];
token.tToken = [dict objectForKey:@"SecurityToken"];
token.expirationTimeInGMTFormat = [dict objectForKey:@"Expiration"];
NSLog(@"get token: %@", token);
return token;
}
}];
OSSClientConfiguration * conf = [OSSClientConfiguration new];
conf.maxRetryCount = 1;
conf.maxConcurrentRequestCount = 1;
conf.timeoutIntervalForRequest = 30;
conf.timeoutIntervalForResource = 24 * 60 * 60;
clients = [[OSSClient alloc] initWithEndpoint:endPoints credentialProvider:credential2 clientConfiguration:conf];
}
