package com.bytedance.sdk.openadsdk.gof;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import com.bytedance.sdk.component.wu.fm.ajl;
import com.bytedance.sdk.openadsdk.BusMonitorDependWrapper;
import java.util.ArrayList;
import java.util.List;

/* JADX INFO: loaded from: classes2.dex */
public class fm {
    private static Context yz;
    private ro ajl;
    private com.bytedance.sdk.openadsdk.gof.lb.fm wsy;
    private Boolean wu;
    public static final long fm = com.bytedance.sdk.openadsdk.gof.yz.fm.fm();
    private static final String[] ro = {"_id", "sdk_version", "scene", "start_count", "success_count", "fail_count", "rit", "tag", "label", "timestamp", "mediation", "is_init", "extra"};

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private static final long f7406lb = System.currentTimeMillis();
    private final ArrayList<yz> jnr = new ArrayList<>();

    /* JADX INFO: renamed from: ef, reason: collision with root package name */
    private final Runnable f7407ef = new Runnable() { // from class: com.bytedance.sdk.openadsdk.gof.fm.1
        @Override // java.lang.Runnable
        public void run() {
            if (!fm.this.yz() || fm.this.jnr.isEmpty()) {
                return;
            }
            fm fmVar = fm.this;
            fmVar.fm(fmVar.jnr);
            fm.this.jnr.clear();
        }
    };
    private int vt = 0;
    private final Runnable ku = new Runnable() { // from class: com.bytedance.sdk.openadsdk.gof.fm.4
        @Override // java.lang.Runnable
        public void run() {
            int i10;
            int i11;
            int i12;
            int i13;
            int i14;
            int i15;
            try {
                SQLiteDatabase sQLiteDatabaseRo = com.bytedance.sdk.openadsdk.gof.fm.fm.ro();
                if (sQLiteDatabaseRo != null) {
                    String[] strArr = {String.valueOf(fm.this.ajl.getOnceLogInterval() < 86400000 ? fm.f7406lb : fm.fm)};
                    int iMax = Math.max(10, fm.this.ajl.getOnceLogCount());
                    int i16 = iMax > 100 ? 10 : iMax;
                    Cursor cursorQuery = sQLiteDatabaseRo.query("monitor_table", fm.ro, "timestamp < ?", strArr, null, null, null, String.valueOf(i16));
                    if (cursorQuery != null) {
                        ArrayList arrayList = new ArrayList();
                        ArrayList arrayList2 = new ArrayList();
                        int columnIndex = cursorQuery.getColumnIndex("_id");
                        int columnIndex2 = cursorQuery.getColumnIndex("sdk_version");
                        int columnIndex3 = cursorQuery.getColumnIndex("scene");
                        int columnIndex4 = cursorQuery.getColumnIndex("start_count");
                        int columnIndex5 = cursorQuery.getColumnIndex("success_count");
                        int columnIndex6 = cursorQuery.getColumnIndex("fail_count");
                        int columnIndex7 = cursorQuery.getColumnIndex("rit");
                        int columnIndex8 = cursorQuery.getColumnIndex("tag");
                        int columnIndex9 = cursorQuery.getColumnIndex("label");
                        int columnIndex10 = cursorQuery.getColumnIndex("timestamp");
                        int columnIndex11 = cursorQuery.getColumnIndex("mediation");
                        int i17 = i16;
                        int columnIndex12 = cursorQuery.getColumnIndex("is_init");
                        try {
                            int columnIndex13 = cursorQuery.getColumnIndex("extra");
                            while (cursorQuery.moveToNext()) {
                                ArrayList arrayList3 = arrayList;
                                com.bytedance.sdk.openadsdk.gof.ro.fm fmVar = new com.bytedance.sdk.openadsdk.gof.ro.fm();
                                if (columnIndex >= 0) {
                                    i10 = columnIndex11;
                                    i11 = columnIndex10;
                                    long j10 = cursorQuery.getLong(columnIndex);
                                    fmVar.fm(j10);
                                    arrayList2.add(String.valueOf(j10));
                                } else {
                                    i10 = columnIndex11;
                                    i11 = columnIndex10;
                                }
                                if (columnIndex2 >= 0) {
                                    fmVar.fm(cursorQuery.getString(columnIndex2));
                                }
                                if (columnIndex3 >= 0) {
                                    fmVar.ro(cursorQuery.getString(columnIndex3));
                                }
                                if (columnIndex4 >= 0) {
                                    fmVar.fm(cursorQuery.getInt(columnIndex4));
                                }
                                if (columnIndex5 >= 0) {
                                    fmVar.ro(cursorQuery.getInt(columnIndex5));
                                }
                                if (columnIndex6 >= 0) {
                                    fmVar.lb(cursorQuery.getInt(columnIndex6));
                                }
                                if (columnIndex7 >= 0) {
                                    fmVar.lb(cursorQuery.getString(columnIndex7));
                                }
                                if (columnIndex8 >= 0) {
                                    fmVar.yz(cursorQuery.getString(columnIndex8));
                                }
                                if (columnIndex9 >= 0) {
                                    fmVar.jnr(cursorQuery.getString(columnIndex9));
                                }
                                if (i11 >= 0) {
                                    i12 = columnIndex;
                                    i13 = i11;
                                    i14 = columnIndex2;
                                    fmVar.ro(cursorQuery.getLong(i13));
                                } else {
                                    i12 = columnIndex;
                                    i13 = i11;
                                    i14 = columnIndex2;
                                }
                                if (i10 >= 0) {
                                    i15 = i10;
                                    fmVar.ajl(cursorQuery.getString(i15));
                                } else {
                                    i15 = i10;
                                }
                                if (columnIndex12 >= 0) {
                                    fmVar.yz(cursorQuery.getInt(columnIndex12));
                                }
                                if (columnIndex13 >= 0) {
                                    fmVar.wsy(cursorQuery.getString(columnIndex13));
                                }
                                arrayList3.add(fmVar);
                                arrayList = arrayList3;
                                columnIndex2 = i14;
                                int i18 = i13;
                                columnIndex11 = i15;
                                columnIndex = i12;
                                columnIndex10 = i18;
                            }
                            ArrayList arrayList4 = arrayList;
                            cursorQuery.close();
                            if (arrayList4.isEmpty()) {
                                return;
                            }
                            fm.this.ajl.onMonitorUpload(arrayList4);
                            SQLiteDatabase sQLiteDatabaseFm = com.bytedance.sdk.openadsdk.gof.fm.fm.fm();
                            if (sQLiteDatabaseFm != null && sQLiteDatabaseFm.isOpen()) {
                                StringBuilder sb = new StringBuilder();
                                sb.append("_id IN (");
                                for (int i19 = 0; i19 < arrayList2.size(); i19++) {
                                    sb.append("?");
                                    if (i19 < arrayList2.size() - 1) {
                                        sb.append(",");
                                    }
                                }
                                sb.append(")");
                                sQLiteDatabaseFm.delete("monitor_table", sb.toString(), (String[]) arrayList2.toArray(new String[0]));
                                if (fm.this.wsy != null) {
                                    fm.this.wsy.fm(fm.f7406lb);
                                }
                            }
                            if (arrayList4.size() < i17 || fm.this.vt > 1000) {
                                return;
                            }
                            fm.this.fm(false);
                        } catch (Throwable unused) {
                        }
                    }
                }
            } catch (Throwable unused2) {
            }
        }
    };

    private fm(ro roVar) {
        try {
            this.ajl = new BusMonitorDependWrapper(roVar);
            this.wsy = new com.bytedance.sdk.openadsdk.gof.lb.fm(roVar.getContext());
            yz = roVar.getContext();
        } catch (Throwable unused) {
        }
    }

    public static /* synthetic */ int yz(fm fmVar) {
        int i10 = fmVar.vt;
        fmVar.vt = i10 + 1;
        return i10;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public boolean yz() {
        if (this.wu == null) {
            ro roVar = this.ajl;
            this.wu = Boolean.valueOf((roVar == null || roVar.getContext() == null || !this.ajl.isMonitorOpen() || this.ajl.getHandler() == null) ? false : true);
        }
        return this.wu.booleanValue();
    }

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

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

    public void fm(final yz yzVar) {
        if (yzVar == null || !yz()) {
            return;
        }
        final ajl handler = this.ajl.getHandler();
        handler.fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.gof.fm.2
            @Override // java.lang.Runnable
            public void run() {
                fm.this.jnr.add(yzVar);
                if (fm.this.jnr.size() >= 10) {
                    handler.ro(fm.this.f7407ef);
                    fm fmVar = fm.this;
                    fmVar.fm(fmVar.jnr);
                    fm.this.jnr.clear();
                }
            }
        });
        handler.ro(this.f7407ef);
        handler.fm(this.f7407ef, 5000L);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(List<yz> list) {
        com.bytedance.sdk.openadsdk.gof.ro.fm fmVarFm;
        if (list == null || list.isEmpty()) {
            return;
        }
        SQLiteDatabase sQLiteDatabase = null;
        try {
            SQLiteDatabase sQLiteDatabaseFm = com.bytedance.sdk.openadsdk.gof.fm.fm.fm();
            if (sQLiteDatabaseFm != null) {
                try {
                    sQLiteDatabaseFm.beginTransaction();
                    for (int i10 = 0; i10 < list.size(); i10++) {
                        yz yzVar = list.get(i10);
                        if (yzVar != null && (fmVarFm = yzVar.fm()) != null) {
                            Cursor cursorQuery = sQLiteDatabaseFm.query("monitor_table", ro, "sdk_version = ? AND scene = ? AND rit = ? AND tag = ? AND label = ? AND mediation = ? AND is_init = ? AND timestamp = ? AND extra = ?", new String[]{fmVarFm.ro(), fmVarFm.lb(), fmVarFm.wsy(), fmVarFm.wu(), fmVarFm.ef(), fmVarFm.ku(), String.valueOf(fmVarFm.duv()), String.valueOf(fmVarFm.vt()), fmVarFm.dsz()}, null, null, null);
                            if (cursorQuery != null) {
                                if (cursorQuery.moveToNext()) {
                                    int columnIndex = cursorQuery.getColumnIndex("_id");
                                    if (columnIndex >= 0) {
                                        fmVarFm.fm(cursorQuery.getLong(columnIndex));
                                    }
                                    int columnIndex2 = cursorQuery.getColumnIndex("start_count");
                                    if (columnIndex2 >= 0) {
                                        fmVarFm.fm(cursorQuery.getInt(columnIndex2) + fmVarFm.yz());
                                    }
                                    int columnIndex3 = cursorQuery.getColumnIndex("success_count");
                                    if (columnIndex3 >= 0) {
                                        fmVarFm.ro(cursorQuery.getInt(columnIndex3) + fmVarFm.jnr());
                                    }
                                    int columnIndex4 = cursorQuery.getColumnIndex("fail_count");
                                    if (columnIndex4 >= 0) {
                                        fmVarFm.lb(cursorQuery.getInt(columnIndex4) + fmVarFm.ajl());
                                    }
                                }
                                cursorQuery.close();
                            }
                            ContentValues contentValues = new ContentValues();
                            if (fmVarFm.fm() > 0) {
                                contentValues.put("_id", Long.valueOf(fmVarFm.fm()));
                            }
                            contentValues.put("sdk_version", fmVarFm.ro());
                            contentValues.put("scene", fmVarFm.lb());
                            contentValues.put("start_count", Integer.valueOf(fmVarFm.yz()));
                            contentValues.put("success_count", Integer.valueOf(fmVarFm.jnr()));
                            contentValues.put("fail_count", Integer.valueOf(fmVarFm.ajl()));
                            contentValues.put("rit", fmVarFm.wsy());
                            contentValues.put("tag", fmVarFm.wu());
                            contentValues.put("label", fmVarFm.ef());
                            contentValues.put("timestamp", Long.valueOf(fmVarFm.vt()));
                            contentValues.put("mediation", fmVarFm.ku());
                            contentValues.put("is_init", Integer.valueOf(fmVarFm.duv()));
                            contentValues.put("extra", fmVarFm.dsz());
                            sQLiteDatabaseFm.insertWithOnConflict("monitor_table", null, contentValues, 5);
                        }
                    }
                    sQLiteDatabaseFm.setTransactionSuccessful();
                } catch (Throwable unused) {
                    sQLiteDatabase = sQLiteDatabaseFm;
                    if (sQLiteDatabase != null) {
                        try {
                            sQLiteDatabase.endTransaction();
                            return;
                        } catch (Throwable unused2) {
                            return;
                        }
                    }
                    return;
                }
            }
            if (sQLiteDatabaseFm != null) {
                try {
                    sQLiteDatabaseFm.endTransaction();
                } catch (Throwable unused3) {
                }
            }
        } catch (Throwable unused4) {
        }
    }

    public void fm(final boolean z10) {
        final ajl handler = this.ajl.getHandler();
        ro roVar = this.ajl;
        if (roVar == null || handler == null || roVar.getContext() == null || this.wsy == null || !yz()) {
            return;
        }
        handler.fm(new Runnable() { // from class: com.bytedance.sdk.openadsdk.gof.fm.3
            @Override // java.lang.Runnable
            public void run() {
                try {
                    fm.yz(fm.this);
                    if (z10) {
                        long jFm = fm.this.wsy.fm();
                        if (jFm == 0) {
                            fm.this.wsy.fm(System.currentTimeMillis());
                            return;
                        } else if (com.bytedance.sdk.openadsdk.gof.yz.fm.fm(jFm) && System.currentTimeMillis() - jFm < fm.this.ajl.getUploadIntervalTime()) {
                            return;
                        }
                    }
                    handler.fm(fm.this.ku);
                } catch (Throwable unused) {
                }
            }
        }, Math.max(this.ajl.getOnceLogInterval(), 10000));
    }
}