整点视频 v3.3.0版本的 MD5 值为:cba0457dc37421eed445b30f92de25d3

以下内容为反编译后的 o0O0O00.java 源代码,内容仅作参考


package com.ys.resemble.util;

import com.ys.resemble.app.AppApplication;
import com.ys.resemble.entity.ApiconfEntry;
import com.ys.resemble.util.OkHttp3Util;
import io.reactivex.Flowable;
import io.reactivex.annotations.NonNull;
import io.reactivex.functions.Function;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.TimeUnit;
import me.goldze.mvvmhabit.base.BaseApplication;
import me.goldze.mvvmhabit.http.NetworkUtil;
import me.jessyan.retrofiturlmanager.RetrofitUrlManager;
import okhttp3.Response;
import org.reactivestreams.Publisher;
public class o0O0O00 implements Function<Flowable<Throwable>, Publisher<?>> {
    private int OooO0O0;
    private int OooO0OO = -1;
    private boolean OooO0Oo = false;
    private final int OooO00o = 1000;

    public class OooO00o implements Function<Throwable, Publisher<?>> {
        OooO00o() {
        }

        @Override
        public Publisher<?> apply(@NonNull Throwable th) throws Exception {
            if (OooOOO0.OooO0Oo(BaseApplication.OooO00o()) || OooOOO0.OooOoo0()) {
                return null;
            }
            if (NetworkUtil.isNetworkAvailable(BaseApplication.OooO00o())) {
                if (AppApplication.OooO0o0.size() > 0) {
                    if (!o0O0O00.this.OooO0Oo) {
                        o0O0O00 o0o0o00 = o0O0O00.this;
                        o0o0o00.OooO0o(AppApplication.OooO0o0, o0o0o00.OooO0OO);
                        me.goldze.mvvmhabit.utils.OooOO0.OooO0Oo("wangyi", "get error, it will try after " + o0O0O00.this.OooO00o + " millisecond, retry count " + o0O0O00.this.OooO0O0);
                        return Flowable.timer(o0O0O00.this.OooO00o, TimeUnit.MILLISECONDS);
                    }
                } else if (!o0O0O00.this.OooO0Oo) {
                    o0O0O00.this.OooO0oO();
                    me.goldze.mvvmhabit.utils.OooOO0.OooO0Oo("wangyi", "get net error, it will try after " + o0O0O00.this.OooO00o + " millisecond, retry count " + o0O0O00.this.OooO0O0);
                    return Flowable.timer(o0O0O00.this.OooO00o, TimeUnit.MILLISECONDS);
                }
            }
            return Flowable.error(th);
        }
    }

    public class OooO0O0 implements OkHttp3Util.OkHttpCallBack {
        OooO0O0(o0O0O00 o0o0o00) {
        }

        @Override
        public void onFailure(IOException iOException) {
        }

        @Override
        public void onSuccess(Response response) {
            try {
                String trim = response.body().string().trim();
                o0000.Ooooooo(trim);
                RetrofitUrlManager.getInstance().setGlobalDomain(trim);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void OooO0o(List<ApiconfEntry> list, int i) {
        int i2 = i + 1;
        if (i2 >= list.size()) {
            OooO0oO();
            return;
        }
        for (int i3 = 0; i3 < list.size(); i3++) {
            if (i3 == i2) {
                if (list.get(i3).getIs_open() != 1 && o0000.OooOO0O() != 1) {
                    i2++;
                    this.OooO0OO = i3;
                } else {
                    o0000.Ooooooo(list.get(i3).getApi());
                    this.OooO0OO = i3;
                    RetrofitUrlManager.getInstance().setGlobalDomain(o0000.OooOOO());
                    return;
                }
            }
        }
    }

    @Override
    public Publisher<?> apply(@NonNull Flowable<Throwable> flowable) throws Exception {
        return flowable.flatMap(new OooO00o());
    }

    public void OooO0oO() {
        me.goldze.mvvmhabit.utils.OooOO0.OooO0Oo("wangyi", "进入了");
        this.OooO0Oo = true;
        OkHttp3Util.OooO00o("https://errdom.oss-cn-heyuan.aliyuncs.com/common/error.png", new OooO0O0(this));
    }
}