package d.f.a;

import android.os.Handler;
import android.util.Log;
import com.cvte.vman.instance.InvokeCmd;
import com.ifpdos.udi.sdk.service.sdk.UdiGlobal;
import com.ifpdos.udi.sdk.service.sdk.json.IConverter;
import com.ifpdos.udi.sdk.service.sdk.json.MissingFieldException;
import com.ifpdos.udi.sdk.service.sdk.log.IRequestTracker;
import com.ifpdos.udi.sdk.service.sdk.server.IRequest;
import com.ifpdos.udi.sdk.service.sdk.server.Response;
import com.seewo.sdk.OpenSDK;
import com.seewo.sdk.SDKAudioHelper;
import com.seewo.sdk.SDKConfigureHelper;
import d.f.a.l1;
import d.f.a.n2;
import d.f.a.r2.h3;
import g.h0.c.l;
import g.k;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Objects;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: TvResetApi.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public final /* synthetic */ class k1 extends g.h0.c.j implements g.h0.b.l<IRequest, Response> {
    public k1(Object obj) {
        super(1, obj, n2.class, "tvReset", "tvReset(Lcom/ifpdos/udi/sdk/service/sdk/server/IRequest;)Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", 0);
    }

    @Override // g.h0.b.l
    public Response invoke(IRequest iRequest) throws InterruptedException {
        m1 m1Var;
        IRequest iRequest2 = iRequest;
        g.h0.c.l.f(iRequest2, "p0");
        n2 n2Var = (n2) this.receiver;
        Objects.requireNonNull(n2Var);
        g.h0.c.l.f(iRequest2, "request");
        Reader inputStreamReader = new InputStreamReader(iRequest2.getData(), g.m0.a.f4156b);
        BufferedReader bufferedReader = inputStreamReader instanceof BufferedReader ? (BufferedReader) inputStreamReader : new BufferedReader(inputStreamReader, InvokeCmd.CMD_TOUCH_CTRL_START);
        try {
            String strB = g.g0.f.b(bufferedReader);
            f.a.y.a.B(bufferedReader, null);
            try {
                n2.a aVar = n2Var.f2649b;
                g.h0.c.l.f(strB, "json");
                g.h0.c.l.f(aVar, "token");
                UdiGlobal udiGlobal = UdiGlobal.INSTANCE;
                d1 d1Var = (d1) ((IConverter) udiGlobal.get(g.h0.c.b0.a(IConverter.class))).fromJson(strB, aVar);
                g.h0.c.l.f(iRequest2, "request");
                g.h0.c.l.f(d1Var, "paramParse");
                ((IRequestTracker) udiGlobal.get(g.h0.c.b0.a(IRequestTracker.class))).onParseRequestSuccess(iRequest2, null, strB, d1Var);
                final d.f.a.o2.h hVar = n2Var.a;
                final l1 l1Var = new l1(d1Var, iRequest2.getUri(), iRequest2.getFields());
                Objects.requireNonNull(hVar);
                g.h0.c.l.f(l1Var, "request");
                if (!OpenSDK.getInstance().isConnected()) {
                    Log.d("UdiHandlerService", "wait for connect to opensdk");
                    CountDownLatch countDownLatch = hVar.f2664e;
                    if (countDownLatch != null) {
                        countDownLatch.await(1L, TimeUnit.SECONDS);
                    }
                }
                if (d.f.a.r2.n2.a()) {
                    ((Handler) hVar.f2663d.getValue()).post(new Runnable() { // from class: d.f.a.o2.b
                        @Override // java.lang.Runnable
                        public final void run() throws Throwable {
                            h hVar2 = hVar;
                            l1 l1Var2 = l1Var;
                            l.f(hVar2, "this$0");
                            l.f(l1Var2, "$request");
                            if (d.i.f.b.a.f()) {
                                d.f.a.r2.n2.i(hVar2.f2662c);
                            }
                            if (d.i.f.b.a.c()) {
                                h3.j("rmmod XQDTouchMA");
                            }
                            SDKConfigureHelper.I.setMachineActivation(false);
                            SDKAudioHelper.I.setMute(true);
                            k[] kVarArr = new k[3];
                            kVarArr[0] = new k("isClearData", "true");
                            kVarArr[1] = new k("isPcOff", "true");
                            Boolean bool = l1Var2.a.a;
                            kVarArr[2] = new k("isShutDown", String.valueOf(bool != null ? bool.booleanValue() : false));
                            d.f.a.r2.j3.e.a.c("/v1/system/reset/system", g.c0.g.v(kVarArr), new d.f.a.r2.j3.f(hVar2.f2662c));
                        }
                    });
                    m1Var = new m1();
                } else {
                    m1Var = new m1(400, new Response.ErrorBody("Serial Number is empty, Can not reset machine!"));
                }
                return m1Var.a;
            } catch (MissingFieldException e2) {
                g.h0.c.l.f(iRequest2, "request");
                g.h0.c.l.f(e2, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(g.h0.c.b0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strB, e2);
                Response.Companion companion = Response.Companion;
                StringBuilder sbE = d.b.a.a.a.E("params ", strB, ", miss field : ");
                sbE.append(e2.getMissingFields());
                return companion.makeErrorResponse(400, new Response.ErrorBody(sbE.toString()));
            } catch (Throwable th) {
                g.h0.c.l.f(iRequest2, "request");
                g.h0.c.l.f(th, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(g.h0.c.b0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strB, th);
                return Response.Companion.makeErrorResponse(400, new Response.ErrorBody(d.b.a.a.a.q("params ", strB, " decode failed")));
            }
        } catch (Throwable th2) {
            try {
                throw th2;
            } catch (Throwable th3) {
                f.a.y.a.B(bufferedReader, th2);
                throw th3;
            }
        }
    }
}