JSJP_Student/Pods/Qiniu/QiniuSDK/Storage/QNUpProgress.m

//
//  QNUpProgress.m
//  QiniuSDK
//
//  Created by yangsen on 2021/5/21.
//  Copyright © 2021 Qiniu. All rights reserved.
//

#import "QNAsyncRun.h"
#import "QNUpProgress.h"

@interface QNUpProgress()

@property(nonatomic, assign)long long maxProgressUploadBytes;
@property(nonatomic, assign)long long previousUploadBytes;
@property(nonatomic,  copy)QNUpProgressHandler progress;
@property(nonatomic,  copy)QNUpByteProgressHandler byteProgress;

@end
@implementation QNUpProgress

+ (instancetype)progress:(QNUpProgressHandler)progress byteProgress:(QNUpByteProgressHandler)byteProgress {
    QNUpProgress *upProgress = [[QNUpProgress alloc] init];
    upProgress.maxProgressUploadBytes = -1;
    upProgress.previousUploadBytes = 0;
    upProgress.progress = progress;
    upProgress.byteProgress = byteProgress;
    return upProgress;
}

- (void)progress:(NSString *)key uploadBytes:(long long)uploadBytes totalBytes:(long long)totalBytes {
    if ((self.progress == nil && self.byteProgress == nil) || uploadBytes < 0 || (totalBytes > 0 && uploadBytes > totalBytes)) {
        return;
    }
    
    if (totalBytes > 0) {
        if (self.maxProgressUploadBytes < 0) {
            self.maxProgressUploadBytes = totalBytes * 0.95;
        }
        
        if (uploadBytes > self.maxProgressUploadBytes) {
            return;
        }
    }
    
    if (uploadBytes > self.previousUploadBytes) {
        self.previousUploadBytes = uploadBytes;
    } else {
        return;
    }
    
    if (self.byteProgress) {
        QNAsyncRunInMain(^{
            self.byteProgress(key, self.previousUploadBytes, totalBytes);
        });
        return;
    }
    
    if (totalBytes < 0) {
        return;
    }
    
    if (self.progress) {
        QNAsyncRunInMain(^{
            double notifyPercent = (double) uploadBytes / (double) totalBytes;
            self.progress(key, notifyPercent);
        });
    }
}

- (void)notifyDone:(NSString *)key totalBytes:(long long)totalBytes {
    if (self.progress == nil && self.byteProgress == nil) {
        return;
    }
    
    if (self.byteProgress) {
        QNAsyncRunInMain(^{
            self.byteProgress(key, totalBytes, totalBytes);
        });
        return;
    }
    
    if (self.progress) {
        QNAsyncRunInMain(^{
            self.progress(key, 1);
        });
    }
}

@end