using Microsoft.AspNetCore.Mvc;
using System.Net;
using System.Net.Http.Headers;
using Microsoft.Extensions.Hosting.Internal;
using Microsoft.AspNetCore.Http.Extensions;
using IStation.Untity;
using Furion.DynamicApiController;
using System.ComponentModel.DataAnnotations;
using Mapster;
using IStation.Calculation;
using IStation.Model;
using Microsoft.AspNetCore.Authorization;
namespace IStation.Application
{
///
/// MonitorDayRecord
///
[Route("Run/MonitorDayRecord")]
[ApiDescriptionSettings("Run", Name = "监测日记录", Order = 970)]
public class MonitorDayRecord_Controller : IDynamicApiController
{
//服务
private readonly Service.MonitorDayRecord _service = new Service.MonitorDayRecord();
#region 获取最近记录
#region 通过 MonitorPointID 获取
///
/// 通过 MonitorPointID 获取最近一条数据(未进行单位转换,使用的是系统单位)
///
[Route("GetLastRecordByMonitorPointID@V1.0")]
[HttpGet]
public List GetLastRecordByMonitorPointID_V1_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取最近一条数据(不需要验证Token)(未进行单位转换,使用的是系统单位)
///
[AllowAnonymous]
[Route("GetLastRecordByMonitorPointID@V1.1")]
[HttpGet]
public List GetLastRecordByMonitorPointID_V1_1([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取最近一条数据(已进行单位转换,使用的是信号显示单位)
///
[Route("GetLastRecordByMonitorPointID@V2.0")]
[HttpGet]
public List GetLastRecordByMonitorPointID_V2_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
var vmList = list.Select(x => new MonitorDayRecordDto(x, monitor?.SignalList?.Find(t => t.ID == x.SignalID))).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取最近一条数据(不需要验证Token)(已进行单位转换,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetLastRecordByMonitorPointID@V2.1")]
[HttpGet]
public List GetLastRecordByMonitorPointID_V2_1([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
var vmList = list.Select(x => new MonitorDayRecordDto(x, monitor?.SignalList?.Find(t => t.ID == x.SignalID))).ToList();
return vmList;
}
#endregion
#region 通过 MonitorPointIds 获取最近记录
///
/// 通过 MonitorPointIds 获取最近一条数据(未进行单位转换,使用的是系统单位)
///
[Route("GetLastRecordByMonitorPointIds@V1.0")]
[HttpGet]
public List GetLastRecordByMonitorPointIds_V1_0([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.MonitorPointIds);
var list = _service.GetLastRecord(input.CorpID, ids);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointIds 获取最近一条数据(不需要验证Token)(未进行单位转换,使用的是系统单位)
///
[AllowAnonymous]
[Route("GetLastRecordByMonitorPointIds@V1.1")]
[HttpGet]
public List GetLastRecordByMonitorPointIds_V1_1([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.MonitorPointIds);
var list = _service.GetLastRecord(input.CorpID, ids);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointIds 获取最近一条数据(已进行单位转换,使用的是信号显示单位)
///
[Route("GetLastRecordByMonitorPointIds@V2.0")]
[HttpGet]
public List GetLastRecordByMonitorPointIds_V2_0([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.MonitorPointIds);
var list = _service.GetLastRecord(input.CorpID, ids);
if (list == null || list.Count < 1)
return default;
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(input.CorpID, ids);
var vmList = list.Select(x =>
{
var monitor = monitorList.Find(t => t.ID == x.MonitorPointID);
var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
var vm = new MonitorDayRecordDto(x, signal);
return vm;
}).ToList();
return vmList;
}
///
/// 通过 MonitorPointIds 获取最近一条数据(不需要验证Token)(已进行单位转换,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetLastRecordByMonitorPointIds@V2.1")]
[HttpGet]
public List GetLastRecordByMonitorPointIds_V2_1([FromQuery][Required] MonitorPointIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.MonitorPointIds);
var list = _service.GetLastRecord(input.CorpID, ids);
if (list == null || list.Count < 1)
return default;
var monitorList = new Service.MonitorPoint().GetExSignalWithSignalTypeByIds(input.CorpID, ids);
var vmList = list.Select(x =>
{
var monitor = monitorList.Find(t => t.ID == x.MonitorPointID);
var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
var vm = new MonitorDayRecordDto(x, signal);
return vm;
}).ToList();
return vmList;
}
#endregion
#region 通过 SignalID 获取最近数据
///
/// 通过 SignalID 获取最近一条数据(未进行单位转换,使用的是系统单位)
///
[Route("GetLastRecordBySignalID@V1.0")]
[HttpGet]
public MonitorDayRecordDto GetLastRecordBySignalID_V1_0([FromQuery][Required] SignalIDUnderCorpInput input)
{
var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
if (model == null)
return default;
var vm = new MonitorDayRecordDto(model);
return vm;
}
///
/// 通过 SignalID 获取最近一条数据(不需要验证Token)(未进行单位转换,使用的是系统单位)
///
[AllowAnonymous]
[Route("GetLastRecordBySignalID@V1.1")]
[HttpGet]
public MonitorDayRecordDto GetLastRecordBySignalID_V1_1([FromQuery][Required] SignalIDUnderCorpInput input)
{
var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
if (model == null)
return default;
var vm = new MonitorDayRecordDto(model);
return vm;
}
///
/// 通过 SignalID 获取最近一条数据(已进行单位转换,使用的是信号显示单位)
///
[Route("GetLastRecordBySignalID@V2.0")]
[HttpGet]
public MonitorDayRecordDto GetLastRecordBySignalID_V2_0([FromQuery][Required] SignalIDUnderCorpInput input)
{
var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
if (model == null)
return default;
var signal = new Service.Signal().GetExSignalTypeByID(input.CorpID, input.SignalID);
var vm = new MonitorDayRecordDto(model, signal);
return vm;
}
///
/// 通过 SignalID 获取最近一条数据(不需要验证Token)(已进行单位转换,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetLastRecordBySignalID@V2.1")]
[HttpGet]
public MonitorDayRecordDto GetLastRecordBySignalID_V2_1([FromQuery][Required] SignalIDUnderCorpInput input)
{
var model = _service.GetLastRecord(input.CorpID, input.MonitorPointID, input.SignalID);
if (model == null)
return default;
var signal = new Service.Signal().GetExSignalTypeByID(input.CorpID, input.SignalID);
var vm = new MonitorDayRecordDto(model, signal);
return vm;
}
#endregion
#region 通过 SignalIds 获取最近数据
///
/// 通过 SignalIds 获取最近一条数据(未进行单位转换,使用的是系统单位)
///
[Route("GetLastRecordBySignalIds@V1.0")]
[HttpGet]
public List GetLastRecordBySignalIds_V1_0([FromQuery][Required] SignalIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.SignalIds);
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 SignalIds 获取最近一条数据(不需要验证Token)(未进行单位转换,使用的是系统单位)
///
[AllowAnonymous]
[Route("GetLastRecordBySignalIds@V1.1")]
[HttpGet]
public List GetLastRecordBySignalIds_V1_1([FromQuery][Required] SignalIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.SignalIds);
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 SignalIds 获取最近一条数据(已进行单位转换,使用的是信号显示单位)
///
[Route("GetLastRecordBySignalIds@V2.0")]
[HttpGet]
public List GetLastRecordBySignalIds_V2_0([FromQuery][Required] SignalIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.SignalIds);
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids);
if (list == null || list.Count < 1)
return default;
var signalList = new Service.Signal().GetExSignalTypeBySignalIds(input.CorpID, ids);
var vmList = list.Select(x => new MonitorDayRecordDto(x, signalList?.Find(t => t.ID == x.SignalID))).ToList();
return vmList;
}
///
/// 通过 SignalIds 获取最近一条数据(不需要验证Token)(已进行单位转换,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetLastRecordBySignalIds@V2.1")]
[HttpGet]
public List GetLastRecordBySignalIds_V2_1([FromQuery][Required] SignalIdsUnderCorpInput input)
{
var ids = LongListHelper.ToList(input.SignalIds);
var list = _service.GetLastRecord(input.CorpID, input.MonitorPointID, ids);
if (list == null || list.Count < 1)
return default;
var signalList = new Service.Signal().GetExSignalTypeBySignalIds(input.CorpID, ids);
var vmList = list.Select(x => new MonitorDayRecordDto(x, signalList?.Find(t => t.ID == x.SignalID))).ToList();
return vmList;
}
#endregion
#endregion
#region 通过测点标识获取
#region 获取所有数据
///
/// 通过 MonitorPointID 获取(未进行单位转换,使用的是系统单位)
///
[Route("GetByMonitorPointID@V1.0")]
[HttpGet]
public List GetByMonitorPointID_V1_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetByMonitorPointID(input.CorpID, input.MonitorPointID);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取(不需要验证Token)(未进行单位转换,使用的是系统单位)
///
[AllowAnonymous]
[Route("GetByMonitorPointID@V1.1")]
[HttpGet]
public List GetByMonitorPointID_V1_1([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetByMonitorPointID(input.CorpID, input.MonitorPointID);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取(已进行单位转换,使用的是信号显示单位)
///
[Route("GetByMonitorPointID@V2.0")]
[HttpGet]
public List GetByMonitorPointID_V2_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetByMonitorPointID(input.CorpID, input.MonitorPointID);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
var vmList = list.Select(x => new MonitorDayRecordDto(x, monitor?.SignalList?.Find(t => t.ID == x.SignalID))).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取(不需要验证Token)(已进行单位转换,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetByMonitorPointID@V2.1")]
[HttpGet]
public List GetByMonitorPointID_V2_1([FromQuery][Required] MonitorPointIDUnderCorpInput input)
{
var list = _service.GetByMonitorPointID(input.CorpID, input.MonitorPointID);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
var vmList = list.Select(x => new MonitorDayRecordDto(x, monitor?.SignalList?.Find(t => t.ID == x.SignalID))).ToList();
return vmList;
}
#endregion
#region 获取某天的数据
///
/// 通过 MonitorPointID 获取某天的数据(未进行显示单位转换,使用的是系统默认单位)
///
[Route("GetByMonitorPointIDOfDay@V1.0")]
[HttpGet]
public List GetByMonitorPointIDOfDay_V1_0
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime Day
)
{
var list = _service.GetByMonitorPointIDOfDay(CorpID, MonitorPointID, Day);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取某天的数据(不需要验证Token)(未进行显示单位转换,使用的是系统默认单位)
///
[AllowAnonymous]
[Route("GetByMonitorPointIDOfDay@V1.1")]
[HttpGet]
public List GetByMonitorPointIDOfDay_V1_1
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime Day
)
{
var list = _service.GetByMonitorPointIDOfDay(CorpID, MonitorPointID, Day);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取某天的数据(已进行单位换算,使用的是信号显示单位)
///
[Route("GetByMonitorPointIDOfDay@V2.0")]
[HttpGet]
public List GetByMonitorPointIDOfDay_V2_0
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime Day
)
{
var list = _service.GetByMonitorPointIDOfDay(CorpID, MonitorPointID, Day);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(CorpID, MonitorPointID);
var vmList = list.Select(x =>
{
var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
var vm = new MonitorDayRecordDto(x, signal);
return vm;
}).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取某天的数据(不需要验证Token)(已进行单位换算,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetByMonitorPointIDOfDay@V2.1")]
[HttpGet]
public List GetByMonitorPointIDOfDay_V2_1
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime Day
)
{
var list = _service.GetByMonitorPointIDOfDay(CorpID, MonitorPointID, Day);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(CorpID, MonitorPointID);
var vmList = list.Select(x =>
{
var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
var vm = new MonitorDayRecordDto(x, signal);
return vm;
}).ToList();
return vmList;
}
#endregion
#region 获取日期区间内的数据
///
/// 通过 MonitorPointID 获取日期区间内的数据(未进行显示单位转换,使用的是系统默认单位)
///
[Route("GetByMonitorPointIDOfDayRange@V1.0")]
[HttpGet]
public List GetByMonitorPointIDOfDayRange_V1_0
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime StartDay,
[Required]
DateTime EndDay
)
{
if (StartDay.Date > EndDay.Date)
{
return default;
}
var list = _service.GetByMonitorPointIDOfDayRange(CorpID, MonitorPointID, StartDay, EndDay);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取日期区间内的数据(不需要验证Token)(未进行显示单位转换,使用的是系统默认单位)
///
[AllowAnonymous]
[Route("GetByMonitorPointIDOfDayRange@V1.1")]
[HttpGet]
public List GetByMonitorPointIDOfDayRange_V1_1
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime StartDay,
[Required]
DateTime EndDay
)
{
if (StartDay.Date > EndDay.Date)
{
return default;
}
var list = _service.GetByMonitorPointIDOfDayRange(CorpID, MonitorPointID, StartDay, EndDay);
var vmList = list?.Select(x => new MonitorDayRecordDto(x)).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取日期区间内的数据(已进行单位换算,使用的是信号显示单位)
///
[Route("GetByMonitorPointIDOfDayRange@V2.0")]
[HttpGet]
public List GetByMonitorPointIDOfDayRange_V2_0
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime StartDay,
[Required]
DateTime EndDay
)
{
if (StartDay.Date > EndDay.Date)
{
return default;
}
var list = _service.GetByMonitorPointIDOfDayRange(CorpID, MonitorPointID, StartDay, EndDay);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(CorpID, MonitorPointID);
var vmList = list.Select(x =>
{
var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
var vm = new MonitorDayRecordDto(x, signal);
return vm;
}).ToList();
return vmList;
}
///
/// 通过 MonitorPointID 获取日期区间内的数据(不需要验证Token)(已进行单位换算,使用的是信号显示单位)
///
[AllowAnonymous]
[Route("GetByMonitorPointIDOfDayRange@V2.1")]
[HttpGet]
public List GetByMonitorPointIDOfDayRange_V2_1
(
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
long CorpID,
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
long MonitorPointID,
[Required]
DateTime StartDay,
[Required]
DateTime EndDay
)
{
if (StartDay.Date > EndDay.Date)
{
return default;
}
var list = _service.GetByMonitorPointIDOfDayRange(CorpID, MonitorPointID, StartDay, EndDay);
if (list == null || list.Count < 1)
return default;
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(CorpID, MonitorPointID);
var vmList = list.Select(x =>
{
var signal = monitor.SignalList.Find(t => t.ID == x.SignalID);
var vm = new MonitorDayRecordDto(x, signal);
return vm;
}).ToList();
return vmList;
}
#endregion
#endregion
#region 补录
///
/// 补录一条
///
[Route("InsertSupplement@V1.0")]
[HttpPost]
public bool InsertSupplement([Required] SupplementMonitorDayRecordInput input)
{
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
if (monitor.CronType != Model.Monitor.eCronType.EachDay)
{
return false;
}
var bol = false;
var dataTime = DateTime.Now;
switch (monitor.MonitorType)
{
case Model.eMonitorType.General:
{
var signal = monitor.SignalList?.FirstOrDefault();
if (signal != null)
{
var data_status = new List();
var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, input.SrcTime, input.SrcValue, data_status);
if (!string.IsNullOrEmpty(data_value))
{
var record = new Model.MonitorDayRecordPure();
record.CorpID = input.CorpID;
record.MonitorPointID = input.MonitorPointID;
record.SignalID = signal.ID;
record.RecordType = monitor.MonitorType;
record.SrcTime = input.SrcTime;
record.SrcValue = input.SrcValue;
record.DataTime = dataTime;
record.DataValue = data_value;
record.DataStatus = data_status;
record.DataDay = input.DataDay.Date;
bol = _service.InsertSupplement(record);
}
}
}
break;
case Model.eMonitorType.Vibration:
{
var sub_record_list = AddMonitorSubRecordInput.ToList(input.SrcValue);
if (sub_record_list != null && sub_record_list.Count > 0)
{
var record_list = new List();
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();
var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, input.SrcTime, sub_record.SrcValue, data_status);
if (string.IsNullOrEmpty(data_value))
continue;
var record = new Model.MonitorDayRecordPure();
record.CorpID = input.CorpID;
record.MonitorPointID = input.MonitorPointID;
record.SignalID = signal.ID;
record.RecordType = monitor.MonitorType;
record.SrcTime = input.SrcTime;
record.SrcValue = sub_record.SrcValue;
record.DataTime = dataTime;
record.DataValue = data_value;
record.DataStatus = data_status;
record.DataDay = input.DataDay.Date;
record_list.Add(record);
}
if (record_list.Count > 0)
{
bol = _service.InsertsSupplement(record_list);
}
}
}
break;
default: break;
}
return bol;
}
///
/// 补录多条
///
[Route("InsertsSupplement@V1.0")]
[HttpPost]
public bool InsertsSupplement([Required] List list)
{
var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
if (corpIds.Count > 1)
{
return false;
}
var dataTime = DateTime.Now;
var record_list = new List();
foreach (var item in list)
{
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(item.CorpID, item.MonitorPointID);
if (monitor.CronType != Model.Monitor.eCronType.EachDay)
{
continue;
}
switch (monitor.MonitorType)
{
case Model.eMonitorType.General:
{
var signal = monitor.SignalList?.FirstOrDefault();
if (signal != null)
{
var data_status = new List();
var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, item.SrcTime, item.SrcValue, data_status);
if (!string.IsNullOrEmpty(data_value))
{
var record = new Model.MonitorDayRecordPure();
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 = dataTime;
record.DataValue = data_value;
record.DataStatus = data_status;
record.DataDay = item.DataDay.Date;
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();
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.MonitorDayRecordPure();
record.CorpID = item.CorpID;
record.MonitorPointID = item.MonitorPointID;
record.SignalID = signal.ID;
record.RecordType = monitor.MonitorType;
record.SrcTime = item.SrcTime;
record.SrcValue = sub_record.SrcValue;
record.DataTime = dataTime;
record.DataValue = data_value;
record.DataStatus = data_status;
record.DataDay = item.DataDay.Date;
record_list.Add(record);
}
}
}
break;
default: break;
}
}
if (record_list.Count < 1)
{
return false;
}
var bol = _service.InsertsSupplement(record_list);
return bol;
}
#endregion
}
}