/// 網(wǎng)絡(luò)請(qǐng)求&重用機(jī)制
    /// - Parameters:
    ///   - target: target description
    ///   - model: model description
    ///   - delay: delay description
    ///   - max: max description
    ///   - callbackQueue: callbackQueue description
    ///   - progress: progress description
    ///   - completion: completion description
    static func cz_request<T: BaseMappable>(target: TargetType,
                                            model: T.Type,
                                            delay: Double = 3,
                                            max: Int = 3,
                                            callbackQueue: DispatchQueue? = .none,
                                            progress: ProgressBlock? = .none,
                                            completion: @escaping (_ result: Result<T, CZError>) -> Void) {
        cz_provider.request(MultiTarget(target), callbackQueue: callbackQueue, progress: progress) { (result) in
            switch result {
            case let .success(response):
                do {
                    let _ = try response.filterSuccessfulStatusCodes()
                } catch {
                    completion(.failure(CZError("數(shù)據(jù)獲取失敗")))
                }
                do {
                    let jsonDict = try response.mapJSON()
                    if let model = Mapper<T>(context: nil).map(JSONObject: jsonDict) {
                        completion(.success(model))
                    } else {
                        completion(.failure(CZError("數(shù)據(jù)解析失敗")))
                    }
                } catch {
                    completion(.failure(CZError("json格式有誤")))
                }
                
            case .failure(_):
                if max == 1 {
                    completion(.failure(CZError("似乎已斷開(kāi)與互聯(lián)網(wǎng)的連接")))
                } else { // 重試
                    DispatchQueue(label: "com.request.queue", attributes: .concurrent).asyncAfter(deadline: DispatchTime.now() + delay) {
                        cz_request(target: target, model: model, delay: delay, max: max - 1, completion: completion)
                    }
                }
            }
        }
    }
    
    /// 網(wǎng)絡(luò)請(qǐng)求&重用機(jī)制(RxSwift)
    /// - Parameters:
    ///   - target: target description
    ///   - model: model description
    ///   - delay: delay description
    ///   - max: max description
    ///   - callbackQueue: callbackQueue description
    ///   - progress: progress description
    static func cz_request<T: BaseMappable>(target: TargetType,
                                            model: T.Type,
                                            delay: Double = 3,
                                            max: Int = 3,
                                            callbackQueue: DispatchQueue? = .none,
                                            progress: ProgressBlock? = .none) -> Single<T>  {
        return Single.create { single in
            let cancellableToken = cz_provider.request(MultiTarget(target), callbackQueue: callbackQueue, progress: progress) { result in
                switch result {
                case let .success(response):
                    do {
                        let _ = try response.filterSuccessfulStatusCodes()
                    } catch {
                        single(.error(CZError("數(shù)據(jù)獲取失敗")))
                    }
                    do {
                        let jsonDict = try response.mapJSON()
                        if let model = Mapper<T>(context: nil).map(JSONObject: jsonDict) {
                            single(.success(model))
                        } else {
                            single(.error(CZError("數(shù)據(jù)解析失敗")))
                        }
                    } catch {
                        single(.error(CZError("json格式有誤")))
                    }
                case .failure(_):
                    single(.error(CZError("似乎已斷開(kāi)與互聯(lián)網(wǎng)的連接")))
                }
            }

            return Disposables.create {
                cancellableToken.cancel()
            }
        }.retryWhen(retryHandler(delay: Int(delay),max: max))
        
    }

/// 重試
/// - Parameter delay: 每幾秒重試
/// - Parameter max: 最大重試次數(shù)
public func retryHandler(delay: Int = 5, max: Int = 5) -> ((Observable<Error>) -> Observable<Int>) {
    return { error in
        return error.enumerated().flatMap { (index, error) -> Observable<Int> in
            guard index < max else {
                return Observable.error(error)
            }
            return Observable<Int>.timer(.seconds(delay), scheduler: MainScheduler.instance)
        }
    }
}