package com.ifpdos.factorytest;

import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.provider.Settings;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import androidx.core.internal.view.SupportMenu;
import androidx.core.view.ViewCompat;
import com.ifpdos.factorytest.rkp.IUdiRkpUploadContract;
import com.ifpdos.factorytest.rkp.RkpUploadHandler;
import com.ifpdos.factorytest.udi.ConnectModeEnum;
import com.ifpdos.factorytest.udi.ProtocolDefineKt;
import com.ifpdos.factorytest.udi.RkpUploadStateApi;
import com.ifpdos.factorytest.udi.RkpUploadStateBody;
import com.ifpdos.factorytest.udi.RkpUploadStateEnum;
import com.ifpdos.factorytest.util.RkpUtil;
import com.ifpdos.factorytest.util.WiredNetworkUtil;
import com.seewo.vcommons.data.PropertiesUtils;
import com.seewo.vcommons.utils.ShellCommandUtils;
import java.io.IOException;
import java.util.Objects;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import okhttp3.HttpUrl;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: loaded from: classes.dex */
public class EdlaRkpTestActivity extends Activity implements IUdiRkpUploadContract {
    private static final int DEVICE_DATA_SAVE_FAIL = 5;
    private static final int KEY_NOT_BURNED = 4;
    private static final int NETWOEK_ERROR = 3;
    private static final int OPENCODE_FAIL = -1;
    private static final String SEARCH_RKP_CODE = "search";
    private static final int SEARCH_SUCCESS = 2;
    private static final String TAG = "EdlaRkpTestActivity";
    private static final String UPDATE_RKP_CODE = "update";
    private static final int UPDATE_SUCCESS = 1;
    private static final int retryMaxTimes = 5;
    private static TextView textView;
    private boolean mIsFromUdi;
    private static final String[] UPLOAD_SERVER_URLS = {"https://dss-iipsyskeyup.cvte.com/1/data_uploader", "https://dss-iipsyskeyup.cvte.com/2/data_uploader", "https://dss-iipsyskeyup.cvte.com/3/data_uploader"};
    private static boolean test_result = false;
    private static int retryCount = 0;
    private static int curUrlIndex = 0;
    private static String csrDataString = null;
    private boolean oriEthernetEnable = true;
    private ConnectModeEnum oriEthernetMode = ConnectModeEnum.DHCP;
    private final ExecutorService mExecutor = Executors.newFixedThreadPool(3);
    private final Handler handler = new Handler(Looper.getMainLooper()) { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity.1
        @Override // android.os.Handler
        public void handleMessage(Message message) {
            super.handleMessage(message);
            int i = message.what;
            if (i == -1) {
                if (EdlaRkpTestActivity.retryCount <= 5) {
                    EdlaRkpTestActivity.curUrlIndex = EdlaRkpTestActivity.retryCount % EdlaRkpTestActivity.UPLOAD_SERVER_URLS.length;
                    EdlaRkpTestActivity.this.handleRkpCertificate(EdlaRkpTestActivity.UPDATE_RKP_CODE, EdlaRkpTestActivity.UPLOAD_SERVER_URLS[EdlaRkpTestActivity.curUrlIndex]);
                    EdlaRkpTestActivity.retryCount++;
                    Log.d(EdlaRkpTestActivity.TAG, "handleMessage fail retry.... " + EdlaRkpTestActivity.retryCount);
                } else {
                    EdlaRkpTestActivity.textView.setText(R.string.test_upload_fail);
                    RkpUtil.setRkpUploadState("fail");
                    EdlaRkpTestActivity.this.notifyTestResult(false);
                }
                Log.d(EdlaRkpTestActivity.TAG, "handleMessage fail");
                EdlaRkpTestActivity.textView.setTextColor(SupportMenu.CATEGORY_MASK);
                EdlaRkpTestActivity.test_result = false;
                return;
            }
            if (i == 1) {
                EdlaRkpTestActivity.textView.setText(R.string.test_uploaded_checking);
                Log.d(EdlaRkpTestActivity.TAG, "handleMessage update succsess");
                EdlaRkpTestActivity.this.handleRkpCertificate(EdlaRkpTestActivity.SEARCH_RKP_CODE, EdlaRkpTestActivity.UPLOAD_SERVER_URLS[EdlaRkpTestActivity.curUrlIndex]);
                return;
            }
            if (i == 2) {
                EdlaRkpTestActivity.textView.setText(R.string.test_upload_success);
                EdlaRkpTestActivity.textView.append(ShellCommandUtils.COMMAND_LINE_END);
                EdlaRkpTestActivity.textView.append(EdlaRkpTestActivity.this.getString(R.string.test_data_save_pass));
                Log.d(EdlaRkpTestActivity.TAG, "handleMessage search success");
                EdlaRkpTestActivity.retryCount = 0;
                EdlaRkpTestActivity.test_result = true;
                RkpUtil.setRkpUploadState("pass");
                EdlaRkpTestActivity.textView.setTextColor(-16711936);
                EdlaRkpTestActivity.this.notifyTestResult(true);
                return;
            }
            if (i == 3) {
                EdlaRkpTestActivity.textView.setText(R.string.test_network_error);
                RkpUtil.setRkpUploadState("not upload");
                EdlaRkpTestActivity.this.notifyTestResult(false);
                Log.d(EdlaRkpTestActivity.TAG, "handleMessage network error");
                EdlaRkpTestActivity.test_result = false;
                return;
            }
            if (i == 4) {
                EdlaRkpTestActivity.textView.setText(R.string.test_key_not_burned);
                RkpUtil.setRkpUploadState("not upload");
                EdlaRkpTestActivity.textView.setTextColor(SupportMenu.CATEGORY_MASK);
                EdlaRkpTestActivity.this.notifyTestResult(false);
                EdlaRkpTestActivity.test_result = false;
                return;
            }
            if (i == 5) {
                if (EdlaRkpTestActivity.retryCount <= 5) {
                    EdlaRkpTestActivity.curUrlIndex = EdlaRkpTestActivity.retryCount % EdlaRkpTestActivity.UPLOAD_SERVER_URLS.length;
                    EdlaRkpTestActivity.this.handleRkpCertificate(EdlaRkpTestActivity.UPDATE_RKP_CODE, EdlaRkpTestActivity.UPLOAD_SERVER_URLS[EdlaRkpTestActivity.curUrlIndex]);
                    EdlaRkpTestActivity.retryCount++;
                    Log.d(EdlaRkpTestActivity.TAG, "handleMessage fail retry.... " + EdlaRkpTestActivity.retryCount);
                } else {
                    EdlaRkpTestActivity.textView.setText(R.string.test_data_save_fail);
                    EdlaRkpTestActivity.textView.setTextColor(SupportMenu.CATEGORY_MASK);
                }
                RkpUtil.setRkpUploadState("pass");
                EdlaRkpTestActivity.this.notifyTestResult(true);
                EdlaRkpTestActivity.test_result = false;
                return;
            }
            Log.d(EdlaRkpTestActivity.TAG, "handleMessage unkonw message");
            EdlaRkpTestActivity.this.notifyTestResult(false);
        }
    };

    @Override // android.app.Activity
    protected void onCreate(Bundle bundle) {
        super.onCreate(bundle);
        csrDataString = RkpUtil.getDeviceCsr();
        setContentView(R.layout.activity_edla_rkp_test);
        textView = (TextView) findViewById(R.id.edla_text);
        initEnvironment(this);
        ((Button) findViewById(R.id.edla_rkp_pass)).setOnClickListener(new View.OnClickListener() { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity$$ExternalSyntheticLambda2
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                this.f$0.lambda$onCreate$0(view);
            }
        });
        ((Button) findViewById(R.id.edla_rkp_fail)).setOnClickListener(new View.OnClickListener() { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity$$ExternalSyntheticLambda3
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                this.f$0.lambda$onCreate$1(view);
            }
        });
        checkNetworkStatus();
        ((Button) findViewById(R.id.edla_rkp_upload)).setOnClickListener(new View.OnClickListener() { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity$$ExternalSyntheticLambda4
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                this.f$0.lambda$onCreate$2(view);
            }
        });
        boolean booleanExtra = getIntent().getBooleanExtra(ProtocolDefineKt.KEY_FROM_UDI, false);
        this.mIsFromUdi = booleanExtra;
        if (booleanExtra) {
            RkpUploadHandler.INSTANCE.registerIUdiCameraImpl(this);
            startRkpUpload();
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$onCreate$0(View view) {
        if (test_result) {
            setResult(1);
            finish();
        } else {
            textView.setText(R.string.test_upload_fail_not_click_success);
        }
    }

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

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

    private void initEnvironment(Context context) {
        boolean ethernetEnable = WiredNetworkUtil.getEthernetEnable(context);
        this.oriEthernetEnable = ethernetEnable;
        if (!ethernetEnable) {
            WiredNetworkUtil.setEthernetEnable(context, true);
        }
        ConnectModeEnum ethernetMode = WiredNetworkUtil.getEthernetMode(context);
        this.oriEthernetMode = ethernetMode;
        if (ethernetMode == ConnectModeEnum.MANUAL) {
            WiredNetworkUtil.setEthernetMode(context, ConnectModeEnum.DHCP);
        }
        Log.d(TAG, "initEnvironment: set settings AUTO_TIME and AUTO_TIME_ZONE to 1");
        Settings.Global.putInt(getContentResolver(), "auto_time", 1);
        Settings.Global.putInt(getContentResolver(), "auto_time_zone", 1);
    }

    @Override // android.app.Activity
    protected void onNewIntent(Intent intent) {
        boolean booleanExtra = getIntent().getBooleanExtra(ProtocolDefineKt.KEY_FROM_UDI, false);
        this.mIsFromUdi = booleanExtra;
        if (booleanExtra) {
            startRkpUpload();
        }
        super.onNewIntent(intent);
    }

    @Override // android.app.Activity
    protected void onDestroy() {
        super.onDestroy();
        restoreEnvironment(this);
        if (this.mIsFromUdi) {
            RkpUploadHandler.INSTANCE.unregisterIUdiCameraImpl(this);
        }
    }

    private void restoreEnvironment(Context context) {
        WiredNetworkUtil.setEthernetEnable(context, this.oriEthernetEnable);
        WiredNetworkUtil.setEthernetMode(context, this.oriEthernetMode);
    }

    public static String escapeJsonString(String str) {
        return str.replace("\"", "\\\"");
    }

    public static String getRequestBody(String str) {
        String strEscapeJsonString = escapeJsonString(csrDataString);
        String deviceSN = RkpUtil.getDeviceSN();
        StringBuilder sb = new StringBuilder("{\"mode\": \"");
        sb.append(str).append("\",\"csr\": \"").append(strEscapeJsonString).append("\",\"sn\": \"").append(deviceSN).append("\"");
        String property = PropertiesUtils.getProperty("ro.ctm.edla.key.laboratory", "");
        if (property.isEmpty() || property.equals("0")) {
            if (ConfigParser.isSmartCustomer()) {
                sb.append(", \"customer\": \"smart\"");
            } else {
                sb.append(", \"customer\": \"cvte\"");
            }
        } else {
            PropertiesUtils.setProperty("sys.edla.key.laboratory", property);
            sb.append(", \"customer\": \"").append(RkpUtil.getLaboratoryKey(property)).append("\"");
        }
        sb.append(", \"data\": \"").append(escapeJsonString(RkpUtil.getOtherDeviceInfo())).append("\"}");
        return sb.toString();
    }

    public static String getTestRequestBody(String str) {
        StringBuilder sb = new StringBuilder("{\"string\": \"");
        sb.append(str).append("\"}");
        return sb.toString();
    }

    public void handleRkpCertificate(final String str, final String str2) {
        this.mExecutor.execute(new Runnable() { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity$$ExternalSyntheticLambda5
            @Override // java.lang.Runnable
            public final void run() {
                this.f$0.lambda$handleRkpCertificate$3(str, str2);
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$handleRkpCertificate$3(String str, String str2) {
        try {
            if (!RkpUtil.isDeviceConnectedToInternet(this)) {
                Message messageObtain = Message.obtain();
                messageObtain.what = 3;
                this.handler.sendMessage(messageObtain);
                return;
            }
            if (!RkpUtil.isKeyHasBurned()) {
                Message messageObtain2 = Message.obtain();
                messageObtain2.what = 4;
                this.handler.sendMessage(messageObtain2);
                return;
            }
            String strDesEncode = RkpUtil.desEncode(getRequestBody(str));
            Log.d(TAG, "handleRkpCertificate: encryptCode = " + strDesEncode);
            Log.d(TAG, "handleRkpCertificate: decryptString = " + RkpUtil.desDecode(strDesEncode));
            Response responseExecute = new OkHttpClient.Builder().connectTimeout(10L, TimeUnit.SECONDS).readTimeout(10L, TimeUnit.SECONDS).build().newCall(new Request.Builder().url(HttpUrl.parse(str2)).post(RequestBody.create(MediaType.parse("application/json"), getTestRequestBody(strDesEncode))).addHeader("accept", "application/json").addHeader("Content-Type", "application/json").build()).execute();
            Log.d(TAG, "handleRkpCertificate: response" + responseExecute);
            if (!responseExecute.isSuccessful()) {
                throw new IOException("Unexpected code " + responseExecute);
            }
            String strString = ((ResponseBody) Objects.requireNonNull(responseExecute.body())).string();
            int response = parseResponse(strString);
            Log.d(TAG, "responseData = " + strString + " result = " + response);
            Message messageObtain3 = Message.obtain();
            messageObtain3.what = response;
            messageObtain3.obj = strString;
            this.handler.sendMessage(messageObtain3);
        } catch (Exception e) {
            Message messageObtain4 = Message.obtain();
            messageObtain4.what = -1;
            messageObtain4.obj = e.getMessage();
            this.handler.sendMessage(messageObtain4);
            Log.e(TAG, " upload error", e);
        }
    }

    public static int parseResponse(String str) {
        if (str.contains("Batch processing complete")) {
            Log.d(TAG, "parseResponse: UPDATE_SUCCESS");
            return 1;
        }
        if (str.contains("Device public key already exists") && str.contains("save_data_failed")) {
            return 5;
        }
        if (!str.contains("Device public key already exists") || !str.contains("save_data_finish")) {
            return -1;
        }
        Log.d(TAG, "parseResponse: SEARCH_SUCCESS");
        return 2;
    }

    @Override // com.ifpdos.factorytest.rkp.IUdiRkpUploadContract
    public void exitRkpUploadTestActivity() {
        Log.d(TAG, "exitRkpUploadTestActivity");
        finish();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void notifyTestResult(boolean z) {
        if (this.mIsFromUdi) {
            if (z) {
                RkpUploadStateApi.INSTANCE.notify(new RkpUploadStateBody(RkpUploadStateEnum.PASS));
            } else {
                RkpUploadStateApi.INSTANCE.notify(new RkpUploadStateBody(RkpUploadStateEnum.FAIL));
            }
        }
    }

    private void startRkpUpload() {
        textView.setText(R.string.test_preparation_environment);
        textView.setTextColor(ViewCompat.MEASURED_STATE_MASK);
        retryCount = 0;
        curUrlIndex = 0;
        handleRkpCertificate(UPDATE_RKP_CODE, UPLOAD_SERVER_URLS[0]);
    }

    private void checkNetworkStatus() {
        this.mExecutor.execute(new Runnable() { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity$$ExternalSyntheticLambda0
            @Override // java.lang.Runnable
            public final void run() {
                this.f$0.lambda$checkNetworkStatus$5();
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$checkNetworkStatus$5() {
        try {
            final boolean zIsDeviceConnectedToInternet = RkpUtil.isDeviceConnectedToInternet(this);
            runOnUiThread(new Runnable() { // from class: com.ifpdos.factorytest.EdlaRkpTestActivity$$ExternalSyntheticLambda1
                @Override // java.lang.Runnable
                public final void run() {
                    this.f$0.lambda$checkNetworkStatus$4(zIsDeviceConnectedToInternet);
                }
            });
        } catch (Exception e) {
            Log.e(TAG, "checkNetworkStatus: check network error", e);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$checkNetworkStatus$4(boolean z) {
        TextView textView2 = textView;
        if (textView2 == null) {
            return;
        }
        if (z) {
            textView2.setText(getString(R.string.str_network_normal));
        } else {
            textView2.setText(getString(R.string.str_network_error_tips));
        }
    }
}