IStation/Service.V4.1.git

			@@ -13,6 +13,7 @@
			using Furion.DataEncryption;
			using AutoMapper;
			using System.Text;
			using IStation.Calculation;

			namespace IStation.Application
			{
			@@ -32,9 +33,9 @@
			/// </summary>
			[Route("Insert@V1.0")]
			[HttpPost]
			public bool Insert([Required] DataDockingStandardCorpRecordInput input)
			public bool Insert([Required] DataDockingStandardInput input)
			{
			LogHelper.Info($"注册码:{input.RegisterCode},插入数据记录数量:{input.Records.Count}.");
			LogHelper.Info($"数据标准对接接口中，注册码:{input.RegisterCode},插入数据记录数量:{input.Records.Count}.");

			var corpIds = DataDockingCorpHelper.GetCorpIds();
			if (corpIds == null \|\| corpIds.Count < 1)
			@@ -72,12 +73,14 @@
			var inputRecord = inputRecords.Find(x => x.RecordId == mapper.SignId);
			if (inputRecord != null)
			{
			var record = new Model.MonitorDataDockingReceiveRecord();
			record.SysId = mapper.SysId;
			record.RecordType = inputRecord.RecordType;
			record.SrcTime = inputRecord.RecordTime;
			record.SrcValue = inputRecord.RecordValue;
			record.DataStatus = new List<string>();
			var record = new Model.MonitorDataDockingReceiveRecord
			{
			SysId = mapper.SysId,
			RecordType = inputRecord.RecordType,
			SrcTime = inputRecord.RecordTime,
			SrcValue = inputRecord.RecordValue,
			DataStatus = new List<string>()
			};
			records.Add(record);
			}
			}
			@@ -96,105 +99,105 @@
			});
			if (bol)
			{
			LogHelper.Info($"客户:{standardConfigure.CorpID},标准数据对接配置:{standardConfigure.ID},推入通道记录数量:{records.Count}.");
			LogHelper.Info($"数据标准对接接口中，客户:{standardConfigure.CorpID},标准数据对接配置:{standardConfigure.ID},推入通道记录数量:{records.Count}.");
			return true;
			}
			return false;
			}



			/// <summary>
			/// 补录多条
			/// 补录
			/// </summary>
			//[Route("InsertsSupplement@V1.0")]
			//[HttpPost]
			//public bool InsertsSupplement([Required] List<SupplementMonitorRealRecordInput> list)
			//{
			// var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
			// if (corpIds.Count > 1)
			// {
			// return false;
			// }
			[Route("Supplement@V1.0")]
			[HttpPost]
			public bool Supplement([Required] DataDockingStandardInput input)
			{
			LogHelper.Info($"数据标准对接接口中，注册码:{input.RegisterCode},补录数据记录数量:{input.Records.Count}.");

			// var record_list = new List<Model.MonitorRealRecordPure>();
			// foreach (var item in list)
			// {
			// var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(item.CorpID, item.MonitorPointID);
			// if (monitor == null)
			// {
			// continue;
			// }
			// if (monitor.CronType != Model.Monitor.eCronType.Real)
			// {
			// continue;
			// }
			// switch (monitor.MonitorType)
			// {
			// case Model.eMonitorType.General:
			// {
			// var signal = monitor.SignalList?.FirstOrDefault();
			// if (signal != null)
			// {
			// var data_status = new List<string>();
			// var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, item.SrcTime, item.SrcValue, data_status);
			// if (!string.IsNullOrEmpty(data_value))
			// {
			// var record = new Model.MonitorRealRecordPure();
			// record.CorpID = item.CorpID;
			// record.MonitorPointID = item.MonitorPointID;
			// record.SignalID = signal.ID;
			// record.RecordType = monitor.MonitorType;
			// record.SrcTime = item.SrcTime;
			// record.SrcValue = item.SrcValue;
			// record.DataTime = item.DataTime;
			// record.DataValue = data_value;
			// record.DataStatus = data_status;
			// record_list.Add(record);
			// }
			// }
			// }
			// break;
			// case Model.eMonitorType.Vibration:
			// {
			// var sub_record_list = AddMonitorSubRecordInput.ToList(item.SrcValue);
			// if (sub_record_list != null && sub_record_list.Count > 0)
			// {
			// foreach (var sub_record in sub_record_list)
			// {
			// var signal = monitor.SignalList?.FirstOrDefault(x => x.ID == sub_record.SignalID);
			// if (signal == null)
			// continue;
			// var data_status = new List<string>();
			// var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, item.SrcTime, sub_record.SrcValue, data_status);
			// if (string.IsNullOrEmpty(data_value))
			// continue;
			// var record = new Model.MonitorRealRecordPure();
			// record.CorpID = item.CorpID;
			// record.MonitorPointID = item.MonitorPointID;
			// record.SignalID = signal.ID;
			// record.RecordType = monitor.MonitorType;
			// record.SrcTime = item.SrcTime;
			// record.SrcValue = item.SrcValue;
			// record.DataTime = item.DataTime;
			// record.DataValue = data_value;
			// record.DataStatus = data_status;
			// record_list.Add(record);
			// }
			// }
			// }
			// break;
			// default: break;
			// }
			// }
			var corpIds = DataDockingCorpHelper.GetCorpIds();
			if (corpIds == null \|\| corpIds.Count < 1)
			{
			throw new Exception("未检索到客户标识配置信息！");
			}
			if (_standardConfigureList == null)
			{
			var configureList = new Service.DataDockingConfigure().GetByCorpIds(corpIds);
			if (configureList == null \|\| configureList.Count < 1)
			{
			throw new Exception("未检索到数据对接配置信息！");
			}
			configureList = configureList.Where(x => x.DockingMode == Model.DataDockingConfigure.eDockingMode.Standard).ToList();
			if (configureList == null \|\| configureList.Count < 1)
			{
			throw new Exception("未检索到数据对接标准配置信息！");
			}
			_standardConfigureList = configureList.Select(x => new Model.DataDockingConfigureExStandard(x)).ToList();
			}
			var standardConfigure = _standardConfigureList.Find(x => x.ConfigureParas != null && x.ConfigureParas.RegisterCode == input.RegisterCode);
			if (standardConfigure == null)
			{
			throw new Exception("未检索到数据对接标准配置信息！");
			}
			if (standardConfigure.Mappers == null \|\| standardConfigure.Mappers.Count < 1)
			{
			throw new Exception("数据对接标准配置信息中，未配置有效映射关系！");
			}

			// if (record_list.Count < 1)
			// {
			// return false;
			// }
			// var bol = _service.InsertsSupplement(record_list);
			// return bol;
			//}
			//生成记录
			var recordList = new List<Model.MonitorBasicRecord>();
			foreach (var mapper in standardConfigure.Mappers)
			{
			var inputRecordList = input.Records.Where(t => t.RecordId == mapper.SignId).ToList();
			if (inputRecordList != null && inputRecordList.Count > 0)
			{
			var inputGroupList = inputRecordList.GroupBy(x => new { x.RecordId, x.RecordTime }).ToList();
			foreach (var inputGroup in inputGroupList)
			{
			var inputFirstRecord = inputGroup.First();
			var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(standardConfigure.CorpID, mapper.SysId);
			if (monitor == null)
			{
			continue;
			}
			switch (inputFirstRecord.RecordType)
			{
			case Model.eMonitorType.General:
			{
			var receiveRecord = new Model.MonitorDataDockingReceiveRecord();
			receiveRecord.SysId = mapper.SysId;
			receiveRecord.RecordType = inputFirstRecord.RecordType;
			receiveRecord.SrcTime = inputFirstRecord.RecordTime;
			receiveRecord.SrcValue = inputFirstRecord.RecordValue;
			var record = MonitorHandleHelper.HandleHistory(monitor, monitor.SignalList.First(),receiveRecord,inputFirstRecord.RecordTime);
			if (record != null)
			{
			recordList.Add(record);
			}
			}
			break;
			case Model.eMonitorType.Vibration:
			{

			}
			break;
			default: break;
			}
			}
			}
			}

			if (recordList.Count < 1)
			{
			return false;
			}

			//临时
			var bol = new Service.MonitorRealRecord().InsertsSupplement(recordList.Select(x=>x as Model.MonitorRealRecordPure).ToList());
			return bol;

			}