package com.cvte.dss.ups.camera.utils;

import android.content.Context;
import android.hardware.usb.UsbDevice;
import android.hardware.usb.UsbManager;
import android.util.Log;
import com.cvte.dss.ups.camera.CameraHdiApi;
import com.cvte.dss.ups.camera.Plugin;
import com.cvte.dss.ups.camera.listener.UpgradeProgressListener;
import com.cvte.dss.ups.camera.model.CameraUpgradeInfo;
import com.cvte.dss.ups.camera.model.UpgradeResult;
import com.cvte.dss.ups.plugin.IUpsPlugin;
import com.cvte.vman.VmanMiddleWare;
import d.b.a.a.a;
import g.c0.g;
import g.h0.b.l;
import g.m0.f;
import g.p;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
import java.util.function.Function;

/* JADX INFO: compiled from: CameraHelper.kt */
/* JADX INFO: loaded from: classes.dex */
public final class CameraHelper {
    private static final long TIME_MILL_SECOND_GET_VERSION = 10000;
    private static final long TIME_MILL_SECOND_GET_VERSION_INTERNAL = 7000;
    public static final CameraHelper INSTANCE = new CameraHelper();
    private static final ConcurrentHashMap<String, Integer> upgradingCameraMap = new ConcurrentHashMap<>();
    private static final ArrayList<CameraUsbInterval> cameraUsbInterval = g.b(new CameraUsbInterval(8183, 1344, 1351));
    private static final ArrayList<CameraInfo> infos = g.b(new CameraInfo(8183, 1280), new CameraInfo(8183, 1282), new CameraInfo(8183, 1283), new CameraInfo(8183, 1284), new CameraInfo(8183, 1287), new CameraInfo(8183, 1288), new CameraInfo(8183, 1289), new CameraInfo(8183, 1296), new CameraInfo(8183, 1297), new CameraInfo(8183, 1299), new CameraInfo(8183, 1300), new CameraInfo(8183, 1301), new CameraInfo(8183, 1306), new CameraInfo(8183, 1307), new CameraInfo(8183, 1312), new CameraInfo(8183, 1313), new CameraInfo(8183, 1317), new CameraInfo(8183, 1318), new CameraInfo(8183, 1319), new CameraInfo(8183, 1320), new CameraInfo(8183, 1322), new CameraInfo(8183, 1323), new CameraInfo(8183, 1324), new CameraInfo(8183, 1327), new CameraInfo(8183, 1328), new CameraInfo(8183, 3919), new CameraInfo(13297, 4218), new CameraInfo(11902, 3185));

    /* JADX INFO: compiled from: CameraHelper.kt */
    public static final class CameraInfo {
        private int pid;
        private int vid;

        public CameraInfo(int i2, int i3) {
            this.vid = i2;
            this.pid = i3;
        }

        public static /* synthetic */ CameraInfo copy$default(CameraInfo cameraInfo, int i2, int i3, int i4, Object obj) {
            if ((i4 & 1) != 0) {
                i2 = cameraInfo.vid;
            }
            if ((i4 & 2) != 0) {
                i3 = cameraInfo.pid;
            }
            return cameraInfo.copy(i2, i3);
        }

        public final int component1() {
            return this.vid;
        }

        public final int component2() {
            return this.pid;
        }

        public final CameraInfo copy(int i2, int i3) {
            return new CameraInfo(i2, i3);
        }

        public boolean equals(Object obj) {
            if (this != obj) {
                if (obj instanceof CameraInfo) {
                    CameraInfo cameraInfo = (CameraInfo) obj;
                    if (this.vid == cameraInfo.vid) {
                        if (this.pid == cameraInfo.pid) {
                        }
                    }
                }
                return false;
            }
            return true;
        }

        public final int getPid() {
            return this.pid;
        }

        public final int getVid() {
            return this.vid;
        }

        public int hashCode() {
            return Integer.hashCode(this.pid) + (Integer.hashCode(this.vid) * 31);
        }

        public final void setPid(int i2) {
            this.pid = i2;
        }

        public final void setVid(int i2) {
            this.vid = i2;
        }

        public String toString() {
            StringBuilder sbB = a.B("CameraInfo(vid=");
            sbB.append(this.vid);
            sbB.append(", pid=");
            return a.s(sbB, this.pid, ")");
        }
    }

    /* JADX INFO: compiled from: CameraHelper.kt */
    public static final class CameraUsbInterval {
        private int endPid;
        private int startPid;
        private int vid;

        public CameraUsbInterval(int i2, int i3, int i4) {
            this.vid = i2;
            this.startPid = i3;
            this.endPid = i4;
        }

        public static /* synthetic */ CameraUsbInterval copy$default(CameraUsbInterval cameraUsbInterval, int i2, int i3, int i4, int i5, Object obj) {
            if ((i5 & 1) != 0) {
                i2 = cameraUsbInterval.vid;
            }
            if ((i5 & 2) != 0) {
                i3 = cameraUsbInterval.startPid;
            }
            if ((i5 & 4) != 0) {
                i4 = cameraUsbInterval.endPid;
            }
            return cameraUsbInterval.copy(i2, i3, i4);
        }

        public final int component1() {
            return this.vid;
        }

        public final int component2() {
            return this.startPid;
        }

        public final int component3() {
            return this.endPid;
        }

        public final CameraUsbInterval copy(int i2, int i3, int i4) {
            return new CameraUsbInterval(i2, i3, i4);
        }

        public boolean equals(Object obj) {
            if (this != obj) {
                if (obj instanceof CameraUsbInterval) {
                    CameraUsbInterval cameraUsbInterval = (CameraUsbInterval) obj;
                    if (this.vid == cameraUsbInterval.vid) {
                        if (this.startPid == cameraUsbInterval.startPid) {
                            if (this.endPid == cameraUsbInterval.endPid) {
                            }
                        }
                    }
                }
                return false;
            }
            return true;
        }

        public final int getEndPid() {
            return this.endPid;
        }

        public final int getStartPid() {
            return this.startPid;
        }

        public final int getVid() {
            return this.vid;
        }

        public int hashCode() {
            return Integer.hashCode(this.endPid) + ((Integer.hashCode(this.startPid) + (Integer.hashCode(this.vid) * 31)) * 31);
        }

        public final void setEndPid(int i2) {
            this.endPid = i2;
        }

        public final void setStartPid(int i2) {
            this.startPid = i2;
        }

        public final void setVid(int i2) {
            this.vid = i2;
        }

        public String toString() {
            StringBuilder sbB = a.B("CameraUsbInterval(vid=");
            sbB.append(this.vid);
            sbB.append(", startPid=");
            sbB.append(this.startPid);
            sbB.append(", endPid=");
            return a.s(sbB, this.endPid, ")");
        }
    }

    private CameraHelper() {
    }

    /* JADX WARN: Multi-variable type inference failed */
    public static /* synthetic */ List findDevices$default(CameraHelper cameraHelper, Context context, l lVar, int i2, Object obj) {
        if ((i2 & 2) != 0) {
            lVar = null;
        }
        return cameraHelper.findDevices(context, lVar);
    }

    private final List<IUpsPlugin.FirmwareInfo> getCameraPluginListById(Context context, String str) throws ExecutionException, InterruptedException {
        CameraUpgradeInfo cameraUpgradeInfoDecode = CameraUpgradeInfo.Companion.decode(str);
        if (cameraUpgradeInfoDecode == null) {
            return g.c0.l.f4067b;
        }
        List<CameraHdiApi> listFindDevices = findDevices(context, new CameraHelper$getCameraPluginListById$cameras$1(cameraUpgradeInfoDecode));
        final ArrayList arrayList = new ArrayList(f.a.y.a.C(listFindDevices, 10));
        Iterator<T> it = listFindDevices.iterator();
        while (it.hasNext()) {
            arrayList.add(((CameraHdiApi) it.next()).m0getCameraInfo());
        }
        Object[] array = arrayList.toArray(new CompletableFuture[0]);
        if (array == null) {
            throw new p("null cannot be cast to non-null type kotlin.Array<T>");
        }
        CompletableFuture[] completableFutureArr = (CompletableFuture[]) array;
        Object obj = CompletableFuture.allOf((CompletableFuture[]) Arrays.copyOf(completableFutureArr, completableFutureArr.length)).thenApply((Function<? super Void, ? extends U>) new Function<T, U>() { // from class: com.cvte.dss.ups.camera.utils.CameraHelper.getCameraPluginListById.1
            @Override // java.util.function.Function
            public final List<IUpsPlugin.FirmwareInfo> apply(Void r3) {
                List list = arrayList;
                ArrayList arrayList2 = new ArrayList(f.a.y.a.C(list, 10));
                Iterator<T> it2 = list.iterator();
                while (it2.hasNext()) {
                    arrayList2.add((IUpsPlugin.FirmwareInfo) ((CompletableFuture) it2.next()).get());
                }
                return arrayList2;
            }
        }).get();
        g.h0.c.l.b(obj, "CompletableFuture.allOf(…t.get() }\n        }.get()");
        return (List) obj;
    }

    public final void addUpgradingCamera(CameraUpgradeInfo cameraUpgradeInfo) {
        g.h0.c.l.g(cameraUpgradeInfo, "cameraUpgradeInfo");
        String id = cameraUpgradeInfo.getId();
        ConcurrentHashMap<String, Integer> concurrentHashMap = upgradingCameraMap;
        Integer num = concurrentHashMap.get(id);
        concurrentHashMap.put(id, Integer.valueOf(num != null ? 1 + num.intValue() : 1));
        for (Map.Entry<String, Integer> entry : concurrentHashMap.entrySet()) {
            Log.e(Plugin.TAG, "addUpgradingCamera key = " + entry.getKey() + " value = " + entry.getValue());
        }
    }

    public final CameraHdiApi findDevice(Context context) {
        g.h0.c.l.g(context, "context");
        Object systemService = context.getSystemService("usb");
        if (systemService == null) {
            throw new p("null cannot be cast to non-null type android.hardware.usb.UsbManager");
        }
        UsbManager usbManager = (UsbManager) systemService;
        for (UsbDevice usbDevice : usbManager.getDeviceList().values()) {
            if (isCameraDevice(usbDevice.getVendorId(), usbDevice.getProductId())) {
                return new CameraHdiApi(usbManager, usbDevice);
            }
        }
        return null;
    }

    /* JADX WARN: Removed duplicated region for block: B:11:0x0044  */
    /* JADX WARN: Removed duplicated region for block: B:14:0x005d  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final java.util.List<com.cvte.dss.ups.camera.CameraHdiApi> findDevices(android.content.Context r7, g.h0.b.l<? super android.hardware.usb.UsbDevice, java.lang.Boolean> r8) {
        /*
            r6 = this;
            java.lang.String r0 = "context"
            g.h0.c.l.g(r7, r0)
            java.lang.String r0 = "usb"
            java.lang.Object r7 = r7.getSystemService(r0)
            if (r7 == 0) goto L65
            android.hardware.usb.UsbManager r7 = (android.hardware.usb.UsbManager) r7
            java.util.HashMap r0 = r7.getDeviceList()
            java.util.Collection r0 = r0.values()
            java.lang.String r1 = "manager.deviceList.values"
            g.h0.c.l.b(r0, r1)
            java.util.ArrayList r1 = new java.util.ArrayList
            r1.<init>()
            java.util.Iterator r0 = r0.iterator()
        L25:
            boolean r2 = r0.hasNext()
            if (r2 == 0) goto L64
            java.lang.Object r2 = r0.next()
            android.hardware.usb.UsbDevice r2 = (android.hardware.usb.UsbDevice) r2
            java.lang.String r3 = "device"
            if (r8 == 0) goto L44
            g.h0.c.l.b(r2, r3)
            java.lang.Object r4 = r8.invoke(r2)
            java.lang.Boolean r4 = (java.lang.Boolean) r4
            boolean r4 = r4.booleanValue()
            if (r4 == 0) goto L5d
        L44:
            com.cvte.dss.ups.camera.utils.CameraHelper r4 = com.cvte.dss.ups.camera.utils.CameraHelper.INSTANCE
            g.h0.c.l.b(r2, r3)
            int r3 = r2.getVendorId()
            int r5 = r2.getProductId()
            boolean r3 = r4.isCameraDevice(r3, r5)
            if (r3 == 0) goto L5d
            com.cvte.dss.ups.camera.CameraHdiApi r3 = new com.cvte.dss.ups.camera.CameraHdiApi
            r3.<init>(r7, r2)
            goto L5e
        L5d:
            r3 = 0
        L5e:
            if (r3 == 0) goto L25
            r1.add(r3)
            goto L25
        L64:
            return r1
        L65:
            g.p r7 = new g.p
            java.lang.String r8 = "null cannot be cast to non-null type android.hardware.usb.UsbManager"
            r7.<init>(r8)
            throw r7
        */
        throw new UnsupportedOperationException("Method not decompiled: com.cvte.dss.ups.camera.utils.CameraHelper.findDevices(android.content.Context, g.h0.b.l):java.util.List");
    }

    public final boolean isCameraDevice(int i2, int i3) {
        int size = infos.size();
        for (int i4 = 0; i4 < size; i4++) {
            ArrayList<CameraInfo> arrayList = infos;
            if (i2 == arrayList.get(i4).getVid() && i3 == arrayList.get(i4).getPid()) {
                return true;
            }
        }
        int size2 = cameraUsbInterval.size();
        for (int i5 = 0; i5 < size2; i5++) {
            ArrayList<CameraUsbInterval> arrayList2 = cameraUsbInterval;
            if (i2 == arrayList2.get(i5).getVid() && i3 >= arrayList2.get(i5).getStartPid() && i3 <= arrayList2.get(i5).getEndPid()) {
                return true;
            }
        }
        return false;
    }

    public final boolean isUpgrading(CameraUpgradeInfo cameraUpgradeInfo) {
        g.h0.c.l.g(cameraUpgradeInfo, "cameraUpgradeInfo");
        return upgradingCameraMap.keySet().contains(cameraUpgradeInfo.getId());
    }

    public final void removeUpgradingCamera(CameraUpgradeInfo cameraUpgradeInfo) {
        g.h0.c.l.g(cameraUpgradeInfo, "cameraUpgradeInfo");
        upgradingCameraMap.remove(cameraUpgradeInfo.getId());
    }

    public final void upgradeCamera(Context context, CameraUpgradeInfo cameraUpgradeInfo, final List<? extends CompletableFuture<UpgradeResult>> list, final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) throws ExecutionException, InterruptedException {
        Object next;
        Object objL;
        g.h0.c.l.g(context, "context");
        g.h0.c.l.g(cameraUpgradeInfo, "upgradeInfo");
        g.h0.c.l.g(list, "tasks");
        g.h0.c.l.g(iUpgradeStatusListener, "listener");
        final float f2 = 0.1f;
        iUpgradeStatusListener.onProcess(0.1f);
        UpgradeProgressListener upgradeProgressListener = new UpgradeProgressListener(f2) { // from class: com.cvte.dss.ups.camera.utils.CameraHelper$upgradeCamera$autoProcess$1
            @Override // com.cvte.dss.ups.camera.listener.UpgradeProgressListener
            public void onProgress(float f3) {
                iUpgradeStatusListener.onProcess(f3);
            }
        };
        upgradeProgressListener.startAutoProcess(0.9f, 90);
        Object[] array = list.toArray(new CompletableFuture[0]);
        if (array == null) {
            throw new p("null cannot be cast to non-null type kotlin.Array<T>");
        }
        CompletableFuture[] completableFutureArr = (CompletableFuture[]) array;
        List list2 = (List) CompletableFuture.allOf((CompletableFuture[]) Arrays.copyOf(completableFutureArr, completableFutureArr.length)).thenApply((Function<? super Void, ? extends U>) new Function<T, U>() { // from class: com.cvte.dss.ups.camera.utils.CameraHelper$upgradeCamera$results$1
            @Override // java.util.function.Function
            public final List<UpgradeResult> apply(Void r3) {
                List list3 = list;
                ArrayList arrayList = new ArrayList(f.a.y.a.C(list3, 10));
                Iterator<T> it = list3.iterator();
                while (it.hasNext()) {
                    arrayList.add((UpgradeResult) ((CompletableFuture) it.next()).get());
                }
                return arrayList;
            }
        }).get();
        g.h0.c.l.b(list2, "results");
        Iterator it = list2.iterator();
        while (true) {
            if (it.hasNext()) {
                next = it.next();
                if (!((UpgradeResult) next).getResult()) {
                    break;
                }
            } else {
                next = null;
                break;
            }
        }
        UpgradeResult upgradeResult = (UpgradeResult) next;
        upgradeProgressListener.process(0.9f);
        if (upgradeResult != null) {
            upgradeProgressListener.process(1.0f);
            String errorMsg = upgradeResult.getErrorMsg();
            if (errorMsg == null) {
                errorMsg = "upgrade camera fail";
            }
            iUpgradeStatusListener.onFailed(errorMsg);
            removeUpgradingCamera(cameraUpgradeInfo);
            return;
        }
        CommonUtils.INSTANCE.safeSleep(TIME_MILL_SECOND_GET_VERSION);
        int i2 = 0;
        for (int i3 = 10; i2 < i3; i3 = 10) {
            List<IUpsPlugin.FirmwareInfo> cameraPluginListById = getCameraPluginListById(context, cameraUpgradeInfo.getId());
            ArrayList arrayList = new ArrayList();
            for (Object obj : cameraPluginListById) {
                IUpsPlugin.FirmwareInfo firmwareInfo = (IUpsPlugin.FirmwareInfo) obj;
                if (g.h0.c.l.a(firmwareInfo.getId(), cameraUpgradeInfo.getId()) && (f.o(firmwareInfo.getVersion()) ^ true)) {
                    arrayList.add(obj);
                }
            }
            int size = arrayList.size();
            Integer orDefault = upgradingCameraMap.getOrDefault(cameraUpgradeInfo.getId(), 0);
            g.h0.c.l.b(orDefault, "upgradingCameraMap.getOrDefault(upgradeInfo.id, 0)");
            if (g.h0.c.l.h(size, orDefault.intValue()) >= 0) {
                try {
                    VmanMiddleWare vmanMiddleWare = VmanMiddleWare.getInstance();
                    g.h0.c.l.b(vmanMiddleWare, "VmanMiddleWare.getInstance()");
                    objL = Integer.valueOf(Log.i(Plugin.TAG, "setCameraStatusUpdate: result = " + vmanMiddleWare.getAvManager().setCameraStatusUpdate(true)));
                } catch (Throwable th) {
                    objL = f.a.y.a.L(th);
                }
                if (g.l.a(objL) != null) {
                    Log.e(Plugin.TAG, "setCameraStatusUpdate error");
                }
                upgradeProgressListener.process(1.0f);
                iUpgradeStatusListener.onComplete();
                removeUpgradingCamera(cameraUpgradeInfo);
                return;
            }
            CommonUtils.INSTANCE.safeSleep(TIME_MILL_SECOND_GET_VERSION_INTERNAL);
            i2++;
        }
        iUpgradeStatusListener.onFailed("check version fail");
        removeUpgradingCamera(cameraUpgradeInfo);
    }
}