南通

wangzelong

2022-10-24 d2e40d6b4990c956d9a598b1f313ac47c141671f

南通

 Socket/IStation.DataDockingSocket4NT/helper/HandleDataHelper.cs

@@ -1,5 +1,6 @@
using System;
using System.Collections.Generic;
using System.Diagnostics.CodeAnalysis;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
@@ -20,7 +21,7 @@
                byte[] byteMessage
            )
        {
        

            if (byteMessage[2] == 0x32)
            {
                return ReadMessage监控值(byteMessage);
@@ -47,7 +48,7 @@
            var iFrequece = (int)(frequece * 10);

            byte[] commandSend = null;
             

            IStation.DataDockingSocket.ModBusRtuHelper.BuildSendMessage06(0x01, 20, 2, iFrequece, ref commandSend);

            return commandSend;
@@ -104,7 +105,7 @@
        }


 

        /// <summary>
        /// 读取消息(监控值)
        /// </summary>
@@ -112,27 +113,121 @@
        private static List<Model.MonitorDataDockingReceiveRecord> ReadMessage监控值(byte[] byteMessage)
        {
            var list = new List<Model.MonitorDataDockingReceiveRecord>();
            return list;
            
                       try
                       {
                           //显示消息
                           //string strMessage = BitConverter.ToString(byteMessage, 0, byteMessage.Length);
                           //DisplayMessage(string.Format(" 收到的消息:  {0} ", strMessage));


                           //DisplayMessage(string.Format(" 设备地址: {0} (0x{1})", byteMessage[0], Convert.ToString(byteMessage[0], 16)));
                           //DisplayMessage(string.Format(" 功能码: {0} ", byteMessage[1]));
            try
            {
                //显示消息
                //string strMessage = BitConverter.ToString(byteMessage, 0, byteMessage.Length);
                //DisplayMessage(string.Format(" 收到的消息:  {0} ", strMessage));

                           byte start = 0x1A;
                           string msg;

                //DisplayMessage(string.Format(" 设备地址: {0} (0x{1})", byteMessage[0], Convert.ToString(byteMessage[0], 16)));
                //DisplayMessage(string.Format(" 功能码: {0} ", byteMessage[1]));

                byte start = 0x1A;
                string msg;
                var now = DateTime.Now;
                //当前管网压力
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1575030496453332992, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########当前管网压力 -----> {0} Mpa 数据二进制{1}", GetInt2Byte(byteMessage, 3, out msg), msg) });

                //变频频率
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1575030605857558528, RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########变频频率 -----> {0} Hz 数据二进制{1}", GetInt2Byte(byteMessage, 3 + (27 - start) * 2, out msg) * 0.1, msg) });

                //变频电流
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301190702632960, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########变频电流 -----> {0} A 数据二进制{1}", GetInt2Byte(byteMessage, 3 + (28 - start) * 2, out msg) * 0.1, msg) });

                //真空当前压力
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1575030435430404096,RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########真空当前压力 -----> {0} Mpa 数据二进制{1}", GetInt2Byte(byteMessage, 3 + (29 - start) * 2, out msg) * 0.001, msg) });

                //A相电压
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301249292865536, RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########A相电压 -----> {0}  数据二进制{1}  ", GetDouble1(byteMessage, 3 + (30 - start) * 2, out msg), msg) });

                //B相电压
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301287175819264, RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########B相电压 -----> {0} 数据二进制{1}", GetDouble1(byteMessage, 3 + (32 - start) * 2, out msg), msg) });

                //C相电压
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301332780486656, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########C相电压 -----> {0} 数据二进制{1} ", GetDouble1(byteMessage, 3 + (34 - start) * 2, out msg), msg) });

                //A相电流
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301384118767616, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########A相电流 -----> {0} 数据二进制{1}", GetDouble1(byteMessage, 3 + (36 - start) * 2, out msg), msg) });

                //B相电流
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301478792597504, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########B相电流 -----> {0} 数据二进制{1}", GetDouble1(byteMessage, 3 + (38 - start) * 2, out msg), msg) });

                //C相电流
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301691439616000, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########C相电流 -----> {0} 数据二进制{1}", GetDouble1(byteMessage, 3 + (40 - start) * 2, out msg), msg) }); 
             
                //变频泵状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303421711650816, RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########变频泵状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (42 - start) * 2, out msg), msg) });

                //真空泵状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303241251721216, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########真空泵状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (43 - start) * 2, out msg), msg) });

                ////电动阀开阀状态
                //list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301332780486656, RecordType = Model.eMonitorType.General, SrcTime = now,
                //    SrcValue = string.Format("########电动阀开阀状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (44 - start) * 2, out msg), msg) });

                ////电动阀关阀状态
                //list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582301332780486656, RecordType = Model.eMonitorType.General, SrcTime = now, 
                //    SrcValue = string.Format("########电动阀关阀状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (45 - start) * 2, out msg), msg) });

                //电磁阀状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303081771700224, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########电磁阀状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (46 - start) * 2, out msg), msg) });

                //水位状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303471342850048, RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########水位状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (47 - start) * 2, out msg), msg) });

                //超压状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303606781120512, RecordType = Model.eMonitorType.General, SrcTime = now, 
                    SrcValue = string.Format("########超压状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (48 - start) * 2, out msg), msg) });

                //报警状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303637420511232, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########报警状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (49 - start) * 2, out msg), msg) });

                //变频器状态
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1582303671927050240, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########变频器状态 -----> {0}   数据二进制{1}", GetInt2Byte(byteMessage, 3 + (50 - start) * 2, out msg), msg) });

                //当前液位
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1575388386963886080, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########当前液位 -----> {0} 数据二进制{1} ", GetInt2Byte(byteMessage, 3 + (51 - start) * 2, out msg) * 0.01, msg) });

                //瞬时流量
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1575030320913321984, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########瞬时流量 -----> {0} 数据二进制{1} ", GetInt4Byte(byteMessage, 3 + (52 - start) * 2, out msg) * 0.001, msg) });

                //累计流量
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1584475350807744512, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########累计流量 -----> {0} 数据二进制{1} ", GetInt4Byte(byteMessage, 3 + (54 - start) * 2, out msg) * 1.0, msg) });

                //累计流量有功功率
                list.Add(new Model.MonitorDataDockingReceiveRecord() { SysId = 1584475756476633088, RecordType = Model.eMonitorType.General, SrcTime = now,
                    SrcValue = string.Format("########有功功率 -----> {0} 数据二进制{1} ", GetDouble1(byteMessage, 3 + (56 - start) * 2, out msg), msg) });

                //当前管网压力:26
                //3 = 3+(26-26)*2
                /*              DisplayMessage(string.Format("########当前管网压力 -----> {0} Mpa 数据二进制{1}", GetInt2Byte(byteMessage, 3, out msg), msg));//0.001Mpa
                
                             //变频频率:27
                             //5 = 3+(27-26)*2
                             DisplayMessage(string.Format("########变频频率 -----> {0} Hz 数据二进制{1}", GetInt2Byte(byteMessage, 3 + (27 - start) * 2, out msg) * 0.1, msg));//0.1HZ
                             
                             //变频电流:28
                             DisplayMessage(string.Format("########变频电流 -----> {0} A 数据二进制{1}", GetInt2Byte(byteMessage, 3 + (28 - start) * 2, out msg) * 0.1, msg));//0.1A
                             //真空当前压力:29
@@ -185,14 +280,16 @@
                */
            }
            catch //(Exception err)
                         {
                     
                             return null;
                         }
            {

                return null;
            }

            return list;
        }

        #region MyRegion
        private int GetInt2Byte(byte[] byteMessage, int startPosition, out string info)
        private static int GetInt2Byte(byte[] byteMessage, int startPosition, out string info)
        {
            byte[] value = new byte[2];
            Array.Copy(byteMessage, startPosition, value, 0, 2);
@@ -208,7 +305,7 @@
            return bytesToInt2(byteMessage, startPosition);
        }

        private int GetInt4Byte(byte[] byteMessage, int startPosition, out string info)
        private static int GetInt4Byte(byte[] byteMessage, int startPosition, out string info)
        {
            byte[] value = new byte[4];
            Array.Copy(byteMessage, startPosition, value, 0, 4);
@@ -262,8 +359,18 @@
                    | ((src[offset + 2] & 0xFF) << 8)
                    | (src[offset + 3] & 0xFF));
            return value;
        } 
        }

        private static double GetDouble1(byte[] byteMessage, int startPosition, out string info)
        {
            byte[] value = new byte[4];
            Array.Copy(byteMessage, startPosition, value, 0, 4);
            info = BitConverter.ToString(value, 0, value.Length);

            //return BitConverter.ToDouble(byteMessage, startPosition);
            return BitConverter.ToSingle(value.Reverse().ToArray(), 0);//采用了IEEE-754二进制浮点数算术标准
        }
        #endregion
    }
    

}