整点视频 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));
}
}