佳GO v3.0.0版本的 MD5 值为:febdbe251c5346d8ea051b2f02d4ce89
以下内容为反编译后的 TestActivity.java 源代码,内容仅作参考
package com.getmessage.lite.view;
import android.app.Activity;
import android.app.ProgressDialog;
import android.net.Uri;
import android.os.Bundle;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;
import androidx.annotation.Nullable;
import androidx.databinding.DataBindingUtil;
import com.blankj.utilcode.util.LogUtils;
import com.blankj.utilcode.util.NetworkUtils;
import com.getmessage.lite.databinding.TestActivityBinding;
import com.getmessage.lite.model.bus_event.TestMsgEvent;
import com.getmessage.lite.view.TestActivity;
import com.getmessage.module_base.app.BaseApplication;
import com.getmessage.module_base.model.bean.database_table.ConversationBean;
import com.getmessage.module_base.model.bean.database_table.GroupBean;
import com.getmessage.module_base.model.bean.database_table.MsgBean;
import com.getmessage.module_base.model.bean.msg_content.TextMsgContent;
import com.herthr.rthth.R;
import com.meizu.cloud.pushsdk.pushtracer.constant.Parameters;
import io.reactivex.android.schedulers.AndroidSchedulers;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import okhttp3.ResponseBody;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;
import p.a.y.e.a.s.e.net.bz0;
import p.a.y.e.a.s.e.net.cc3;
import p.a.y.e.a.s.e.net.dx2;
import p.a.y.e.a.s.e.net.dz0;
import p.a.y.e.a.s.e.net.fp3;
import p.a.y.e.a.s.e.net.g8;
import p.a.y.e.a.s.e.net.gt3;
import p.a.y.e.a.s.e.net.hz0;
import p.a.y.e.a.s.e.net.j21;
import p.a.y.e.a.s.e.net.j51;
import p.a.y.e.a.s.e.net.ky2;
import p.a.y.e.a.s.e.net.ly2;
import p.a.y.e.a.s.e.net.m62;
import p.a.y.e.a.s.e.net.mb3;
import p.a.y.e.a.s.e.net.p11;
import p.a.y.e.a.s.e.net.p8;
import p.a.y.e.a.s.e.net.qz0;
import p.a.y.e.a.s.e.net.r5;
import p.a.y.e.a.s.e.net.tx2;
import p.a.y.e.a.s.e.net.uz0;
import p.a.y.e.a.s.e.net.vx2;
import p.a.y.e.a.s.e.net.ws3;
import p.a.y.e.a.s.e.net.wx2;
import p.a.y.e.a.s.e.net.zw1;
public class TestActivity extends Activity {
public static String lite_finally = "";
public static boolean lite_package;
private AtomicInteger lite_boolean;
private AtomicInteger lite_default;
private List<GroupBean> lite_extends = dz0.lite_int();
private TestActivityBinding lite_static;
public ky2 lite_switch;
private ProgressDialog lite_throws;
public class a implements View.OnClickListener {
public class C0026a extends mb3<Integer> {
public C0026a() {
}
@Override
public void onNext(Integer num) {
TestActivity.this.lite_static.lite_abstract.setText("所有会话列表的所有消息数:" + num);
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable th) {
th.printStackTrace();
}
}
public class b implements wx2<Integer> {
public b() {
}
@Override
public void lite_do(vx2<Integer> vx2Var) throws Exception {
List<ConversationBean> lite_try = bz0.lite_case().lite_try(BaseApplication.getInstance().getUserInfoBean().getUser_uid());
int i = 0;
for (int i2 = 0; i2 < lite_try.size(); i2++) {
i += hz0.lite_double().lite_class(lite_try.get(i2).getCounterId());
}
vx2Var.onNext(Integer.valueOf(i));
}
}
public a() {
}
private void lite_do() {
TestActivity.this.lite_long((ly2) tx2.p0(new b()).G4(cc3.lite_for()).Y2(AndroidSchedulers.mainThread()).H4(new C0026a()));
}
@Override
public void onClick(View view) {
lite_do();
}
}
public class b extends mb3<String> {
public b() {
}
@Override
public void onNext(String str) {
TestActivity.this.lite_static.lite_private.setText(str);
TestActivity.this.lite_static.lite_interface.start();
TestActivity.this.lite_throws.dismiss();
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable th) {
TestActivity.this.lite_throws.dismiss();
TextView textView = TestActivity.this.lite_static.lite_private;
StringBuilder b = r5.b("测试发生异常,不代表网络异常----");
b.append(th.getMessage());
textView.setText(b.toString());
}
}
public class c implements wx2<String> {
public c() {
}
@Override
public void lite_do(vx2<String> vx2Var) throws Exception {
StringBuilder b = r5.b("国内连通:\n");
TestActivity.this.lite_super(b, "HuaWei_http连通:", "---HuaWei_ping连通:", "http://www.huawei.com", "185.176.76.132");
TestActivity.this.lite_super(b, "Tencent_http连通:", "---Tencent_ping连通:", "http://www.qq.com", "220.194.111.148");
b.append("港澳连通:\n");
TestActivity.this.lite_super(b, "sinaHk_http连通:", "---sinaHk_ping连通:", "http://www.sina.com.hk", "173.252.102.16");
b.append("国际连通:\n");
TestActivity.this.lite_super(b, "google_http连通:", "---google_ping连通:", "http://www.google.com", "172.217.5.196");
vx2Var.onNext(b.toString());
}
}
public class d extends mb3<String> {
public d() {
}
@Override
public void onNext(String str) {
TestActivity.this.lite_throws.dismiss();
TestActivity.this.lite_static.lite_continue.setText(str);
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable th) {
TestActivity.this.lite_throws.dismiss();
TextView textView = TestActivity.this.lite_static.lite_continue;
StringBuilder b = r5.b("测试发生异常,不代表网络异常----");
b.append(th.getMessage());
textView.setText(b.toString());
}
}
public class e implements wx2<String> {
public e() {
}
@Override
public void lite_do(vx2<String> vx2Var) throws Exception {
StringBuilder sb = new StringBuilder();
dx2<gt3<ResponseBody>> B = qz0.B(uz0.lite_int(BaseApplication.getInstance().getConfig().getApiPath()), true);
if (B != null) {
long currentTimeMillis = System.currentTimeMillis();
gt3<ResponseBody> lite_byte = B.lite_byte();
if (lite_byte == null || lite_byte.lite_if() != 200) {
r5.K(sb, "Http连通:", "无法连通", "\n");
} else {
sb.append("Http连通:");
sb.append(System.currentTimeMillis() - currentTimeMillis);
sb.append(Parameters.MESSAGE_SEQ);
sb.append("\n");
boolean lite_throw = NetworkUtils.lite_throw(BaseApplication.getInstance().getConfig().getProjectHosts());
sb.append("ping连通:");
sb.append(lite_throw);
sb.append("\n");
}
}
vx2Var.onNext(sb.toString());
}
}
public class f extends mb3<String> {
public f() {
}
@Override
public void onNext(String str) {
TestActivity.this.lite_static.lite_strictfp.setText(str);
TestActivity.this.lite_throws.dismiss();
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable th) {
TestActivity.this.lite_throws.dismiss();
TextView textView = TestActivity.this.lite_static.lite_strictfp;
StringBuilder b = r5.b("测试发生异常,不代表网络异常----");
b.append(th.getMessage());
textView.setText(b.toString());
}
}
public class g implements wx2<String> {
public g() {
}
@Override
public void lite_do(vx2<String> vx2Var) throws Exception {
StringBuilder sb = new StringBuilder();
boolean lite_import = NetworkUtils.lite_import();
sb.append("是否连接网络:");
sb.append(lite_import);
sb.append("\n");
boolean lite_public = NetworkUtils.lite_public();
sb.append("是否使用移动数据:");
sb.append(lite_public);
sb.append("\n");
NetworkUtils.NetworkType lite_long = NetworkUtils.lite_long();
sb.append("当前网络:");
sb.append(lite_long.toString());
sb.append("\n");
if (lite_long == NetworkUtils.NetworkType.NETWORK_WIFI) {
boolean lite_void = NetworkUtils.lite_void();
sb.append("是否开启WiFi:");
sb.append(lite_void);
sb.append("\n");
if (lite_void && lite_import) {
String lite_new = NetworkUtils.lite_new();
sb.append("wifi登机口:");
sb.append(lite_new);
sb.append("\n");
String lite_else = NetworkUtils.lite_else();
sb.append("wifi网络掩码:");
sb.append(lite_else);
sb.append("\n");
String lite_case = NetworkUtils.lite_case();
sb.append("wifiIP地址:");
sb.append(lite_case);
sb.append("\n");
String lite_this = NetworkUtils.lite_this();
sb.append("wifi服务器地址:");
sb.append(lite_this);
sb.append("\n");
}
} else if ((lite_long == NetworkUtils.NetworkType.NETWORK_4G || lite_long == NetworkUtils.NetworkType.NETWORK_3G || lite_long == NetworkUtils.NetworkType.NETWORK_2G) && lite_import) {
String lite_goto = NetworkUtils.lite_goto();
sb.append("运营商名称:");
sb.append(lite_goto);
sb.append("\n");
}
vx2Var.onNext(sb.toString());
}
}
public class h implements View.OnClickListener {
public h() {
}
@Override
public void onClick(View view) {
TestActivity.this.lite_catch(false);
}
}
public class i implements View.OnClickListener {
public i() {
}
@Override
public void onClick(View view) {
TestActivity.this.lite_catch(true);
}
}
public class j implements View.OnClickListener {
public j() {
}
@Override
public void onClick(View view) {
TestActivity.this.finish();
}
}
public class k implements View.OnClickListener {
public k() {
}
@Override
public void onClick(View view) {
TestActivity.this.lite_while();
}
}
public class l implements View.OnClickListener {
public l() {
}
@Override
public void onClick(View view) {
TestActivity.this.lite_throw();
}
}
public class m implements View.OnClickListener {
public m() {
}
@Override
public void onClick(View view) {
TestActivity.this.lite_double();
}
}
public class n extends mb3<Long> {
public final boolean lite_boolean;
public final String lite_switch;
public final String lite_throws;
public n(String str, String str2, boolean z) {
this.lite_switch = str;
this.lite_throws = str2;
this.lite_boolean = z;
}
@Override
public void onNext(Long l) {
TestActivity.this.lite_float(TestActivity.this.lite_void(this.lite_switch + "********" + l), this.lite_throws, this.lite_boolean);
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable th) {
th.printStackTrace();
}
}
public class o extends mb3<Map<String, String>> {
public o() {
}
@Override
public void onNext(Map<String, String> map) {
if (map == null || !map.get("sendResult").equals(zw1.lite_synchronized)) {
return;
}
TestActivity.this.lite_boolean.set(TestActivity.this.lite_boolean.get() + 1);
EditText editText = TestActivity.this.lite_static.lite_default;
StringBuilder b = r5.b("发送消息数:");
b.append(TestActivity.this.lite_boolean.get());
b.append(";接收消息数:");
b.append(TestActivity.this.lite_default.get());
editText.setText(b.toString());
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable th) {
th.printStackTrace();
}
}
private void lite_break() {
this.lite_static.lite_abstract.setOnClickListener(new a());
this.lite_static.lite_boolean.setOnClickListener(new h());
this.lite_static.lite_package.setOnClickListener(new i());
this.lite_static.lite_extends.setOnClickListener(new j());
this.lite_static.lite_switch.setOnClickListener(new k());
this.lite_static.lite_static.setOnClickListener(new l());
this.lite_static.lite_throws.setOnClickListener(new m());
}
public void lite_catch(boolean z) {
int lite_void = g8.lite_char().lite_void("消息测试累加", 0);
String lite_class = r5.lite_class("消息测试发送", lite_void);
g8.lite_char().lite_while("消息测试累加", lite_void);
String lite_case = r5.lite_case(this.lite_static.lite_default);
if (r5.E(lite_case) == null) {
p8.lite_default("没有检索到此群信息 无法发送——监听!");
return;
}
lite_finally = lite_case;
lite_package = true;
this.lite_static.lite_boolean.setVisibility(8);
this.lite_static.lite_default.setEnabled(false);
this.lite_static.lite_default.setVisibility(0);
this.lite_static.lite_volatile.setVisibility(8);
this.lite_static.lite_volatile.setText("发送消息数:0;接收消息数:0");
g8.lite_char().lite_public("testMsgInfo", "发送消息数:0;接收消息数:0");
lite_short(lite_class, lite_case, z);
}
public void lite_const(boolean z, String str, MsgBean msgBean, vx2 vx2Var) throws Exception {
if (z) {
str = this.lite_extends.get(new Random().nextInt(this.lite_extends.size())).getG_id();
}
m62.lite_byte(r5.lite_throws("当前发送到的gid:", str), new Object[0]);
if (hz0.lite_double().lite_continue(msgBean, str)) {
m62.lite_byte("存储消息成功", new Object[0]);
lite_final(str, msgBean, vx2Var, j51.lite_byte(this, str, msgBean));
}
}
public void lite_double() {
this.lite_throws.show();
lite_long((ly2) tx2.p0(new c()).Y2(AndroidSchedulers.mainThread()).G4(cc3.lite_for()).H4(new b()));
}
public void lite_float(final MsgBean msgBean, final String str, final boolean z) {
lite_long((ly2) tx2.p0(new wx2() {
@Override
public final void lite_do(vx2 vx2Var) {
TestActivity.this.lite_const(z, str, msgBean, vx2Var);
}
}).Y2(AndroidSchedulers.mainThread()).G4(cc3.lite_for()).H4(new o()));
}
private void lite_short(String str, String str2, boolean z) {
lite_long((ly2) tx2.g2(0L, 2147483647L, 0L, 50L, TimeUnit.MILLISECONDS, cc3.lite_for()).Y2(AndroidSchedulers.mainThread()).H4(new n(str, str2, z)));
}
public void lite_super(StringBuilder sb, String str, String str2, String str3, String str4) {
try {
ws3<ResponseBody> S1 = qz0.L().S1(uz0.lite_char(str3));
sb.append(str);
sb.append(S1.execute().lite_char().code());
for (int i2 = 0; i2 < 1; i2++) {
long currentTimeMillis = System.currentTimeMillis();
boolean lite_throw = NetworkUtils.lite_throw(str4);
if (i2 == 0) {
sb.append(str2);
sb.append(lite_throw ? Long.valueOf(System.currentTimeMillis() - currentTimeMillis) : "X");
} else {
sb.append("--");
sb.append(lite_throw ? Long.valueOf(System.currentTimeMillis() - currentTimeMillis) : "X");
}
}
sb.append("\n");
} catch (Exception unused) {
sb.append("--X\n");
}
}
public void lite_throw() {
this.lite_throws.show();
lite_long((ly2) tx2.p0(new e()).Y2(AndroidSchedulers.mainThread()).G4(cc3.lite_for()).H4(new d()));
}
public MsgBean lite_void(String str) {
LogUtils.lite_class(str);
MsgBean createMeSendBaseMsg = MsgBean.createMeSendBaseMsg(10);
createMeSendBaseMsg.setMessage_mode(2);
TextMsgContent textMsgContent = new TextMsgContent();
textMsgContent.setContent(str);
textMsgContent.setAtInfo(j21.lite_char().lite_try());
j21.lite_char().lite_for();
createMeSendBaseMsg.setContent(p11.lite_do().toJson(textMsgContent));
createMeSendBaseMsg.setFromUid(BaseApplication.getInstance().getUserInfoBean().getUser_uid());
createMeSendBaseMsg.setFromNickName(BaseApplication.getInstance().getUserInfoBean().getNickname() + "--Test");
return createMeSendBaseMsg;
}
public void lite_while() {
this.lite_throws.show();
lite_long((ly2) tx2.p0(new g()).Y2(AndroidSchedulers.mainThread()).G4(cc3.lite_for()).H4(new f()));
}
public void lite_final(String str, MsgBean msgBean, vx2<Map<String, String>> vx2Var, int i2) {
if (i2 == 0) {
HashMap hashMap = new HashMap();
hashMap.put("sendResult", zw1.lite_synchronized);
vx2Var.onNext(hashMap);
}
}
public void lite_long(ly2 ly2Var) {
if (this.lite_switch == null) {
this.lite_switch = new ky2();
}
this.lite_switch.lite_if(ly2Var);
}
public void lite_this() {
ky2 ky2Var = this.lite_switch;
if (ky2Var != null) {
ky2Var.lite_new();
this.lite_switch = null;
}
}
@Override
public void onCreate(@Nullable Bundle bundle) {
getWindow().setFlags(128, 128);
super.onCreate(bundle);
fp3.lite_try().lite_super(this);
this.lite_boolean = new AtomicInteger();
this.lite_default = new AtomicInteger();
TestActivityBinding testActivityBinding = (TestActivityBinding) DataBindingUtil.setContentView(this, R.layout.test_activity);
this.lite_static = testActivityBinding;
testActivityBinding.lite_interface.setVideoURI(Uri.parse("http://vfx.mtime.cn/Video/2019/03/21/mp4/190321153853126488.mp4"));
ProgressDialog progressDialog = new ProgressDialog(this);
this.lite_throws = progressDialog;
progressDialog.setTitle("正在测试,请等待....");
this.lite_throws.setCancelable(false);
this.lite_throws.setCanceledOnTouchOutside(false);
this.lite_static.lite_finally.setVisibility(8);
lite_break();
this.lite_static.lite_volatile.setText(g8.lite_char().lite_class("testMsgInfo"));
}
@Override
public void onDestroy() {
super.onDestroy();
fp3.lite_try().lite_native(this);
lite_this();
if (this.lite_static.lite_default.getText().toString().length() > 10) {
g8.lite_char().lite_public("testMsgInfo", this.lite_static.lite_default.getText().toString());
}
}
@Override
public void onStop() {
super.onStop();
lite_package = false;
}
@Subscribe(threadMode = ThreadMode.MAIN)
public void receiveMsg(TestMsgEvent testMsgEvent) {
if (testMsgEvent != null) {
this.lite_default.set(this.lite_default.get() + 1);
TextView textView = this.lite_static.lite_volatile;
StringBuilder b2 = r5.b("发送消息数:");
b2.append(this.lite_boolean.get());
b2.append(";接收消息数:");
b2.append(this.lite_default.get());
textView.setText(b2.toString());
}
}
}