超媒网络 v3.0.0版本的 MD5 值为：e72248abb238993f421967424d9a9515

以下内容为反编译后的 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.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 jxjzxe.bqpfrt.fyicpb.R;
import okhttp3.ResponseBody;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;
import p.a.y.e.a.s.e.net.ap3;
import p.a.y.e.a.s.e.net.az0;
import p.a.y.e.a.s.e.net.bt3;
import p.a.y.e.a.s.e.net.cz0;
import p.a.y.e.a.s.e.net.f21;
import p.a.y.e.a.s.e.net.f51;
import p.a.y.e.a.s.e.net.fy2;
import p.a.y.e.a.s.e.net.g8;
import p.a.y.e.a.s.e.net.gy2;
import p.a.y.e.a.s.e.net.gz0;
import p.a.y.e.a.s.e.net.hb3;
import p.a.y.e.a.s.e.net.i62;
import p.a.y.e.a.s.e.net.l11;
import p.a.y.e.a.s.e.net.ox2;
import p.a.y.e.a.s.e.net.p8;
import p.a.y.e.a.s.e.net.pz0;
import p.a.y.e.a.s.e.net.qx2;
import p.a.y.e.a.s.e.net.r5;
import p.a.y.e.a.s.e.net.rs3;
import p.a.y.e.a.s.e.net.rx2;
import p.a.y.e.a.s.e.net.sz0;
import p.a.y.e.a.s.e.net.vw1;
import p.a.y.e.a.s.e.net.xb3;
import p.a.y.e.a.s.e.net.yw2;
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 = cz0.lite_int();
    private TestActivityBinding lite_static;
    public fy2 lite_switch;
    private ProgressDialog lite_throws;

    public class a implements View.OnClickListener {

        public class C0026a extends hb3<Integer> {
            public C0026a() {
            }

            @Override
            public void onNext(Integer num) {
                TextView textView = TestActivity.this.lite_static.lite_abstract;
                textView.setText("所有会话列表的所有消息数：" + num);
            }

            @Override
            public void onComplete() {
            }

            @Override
            public void onError(Throwable th) {
                th.printStackTrace();
            }
        }

        public class b implements rx2<Integer> {
            public b() {
            }

            @Override
            public void lite_do(qx2<Integer> qx2Var) throws Exception {
                List<ConversationBean> lite_try = az0.lite_case().lite_try(BaseApplication.getInstance().getUserInfoBean().getUser_uid());
                int i = 0;
                for (int i2 = 0; i2 < lite_try.size(); i2++) {
                    i += gz0.lite_double().lite_class(lite_try.get(i2).getCounterId());
                }
                qx2Var.onNext(Integer.valueOf(i));
            }
        }

        public a() {
        }

        private void lite_do() {
            TestActivity.this.lite_long((gy2) ox2.p0(new b()).G4(xb3.lite_for()).Y2(AndroidSchedulers.mainThread()).H4(new C0026a()));
        }

        @Override
        public void onClick(View view) {
            lite_do();
        }
    }

    public class b extends hb3<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 rx2<String> {
        public c() {
        }

        @Override
        public void lite_do(qx2<String> qx2Var) 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");
            qx2Var.onNext(b.toString());
        }
    }

    public class d extends hb3<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 rx2<String> {
        public e() {
        }

        @Override
        public void lite_do(qx2<String> qx2Var) throws Exception {
            StringBuilder sb = new StringBuilder();
            yw2<bt3<ResponseBody>> B = pz0.B(sz0.lite_new(BaseApplication.getInstance().getConfig().getApiPath()), true);
            if (B != null) {
                long currentTimeMillis = System.currentTimeMillis();
                bt3<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");
                }
            }
            qx2Var.onNext(sb.toString());
        }
    }

    public class f extends hb3<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 rx2<String> {
        public g() {
        }

        @Override
        public void lite_do(qx2<String> qx2Var) 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");
            }
            qx2Var.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 hb3<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 testActivity = TestActivity.this;
            TestActivity.this.lite_float(testActivity.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 hb3<Map<String, String>> {
        public o() {
        }

        @Override
        public void onNext(Map<String, String> map) {
            if (map == null || !map.get("sendResult").equals(vw1.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, qx2 qx2Var) throws Exception {
        if (z) {
            str = this.lite_extends.get(new Random().nextInt(this.lite_extends.size())).getG_id();
        }
        i62.lite_byte(r5.lite_throws("当前发送到的gid：", str), new Object[0]);
        if (gz0.lite_double().lite_continue(msgBean, str)) {
            i62.lite_byte("存储消息成功", new Object[0]);
            lite_final(str, msgBean, qx2Var, f51.lite_byte(this, str, msgBean));
        }
    }

    public void lite_double() {
        this.lite_throws.show();
        lite_long((gy2) ox2.p0(new c()).Y2(AndroidSchedulers.mainThread()).G4(xb3.lite_for()).H4(new b()));
    }

    public void lite_float(final MsgBean msgBean, final String str, final boolean z) {
        lite_long((gy2) ox2.p0(new rx2() {
            @Override
            public final void lite_do(qx2 qx2Var) {
                TestActivity.this.lite_const(z, str, msgBean, qx2Var);
            }
        }).Y2(AndroidSchedulers.mainThread()).G4(xb3.lite_for()).H4(new o()));
    }

    private void lite_short(String str, String str2, boolean z) {
        lite_long((gy2) ox2.g2(0L, 2147483647L, 0L, 50L, TimeUnit.MILLISECONDS, xb3.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 {
            rs3<ResponseBody> S1 = pz0.L().S1(sz0.lite_else(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((gy2) ox2.p0(new e()).Y2(AndroidSchedulers.mainThread()).G4(xb3.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(f21.lite_char().lite_try());
        f21.lite_char().lite_for();
        createMeSendBaseMsg.setContent(l11.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((gy2) ox2.p0(new g()).Y2(AndroidSchedulers.mainThread()).G4(xb3.lite_for()).H4(new f()));
    }

    public void lite_final(String str, MsgBean msgBean, qx2<Map<String, String>> qx2Var, int i2) {
        if (i2 == 0) {
            HashMap hashMap = new HashMap();
            hashMap.put("sendResult", vw1.lite_synchronized);
            qx2Var.onNext(hashMap);
        }
    }

    public void lite_long(gy2 gy2Var) {
        if (this.lite_switch == null) {
            this.lite_switch = new fy2();
        }
        this.lite_switch.lite_if(gy2Var);
    }

    public void lite_this() {
        fy2 fy2Var = this.lite_switch;
        if (fy2Var != null) {
            fy2Var.lite_new();
            this.lite_switch = null;
        }
    }

    @Override
    public void onCreate(@Nullable Bundle bundle) {
        getWindow().setFlags(128, 128);
        super.onCreate(bundle);
        ap3.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();
        ap3.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());
        }
    }
}