mqqt 代码修改

ningshuxia

2023-06-27 6f8e36ae1d6c41560b2d7692f12c9371a9ccdcf2

 Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt2.cs

@@ -99,7 +99,7 @@
            {
                LogCustomHelper.Error("MQTT2 data.msg 为空");
                return;
            } 
            }

            var bytes = StringToHexValuve(data.msg, out string err)?.ToArray();
            LogCustomHelper.Info($"MQTT2 msg:{BitConverter.ToString(bytes)}");
@@ -151,23 +151,23 @@

            //x加速度
            Array.Copy(bytes, 18, byte2, 0, 2);
            var xjsd = bytesToInt2(byte2.Reverse().ToArray());
            var xjsd = BitConverter.ToInt16(byte2.Reverse().ToArray());
            record.SysId = 1628644990471245824;
            record.SrcValue = xjsd.ToString();
            record.SrcValue = (xjsd / 10 / 9.8).ToString();
            list.Add(new Model.MonitorDataDockingReceiveRecord(record));

            //Y加速度
            Array.Copy(bytes, 20, byte2, 0, 2);
            var yjsd = bytesToInt2(byte2.Reverse().ToArray());
            var yjsd = BitConverter.ToInt16(byte2.Reverse().ToArray());
            record.SysId = 1628645042027630592;
            record.SrcValue = yjsd.ToString();
            record.SrcValue = (yjsd / 10 / 9.8).ToString();
            list.Add(new Model.MonitorDataDockingReceiveRecord(record));

            //Z加速度
            Array.Copy(bytes, 22, byte2, 0, 2);
            var zjsd = bytesToInt2(byte2.Reverse().ToArray());
            var zjsd = BitConverter.ToInt16(byte2.Reverse().ToArray());
            record.SysId = 1628645078274805760;
            record.SrcValue = zjsd.ToString();
            record.SrcValue = (zjsd / 10 / 9.8).ToString();
            list.Add(new Model.MonitorDataDockingReceiveRecord(record));

            HandleDataHelper.Add(list);