曹妃甸核酸检测平台.apk(点击下载) / a.java

package com.netease.nrtc.utility.b;

import android.net.Uri;
import com.netease.nrtc.c;
import com.netease.nrtc.engine.impl.C0373a;
import com.netease.nrtc.engine.impl.f;
import com.netease.yunxin.base.http.HttpStack;
import com.netease.yunxin.base.trace.Trace;
import com.netease.yunxin.nos.sdk.NosFacade;
import com.netease.yunxin.nos.sdk.UploadCallback;
import com.sina.weibo.sdk.auth.Oauth2AccessToken;
import java.io.File;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class a {

    /* renamed from: a  reason: collision with root package name */
    private RunnableC0110a f11045a;

    /* renamed from: b  reason: collision with root package name */
    private final b f11046b = new b();

    /* renamed from: c  reason: collision with root package name */
    private final ExecutorService f11047c = new ThreadPoolExecutor(0, 1, 30, TimeUnit.SECONDS, new LinkedBlockingQueue());

    /* access modifiers changed from: private */
    /* renamed from: com.netease.nrtc.utility.b.a$a  reason: collision with other inner class name */
    public static class RunnableC0110a implements Runnable {

        /* renamed from: a  reason: collision with root package name */
        private final b f11048a;

        /* renamed from: b  reason: collision with root package name */
        private final f f11049b;

        RunnableC0110a(b bVar, f fVar) {
            this.f11048a = bVar;
            this.f11049b = fVar;
        }

        public long a() {
            return this.f11049b.c();
        }

        public void run() {
            String str;
            try {
                str = this.f11048a.a(String.format("tmp_%d.zip", Long.valueOf(this.f11049b.c())));
            } catch (Exception e2) {
                e2.printStackTrace();
                str = null;
            }
            if (str == null) {
                Trace.e("LogUploadService", "path not found:" + this.f11048a.a());
                return;
            }
            final File file = new File(str);
            c.a(str, str, this.f11049b.b(), new UploadCallback() {
                /* class com.netease.nrtc.utility.b.a.RunnableC0110a.AnonymousClass1 */

                @Override // com.netease.yunxin.nos.sdk.UploadCallback
                public void onCanceled(Object obj) {
                }

                @Override // com.netease.yunxin.nos.sdk.UploadCallback
                public void onFailure(Object obj, int i, String str) {
                    Trace.e("LogUploadService", String.format("onFailure: %s %d %s", obj, Integer.valueOf(i), str));
                }

                @Override // com.netease.yunxin.nos.sdk.UploadCallback
                public void onProgress(Object obj, long j, long j2) {
                    Trace.d("LogUploadService", String.format("onProgress: %s %d/%d", obj, Long.valueOf(j), Long.valueOf(j2)));
                }

                @Override // com.netease.yunxin.nos.sdk.UploadCallback
                public void onSuccess(Object obj, String str) {
                    Trace.i("LogUploadService", String.format("file upload onSuccess: %s", obj));
                    HttpStack.HttpStackResponse doPost = HttpStack.doPost(Uri.parse("https://nrtc.netease.im/nrtc/uploadSdkLog.action").buildUpon().appendQueryParameter("cid", String.valueOf(RunnableC0110a.this.f11049b.c())).appendQueryParameter(Oauth2AccessToken.KEY_UID, String.valueOf(RunnableC0110a.this.f11049b.d())).appendQueryParameter("appkey", C0373a.f10495d).appendQueryParameter("sdkLogUrl", NosFacade.buildFormatUrl(RunnableC0110a.this.f11049b.b())).appendQueryParameter("deviceid", RunnableC0110a.this.f11049b.e()).build().toString());
                    if (doPost == null || doPost.code != 200) {
                        Object[] objArr = new Object[1];
                        objArr[0] = doPost == null ? "null" : doPost.result;
                        Trace.e("LogUploadService", String.format("call http failed: %s", objArr));
                    } else {
                        Trace.i("LogUploadService", String.format("call http onSuccess: %s %s", obj, doPost.result));
                    }
                    file.delete();
                }
            });
        }
    }

    private a() {
    }

    public static a a(String str) {
        a aVar = new a();
        aVar.b(str);
        return aVar;
    }

    private void b(String str) {
        this.f11046b.b(str);
    }

    public void a() {
        RunnableC0110a aVar = this.f11045a;
        if (aVar != null) {
            this.f11047c.execute(aVar);
            this.f11045a = null;
        }
    }

    public void a(f fVar) {
        RunnableC0110a aVar = this.f11045a;
        if (aVar == null || aVar.a() != fVar.c()) {
            this.f11045a = new RunnableC0110a(this.f11046b, fVar);
        } else {
            Trace.i("LogUploadService", "upload task is running");
        }
    }
}