package com.bytedance.sdk.openadsdk.yz;

import android.os.Handler;
import android.os.Message;
import android.os.SystemClock;
import android.text.TextUtils;
import androidx.media3.common.PlaybackException;
import com.bytedance.sdk.openadsdk.core.model.lse;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: loaded from: classes2.dex */
public class onz {
    private static volatile onz fm;

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private ro f7676lb = ro.fm();
    private final Handler ro = new Handler(com.bytedance.sdk.openadsdk.core.fhx.ro().getLooper(), new Handler.Callback() { // from class: com.bytedance.sdk.openadsdk.yz.onz.1
        @Override // android.os.Handler.Callback
        public boolean handleMessage(Message message) {
            if (message.what != 100) {
                return true;
            }
            Object obj = message.obj;
            fm fmVar = (obj == null || !(obj instanceof fm)) ? null : (fm) obj;
            if (fmVar == null) {
                return true;
            }
            onz.this.ro(fmVar);
            return true;
        }
    });
    private Map<String, Object> yz;

    public static class fm implements Serializable, Runnable {
        public Map<String, Object> jnr;

        /* JADX INFO: renamed from: lb, reason: collision with root package name */
        public lse f7677lb;
        public String yz;
        public final AtomicInteger fm = new AtomicInteger(0);
        public final AtomicBoolean ro = new AtomicBoolean(false);
        private final long ajl = SystemClock.elapsedRealtime();

        public fm(lse lseVar, String str, Map<String, Object> map) {
            this.f7677lb = lseVar;
            this.yz = str;
            this.jnr = map;
        }

        public static fm fm(lse lseVar, String str, Map<String, Object> map) {
            return new fm(lseVar, str, map);
        }

        public void ro() {
            this.fm.incrementAndGet();
        }

        @Override // java.lang.Runnable
        public void run() {
            if (this.f7677lb == null || TextUtils.isEmpty(this.yz)) {
                return;
            }
            String str = this.ro.get() ? "dpl_success" : "dpl_failed";
            if (this.jnr == null) {
                this.jnr = new HashMap();
            }
            lse lseVar = this.f7677lb;
            if (lseVar != null && lseVar.fb() == 0) {
                Map<String, Object> map = this.jnr;
                lse lseVar2 = this.f7677lb;
                map.put("auto_click", Boolean.valueOf((lseVar2 == null || lseVar2.gqi()) ? false : true));
            }
            this.jnr.put("lifeCycleInit", Boolean.valueOf(com.bytedance.sdk.openadsdk.core.irt.fm().lb()));
            this.jnr.put("duration", Long.valueOf(SystemClock.elapsedRealtime() - this.ajl));
            lb.fm(this.f7677lb, this.yz, str, this.jnr);
        }

        public fm fm(boolean z10) {
            this.ro.set(z10);
            return this;
        }

        public int fm() {
            return this.fm.get();
        }
    }

    public static class ro {
        public int fm = 300;
        public int ro = PlaybackException.ERROR_CODE_DRM_UNSPECIFIED;

        private ro() {
        }

        public static ro fm() {
            return new ro();
        }
    }

    private onz() {
    }

    private void lb(fm fmVar) {
        if (fmVar == null) {
            return;
        }
        this.ro.post(fmVar);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void ro(fm fmVar) {
        if (fmVar == null) {
            return;
        }
        boolean zYz = com.bytedance.sdk.openadsdk.core.irt.fm().yz();
        boolean zFm = com.bytedance.sdk.openadsdk.core.irt.fm().fm(true);
        if (!zYz && zFm) {
            fm(fmVar);
            return;
        }
        if (fmVar.jnr == null) {
            fmVar.jnr = new HashMap();
        }
        fmVar.jnr.put("is_background", Boolean.valueOf(zYz));
        fmVar.jnr.put("has_focus", Boolean.valueOf(zFm));
        lb(fmVar.fm(true));
    }

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

    public onz fm(Map<String, Object> map) {
        this.yz = map;
        return fm();
    }

    public void fm(lse lseVar, String str) {
        Message messageObtainMessage = this.ro.obtainMessage();
        messageObtainMessage.what = 100;
        messageObtainMessage.obj = fm.fm(lseVar, str, this.yz);
        messageObtainMessage.sendToTarget();
    }

    private void fm(fm fmVar) {
        if (fmVar == null) {
            return;
        }
        fmVar.ro();
        int iFm = fmVar.fm();
        ro roVar = this.f7676lb;
        if (iFm * roVar.fm > roVar.ro) {
            lb(fmVar.fm(false));
            return;
        }
        Message messageObtainMessage = this.ro.obtainMessage();
        messageObtainMessage.what = 100;
        messageObtainMessage.obj = fmVar;
        this.ro.sendMessageDelayed(messageObtainMessage, this.f7676lb.fm);
    }
}