package g.f.c.b.tea;

import android.util.Log;
import com.cvte.va.sdk.mica.api.DeviceStatusManager;
import com.cvte.vman.VmanMiddleWare;
import com.ifpdos.udi.sdk.service.sdk.UdiGlobal;
import com.ifpdos.udi.sdk.service.sdk.json.IJsonObject;
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.ifpdos.udi.sdk.service.sdk.server.UdiException;
import com.ifpdos.udi.service.tea.DeviceTypeEnum;
import com.ifpdos.udi.service.tea.RingCallBody;
import com.ifpdos.udi.service.tea.TeaDeviceHelper;
import g.a.a.a.a;
import g.h.a.i;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Objects;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.io.f;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.e0;
import kotlin.jvm.internal.m;
import kotlin.jvm.internal.o;
import kotlin.text.Charsets;

/* JADX INFO: loaded from: classes.dex */
@Metadata(k = 3, mv = {1, 6, 0}, xi = 48)
public final /* synthetic */ class n0 extends m implements Function1<IRequest, Response> {
    public n0(Object obj) {
        super(1, obj, setDeviceRingCallTeaServiceCoreAdapter.class, "setDeviceRingCall", "setDeviceRingCall(Lcom/ifpdos/udi/sdk/service/sdk/server/IRequest;)Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", 0);
    }

    @Override // kotlin.jvm.functions.Function1
    public Response invoke(IRequest iRequest) throws IOException, UdiException {
        String str;
        Response.Companion companion;
        Response.ErrorBody errorBody;
        IJsonObject iJsonObjectA;
        IJsonObject iJsonObjectMerge;
        int i2;
        IRequest iRequest2 = iRequest;
        o.f(iRequest2, "p0");
        setDeviceRingCallTeaServiceCoreAdapter setdeviceringcallteaservicecoreadapter = (setDeviceRingCallTeaServiceCoreAdapter) this.receiver;
        Objects.requireNonNull(setdeviceringcallteaservicecoreadapter);
        o.f(iRequest2, "request");
        UdiCompileUtils udiCompileUtils = UdiCompileUtils.a;
        if (udiCompileUtils.c(iRequest2)) {
            Reader inputStreamReader = new InputStreamReader(iRequest2.getData(), Charsets.f9181b);
            BufferedReader bufferedReader = inputStreamReader instanceof BufferedReader ? (BufferedReader) inputStreamReader : new BufferedReader(inputStreamReader, 8192);
            try {
                String strC = f.c(bufferedReader);
                i.E(bufferedReader, null);
                str = strC;
            } catch (Throwable th) {
                try {
                    throw th;
                } catch (Throwable th2) {
                    i.E(bufferedReader, th);
                    throw th2;
                }
            }
        } else {
            str = null;
        }
        try {
            IJsonObject iJsonObjectG = udiCompileUtils.g(a.P("type", new Pair(udiCompileUtils.h(iRequest2.getUrl()).get(3), "com.ifpdos.udi.service.tea.DeviceTypeEnum")));
            if (str != null) {
                try {
                    iJsonObjectA = udiCompileUtils.a(str);
                } catch (Throwable th3) {
                    o.f(iRequest2, "request");
                    o.f(th3, "throwable");
                    ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, str, th3);
                    companion = Response.INSTANCE;
                    errorBody = new Response.ErrorBody(a.t("params decode failed: ", str));
                    return companion.makeErrorResponse(400, errorBody);
                }
            } else {
                iJsonObjectA = null;
            }
            if (iJsonObjectA == null || (iJsonObjectMerge = iJsonObjectG.merge(iJsonObjectA)) == null) {
                iJsonObjectMerge = iJsonObjectG;
            }
            try {
                RingCallBody ringCallBody = (RingCallBody) udiCompileUtils.b(iJsonObjectMerge, setdeviceringcallteaservicecoreadapter.f4729b);
                UdiCompileUtils.f(udiCompileUtils, iRequest2, str, ringCallBody, null, 8);
                TeaServiceCore teaServiceCore = setdeviceringcallteaservicecoreadapter.a;
                Objects.requireNonNull(teaServiceCore);
                o.f(ringCallBody, "request");
                DeviceTypeEnum type = ringCallBody.getType();
                boolean enable = ringCallBody.getEnable();
                TeaDeviceManager teaDeviceManager = teaServiceCore.f4671b;
                if (teaDeviceManager == null) {
                    o.n("peripheralDeviceManager");
                    throw null;
                }
                o.f(type, "deviceTypeEnum");
                Log.d("TeaDeviceManager", "setDeviceRingCall: " + type + ' ' + enable);
                int iOrdinal = type.ordinal();
                if (iOrdinal == 0) {
                    BM51UsbTea bM51UsbTea = teaDeviceManager.f4741d;
                    if (bM51UsbTea != null && true == bM51UsbTea.b(teaDeviceManager.a)) {
                        a.k0("setDeviceRingCall to BM51 usb ", enable, "TeaDeviceManager");
                        BM51UsbTea bM51UsbTea2 = teaDeviceManager.f4741d;
                        if (bM51UsbTea2 != null) {
                            a.k0("setDeviceRingCall:", enable, "BM51Usb");
                            TeaDeviceHelper.a.j();
                            bM51UsbTea2.f4680i.setDeviceRingCall(enable);
                            i = 1;
                        }
                    }
                    if (teaDeviceManager.f4739b.b(teaDeviceManager.a)) {
                        Log.d("TeaDeviceManager", "setDeviceRingCall to BM51 dongle " + enable);
                        DeviceStatusManager.getInstance().setDeviceRingCall(enable);
                        i = 1;
                    }
                    if (teaDeviceManager.f4747j.h()) {
                        a.k0("setDeviceRingCall to BM51 poe ", enable, "TeaDeviceManager");
                        TeaPoeBM51Device teaPoeBM51Device = teaDeviceManager.f4747j;
                        Objects.requireNonNull(teaPoeBM51Device);
                        Log.d("TeaPoeBM51Device", "setDeviceRingCall:" + enable);
                        TeaDeviceHelper.a.l();
                        teaPoeBM51Device.f4663d.setDeviceRingCall(enable);
                        i = 1;
                    }
                } else if (iOrdinal == 1) {
                    if (teaDeviceManager.f4743f.b(teaDeviceManager.a) || teaDeviceManager.f4742e.b(teaDeviceManager.a)) {
                        Log.d("TeaDeviceManager", "setDeviceRingCall to BM50 " + enable);
                        DeviceStatusManager.getInstance().setDeviceRingCall(enable);
                        i2 = 1;
                    } else {
                        i2 = 0;
                    }
                    if (teaDeviceManager.f4746i.h()) {
                        a.k0("setDeviceRingCall to BM50 poe ", enable, "TeaDeviceManager");
                        Objects.requireNonNull(teaDeviceManager.f4746i);
                        Log.d("MicPoeBM50Device", "setDeviceRingCall:" + enable);
                        VmanMiddleWare.getInstance().getAoipCtrl().setCallStatus(enable ? 2 : 0);
                        i = 1;
                    } else {
                        i = i2;
                    }
                }
                if (i != 0) {
                    return Response.INSTANCE.makeOkResponse();
                }
                Log.e("TeaServiceCore", "setDeviceRingCall failed");
                throw new UdiException(500, new Response.ErrorBody("Internal Server Error"));
            } catch (MissingFieldException e2) {
                UdiCompileUtils udiCompileUtils2 = UdiCompileUtils.a;
                UdiCompileUtils.e(udiCompileUtils2, iRequest2, str, e2, null, 8);
                return udiCompileUtils2.d(null, iJsonObjectG.toString(), str, e2.getMissingFields());
            } catch (Throwable th4) {
                o.f(iRequest2, "request");
                o.f(th4, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, str, th4);
                companion = Response.INSTANCE;
                errorBody = new Response.ErrorBody(a.t("params decode failed: ", str));
                return companion.makeErrorResponse(400, errorBody);
            }
        } catch (Exception e3) {
            o.f(iRequest2, "request");
            o.f(e3, "throwable");
            return Response.INSTANCE.makeErrorResponse(400, new Response.ErrorBody(a.t("params decode failed: ", a.j((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class)), iRequest2, null, str, e3))));
        }
    }
}