package com.seewo.ota.v;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.FileUtils;
import android.os.Handler;
import android.os.Looper;
import android.os.SystemProperties;
import android.text.TextUtils;
import android.util.Log;
import com.google.gson.Gson;
import com.seewo.adbcommons.model.CmdOTAEvent;
import com.seewo.libmyousdk.model.RomUpdateInfo;
import com.seewo.ota.o.e;
import com.seewo.ota.update.speechi.Config;
import com.seewo.ota.update.speechi.SpeechiUpdateInfo;
import com.seewo.ota.util.r;
import com.seewo.ota.util.t;
import d.e.h.a.b;
import java.io.File;
import java.io.IOException;
import java.net.URLEncoder;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: compiled from: SpeechiUpdateManager.java */
/* JADX INFO: loaded from: classes.dex */
public class n extends k {
    private final Handler m;
    private b.a n;
    private SpeechiUpdateInfo o;
    private final com.seewo.ota.p.b p;
    private boolean q;
    private final e.b r;
    private final BroadcastReceiver s;

    /* JADX INFO: compiled from: SpeechiUpdateManager.java */
    class a implements e.b {
        a() {
        }

        @Override // com.seewo.ota.o.e.b
        public void a() {
            n.this.b0();
        }

        @Override // com.seewo.ota.o.e.b
        public void b(int i2) {
            n.this.c0(i2);
        }

        @Override // com.seewo.ota.o.e.b
        public void c(File file) {
            n.this.d0(true);
        }
    }

    /* JADX INFO: compiled from: SpeechiUpdateManager.java */
    class b extends BroadcastReceiver {
        b() {
        }

        @Override // android.content.BroadcastReceiver
        public void onReceive(Context context, Intent intent) {
            if (intent != null && "com.seewo.ota.action.DISABLE_SPEECHI_UPDATE".equals(intent.getAction())) {
                SystemProperties.set("persist.sys.disable_speechi_update", String.valueOf(intent.getBooleanExtra("disable_speechi_update", false)));
                n.this.h();
            }
        }
    }

    /* JADX INFO: compiled from: SpeechiUpdateManager.java */
    class c implements Callback {
        c() {
        }

        private void a() {
            FileUtils.deleteContentsAndDir(new File(n.this.y()));
            if (n.this.f2363f == 1 && Config.isSlotMachine()) {
                CmdOTAEvent cmdOTAEvent = new CmdOTAEvent();
                cmdOTAEvent.mEventCode = 4;
                d.e.a.a.g().j(cmdOTAEvent);
            }
        }

        @Override // okhttp3.Callback
        public void onFailure(Call call, IOException iOException) {
            Log.e("SpeechiUpdateManager", "onFailure:" + iOException.getMessage());
            n.this.e0(b.a.NONE, 2);
        }

        @Override // okhttp3.Callback
        public void onResponse(Call call, Response response) throws IOException {
            Log.d("SpeechiUpdateManager", "onResponse:");
            if (SystemProperties.getBoolean("persist.sys.disable_speechi_update", false)) {
                Log.d("SpeechiUpdateManager", "checkUpdate: disable speechi update");
                return;
            }
            if (!response.isSuccessful()) {
                Log.d("SpeechiUpdateManager", "onResponse: OTA_CHECK_ERROR request failed");
                n.this.e0(b.a.NONE, 2);
                return;
            }
            ResponseBody responseBodyBody = response.body();
            if (responseBodyBody == null) {
                Log.d("SpeechiUpdateManager", "onResponse: OTA_CHECK_ERROR null");
                n.this.e0(b.a.NONE, 2);
                return;
            }
            String strString = responseBodyBody.string();
            try {
                Log.d("SpeechiUpdateManager", "onResponse:" + strString);
                SpeechiUpdateInfo speechiUpdateInfo = (SpeechiUpdateInfo) new Gson().fromJson(strString, SpeechiUpdateInfo.class);
                if (speechiUpdateInfo.getStatusCode() == 404) {
                    Log.d("SpeechiUpdateManager", "onResponse: NONE_VERSION_UPDATE");
                    a();
                    n.this.e0(b.a.NONE, 1);
                } else if (speechiUpdateInfo.getStatusCode() != 200 || TextUtils.isEmpty(speechiUpdateInfo.getAppVersion().getName())) {
                    Log.d("SpeechiUpdateManager", "onResponse: NO_VERSION");
                    n.this.e0(b.a.NONE, 1);
                } else {
                    Log.d("SpeechiUpdateManager", "onResponse: HAVE_VERSION");
                    speechiUpdateInfo.getAppVersion().setPath(n.this.y());
                    speechiUpdateInfo.getAppVersion().setOtaType(n.this.f2363f);
                    speechiUpdateInfo.getAppVersion().setDownloadUrl(n.this.h0() + URLEncoder.encode(speechiUpdateInfo.getAppVersion().getName(), "UTF-8"));
                    Log.d("SpeechiUpdateManager", "onResponse: " + speechiUpdateInfo);
                    n.this.o = speechiUpdateInfo;
                    if (t.j(n.this.y(), n.this.i0())) {
                        n.this.d0(false);
                    } else {
                        n.this.e0(b.a.HAVE, 0);
                    }
                }
            } catch (Exception e2) {
                Log.e("SpeechiUpdateManager", e2.getMessage(), e2);
                n.this.e0(b.a.NONE, 2);
            }
        }
    }

    public n(Context context, com.seewo.ota.p.b bVar) {
        super(context, null);
        this.m = new Handler(Looper.getMainLooper());
        this.r = new a();
        this.s = new b();
        this.p = bVar;
        this.f2363f = 1;
        this.n = b.a.NONE;
    }

    private void a0() {
        com.seewo.ota.o.e.i().q(this.r);
        com.seewo.ota.o.e.i().f(this.o.getAppVersion().getDownloadUrl(), y());
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void b0() {
        this.m.post(new Runnable() { // from class: com.seewo.ota.v.i
            @Override // java.lang.Runnable
            public final void run() {
                this.f2356b.k0();
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void c0(final int i2) {
        this.m.post(new Runnable() { // from class: com.seewo.ota.v.h
            @Override // java.lang.Runnable
            public final void run() {
                this.f2354b.l0(i2);
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void d0(final boolean z) {
        this.m.post(new Runnable() { // from class: com.seewo.ota.v.g
            @Override // java.lang.Runnable
            public final void run() {
                this.f2352b.m0(z);
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void e0(b.a aVar, final int i2) {
        this.n = aVar;
        this.m.post(new Runnable() { // from class: com.seewo.ota.v.j
            @Override // java.lang.Runnable
            public final void run() {
                this.f2357b.n0(i2);
            }
        });
    }

    private String f0() {
        return j0() ? "http://ota-local-test.com/store/" : "http://54.93.108.66/store/";
    }

    private String g0() {
        return f0() + "ws/update/getUpdateInfo/" + s() + File.separator + t();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public String h0() {
        return f0() + "iip/downloadFullZip.html?zipPath=";
    }

    /* JADX INFO: Access modifiers changed from: private */
    public RomUpdateInfo i0() {
        SpeechiUpdateInfo speechiUpdateInfo = this.o;
        if (speechiUpdateInfo == null) {
            return null;
        }
        return new RomUpdateInfo(speechiUpdateInfo.getAppVersion().getName(), "-1", this.o.getStatusCode() == 200 && !TextUtils.isEmpty(this.o.getAppVersion().getName()), this.o.getAppVersion().getName(), this.o.getAppVersion().getDownloadUrl(), this.o.getAppVersion().getFileMd5(), (int) this.o.getAppVersion().getFileSize(), this.o.getAppVersion().getBuildDate(), false, this.q);
    }

    @Override // com.seewo.ota.v.k
    public int C() {
        return this.n.ordinal();
    }

    @Override // com.seewo.ota.v.k
    public void N() {
        Log.d("SpeechiUpdateManager", "startDownload: " + this.f2363f);
        if (SystemProperties.getBoolean("persist.sys.disable_speechi_update", false)) {
            Log.d("SpeechiUpdateManager", "checkUpdate: disable speechi update");
        } else if (this.o == null) {
            Log.e("SpeechiUpdateManager", "startDownload: mRomUpdateInfo == null");
        } else {
            this.n = b.a.DOWNLOADING;
            e.a.h.E(Boolean.TRUE).T(e.a.x.a.b()).F(new e.a.t.d() { // from class: com.seewo.ota.v.f
                @Override // e.a.t.d
                public final Object apply(Object obj) {
                    return this.f2351b.o0((Boolean) obj);
                }
            }).G(e.a.q.b.a.a()).N();
        }
    }

    @Override // com.seewo.ota.v.k
    public void Q() {
        super.Q();
        this.f2360c.registerReceiver(this.s, new IntentFilter("com.seewo.ota.action.DISABLE_SPEECHI_UPDATE"));
    }

    @Override // com.seewo.ota.v.k
    public void R() {
        super.R();
        this.f2360c.unregisterReceiver(this.s);
    }

    @Override // com.seewo.ota.v.k
    public void h() {
        com.seewo.ota.o.e.i().d();
        b0();
    }

    @Override // com.seewo.ota.v.k
    protected void i() {
    }

    @Override // com.seewo.ota.v.k
    public void j(boolean z) {
        Log.d("SpeechiUpdateManager", "checkUpdate :" + z);
        if (SystemProperties.getBoolean("persist.sys.disable_speechi_update", false)) {
            Log.d("SpeechiUpdateManager", "checkUpdate: disable speechi update");
            return;
        }
        b.a aVar = this.n;
        if (aVar == b.a.CHECKING || aVar == b.a.DOWNLOADING) {
            return;
        }
        this.o = null;
        this.q = z;
        this.n = b.a.CHECKING;
        Log.d("SpeechiUpdateManager", "CheckUpdateUrl: " + g0());
        com.seewo.ota.o.f.b().a(g0(), new c());
    }

    protected boolean j0() {
        return SystemProperties.get("persist.sys.ota.test_mode", "").equals("ota_test");
    }

    public /* synthetic */ void k0() {
        this.n = b.a.NONE;
        com.seewo.ota.p.b bVar = this.p;
        if (bVar != null) {
            bVar.i(this.f2363f);
        }
    }

    public /* synthetic */ void l0(int i2) {
        this.n = b.a.DOWNLOADING;
        com.seewo.ota.p.b bVar = this.p;
        if (bVar != null) {
            bVar.e(i2, this.f2363f);
        }
    }

    public /* synthetic */ void m0(boolean z) {
        this.n = b.a.DOWNLOADED;
        com.seewo.ota.p.b bVar = this.p;
        if (bVar != null) {
            bVar.j(i0(), this.f2363f, this.q, z);
        }
    }

    public /* synthetic */ void n0(int i2) {
        com.seewo.ota.p.b bVar = this.p;
        if (bVar != null) {
            bVar.g(i2, this.f2363f, i0(), this.q);
        }
    }

    public /* synthetic */ Boolean o0(Boolean bool) throws Exception {
        if (!t.j(y(), i0())) {
            a0();
            return Boolean.TRUE;
        }
        Log.d("SpeechiUpdateManager", "Don't need to download the file again, the upgrade file is already available locally.");
        d0(false);
        return Boolean.TRUE;
    }

    @Override // com.seewo.ota.v.k
    protected String r() {
        return "";
    }

    @Override // com.seewo.ota.v.k
    protected String s() {
        return r.a();
    }

    @Override // com.seewo.ota.v.k
    protected String t() {
        return Config.getPlatformCurrentVersion();
    }

    @Override // com.seewo.ota.v.k
    protected String y() {
        return B();
    }

    @Override // com.seewo.ota.v.k
    public RomUpdateInfo z() {
        return i0();
    }
}