package com.seewo.factoryaging.sensor;

import android.annotation.SuppressLint;
import android.content.Context;
import android.util.Log;
import com.google.gson.Gson;
import com.seewo.factoryaging.y;
import com.seewo.factoryaging.z;
import j.i;
import j.k;
import j.k0.o;
import j.p0.d.g0;
import j.p0.d.r;
import j.p0.d.s;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
import java.util.Locale;
import java.util.concurrent.TimeUnit;
import jxl.write.WriteException;
import okhttp3.HttpUrl;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: compiled from: SensorPresenter.kt */
/* JADX INFO: loaded from: classes.dex */
public final class e extends com.seewo.factoryaging.sensor.c {
    private final Context c;
    private final i d;
    private final i e;
    private final i f;

    /* JADX INFO: compiled from: SensorPresenter.kt */
    static final class a extends s implements j.p0.c.a<com.seewo.factoryaging.q0.b> {
        a() {
            super(0);
        }

        @Override // j.p0.c.a
        /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
        public final com.seewo.factoryaging.q0.b invoke() {
            return new com.seewo.factoryaging.q0.b(e.this.c);
        }
    }

    /* JADX INFO: compiled from: SensorPresenter.kt */
    static final class b extends s implements j.p0.c.a<com.seewo.factoryaging.co2.h> {
        b() {
            super(0);
        }

        @Override // j.p0.c.a
        /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
        public final com.seewo.factoryaging.co2.h invoke() {
            return new com.seewo.factoryaging.co2.h(e.this.c);
        }
    }

    /* JADX INFO: compiled from: SensorPresenter.kt */
    static final class c extends s implements j.p0.c.a<h> {
        c() {
            super(0);
        }

        @Override // j.p0.c.a
        /* JADX INFO: renamed from: a, reason: merged with bridge method [inline-methods] */
        public final h invoke() {
            return new h(e.this.c);
        }
    }

    public e(Context context) {
        r.f(context, "context");
        this.c = context;
        this.d = k.b(new c());
        this.e = k.b(new a());
        this.f = k.b(new b());
    }

    private final com.seewo.factoryaging.q0.b n() {
        return (com.seewo.factoryaging.q0.b) this.e.getValue();
    }

    private final com.seewo.factoryaging.co2.h o() {
        return (com.seewo.factoryaging.co2.h) this.f.getValue();
    }

    private final String p() throws IOException {
        OkHttpClient okHttpClientBuild = h.b.b.a.f.d().callTimeout(3L, TimeUnit.SECONDS).build();
        Gson gson = new Gson();
        Request.Builder builder = new Request.Builder();
        String strA = h.b.b.a.f.a("/v1/device/sensor/color/temperature");
        r.e(strA, "getFullUrl(URL_COLOR_TEMPERATURE_SENSOR)");
        Response responseExecute = okHttpClientBuild.newCall(builder.url(strA).get().build()).execute();
        ResponseBody responseBodyBody = responseExecute.body();
        if (responseBodyBody != null) {
            try {
                return String.valueOf(((z) gson.fromJson(responseBodyBody.string(), z.class)).a());
            } catch (Throwable th) {
                Log.e("SensorPresenter", "getColorTemperature", th);
                return HttpUrl.FRAGMENT_ENCODE_SET;
            }
        }
        Log.e("SensorPresenter", "getColorTemperature error" + responseExecute);
        return HttpUrl.FRAGMENT_ENCODE_SET;
    }

    private final h q() {
        return (h) this.d.getValue();
    }

    private final String r() throws IOException {
        OkHttpClient okHttpClientBuild = h.b.b.a.f.d().callTimeout(3L, TimeUnit.SECONDS).build();
        Gson gson = new Gson();
        Request.Builder builder = new Request.Builder();
        String strA = h.b.b.a.f.a("/v1/device/sensor/voc");
        r.e(strA, "getFullUrl(URL_COLOR_VOC_SENSOR)");
        Response responseExecute = okHttpClientBuild.newCall(builder.url(strA).get().build()).execute();
        ResponseBody responseBodyBody = responseExecute.body();
        if (responseBodyBody == null) {
            Log.e("SensorPresenter", "getVocValue error " + responseExecute);
            return HttpUrl.FRAGMENT_ENCODE_SET;
        }
        try {
            g0 g0Var = g0.a;
            String str = String.format("%.1f", Arrays.copyOf(new Object[]{Float.valueOf(((y) gson.fromJson(responseBodyBody.string(), y.class)).a())}, 1));
            r.e(str, "format(format, *args)");
            return str;
        } catch (Throwable th) {
            Log.e("SensorPresenter", "getVocValue ", th);
            return HttpUrl.FRAGMENT_ENCODE_SET;
        }
    }

    private final void u(long j2, float f) throws WriteException, IOException {
        if (j2 % TimeUnit.MINUTES.toSeconds(15L) == 0) {
            n().a(new com.seewo.factoryaging.q0.a(f));
            n().g();
        }
    }

    private final void v(long j2, int i2) throws WriteException, IOException {
        if (j2 % TimeUnit.MINUTES.toSeconds(15L) == 0) {
            o().a(new com.seewo.factoryaging.co2.f(i2, 0, 2, null));
            o().g();
        }
    }

    private final void w(long j2, String str, String str2) throws WriteException, IOException {
        if (j2 % TimeUnit.MINUTES.toSeconds(15L) == 0) {
            q().a(new f(str, str2));
            q().g();
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final List x(e eVar, Long l2) throws WriteException, IOException {
        r.f(eVar, "this$0");
        r.f(l2, "it");
        String str = h.c.c.f.a.f() + (char) 8451;
        float fD = h.c.c.f.a.d();
        g0 g0Var = g0.a;
        String str2 = String.format(Locale.ENGLISH, "%.1f%%", Arrays.copyOf(new Object[]{Float.valueOf(fD)}, 1));
        r.e(str2, "format(locale, format, *args)");
        float fA = h.c.c.f.a.a();
        if (fA < 0.0f) {
            fA = 0.0f;
        }
        g0 g0Var2 = g0.a;
        String str3 = String.format(Locale.getDefault(), "%.2f", Arrays.copyOf(new Object[]{Float.valueOf(fA)}, 1));
        r.e(str3, "format(locale, format, *args)");
        int iB = h.c.c.f.a.b();
        String strR = eVar.r();
        eVar.v(l2.longValue(), iB);
        eVar.u(l2.longValue(), fA);
        eVar.w(l2.longValue(), str, str2);
        if (!com.seewo.factoryaging.e1.f.a.i()) {
            return o.i(str, str2, str3, String.valueOf(iB), strR);
        }
        return o.i(str, str2, str3, String.valueOf(iB), eVar.p() + 'K', strR);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void y(e eVar, List list) {
        d dVarI;
        d dVarI2;
        d dVarI3;
        d dVarI4;
        d dVarI5;
        r.f(eVar, "this$0");
        if (com.seewo.factoryaging.e1.f.a.i() && (dVarI5 = eVar.i()) != null) {
            dVarI5.q((String) list.get(4));
        }
        if (!com.seewo.factoryaging.e1.d.a.e() && com.seewo.factoryaging.e1.f.a.q()) {
            d dVarI6 = eVar.i();
            if (dVarI6 != null) {
                dVarI6.s();
                return;
            }
            return;
        }
        if ((com.seewo.factoryaging.e1.d.a.e() || com.seewo.factoryaging.e1.f.a.r()) && (dVarI = eVar.i()) != null) {
            dVarI.w((String) list.get(0));
        }
        if ((com.seewo.factoryaging.e1.d.a.e() || com.seewo.factoryaging.e1.f.a.l()) && (dVarI2 = eVar.i()) != null) {
            dVarI2.c((String) list.get(1));
        }
        if ((com.seewo.factoryaging.e1.d.a.e() || com.seewo.factoryaging.e1.f.a.z(eVar.c)) && (dVarI3 = eVar.i()) != null) {
            dVarI3.r((String) list.get(2));
        }
        if ((com.seewo.factoryaging.e1.d.a.e() || com.seewo.factoryaging.e1.f.a.A(eVar.c)) && (dVarI4 = eVar.i()) != null) {
            dVarI4.C((String) list.get(3));
        }
        if (com.seewo.factoryaging.e1.f.a.B()) {
            int i2 = com.seewo.factoryaging.e1.f.a.i() ? 5 : 4;
            d dVarI7 = eVar.i();
            if (dVarI7 != null) {
                dVarI7.g((String) list.get(i2));
            }
        }
    }

    @Override // com.seewo.factoryaging.sensor.c
    @SuppressLint({"CheckResult"})
    public void l() {
        i.a.d.r(1L, TimeUnit.SECONDS).c(c()).u(i.a.q.a.b()).t(new i.a.m.d() { // from class: com.seewo.factoryaging.sensor.b
            @Override // i.a.m.d
            public final Object a(Object obj) {
                return e.x(this.a, (Long) obj);
            }
        }).u(i.a.j.b.a.a()).x(new i.a.m.c() { // from class: com.seewo.factoryaging.sensor.a
            @Override // i.a.m.c
            public final void accept(Object obj) {
                e.y(this.a, (List) obj);
            }
        });
    }
}