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
|
{
|
/// <summary>
|
/// MonitorMonthRecord
|
/// </summary>
|
[Route("Run/MonitorMonthRecord/Mgr")]
|
[ApiDescriptionSettings("Run", Name = "监测月记录(管理)", Order = 950)]
|
public class MonitorMonthRecord_MgrController : IDynamicApiController
|
{
|
//服务
|
private readonly Service.MonitorMonthRecord _service = new Service.MonitorMonthRecord();
|
|
#region 通过 MonitorPointID 获取
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取(未进行单位转换，使用的是系统单位)
|
/// </summary>
|
[Route("GetByMonitorPointID@V1.0")]
|
[HttpGet]
|
public List<MonitorMonthRecordMgrDto> GetByMonitorPointID_V1_0([FromQuery][Required] MonitorPointIDUnderCorpInput input)
|
{
|
var list = _service.GetByMonitorPointID(input.CorpID, input.MonitorPointID);
|
var vmList = list?.Select(x => new MonitorMonthRecordMgrDto(x)).ToList();
|
return vmList;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取某年的数据(未进行单位转换，使用的是系统单位)
|
/// </summary>
|
[Route("GetByMonitorPointIDOfYear@V1.0")]
|
[HttpGet]
|
public List<MonitorMonthRecordMgrDto> GetByMonitorPointIDOfYear_V1_0
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
|
long MonitorPointID,
|
[Required]
|
int Year
|
)
|
{
|
var list = _service.GetByMonitorPointIDOfYear(CorpID, MonitorPointID, Year);
|
var vmList = list?.Select(x => new MonitorMonthRecordMgrDto(x)).ToList();
|
return vmList;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取某月的数据(未进行单位转换，使用的是系统单位)
|
/// </summary>
|
[Route("GetByMonitorPointIDOfMonth@V1.0")]
|
[HttpGet]
|
public List<MonitorMonthRecordMgrDto> GetByMonitorPointIDOfMonth_V1_0
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
|
long MonitorPointID,
|
[Required]
|
int Year,
|
[Required, Range(1, 12, ErrorMessage = "Month 必须介于1-12之间")]
|
int Month
|
)
|
{
|
var list = _service.GetByMonitorPointIDOfMonth(CorpID, MonitorPointID, Year, Month);
|
var vmList = list?.Select(x => new MonitorMonthRecordMgrDto(x)).ToList();
|
return vmList;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取年区间内的数据(未进行单位转换，使用的是系统单位)
|
/// </summary>
|
[Route("GetByMonitorPointIDOfYearRange@V1.0")]
|
[HttpGet]
|
public List<MonitorMonthRecordMgrDto> GetByMonitorPointIDOfYearRange_V1_0
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
|
long MonitorPointID,
|
[Required]
|
int StartYear,
|
[Required]
|
int EndYear
|
)
|
{
|
|
var list = _service.GetByMonitorPointIDOfYearRange(CorpID, MonitorPointID, StartYear, EndYear);
|
var vmList = list?.Select(x => new MonitorMonthRecordMgrDto(x)).ToList();
|
return vmList;
|
}
|
|
/// <summary>
|
/// 通过 MonitorPointID 获取月区间内的数据(未进行单位转换，使用的是系统单位)
|
/// </summary>
|
[Route("GetByMonitorPointIDOfMonthRange@V1.0")]
|
[HttpGet]
|
public List<MonitorMonthRecordMgrDto> GetByMonitorPointIDOfMonthRange_V1_0
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "MonitorPointID 必须大于0")]
|
long MonitorPointID,
|
[Required]
|
int StartYear,
|
[Required, Range(1, 12, ErrorMessage = "StartMonth 必须介于1-12之间")]
|
int StartMonth,
|
[Required]
|
int EndYear,
|
[Required, Range(1, 12, ErrorMessage = "EndMonth 必须介于1-12之间")]
|
int EndMonth
|
)
|
{
|
var list = _service.GetByMonitorPointIDOfMonthRange(CorpID, MonitorPointID, StartYear, StartMonth, EndYear, EndMonth);
|
var vmList = list?.Select(x => new MonitorMonthRecordMgrDto(x)).ToList();
|
return vmList;
|
}
|
|
#endregion
|
|
#region 更新
|
|
/// <summary>
|
/// 更新
|
/// </summary>
|
[Route("Update@V1.0")]
|
[HttpPut]
|
public bool Update([Required] UpdateMonitorMonthRecordInput input)
|
{
|
var model = new Model.MonitorMonthRecord()
|
{
|
ID = input.ID,
|
CorpID = input.CorpID,
|
MonitorPointID = input.MonitorPointID,
|
SignalID = input.SignalID,
|
RecordType = input.RecordType,
|
DataYear= input.DataYear,
|
DataMonth= input.DataMonth,
|
SrcTime = input.SrcTime,
|
SrcValue = input.SrcValue,
|
DataTime = input.DataTime,
|
DataValue = input.DataValue,
|
DataStatus = input.DataStatus
|
};
|
var bol = _service.Update(model);
|
return bol;
|
}
|
|
/// <summary>
|
/// 批量更新
|
/// </summary>
|
[Route("Updates@V1.0")]
|
[HttpPut]
|
public bool Updates([Required] List<UpdateMonitorMonthRecordInput> list)
|
{
|
if (list == null || list.Count < 1)
|
return default;
|
var modelList = list.Select(x => new Model.MonitorMonthRecord()
|
{
|
ID = x.ID,
|
CorpID = x.CorpID,
|
MonitorPointID = x.MonitorPointID,
|
SignalID = x.SignalID,
|
RecordType = x.RecordType,
|
DataYear = x.DataYear,
|
DataMonth = x.DataMonth,
|
SrcTime = x.SrcTime,
|
SrcValue = x.SrcValue,
|
DataTime = x.DataTime,
|
DataValue = x.DataValue,
|
DataStatus = x.DataStatus
|
}).ToList();
|
var bol = _service.Updates(modelList);
|
return bol;
|
}
|
|
#endregion
|
|
#region 补录
|
|
/// <summary>
|
/// 补录一条（已弃用，请选用管理下相关接口）
|
/// </summary>
|
[Route("InsertSupplement@V1.0")]
|
[HttpPost]
|
public bool InsertSupplement([Required] SupplementMonitorMonthRecordInput input)
|
{
|
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
|
if (monitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
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<string>();
|
var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, input.SrcTime, input.SrcValue, data_status);
|
if (!string.IsNullOrEmpty(data_value))
|
{
|
var record = new Model.MonitorMonthRecordPure();
|
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.DataYear = input.DataYear;
|
record.DataMonth = input.DataMonth;
|
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<Model.MonitorMonthRecordPure>();
|
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, input.SrcTime, sub_record.SrcValue, data_status);
|
if (string.IsNullOrEmpty(data_value))
|
continue;
|
var record = new Model.MonitorMonthRecordPure();
|
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.DataYear = input.DataYear;
|
record.DataMonth = input.DataMonth;
|
record_list.Add(record);
|
}
|
if (record_list.Count > 0)
|
{
|
bol = _service.InsertsSupplement(record_list);
|
}
|
}
|
}
|
break;
|
default: break;
|
}
|
|
return bol;
|
}
|
|
/// <summary>
|
/// 补录多条（已弃用，请选用管理下相关接口）
|
/// </summary>
|
[Route("InsertsSupplement@V1.0")]
|
[HttpPost]
|
public bool InsertsSupplement([Required] List<SupplementMonitorMonthRecordInput> 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<Model.MonitorMonthRecordPure>();
|
foreach (var item in list)
|
{
|
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(item.CorpID, item.MonitorPointID);
|
if (monitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
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.MonitorMonthRecordPure();
|
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.DataYear = item.DataYear;
|
record.DataMonth = item.DataMonth;
|
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.MonitorMonthRecordPure();
|
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.DataYear = item.DataYear;
|
record.DataMonth = item.DataMonth;
|
record_list.Add(record);
|
}
|
}
|
}
|
break;
|
default: break;
|
}
|
}
|
|
if (record_list.Count < 1)
|
{
|
return false;
|
}
|
var bol = _service.InsertsSupplement(record_list);
|
return bol;
|
}
|
|
#endregion
|
|
#region 重录
|
|
/// <summary>
|
/// 重录一条(重录会删除已存在的记录)
|
/// </summary>
|
[Route("InsertAgain@V1.0")]
|
[HttpPost]
|
public bool InsertAgain([Required] AgainMonitorMonthRecordInput input)
|
{
|
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(input.CorpID, input.MonitorPointID);
|
if (monitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
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<string>();
|
var data_value = MonitorHandleHelper.Handle(monitor, signal, lastRecord: null, input.SrcTime, input.SrcValue, data_status);
|
if (!string.IsNullOrEmpty(data_value))
|
{
|
var record = new Model.MonitorMonthRecordPure();
|
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.DataYear = input.DataYear;
|
record.DataMonth = input.DataMonth;
|
bol = _service.InsertAgain(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<Model.MonitorMonthRecordPure>();
|
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, input.SrcTime, sub_record.SrcValue, data_status);
|
if (string.IsNullOrEmpty(data_value))
|
continue;
|
var record = new Model.MonitorMonthRecordPure();
|
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.DataYear = input.DataYear;
|
record.DataMonth = input.DataMonth;
|
record_list.Add(record);
|
}
|
if (record_list.Count > 0)
|
{
|
bol = _service.InsertsAgain(record_list);
|
}
|
}
|
}
|
break;
|
default: break;
|
}
|
|
return bol;
|
}
|
|
/// <summary>
|
/// 重录多条(重录会删除已存在的记录)
|
/// </summary>
|
[Route("InsertsAgain@V1.0")]
|
[HttpPost]
|
public bool InsertsAgain([Required] List<AgainMonitorMonthRecordInput> 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<Model.MonitorMonthRecordPure>();
|
foreach (var item in list)
|
{
|
var monitor = new Service.MonitorPoint().GetExSignalWithSignalTypeByID(item.CorpID, item.MonitorPointID);
|
if (monitor.CronType != Model.Monitor.eCronType.EachMonth)
|
{
|
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.MonitorMonthRecordPure();
|
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.DataYear = item.DataYear;
|
record.DataMonth = item.DataMonth;
|
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.MonitorMonthRecordPure();
|
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.DataYear = item.DataYear;
|
record.DataMonth = item.DataMonth;
|
record_list.Add(record);
|
}
|
}
|
}
|
break;
|
default: break;
|
}
|
}
|
|
if (record_list.Count < 1)
|
{
|
return false;
|
}
|
var bol = _service.InsertsAgain(record_list);
|
return bol;
|
}
|
|
#endregion
|
|
}
|
}
|
