修复监测记录SrcTime

lixiaojun

2022-12-01 dbc11dad71dd51b98a79186491bf5d8440a30278

 Application/IStation.Application.Run/data_docking/DataDocking_StandardController.cs

@@ -63,12 +63,13 @@
            if (standardConfigure.Mappers == null || standardConfigure.Mappers.Count < 1)
            {
                throw new Exception("数据对接标准配置信息中，未配置有效映射关系！");
            }
            } 

            var records = new List<Model.MonitorDataDockingReceiveRecord>();
            var inputRecords = input.Records.OrderByDescending(x=>x.RecordTime).ToList();
            foreach (var mapper in standardConfigure.Mappers)
            {
                var inputRecord = input.Records.Find(x=>x.RecordId==mapper.SignId);
                var inputRecord = inputRecords.Find(x => x.RecordId == mapper.SignId);
                if (inputRecord != null)
                {
                    var record = new Model.MonitorDataDockingReceiveRecord();
@@ -89,7 +90,7 @@
            var queueHelper = new RabbitMqQueueHelper();
            var bol = queueHelper.Push(Settings.Queue.DataDockingQueueName, new Model.MonitorDataDockingCorpRecord()
            {
                CorpID=standardConfigure.CorpID,
                CorpID = standardConfigure.CorpID,
                ConfigureID = standardConfigure.ID,
                Records = records
            });