流利说-英语 v8.47.26版本的 MD5 值为：0079dce5ff96e6cdbc95c261b3f51387

以下内容为反编译后的 d.java 源代码，内容仅作参考

package com.liulishuo.uploader.aliyun;

import android.util.Log;
import com.liulishuo.lingouploader.m;
import com.liulishuo.lingouploader.r;
import com.liulishuo.lingouploader.w;
import java.io.File;
import java.util.List;
import kotlin.i;
import kotlin.jvm.internal.o;
import kotlin.jvm.internal.t;
import okhttp3.Response;

@i
public final class d implements w {
    private final String bucket;
    private final com.liulishuo.uploader.aliyun.oss.a iZH;
    private final c iZI;
    private final String iZJ;
    private final r iZK;
    private final e iZL;
    public static final a iZN = new a(null);
    private static final r iZM = new r().zT(10).hU(false).zS(1).zU(1);

    @Override
    public String getType() {
        return "OSS";
    }

    public d(String bucket, c tokenProvider, String endpoint, r uploadPolicy, e okHttpClientFactory) {
        t.f(bucket, "bucket");
        t.f(tokenProvider, "tokenProvider");
        t.f(endpoint, "endpoint");
        t.f(uploadPolicy, "uploadPolicy");
        t.f(okHttpClientFactory, "okHttpClientFactory");
        this.bucket = bucket;
        this.iZI = tokenProvider;
        this.iZJ = endpoint;
        this.iZK = uploadPolicy;
        this.iZL = okHttpClientFactory;
        this.iZH = new com.liulishuo.uploader.aliyun.oss.a(this.iZL.build(), this.iZJ);
    }

    public d(String str, c cVar, String str2, r rVar, e eVar, int i, o oVar) {
        this(str, cVar, (i & 4) != 0 ? "https://oss-cn-shanghai.aliyuncs.com" : str2, (i & 8) != 0 ? iZM : rVar, (i & 16) != 0 ? e.iZO.dmp() : eVar);
    }

    @i
    public static final class a {
        private a() {
        }

        public a(o oVar) {
            this();
        }
    }

    @Override
    public r bTL() {
        return this.iZK;
    }

    @Override
    public void a(List<m> list, w.a dao) {
        String description;
        b aQi;
        t.f(list, "list");
        t.f(dao, "dao");
        for (m mVar : list) {
            if (dao.bTx()) {
                return;
            }
            w.b m = dao.m(mVar.getId());
            try {
                description = mVar.getDescription();
                if (description == null) {
                    t.dAE();
                }
                aQi = this.iZI.aQi();
                if (aQi != null && aQi.getExpireTime() < System.currentTimeMillis() / 1000) {
                    aQi = (b) null;
                }
                if (aQi == null) {
                    aQi = this.iZI.aQj();
                }
            } catch (Exception e) {
                String stackTraceString = Log.getStackTraceString(e);
                t.d(stackTraceString, "Log.getStackTraceString(exception)");
                dao.a(m, stackTraceString);
            }
            if (aQi == null) {
                dao.a(m, "oss token is null");
                return;
            }
            Response a2 = this.iZH.a(this.bucket, description, this.iZI, mVar.getPayloadPath());
            if (a2.isSuccessful()) {
                dao.a(m);
                new File(mVar.getPayloadPath()).delete();
                return;
            }
            OSSUploader$process$1$1 oSSUploader$process$1$1 = OSSUploader$process$1$1.INSTANCE;
            if (a2.code() != 403) {
                dao.a(m, "upload fail use token " + oSSUploader$process$1$1.invoke(a2));
                return;
            }
            if (this.iZI.aQj() == null) {
                dao.a(m, "reFetched oss token is null");
                return;
            }
            Response a3 = this.iZH.a(this.bucket, description, this.iZI, mVar.getPayloadPath());
            if (a3.isSuccessful()) {
                dao.a(m);
                new File(mVar.getPayloadPath()).delete();
            } else {
                dao.a(m, "upload fail use reFetch token " + oSSUploader$process$1$1.invoke(a3));
            }
        }
    }
}