package d.d.a.h;
import android.os.Handler;
import android.os.Message;
import cn.jiguang.net.HttpUtils;
import com.alibaba.sdk.android.oss.ClientConfiguration;
import com.alibaba.sdk.android.oss.ClientException;
import com.alibaba.sdk.android.oss.OSS;
import com.alibaba.sdk.android.oss.OSSClient;
import com.alibaba.sdk.android.oss.ServiceException;
import com.alibaba.sdk.android.oss.callback.OSSCompletedCallback;
import com.alibaba.sdk.android.oss.callback.OSSProgressCallback;
import com.alibaba.sdk.android.oss.common.OSSLog;
import com.alibaba.sdk.android.oss.common.auth.OSSPlainTextAKSKCredentialProvider;
import com.alibaba.sdk.android.oss.common.utils.HttpHeaders;
import com.alibaba.sdk.android.oss.model.GetObjectRequest;
import com.alibaba.sdk.android.oss.model.GetObjectResult;
import com.alibaba.sdk.android.oss.model.PutObjectRequest;
import com.alibaba.sdk.android.oss.model.PutObjectResult;
import com.fob.ds.base.DSApplication;
import com.fob.ds.domain.BaseUrlBean;
import d.d.a.g.g;
import d.d.a.j.b0;
import d.d.a.j.i0;
import d.d.a.j.n;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
public class a {
/* renamed from: d reason: collision with root package name */
static String f2743d = "http://oss-cn-shanghai.aliyuncs.com";
/* renamed from: e reason: collision with root package name */
static String f2744e = "LTAI4FrT82y";
/* renamed from: f reason: collision with root package name */
static String f2745f = "TWwf6qYKMPEKUc";
/* renamed from: g reason: collision with root package name */
static String f2746g = "ds-app-line";
static String h = ("line_" + d.d.a.b.b.q + ".json");
static String i = "ds-app-log";
d.d.a.f.c<BaseUrlBean> a;
private OSS b;
/* renamed from: c reason: collision with root package name */
Handler f2747c;
/* renamed from: d.d.a.h.a$a reason: collision with other inner class name */
class HandlerC0109a extends Handler {
HandlerC0109a() {
}
public void handleMessage(Message message) {
super.handleMessage(message);
int i = message.arg1;
if (i == 1) {
BaseUrlBean baseUrlBean = (BaseUrlBean) new d.e.a.e().i((String) message.obj, BaseUrlBean.class);
d.d.a.f.c<BaseUrlBean> cVar = a.this.a;
if (cVar != null) {
cVar.a(baseUrlBean);
}
} else if (i == 2) {
d.d.a.g.c.c("获取线路读写异常");
d.d.a.f.c<BaseUrlBean> cVar2 = a.this.a;
if (cVar2 != null) {
cVar2.a(null);
}
} else if (i == 3) {
d.d.a.g.c.c("本地异常，如网络异常等。");
d.d.a.f.c<BaseUrlBean> cVar3 = a.this.a;
if (cVar3 != null) {
cVar3.a(null);
}
} else if (i == 4) {
d.d.a.g.c.c("服务异常。");
d.d.a.f.c<BaseUrlBean> cVar4 = a.this.a;
if (cVar4 != null) {
cVar4.a(null);
}
}
}
}
/* access modifiers changed from: package-private */
public class b implements Runnable {
b() {
}
public void run() {
a.this.d();
}
}
/* access modifiers changed from: package-private */
public class c implements OSSProgressCallback<PutObjectRequest> {
c(a aVar) {
}
/* renamed from: a */
public void onProgress(PutObjectRequest putObjectRequest, long j, long j2) {
d.d.a.g.c.c("PutObject currentSize: " + j + " totalSize: " + j2);
}
}
/* access modifiers changed from: package-private */
public class d implements OSSCompletedCallback<PutObjectRequest, PutObjectResult> {
final /* synthetic */ File a;
d(a aVar, File file) {
this.a = file;
}
/* renamed from: a */
public void onFailure(PutObjectRequest putObjectRequest, ClientException clientException, ServiceException serviceException) {
if (clientException != null) {
clientException.printStackTrace();
}
if (serviceException != null) {
d.d.a.g.c.c("ErrorCode" + serviceException.getErrorCode());
d.d.a.g.c.c("RequestId" + serviceException.getRequestId());
d.d.a.g.c.c("HostId" + serviceException.getHostId());
d.d.a.g.c.c("RawMessage" + serviceException.getRawMessage());
}
}
/* renamed from: b */
public void onSuccess(PutObjectRequest putObjectRequest, PutObjectResult putObjectResult) {
d.d.a.g.c.c("Oss 上传成功 -------- " + this.a.getAbsolutePath());
d.d.a.g.c.c("PutObjectUploadSuccess");
d.d.a.g.c.c(HttpHeaders.ETAG + putObjectResult.getETag());
d.d.a.g.c.c("RequestId" + putObjectResult.getRequestId());
i0.a(this.a);
}
}
/* access modifiers changed from: package-private */
public class e implements OSSCompletedCallback<GetObjectRequest, GetObjectResult> {
e() {
}
/* renamed from: a */
public void onFailure(GetObjectRequest getObjectRequest, ClientException clientException, ServiceException serviceException) {
if (clientException != null) {
clientException.printStackTrace();
Message message = new Message();
message.arg1 = 3;
a.this.f2747c.sendMessage(message);
}
if (serviceException != null) {
Message message2 = new Message();
message2.arg1 = 4;
a.this.f2747c.sendMessage(message2);
d.d.a.g.c.c("ErrorCode " + serviceException.getErrorCode());
d.d.a.g.c.c("RequestId " + serviceException.getRequestId());
d.d.a.g.c.c("HostId " + serviceException.getHostId());
d.d.a.g.c.c("RawMessage " + serviceException.getRawMessage());
}
}
/* renamed from: b */
public void onSuccess(GetObjectRequest getObjectRequest, GetObjectResult getObjectResult) {
d.d.a.g.c.c("asyncGetObjectDownloadSuccess");
d.d.a.g.c.c("Content-Length " + getObjectResult.getContentLength());
InputStream objectContent = getObjectResult.getObjectContent();
byte[] bArr = new byte[2048];
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
while (true) {
try {
int read = objectContent.read(bArr);
if (read != -1) {
byteArrayOutputStream.write(bArr, 0, read);
} else {
byte[] byteArray = byteArrayOutputStream.toByteArray();
byteArrayOutputStream.close();
objectContent.close();
String str = new String(byteArray);
d.d.a.g.c.c("oSS 返回数据 " + str);
Message message = new Message();
message.arg1 = 1;
message.obj = str;
a.this.f2747c.sendMessage(message);
return;
}
} catch (IOException e2) {
Message message2 = new Message();
message2.arg1 = 2;
a.this.f2747c.sendMessage(message2);
e2.printStackTrace();
return;
}
}
}
}
/* access modifiers changed from: private */
public static class f {
private static final a a = new a(null);
}
/* synthetic */ a(HandlerC0109a aVar) {
this();
}
public static a b() {
return f.a;
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void d() {
if (this.b == null) {
this.b = e();
}
this.b.asyncGetObject(new GetObjectRequest(f2746g, h), new e());
}
private OSS e() {
OSSPlainTextAKSKCredentialProvider oSSPlainTextAKSKCredentialProvider = new OSSPlainTextAKSKCredentialProvider(f2744e + "LuE5jDXKjVjSM", f2745f + "BkM68e7Obc7OFIGw");
ClientConfiguration clientConfiguration = new ClientConfiguration();
clientConfiguration.setConnectionTimeout(5000);
clientConfiguration.setSocketTimeout(5000);
clientConfiguration.setMaxConcurrentRequest(2);
clientConfiguration.setMaxErrorRetry(2);
OSSClient oSSClient = new OSSClient(DSApplication.c(), f2743d, oSSPlainTextAKSKCredentialProvider, clientConfiguration);
OSSLog.disableLog();
return oSSClient;
}
private void h(String str, int i2, String str2) {
if (this.b == null) {
this.b = e();
}
String str3 = i2 == 0 ? "mtr" : "httpErr";
File file = new File(str);
if (b0.a(str2)) {
str2 = "游客";
}
d.d.a.g.c.c("Oss 开始上传文件 " + str);
String str4 = i;
PutObjectRequest putObjectRequest = new PutObjectRequest(str4, d.d.a.b.b.o + HttpUtils.PATHS_SEPARATOR + str3 + HttpUtils.PATHS_SEPARATOR + (n.e(new Date()) + "_" + str2 + "_" + System.currentTimeMillis() + "_log.txt"), str);
putObjectRequest.setProgressCallback(new c(this));
this.b.asyncPutObject(putObjectRequest, new d(this, file));
}
private void i(String str, int i2) {
File file = new File(DSApplication.c().a(i2));
if (file.exists()) {
for (File file2 : file.listFiles()) {
b().h(file2.getAbsolutePath(), i2, str);
}
}
}
public void c(d.d.a.f.c<BaseUrlBean> cVar) {
this.a = cVar;
g.b().a(new b());
}
public void f(String str) {
try {
i(str, 1);
} catch (Exception e2) {
e2.printStackTrace();
}
}
public void g(String str) {
try {
i(str, 0);
} catch (Exception e2) {
e2.printStackTrace();
}
}
private a() {
this.f2747c = new HandlerC0109a();
}
}