package com.bytedance.sdk.openadsdk.rkt;

import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
import androidx.autofill.inline.common.oIBu.pfzkWMa;
import com.amazon.a.a.o.b.f;
import com.android.vending.expansion.zipfile.APEZProvider;
import com.brentvatne.react.ReactVideoView;
import com.bytedance.sdk.openadsdk.BusMonitorDependWrapper;
import java.util.ArrayList;
/* loaded from: classes7.dex */
public class YFl {
    private static Context AlY;
    private static final long wN = System.currentTimeMillis();
    private com.bytedance.sdk.openadsdk.rkt.tN.YFl Sg;
    private Sg YFl;
    private Boolean tN;
    private int vc = 0;
    private Runnable DSW = new Runnable() { // from class: com.bytedance.sdk.openadsdk.rkt.YFl.3
        @Override // java.lang.Runnable
        public void run() {
            String str;
            ArrayList arrayList;
            String str2 = APEZProvider.FILEID;
            try {
                SQLiteDatabase Sg = com.bytedance.sdk.openadsdk.rkt.YFl.YFl.Sg();
                if (Sg != null) {
                    String[] strArr = {APEZProvider.FILEID, "sdk_version", "scene", "start_count", "success_count", "fail_count", "rit", "tag", "label", "timestamp", "mediation", "is_init", ReactVideoView.EVENT_PROP_EXTRA};
                    String str3 = ReactVideoView.EVENT_PROP_EXTRA;
                    String[] strArr2 = {String.valueOf(YFl.wN)};
                    try {
                        int max = Math.max(10, YFl.this.YFl.getOnceLogCount());
                        int i = max > 100 ? 10 : max;
                        int i2 = i;
                        Cursor query = Sg.query("monitor_table", strArr, "timestamp <= ?", strArr2, null, null, null, String.valueOf(i));
                        if (query != null) {
                            ArrayList arrayList2 = new ArrayList();
                            ArrayList arrayList3 = new ArrayList();
                            while (query.moveToNext()) {
                                com.bytedance.sdk.openadsdk.rkt.Sg.YFl yFl = new com.bytedance.sdk.openadsdk.rkt.Sg.YFl();
                                if (query.getColumnIndex(str2) >= 0) {
                                    str = str2;
                                    arrayList = arrayList2;
                                    long j = query.getLong(query.getColumnIndex(str2));
                                    yFl.YFl(j);
                                    arrayList3.add(String.valueOf(j));
                                } else {
                                    str = str2;
                                    arrayList = arrayList2;
                                }
                                if (query.getColumnIndex("sdk_version") >= 0) {
                                    yFl.YFl(query.getString(query.getColumnIndex("sdk_version")));
                                }
                                if (query.getColumnIndex("scene") >= 0) {
                                    yFl.Sg(query.getString(query.getColumnIndex("scene")));
                                }
                                if (query.getColumnIndex("start_count") >= 0) {
                                    yFl.YFl(query.getInt(query.getColumnIndex("start_count")));
                                }
                                if (query.getColumnIndex("success_count") >= 0) {
                                    yFl.Sg(query.getInt(query.getColumnIndex("success_count")));
                                }
                                if (query.getColumnIndex("fail_count") >= 0) {
                                    yFl.tN(query.getInt(query.getColumnIndex("fail_count")));
                                }
                                if (query.getColumnIndex("rit") >= 0) {
                                    yFl.tN(query.getString(query.getColumnIndex("rit")));
                                }
                                if (query.getColumnIndex("tag") >= 0) {
                                    yFl.AlY(query.getString(query.getColumnIndex("tag")));
                                }
                                if (query.getColumnIndex("label") >= 0) {
                                    yFl.wN(query.getString(query.getColumnIndex("label")));
                                }
                                if (query.getColumnIndex("mediation") >= 0) {
                                    yFl.vc(query.getString(query.getColumnIndex("mediation")));
                                }
                                if (query.getColumnIndex("is_init") >= 0) {
                                    yFl.AlY(query.getInt(query.getColumnIndex("is_init")));
                                }
                                String str4 = str3;
                                if (query.getColumnIndex(str4) >= 0) {
                                    yFl.DSW(query.getString(query.getColumnIndex(str4)));
                                }
                                ArrayList arrayList4 = arrayList;
                                arrayList4.add(yFl);
                                str3 = str4;
                                arrayList2 = arrayList4;
                                str2 = str;
                            }
                            ArrayList arrayList5 = arrayList2;
                            query.close();
                            if (!arrayList5.isEmpty()) {
                                YFl.this.YFl.onMonitorUpload(arrayList5);
                                SQLiteDatabase YFl = com.bytedance.sdk.openadsdk.rkt.YFl.YFl.YFl();
                                if (YFl != null && YFl.isOpen()) {
                                    StringBuilder sb = new StringBuilder();
                                    sb.append("_id IN (");
                                    for (int i3 = 0; i3 < arrayList3.size(); i3++) {
                                        sb.append("?");
                                        if (i3 < arrayList3.size() - 1) {
                                            sb.append(f.f114a);
                                        }
                                    }
                                    sb.append(")");
                                    YFl.delete("monitor_table", sb.toString(), (String[]) arrayList3.toArray(new String[0]));
                                    if (YFl.this.Sg != null) {
                                        YFl.this.Sg.YFl(YFl.wN);
                                    }
                                }
                                if (arrayList5.size() < i2 || YFl.this.vc > 1000) {
                                    return;
                                }
                                YFl.this.YFl(false);
                            }
                        }
                    } catch (Throwable th) {
                        th = th;
                        Log.e("BusMonitorCenter", th.getMessage());
                    }
                }
            } catch (Throwable th2) {
                th = th2;
            }
        }
    };

    static /* synthetic */ int tN(YFl yFl) {
        int i = yFl.vc;
        yFl.vc = i + 1;
        return i;
    }

    private YFl(Sg sg) {
        try {
            this.YFl = new BusMonitorDependWrapper(sg);
            this.Sg = new com.bytedance.sdk.openadsdk.rkt.tN.YFl(sg.getContext());
            AlY = sg.getContext();
        } catch (Throwable th) {
            Log.e("BusMonitorCenter", th.getMessage());
        }
    }

    public static YFl YFl(Sg sg) {
        return new YFl(sg);
    }

    public static Context YFl() {
        Context context = AlY;
        return context != null ? context : BusMonitorDependWrapper.getReflectContext();
    }

    public void YFl(final AlY alY) {
        new Object[]{pfzkWMa.PHFF, alY.generatorModel().tN()};
        if (alY == null || !tN()) {
            return;
        }
        new Object[]{"insertBusMonitorModel2", alY.generatorModel().tN()};
        this.YFl.getExecutorService().execute(new Runnable() { // from class: com.bytedance.sdk.openadsdk.rkt.YFl.1
            /* JADX WARN: Removed duplicated region for block: B:83:0x0259 A[ORIG_RETURN, RETURN] */
            /* JADX WARN: Removed duplicated region for block: B:98:0x024e A[EXC_TOP_SPLITTER, SYNTHETIC] */
            @Override // java.lang.Runnable
            /*
                Code decompiled incorrectly, please refer to instructions dump.
                To view partially-correct add '--show-bad-code' argument
            */
            public void run() {
                /*
                    Method dump skipped, instructions count: 620
                    To view this dump add '--comments-level debug' option
                */
                throw new UnsupportedOperationException("Method not decompiled: com.bytedance.sdk.openadsdk.rkt.YFl.AnonymousClass1.run():void");
            }
        });
    }

    private boolean tN() {
        if (this.tN == null) {
            Sg sg = this.YFl;
            if (sg != null && sg.getContext() != null && this.YFl.getExecutorService() != null) {
                return true;
            }
        } else {
            Sg sg2 = this.YFl;
            if (sg2 != null && sg2.getContext() != null && this.YFl.isMonitorOpen() && this.YFl.getExecutorService() != null) {
                return true;
            }
        }
        return false;
    }

    public void YFl(final boolean z) {
        Sg sg = this.YFl;
        if (sg == null || sg.getHandler() == null || this.YFl.getContext() == null || this.Sg == null || !this.YFl.isMonitorOpen()) {
            return;
        }
        this.YFl.getHandler().postDelayed(new Runnable() { // from class: com.bytedance.sdk.openadsdk.rkt.YFl.2
            @Override // java.lang.Runnable
            public void run() {
                try {
                    YFl.tN(YFl.this);
                    if (z) {
                        long YFl = YFl.this.Sg.YFl();
                        if (YFl == 0) {
                            YFl.this.Sg.YFl(System.currentTimeMillis());
                            return;
                        } else if (YFl.wN - YFl < YFl.this.YFl.getUploadIntervalTime()) {
                            return;
                        }
                    }
                    if (YFl.this.YFl.getExecutorService() != null) {
                        YFl.this.YFl.getExecutorService().execute(YFl.this.DSW);
                    }
                } catch (Throwable th) {
                    Log.e("BusMonitorCenter", th.getMessage());
                }
            }
        }, Math.max(this.YFl.getOnceLogInterval(), 10000));
    }
}