为 Concox GPS 跟踪器 HVT001 实现 C# 侦听器时出现问题

Question

我正在尝试使用在线提供的代码示例为 Concox GPS 跟踪器（型号 HVT001）实现 C# 侦听器，但由于某种原因，我无法正确获取终端 ID (IMEI)，我不能登录后获取任何位置信息

下面是我的控制台窗口输入的屏幕截图：

如您所见，终端 ID 显示为乱码，没有位置消息出现（我还收到了我不认识的协议号）

任何帮助将不胜感激。 完整代码在这里：https://docs.google.com/document/d/1UsF7ocb5CsCI1rxTcJHLP2eejR6vvboD_M8UeadkVmI/edit?usp=sharing

这是代码的sn-p：

public void ProcessMessages()
    {
        UInt16 sendCRC = 0;
        DateTime date;
        int year = 0;
        int month = 0;
        int day = 0;
        int hour = 0;
        int minute = 0;
        int second = 0;

        KeyValuePair<List<byte>, StateObject> byteState;
        KeyValuePair<UNPACK_STATUS, byte[]> status;
        byte[] receiveMessage = null;
        StateObject state = null;
        byte[] serialNumber = null;
        byte[] serverFlagBit = null;
        byte[] stringArray = null;
        string stringMessage = "";
        byte lengthOfCommand = 0;
        PROTOCOL_NUMBER protocolNumber = PROTOCOL_NUMBER.NONE;

        try
        {
            Boolean firstMessage = true;
            acceptDone.Set();
            //loop forever
            while (true)
            {
                allDone.WaitOne();

                //read fifo until empty
                while (true)
                {
                    //read one connection until buffer doesn't contain any more packets
                    byteState = ReadWrite(PROCESS_STATE.PROCESS, null, null, -1);

                    if (byteState.Value.fifoCount == -1) break;

                    state = byteState.Value;
                    while (true)
                    {
                        status = Unpack(byteState);
                        if (status.Key == UNPACK_STATUS.NOT_ENOUGH_BYTES)
                            break;

                        if (status.Key == UNPACK_STATUS.ERROR)
                        {
                            Console.WriteLine("Error : Bad Receive Message, Data");
                            break;
                        }

                        //message is 2 start bytes + 1 byte (message length) + 1 byte message length + 2 end bytes
                        receiveMessage = status.Value;

                        int messageLength = receiveMessage[2];
                        Console.WriteLine("Status : '{0}', Receive Message : '{1}'", status.Key == UNPACK_STATUS.GOOD_MESSAGE ? "Good" : "Bad", BytesToString(receiveMessage.Take(messageLength + 5).ToArray()));

                        if (status.Key != UNPACK_STATUS.GOOD_MESSAGE)
                        {
                            break;
                        }
                        else
                        {
                            if (firstMessage)
                            {
                                if (receiveMessage[3] != 0x01)
                                {
                                    Console.WriteLine("Error : Expected Login Message : '{0}'", BytesToString(receiveMessage));
                                    break;
                                }
                                firstMessage = false;
                            }

                            //skip start bytes, message length.  then go back 4 bytes (CRC and serial number)
                            serialNumber = receiveMessage.Skip(2 + 1 + messageLength - 4).Take(2).ToArray();

                            protocolNumber = (PROTOCOL_NUMBER)receiveMessage[3];
                            Console.WriteLine("Protocol Number : '{0}'", protocolNumber.ToString());
                            switch (protocolNumber)
                            {
                                case PROTOCOL_NUMBER.LOGIN_MESSAGE:
                                    serialNumber.CopyTo(loginResponse, 4);

                                    sendCRC = crc_bytes(loginResponse.Skip(2).Take(loginResponse.Length - 6).ToArray());

                                    loginResponse[loginResponse.Length - 4] = (byte)((sendCRC >> 8) & 0xFF);
                                    loginResponse[loginResponse.Length - 3] = (byte)((sendCRC) & 0xFF);

                                    string IMEI = Encoding.ASCII.GetString(receiveMessage.Skip(4).Take(messageLength - 5).ToArray());

                                    Console.WriteLine("Received good login message from Serial Number : '{0}', Terminal ID = '{1}'", "0x" + serialNumber[0].ToString("X2") + serialNumber[1].ToString("X2"), IMEI);

                                    //byteState.Value.IMEI = IMEI;

                                    Console.WriteLine("Send Message : '{0}'", BytesToString(loginResponse));
                                    Send(state.workSocket, loginResponse);

                                    WriteDBMessageLogin loginMessage = new WriteDBMessageLogin() { message = DATABASE_MESSAGE_TYPE.LOGIN, IMEI = IMEI, date = DateTime.Now };

                                    WriteDBAsync.ReadWriteFifo(WriteDBAsync.Mode.WRITE, loginMessage);

                                    Console.WriteLine("Wrote to database");
                                    break;
                                case PROTOCOL_NUMBER.LOCATION_DATA:
                                    year = receiveMessage[4];
                                    month = receiveMessage[5];
                                    day = receiveMessage[6];
                                    hour = receiveMessage[7];
                                    minute = receiveMessage[8];
                                    second = receiveMessage[9];

                                    date = new DateTime(2000 + year, month, day, hour, minute, second);

                                    WriteDBMessageLocation locationMessage = new WriteDBMessageLocation();
                                    locationMessage.message = DATABASE_MESSAGE_TYPE.LOCATION;

                                    locationMessage.trackTime = date;
                                    locationMessage.currTime = DateTime.Now;

                                    locationMessage.lattitude = new byte[4];
                                    Array.Copy(receiveMessage, 11, locationMessage.lattitude, 0, 4);

                                    locationMessage.longitude = new byte[4];
                                    Array.Copy(receiveMessage, 15, locationMessage.longitude, 0, 4);
                                    locationMessage.speed = receiveMessage[19];

                                    locationMessage.courseStatus = new byte[2];
                                    Array.Copy(receiveMessage, 20, locationMessage.courseStatus, 0, 2);

                                    locationMessage.IMEI = byteState.Value.IMEI;
                                    WriteDBAsync.ReadWriteFifo(WriteDBAsync.Mode.WRITE, locationMessage);


                                    Console.WriteLine("Received good location message from Serial Number '{0}', Time = '{1}'", "0x" + serialNumber[0].ToString("X2") + serialNumber[1].ToString("X2"), date.ToLongDateString());
                                    break;

                                case PROTOCOL_NUMBER.ALARM_DATA:

                                    //first response
                                    int alarmPacketLen = alarmResponse.Length - 5;
                                    alarmResponse[2] = (byte)(alarmPacketLen & 0xFF);

                                    serialNumber.CopyTo(alarmResponse, alarmPacketLen - 1);

                                    sendCRC = crc_bytes(alarmResponse.Skip(2).Take(alarmPacketLen - 1).ToArray());

                                    alarmResponse[alarmPacketLen + 1] = (byte)((sendCRC >> 8) & 0xFF);
                                    alarmResponse[alarmPacketLen + 2] = (byte)((sendCRC) & 0xFF);

                                    Console.WriteLine("Send Alarm Response Message : '{0}'", BytesToString(alarmResponse));
                                    Send(state.workSocket, alarmResponse);


                                    //second response
                                    year = receiveMessage[4];
                                    month = receiveMessage[5];
                                    day = receiveMessage[6];
                                    hour = receiveMessage[7];
                                    minute = receiveMessage[8];
                                    second = receiveMessage[9];

                                    date = new DateTime(2000 + year, month, day, hour, minute, second);
                                    Console.WriteLine("Received good alarm message from Serial Number '{0}', Time = '{1}'", "0x" + serialNumber[0].ToString("X2") + serialNumber[1].ToString("X2"), date.ToLongDateString());
                                    int alarmDataAddressPacketLen = alarmDataAddressResponse.Length - 5;
                                    alarmDataAddressResponse[2] = (byte)(alarmDataAddressPacketLen & 0xFF);

                                    serialNumber.CopyTo(alarmDataAddressResponse, alarmDataAddressPacketLen - 1);

                                    sendCRC = crc_bytes(alarmDataAddressResponse.Skip(2).Take(alarmDataAddressPacketLen - 1).ToArray());

                                    alarmDataAddressResponse[alarmDataAddressPacketLen + 1] = (byte)((sendCRC >> 8) & 0xFF);
                                    alarmDataAddressResponse[alarmDataAddressPacketLen + 2] = (byte)((sendCRC) & 0xFF);

                                    Console.WriteLine("Send Alarm Data Address Message : '{0}'", BytesToString(alarmDataAddressResponse));
                                    Send(state.workSocket, alarmDataAddressResponse);

                                    break;

                                case PROTOCOL_NUMBER.STATUS_INFO:
                                    serialNumber.CopyTo(heartbeatResponse, 4);

                                    byte info = receiveMessage[4];
                                    byte voltage = receiveMessage[5];
                                    byte GSMsignalStrength = receiveMessage[6];
                                    UInt16 alarmLanguage = (UInt16)((receiveMessage[7] << 8) | receiveMessage[8]);

                                    ALARM alarm = (ALARM)((info >> 3) & 0x07);

                                    sendCRC = crc_bytes(heartbeatResponse.Skip(2).Take(heartbeatResponse.Length - 6).ToArray());

                                    heartbeatResponse[heartbeatResponse.Length - 4] = (byte)((sendCRC >> 8) & 0xFF);
                                    heartbeatResponse[heartbeatResponse.Length - 3] = (byte)((sendCRC) & 0xFF);

                                    Console.WriteLine("Received good status message from Serial Number : '{0}', INFO : '0x{1}{2}{3}{4}'",
                                        "0x" + serialNumber[0].ToString("X2") + serialNumber[1].ToString("X2"),
                                        info.ToString("X2"), voltage.ToString("X2"), GSMsignalStrength.ToString("X2"),
                                        alarmLanguage.ToString("X4"));

                                    Console.WriteLine("Send Message : '{0}'", BytesToString(heartbeatResponse));
                                    Send(state.workSocket, heartbeatResponse);

                                    switch (alarm)
                                    {
                                        //reset cut off alarm
                                        case ALARM.POWER_CUT_ALARM:
                                            int connectOilAndElectricityPacketLen = connectOilAndEletricity.Length - 5;
                                            serialNumber.CopyTo(connectOilAndEletricity, connectOilAndElectricityPacketLen - 1);
                                            sendCRC = crc_bytes(connectOilAndEletricity.Skip(2).Take(connectOilAndEletricity.Length - 6).ToArray());
                                            connectOilAndEletricity[connectOilAndEletricity.Length - 4] = (byte)((sendCRC >> 8) & 0xFF);
                                            connectOilAndEletricity[connectOilAndEletricity.Length - 3] = (byte)((sendCRC) & 0xFF);

                                            serverFlagBit = new byte[4];
                                            Array.Copy(connectOilAndEletricity, 5, serverFlagBit, 0, 4);

                                            lengthOfCommand = connectOilAndEletricity[4];
                                            stringArray = new byte[lengthOfCommand - 4]; //do not include server flag bit
                                            Array.Copy(connectOilAndEletricity, 9, stringArray, 0, lengthOfCommand - 4);
                                            stringMessage = Encoding.ASCII.GetString(stringArray);

                                            Console.WriteLine("Reset Oil and Electricity, Server Flag Bit : '{0}{1}{2}{3}', Message : '{4}'",
                                              serverFlagBit[0].ToString("X2"),
                                              serverFlagBit[1].ToString("X2"),
                                              serverFlagBit[2].ToString("X2"),
                                              serverFlagBit[3].ToString("X2"),
                                              stringMessage);
                                            Send(state.workSocket, connectOilAndEletricity);
                                            break;
                                    }

                                    break;

                                case PROTOCOL_NUMBER.STRING_INFO:
                                    lengthOfCommand = receiveMessage[4];
                                    serverFlagBit = new byte[4];
                                    Array.Copy(receiveMessage, 5, serverFlagBit, 0, 4);
                                    stringArray = new byte[lengthOfCommand - 4]; //do not include server flag bit
                                    Array.Copy(receiveMessage, 9, stringArray, 0, lengthOfCommand - 4);
                                    stringMessage = Encoding.ASCII.GetString(stringArray);

                                    Console.WriteLine("String Message, Server Flag Bit : '{0}{1}{2}{3}', Message : '{4}'",
                                        serverFlagBit[0].ToString("X2"),
                                        serverFlagBit[1].ToString("X2"),
                                        serverFlagBit[2].ToString("X2"),
                                        serverFlagBit[3].ToString("X2"),
                                        stringMessage);

                                    break;

                            } //end switch
                        }// End if
                    } //end while
                }//end while fifo > 0
                allDone.Reset();
            }//end while true
        }
        catch (Exception e)
        {

            Console.WriteLine(e.Message);
        }

    }

Answer 1

首先，谷歌文档是无法共享代码的，请记住下一个问题。我不能真正测试你的代码，但从我在这个 GPS 的文档中读到的内容。我可以告诉你，你的 IMEI 问题是你没有很好地反序列化它。

根据文档，登录消息包有18个字节，按顺序划分

• 2 作为起始位
• 1 代表包裹的长度
• 1 表示协议号（在本例中为协议 1 或 0x01）
• 8 以 IMEI 为例，此 IMEI 123456789123456 的发送方式如下：0x01 0x23 0x45 0x67 0x89 0x120x34 0x56
• 2 获取序列号上的信息
• 2 用于错误检查
• 还有 2 个用于停止

这是您反序列化的行：

string IMEI = Encoding.ASCII.GetString(receiveMessage.Skip(4).Take(messageLength - 5).ToArray());

首先不需要计算你应该拿多少，他们总是8所以receiveMessage.Skip(4).Take(8).ToArray()

然后是编码的问题，您不想将这些数字转换为它们的ascii char，您只想将写入的数字作为十六进制字符串，删除生成方法的破折号，并删除前导如果存在则为零

BitConverter.ToString(ByteArr).Replace("-","").TrimStart('0')

这是您的 IMEI 变量的样子：

string IMEI = BitConverter.ToString(receiveMessage.Skip(4).Take(8).ToArray()).Replace("-","").TrimStart('0');