package com.bytedance.sdk.openadsdk.duv.fm;

import com.bytedance.sdk.component.fm.lb;
import com.bytedance.sdk.openadsdk.core.hxv;
import com.bytedance.sdk.openadsdk.core.model.lse;
import java.lang.ref.WeakReference;
import java.util.HashSet;
import org.json.JSONObject;

/* JADX INFO: loaded from: classes2.dex */
public class fhx extends com.bytedance.sdk.component.fm.lb<JSONObject, JSONObject> {
    private WeakReference<hxv> fm;

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private long f7382lb;
    private lse ro;
    private HashSet<Integer> yz = new HashSet<>();

    public fhx(hxv hxvVar, lse lseVar) {
        this.fm = new WeakReference<>(hxvVar);
        this.ro = lseVar;
    }

    public static void fm(com.bytedance.sdk.component.fm.fhx fhxVar, final hxv hxvVar, final lse lseVar) {
        fhxVar.fm("requestDelayCallback", new lb.ro() { // from class: com.bytedance.sdk.openadsdk.duv.fm.fhx.1
            @Override // com.bytedance.sdk.component.fm.lb.ro
            public com.bytedance.sdk.component.fm.lb fm() {
                return new fhx(hxvVar, lseVar);
            }
        });
    }

    @Override // com.bytedance.sdk.component.fm.lb
    public void fm(JSONObject jSONObject, com.bytedance.sdk.component.fm.jnr jnrVar) throws Exception {
        hxv hxvVar = this.fm.get();
        if (hxvVar != null && jSONObject != null) {
            hxvVar.fm(new com.bytedance.sdk.openadsdk.dsz.ro() { // from class: com.bytedance.sdk.openadsdk.duv.fm.fhx.2
                @Override // com.bytedance.sdk.openadsdk.dsz.ro
                public void fm(int i10) {
                    fhx.this.yz.add(Integer.valueOf(i10));
                    if (fhx.this.yz.size() >= fhx.this.f7382lb) {
                        try {
                            fhx.this.fm(new JSONObject());
                            fhx.this.yz.clear();
                        } catch (Exception e10) {
                            e10.getMessage();
                        }
                    }
                }
            });
            if (jSONObject.optInt("delay", -1) < 0) {
                return;
            }
            this.f7382lb = r2 / 1000;
            return;
        }
        lb();
    }
}