package c.t.m.g;
import android.content.Context;
import android.os.Build;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import androidx.core.content.PermissionChecker;
import c.t.m.g.br;
import c.t.m.g.bw;
import com.igexin.push.config.c;
import com.xingin.graphic.STMobileHumanActionNative;
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
/* compiled from: TML */
public class ce extends aw {
/* renamed from: c reason: collision with root package name */
private static volatile ce f9609c = null;
/* renamed from: d reason: collision with root package name */
private static String f9610d = "";
/* renamed from: e reason: collision with root package name */
private static volatile String f9611e = "";
/* renamed from: j reason: collision with root package name */
private static final AtomicBoolean f9612j = new AtomicBoolean(false);
/* renamed from: f reason: collision with root package name */
private SimpleDateFormat f9613f = bi.a("HHmmss");
/* renamed from: g reason: collision with root package name */
private a f9614g;
/* renamed from: h reason: collision with root package name */
private boolean f9615h = false;
/* renamed from: i reason: collision with root package name */
private final ConcurrentHashMap<String, Integer> f9616i = new ConcurrentHashMap<>();
public static ce c() {
if (f9609c == null) {
synchronized (ce.class) {
if (f9609c == null) {
f9609c = new ce();
}
}
}
return f9609c;
}
public static String h() {
String str;
StringBuilder sb3 = new StringBuilder();
sb3.append(bi.a("yyyyMMdd-HHmmss").format(new Date()));
sb3.append(',');
sb3.append("");
sb3.append(',');
sb3.append(cc.e());
sb3.append(',');
sb3.append("");
sb3.append(',');
sb3.append(cc.b());
sb3.append(',');
if (bz.a(f9611e)) {
str = "";
} else {
str = f9611e;
}
sb3.append(str);
sb3.append(',');
sb3.append(cc.d());
sb3.append(',');
sb3.append(cc.f());
sb3.append(',');
sb3.append("");
sb3.append(',');
sb3.append("");
return sb3.toString();
}
public static String i() {
return cc.k() + ',' + f9610d + ',' + cc.b() + ',' + Build.BRAND + '_' + cc.i() + ',' + Build.VERSION.SDK_INT + ',' + bw.b() + ',' + cc.g() + "," + cc.f();
}
@Override // c.t.m.g.ax
public String b() {
return "MllcPro";
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void b(String str, String str2) {
a aVar;
bu.a("MllcPro", str + "@" + str2);
if (f() && (aVar = this.f9614g) != null) {
Message obtainMessage = aVar.obtainMessage(103);
obtainMessage.obj = this.f9613f.format(new Date()) + "," + str + "," + str2;
obtainMessage.sendToTarget();
}
}
public static void a(String str) {
f9610d = str;
}
public static final void a(String str, String str2) {
c().b(str, str2);
}
public void a(boolean z14) {
this.f9615h = z14;
}
@Override // c.t.m.g.aw
public int a(Looper looper) {
bu.a("MllcPro", "startup:isUp->" + this.f9615h);
if (this.f9615h) {
a aVar = new a(bo.a("th_loc_extra").getLooper());
this.f9614g = aVar;
bq.a(aVar, 101);
}
this.f9616i.clear();
return 0;
}
@Override // c.t.m.g.ax
public void a() {
a aVar = this.f9614g;
if (aVar != null) {
aVar.a();
this.f9614g = null;
bo.b("th_loc_extra");
}
}
/* compiled from: TML */
public class a extends Handler {
/* renamed from: b reason: collision with root package name */
private StringBuffer f9618b = new StringBuffer(18432);
/* renamed from: c reason: collision with root package name */
private long f9619c;
public a(Looper looper) {
super(looper);
}
private void a(Message message) {
switch (message.what) {
case 101:
removeMessages(101);
this.f9619c = System.currentTimeMillis();
String stringBuffer = this.f9618b.toString();
this.f9618b.setLength(0);
StringBuffer stringBuffer2 = this.f9618b;
stringBuffer2.append("LOC_CORE");
stringBuffer2.append(',');
stringBuffer2.append(ce.h());
if (!bz.a(stringBuffer)) {
this.f9618b.append(stringBuffer);
}
ce.this.b("SYSTEM", ce.i());
removeMessages(102);
bq.a(ce.this.f9614g, 102, (long) c.f25222l);
ce ceVar = ce.this;
ceVar.b("PERMISSION", ceVar.a((ce) bf.a()));
return;
case 102:
removeMessages(102);
bq.a(ce.this.f9614g, 102, (long) c.f25222l);
ce ceVar2 = ce.this;
ceVar2.b("PERMISSION", ceVar2.a((ce) bf.a()));
return;
case 103:
StringBuffer stringBuffer3 = this.f9618b;
stringBuffer3.append('$');
stringBuffer3.append((String) message.obj);
if (this.f9618b.length() < 18432 && System.currentTimeMillis() - this.f9619c < 180000) {
return;
}
ce.this.a((ce) this.f9618b.toString(), (String) false);
this.f9618b.setLength(0);
bq.a(ce.this.f9614g, 101);
return;
case 104:
ce.this.a((ce) "", (String) true);
return;
case 105:
ce.this.a((ce) this.f9618b.toString(), (String) false);
this.f9618b.setLength(0);
bq.a(ce.this.f9614g, 101);
return;
default:
return;
}
}
public void handleMessage(Message message) {
try {
a(message);
} catch (Throwable th3) {
bu.a("MllcPro", "handler message error.", th3);
}
}
public void a() {
StringBuffer stringBuffer = this.f9618b;
stringBuffer.append('$');
stringBuffer.append(ce.this.f9613f.format(new Date()) + ",LOC,shutdown");
String stringBuffer2 = this.f9618b.toString();
this.f9618b.setLength(0);
ce.this.a((ce) stringBuffer2, (String) true);
bq.b(ce.this.f9614g);
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private String a(Context context) {
String[] strArr = {"android.permission.ACCESS_FINE_LOCATION", "android.permission.ACCESS_COARSE_LOCATION", "android.permission.ACCESS_WIFI_STATE", "android.permission.CHANGE_WIFI_STATE", "android.permission.ACCESS_NETWORK_STATE", "android.permission.CHANGE_NETWORK_STATE", "android.permission.READ_PHONE_STATE"};
int i10 = context.getApplicationInfo().targetSdkVersion;
int i14 = 0;
for (int i15 = 0; i15 < 7; i15++) {
try {
if (!a(context, strArr[i15], i10)) {
i14 |= 1 << i15;
}
} catch (Throwable unused) {
i14 = -1;
}
}
int a14 = ed.a().a(context);
return Build.VERSION.SDK_INT + "&" + i10 + "&" + i14 + "&" + a14;
}
/* compiled from: TML */
public class b implements Runnable {
/* renamed from: a reason: collision with root package name */
public byte[] f9620a;
/* renamed from: b reason: collision with root package name */
public boolean f9621b = false;
public b(byte[] bArr, boolean z14) {
this.f9620a = bArr;
this.f9621b = z14;
}
private void a() {
long j14;
long j15;
File[] fileArr;
boolean z14;
bw.a a14 = bw.a();
long j16 = a14 != bw.a.NETWORK_WIFI ? 102400 : STMobileHumanActionNative.ST_MOBILE_HAND_FIST;
try {
File file = new File(bf.a().getExternalFilesDir("data").getAbsolutePath() + "/mllc");
File[] listFiles = file.listFiles();
if (!bz.c(listFiles)) {
long currentTimeMillis = System.currentTimeMillis();
int length = listFiles.length;
long j17 = 0;
int i10 = 0;
while (true) {
if (i10 >= length) {
break;
}
File file2 = listFiles[i10];
if (j17 >= j16) {
break;
}
if (!a(file2, currentTimeMillis)) {
j15 = j16;
fileArr = listFiles;
j14 = currentTimeMillis;
} else {
byte[] b14 = bn.b(file2);
j15 = j16;
String name = file2.getName();
file2.delete();
if (!bz.a(b14)) {
fileArr = listFiles;
j14 = currentTimeMillis;
j17 += (long) b14.length;
z14 = a(b14, false, name.endsWith(".enc2"));
bu.a("MllcPro", "upload:" + name + "," + b14.length + "," + z14);
} else {
fileArr = listFiles;
j14 = currentTimeMillis;
z14 = true;
}
if (!z14) {
bn.a(file.getAbsolutePath(), 10485760);
break;
}
}
i10++;
listFiles = fileArr;
j16 = j15;
currentTimeMillis = j14;
}
ce ceVar = ce.this;
ceVar.b("NET", a14 + ",up file len:" + j17);
}
} catch (Throwable th3) {
bu.a("MllcPro", "up local file error.", th3);
}
}
public void run() {
if (!bz.a(this.f9620a)) {
a(this.f9620a, true, true);
}
if (this.f9621b && !ce.f9612j.get()) {
ce.f9612j.set(true);
a();
ce.f9612j.set(false);
}
}
private boolean a(File file, long j14) {
if (file == null || !file.exists()) {
return false;
}
if (j14 - file.lastModified() < 2592000000L) {
return true;
}
bn.a(file);
return false;
}
private boolean a(byte[] bArr, boolean z14, final boolean z15) {
try {
if (bz.a(bArr)) {
return true;
}
final byte[] a14 = z14 ? bm.a(bArr, true) : bArr;
if (bz.a(a14)) {
return true;
}
ce.this.b("NET", "[src,enc]=[" + bArr.length + "," + a14.length + "],type=" + bw.b());
final boolean[] zArr = {true};
br.a(z15 ? "https://cs.map.qq.com/atta?type=1&multi=0" : "https://analytics.map.qq.com/tr?mllc", a14, new br.c() {
/* class c.t.m.g.ce.b.AnonymousClass1 */
@Override // c.t.m.g.br.c
public void a(String str) {
bu.a("MllcPro", "upload success:" + str);
}
@Override // c.t.m.g.br.c
public void b(String str) {
bu.a("MllcPro", "upload failed:" + str);
try {
File file = new File(bf.a().getExternalFilesDir("data").getAbsolutePath() + "/mllc");
if (!file.exists()) {
file.mkdirs();
}
StringBuilder sb3 = new StringBuilder();
sb3.append("mllc_");
sb3.append(System.currentTimeMillis());
sb3.append(z15 ? ".enc2" : ".enc");
bn.a(new File(file, sb3.toString()), a14, true);
} catch (Throwable unused) {
}
zArr[0] = false;
}
});
return zArr[0];
} catch (Throwable th3) {
bu.a("MllcPro", "up byte[] error.", th3);
return false;
}
}
}
private boolean a(Context context, String str, int i10) {
if (Build.VERSION.SDK_INT < 23) {
return true;
}
if (i10 < 23) {
if (PermissionChecker.checkSelfPermission(context, str) == 0) {
return true;
}
return false;
} else if (context.checkSelfPermission(str) == 0) {
return true;
} else {
return false;
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void a(String str, boolean z14) {
try {
bo.a("th_loc_task_t_consume", new b(str.getBytes("UTF-8"), z14));
} catch (Throwable th3) {
bu.a("MllcPro", "uploadToServerAsync error.", th3);
}
}
}