package com.seewo.ota.o;

import android.os.Handler;
import android.os.Looper;
import android.util.Log;
import e.a.h;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.security.MessageDigest;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

/* JADX INFO: compiled from: DownloadHelper.java */
/* JADX INFO: loaded from: classes.dex */
public class e {

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private static volatile e f2217g;
    private final Handler a = new Handler(Looper.getMainLooper());

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private b f2218b = null;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private boolean f2219c = false;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private final OkHttpClient f2220d = new OkHttpClient();

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private Call f2221e = null;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private e.a.r.b f2222f;

    /* JADX INFO: compiled from: DownloadHelper.java */
    class a implements Callback {
        final /* synthetic */ String a;

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        final /* synthetic */ Long f2223b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        final /* synthetic */ Long f2224c;

        a(String str, Long l, Long l2) {
            this.a = str;
            this.f2223b = l;
            this.f2224c = l2;
        }

        @Override // okhttp3.Callback
        public void onFailure(Call call, IOException iOException) {
            Log.e("DownloadHelper", "onFailure " + iOException.getMessage(), iOException);
            e.this.n();
        }

        @Override // okhttp3.Callback
        public void onResponse(Call call, Response response) throws Throwable {
            RandomAccessFile randomAccessFile;
            Log.d("DownloadHelper", "onResponse ");
            byte[] bArr = new byte[4096];
            InputStream inputStream = null;
            try {
                try {
                    InputStream inputStreamByteStream = response.body().byteStream();
                    try {
                        File file = new File(this.a);
                        randomAccessFile = new RandomAccessFile(file, "rw");
                        try {
                            randomAccessFile.seek(this.f2223b.longValue());
                            Log.d("DownloadHelper", "start download size: " + this.f2224c + "  into " + this.a);
                            long j2 = 0;
                            while (true) {
                                int i2 = inputStreamByteStream.read(bArr);
                                if (i2 == -1) {
                                    Log.d("DownloadHelper", "downloadSuccess " + file.getPath() + "  , md5:" + e.this.h(file.getPath()));
                                    e.this.p(file);
                                    com.seewo.ota.data.a.g().E("DownloadHelper", this.f2224c.longValue());
                                    inputStreamByteStream.close();
                                    randomAccessFile.close();
                                    break;
                                }
                                if (call.isCanceled()) {
                                    Log.d("DownloadHelper", "Download Canceled:" + this.a);
                                    try {
                                        inputStreamByteStream.close();
                                        randomAccessFile.close();
                                        response.body().close();
                                        return;
                                    } catch (Exception unused) {
                                        return;
                                    }
                                }
                                randomAccessFile.write(bArr, 0, i2);
                                j2 += (long) i2;
                                e.this.o((int) ((((this.f2223b.longValue() + j2) * 1.0f) / this.f2224c.longValue()) * 100.0f));
                            }
                        } catch (Exception e2) {
                            e = e2;
                            inputStream = inputStreamByteStream;
                            try {
                                Log.e("DownloadHelper", "onResponse error " + e.getMessage(), e);
                                e.this.n();
                                inputStream.close();
                                randomAccessFile.close();
                                response.body().close();
                            } catch (Throwable th) {
                                th = th;
                                try {
                                    inputStream.close();
                                    randomAccessFile.close();
                                    response.body().close();
                                } catch (Exception unused2) {
                                }
                                throw th;
                            }
                        } catch (Throwable th2) {
                            th = th2;
                            inputStream = inputStreamByteStream;
                            inputStream.close();
                            randomAccessFile.close();
                            response.body().close();
                            throw th;
                        }
                    } catch (Exception e3) {
                        e = e3;
                        randomAccessFile = null;
                    } catch (Throwable th3) {
                        th = th3;
                        randomAccessFile = null;
                    }
                } catch (Exception unused3) {
                }
            } catch (Exception e4) {
                e = e4;
                randomAccessFile = null;
            } catch (Throwable th4) {
                th = th4;
                randomAccessFile = null;
            }
        }
    }

    /* JADX INFO: compiled from: DownloadHelper.java */
    public interface b {
        void a();

        void b(int i2);

        void c(File file);
    }

    private e() {
    }

    private void e(String str, String str2, Long l, Long l2) {
        Log.d("DownloadHelper", "download：" + str2 + " ,downloadedLength: " + l + "  , totalDownloadLength:" + l2);
        Request.Builder builderUrl = new Request.Builder().url(str);
        StringBuilder sb = new StringBuilder();
        sb.append("bytes=");
        sb.append(l);
        sb.append("-");
        Call callNewCall = this.f2220d.newCall(builderUrl.addHeader("RANGE", sb.toString()).build());
        this.f2221e = callNewCall;
        callNewCall.enqueue(new a(str2, l, l2));
    }

    private long g(String str) {
        try {
            Response responseExecute = this.f2220d.newCall(new Request.Builder().url(str).build()).execute();
            if (responseExecute == null || !responseExecute.isSuccessful()) {
                return 0L;
            }
            long jContentLength = responseExecute.body().contentLength();
            responseExecute.body().close();
            responseExecute.close();
            return jContentLength;
        } catch (IOException e2) {
            Log.e("DownloadHelper", e2.getMessage(), e2);
            return 0L;
        }
    }

    public static e i() {
        if (f2217g == null) {
            synchronized (e.class) {
                if (f2217g == null) {
                    f2217g = new e();
                }
            }
        }
        return f2217g;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void n() {
        this.f2219c = false;
        if (this.f2218b != null) {
            this.a.post(new Runnable() { // from class: com.seewo.ota.o.d
                @Override // java.lang.Runnable
                public final void run() {
                    this.f2216b.k();
                }
            });
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void o(final int i2) {
        if (this.f2218b != null) {
            this.a.post(new Runnable() { // from class: com.seewo.ota.o.a
                @Override // java.lang.Runnable
                public final void run() {
                    this.f2209b.l(i2);
                }
            });
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void p(final File file) {
        this.f2219c = false;
        if (this.f2218b != null) {
            this.a.post(new Runnable() { // from class: com.seewo.ota.o.c
                @Override // java.lang.Runnable
                public final void run() {
                    this.f2214b.m(file);
                }
            });
        }
    }

    private String r(byte[] bArr) {
        StringBuilder sb = new StringBuilder();
        for (byte b2 : bArr) {
            int i2 = b2 & 255;
            if (i2 < 16) {
                sb.append("0");
            }
            sb.append(Integer.toHexString(i2).toUpperCase());
        }
        return sb.toString();
    }

    public void d() {
        Call call = this.f2221e;
        if (call != null) {
            call.cancel();
        }
        e.a.r.b bVar = this.f2222f;
        if (bVar != null) {
            bVar.dispose();
        }
        this.f2219c = false;
    }

    public void f(final String str, final String str2) {
        if (str == null) {
            return;
        }
        if (this.f2219c) {
            Log.d("DownloadHelper", "isDownloading");
            return;
        }
        d();
        Log.d("DownloadHelper", "downloadOtaFile :" + str);
        this.f2219c = true;
        this.f2222f = h.E(Boolean.TRUE).T(e.a.x.a.b()).F(new e.a.t.d() { // from class: com.seewo.ota.o.b
            @Override // e.a.t.d
            public final Object apply(Object obj) {
                return this.f2211b.j(str2, str, (Boolean) obj);
            }
        }).G(e.a.q.b.a.a()).N();
    }

    public String h(String str) {
        try {
            FileInputStream fileInputStream = new FileInputStream(str);
            byte[] bArr = new byte[4096];
            MessageDigest messageDigest = MessageDigest.getInstance("MD5");
            messageDigest.reset();
            while (true) {
                int i2 = fileInputStream.read(bArr);
                if (i2 <= 0) {
                    fileInputStream.close();
                    return r(messageDigest.digest());
                }
                messageDigest.update(bArr, 0, i2);
            }
        } catch (Exception e2) {
            Log.e("DownloadHelper", e2.getMessage(), e2);
            return "";
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:12:0x0079  */
    /* JADX WARN: Removed duplicated region for block: B:13:0x0082  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public /* synthetic */ java.lang.Boolean j(java.lang.String r8, java.lang.String r9, java.lang.Boolean r10) throws java.lang.Exception {
        /*
            r7 = this;
            com.seewo.ota.data.a r10 = com.seewo.ota.data.a.g()
            java.lang.String r0 = "DownloadHelper"
            java.lang.String r10 = r10.f(r0)
            java.lang.StringBuilder r1 = new java.lang.StringBuilder
            r1.<init>()
            java.lang.String r2 = "lastDownloadUrl:"
            r1.append(r2)
            r1.append(r10)
            java.lang.String r1 = r1.toString()
            android.util.Log.d(r0, r1)
            java.io.File r1 = new java.io.File
            r1.<init>(r8)
            boolean r2 = r1.exists()
            r3 = 0
            if (r2 != 0) goto L34
            java.lang.String r10 = "ota file is not exist"
            android.util.Log.d(r0, r10)
            r1.createNewFile()
            goto L45
        L34:
            boolean r10 = r9.equals(r10)
            if (r10 != 0) goto L47
            java.lang.String r10 = "ota file url is difference"
            android.util.Log.d(r0, r10)
            r1.delete()
            r1.createNewFile()
        L45:
            r1 = r3
            goto L63
        L47:
            java.lang.StringBuilder r10 = new java.lang.StringBuilder
            r10.<init>()
            java.lang.String r2 = "ota file download continue, "
            r10.append(r2)
            long r5 = r1.length()
            r10.append(r5)
            java.lang.String r10 = r10.toString()
            android.util.Log.d(r0, r10)
            long r1 = r1.length()
        L63:
            com.seewo.ota.data.a r10 = com.seewo.ota.data.a.g()
            r10.F(r0, r9)
            com.seewo.ota.data.a r10 = com.seewo.ota.data.a.g()
            r10.E(r0, r3)
            long r5 = r7.g(r9)
            int r10 = (r5 > r3 ? 1 : (r5 == r3 ? 0 : -1))
            if (r10 != 0) goto L82
            java.lang.String r8 = "download failed, otaContentLength is empty"
            android.util.Log.e(r0, r8)
            r7.n()
            goto L9f
        L82:
            int r10 = (r5 > r1 ? 1 : (r5 == r1 ? 0 : -1))
            if (r10 != 0) goto L94
            java.lang.String r9 = "download had been downloaded"
            android.util.Log.e(r0, r9)
            java.io.File r9 = new java.io.File
            r9.<init>(r8)
            r7.p(r9)
            goto L9f
        L94:
            java.lang.Long r10 = java.lang.Long.valueOf(r1)
            java.lang.Long r0 = java.lang.Long.valueOf(r5)
            r7.e(r9, r8, r10, r0)
        L9f:
            java.lang.Boolean r8 = java.lang.Boolean.TRUE
            return r8
        */
        throw new UnsupportedOperationException("Method not decompiled: com.seewo.ota.o.e.j(java.lang.String, java.lang.String, java.lang.Boolean):java.lang.Boolean");
    }

    public /* synthetic */ void k() {
        this.f2218b.a();
    }

    public /* synthetic */ void l(int i2) {
        this.f2218b.b(i2);
    }

    public /* synthetic */ void m(File file) {
        this.f2218b.c(file);
    }

    public void q(b bVar) {
        this.f2218b = bVar;
    }
}