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

如何解决为Concox GPS追踪器HVT001实现C#侦听器时出现问题

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

下面是控制台窗口中输入内容的屏幕截图:

Below is a screen capture of the input from my console window

您可以看到终端ID显示为乱码,并且没有位置消息出现(我也得到了我无法识别的协议编号)

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

这是代码段:

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,-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,4);

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

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

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


                                    Console.WriteLine("Received good location message from Serial Number '{0}',Time = '{1}'",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,second);
                                    Console.WriteLine("Received good alarm message from Serial Number '{0}',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}'",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,4);

                                            lengthOfCommand = connectOilAndEletricity[4];
                                            stringArray = new byte[lengthOfCommand - 4]; //do not include server flag bit
                                            Array.Copy(connectOilAndEletricity,9,stringArray,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,4);
                                    stringArray = new byte[lengthOfCommand - 4]; //do not include server flag bit
                                    Array.Copy(receiveMessage,lengthOfCommand - 4);
                                    stringMessage = Encoding.ASCII.GetString(stringArray);

                                    Console.WriteLine("String Message,stringMessage);

                                    break;

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

            Console.WriteLine(e.Message);
        }

    }

解决方法

首先,Google文档无法共享代码,请记住以下问题。我无法真正测试您的代码,但是从我从这份GPS文档中读到的内容来看。我可以告诉你,您的IMEI问题在于您对它的反序列化不好。

根据文档,登录消息包有18个字节,并按此顺序进行了划分

  • 2作为起始位
  • 1(表示包裹长度)
  • 1作为协议编号(在本例中为协议1或0x01)
  • 以IMEI的
  • 8为例,此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字符,只想将要写入的数字作为十六进制字符串,删除生成方法的破折号,并删除前导零(如果存在)

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

这是您的IMEI变量的外观:

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams[&#39;font.sans-serif&#39;] = [&#39;SimHei&#39;] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -&gt; systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping(&quot;/hires&quot;) public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate&lt;String
使用vite构建项目报错 C:\Users\ychen\work&gt;npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)&gt; insert overwrite table dwd_trade_cart_add_inc &gt; select data.id, &gt; data.user_id, &gt; data.course_id, &gt; date_format(
错误1 hive (edu)&gt; insert into huanhuan values(1,&#39;haoge&#39;); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive&gt; show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 &lt;configuration&gt; &lt;property&gt; &lt;name&gt;yarn.nodemanager.res