package com.bytedance.sdk.openadsdk.oem;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.Build;
import android.text.TextUtils;
import android.util.LruCache;
import com.bytedance.sdk.component.utils.wey;
import com.bytedance.sdk.component.wu.ro.lb;
import com.bytedance.sdk.openadsdk.core.fhx;
import com.bytedance.sdk.openadsdk.core.gof;
import com.bytedance.sdk.openadsdk.core.model.gzf;
import com.bytedance.sdk.openadsdk.core.model.lse;
import com.bytedance.sdk.openadsdk.hlt.jnr;
import com.bytedance.sdk.openadsdk.utils.bx;
import com.bytedance.sdk.openadsdk.utils.xgn;
import org.json.JSONObject;

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

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private fm f7506lb;
    private final LruCache<String, lse> ro;
    private int yz = 0;

    private IPBroadcastReceiver() {
        int i10 = 10;
        int iFm = jnr.fm("ip_data_config", "ip_ad_cache_count", 10);
        if (iFm > 0 && iFm <= 200) {
            i10 = iFm;
        }
        this.ro = new LruCache<>(i10);
    }

    public void fm() {
        this.f7506lb = null;
    }

    @Override // android.content.BroadcastReceiver
    public void onReceive(Context context, Intent intent) {
        intent.getAction();
        if ("com.xiaomi.market.DOWNLOAD_INSTALL_RESULT".equals(intent.getAction())) {
            fm(intent);
        } else if ("com.oplus.market.intent.action.ADD_APP_STATUS_CHANGED".equals(intent.getAction())) {
            ro(intent);
        }
    }

    private void ro(final Intent intent) {
        if (intent == null) {
            return;
        }
        xgn.ro(new lb("ip-oppo") { // from class: com.bytedance.sdk.openadsdk.oem.IPBroadcastReceiver.2
            @Override // java.lang.Runnable
            public void run() {
                try {
                    int intExtra = intent.getIntExtra("event_type", 0);
                    final String stringExtra = intent.getStringExtra("event_track");
                    if (intExtra != 7 && intExtra != 9 && stringExtra != null) {
                        final String stringExtra2 = intent.getStringExtra("event_id");
                        final String stringExtra3 = intent.getStringExtra("app_package_name");
                        final String stringExtra4 = intent.getStringExtra("market_version");
                        final String stringExtra5 = intent.getStringExtra("caller");
                        final int iFm = ro.fm(intExtra);
                        final int iRo = ro.ro(intExtra);
                        String.format("eventId: %s, eventType: %s, eventTrack: %s, appPackage: %s, marketVersion: %s, caller: %s, errorCode: %s, status: %s", stringExtra2, Integer.valueOf(intExtra), stringExtra, stringExtra3, stringExtra4, stringExtra5, Integer.valueOf(iFm), Integer.valueOf(iRo));
                        fm fmVar = IPBroadcastReceiver.this.f7506lb;
                        if (iFm > 0 && fmVar != null) {
                            fmVar.fm(stringExtra3, iFm);
                        }
                        final lse lseVarFm = IPBroadcastReceiver.this.fm(stringExtra3);
                        if (lseVarFm != null) {
                            com.bytedance.sdk.openadsdk.yz.lb.fm(System.currentTimeMillis(), lseVarFm, bx.fm(lseVarFm), "ip_listener_log", new com.bytedance.sdk.openadsdk.irt.ro.fm() { // from class: com.bytedance.sdk.openadsdk.oem.IPBroadcastReceiver.2.1
                                @Override // com.bytedance.sdk.openadsdk.irt.ro.fm, com.bytedance.sdk.openadsdk.irt.ro.ro
                                public JSONObject fm() {
                                    JSONObject jSONObject = new JSONObject();
                                    try {
                                        jSONObject.put("ip_error_code", iFm);
                                        jSONObject.put("ip_market_version", stringExtra4);
                                        jSONObject.put("ip_app_pkg", stringExtra3);
                                        jSONObject.put("ip_caller_pkg", stringExtra5);
                                        jSONObject.put("ip_event_id", stringExtra2);
                                        jSONObject.put("ip_event_track", stringExtra);
                                        jSONObject.put("ip_status", iRo);
                                        jSONObject.put("ip_exec_type", IPBroadcastReceiver.this.yz);
                                        lse lseVar = lseVarFm;
                                        if (lseVar != null) {
                                            jSONObject.put("ip_is_w2a", lseVar.gof());
                                            if (lseVarFm.pz() != null) {
                                                jSONObject.put("ip_oem_type", lseVarFm.pz().ajl());
                                            }
                                        }
                                        return jSONObject;
                                    } catch (Throwable th) {
                                        wey.fm("IPMiBroadcastReceiver", "handleOppoInstallResult error = ", th);
                                        return null;
                                    }
                                }
                            });
                        }
                    }
                } catch (Throwable th) {
                    wey.fm("IPMiBroadcastReceiver", "handleOppoInstallResult error = ", th);
                    IPBroadcastReceiver.this.yz = 2;
                }
            }
        });
    }

    public void fm(fm fmVar) {
        this.f7506lb = fmVar;
    }

    public static void ro(final Context context, final lse lseVar) {
        gzf gzfVarPz;
        if (fm != null || lseVar == null || (gzfVarPz = lseVar.pz()) == null) {
            return;
        }
        if (gzfVarPz.wsy() || gzfVarPz.wu()) {
            fhx.ro().post(new Runnable() { // from class: com.bytedance.sdk.openadsdk.oem.IPBroadcastReceiver.3
                @Override // java.lang.Runnable
                public void run() {
                    try {
                        IPBroadcastReceiver.fm(gof.fm(context), lseVar);
                    } catch (Throwable th) {
                        wey.fm("IPMiBroadcastReceiver", "registerBroadcastReceiverAsy error ", th);
                    }
                }
            });
        }
    }

    public void fm(String str, lse lseVar) {
        if (TextUtils.isEmpty(str) || lseVar == null || this.ro.get(str) != null) {
            return;
        }
        this.ro.put(str, lseVar);
    }

    public lse fm(String str) {
        if (TextUtils.isEmpty(str)) {
            return null;
        }
        return this.ro.get(str);
    }

    private void fm(final Intent intent) {
        if (intent == null) {
            return;
        }
        xgn.ro(new lb("ip-mi") { // from class: com.bytedance.sdk.openadsdk.oem.IPBroadcastReceiver.1
            @Override // java.lang.Runnable
            public void run() {
                final int i10;
                final int i11;
                final int i12;
                try {
                    int intExtra = 0;
                    final int intExtra2 = intent.getIntExtra("errorCode", 0);
                    if (intExtra2 < 0) {
                        int intExtra3 = intent.getIntExtra("reason", 0);
                        if (intExtra2 == -4 && intExtra3 == -1) {
                            return;
                        } else {
                            i10 = intExtra3;
                        }
                    } else {
                        i10 = 0;
                    }
                    if (intExtra2 == 5) {
                        int intExtra4 = intent.getIntExtra("status", 0);
                        if (intExtra4 == -2) {
                            try {
                                intExtra = intent.getIntExtra("progress", 0);
                            } catch (Throwable unused) {
                                IPBroadcastReceiver.this.yz = 1;
                            }
                            if (intExtra < 100) {
                                return;
                            }
                        }
                        i11 = intExtra4;
                        i12 = intExtra;
                    } else {
                        i11 = 0;
                        i12 = 0;
                    }
                    String stringExtra = intent.getStringExtra("packageName");
                    fm fmVar = IPBroadcastReceiver.this.f7506lb;
                    if (intExtra2 > 0 && fmVar != null) {
                        fmVar.fm(stringExtra, intExtra2);
                    }
                    final lse lseVarFm = IPBroadcastReceiver.this.fm(stringExtra);
                    if (lseVarFm != null) {
                        com.bytedance.sdk.openadsdk.yz.lb.fm(System.currentTimeMillis(), lseVarFm, bx.fm(lseVarFm), "ip_listener_log", new com.bytedance.sdk.openadsdk.irt.ro.fm() { // from class: com.bytedance.sdk.openadsdk.oem.IPBroadcastReceiver.1.1
                            @Override // com.bytedance.sdk.openadsdk.irt.ro.fm, com.bytedance.sdk.openadsdk.irt.ro.ro
                            public JSONObject fm() {
                                JSONObject jSONObject = new JSONObject();
                                try {
                                    jSONObject.put("ip_error_code", intExtra2);
                                    lse lseVar = lseVarFm;
                                    if (lseVar != null) {
                                        jSONObject.put("ip_is_w2a", lseVar.gof());
                                    }
                                    int i13 = intExtra2;
                                    if (i13 > 0) {
                                        if (i13 == 5) {
                                            jSONObject.put("ip_status", i11);
                                            jSONObject.put("ip_exec_type", IPBroadcastReceiver.this.yz);
                                        }
                                        if (i11 == -2) {
                                            jSONObject.put("ip_progress", i12);
                                        }
                                    }
                                    if (intExtra2 < 0) {
                                        jSONObject.put("ip_reason", i10);
                                    }
                                    return jSONObject;
                                } catch (Throwable th) {
                                    wey.fm("IPMiBroadcastReceiver", "handleXiaomiInstallResult error ", th);
                                    return null;
                                }
                            }
                        });
                    }
                } catch (Throwable th) {
                    wey.fm("IPMiBroadcastReceiver", "handleXiaomiInstallResult error ", th);
                }
            }
        });
    }

    public static IPBroadcastReceiver fm(Context context, lse lseVar) {
        gzf gzfVarPz;
        if (jnr.fm("ip_data_config", "ip_link_listener", 0) == 0 || lseVar == null || (gzfVarPz = lseVar.pz()) == null) {
            return null;
        }
        if (fm == null) {
            synchronized (IPBroadcastReceiver.class) {
                try {
                    if (fm == null) {
                        fm = new IPBroadcastReceiver();
                        IntentFilter intentFilter = new IntentFilter();
                        if (gzfVarPz.wsy()) {
                            intentFilter.addAction("com.xiaomi.market.DOWNLOAD_INSTALL_RESULT");
                        } else if (gzfVarPz.wu()) {
                            intentFilter.addAction("com.oplus.market.intent.action.ADD_APP_STATUS_CHANGED");
                        }
                        if (Build.VERSION.SDK_INT >= 34 && bx.ajl(context) >= 34) {
                            context.registerReceiver(fm, intentFilter, 2);
                        } else {
                            context.registerReceiver(fm, intentFilter);
                        }
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        }
        return fm;
    }
}