package com.bytedance.sdk.openadsdk.ajl;

import android.os.Handler;
import android.os.HandlerThread;
import android.os.SystemClock;
import android.text.TextUtils;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import com.bytedance.sdk.component.utils.wey;
import com.bytedance.sdk.component.utils.wu;
import com.bytedance.sdk.openadsdk.core.fhx;
import com.bytedance.sdk.openadsdk.core.model.lse;
import com.bytedance.sdk.openadsdk.irt.fm.lb;
import com.bytedance.sdk.openadsdk.irt.yz;
import com.bytedance.sdk.openadsdk.utils.hxv;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import org.json.JSONException;
import org.json.JSONObject;

/* JADX INFO: loaded from: classes2.dex */
public class ro {
    private static volatile ro fm;
    private final ConcurrentHashMap<String, com.bytedance.sdk.openadsdk.qhl.fm> ro = new ConcurrentHashMap<>();

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private com.bytedance.sdk.openadsdk.qhl.fm f6823lb = null;
    private volatile boolean yz = false;
    private volatile HandlerThread jnr = null;
    private volatile Handler ajl = null;
    private String wsy = "";
    private int wu = 0;

    /* JADX INFO: renamed from: ef, reason: collision with root package name */
    private volatile long f6822ef = 0;
    private final Runnable vt = new Runnable() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.6
        @Override // java.lang.Runnable
        public void run() {
            try {
                JSONObject jSONObject = new JSONObject();
                JSONObject jSONObject2 = new JSONObject();
                try {
                    if (fm.fm().jnr()) {
                        Set<String> setKeySet = ro.this.ro.keySet();
                        if (setKeySet.size() > ro.this.wu) {
                            ro.this.wu = setKeySet.size();
                        }
                        HashSet hashSet = new HashSet(5);
                        ArrayList arrayList = new ArrayList(setKeySet.size());
                        arrayList.addAll(ro.this.ro.values());
                        Collections.sort(arrayList);
                        for (int i10 = 0; i10 < arrayList.size() && i10 < 5; i10++) {
                            hashSet.add(((com.bytedance.sdk.openadsdk.qhl.fm) arrayList.get(i10)).ro());
                        }
                        try {
                            for (String str : setKeySet) {
                                com.bytedance.sdk.openadsdk.qhl.fm fmVar = (com.bytedance.sdk.openadsdk.qhl.fm) ro.this.ro.get(str);
                                if (fmVar != null) {
                                    JSONObject jSONObjectFm = fmVar.fm(jSONObject2);
                                    if (hashSet.contains(str)) {
                                        jSONObject.put(str, jSONObjectFm);
                                    }
                                }
                            }
                            jSONObject.put("common", jSONObject2);
                        } catch (JSONException e10) {
                            wey.lb(e10.getMessage(), new Object[0]);
                        }
                    } else {
                        try {
                            if (ro.this.f6823lb != null) {
                                jSONObject.put("common", ro.this.f6823lb.fm(jSONObject2));
                            }
                        } catch (JSONException e11) {
                            wey.lb(e11.getMessage(), new Object[0]);
                        }
                    }
                } catch (Throwable th) {
                    wey.lb(th.getMessage(), new Object[0]);
                }
                ro.this.wsy = jSONObject.toString();
                ro roVar = ro.this;
                roVar.fm(roVar.vt, fm.fm().yz());
            } catch (OutOfMemoryError e12) {
                wey.lb(e12.getMessage(), new Object[0]);
            }
        }
    };

    private ro() {
    }

    private void jnr() {
        if (this.yz) {
            return;
        }
        this.yz = true;
        fm(this.vt, fm.fm().yz());
    }

    private Handler lb() {
        if (this.jnr == null || !this.jnr.isAlive()) {
            synchronized (fhx.class) {
                try {
                    if (this.jnr == null || !this.jnr.isAlive()) {
                        this.jnr = wu.fm("pag_feature", -1);
                        this.ajl = new Handler(this.jnr.getLooper());
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        } else if (this.ajl == null) {
            synchronized (fhx.class) {
                try {
                    if (this.ajl == null) {
                        this.ajl = new Handler(this.jnr.getLooper());
                    }
                } finally {
                }
            }
        }
        return this.ajl;
    }

    private void yz() {
        final long jElapsedRealtime = SystemClock.elapsedRealtime();
        if (jElapsedRealtime - this.f6822ef > 10000) {
            yz.fm("track_feature_result", false, new com.bytedance.sdk.openadsdk.irt.ro() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.1
                @Override // com.bytedance.sdk.openadsdk.irt.ro
                @Nullable
                public lb fm() throws Exception {
                    ro.this.f6822ef = jElapsedRealtime;
                    JSONObject jSONObject = new JSONObject();
                    jSONObject.put("msg", String.valueOf(ro.this.wu));
                    return com.bytedance.sdk.openadsdk.irt.fm.yz.ro().fm("track_feature_result").ro(jSONObject.toString());
                }
            });
        }
    }

    public void ro() {
        try {
            if (fm.fm().lb()) {
                fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.7
                    @Override // java.lang.Runnable
                    public void run() {
                        if (!fm.fm().jnr()) {
                            if (ro.this.f6823lb != null) {
                                ro.this.f6823lb.fm();
                            }
                        } else {
                            Iterator it = ro.this.ro.keySet().iterator();
                            while (it.hasNext()) {
                                com.bytedance.sdk.openadsdk.qhl.fm fmVar = (com.bytedance.sdk.openadsdk.qhl.fm) ro.this.ro.get((String) it.next());
                                if (fmVar != null) {
                                    fmVar.fm();
                                }
                            }
                        }
                    }
                });
            }
        } catch (OutOfMemoryError e10) {
            wey.lb(e10.getMessage(), new Object[0]);
        }
    }

    private void fm(Runnable runnable) {
        if (hxv.fm || runnable == null) {
            return;
        }
        try {
            lb().post(runnable);
        } catch (Throwable unused) {
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(Runnable runnable, long j10) {
        if (hxv.fm || runnable == null) {
            return;
        }
        try {
            lb().postDelayed(runnable, j10);
        } catch (Throwable unused) {
        }
    }

    public static ro fm() {
        if (fm == null) {
            synchronized (com.bytedance.sdk.openadsdk.core.lb.class) {
                try {
                    if (fm == null) {
                        fm = new ro();
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        }
        return fm;
    }

    public void fm(JSONObject jSONObject) {
        if (fm.fm().lb()) {
            try {
                jSONObject.put("feature_data", this.wsy);
                yz();
            } catch (JSONException e10) {
                wey.lb(e10.getMessage(), new Object[0]);
            }
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(@NonNull String str, @NonNull String str2, String str3) {
        try {
            if (!TextUtils.isEmpty(str) && !TextUtils.isEmpty(str2) && fm.fm().lb()) {
                jnr();
                if (fm.fm().jnr()) {
                    com.bytedance.sdk.openadsdk.qhl.fm fmVar = this.ro.get(str2);
                    if (fmVar == null) {
                        fmVar = new com.bytedance.sdk.openadsdk.qhl.fm(str2);
                    }
                    fmVar.fm(str, str3);
                    this.ro.put(str2, fmVar);
                    return;
                }
                if (this.f6823lb == null) {
                    this.f6823lb = new com.bytedance.sdk.openadsdk.qhl.fm(str2);
                }
                this.f6823lb.fm(str, str3);
            }
        } catch (OutOfMemoryError e10) {
            wey.lb(e10.getMessage(), new Object[0]);
        }
    }

    public void fm(@NonNull final String str, @NonNull final String str2, final String str3, String str4) {
        if (TextUtils.isEmpty(str) || TextUtils.isEmpty(str2) || !fm.fm().lb()) {
            return;
        }
        if (!"show".equals(str) && !"click".equals(str) && !"dislike".equals(str)) {
            if (fm.fm().gof()) {
                if (TextUtils.isEmpty(str4)) {
                    return;
                }
                if (!"rewarded_video".equals(str4) && !"fullscreen_interstitial_ad".equals(str4) && !"open_ad".equals(str4)) {
                    return;
                }
            }
            if ("feed_play".equals(str) || "feed_pause".equals(str) || "feed_continue".equals(str) || "feed_over".equals(str) || "feed_break".equals(str) || "play_error".equals(str)) {
                fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.3
                    @Override // java.lang.Runnable
                    public void run() {
                        ro.this.fm(str, str2, str3);
                    }
                });
                return;
            }
            return;
        }
        fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.2
            @Override // java.lang.Runnable
            public void run() {
                ro.this.fm(str, str2, str3);
            }
        });
    }

    public void fm(@NonNull final String str, final lse lseVar) {
        if (!TextUtils.isEmpty(str) && fm.fm().lb() && lse.jnr(lseVar)) {
            if (!fm.fm().gof() || lseVar.tmm() == 8 || lseVar.tmm() == 7 || lseVar.tmm() == 3) {
                if ("videoPercent30".equals(str) || "videoForceBreak".equals(str)) {
                    fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.4
                        @Override // java.lang.Runnable
                        public void run() {
                            String strIb = lseVar.ib();
                            String strSs = lseVar.ss();
                            if (TextUtils.isEmpty(strIb)) {
                                return;
                            }
                            ro.this.fm(str, strIb, strSs);
                        }
                    });
                }
            }
        }
    }

    public void fm(@NonNull final String str, final lse lseVar, final String str2) {
        if (TextUtils.isEmpty(str) || !fm.fm().lb()) {
            return;
        }
        if ("landingStart".equals(str) || "landingFinish".equals(str) || "landingContinue".equals(str) || "landingPause".equals(str)) {
            fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.ajl.ro.5
                @Override // java.lang.Runnable
                public void run() {
                    lse lseVar2 = lseVar;
                    if (lseVar2 == null || TextUtils.isEmpty(lseVar2.ib())) {
                        return;
                    }
                    ro.this.fm(str, lseVar.ib(), lseVar.ss() + str2);
                }
            });
        }
    }
}