package com.mbridge.msdk.videocommon.download; import android.content.Context; import android.text.TextUtils; import com.mbridge.msdk.MBridgeConstans; import com.mbridge.msdk.c.d; import com.mbridge.msdk.foundation.entity.CampaignEx; import com.mbridge.msdk.foundation.tools.w; import com.mbridge.msdk.videocommon.d.c; import com.mbridge.msdk.videocommon.listener.a; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; /* compiled from: DownLoadManager */ public class b { private static b a; private ThreadPoolExecutor b; private boolean c = false; private ConcurrentHashMap<String, d> d = new ConcurrentHashMap<>(); private Map<String, List<Map<String, a>>> e; private Map<String, List<CampaignEx>> f; private Map<String, List<a>> g; private b() { ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 15, 15, TimeUnit.SECONDS, new LinkedBlockingDeque(), new ThreadPoolExecutor.DiscardPolicy()); this.b = threadPoolExecutor; threadPoolExecutor.allowCoreThreadTimeOut(true); } public static b getInstance() { if (a == null) { synchronized (b.class) { if (a == null) { a = new b(); } } } return a; } public final a a(String str, String str2) { d c2 = c(str); if (c2 != null) { return c2.a(str2); } return null; } public final List<CampaignEx> a(String str) { Map<String, List<CampaignEx>> map = this.f; if (map == null || !map.containsKey(str)) { return null; } return this.f.get(str); } public final List<a> b(String str) { Map<String, List<a>> map = this.g; if (map == null || !map.containsKey(str)) { return null; } return this.g.get(str); } public final d c(String str) { ConcurrentHashMap<String, d> concurrentHashMap = this.d; if (concurrentHashMap == null || !concurrentHashMap.containsKey(str)) { return null; } return this.d.get(str); } public final boolean a(int i, String str, boolean z) { try { d c2 = c(str); if (c2 == null || c2.a(i, z) == null) { return false; } return true; } catch (Exception e2) { if (!MBridgeConstans.DEBUG) { return false; } e2.printStackTrace(); return false; } } public final boolean a(int i, String str, boolean z, int i2, boolean z2, int i3, List<CampaignEx> list) { return a(i, str, z, i2, z2, i3, list, false); } /* JADX WARNING: Code restructure failed: missing block: B:67:0x0127, code lost: if (r5.size() >= r18) goto L_0x018b; */ /* JADX WARNING: Code restructure failed: missing block: B:87:0x0189, code lost: if (r4.size() > 0) goto L_0x018b; */ /* JADX WARNING: Removed duplicated region for block: B:119:0x0243 */ public final boolean a(int i, String str, boolean z, int i2, boolean z2, int i3, List<CampaignEx> list, boolean z3) { Exception e2; boolean z4; CampaignEx campaignEx; boolean z5 = false; if (list != null) { try { if (list.size() != 0) { d c2 = c(str); if (c2 != null) { List<a> a2 = c2.a(str, i, z, list, z3); if (a2 != null) { if (a2.size() != 0) { if (z2) { if (list.size() <= 0 || (campaignEx = list.get(0)) == null || campaignEx.getRsIgnoreCheckRule() == null || campaignEx.getRsIgnoreCheckRule().size() <= 0 || !campaignEx.getRsIgnoreCheckRule().contains(0)) { z4 = false; } else { w.b("DownLoadManager", "Is not check video download status with TPL"); z4 = true; } if (i3 == 0) { try { ArrayList arrayList = new ArrayList(); for (a aVar : a2) { for (CampaignEx campaignEx2 : list) { if (!(aVar == null || aVar.g() == null || campaignEx2 == null || !campaignEx2.getId().equals(aVar.g().getId()) || !campaignEx2.getRequestId().equals(aVar.g().getRequestId()))) { arrayList.add(aVar); } } } if (arrayList.size() <= 0) { z5 = z4; } } catch (Exception e3) { e2 = e3; z5 = z4; if (MBridgeConstans.DEBUG) { } return z5; } } else { ArrayList arrayList2 = new ArrayList(); for (a aVar2 : a2) { for (CampaignEx campaignEx3 : list) { if (!(aVar2 == null || aVar2.g() == null || campaignEx3 == null || !campaignEx3.getId().equals(aVar2.g().getId()) || !campaignEx3.getRequestId().equals(aVar2.g().getRequestId()))) { arrayList2.add(aVar2); } } } } } else { ArrayList arrayList3 = new ArrayList(); for (a aVar3 : a2) { for (CampaignEx campaignEx4 : list) { if (!(aVar3 == null || aVar3.g() == null || campaignEx4 == null || !campaignEx4.getId().equals(aVar3.g().getId()) || !campaignEx4.getRequestId().equals(aVar3.g().getRequestId()))) { arrayList3.add(aVar3); } } } } z5 = true; } } if (z5) { Map<String, List<Map<String, a>>> map = this.e; if (map == null) { this.e = new HashMap(); } else if (map.containsKey(str)) { this.e.remove(str); } Map<String, List<a>> map2 = this.g; if (map2 == null) { this.g = new HashMap(); } else if (map2.containsKey(str)) { this.g.remove(str); } Map<String, List<CampaignEx>> map3 = this.f; if (map3 == null) { this.f = new HashMap(); } else if (map3.containsKey(str)) { this.f.remove(str); } if (a2 != null && a2.size() > 0) { ArrayList arrayList4 = new ArrayList(); ArrayList arrayList5 = new ArrayList(); ArrayList arrayList6 = new ArrayList(); for (a aVar4 : a2) { ConcurrentHashMap concurrentHashMap = new ConcurrentHashMap(); CampaignEx g2 = aVar4.g(); concurrentHashMap.put(g2.getId() + g2.getVideoUrlEncode() + g2.getBidToken(), aVar4); arrayList4.add(concurrentHashMap); arrayList5.add(g2); arrayList6.add(aVar4); } this.e.put(str, arrayList4); this.f.put(str, arrayList5); this.g.put(str, arrayList6); } } } } } catch (Exception e4) { e2 = e4; if (MBridgeConstans.DEBUG) { e2.printStackTrace(); } return z5; } } return z5; } public void load(String str) { d c2 = c(str); if (c2 != null) { c2.a(); } } public d createUnitCache(Context context, String str, List<CampaignEx> list, int i, a aVar) { if (TextUtils.isEmpty(str) || list == null || list.size() == 0) { return null; } if (this.d.containsKey(str)) { d dVar = this.d.get(str); if (i == 94 || i == 287) { dVar.a(list.get(0).getRequestId(), aVar); } else { dVar.a(aVar); } dVar.a(list); return dVar; } d dVar2 = new d(context, list, this.b, str, i); if (aVar != null) { dVar2.a(aVar); } this.d.put(str, dVar2); return dVar2; } public d createUnitCache(Context context, String str, CampaignEx campaignEx, int i, a aVar) { if (TextUtils.isEmpty(str) || campaignEx == null) { return null; } if (this.d.containsKey(str)) { d dVar = this.d.get(str); if (i == 94 || i == 287) { dVar.a(campaignEx.getRequestId(), aVar); } else { dVar.a(aVar); } dVar.a(campaignEx); return dVar; } d dVar2 = new d(context, campaignEx, this.b, str, i); if (aVar != null) { dVar2.a(aVar); } this.d.put(str, dVar2); return dVar2; } public final void a(boolean z) { this.c = z; ConcurrentHashMap<String, d> concurrentHashMap = this.d; if (concurrentHashMap != null) { for (Map.Entry<String, d> entry : concurrentHashMap.entrySet()) { d value = entry.getValue(); if (value != null) { value.b(); } } } } public final int b(String str, String str2) { CopyOnWriteArrayList<Map<String, a>> c2; a value; CampaignEx g2; ConcurrentHashMap<String, d> concurrentHashMap = this.d; if (concurrentHashMap != null) { for (Map.Entry<String, d> entry : concurrentHashMap.entrySet()) { d value2 = entry.getValue(); if (!(value2 == null || (c2 = value2.c()) == null)) { int size = c2.size(); for (int i = 0; i < size; i++) { Map<String, a> map = c2.get(i); if (map != null) { Iterator<Map.Entry<String, a>> it = map.entrySet().iterator(); if (!(!it.hasNext() || (value = it.next().getValue()) == null || (g2 = value.g()) == null)) { String videoUrlEncode = g2.getVideoUrlEncode(); if (!TextUtils.isEmpty(str2) && !TextUtils.isEmpty(videoUrlEncode) && str2.equals(videoUrlEncode)) { return value.f(); } } } } continue; } } } return 0; } public final void b(boolean z) { if (!z) { this.c = false; } else if (this.c) { return; } ConcurrentHashMap<String, d> concurrentHashMap = this.d; if (concurrentHashMap != null) { for (Map.Entry<String, d> entry : concurrentHashMap.entrySet()) { entry.getValue().a(); } } } public final void a() { ConcurrentHashMap<String, d> concurrentHashMap = this.d; if (concurrentHashMap != null) { for (Map.Entry<String, d> entry : concurrentHashMap.entrySet()) { d value = entry.getValue(); String key = entry.getKey(); try { Class.forName("com.mbridge.msdk.videocommon.d.a"); c a2 = com.mbridge.msdk.videocommon.d.b.a().a(com.mbridge.msdk.foundation.controller.a.f().k(), key); if (a2 != null) { if (a2.v() == 2) { value.b(); } else { value.a(); } } } catch (Exception e2) { w.d("DownLoadManager", e2.getMessage()); try { if (!TextUtils.isEmpty(key)) { d e3 = com.mbridge.msdk.c.b.a().e(com.mbridge.msdk.foundation.controller.a.f().k(), key); if (e3 == null) { e3 = d.e(key); } if (e3.k() == 2) { value.b(); } else { value.a(); } } } catch (Exception e4) { w.d("DownLoadManager", e4.getMessage()); } } } } } }