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 android.support.v4.media.session.PlaybackStateCompat;
import androidx.core.content.PermissionChecker;
import c.t.m.g.br;
import c.t.m.g.bw;
import com.huawei.hms.framework.common.ContainerUtils;
import com.igexin.push.config.c;
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
import kotlin.text.Typography;
import org.jsoup.nodes.DocumentType;
/* compiled from: TML */
public class ce extends aw {
/* renamed from: c reason: collision with root package name */
private static volatile ce f93c = null;
private static String d = "";
private static volatile String e = "";
private static final AtomicBoolean j = new AtomicBoolean(false);
private SimpleDateFormat f = bi.a("HHmmss");
private a g;
private boolean h = false;
private final ConcurrentHashMap<String, Integer> i = new ConcurrentHashMap<>();
@Override // c.t.m.g.ax
public String b() {
return "MllcPro";
}
public static void a(String str) {
d = str;
}
public static ce c() {
if (f93c == null) {
synchronized (ce.class) {
if (f93c == null) {
f93c = new ce();
}
}
}
return f93c;
}
public static final void a(String str, String str2) {
c().b(str, str2);
}
public void a(boolean z) {
this.h = z;
}
/* 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.g) != null) {
Message obtainMessage = aVar.obtainMessage(103);
obtainMessage.obj = this.f.format(new Date()) + "," + str + "," + str2;
obtainMessage.sendToTarget();
}
}
@Override // c.t.m.g.aw
public int a(Looper looper) {
bu.a("MllcPro", "startup:isUp->" + this.h);
if (this.h) {
this.g = new a(bo.a("th_loc_extra").getLooper());
bq.a(this.g, 101);
}
this.i.clear();
return 0;
}
@Override // c.t.m.g.ax
public void a() {
a aVar = this.g;
if (aVar != null) {
aVar.a();
this.g = null;
bo.b("th_loc_extra");
}
}
/* 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 i2 = context.getApplicationInfo().targetSdkVersion;
int i3 = 0;
for (int i4 = 0; i4 < strArr.length; i4++) {
try {
if (!a(context, strArr[i4], i2)) {
i3 |= 1 << i4;
}
} catch (Throwable unused) {
i3 = -1;
}
}
int a2 = ed.a().a(context);
return Build.VERSION.SDK_INT + ContainerUtils.FIELD_DELIMITER + i2 + ContainerUtils.FIELD_DELIMITER + i3 + ContainerUtils.FIELD_DELIMITER + a2;
}
private boolean a(Context context, String str, int i2) {
if (Build.VERSION.SDK_INT < 23) {
return true;
}
if (i2 < 23) {
if (PermissionChecker.checkSelfPermission(context, str) == 0) {
return true;
}
return false;
} else if (context.checkSelfPermission(str) == 0) {
return true;
} else {
return false;
}
}
public static String h() {
StringBuilder sb = new StringBuilder();
sb.append(bi.a("yyyyMMdd-HHmmss").format(new Date()));
sb.append(',');
sb.append("");
sb.append(',');
sb.append(cc.e());
sb.append(',');
sb.append("");
sb.append(',');
sb.append(cc.b());
sb.append(',');
sb.append(bz.a(e) ? "" : e);
sb.append(',');
sb.append(cc.d());
sb.append(',');
sb.append(cc.f());
sb.append(',');
sb.append("");
sb.append(',');
sb.append("");
return sb.toString();
}
public static String i() {
return cc.k() + ',' + d + ',' + cc.b() + ',' + Build.BRAND + '_' + cc.i() + ',' + Build.VERSION.SDK_INT + ',' + bw.b() + ',' + cc.g() + "," + cc.f();
}
/* access modifiers changed from: package-private */
/* compiled from: TML */
public class a extends Handler {
private StringBuffer b = new StringBuffer(18432);
/* renamed from: c reason: collision with root package name */
private long f94c;
public a(Looper looper) {
super(looper);
}
public void handleMessage(Message message) {
try {
a(message);
} catch (Throwable th) {
bu.a("MllcPro", "handler message error.", th);
}
}
private void a(Message message) {
switch (message.what) {
case 101:
removeMessages(101);
this.f94c = System.currentTimeMillis();
String stringBuffer = this.b.toString();
this.b.setLength(0);
StringBuffer stringBuffer2 = this.b;
stringBuffer2.append("LOC_CORE");
stringBuffer2.append(',');
stringBuffer2.append(ce.h());
if (!bz.a(stringBuffer)) {
this.b.append(stringBuffer);
}
ce.this.b(DocumentType.SYSTEM_KEY, ce.i());
removeMessages(102);
bq.a(ce.this.g, 102, (long) c.l);
ce ceVar = ce.this;
ceVar.b("PERMISSION", ceVar.a((ce) bf.a()));
return;
case 102:
removeMessages(102);
bq.a(ce.this.g, 102, (long) c.l);
ce ceVar2 = ce.this;
ceVar2.b("PERMISSION", ceVar2.a((ce) bf.a()));
return;
case 103:
StringBuffer stringBuffer3 = this.b;
stringBuffer3.append(Typography.dollar);
stringBuffer3.append((String) message.obj);
if (this.b.length() < 18432 && System.currentTimeMillis() - this.f94c < 180000) {
return;
}
ce.this.a((ce) this.b.toString(), (String) false);
this.b.setLength(0);
bq.a(ce.this.g, 101);
return;
case 104:
ce.this.a((ce) "", (String) true);
return;
case 105:
ce.this.a((ce) this.b.toString(), (String) false);
this.b.setLength(0);
bq.a(ce.this.g, 101);
return;
default:
return;
}
}
public void a() {
StringBuffer stringBuffer = this.b;
stringBuffer.append(Typography.dollar);
stringBuffer.append(ce.this.f.format(new Date()) + ",LOC,shutdown");
String stringBuffer2 = this.b.toString();
this.b.setLength(0);
ce.this.a((ce) stringBuffer2, (String) true);
bq.b(ce.this.g);
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void a(String str, boolean z) {
try {
bo.a("th_loc_task_t_consume", new b(str.getBytes("UTF-8"), z));
} catch (Throwable th) {
bu.a("MllcPro", "uploadToServerAsync error.", th);
}
}
/* access modifiers changed from: package-private */
/* compiled from: TML */
public class b implements Runnable {
byte[] a;
boolean b = false;
b(byte[] bArr, boolean z) {
this.a = bArr;
this.b = z;
}
public void run() {
if (!bz.a(this.a)) {
a(this.a, true, true);
}
if (this.b && !ce.j.get()) {
ce.j.set(true);
a();
ce.j.set(false);
}
}
private void a() {
long j;
int i;
boolean z;
bw.a a2 = bw.a();
long j2 = a2 != bw.a.NETWORK_WIFI ? 102400 : PlaybackStateCompat.ACTION_SET_SHUFFLE_MODE;
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 j3 = 0;
int i2 = 0;
while (true) {
if (i2 >= length) {
break;
}
File file2 = listFiles[i2];
if (j3 >= j2) {
break;
}
if (!a(file2, currentTimeMillis)) {
j = j2;
i = i2;
} else {
byte[] b2 = bn.b(file2);
String name = file2.getName();
file2.delete();
if (!bz.a(b2)) {
i = i2;
j3 += (long) b2.length;
z = a(b2, false, name.endsWith(".enc2"));
StringBuilder sb = new StringBuilder();
j = j2;
sb.append("upload:");
sb.append(name);
sb.append(",");
sb.append(b2.length);
sb.append(",");
sb.append(z);
bu.a("MllcPro", sb.toString());
} else {
j = j2;
i = i2;
z = true;
}
if (!z) {
bn.a(file.getAbsolutePath(), 10485760);
break;
}
}
i2 = i + 1;
j2 = j;
}
ce.this.b("NET", a2 + ",up file len:" + j3);
}
} catch (Throwable th) {
bu.a("MllcPro", "up local file error.", th);
}
}
private boolean a(File file, long j) {
if (file == null || !file.exists()) {
return false;
}
if (j - file.lastModified() < 2592000000L) {
return true;
}
bn.a(file);
return false;
}
private boolean a(byte[] bArr, boolean z, final boolean z2) {
try {
if (bz.a(bArr)) {
return true;
}
final byte[] a2 = z ? bm.a(bArr, true) : bArr;
if (bz.a(a2)) {
return true;
}
ce.this.b("NET", "[src,enc]=[" + bArr.length + "," + a2.length + "],type=" + bw.b());
final boolean[] zArr = {true};
br.a(z2 ? "https://cs.map.qq.com/atta?type=1&multi=0" : "https://analytics.map.qq.com/tr?mllc", a2, 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 sb = new StringBuilder();
sb.append("mllc_");
sb.append(System.currentTimeMillis());
sb.append(z2 ? ".enc2" : ".enc");
bn.a(new File(file, sb.toString()), a2, true);
} catch (Throwable unused) {
}
zArr[0] = false;
}
});
return zArr[0];
} catch (Throwable th) {
bu.a("MllcPro", "up byte[] error.", th);
return false;
}
}
}
}