package com.bytedance.sdk.openadsdk.component.reward;

import android.content.Context;
import android.content.Intent;
import android.text.TextUtils;
import androidx.annotation.Nullable;
import com.bytedance.sdk.component.utils.nt;
import com.bytedance.sdk.openadsdk.AdSlot;
import com.bytedance.sdk.openadsdk.CacheDirFactory;
import com.bytedance.sdk.openadsdk.core.fhx.lb.fm;
import com.bytedance.sdk.openadsdk.core.maa;
import com.bytedance.sdk.openadsdk.core.model.ai;
import com.bytedance.sdk.openadsdk.core.model.hi;
import com.bytedance.sdk.openadsdk.core.model.lse;
import com.bytedance.sdk.openadsdk.core.model.mq;
import e6.a;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import org.json.JSONObject;
import y5.c;

/* JADX INFO: loaded from: classes2.dex */
public abstract class fm<L, A> {
    protected final Context fm;
    protected com.bytedance.sdk.component.wu.ro.lb yz;
    protected final AtomicBoolean ro = new AtomicBoolean(false);

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    protected final List<fm<L, A>.yz> f6901lb = Collections.synchronizedList(new ArrayList());
    private final nt.fm jnr = new nt.fm() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.6
        @Override // com.bytedance.sdk.component.utils.nt.fm
        public void fm(Context context, Intent intent, boolean z10, int i10) {
            if (z10) {
                fm fmVar = fm.this;
                if (fmVar.yz == null) {
                    fmVar.yz = new ro("net connect task", fmVar.f6901lb);
                    com.bytedance.sdk.component.utils.ef.fm().post(fm.this.yz);
                }
            }
        }
    };

    /* JADX INFO: renamed from: com.bytedance.sdk.openadsdk.component.reward.fm$fm, reason: collision with other inner class name */
    public class C0051fm {
        protected final AdSlot fm;

        /* JADX INFO: renamed from: lb, reason: collision with root package name */
        protected final L f6906lb;
        protected final com.bytedance.sdk.openadsdk.core.model.fm ro;
        protected final boolean yz;

        public C0051fm(AdSlot adSlot, com.bytedance.sdk.openadsdk.core.model.fm fmVar, L l10, boolean z10) {
            this.fm = adSlot;
            this.ro = fmVar;
            this.f6906lb = l10;
            this.yz = z10;
        }

        public void fm(int i10, String str) {
            L l10 = this.f6906lb;
            if (l10 != null) {
                fm.this.fm(l10, i10, str);
            }
        }

        public void fm(A a10) {
            fm.this.fm(this.fm, this.ro, this.f6906lb, a10, this.yz);
        }
    }

    public class lb {
        protected final fm<L, A>.C0051fm fm;

        /* JADX INFO: renamed from: lb, reason: collision with root package name */
        protected final AtomicInteger f6907lb;
        protected final AtomicBoolean ro;
        protected final com.bytedance.sdk.openadsdk.core.model.fm yz;

        private int fm() {
            if (!this.yz.ajl()) {
                return 0;
            }
            int i10 = 0;
            for (int i11 = 0; i11 < this.yz.jnr().size(); i11++) {
                lse lseVar = this.yz.jnr().get(i11);
                if (lseVar != null && !ai.lb(lseVar) && lseVar.ex() != null) {
                    i10++;
                }
            }
            return i10;
        }

        private lb(fm<L, A>.C0051fm c0051fm, com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
            this.ro = new AtomicBoolean(false);
            this.fm = c0051fm;
            this.yz = fmVar;
            this.f6907lb = new AtomicInteger(fm());
        }

        public void fm(int i10, String str) {
            if (this.f6907lb.decrementAndGet() > 0 || !this.ro.compareAndSet(false, true)) {
                return;
            }
            this.fm.fm(i10, str);
            com.bytedance.sdk.openadsdk.irt.yz.fm("choose_ad_load_error", false, new com.bytedance.sdk.openadsdk.irt.ro() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.lb.1
                @Override // com.bytedance.sdk.openadsdk.irt.ro
                @Nullable
                public com.bytedance.sdk.openadsdk.irt.fm.lb fm() throws Exception {
                    JSONObject jSONObject = new JSONObject();
                    jSONObject.put("req_id", lb.this.yz.lb());
                    return com.bytedance.sdk.openadsdk.irt.fm.yz.ro().fm("choose_ad_load_error").ro(jSONObject.toString());
                }
            });
        }

        public void fm(A a10) {
            this.f6907lb.decrementAndGet();
            if (this.fm == null || !this.ro.compareAndSet(false, true)) {
                return;
            }
            this.fm.fm(a10);
        }
    }

    public class ro extends com.bytedance.sdk.component.wu.ro.lb {
        private final List<fm<L, A>.yz> ro;

        public ro(String str, List<fm<L, A>.yz> list) {
            super(str);
            this.ro = list;
        }

        @Override // java.lang.Runnable
        public void run() {
            List<fm<L, A>.yz> list = this.ro;
            if (list == null || list.isEmpty()) {
                fm.this.yz = null;
                return;
            }
            ArrayList arrayList = new ArrayList(this.ro);
            this.ro.clear();
            Iterator it = arrayList.iterator();
            while (it.hasNext()) {
                try {
                    ((yz) it.next()).run();
                } catch (Exception e10) {
                    com.bytedance.sdk.component.utils.wey.fm("BVL", "continue download task error", e10);
                }
            }
            fm.this.yz = null;
        }
    }

    public class yz extends com.bytedance.sdk.component.wu.ro.lb {
        final lse fm;

        /* JADX INFO: renamed from: lb, reason: collision with root package name */
        final com.bytedance.sdk.openadsdk.core.model.fm f6908lb;
        final AdSlot ro;

        public yz(lse lseVar, AdSlot adSlot, com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
            super("VideoPreloadTask");
            this.fm = lseVar;
            this.ro = adSlot;
            this.f6908lb = fmVar;
        }

        @Override // java.lang.Runnable
        public void run() {
            lse lseVar = this.fm;
            if (lseVar == null || lseVar.ex() == null) {
                return;
            }
            com.bytedance.sdk.openadsdk.core.fhx.fm.ro roVarFm = lse.fm(((a) CacheDirFactory.getICacheDir(this.fm.il())).b(), this.fm);
            roVarFm.fm("material_meta", this.fm);
            roVarFm.fm("ad_slot", this.ro);
            com.bytedance.sdk.openadsdk.core.fhx.jnr.fm.fm(roVarFm, new c() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.yz.1
                @Override // y5.a
                public void fm(com.bykv.vk.openvk.fm.fm.fm.lb.lb lbVar, int i10, String str) {
                }

                @Override // y5.a
                public void fm(com.bykv.vk.openvk.fm.fm.fm.lb.lb lbVar, int i10) {
                    fhx fhxVarFm = fm.this.fm();
                    yz yzVar = yz.this;
                    fhxVarFm.fm(yzVar.ro, yzVar.f6908lb);
                }
            });
        }
    }

    public fm(Context context) {
        this.fm = context == null ? com.bytedance.sdk.openadsdk.core.gof.fm() : context.getApplicationContext();
        lb();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void lb(AdSlot adSlot) {
        fm().fm(adSlot.getCodeId());
    }

    private void ro(final AdSlot adSlot) {
        com.bytedance.sdk.openadsdk.core.gof.lb().fm(adSlot, fm(adSlot, true), ro(), new maa() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.1
            boolean fm = false;

            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.lse.fm
            public void fm(int i10, String str) {
            }

            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.sds
            public String fm() {
                return fm.this.fm().fm(adSlot.getCodeId(), false);
            }

            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.sds
            public boolean fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
                boolean zFm = fm.this.fm().fm(fmVar);
                this.fm = zFm;
                return zFm;
            }

            /* JADX WARN: Multi-variable type inference failed */
            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.lse.fm
            public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar, com.bytedance.sdk.openadsdk.core.model.lb lbVar) {
                if (this.fm || fmVar.jnr() == null || fmVar.jnr().isEmpty()) {
                    return;
                }
                fm fmVar2 = fm.this;
                fm.this.fm(fmVar, fmVar2.fm(fmVar2.fm, fmVar, adSlot), adSlot, true, (Object) null);
            }
        });
    }

    public abstract int ajl();

    public void finalize() throws Throwable {
        super.finalize();
        if (this.yz != null) {
            try {
                com.bytedance.sdk.component.utils.ef.fm().removeCallbacks(this.yz);
            } catch (Throwable unused) {
            }
            this.yz = null;
        }
        yz();
    }

    public abstract fhx fm();

    public abstract A fm(Context context, com.bytedance.sdk.openadsdk.core.model.fm fmVar, AdSlot adSlot);

    public abstract Object fm(A a10);

    public abstract void fm(L l10, int i10, String str);

    public abstract void fm(L l10, Object obj);

    public void jnr() {
        try {
            fm().fm();
        } catch (Throwable unused) {
        }
    }

    public abstract int ro();

    public abstract void ro(A a10);

    public void yz() {
        if (this.ro.get()) {
            this.ro.set(false);
            try {
                nt.fm(this.jnr);
            } catch (Exception unused) {
            }
        }
    }

    private void ro(final AdSlot adSlot, final L l10) {
        final long jCurrentTimeMillis = System.currentTimeMillis();
        com.bytedance.sdk.openadsdk.core.gof.lb().fm(adSlot, fm(adSlot, false), ro(), new maa() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.2
            boolean fm = false;

            /* JADX WARN: Multi-variable type inference failed */
            /* JADX WARN: Type inference fix 'apply assigned field type' failed
            java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$PrimitiveArg
            	at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593)
            	at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35)
            	at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94)
             */
            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.lse.fm
            public void fm(int i10, String str) {
                Object obj = l10;
                if (obj != null) {
                    fm.this.fm(obj, i10, str);
                }
            }

            /* JADX WARN: Multi-variable type inference failed */
            /* JADX WARN: Type inference fix 'apply assigned field type' failed
            java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$PrimitiveArg
            	at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593)
            	at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35)
            	at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309)
            	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94)
             */
            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.lse.fm
            public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar, com.bytedance.sdk.openadsdk.core.model.lb lbVar) {
                if (fmVar.jnr() == null || fmVar.jnr().isEmpty()) {
                    Object obj = l10;
                    if (obj != null) {
                        fm.this.fm(obj, -3, com.bytedance.sdk.openadsdk.core.ef.fm(-3));
                        lbVar.fm(-3);
                        lbVar.lb(fm.this.ajl());
                        com.bytedance.sdk.openadsdk.core.model.lb.fm(lbVar);
                        return;
                    }
                    return;
                }
                fm fmVar2 = fm.this;
                Object objFm = fmVar2.fm(fmVar2.fm, fmVar, adSlot);
                if (!TextUtils.isEmpty(adSlot.getBidAdm())) {
                    com.bytedance.sdk.openadsdk.maa.fm.yz.fm().fm(fmVar.jnr().isEmpty() ? null : fmVar.jnr().get(0));
                    com.bytedance.sdk.openadsdk.irt.yz.fm(fmVar.wsy(), System.currentTimeMillis() - jCurrentTimeMillis);
                }
                if (l10 != null && com.bytedance.sdk.openadsdk.core.gof.yz().mq() == 0) {
                    fm.this.fm(adSlot, fmVar, l10, objFm, this.fm);
                }
                fm.this.fm(fmVar, objFm, adSlot, false, l10);
            }

            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.sds
            public String fm() {
                if (!TextUtils.isEmpty(adSlot.getBidAdm())) {
                    return null;
                }
                String strFm = fm.this.fm().fm(adSlot.getCodeId(), true);
                TextUtils.isEmpty(strFm);
                if (TextUtils.isEmpty(strFm)) {
                    return null;
                }
                return strFm;
            }

            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.sds
            public boolean fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
                boolean zFm = fm.this.fm().fm(fmVar);
                this.fm = zFm;
                return zFm;
            }
        });
    }

    public void fm(AdSlot adSlot) {
        if (adSlot == null || TextUtils.isEmpty(adSlot.getCodeId()) || !TextUtils.isEmpty(adSlot.getBidAdm())) {
            return;
        }
        ro(adSlot);
    }

    public void lb() {
        if (this.ro.get()) {
            return;
        }
        this.ro.set(true);
        nt.fm(this.jnr, this.fm);
    }

    public void fm(AdSlot adSlot, L l10) {
        Objects.toString(adSlot);
        Objects.toString(l10);
        ro(adSlot, l10);
    }

    public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar, A a10, AdSlot adSlot, boolean z10, L l10) {
        if (!z10) {
            com.bytedance.sdk.openadsdk.onz.lb.fm().fm(fmVar.wsy());
        }
        fm<L, A>.lb lbVar = new lb(new C0051fm(adSlot, fmVar, l10, false), fmVar);
        fm(fmVar);
        for (int i10 = 0; i10 < fmVar.jnr().size(); i10++) {
            lse lseVar = fmVar.jnr().get(i10);
            int iYwr = lseVar.ywr();
            if (i10 == 0 && iYwr == 43) {
                lseVar.ex().f5935o = 0;
            }
            if (com.bytedance.sdk.openadsdk.component.reward.lb.wu.fm(lseVar)) {
                if (com.bytedance.sdk.openadsdk.component.reward.lb.wu.jnr()) {
                    lseVar.ex().f5935o = 0;
                    fm(fmVar, lseVar, a10, adSlot, z10, lbVar);
                }
            } else {
                fm(fmVar, lseVar, a10, adSlot, z10, lbVar);
            }
            if (fmVar.ef() && iYwr != 43) {
                return;
            }
        }
    }

    public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
        hi hiVarKu = fmVar.ku();
        int iIrt = fmVar.ef() ? 10 : 1;
        if (hiVarKu != null) {
            iIrt = hiVarKu.irt();
        }
        for (final int i10 = 0; i10 < fmVar.jnr().size() && i10 < iIrt; i10++) {
            com.bytedance.sdk.openadsdk.core.fhx.lb.fm.fm().fm(fmVar.jnr().get(i10), new fm.InterfaceC0069fm() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.3
                @Override // com.bytedance.sdk.openadsdk.core.fhx.lb.fm.InterfaceC0069fm
                public void fm(boolean z10) {
                    com.bytedance.sdk.component.utils.wey.fm("BVL", "onCachedResponse: i=" + i10 + ", isSuccess=" + z10);
                }
            });
        }
    }

    private boolean fm(boolean z10, lse lseVar, AdSlot adSlot) {
        if (z10) {
            return !ai.lb(lseVar) && lse.jnr(lseVar) && com.bytedance.sdk.openadsdk.core.gof.yz().mq(adSlot.getCodeId()).yz == 1 && !com.bytedance.sdk.component.utils.gof.yz(this.fm);
        }
        return false;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public boolean fm(fm<L, A>.lb lbVar) {
        return lbVar != null && com.bytedance.sdk.openadsdk.core.gof.yz().mq() == 1;
    }

    private void fm(lse lseVar, final AdSlot adSlot, final com.bytedance.sdk.openadsdk.core.model.fm fmVar, final A a10, final boolean z10, final fm<L, A>.lb lbVar) {
        com.bytedance.sdk.openadsdk.core.fhx.fm.ro roVarFm = lse.fm(((a) CacheDirFactory.getICacheDir(lseVar.il())).b(), lseVar);
        roVarFm.fm("material_meta", lseVar);
        roVarFm.fm("ad_slot", adSlot);
        com.bytedance.sdk.openadsdk.core.fhx.jnr.fm.fm(roVarFm, new c() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.4
            /* JADX WARN: Multi-variable type inference failed */
            @Override // y5.a
            public void fm(com.bykv.vk.openvk.fm.fm.fm.lb.lb lbVar2, int i10) {
                fm.this.ro(a10);
                if (z10) {
                    fm.this.fm().fm(adSlot, fmVar);
                } else if (fm.this.fm(lbVar)) {
                    lbVar.fm(a10);
                }
            }

            @Override // y5.a
            public void fm(com.bykv.vk.openvk.fm.fm.fm.lb.lb lbVar2, int i10, String str) {
                if (fm.this.fm(lbVar)) {
                    lbVar.fm(i10, str);
                }
            }
        });
    }

    public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar, lse lseVar, A a10, AdSlot adSlot, boolean z10, fm<L, A>.lb lbVar) {
        if (fm(z10, lseVar, adSlot)) {
            fm((yz) new yz(lseVar, adSlot, fmVar));
            return;
        }
        boolean zFm = fm((lb) lbVar);
        if (ai.lb(lseVar)) {
            if (z10) {
                fm().fm(adSlot, fmVar);
            }
        } else if (lse.jnr(lseVar)) {
            if (lseVar.ex() == null) {
                return;
            }
            fm(lseVar, adSlot, fmVar, a10, z10, lbVar);
            return;
        } else if (z10) {
            fm().fm(adSlot, fmVar);
        }
        if (zFm) {
            lbVar.fm(a10);
        }
    }

    public void fm(final AdSlot adSlot, final com.bytedance.sdk.openadsdk.core.model.fm fmVar, L l10, A a10, final boolean z10) {
        com.bytedance.sdk.openadsdk.core.fhx.ro().post(new Runnable() { // from class: com.bytedance.sdk.openadsdk.component.reward.fm.5
            @Override // java.lang.Runnable
            public void run() {
                if (z10) {
                    fm.this.lb(adSlot);
                } else {
                    fm.this.fm().fm(adSlot, fmVar);
                    fm.this.lb(adSlot);
                }
            }
        });
        if (l10 != null) {
            fm(l10, fm(a10));
        }
    }

    public void fm(fm<L, A>.yz yzVar) {
        if (yzVar == null) {
            return;
        }
        if (this.f6901lb.size() > 0) {
            this.f6901lb.remove(0);
        }
        this.f6901lb.add(yzVar);
    }

    public mq fm(AdSlot adSlot, boolean z10) {
        mq mqVar = new mq();
        if (adSlot != null && (com.bytedance.sdk.openadsdk.core.gof.yz().dsz(adSlot.getCodeId()) || adSlot.getExpressViewAcceptedWidth() > 0.0f || adSlot.isExpressAd())) {
            mqVar.f7209ef = 2;
        }
        if (ro() == 7) {
            mqVar.ro = z10 ? 2 : 1;
        } else {
            mqVar.f7210lb = z10 ? 2 : 1;
        }
        return mqVar;
    }

    public void fm(String str, lse lseVar) {
        fm().fm(str, lseVar);
    }
}