mqqt 代码修改

ningshuxia

2023-06-27 6f8e36ae1d6c41560b2d7692f12c9371a9ccdcf2

mqqt 代码修改

 Mqtt/IStation.DataDockingMqtt4SQI/sub/Mqtt1.cs

@@ -86,7 +86,7 @@
            if (e.ApplicationMessage == null)
                return;
            Console.WriteLine(">>> 收到消息:" + e.ApplicationMessage.ConvertPayloadToString() + ",来自客户端" + e.ClientId + ",主题:" + e.ApplicationMessage.Topic);
        

            var data = JsonHelper.Json2Object<Mqtt1Msg>(e.ApplicationMessage.ConvertPayloadToString());
            if (data != null && data.sensor != null && data.sensor.data != null && data.sensor.data.value != null
                && data.sensor.data.value.Count > 0)
@@ -133,12 +133,12 @@
                    r.SysId = 1620682379477782528;
                    HandleDataHelper.Add(r);
                }
                /*if (id== "")
                if (id == "23020001")
                {
                    //进口压力
                    r.SysId = 1620681990539972608;
                    HandleDataHelper.Add(r); 
                }*/
                    HandleDataHelper.Add(r);
                }
            }
        }
    }

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