package com.ifpdos.factorytest;

import android.content.Context;
import android.util.AttributeSet;
import android.util.Log;
import com.seewo.vcommons.helper.StorageHelper;
import com.seewo.vcommons.utils.ShellCommandUtils;
import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.functions.Function;
import io.reactivex.schedulers.Schedulers;
import java.util.List;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public class UsbTest extends TestItem {
    private static final String TAG = "UsbTest";
    private AskDialog askDialog;
    Disposable dis;
    private OnAskDialogResultListener mAskRetListener;
    private Context mContext;
    private TFCardTest mTFCardTest;

    public UsbTest(Context context, AttributeSet attributeSet) {
        super(context, attributeSet);
        this.mAskRetListener = null;
        this.mContext = context;
        this.mTFCardTest = new TFCardTest(context, attributeSet);
        StorageHelper.getInstance().init(this.mContext);
    }

    @Override // com.ifpdos.factorytest.TestItem
    void onResume() {
        super.onResume();
        scanUsb();
    }

    @Override // com.ifpdos.factorytest.TestItem
    boolean doTest() {
        if (this.mContext == null) {
            testDone(false, this.mTagDone);
            return false;
        }
        String string = getResources().getString(R.string.test_usb_ask_dialog);
        this.mAskRetListener = new OnAskDialogResultListener() { // from class: com.ifpdos.factorytest.UsbTest.1
            @Override // com.ifpdos.factorytest.OnAskDialogResultListener
            public void onAskDialogResult(Context context, boolean z) {
                UsbTest usbTest = UsbTest.this;
                usbTest.testDone(z, usbTest.mTagDone);
                UsbTest.this.closeUsbListener();
                UsbTest.this.askDialog = null;
            }
        };
        this.askDialog = new AskDialog(this.mContext, string, updateUsbDevice(), this.mAskRetListener);
        scanUsb();
        return true;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void closeUsbListener() {
        Disposable disposable = this.dis;
        if (disposable == null || disposable.isDisposed()) {
            return;
        }
        this.dis.dispose();
    }

    @Override // com.ifpdos.factorytest.TestItem
    void onStop() {
        super.onStop();
        if (this.askDialog != null) {
            Log.d(TAG, "触发stop中的dispose");
            closeUsbListener();
        }
    }

    @Override // com.ifpdos.factorytest.TestItem
    void onDestroy() {
        super.onDestroy();
        this.mTFCardTest.onDestroy();
    }

    private String updateUsbDevice() {
        StringBuilder sb = new StringBuilder();
        List<StorageHelper.StorageItem> usbItems = StorageHelper.getInstance().getUsbItems();
        List<StorageHelper.StorageItem> tFCardItems = this.mTFCardTest.getTFCardItems();
        Log.d(TAG, "usbNumber=" + usbItems.size());
        Log.d(TAG, "TFCardNumber=" + tFCardItems.size());
        if (tFCardItems.size() > 0 && usbItems.size() > 0) {
            for (int i = 0; i < tFCardItems.size(); i++) {
                int i2 = 0;
                while (i2 < usbItems.size()) {
                    if (tFCardItems.get(i).mPath.equals(usbItems.get(i2).mPath)) {
                        usbItems.remove(i2);
                        i2--;
                    }
                    i2++;
                }
            }
        }
        Log.d(TAG, "realUsbNumber=" + usbItems.size());
        if (usbItems.size() > 0) {
            for (int i3 = 1; i3 <= usbItems.size(); i3++) {
                sb.append(this.mContext.getResources().getString(R.string.usb_found)).append(usbItems.get(i3 - 1).mLabel).append(ShellCommandUtils.COMMAND_LINE_END);
            }
        } else {
            sb.append(this.mContext.getResources().getString(R.string.no_usb_found));
        }
        return sb.toString();
    }

    private void scanUsb() {
        if (this.askDialog != null) {
            Disposable disposable = this.dis;
            if (disposable != null && !disposable.isDisposed()) {
                this.dis.dispose();
            }
            Log.d(TAG, "start scanUsb");
            this.dis = Observable.interval(0L, 1L, TimeUnit.SECONDS).subscribeOn(Schedulers.io()).map(new Function() { // from class: com.ifpdos.factorytest.UsbTest$$ExternalSyntheticLambda0
                @Override // io.reactivex.functions.Function
                public final Object apply(Object obj) {
                    return this.f$0.lambda$scanUsb$0((Long) obj);
                }
            }).observeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer() { // from class: com.ifpdos.factorytest.UsbTest$$ExternalSyntheticLambda1
                @Override // io.reactivex.functions.Consumer
                public final void accept(Object obj) throws Exception {
                    this.f$0.lambda$scanUsb$1((String) obj);
                }
            });
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ String lambda$scanUsb$0(Long l) throws Exception {
        return updateUsbDevice();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void lambda$scanUsb$1(String str) throws Exception {
        this.askDialog.mDialog.setMessage(str);
    }
}