package com.efs.sdk.base.core.b;
import android.os.Handler;
import android.os.Message;
import android.text.TextUtils;
import android.util.Base64;
import com.efs.sdk.base.core.b.a;
import com.efs.sdk.base.core.controller.ControllerCenter;
import com.efs.sdk.base.core.d.b;
import com.efs.sdk.base.core.e.a.c;
import com.efs.sdk.base.core.e.a.d;
import com.efs.sdk.base.core.f.f;
import com.efs.sdk.base.core.util.Log;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public final class g extends Handler implements e {
private final ConcurrentHashMap<String, a> a = new ConcurrentHashMap<>();
private d b = new d();
private c c = new c();
g() {
super(com.efs.sdk.base.core.util.a.a.a.getLooper());
}
public final void handleMessage(Message message) {
int i = message.what;
if (i == 0) {
b bVar = (b) message.obj;
for (int i2 = 0; i2 < 3; i2++) {
try {
a b2 = b(bVar);
if (b2 == null) {
Log.w("efs.cache", "writer is null for type " + bVar.a.a);
return;
}
if (b2.getChannel().position() + ((long) bVar.c.length) > 819200) {
c(bVar.a.a);
b2 = b(bVar);
if (b2 == null) {
Log.w("efs.cache", "writer is null for type " + bVar.a.a);
return;
}
}
b2.write(Base64.encode(bVar.c, 11));
b2.write("\n".getBytes());
return;
} catch (Throwable th) {
Log.e("efs.cache", "cache file error", th);
}
}
} else if (i == 1 && (message.obj instanceof String)) {
c(message.obj.toString());
}
}
@Override // com.efs.sdk.base.core.b.e
public final void a(b bVar) {
Message obtain = Message.obtain();
obtain.obj = bVar;
obtain.what = 0;
sendMessage(obtain);
}
@Override // com.efs.sdk.base.core.b.e
public final boolean a(File file, b bVar) {
if (!bVar.b()) {
a(file);
return false;
} else if (!file.exists()) {
return false;
} else {
bVar.d = file;
bVar.c();
bVar.b(1);
return true;
}
}
@Override // com.efs.sdk.base.core.b.e
public final void a(String str) {
if (!TextUtils.isEmpty(str)) {
Message obtain = Message.obtain();
obtain.obj = str;
obtain.what = 1;
sendMessage(obtain);
}
}
private static long b(String str) {
Map<String, String> c2 = com.efs.sdk.base.core.config.a.c.a().c();
String concat = "record_accumulation_time_".concat(String.valueOf(str));
if (!c2.containsKey(concat)) {
return 60000;
}
String str2 = c2.get(concat);
if (TextUtils.isEmpty(str2)) {
return 60000;
}
try {
return Math.max(Long.parseLong(str2) * 1000, 1000L);
} catch (Throwable th) {
Log.e("efs.cache", "get cache interval error", th);
return 60000;
}
}
/* JADX WARNING: Removed duplicated region for block: B:19:0x007c */
private a b(b bVar) {
a aVar;
Throwable th;
if (this.a.containsKey(bVar.a.a)) {
return this.a.get(bVar.a.a);
}
File file = new File(com.efs.sdk.base.core.util.a.e(ControllerCenter.getGlobalEnvStruct().mAppContext, ControllerCenter.getGlobalEnvStruct().getAppid()), com.efs.sdk.base.core.util.b.a(bVar));
try {
aVar = new a(file);
try {
a putIfAbsent = this.a.putIfAbsent(bVar.a.a, aVar);
if (putIfAbsent != null) {
com.efs.sdk.base.core.util.b.a(aVar);
com.efs.sdk.base.core.util.b.b(file);
return putIfAbsent;
}
Message obtain = Message.obtain();
obtain.obj = bVar.a.a;
obtain.what = 1;
sendMessageDelayed(obtain, b(bVar.a.a));
if (!"wa".equalsIgnoreCase(bVar.a.a)) {
f.a.a.c.b();
}
return aVar;
} catch (Throwable th2) {
th = th2;
th.printStackTrace();
if (!"wa".equalsIgnoreCase(bVar.a.a)) {
}
return aVar;
}
} catch (Throwable th3) {
aVar = null;
th = th3;
th.printStackTrace();
if (!"wa".equalsIgnoreCase(bVar.a.a)) {
}
return aVar;
}
}
private void c(String str) {
a aVar;
if (this.a.containsKey(str) && (aVar = this.a.get(str)) != null) {
try {
aVar.flush();
com.efs.sdk.base.core.util.b.a(aVar);
a(aVar.b);
this.a.remove(str);
if (!"wa".equalsIgnoreCase(str)) {
f.a.a.c.c();
}
} catch (Throwable th) {
this.a.remove(str);
if (!"wa".equalsIgnoreCase(str)) {
f.a.a.c.c();
}
throw th;
}
}
}
@Override // com.efs.sdk.base.core.b.e
public final void a(File file) {
b b2 = com.efs.sdk.base.core.util.b.b(file.getName());
if (b2 == null) {
a unused = a.b.a;
a.b(file);
} else if (!a(b2, file) || b2.c == null || b2.c.length <= 0) {
a unused2 = a.b.a;
a.b(file);
} else {
com.efs.sdk.base.core.util.b.a(new File(com.efs.sdk.base.core.util.a.f(ControllerCenter.getGlobalEnvStruct().mAppContext, ControllerCenter.getGlobalEnvStruct().getAppid()), com.efs.sdk.base.core.util.b.a(b2)), b2.c);
com.efs.sdk.base.core.util.b.b(file);
}
}
/* JADX INFO: finally extract failed */
private boolean a(b bVar, File file) {
Throwable th;
BufferedReader bufferedReader;
StringBuilder sb = new StringBuilder();
FileReader fileReader = null;
try {
FileReader fileReader2 = new FileReader(file);
try {
bufferedReader = new BufferedReader(fileReader2);
} catch (Throwable th2) {
th = th2;
bufferedReader = null;
fileReader = fileReader2;
try {
Log.e("efs.cache", "local decode error", th);
com.efs.sdk.base.core.util.b.a(bufferedReader);
com.efs.sdk.base.core.util.b.a(fileReader);
return false;
} catch (Throwable th3) {
com.efs.sdk.base.core.util.b.a(bufferedReader);
com.efs.sdk.base.core.util.b.a(fileReader);
throw th3;
}
}
try {
for (String readLine = bufferedReader.readLine(); readLine != null; readLine = bufferedReader.readLine()) {
String b2 = com.efs.sdk.base.core.util.c.b.b(readLine.getBytes());
if (!TextUtils.isEmpty(b2)) {
sb.append(b2);
sb.append("\n");
}
}
bVar.a(sb.toString().getBytes());
bVar.c();
this.c.a(bVar);
bVar.d = file;
com.efs.sdk.base.core.util.b.a(bufferedReader);
com.efs.sdk.base.core.util.b.a(fileReader2);
return true;
} catch (Throwable th4) {
th = th4;
fileReader = fileReader2;
Log.e("efs.cache", "local decode error", th);
com.efs.sdk.base.core.util.b.a(bufferedReader);
com.efs.sdk.base.core.util.b.a(fileReader);
return false;
}
} catch (Throwable th5) {
th = th5;
bufferedReader = null;
Log.e("efs.cache", "local decode error", th);
com.efs.sdk.base.core.util.b.a(bufferedReader);
com.efs.sdk.base.core.util.b.a(fileReader);
return false;
}
}
/* access modifiers changed from: package-private */
public static class a extends FileOutputStream {
long a = System.currentTimeMillis();
File b;
a(File file) {
super(file);
this.b = file;
}
}
}