package com.seewo.ota.v.s;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.DialogInterface;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.UserManager;
import android.util.Log;
import android.view.Window;
import com.seewo.adbcommons.model.base.ICmdMsg;
import com.seewo.libvui.h.e;
import com.seewo.ota.R;
import com.seewo.ota.update.device.model.vman.SensorBoxVmanUpdateTask;
import com.seewo.ota.v.s.s.i1;
import com.seewo.ota.v.s.s.r0;
import f.t;
import f.u.s;
import f.z.d.v;
import g.a.h0;
import g.a.i0;
import g.a.s0;
import g.a.x0;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.ListIterator;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
/* JADX INFO: loaded from: classes.dex */
public final class p implements h0 {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final Context f2403b;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private final o f2404f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final /* synthetic */ h0 f2405g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private final f.e f2406h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private final f.e f2407i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private final f.e f2408j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    private final f.e f2409k;
    private final e l;
    private final AtomicBoolean m;
    private AtomicBoolean n;

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    @f.w.k.a.f(c = "com.seewo.ota.update.device.UsbDeviceUpdateManager$confirmUpdate$2", f = "UsbDeviceUpdateManager.kt", l = {}, m = "invokeSuspend")
    static final class a extends f.w.k.a.k implements f.z.c.p<h0, f.w.d<? super t>, Object> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        int f2410b;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        final /* synthetic */ List<com.seewo.ota.v.s.s.h0> f2412g;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        /* JADX WARN: Multi-variable type inference failed */
        a(List<? extends com.seewo.ota.v.s.s.h0> list, f.w.d<? super a> dVar) {
            super(2, dVar);
            this.f2412g = list;
        }

        @Override // f.w.k.a.a
        public final f.w.d<t> create(Object obj, f.w.d<?> dVar) {
            return p.this.new a(this.f2412g, dVar);
        }

        @Override // f.z.c.p
        public final Object invoke(h0 h0Var, f.w.d<? super t> dVar) {
            return ((a) create(h0Var, dVar)).invokeSuspend(t.a);
        }

        @Override // f.w.k.a.a
        public final Object invokeSuspend(Object obj) throws Throwable {
            f.w.j.d.d();
            if (this.f2410b != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            f.m.b(obj);
            p.this.f2404f.J(this.f2412g);
            p.this.n.set(false);
            return t.a;
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    static final class b extends f.z.d.l implements f.z.c.a<Long> {
        b() {
            super(0);
        }

        @Override // f.z.c.a
        /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
        public final Long invoke() {
            return Long.valueOf(((long) (p.this.f2403b.getResources().getInteger(R.integer.local_update_device_delay_day) * 24 * 60 * 60)) * 1000);
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    static final class c extends f.z.d.l implements f.z.c.a<Long> {
        c() {
            super(0);
        }

        @Override // f.z.c.a
        /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
        public final Long invoke() {
            return Long.valueOf(p.this.f2403b.getResources().getInteger(R.integer.local_update_device_interval_time));
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    @f.w.k.a.f(c = "com.seewo.ota.update.device.UsbDeviceUpdateManager$insertUsbDevice$1$1", f = "UsbDeviceUpdateManager.kt", l = {96}, m = "invokeSuspend")
    static final class d extends f.w.k.a.k implements f.z.c.p<h0, f.w.d<? super t>, Object> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        int f2415b;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        final /* synthetic */ List<com.seewo.ota.v.s.s.h0> f2417g;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        /* JADX WARN: Multi-variable type inference failed */
        d(List<? extends com.seewo.ota.v.s.s.h0> list, f.w.d<? super d> dVar) {
            super(2, dVar);
            this.f2417g = list;
        }

        @Override // f.w.k.a.a
        public final f.w.d<t> create(Object obj, f.w.d<?> dVar) {
            return p.this.new d(this.f2417g, dVar);
        }

        @Override // f.z.c.p
        public final Object invoke(h0 h0Var, f.w.d<? super t> dVar) {
            return ((d) create(h0Var, dVar)).invokeSuspend(t.a);
        }

        @Override // f.w.k.a.a
        public final Object invokeSuspend(Object obj) throws Throwable {
            Object objD = f.w.j.d.d();
            int i2 = this.f2415b;
            if (i2 == 0) {
                f.m.b(obj);
                p pVar = p.this;
                List<com.seewo.ota.v.s.s.h0> list = this.f2417g;
                this.f2415b = 1;
                if (pVar.v(list, this) == objD) {
                    return objD;
                }
            } else {
                if (i2 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                f.m.b(obj);
            }
            return t.a;
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    public static final class e extends BroadcastReceiver {

        /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
        @f.w.k.a.f(c = "com.seewo.ota.update.device.UsbDeviceUpdateManager$receiver$1$onReceive$1", f = "UsbDeviceUpdateManager.kt", l = {51}, m = "invokeSuspend")
        static final class a extends f.w.k.a.k implements f.z.c.p<h0, f.w.d<? super t>, Object> {

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            int f2418b;

            /* JADX INFO: renamed from: f, reason: collision with root package name */
            final /* synthetic */ p f2419f;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            a(p pVar, f.w.d<? super a> dVar) {
                super(2, dVar);
                this.f2419f = pVar;
            }

            @Override // f.w.k.a.a
            public final f.w.d<t> create(Object obj, f.w.d<?> dVar) {
                return new a(this.f2419f, dVar);
            }

            @Override // f.z.c.p
            public final Object invoke(h0 h0Var, f.w.d<? super t> dVar) {
                return ((a) create(h0Var, dVar)).invokeSuspend(t.a);
            }

            @Override // f.w.k.a.a
            public final Object invokeSuspend(Object obj) throws Throwable {
                Object objD = f.w.j.d.d();
                int i2 = this.f2418b;
                if (i2 == 0) {
                    f.m.b(obj);
                    this.f2419f.m.set(false);
                    long jN = this.f2419f.n();
                    this.f2418b = 1;
                    if (s0.a(jN, this) == objD) {
                        return objD;
                    }
                } else {
                    if (i2 != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    f.m.b(obj);
                }
                this.f2419f.m.set(true);
                return t.a;
            }
        }

        e() {
        }

        @Override // android.content.BroadcastReceiver
        public void onReceive(Context context, Intent intent) {
            f.z.d.k.e(context, "context");
            f.z.d.k.e(intent, "intent");
            if (f.z.d.k.a(intent.getAction(), "com.ifpdos.broadcast.LOCAL_UPDATE_DEVICE")) {
                p pVar = p.this;
                g.a.g.d(pVar, null, null, new a(pVar, null), 3, null);
            }
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    @f.w.k.a.f(c = "com.seewo.ota.update.device.UsbDeviceUpdateManager$showUpdateDialog$2", f = "UsbDeviceUpdateManager.kt", l = {}, m = "invokeSuspend")
    static final class f extends f.w.k.a.k implements f.z.c.p<h0, f.w.d<? super t>, Object> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        int f2420b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final /* synthetic */ List<com.seewo.ota.v.s.s.h0> f2421f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        final /* synthetic */ p f2422g;

        /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
        static final class a extends f.z.d.l implements f.z.c.l<com.seewo.ota.v.s.s.h0, CharSequence> {

            /* JADX INFO: renamed from: b, reason: collision with root package name */
            public static final a f2423b = new a();

            a() {
                super(1);
            }

            /* JADX WARN: Multi-variable type inference failed */
            @Override // f.z.c.l
            /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
            public final CharSequence c(com.seewo.ota.v.s.s.h0 h0Var) {
                f.z.d.k.e(h0Var, "it");
                if (!(h0Var instanceof i1)) {
                    return "";
                }
                String strNeedUpdateTips = ((i1) h0Var).needUpdateTips();
                f.z.d.k.d(strNeedUpdateTips, "{\n                it.nee…pdateTips()\n            }");
                return strNeedUpdateTips;
            }
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        /* JADX WARN: Multi-variable type inference failed */
        f(List<? extends com.seewo.ota.v.s.s.h0> list, p pVar, f.w.d<? super f> dVar) {
            super(2, dVar);
            this.f2421f = list;
            this.f2422g = pVar;
        }

        @Override // f.w.k.a.a
        public final f.w.d<t> create(Object obj, f.w.d<?> dVar) {
            return new f(this.f2421f, this.f2422g, dVar);
        }

        @Override // f.z.c.p
        public final Object invoke(h0 h0Var, f.w.d<? super t> dVar) {
            return ((f) create(h0Var, dVar)).invokeSuspend(t.a);
        }

        @Override // f.w.k.a.a
        public final Object invokeSuspend(Object obj) throws Throwable {
            f.w.j.d.d();
            if (this.f2420b != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            f.m.b(obj);
            this.f2422g.w(s.u(this.f2421f, "\n", null, null, 0, null, a.f2423b, 30, null), this.f2421f);
            return t.a;
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    @f.w.k.a.f(c = "com.seewo.ota.update.device.UsbDeviceUpdateManager$showUpdateTipsDialog$dialog$3$1", f = "UsbDeviceUpdateManager.kt", l = {ICmdMsg.ACTION_WRITE_USER_NFC_CARD}, m = "invokeSuspend")
    static final class g extends f.w.k.a.k implements f.z.c.p<h0, f.w.d<? super t>, Object> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        int f2424b;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        final /* synthetic */ DialogInterface f2425f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        final /* synthetic */ p f2426g;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        final /* synthetic */ List<com.seewo.ota.v.s.s.h0> f2427h;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        /* JADX WARN: Multi-variable type inference failed */
        g(DialogInterface dialogInterface, p pVar, List<? extends com.seewo.ota.v.s.s.h0> list, f.w.d<? super g> dVar) {
            super(2, dVar);
            this.f2425f = dialogInterface;
            this.f2426g = pVar;
            this.f2427h = list;
        }

        @Override // f.w.k.a.a
        public final f.w.d<t> create(Object obj, f.w.d<?> dVar) {
            return new g(this.f2425f, this.f2426g, this.f2427h, dVar);
        }

        @Override // f.z.c.p
        public final Object invoke(h0 h0Var, f.w.d<? super t> dVar) {
            return ((g) create(h0Var, dVar)).invokeSuspend(t.a);
        }

        @Override // f.w.k.a.a
        public final Object invokeSuspend(Object obj) throws Throwable {
            Object objD = f.w.j.d.d();
            int i2 = this.f2424b;
            if (i2 == 0) {
                f.m.b(obj);
                this.f2425f.dismiss();
                p pVar = this.f2426g;
                List<com.seewo.ota.v.s.s.h0> list = this.f2427h;
                this.f2424b = 1;
                if (pVar.j(list, this) == objD) {
                    return objD;
                }
            } else {
                if (i2 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                f.m.b(obj);
            }
            return t.a;
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    static final class h extends f.z.d.l implements f.z.c.a<List<? extends com.seewo.ota.v.s.s.h0>> {
        h() {
            super(0);
        }

        /* JADX WARN: Multi-variable type inference failed */
        @Override // f.z.c.a
        public final List<? extends com.seewo.ota.v.s.s.h0> invoke() {
            return f.u.j.b(new SensorBoxVmanUpdateTask(p.this.f2403b, null, 2, 0 == true ? 1 : 0));
        }
    }

    /* JADX INFO: compiled from: UsbDeviceUpdateManager.kt */
    static final class i extends f.z.d.l implements f.z.c.a<UserManager> {
        i() {
            super(0);
        }

        @Override // f.z.c.a
        /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
        public final UserManager invoke() {
            Object systemService = p.this.f2403b.getSystemService("user");
            if (systemService != null) {
                return (UserManager) systemService;
            }
            throw new NullPointerException("null cannot be cast to non-null type android.os.UserManager");
        }
    }

    public p(Context context, o oVar) {
        f.z.d.k.e(context, "mContext");
        f.z.d.k.e(oVar, "deviceUpdateManager");
        this.f2403b = context;
        this.f2404f = oVar;
        this.f2405g = i0.a(x0.b());
        this.f2406h = f.g.a(new h());
        this.f2407i = f.g.a(new c());
        this.f2408j = f.g.a(new b());
        this.f2409k = f.g.a(new i());
        this.l = new e();
        this.m = new AtomicBoolean(true);
        this.n = new AtomicBoolean(false);
        this.f2403b.registerReceiver(this.l, new IntentFilter("com.ifpdos.broadcast.LOCAL_UPDATE_DEVICE"));
    }

    private final void i() {
        this.n.set(false);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final Object j(List<? extends com.seewo.ota.v.s.s.h0> list, f.w.d<? super t> dVar) {
        Object objE = g.a.f.e(x0.b(), new a(list, null), dVar);
        return objE == f.w.j.d.d() ? objE : t.a;
    }

    private final void k() {
        long jCurrentTimeMillis = System.currentTimeMillis();
        com.seewo.ota.data.a.g().D(Long.valueOf(m() + jCurrentTimeMillis));
        i();
        Log.d(v.b(p.class).a(), "delayUpdate: delayTime=" + com.seewo.ota.data.a.g().e() + " currentTime=" + jCurrentTimeMillis);
    }

    private final boolean l() {
        if (this.m.get()) {
            long jCurrentTimeMillis = System.currentTimeMillis();
            Long lE = com.seewo.ota.data.a.g().e();
            f.z.d.k.d(lE, "getInstance().delayTime");
            if (jCurrentTimeMillis >= lE.longValue()) {
                return true;
            }
        }
        return false;
    }

    private final long m() {
        return ((Number) this.f2408j.getValue()).longValue();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final long n() {
        return ((Number) this.f2407i.getValue()).longValue();
    }

    private final List<com.seewo.ota.v.s.s.h0> o() {
        return (List) this.f2406h.getValue();
    }

    private final UserManager p() {
        return (UserManager) this.f2409k.getValue();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final Object v(List<? extends com.seewo.ota.v.s.s.h0> list, f.w.d<? super t> dVar) {
        Object objE = g.a.f.e(x0.c(), new f(list, this, null), dVar);
        return objE == f.w.j.d.d() ? objE : t.a;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void w(String str, final List<? extends com.seewo.ota.v.s.s.h0> list) {
        e.a aVar = new e.a(this.f2403b);
        aVar.y(R.string.update_dialog_title);
        aVar.o(str);
        aVar.p(R.string.btn_cancel, new DialogInterface.OnClickListener() { // from class: com.seewo.ota.v.s.n
            @Override // android.content.DialogInterface.OnClickListener
            public final void onClick(DialogInterface dialogInterface, int i2) {
                p.x(this.f2391b, dialogInterface, i2);
            }
        });
        aVar.r(R.string.btn_delay, new DialogInterface.OnClickListener() { // from class: com.seewo.ota.v.s.l
            @Override // android.content.DialogInterface.OnClickListener
            public final void onClick(DialogInterface dialogInterface, int i2) {
                p.y(this.f2388b, dialogInterface, i2);
            }
        });
        aVar.w(R.string.btn_ok, new DialogInterface.OnClickListener() { // from class: com.seewo.ota.v.s.m
            @Override // android.content.DialogInterface.OnClickListener
            public final void onClick(DialogInterface dialogInterface, int i2) {
                p.z(this.f2389b, list, dialogInterface, i2);
            }
        });
        com.seewo.libvui.h.b bVarA = aVar.a();
        Window window = bVarA.getWindow();
        if (window != null) {
            window.setType(2003);
        }
        bVarA.show();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void x(p pVar, DialogInterface dialogInterface, int i2) {
        f.z.d.k.e(pVar, "this$0");
        pVar.i();
        dialogInterface.dismiss();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void y(p pVar, DialogInterface dialogInterface, int i2) {
        f.z.d.k.e(pVar, "this$0");
        pVar.k();
        dialogInterface.dismiss();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void z(p pVar, List list, DialogInterface dialogInterface, int i2) {
        f.z.d.k.e(pVar, "this$0");
        f.z.d.k.e(list, "$waitUpdateTasks");
        g.a.g.d(pVar, null, null, new g(dialogInterface, pVar, list, null), 3, null);
    }

    @Override // g.a.h0
    public f.w.g getCoroutineContext() {
        return this.f2405g.getCoroutineContext();
    }

    public final void q(com.seewo.ota.v.s.r.c cVar) {
        int iNextIndex;
        f.z.d.k.e(cVar, "usbInfo");
        synchronized (this.n) {
            if (this.n.get()) {
                Log.i(v.b(getClass()).a(), "insertUsbDevice: is updating.");
            } else if (!l()) {
                Log.i(v.b(getClass()).a(), "insertUsbDevice: not allow update device.");
            } else {
                if (!p().isAdminUser()) {
                    Log.d(v.b(getClass()).a(), "startUpdateDevice: not system user");
                    return;
                }
                this.n.set(true);
                List<com.seewo.ota.v.s.s.h0> listO = o();
                ArrayList arrayList = new ArrayList();
                Iterator<T> it = listO.iterator();
                while (true) {
                    boolean z = false;
                    if (!it.hasNext()) {
                        break;
                    }
                    Object next = it.next();
                    r0 r0Var = (com.seewo.ota.v.s.s.h0) next;
                    if (r0Var instanceof i1) {
                        List<com.seewo.ota.v.s.r.c> listSupportUsbInfoList = ((i1) r0Var).supportUsbInfoList();
                        f.z.d.k.d(listSupportUsbInfoList, "it.supportUsbInfoList()");
                        ListIterator<com.seewo.ota.v.s.r.c> listIterator = listSupportUsbInfoList.listIterator(listSupportUsbInfoList.size());
                        while (true) {
                            if (!listIterator.hasPrevious()) {
                                iNextIndex = -1;
                                break;
                            }
                            com.seewo.ota.v.s.r.c cVarPrevious = listIterator.previous();
                            if (cVarPrevious.a() == cVar.a() && cVarPrevious.b() == cVar.b()) {
                                iNextIndex = listIterator.nextIndex();
                                break;
                            }
                        }
                        if (iNextIndex >= 0 && r0Var.isNeedRun()) {
                            z = true;
                        }
                    }
                    if (z) {
                        arrayList.add(next);
                    }
                }
                if (!arrayList.isEmpty()) {
                    g.a.g.d(this, null, null, new d(arrayList, null), 3, null);
                } else {
                    this.n.set(false);
                }
            }
            t tVar = t.a;
        }
    }

    public final void u() {
        this.f2403b.unregisterReceiver(this.l);
    }
}