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 g.a.a.a.a; import g.h.a.i; import java.util.ArrayList; import java.util.Arrays; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutionException; import java.util.function.Function; import kotlin.Metadata; import kotlin.Result; import kotlin.TypeCastException; import kotlin.collections.EmptyList; import kotlin.collections.j; import kotlin.jvm.functions.Function1; import kotlin.jvm.internal.o; /* JADX INFO: loaded from: classes.dex */ @Metadata(bv = {1, 0, 3}, d1 = {"\u0000\u0086\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\b\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\bÆ\u0002\u0018\u00002\u00020\u0001:\u000289B\t\b\u0002¢\u0006\u0004\b6\u00107J%\u0010\b\u001a\b\u0012\u0004\u0012\u00020\u00070\u00062\u0006\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\b\u0010\tJ\u0017\u0010\u000b\u001a\u0004\u0018\u00010\n2\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u000b\u0010\fJ3\u0010\u0011\u001a\b\u0012\u0004\u0012\u00020\n0\u00062\u0006\u0010\u0003\u001a\u00020\u00022\u0016\b\u0002\u0010\u0010\u001a\u0010\u0012\u0004\u0012\u00020\u000e\u0012\u0004\u0012\u00020\u000f\u0018\u00010\r¢\u0006\u0004\b\u0011\u0010\u0012J\u001d\u0010\u0016\u001a\u00020\u000f2\u0006\u0010\u0014\u001a\u00020\u00132\u0006\u0010\u0015\u001a\u00020\u0013¢\u0006\u0004\b\u0016\u0010\u0017J9\u0010 \u001a\u00020\u001f2\u0006\u0010\u0003\u001a\u00020\u00022\u0006\u0010\u0019\u001a\u00020\u00182\u0012\u0010\u001c\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u001b0\u001a0\u00062\u0006\u0010\u001e\u001a\u00020\u001d¢\u0006\u0004\b \u0010!J\u0015\u0010#\u001a\u00020\u000f2\u0006\u0010\"\u001a\u00020\u0018¢\u0006\u0004\b#\u0010$J\u0015\u0010%\u001a\u00020\u001f2\u0006\u0010\"\u001a\u00020\u0018¢\u0006\u0004\b%\u0010&J\u0015\u0010'\u001a\u00020\u001f2\u0006\u0010\"\u001a\u00020\u0018¢\u0006\u0004\b'\u0010&R\u0016\u0010)\u001a\u00020(8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b)\u0010*R\"\u0010,\u001a\u000e\u0012\u0004\u0012\u00020\u0004\u0012\u0004\u0012\u00020\u00130+8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b,\u0010-R&\u00101\u001a\u0012\u0012\u0004\u0012\u00020/0.j\b\u0012\u0004\u0012\u00020/`08\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b1\u00102R&\u00104\u001a\u0012\u0012\u0004\u0012\u0002030.j\b\u0012\u0004\u0012\u000203`08\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b4\u00102R\u0016\u00105\u001a\u00020(8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b5\u0010*¨\u0006:"}, d2 = {"Lcom/cvte/dss/ups/camera/utils/CameraHelper;", "", "Landroid/content/Context;", "context", "", "idStr", "", "Lcom/cvte/dss/ups/plugin/IUpsPlugin$FirmwareInfo;", "getCameraPluginListById", "(Landroid/content/Context;Ljava/lang/String;)Ljava/util/List;", "Lcom/cvte/dss/ups/camera/CameraHdiApi;", "findDevice", "(Landroid/content/Context;)Lcom/cvte/dss/ups/camera/CameraHdiApi;", "Lkotlin/Function1;", "Landroid/hardware/usb/UsbDevice;", "", "filter", "findDevices", "(Landroid/content/Context;Lkotlin/jvm/functions/Function1;)Ljava/util/List;", "", "vid", "pid", "isCameraDevice", "(II)Z", "Lcom/cvte/dss/ups/camera/model/CameraUpgradeInfo;", "upgradeInfo", "Ljava/util/concurrent/CompletableFuture;", "Lcom/cvte/dss/ups/camera/model/UpgradeResult;", "tasks", "Lcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;", "listener", "", "upgradeCamera", "(Landroid/content/Context;Lcom/cvte/dss/ups/camera/model/CameraUpgradeInfo;Ljava/util/List;Lcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;)V", "cameraUpgradeInfo", "isUpgrading", "(Lcom/cvte/dss/ups/camera/model/CameraUpgradeInfo;)Z", "addUpgradingCamera", "(Lcom/cvte/dss/ups/camera/model/CameraUpgradeInfo;)V", "removeUpgradingCamera", "", "TIME_MILL_SECOND_GET_VERSION_INTERNAL", "J", "Ljava/util/concurrent/ConcurrentHashMap;", "upgradingCameraMap", "Ljava/util/concurrent/ConcurrentHashMap;", "Ljava/util/ArrayList;", "Lcom/cvte/dss/ups/camera/utils/CameraHelper$CameraUsbInterval;", "Lkotlin/collections/ArrayList;", "cameraUsbInterval", "Ljava/util/ArrayList;", "Lcom/cvte/dss/ups/camera/utils/CameraHelper$CameraInfo;", "infos", "TIME_MILL_SECOND_GET_VERSION", "", "()V", "CameraInfo", "CameraUsbInterval", "lib_release"}, k = 1, mv = {1, 4, 0}) 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 upgradingCameraMap = new ConcurrentHashMap<>(); private static final ArrayList cameraUsbInterval = j.c(new CameraUsbInterval(8183, 1344, 1351)); private static final ArrayList infos = j.c(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), new CameraInfo(1536, 1319), new CameraInfo(1536, 211)); @Metadata(bv = {1, 0, 3}, d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\b\n\u0002\b\u0007\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u000b\b\u0086\b\u0018\u00002\u00020\u0001B\u0017\u0012\u0006\u0010\u0006\u001a\u00020\u0002\u0012\u0006\u0010\u0007\u001a\u00020\u0002¢\u0006\u0004\b\u0018\u0010\u0019J\u0010\u0010\u0003\u001a\u00020\u0002HÆ\u0003¢\u0006\u0004\b\u0003\u0010\u0004J\u0010\u0010\u0005\u001a\u00020\u0002HÆ\u0003¢\u0006\u0004\b\u0005\u0010\u0004J$\u0010\b\u001a\u00020\u00002\b\b\u0002\u0010\u0006\u001a\u00020\u00022\b\b\u0002\u0010\u0007\u001a\u00020\u0002HÆ\u0001¢\u0006\u0004\b\b\u0010\tJ\u0010\u0010\u000b\u001a\u00020\nHÖ\u0001¢\u0006\u0004\b\u000b\u0010\fJ\u0010\u0010\r\u001a\u00020\u0002HÖ\u0001¢\u0006\u0004\b\r\u0010\u0004J\u001a\u0010\u0010\u001a\u00020\u000f2\b\u0010\u000e\u001a\u0004\u0018\u00010\u0001HÖ\u0003¢\u0006\u0004\b\u0010\u0010\u0011R\"\u0010\u0006\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0006\u0010\u0012\u001a\u0004\b\u0013\u0010\u0004\"\u0004\b\u0014\u0010\u0015R\"\u0010\u0007\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0007\u0010\u0012\u001a\u0004\b\u0016\u0010\u0004\"\u0004\b\u0017\u0010\u0015¨\u0006\u001a"}, d2 = {"Lcom/cvte/dss/ups/camera/utils/CameraHelper$CameraInfo;", "", "", "component1", "()I", "component2", "vid", "pid", "copy", "(II)Lcom/cvte/dss/ups/camera/utils/CameraHelper$CameraInfo;", "", "toString", "()Ljava/lang/String;", "hashCode", "other", "", "equals", "(Ljava/lang/Object;)Z", "I", "getVid", "setVid", "(I)V", "getPid", "setPid", "", "(II)V", "lib_release"}, k = 1, mv = {1, 4, 0}) public static final /* data */ 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); } /* JADX INFO: renamed from: component1, reason: from getter */ public final int getVid() { return this.vid; } /* JADX INFO: renamed from: component2, reason: from getter */ public final int getPid() { return this.pid; } public final CameraInfo copy(int vid, int pid) { return new CameraInfo(vid, pid); } public boolean equals(Object other) { if (this != other) { if (other instanceof CameraInfo) { CameraInfo cameraInfo = (CameraInfo) other; 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 sbF = a.F("CameraInfo(vid="); sbF.append(this.vid); sbF.append(", pid="); return a.y(sbF, this.pid, ")"); } } @Metadata(bv = {1, 0, 3}, d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\b\n\u0002\b\t\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\r\b\u0086\b\u0018\u00002\u00020\u0001B\u001f\u0012\u0006\u0010\u0007\u001a\u00020\u0002\u0012\u0006\u0010\b\u001a\u00020\u0002\u0012\u0006\u0010\t\u001a\u00020\u0002¢\u0006\u0004\b\u001c\u0010\u001dJ\u0010\u0010\u0003\u001a\u00020\u0002HÆ\u0003¢\u0006\u0004\b\u0003\u0010\u0004J\u0010\u0010\u0005\u001a\u00020\u0002HÆ\u0003¢\u0006\u0004\b\u0005\u0010\u0004J\u0010\u0010\u0006\u001a\u00020\u0002HÆ\u0003¢\u0006\u0004\b\u0006\u0010\u0004J.\u0010\n\u001a\u00020\u00002\b\b\u0002\u0010\u0007\u001a\u00020\u00022\b\b\u0002\u0010\b\u001a\u00020\u00022\b\b\u0002\u0010\t\u001a\u00020\u0002HÆ\u0001¢\u0006\u0004\b\n\u0010\u000bJ\u0010\u0010\r\u001a\u00020\fHÖ\u0001¢\u0006\u0004\b\r\u0010\u000eJ\u0010\u0010\u000f\u001a\u00020\u0002HÖ\u0001¢\u0006\u0004\b\u000f\u0010\u0004J\u001a\u0010\u0012\u001a\u00020\u00112\b\u0010\u0010\u001a\u0004\u0018\u00010\u0001HÖ\u0003¢\u0006\u0004\b\u0012\u0010\u0013R\"\u0010\t\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\t\u0010\u0014\u001a\u0004\b\u0015\u0010\u0004\"\u0004\b\u0016\u0010\u0017R\"\u0010\u0007\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0007\u0010\u0014\u001a\u0004\b\u0018\u0010\u0004\"\u0004\b\u0019\u0010\u0017R\"\u0010\b\u001a\u00020\u00028\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\b\u0010\u0014\u001a\u0004\b\u001a\u0010\u0004\"\u0004\b\u001b\u0010\u0017¨\u0006\u001e"}, d2 = {"Lcom/cvte/dss/ups/camera/utils/CameraHelper$CameraUsbInterval;", "", "", "component1", "()I", "component2", "component3", "vid", "startPid", "endPid", "copy", "(III)Lcom/cvte/dss/ups/camera/utils/CameraHelper$CameraUsbInterval;", "", "toString", "()Ljava/lang/String;", "hashCode", "other", "", "equals", "(Ljava/lang/Object;)Z", "I", "getEndPid", "setEndPid", "(I)V", "getVid", "setVid", "getStartPid", "setStartPid", "", "(III)V", "lib_release"}, k = 1, mv = {1, 4, 0}) public static final /* data */ 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); } /* JADX INFO: renamed from: component1, reason: from getter */ public final int getVid() { return this.vid; } /* JADX INFO: renamed from: component2, reason: from getter */ public final int getStartPid() { return this.startPid; } /* JADX INFO: renamed from: component3, reason: from getter */ public final int getEndPid() { return this.endPid; } public final CameraUsbInterval copy(int vid, int startPid, int endPid) { return new CameraUsbInterval(vid, startPid, endPid); } public boolean equals(Object other) { if (this != other) { if (other instanceof CameraUsbInterval) { CameraUsbInterval cameraUsbInterval = (CameraUsbInterval) other; 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) + a.b(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 sbF = a.F("CameraUsbInterval(vid="); sbF.append(this.vid); sbF.append(", startPid="); sbF.append(this.startPid); sbF.append(", endPid="); return a.y(sbF, this.endPid, ")"); } } private CameraHelper() { } /* JADX WARN: Multi-variable type inference failed */ public static /* synthetic */ List findDevices$default(CameraHelper cameraHelper, Context context, Function1 function1, int i2, Object obj) { if ((i2 & 2) != 0) { function1 = null; } return cameraHelper.findDevices(context, function1); } private final List getCameraPluginListById(Context context, String idStr) throws ExecutionException, InterruptedException { CameraUpgradeInfo cameraUpgradeInfoDecode = CameraUpgradeInfo.INSTANCE.decode(idStr); if (cameraUpgradeInfoDecode == null) { return EmptyList.f9307f; } List listFindDevices = findDevices(context, new CameraHelper$getCameraPluginListById$cameras$1(cameraUpgradeInfoDecode)); final ArrayList arrayList = new ArrayList(i.H(listFindDevices, 10)); Iterator it = listFindDevices.iterator(); while (it.hasNext()) { arrayList.add(((CameraHdiApi) it.next()).m0getCameraInfo()); } Object[] array = arrayList.toArray(new CompletableFuture[0]); Objects.requireNonNull(array, "null cannot be cast to non-null type kotlin.Array"); CompletableFuture[] completableFutureArr = (CompletableFuture[]) array; Object obj = CompletableFuture.allOf((CompletableFuture[]) Arrays.copyOf(completableFutureArr, completableFutureArr.length)).thenApply((Function) new Function() { // from class: com.cvte.dss.ups.camera.utils.CameraHelper.getCameraPluginListById.1 @Override // java.util.function.Function public final List apply(Void r3) { List list = arrayList; ArrayList arrayList2 = new ArrayList(i.H(list, 10)); Iterator it2 = list.iterator(); while (it2.hasNext()) { arrayList2.add((IUpsPlugin.FirmwareInfo) ((CompletableFuture) it2.next()).get()); } return arrayList2; } }).get(); o.b(obj, "CompletableFuture.allOf(…t.get() }\n }.get()"); return (List) obj; } public final void addUpgradingCamera(CameraUpgradeInfo cameraUpgradeInfo) { o.g(cameraUpgradeInfo, "cameraUpgradeInfo"); String id = cameraUpgradeInfo.getId(); ConcurrentHashMap concurrentHashMap = upgradingCameraMap; Integer num = concurrentHashMap.get(id); concurrentHashMap.put(id, Integer.valueOf(num != null ? 1 + num.intValue() : 1)); for (Map.Entry entry : concurrentHashMap.entrySet()) { Log.e(Plugin.TAG, "addUpgradingCamera key = " + entry.getKey() + " value = " + entry.getValue()); } } public final CameraHdiApi findDevice(Context context) { o.g(context, "context"); Object systemService = context.getSystemService("usb"); if (systemService == null) { throw new TypeCastException("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 findDevices(android.content.Context r7, kotlin.jvm.functions.Function1 r8) { /* r6 = this; java.lang.String r0 = "context" kotlin.jvm.internal.o.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" kotlin.jvm.internal.o.b(r0, r1) java.util.ArrayList r1 = new java.util.ArrayList r1.() 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 kotlin.jvm.internal.o.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 kotlin.jvm.internal.o.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.(r7, r2) goto L5e L5d: r3 = 0 L5e: if (r3 == 0) goto L25 r1.add(r3) goto L25 L64: return r1 L65: r.n r7 = new r.n java.lang.String r8 = "null cannot be cast to non-null type android.hardware.usb.UsbManager" r7.(r8) throw r7 */ throw new UnsupportedOperationException("Method not decompiled: com.cvte.dss.ups.camera.utils.CameraHelper.findDevices(android.content.Context, kotlin.jvm.functions.Function1):java.util.List"); } public final boolean isCameraDevice(int vid, int pid) { int size = infos.size(); for (int i2 = 0; i2 < size; i2++) { ArrayList arrayList = infos; if (vid == arrayList.get(i2).getVid() && pid == arrayList.get(i2).getPid()) { return true; } } int size2 = cameraUsbInterval.size(); for (int i3 = 0; i3 < size2; i3++) { ArrayList arrayList2 = cameraUsbInterval; if (vid == arrayList2.get(i3).getVid() && pid >= arrayList2.get(i3).getStartPid() && pid <= arrayList2.get(i3).getEndPid()) { return true; } } return false; } public final boolean isUpgrading(CameraUpgradeInfo cameraUpgradeInfo) { o.g(cameraUpgradeInfo, "cameraUpgradeInfo"); return upgradingCameraMap.keySet().contains(cameraUpgradeInfo.getId()); } public final void removeUpgradingCamera(CameraUpgradeInfo cameraUpgradeInfo) { o.g(cameraUpgradeInfo, "cameraUpgradeInfo"); upgradingCameraMap.remove(cameraUpgradeInfo.getId()); } public final void upgradeCamera(Context context, CameraUpgradeInfo upgradeInfo, final List> tasks, final IUpsPlugin.IUpgradeStatusListener listener) throws ExecutionException, InterruptedException { Object next; String errorMsg; Object objQ0; o.g(context, "context"); o.g(upgradeInfo, "upgradeInfo"); o.g(tasks, "tasks"); o.g(listener, "listener"); final float f2 = 0.1f; listener.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 progress) { listener.onProcess(progress); } }; upgradeProgressListener.startAutoProcess(0.9f, 90); Object[] array = tasks.toArray(new CompletableFuture[0]); Objects.requireNonNull(array, "null cannot be cast to non-null type kotlin.Array"); CompletableFuture[] completableFutureArr = (CompletableFuture[]) array; List list = (List) CompletableFuture.allOf((CompletableFuture[]) Arrays.copyOf(completableFutureArr, completableFutureArr.length)).thenApply((Function) new Function() { // from class: com.cvte.dss.ups.camera.utils.CameraHelper$upgradeCamera$results$1 @Override // java.util.function.Function public final List apply(Void r3) { List list2 = tasks; ArrayList arrayList = new ArrayList(i.H(list2, 10)); Iterator it = list2.iterator(); while (it.hasNext()) { arrayList.add((UpgradeResult) ((CompletableFuture) it.next()).get()); } return arrayList; } }).get(); o.b(list, "results"); Iterator it = list.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); errorMsg = upgradeResult.getErrorMsg(); if (errorMsg == null) { errorMsg = "upgrade camera fail"; } } else { CommonUtils.INSTANCE.safeSleep(TIME_MILL_SECOND_GET_VERSION); int i2 = 0; for (int i3 = 10; i2 < i3; i3 = 10) { List cameraPluginListById = getCameraPluginListById(context, upgradeInfo.getId()); ArrayList arrayList = new ArrayList(); for (Object obj : cameraPluginListById) { IUpsPlugin.FirmwareInfo firmwareInfo = (IUpsPlugin.FirmwareInfo) obj; if (o.a(firmwareInfo.getId(), upgradeInfo.getId()) && (kotlin.text.j.p(firmwareInfo.getVersion()) ^ true)) { arrayList.add(obj); } } int size = arrayList.size(); Integer orDefault = upgradingCameraMap.getOrDefault(upgradeInfo.getId(), 0); o.b(orDefault, "upgradingCameraMap.getOrDefault(upgradeInfo.id, 0)"); if (o.h(size, orDefault.intValue()) >= 0) { try { VmanMiddleWare vmanMiddleWare = VmanMiddleWare.getInstance(); o.b(vmanMiddleWare, "VmanMiddleWare.getInstance()"); objQ0 = Integer.valueOf(Log.i(Plugin.TAG, "setCameraStatusUpdate: result = " + vmanMiddleWare.getAvManager().setCameraStatusUpdate(true))); } catch (Throwable th) { objQ0 = i.q0(th); } if (Result.a(objQ0) != null) { Log.e(Plugin.TAG, "setCameraStatusUpdate error"); } upgradeProgressListener.process(1.0f); listener.onComplete(); removeUpgradingCamera(upgradeInfo); return; } CommonUtils.INSTANCE.safeSleep(TIME_MILL_SECOND_GET_VERSION_INTERNAL); i2++; } errorMsg = "check version fail"; } listener.onFailed(errorMsg); removeUpgradingCamera(upgradeInfo); } }