package com.bytedance.sdk.openadsdk.core;

import android.content.Intent;
import android.text.TextUtils;
import androidx.annotation.MainThread;
import com.google.android.gms.measurement.internal.u1;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes2.dex */
public class ai {
    private static ai fm;
    private com.bytedance.sdk.openadsdk.fm.lb.ro ajl;
    private com.bytedance.sdk.openadsdk.fm.jnr.fm jnr;
    private com.bytedance.sdk.openadsdk.fm.yz.ro wsy;
    private final AtomicInteger ro = new AtomicInteger(0);

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private Map<Integer, com.bytedance.sdk.openadsdk.core.model.fm> f7017lb = new ConcurrentHashMap();
    private final ConcurrentHashMap<String, fm<?>> yz = new ConcurrentHashMap<>();
    private final Map<String, ro> wu = new HashMap();

    public static class fm<T> {
        public final T fm;

        /* JADX INFO: renamed from: lb, reason: collision with root package name */
        public final long f7018lb = System.currentTimeMillis();
        public final String ro;

        public fm(T t10, String str) {
            this.fm = t10;
            this.ro = str;
        }
    }

    public interface ro {
        void fm();
    }

    private ai() {
    }

    public void fm(com.bytedance.sdk.openadsdk.fm.jnr.fm fmVar) {
        this.jnr = fmVar;
    }

    public void jnr() {
        this.jnr = null;
        this.ajl = null;
        this.wsy = null;
    }

    public com.bytedance.sdk.openadsdk.fm.lb.ro lb() {
        return this.ajl;
    }

    public com.bytedance.sdk.openadsdk.fm.jnr.fm ro() {
        return this.jnr;
    }

    public com.bytedance.sdk.openadsdk.fm.yz.ro yz() {
        return this.wsy;
    }

    private static String yz(com.bytedance.sdk.openadsdk.core.model.lse lseVar) {
        if (lseVar == null) {
            return null;
        }
        String strSs = lseVar.ss();
        return TextUtils.isEmpty(strSs) ? String.valueOf(lseVar.hashCode()) : strSs;
    }

    public void fm(com.bytedance.sdk.openadsdk.fm.lb.ro roVar) {
        this.ajl = roVar;
    }

    public void lb(int i10) {
        this.f7017lb.remove(Integer.valueOf(i10));
    }

    public com.bytedance.sdk.openadsdk.core.model.fm ro(int i10) {
        return this.f7017lb.remove(Integer.valueOf(i10));
    }

    public void fm(com.bytedance.sdk.openadsdk.fm.yz.ro roVar) {
        this.wsy = roVar;
    }

    public void lb(com.bytedance.sdk.openadsdk.core.model.lse lseVar) {
        String strYz = yz(lseVar);
        if (TextUtils.isEmpty(strYz)) {
            return;
        }
        this.wu.remove(strYz);
    }

    public void ro(com.bytedance.sdk.openadsdk.core.model.lse lseVar) {
        ro roVar;
        if (lseVar == null) {
            return;
        }
        String strYz = yz(lseVar);
        if (TextUtils.isEmpty(strYz) || (roVar = this.wu.get(strYz)) == null) {
            return;
        }
        roVar.fm();
    }

    public <T> void fm(String str, T t10) {
        if (TextUtils.isEmpty(str) || t10 == null) {
            return;
        }
        this.yz.put(str, new fm<>(t10, str));
    }

    public <T> T fm(String str, Class<T> cls) {
        fm<?> fmVar;
        if (TextUtils.isEmpty(str) || cls == null || (fmVar = this.yz.get(str)) == null || !cls.isInstance(fmVar.fm)) {
            return null;
        }
        return cls.cast(fmVar.fm);
    }

    public fm<?> fm(String str) {
        if (TextUtils.isEmpty(str)) {
            return null;
        }
        return this.yz.remove(str);
    }

    @MainThread
    public static ai fm() {
        if (fm == null) {
            fm = new ai();
        }
        return fm;
    }

    public com.bytedance.sdk.openadsdk.core.model.lse fm(int i10) {
        com.bytedance.sdk.openadsdk.core.model.fm fmVarRemove = this.f7017lb.remove(Integer.valueOf(i10));
        if (fmVarRemove != null) {
            return fmVarRemove.dsz();
        }
        return null;
    }

    public int fm(com.bytedance.sdk.openadsdk.core.model.lse lseVar) {
        com.bytedance.sdk.openadsdk.core.model.fm fmVar = new com.bytedance.sdk.openadsdk.core.model.fm();
        fmVar.ro(lseVar);
        return fm(fmVar);
    }

    public int fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
        int iIncrementAndGet = this.ro.incrementAndGet();
        this.f7017lb.put(Integer.valueOf(iIncrementAndGet), fmVar);
        return iIncrementAndGet;
    }

    public static int fm(Intent intent) {
        if (intent != null) {
            return intent.getIntExtra("meta_index", -1);
        }
        return -1;
    }

    public void fm(com.bytedance.sdk.openadsdk.core.model.lse lseVar, ro roVar) {
        if (lseVar == null || roVar == null) {
            return;
        }
        String strYz = yz(lseVar);
        if (TextUtils.isEmpty(strYz)) {
            return;
        }
        this.wu.put(strYz, roVar);
    }

    public void fm(String str, boolean z10, boolean z11) {
        boolean z12 = z10 || !z11;
        boolean zFhx = vt.ro().fhx();
        if (zFhx) {
            com.bytedance.sdk.component.utils.wey.fm("BVA", "cleanListener: isFinish = " + z10 + ",isConfigChange = " + z11);
        }
        if (z12) {
            fm(str, zFhx);
        } else if (z10 || !z11) {
            fm(str, zFhx);
        }
    }

    private void fm(String str, boolean z10) {
        fm<?> fmVarFm = fm(str);
        if (z10) {
            if (fmVarFm != null) {
                StringBuilder sbN = u1.n("cleanListener: removeCallback success,listenerKey=", str, ",callback=");
                sbN.append(fmVarFm.fm);
                com.bytedance.sdk.component.utils.wey.fm("BVA", sbN.toString());
                return;
            }
            com.bytedance.sdk.component.utils.wey.fm("BVA", "cleanListener: removeCallback failed,listenerKey=".concat(String.valueOf(str)));
        }
    }
}