package com.ifpdos.autotest.lancontrol.serialport;

import android.util.Log;
import com.seewo.libmcuservice.constant.IMcuConstants;
import com.seewo.vtv.interfaces.ISerialDeviceHelper;
import d.j0.c0;
import d.j0.j;
import d.n;
import d.n0.c.l;
import d.n0.c.s;

/* JADX INFO: compiled from: TvApiSerialPortHandler.kt */
/* JADX INFO: loaded from: classes.dex */
@n
public final class e implements b {

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private ISerialDeviceHelper.OnSerialDataListener f2220c;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private b.c.e.c.a.e f2219b = new b.c.e.c.a.e();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private com.ifpdos.autotest.k0.g.c f2221d = com.ifpdos.autotest.k0.g.c.f2056a.a();

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

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

    private final boolean d(int[] iArr) {
        b.c.e.c.a.e eVar = this.f2219b;
        Integer numValueOf = eVar != null ? Integer.valueOf(eVar.sendSerialData(ISerialDeviceHelper.SerialEnum.DEV_TTY1, iArr.length, iArr)) : null;
        return numValueOf != null && numValueOf.intValue() == 0;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void f(e eVar, c cVar, int i, int[] iArr) {
        s.e(eVar, "this$0");
        s.e(cVar, "$callback");
        byte[] bArr = new byte[i];
        for (int i2 = 0; i2 < i; i2++) {
            bArr[i2] = (byte) iArr[i2];
        }
        com.ifpdos.autotest.k0.g.c cVar2 = eVar.f2221d;
        if (cVar2 != null) {
            cVar2.b(bArr, cVar);
        }
    }

    @Override // com.ifpdos.autotest.lancontrol.serialport.b
    public boolean a(final c cVar) {
        s.e(cVar, "callback");
        b.c.e.c.a.e eVar = this.f2219b;
        if (eVar != null) {
            eVar.excSystemCmd("setenforce 0");
        }
        Log.e("TvApiSerialPortHandler", "startSerialPort");
        b.c.e.c.a.e eVar2 = this.f2219b;
        Integer numValueOf = eVar2 != null ? Integer.valueOf(eVar2.setSerialDeviceSwitch(ISerialDeviceHelper.SerialEnum.DEV_TTY1, ISerialDeviceHelper.SerialEnum.SERIAL_ON)) : null;
        b.c.e.c.a.e eVar3 = this.f2219b;
        if (eVar3 != null) {
            eVar3.d(ISerialDeviceHelper.SerialEnum.DEV_TTY1, 230400L);
        }
        try {
            Thread.sleep(300L);
        } catch (InterruptedException e2) {
            Log.getStackTraceString(e2);
        }
        if (numValueOf != null && numValueOf.intValue() == 0) {
            ISerialDeviceHelper.OnSerialDataListener onSerialDataListener = new ISerialDeviceHelper.OnSerialDataListener() { // from class: com.ifpdos.autotest.lancontrol.serialport.a
                @Override // com.seewo.vtv.interfaces.ISerialDeviceHelper.OnSerialDataListener
                public final void onReceiverSerialData(int i, int[] iArr) {
                    e.f(this.f2215a, cVar, i, iArr);
                }
            };
            this.f2220c = onSerialDataListener;
            b.c.e.c.a.e eVar4 = this.f2219b;
            if (eVar4 != null) {
                eVar4.registerSerialDataListener(onSerialDataListener);
            }
        }
        return numValueOf != null && numValueOf.intValue() == 0;
    }

    @Override // com.ifpdos.autotest.lancontrol.serialport.b
    public void b() {
        b.c.e.c.a.e eVar = this.f2219b;
        if (eVar != null) {
            eVar.unRegisterSerialDataListener(this.f2220c);
        }
        this.f2220c = null;
        b.c.e.c.a.e eVar2 = this.f2219b;
        if (eVar2 != null) {
            eVar2.setSerialDeviceSwitch(ISerialDeviceHelper.SerialEnum.DEV_TTY1, ISerialDeviceHelper.SerialEnum.SERIAL_OFF);
        }
    }

    @Override // com.ifpdos.autotest.lancontrol.serialport.b
    public void c(String str) {
        s.e(str, "message");
        byte[] bytes = str.getBytes(d.s0.d.f2700b);
        s.d(bytes, "this as java.lang.String).getBytes(charset)");
        int length = bytes.length;
        int[] iArr = new int[length];
        for (c0<Byte> c0Var : j.y(bytes)) {
            iArr[c0Var.a()] = c0Var.b().byteValue() & IMcuConstants.DEFAULT_VALUE;
        }
        int i = (length / 128) + 1;
        int i2 = 0;
        while (i > 0) {
            int i3 = length - i2;
            if (i3 > 128) {
                i3 = 128;
            }
            int[] iArr2 = new int[i3];
            System.arraycopy(iArr, i2, iArr2, 0, i3);
            i--;
            i2 += 128;
            if (!d(iArr2)) {
                Log.e("TvApiSerialPortHandler", "send result failed");
                return;
            }
        }
    }
}