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

import android.annotation.SuppressLint;
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.api.reward.PAGRewardedAd;
import com.bytedance.sdk.openadsdk.api.reward.PAGRewardedAdLoadListener;
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.List;
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 class qhl {

    @SuppressLint({"StaticFieldLeak"})
    private static volatile qhl fm;
    private com.bytedance.sdk.component.wu.ro.lb jnr;
    private final Context ro;

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

    public static class fm implements PAGRewardedAdLoadListener {
        private final Context fm;
        private final boolean jnr;

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

        public fm(Context context, AdSlot adSlot, com.bytedance.sdk.openadsdk.core.model.fm fmVar, PAGRewardedAdLoadListener pAGRewardedAdLoadListener, boolean z10) {
            this.fm = context;
            this.ro = adSlot;
            this.f6976lb = fmVar;
            this.yz = pAGRewardedAdLoadListener;
            this.jnr = z10;
        }

        @Override // com.bytedance.sdk.openadsdk.api.PAGLoadListener
        /* JADX INFO: renamed from: fm, reason: merged with bridge method [inline-methods] */
        public void onAdLoaded(PAGRewardedAd pAGRewardedAd) {
            qhl.fm(this.fm).fm(this.ro, this.f6976lb, this.yz, pAGRewardedAd, this.jnr);
        }

        @Override // com.bytedance.sdk.openadsdk.api.PAGLoadListener, com.bytedance.sdk.openadsdk.common.wsy
        public void onError(int i10, String str) {
            PAGRewardedAdLoadListener pAGRewardedAdLoadListener = this.yz;
            if (pAGRewardedAdLoadListener != null) {
                pAGRewardedAdLoadListener.onError(i10, str);
            }
        }
    }

    public static class lb implements PAGRewardedAdLoadListener {
        private final PAGRewardedAdLoadListener fm;

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

        @Override // com.bytedance.sdk.openadsdk.api.PAGLoadListener, com.bytedance.sdk.openadsdk.common.wsy
        public void onError(int i10, String str) {
            if (this.f6977lb.decrementAndGet() > 0 || this.fm == null || !this.ro.compareAndSet(false, true)) {
                return;
            }
            this.fm.onError(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.qhl.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());
                }
            });
        }

        private lb(PAGRewardedAdLoadListener pAGRewardedAdLoadListener, com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
            this.ro = new AtomicBoolean(false);
            this.fm = pAGRewardedAdLoadListener;
            this.yz = fmVar;
            this.f6977lb = new AtomicInteger(fm());
        }

        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;
        }

        @Override // com.bytedance.sdk.openadsdk.api.PAGLoadListener
        /* JADX INFO: renamed from: fm, reason: merged with bridge method [inline-methods] */
        public void onAdLoaded(PAGRewardedAd pAGRewardedAd) {
            this.f6977lb.decrementAndGet();
            if (this.fm == null || !this.ro.compareAndSet(false, true)) {
                return;
            }
            this.fm.onAdLoaded(pAGRewardedAd);
        }
    }

    public static class ro 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 f6978lb;
        final AdSlot ro;

        public ro(lse lseVar, AdSlot adSlot, com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
            super("Reward Task");
            this.fm = lseVar;
            this.ro = adSlot;
            this.f6978lb = 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.qhl.ro.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) {
                    irt irtVarFm = irt.fm(com.bytedance.sdk.openadsdk.core.gof.fm());
                    ro roVar = ro.this;
                    irtVarFm.fm(roVar.ro, roVar.f6978lb);
                }
            });
        }
    }

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

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

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

    private void ro(final AdSlot adSlot) {
        mq mqVar = new mq();
        mqVar.ro = 2;
        if (com.bytedance.sdk.openadsdk.core.gof.yz().dsz(adSlot.getCodeId()) || adSlot.getExpressViewAcceptedWidth() > 0.0f || adSlot.isExpressAd()) {
            mqVar.f7209ef = 2;
        }
        com.bytedance.sdk.openadsdk.core.gof.lb().fm(adSlot, mqVar, 7, new maa() { // from class: com.bytedance.sdk.openadsdk.component.reward.qhl.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 irt.fm(qhl.this.ro).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 = irt.fm(qhl.this.ro).fm(fmVar);
                this.fm = zFm;
                return zFm;
            }

            @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;
                }
                qhl.this.fm(fmVar, new wey(qhl.this.ro, fmVar, adSlot), adSlot, true, (PAGRewardedAdLoadListener) null);
            }
        });
    }

    private void lb() {
        if (this.f6971lb.get()) {
            this.f6971lb.set(false);
            try {
                nt.fm(this.ajl);
            } catch (Exception unused) {
            }
        }
    }

    public static qhl fm(Context context) {
        if (fm == null) {
            synchronized (qhl.class) {
                try {
                    if (fm == null) {
                        fm = new qhl(context);
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        }
        return fm;
    }

    private void ro(final AdSlot adSlot, final PAGRewardedAdLoadListener pAGRewardedAdLoadListener) {
        if (com.bytedance.sdk.component.utils.fhx.lb()) {
            a6.a.a(adSlot.getBidAdm());
        }
        final long jCurrentTimeMillis = System.currentTimeMillis();
        mq mqVar = new mq();
        mqVar.ro = 1;
        if (com.bytedance.sdk.openadsdk.core.gof.yz().dsz(adSlot.getCodeId()) || adSlot.getExpressViewAcceptedWidth() > 0.0f || adSlot.isExpressAd()) {
            mqVar.f7209ef = 2;
        }
        com.bytedance.sdk.openadsdk.core.gof.lb().fm(adSlot, mqVar, 7, new maa() { // from class: com.bytedance.sdk.openadsdk.component.reward.qhl.2
            boolean fm = false;

            @Override // com.bytedance.sdk.openadsdk.core.maa, com.bytedance.sdk.openadsdk.core.lse.fm
            public void fm(int i10, String str) {
                PAGRewardedAdLoadListener pAGRewardedAdLoadListener2 = pAGRewardedAdLoadListener;
                if (pAGRewardedAdLoadListener2 != null) {
                    pAGRewardedAdLoadListener2.onError(i10, str);
                }
            }

            @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()) {
                    PAGRewardedAdLoadListener pAGRewardedAdLoadListener2 = pAGRewardedAdLoadListener;
                    if (pAGRewardedAdLoadListener2 != null) {
                        pAGRewardedAdLoadListener2.onError(-3, com.bytedance.sdk.openadsdk.core.ef.fm(-3));
                        lbVar.fm(-3);
                        lbVar.lb(6);
                        com.bytedance.sdk.openadsdk.core.model.lb.fm(lbVar);
                        return;
                    }
                    return;
                }
                wey weyVar = new wey(qhl.this.ro, 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 (pAGRewardedAdLoadListener != null && com.bytedance.sdk.openadsdk.core.gof.yz().mq() == 0) {
                    qhl.this.fm(adSlot, fmVar, pAGRewardedAdLoadListener, weyVar.fm(), this.fm);
                }
                qhl.this.fm(fmVar, weyVar, adSlot, false, pAGRewardedAdLoadListener);
            }

            @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 = irt.fm(qhl.this.ro).fm(adSlot.getCodeId(), true);
                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 = irt.fm(qhl.this.ro).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 fm(String str, lse lseVar) {
        irt.fm(this.ro).fm(str, lseVar);
    }

    public void fm() {
        try {
            irt.fm(this.ro).fm();
        } catch (Throwable unused) {
        }
    }

    private void ro() {
        if (this.f6971lb.get()) {
            return;
        }
        this.f6971lb.set(true);
        nt.fm(this.ajl, this.ro);
    }

    public void fm(AdSlot adSlot, PAGRewardedAdLoadListener pAGRewardedAdLoadListener) {
        ro(adSlot, pAGRewardedAdLoadListener);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar, wey weyVar, AdSlot adSlot, boolean z10, PAGRewardedAdLoadListener pAGRewardedAdLoadListener) {
        if (!z10) {
            com.bytedance.sdk.openadsdk.onz.lb.fm().fm(fmVar.wsy());
        }
        lb lbVar = new lb(new fm(this.ro, adSlot, fmVar, pAGRewardedAdLoadListener, 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, weyVar, adSlot, z10, lbVar);
                }
            } else {
                fm(fmVar, lseVar, weyVar, adSlot, z10, lbVar);
            }
            if (fmVar.ef() && iYwr != 43) {
                return;
            }
        }
    }

    private 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++) {
            lse lseVar = fmVar.jnr().get(i10);
            if (i10 >= iIrt) {
                return;
            }
            com.bytedance.sdk.openadsdk.core.fhx.lb.fm.fm().fm(lseVar, new fm.InterfaceC0069fm() { // from class: com.bytedance.sdk.openadsdk.component.reward.qhl.3
                @Override // com.bytedance.sdk.openadsdk.core.fhx.lb.fm.InterfaceC0069fm
                public void fm(boolean z10) {
                    com.bytedance.sdk.component.utils.wey.fm("RewardVideoLoadManager", "onCachedResponse: i=" + i10 + ", isSuccess=" + z10);
                }
            });
        }
    }

    private void fm(final com.bytedance.sdk.openadsdk.core.model.fm fmVar, lse lseVar, final wey weyVar, final AdSlot adSlot, final boolean z10, final lb lbVar) {
        if (z10 && !ai.lb(lseVar) && com.bytedance.sdk.openadsdk.core.gof.yz().mq(adSlot.getCodeId()).yz == 1 && !com.bytedance.sdk.component.utils.gof.yz(this.ro)) {
            fm(new ro(lseVar, adSlot, fmVar));
            return;
        }
        boolean z11 = lbVar != null && com.bytedance.sdk.openadsdk.core.gof.yz().mq() == 1;
        if (ai.lb(lseVar)) {
            if (z10) {
                irt.fm(this.ro).fm(adSlot, fmVar);
            }
        } else if (lseVar.ex() != null) {
            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.qhl.4
                @Override // y5.a
                public void fm(com.bykv.vk.openvk.fm.fm.fm.lb.lb lbVar2, int i10) {
                    weyVar.ro();
                    if (z10) {
                        irt.fm(qhl.this.ro).fm(adSlot, fmVar);
                    } else {
                        if (lbVar == null || com.bytedance.sdk.openadsdk.core.gof.yz().mq() != 1) {
                            return;
                        }
                        lbVar.onAdLoaded(weyVar.fm());
                    }
                }

                @Override // y5.a
                public void fm(com.bykv.vk.openvk.fm.fm.fm.lb.lb lbVar2, int i10, String str) {
                    if (lbVar == null || com.bytedance.sdk.openadsdk.core.gof.yz().mq() != 1) {
                        return;
                    }
                    lbVar.onError(i10, str);
                }
            });
            return;
        }
        if (z11) {
            lbVar.onAdLoaded(weyVar.fm());
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(final AdSlot adSlot, final com.bytedance.sdk.openadsdk.core.model.fm fmVar, PAGRewardedAdLoadListener pAGRewardedAdLoadListener, PAGRewardedAd pAGRewardedAd, final boolean z10) {
        com.bytedance.sdk.openadsdk.core.fhx.ro().post(new Runnable() { // from class: com.bytedance.sdk.openadsdk.component.reward.qhl.5
            @Override // java.lang.Runnable
            public void run() {
                if (z10) {
                    qhl.this.lb(adSlot);
                } else {
                    irt.fm(qhl.this.ro).fm(adSlot, fmVar);
                    qhl.this.lb(adSlot);
                }
            }
        });
        if (pAGRewardedAdLoadListener != null) {
            pAGRewardedAdLoadListener.onAdLoaded(pAGRewardedAd);
        }
    }

    private void fm(ro roVar) {
        if (roVar == null) {
            return;
        }
        if (this.yz.size() > 0) {
            this.yz.remove(0);
        }
        this.yz.add(roVar);
    }
}