package com.ifpdos.autotest.k0.f;

import android.util.Log;
import com.ifpdos.autotest.lancontrol.module.base.RequestSourceModel;
import com.ifpdos.autotest.model.RequestSession;
import com.seewo.libmcuservice.aidl.model.McuEnum;
import d.n;
import d.n0.c.l;
import d.n0.c.s;

/* JADX INFO: compiled from: SerialPortServer.kt */
/* JADX INFO: loaded from: classes.dex */
@n
public final class d implements com.ifpdos.autotest.k0.f.b {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public static final a f2047a = new a(null);

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private com.ifpdos.autotest.lancontrol.serialport.b f2048b;

    /* JADX INFO: compiled from: SerialPortServer.kt */
    @n
    public static final class a {
        private a() {
        }

        public /* synthetic */ a(l lVar) {
            this();
        }
    }

    /* JADX INFO: compiled from: SerialPortServer.kt */
    @n
    public static final class b implements com.ifpdos.autotest.lancontrol.serialport.c {
        b() {
        }

        @Override // com.ifpdos.autotest.lancontrol.serialport.c
        public void a(String str) {
            s.e(str, McuEnum.KEY_DATA);
            Log.i("SerialPortServer", McuEnum.KEY_DATA + str);
            try {
                d.this.c(str);
            } catch (Exception e2) {
                Log.i("SerialPortServer", "", e2);
            }
        }
    }

    @Override // com.ifpdos.autotest.k0.f.b
    public void a() {
        com.ifpdos.autotest.lancontrol.serialport.b bVarA = com.ifpdos.autotest.lancontrol.serialport.d.f2217a.a();
        this.f2048b = bVarA;
        if (bVarA != null) {
            bVarA.a(new b());
        }
    }

    @Override // com.ifpdos.autotest.k0.f.b
    public void b() {
        com.ifpdos.autotest.lancontrol.serialport.b bVar = this.f2048b;
        if (bVar != null) {
            bVar.b();
        }
    }

    public final synchronized void c(String str) {
        s.e(str, McuEnum.KEY_DATA);
        if (com.ifpdos.autotest.k0.d.b.e()) {
            com.ifpdos.autotest.k0.d.b.f2026a.d(str, this.f2048b);
            return;
        }
        try {
            RequestSourceModel requestSourceModel = (RequestSourceModel) b.c.c.l.a.f(str, RequestSourceModel.class);
            if (requestSourceModel == null) {
                Log.e("SerialPortUtil", "data is not RequestSourceModel type or error data=" + str);
                return;
            }
            RequestSession requestSession = new RequestSession(requestSourceModel.requestType, requestSourceModel.request, new com.ifpdos.autotest.k0.f.f.b(this.f2048b));
            com.ifpdos.autotest.k0.e.b.a aVar = com.ifpdos.autotest.k0.e.b.a.f2035a;
            RequestSession.RequestType requestType = requestSession.getRequestType();
            s.d(requestType, "requestSession.requestType");
            com.ifpdos.autotest.lancontrol.module.base.b bVarA = aVar.a(requestType);
            if (bVarA != null) {
                bVarA.a(requestSession);
            }
            com.ifpdos.autotest.k0.d.b.f2026a.b(str);
        } catch (Exception e2) {
            Log.e("SerialPortUtil", "getMessageForSerialPort decodeJSON Exception=" + e2.getMessage());
        }
    }
}