package com.ifpdos.factorytest;

import android.app.Activity;
import android.content.Context;
import android.net.wifi.WifiManager;
import android.os.Bundle;
import android.os.Environment;
import android.text.Editable;
import android.text.TextUtils;
import android.text.TextWatcher;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import androidx.core.internal.view.SupportMenu;
import com.google.gson.JsonParser;
import com.ifpdos.Utils.UdiUtil;
import com.ifpdos.Utils.okhttp.OkHttpHelper;
import com.ifpdos.factorytest.entity.EthernetConfigBody;
import com.ifpdos.factorytest.udi.ConnectModeEnum;
import com.ifpdos.factorytest.util.WifiUtil;
import com.ifpdos.factorytest.util.WiredNetworkUtil;
import com.seewo.libsvendors.vendor.rockchip.ethernet.RockchipEthernetDevInfo;
import com.seewo.vcommons.utils.ActivityUtils;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;
import java.io.BufferedReader;
import java.io.Closeable;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/* JADX INFO: loaded from: classes.dex */
public class NetworkTestActivity extends Activity {
    private static final String DEFAULT_IP = "www.baidu.com";
    private static final String NETWORK_CONFIG_DIR = "dft_config";
    private static final String NETWORK_CONFIG_FILE = "network.json";
    private static final int RETRY_MAX_TIMES = 20;
    private static final String TAG = "NetworkTestActivity";
    private Button btn_fail;
    private Button btn_pass;
    private Button btn_start;
    private Disposable dis;
    private EditText edt_ping;
    private boolean orgWifiEnable;
    private boolean orgWiredEnable;
    private TextView tv_ping;
    private TextView tv_ping_ip;
    private TextView tv_port;
    private int wifiState;
    private volatile boolean isConnect = false;
    private volatile boolean pingResult = false;
    private boolean testFinish = true;
    private String ipAddress = NETWORK_CONFIG_FILE;
    private WifiManager mWifiManager = null;
    private ConnectModeEnum oriEthernetMode = ConnectModeEnum.DHCP;
    private ExecutorService executor = Executors.newSingleThreadExecutor();

    @Override // android.app.Activity
    protected void onCreate(Bundle bundle) {
        super.onCreate(bundle);
        setContentView(R.layout.activity_network_test);
        this.orgWiredEnable = WiredNetworkUtil.getEthernetEnable(this);
        this.orgWifiEnable = WifiUtil.getWifiManager().isWifiEnabled();
        this.btn_start = (Button) findViewById(R.id.bt_start_network_test);
        this.btn_pass = (Button) findViewById(R.id.network_pass);
        this.btn_fail = (Button) findViewById(R.id.network_fail);
        this.edt_ping = (EditText) findViewById(R.id.edt_ping);
        this.tv_port = (TextView) findViewById(R.id.tv_network_port);
        this.tv_ping = (TextView) findViewById(R.id.tv_ping_result);
        this.tv_ping_ip = (TextView) findViewById(R.id.tv_ping_ip);
        this.ipAddress = DEFAULT_IP;
        this.edt_ping.setText(DEFAULT_IP);
        this.oriEthernetMode = WiredNetworkUtil.getEthernetMode(this);
        setBtnClickable(false);
        this.executor.execute(new Runnable() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda4
            @Override // java.lang.Runnable
            public final void run() {
                this.f$0.lambda$onCreate$1();
            }
        });
        this.edt_ping.addTextChangedListener(new TextWatcher() { // from class: com.ifpdos.factorytest.NetworkTestActivity.1
            @Override // android.text.TextWatcher
            public void beforeTextChanged(CharSequence charSequence, int i, int i2, int i3) {
            }

            @Override // android.text.TextWatcher
            public void onTextChanged(CharSequence charSequence, int i, int i2, int i3) {
            }

            @Override // android.text.TextWatcher
            public void afterTextChanged(Editable editable) {
                NetworkTestActivity.this.ipAddress = editable.toString().replaceAll("\\s*", "");
                Log.d(NetworkTestActivity.TAG, "ipAddress: " + NetworkTestActivity.this.ipAddress);
            }
        });
        this.btn_start.setOnClickListener(new View.OnClickListener() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda5
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                this.f$0.lambda$onCreate$2(view);
            }
        });
        this.btn_pass.setOnClickListener(new View.OnClickListener() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda6
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                this.f$0.lambda$onCreate$3(view);
            }
        });
        this.btn_fail.setOnClickListener(new View.OnClickListener() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda7
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                this.f$0.lambda$onCreate$4(view);
            }
        });
        this.btn_start.setFocusableInTouchMode(true);
        this.btn_start.requestFocus();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$onCreate$1() {
        this.ipAddress = getIpAddressConfig();
        runOnUiThread(new Runnable() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda1
            @Override // java.lang.Runnable
            public final void run() {
                this.f$0.lambda$onCreate$0();
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$onCreate$0() {
        this.edt_ping.setText(this.ipAddress);
        setBtnClickable(true);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$onCreate$2(View view) {
        startNetworkTest();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$onCreate$3(View view) {
        setResult(1);
        finish();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$onCreate$4(View view) {
        setResult(2);
        finish();
    }

    private void startNetworkTest() {
        this.tv_port.setText(R.string.network_port_testing);
        this.tv_port.setTextColor(-1);
        this.tv_ping.setText(R.string.network_ping_testing);
        this.tv_ping.setTextColor(-1);
        this.tv_ping_ip.setText(R.string.network_ping_test_ip);
        this.tv_ping_ip.setTextColor(-1);
        if (this.testFinish) {
            this.testFinish = false;
            setBtnClickable(false);
            this.dis = Observable.create(new ObservableOnSubscribe() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda2
                @Override // io.reactivex.ObservableOnSubscribe
                public final void subscribe(ObservableEmitter observableEmitter) throws Exception {
                    this.f$0.lambda$startNetworkTest$5(observableEmitter);
                }
            }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda3
                @Override // io.reactivex.functions.Consumer
                public final void accept(Object obj) throws Exception {
                    this.f$0.lambda$startNetworkTest$6((Boolean) obj);
                }
            });
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$startNetworkTest$5(ObservableEmitter observableEmitter) throws Exception {
        this.isConnect = isEthernetConnected(this);
        if (!this.isConnect) {
            observableEmitter.onNext(false);
            return;
        }
        this.pingResult = pingIp(this.ipAddress);
        if (this.isConnect && this.pingResult) {
            observableEmitter.onNext(true);
        } else {
            observableEmitter.onNext(false);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$startNetworkTest$6(Boolean bool) throws Exception {
        if (!this.isConnect) {
            this.tv_port.setText(R.string.network_port_test_fail);
            this.tv_port.setTextColor(SupportMenu.CATEGORY_MASK);
            this.tv_ping.setTextColor(SupportMenu.CATEGORY_MASK);
            this.tv_ping.setText(R.string.network_ping_test_fail);
        } else {
            this.tv_port.setTextColor(-16711936);
            this.tv_port.setText(R.string.network_port_test_success);
            if (this.pingResult) {
                this.tv_ping.setTextColor(-16711936);
                this.tv_ping.setText(R.string.network_ping_test_success);
            } else {
                this.tv_ping.setTextColor(SupportMenu.CATEGORY_MASK);
                this.tv_ping.setText(R.string.network_ping_test_fail);
            }
        }
        setBtnClickable(true);
        this.testFinish = true;
    }

    private void setBtnClickable(boolean z) {
        this.btn_start.setClickable(z);
        this.btn_pass.setClickable(z);
        this.btn_fail.setClickable(z);
    }

    /* JADX WARN: Not initialized variable reg: 4, insn: 0x0033: MOVE (r1 I:??[OBJECT, ARRAY]) = (r4 I:??[OBJECT, ARRAY]), block:B:10:0x0033 */
    private String getIpAddressConfig() throws Throwable {
        InputStream fileInputStream;
        IOException e;
        Closeable closeable;
        File file = new File(new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS), NETWORK_CONFIG_DIR), NETWORK_CONFIG_FILE);
        if (file.exists()) {
            Log.d(TAG, "在Finder中发现配置文件");
            Closeable closeable2 = null;
            try {
                try {
                    fileInputStream = new FileInputStream(file);
                    try {
                        String str = parserConfig(fileInputStream);
                        safeClose(fileInputStream);
                        return str;
                    } catch (IOException e2) {
                        e = e2;
                        Log.d(TAG, "IO error: " + e.getMessage());
                        safeClose(fileInputStream);
                        return DEFAULT_IP;
                    }
                } catch (Throwable th) {
                    th = th;
                    closeable2 = closeable;
                    safeClose(closeable2);
                    throw th;
                }
            } catch (IOException e3) {
                fileInputStream = null;
                e = e3;
            } catch (Throwable th2) {
                th = th2;
                safeClose(closeable2);
                throw th;
            }
        } else {
            return DEFAULT_IP;
        }
    }

    private String parserConfig(InputStream inputStream) throws Throwable {
        InputStreamReader inputStreamReader;
        Closeable closeable = null;
        try {
            try {
                inputStreamReader = new InputStreamReader(inputStream);
            } catch (Exception e) {
                e = e;
            }
        } catch (Throwable th) {
            th = th;
        }
        try {
            String asString = new JsonParser().parse(inputStreamReader).getAsJsonObject().get("network_config").getAsJsonObject().get("address").getAsString();
            Log.d(TAG, "读取ping地址为：" + asString);
            safeClose(inputStreamReader);
            return asString;
        } catch (Exception e2) {
            e = e2;
            closeable = inputStreamReader;
            Log.d(TAG, "读取配置文件出错：" + e.getMessage());
            safeClose(closeable);
            return DEFAULT_IP;
        } catch (Throwable th2) {
            th = th2;
            closeable = inputStreamReader;
            safeClose(closeable);
            throw th;
        }
    }

    private void safeClose(Closeable closeable) {
        if (closeable == null) {
            return;
        }
        try {
            closeable.close();
        } catch (IOException unused) {
        }
    }

    @Override // android.app.Activity
    protected void onStart() {
        super.onStart();
        WifiManager wifiManager = (WifiManager) getApplicationContext().getSystemService("wifi");
        this.mWifiManager = wifiManager;
        int wifiState = wifiManager.getWifiState();
        this.wifiState = wifiState;
        if (wifiState == 3) {
            this.mWifiManager.setWifiEnabled(false);
        }
        WiredNetworkUtil.setEthernetEnable(this, true);
        if (this.oriEthernetMode != ConnectModeEnum.DHCP) {
            WiredNetworkUtil.setEthernetMode(this, ConnectModeEnum.DHCP);
        }
    }

    @Override // android.app.Activity
    protected void onDestroy() {
        super.onDestroy();
        Disposable disposable = this.dis;
        if (disposable != null && !disposable.isDisposed()) {
            this.dis.dispose();
        }
        WiredNetworkUtil.setEthernetEnable(this, this.orgWiredEnable);
        WiredNetworkUtil.setEthernetMode(this, this.oriEthernetMode);
        WifiUtil.getWifiManager().setWifiEnabled(this.orgWifiEnable);
        this.executor.shutdownNow();
    }

    public static boolean pingIp(String str) {
        String str2 = "ping -c 5 -i 0.2 -W 1 " + str;
        Log.i(TAG, "command: " + str2);
        try {
            Process processExec = Runtime.getRuntime().exec(str2);
            if (processExec.waitFor() != 0) {
                return false;
            }
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(processExec.getInputStream()));
            for (String line = bufferedReader.readLine(); line != null; line = bufferedReader.readLine()) {
                Log.i(TAG, "str=" + line);
                if (line.startsWith("5 packets transmitted")) {
                    String[] strArrSplit = line.split(" ");
                    if (3 < strArrSplit.length && Integer.parseInt(strArrSplit[3]) >= 3) {
                        return true;
                    }
                }
            }
            return false;
        } catch (Exception e) {
            e.printStackTrace();
            Log.i(TAG, "pingIpResult: ", e);
            return false;
        }
    }

    public String getEthernetIP(Context context) {
        String str;
        Log.d(TAG, "setEthernetDhcp");
        if (ActivityUtils.isAppExist(context, Common.UDI_CORE_PACKAGE)) {
            str = UdiUtil.URL_ETHERNET_CONFIG;
        } else {
            str = UdiUtil.URL_PC_ETHERNET_CONFIG;
        }
        EthernetConfigBody ethernetConfigBody = (EthernetConfigBody) OkHttpHelper.getInstance().get(str, EthernetConfigBody.class);
        if (ethernetConfigBody == null) {
            return "";
        }
        return ethernetConfigBody.ip;
    }

    private boolean isEthernetConnected(Context context) {
        final String ethernetIP = null;
        int i = 0;
        final boolean z = true;
        while (z && i < 20) {
            ethernetIP = getEthernetIP(context);
            z = TextUtils.isEmpty(ethernetIP) || RockchipEthernetDevInfo.INVALID_IP.equals(ethernetIP);
            if (z) {
                i++;
                try {
                    Thread.sleep(1000L);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        runOnUiThread(new Runnable() { // from class: com.ifpdos.factorytest.NetworkTestActivity$$ExternalSyntheticLambda0
            @Override // java.lang.Runnable
            public final void run() {
                this.f$0.lambda$isEthernetConnected$7(ethernetIP, z);
            }
        });
        if (z) {
            return false;
        }
        boolean zPingIp = pingIp(ethernetIP);
        Log.d(TAG, "有线网络ip：" + ethernetIP);
        return zPingIp;
    }

    /* JADX INFO: Access modifiers changed from: private */
    /* JADX INFO: renamed from: updateTextViewWithIP, reason: merged with bridge method [inline-methods] */
    public void lambda$isEthernetConnected$7(String str, boolean z) {
        if (z) {
            this.tv_ping_ip.setTextColor(SupportMenu.CATEGORY_MASK);
        } else {
            this.tv_ping_ip.setTextColor(-16711936);
        }
        this.tv_ping_ip.setText(" ip: " + str);
    }
}