package tb;
import android.annotation.SuppressLint;
import com.google.android.gms.common.GoogleApiAvailabilityLight;
import com.tencent.wcdb.database.SQLiteException;
import com.xiaomi.mipush.sdk.Constants;
import com.xingin.advert.report.AdBean;
import com.xingin.advert.report.AdDao;
import com.xingin.utils.async.run.task.XYRunnable;
import java.util.List;
import java.util.concurrent.ConcurrentLinkedQueue;
import kotlin.Metadata;
import kotlin.collections.CollectionsKt___CollectionsKt;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import tb.l;
import wi2.h;
@Metadata(bv = {}, d1 = {"\u0000&\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010 \n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0000\u0018\u00002\u00020\u0001:\u0001\u0012B\u000f\u0012\u0006\u0010\u000f\u001a\u00020\u000e¢\u0006\u0004\b\u0010\u0010\u0011J\b\u0010\u0003\u001a\u00020\u0002H\u0016J\u0010\u0010\u0006\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0016J\b\u0010\u0007\u001a\u00020\u0002H\u0002J\u0010\u0010\b\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0002J\u0010\u0010\t\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0003J\u0016\u0010\f\u001a\u00020\u00022\f\u0010\u000b\u001a\b\u0012\u0004\u0012\u00020\u00040\nH\u0002J\u0010\u0010\r\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004H\u0002¨\u0006\u0013"}, d2 = {"Ltb/c;", "Ltb/l;", "", "g", "Lcom/xingin/advert/report/AdBean;", "adBean", "c", GoogleApiAvailabilityLight.TRACKING_SOURCE_NOTIFICATION, "m", com.igexin.push.core.d.c.f25536c, "", "beans", "l", "o", "Lcom/xingin/advert/report/AdDao;", "adDao", "<init>", "(Lcom/xingin/advert/report/AdDao;)V", "a", "ads_release"}, k = 1, mv = {1, 6, 0})
/* compiled from: AdMonitorService.kt */
public final class c extends l {
/* renamed from: h reason: collision with root package name */
public static final a f132881h = new a(null);
/* renamed from: f reason: collision with root package name */
public final AdDao f132882f;
/* renamed from: g reason: collision with root package name */
public final ConcurrentLinkedQueue<AdBean> f132883g;
@Metadata(bv = {}, d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0005\b\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0005\u0010\u0006R\u0014\u0010\u0003\u001a\u00020\u00028\u0002XT¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004¨\u0006\u0007"}, d2 = {"Ltb/c$a;", "", "", "TAG", "Ljava/lang/String;", "<init>", "()V", "ads_release"}, k = 1, mv = {1, 6, 0})
/* compiled from: AdMonitorService.kt */
public static final class a {
public a() {
}
public /* synthetic */ a(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
@Metadata(bv = {}, d1 = {"\u0000\u0011\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002*\u0001\u0000\b\n\u0018\u00002\u00020\u0001J\b\u0010\u0003\u001a\u00020\u0002H\u0016¨\u0006\u0004"}, d2 = {"tb/c$b", "Lcom/xingin/utils/async/run/task/XYRunnable;", "", "execute", "ads_release"}, k = 1, mv = {1, 6, 0})
/* compiled from: AdMonitorService.kt */
public static final class b extends XYRunnable {
/* renamed from: a reason: collision with root package name */
public final /* synthetic */ c f132884a;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public b(c cVar, h hVar) {
super("GetAndPing", hVar);
this.f132884a = cVar;
}
@Override // com.xingin.utils.async.run.task.XYRunnable
public void execute() {
while (!this.f132884a.f132883g.isEmpty()) {
AdBean adBean = (AdBean) this.f132884a.f132883g.poll();
if (adBean != null) {
this.f132884a.o(adBean);
}
}
}
}
@Metadata(bv = {}, d1 = {"\u0000\u0011\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002*\u0001\u0000\b\n\u0018\u00002\u00020\u0001J\b\u0010\u0003\u001a\u00020\u0002H\u0016¨\u0006\u0004"}, d2 = {"tb/c$c", "Lcom/xingin/utils/async/run/task/XYRunnable;", "", "execute", "ads_release"}, k = 1, mv = {1, 6, 0})
/* renamed from: tb.c$c reason: collision with other inner class name */
/* compiled from: AdMonitorService.kt */
public static final class C2132c extends XYRunnable {
/* renamed from: a reason: collision with root package name */
public final /* synthetic */ AdBean f132885a;
/* renamed from: b reason: collision with root package name */
public final /* synthetic */ c f132886b;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public C2132c(AdBean adBean, c cVar) {
super("retryAdMon", null, 2, null);
this.f132885a = adBean;
this.f132886b = cVar;
}
@Override // com.xingin.utils.async.run.task.XYRunnable
public void execute() {
String baseUrl = this.f132885a.getBaseUrl();
String body = this.f132885a.getBody();
qb.a.b("AdMonitorService", "retry: " + baseUrl + " " + body);
this.f132886b.o(this.f132885a);
}
}
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public c(AdDao adDao) {
super(10, Integer.MAX_VALUE);
Intrinsics.checkNotNullParameter(adDao, "adDao");
this.f132882f = adDao;
ConcurrentLinkedQueue<AdBean> concurrentLinkedQueue = new ConcurrentLinkedQueue<>();
this.f132883g = concurrentLinkedQueue;
try {
concurrentLinkedQueue.addAll(AdDao.a.a(adDao, System.currentTimeMillis(), null, 2, null));
concurrentLinkedQueue.addAll(AdDao.a.b(adDao, null, 1, null));
String str = CollectionsKt___CollectionsKt.joinToString$default(concurrentLinkedQueue, ", ", null, null, 0, null, null, 62, null);
qb.a.a("load monitor: " + str);
} catch (SQLiteException e14) {
qb.a.c("load monitor failed: " + e14);
}
}
@Override // tb.l
public void c(AdBean adBean) {
Intrinsics.checkNotNullParameter(adBean, "adBean");
qb.a.a("add monitor: " + adBean);
this.f132883g.add(adBean);
n();
}
@Override // tb.l
public void g() {
n();
}
public final void l(List<AdBean> list) {
for (T t14 : list) {
try {
this.f132882f.insert(t14);
} catch (Throwable th3) {
String baseUrl = t14.getBaseUrl();
qb.a.d("AdMonitorService", "dbError: " + baseUrl + " insert failed: " + th3);
}
qb.a.a("insert monitor: " + ((Object) t14));
}
this.f132883g.addAll(list);
}
public final void m(AdBean adBean) {
try {
this.f132882f.delete(adBean);
} catch (Throwable th3) {
String baseUrl = adBean.getBaseUrl();
qb.a.d("AdMonitorService", "dbError: " + baseUrl + " delete failed: " + th3);
}
qb.a.a("delete monitor: " + adBean);
}
public final void n() {
mi2.a.n(new b(this, h.HIGH));
}
public final void o(AdBean adBean) {
l.b<List<AdBean>> bVar;
qb.a.a("handle monitor: " + adBean);
String baseUrl = adBean.getBaseUrl();
if (Intrinsics.areEqual(baseUrl, "https://referee.xiaohongshu.com/v1/third/collect")) {
bVar = b(adBean);
} else if (Intrinsics.areEqual(baseUrl, "https://referee.xiaohongshu.com/v1/stateReport")) {
bVar = e(adBean);
} else {
bVar = d(adBean);
}
adBean.setCount(adBean.getCount() + 1);
if (bVar instanceof l.b.a) {
if (adBean.getCount() >= adBean.getMaxCount()) {
m(adBean);
} else {
p(adBean);
}
List<AdBean> list = (List) ((l.b.a) bVar).a();
if (list != null) {
l(list);
}
} else if (bVar instanceof l.b.C2136b) {
m(adBean);
l((List) ((l.b.C2136b) bVar).a());
}
}
@SuppressLint({"CheckResult"})
public final void p(AdBean adBean) {
try {
this.f132882f.update(adBean);
} catch (Throwable th3) {
String baseUrl = adBean.getBaseUrl();
qb.a.d("AdMonitorService", "dbError: " + baseUrl + " update failed: " + th3);
}
qb.a.a("update monitor: " + adBean);
mi2.a.l(new C2132c(adBean, this), Constants.ASSEMBLE_PUSH_NETWORK_INTERVAL);
}
}