package com.ifpdos.factorytest.receiver;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.os.Environment;
import android.util.Log;
import com.ifpdos.factorytest.util.FileUtil;
import io.reactivex.Observable;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;
import java.io.File;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public class USBReceiver extends BroadcastReceiver {
    private static final String CONFIG_CONTENT = "dft_config";
    private static final String TAG = "USBReceiver";
    Disposable disposable;

    @Override // android.content.BroadcastReceiver
    public void onReceive(Context context, Intent intent) {
        Log.d(TAG, "onReceive: 发现U盘");
        if (isDftConfigExist()) {
            Log.d(TAG, "dft_config has Existed");
        } else {
            this.disposable = Observable.timer(5L, TimeUnit.SECONDS).subscribeOn(Schedulers.io()).subscribe(new Consumer() { // from class: com.ifpdos.factorytest.receiver.USBReceiver$$ExternalSyntheticLambda0
                @Override // io.reactivex.functions.Consumer
                public final void accept(Object obj) {
                    FileUtil.copyDftConfig();
                }
            });
        }
    }

    public void onDestroy() {
        Disposable disposable = this.disposable;
        if (disposable == null || disposable.isDisposed()) {
            return;
        }
        Log.d(TAG, "onDestroy: USBReceiver");
        this.disposable.dispose();
    }

    public boolean isDftConfigExist() {
        return new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + File.separator + CONFIG_CONTENT).exists();
    }
}