ningshuxia
2022-11-30 618f76fd41527d4fec0eefd1d492a8c52da79032
Socket/IStation.DataDockingSocket4KQ/HandleHelper.cs
@@ -8,6 +8,9 @@
namespace IStation.DataDockingSocket
{
    /// <summary>
    /// 处理辅助类
    /// </summary>
    public class HandleHelper : IDataDockingSocket.IHandleHelper
    {
        /// <summary>
@@ -86,13 +89,13 @@
            var item = appParas.InstructionItems.Find(x => x.Verify(bytes));
            if (item == null)
                return;
            var src_list = HandleDataHelper.HandleData(item, bytes);
            if (src_list != null && src_list.Count > 0)
            var srcList = HandleDataHelper.HandleData(item, bytes);
            if (srcList != null && srcList.Count > 0)
            {
                var receive_list = new List<Model.MonitorDataDockingReceiveRecord>();
                var receiveList = new List<Model.MonitorDataDockingReceiveRecord>();
                foreach (var mapper in mappers)
                {
                    var src = src_list.Find(x => x.SignId == mapper.SignId);
                    var src = srcList.Find(x => x.SignId == mapper.SignId);
                    if (src != null)
                    {
                        var record = new Model.MonitorDataDockingReceiveRecord();
@@ -100,10 +103,10 @@
                        record.RecordType = src.RecordType;
                        record.SrcTime = src.SrcTime;
                        record.SrcValue = src.SrcValue;
                        receive_list.Add(record);
                        receiveList.Add(record);
                    }
                }
                receive(receive_list);
                receive(receiveList);
            }
            if (appParas.Src)
@@ -112,14 +115,10 @@
            }
            if (appParas.Debug)
            {
                DebugHelper.Debug(src_list);
                DebugHelper.Debug(srcList);
            }
        }
        public bool Valid(byte[] bytes)
        {
            return false;
        }