mqqt 代码修改

ningshuxia

2023-06-27 6f8e36ae1d6c41560b2d7692f12c9371a9ccdcf2

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