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;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// RunSpan
|
/// </summary>
|
[Route("Run/RunSpan")]
|
[ApiDescriptionSettings("Run", Name = "运行区间", Order = 800)]
|
public class RunSpan_Controller : IDynamicApiController
|
{
|
|
/// <summary>
|
/// 通过日期获取泵站下运行区间信息
|
/// </summary>
|
[Route("GetItemsByStationIDOfDay@V1.0")]
|
[HttpGet]
|
public List<MonitorRunSpanItem> GetItemsByStationIDOfDay
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "StationID 必须大于0")]
|
long StationID,
|
[Required]
|
DateTime Day
|
)
|
{
|
var station = new Service.Station().GetByID(CorpID, StationID);
|
if (station == null)
|
{
|
return default;
|
}
|
|
var group_list = new Service.MonitorPointGroup().GetByBelongTypeAndBelongID(CorpID, IStation.ObjectType.Station, StationID);
|
if (group_list == null || group_list.Count < 1)
|
{
|
return default;
|
}
|
group_list = group_list.Where(x => x.Flags != null && x.Flags.Contains(LogicFlags.机泵))
|
.OrderBy(x => x.ParentIds == null ? 0 : x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
|
if (group_list == null || group_list.Count < 1)
|
{
|
return default;
|
}
|
|
var monitor_list = new Service.MonitorPoint()
|
.GetExSignalWithSignalTypeByBelongTypeAndBelongID
|
(CorpID, IStation.ObjectType.Station, StationID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
|
var vm_list = new List<MonitorRunSpanItem>();
|
foreach (var group in group_list)
|
{
|
var vm_item = new MonitorRunSpanItem();
|
vm_item.CorpID = group.CorpID;
|
vm_item.ObjectType = IStation.ObjectType.MonitorPointGroup;
|
vm_item.ObjectID = group.ID;
|
vm_item.ObjectName = group.Name;
|
vm_item.Spans = new List<MonitorRunSpan>();
|
vm_list.Add(vm_item);
|
|
var monitor_run_list = monitor_list?.Where(x =>x.GroupID==group.ID&& x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
|
var monitor_run_default = monitor_run_list?.Find(x => x.Flags != null && x.Flags.Contains(LogicFlags.默认));
|
if (monitor_run_default == null)
|
monitor_run_default = monitor_run_list?.FirstOrDefault();
|
|
List<Model.MonitorRealRecordContent> record_list = null;
|
if (monitor_run_default != null)
|
{
|
record_list = new Service.MonitorRealRecord()
|
.GetContentBySignalIDOfDay(monitor_run_default.CorpID, monitor_run_default.ID, monitor_run_default.SignalList.First().ID, Day);
|
}
|
|
if (record_list == null || record_list.Count < 1)
|
{
|
var vm_span = new MonitorRunSpan();
|
vm_span.RunStatus = IStation.RunStatus.Shut;
|
vm_span.StartTime = Day.Date;
|
var end_time = Day.Date.AddDays(1);
|
if (end_time > DateTime.Now)
|
end_time = DateTime.Now;
|
vm_span.EndTime = end_time;
|
vm_span.Duration = (end_time - Day.Date).TotalSeconds;
|
vm_item.Spans.Add(vm_span);
|
continue;
|
}
|
|
foreach (var record in record_list)
|
{
|
var run_status = 0;
|
if (double.TryParse(record.DataValue, out double data_value))
|
{
|
run_status = data_value > 0 ? 1 : 0;
|
}
|
var vm_span = vm_item.Spans.LastOrDefault();
|
if (vm_span == null)
|
{
|
vm_span = new MonitorRunSpan();
|
vm_span.RunStatus = run_status;
|
vm_span.StartTime = record.DataTime;
|
vm_item.Spans.Add(vm_span);
|
}
|
if (run_status == vm_span.RunStatus)
|
{
|
var end_time = record.DataTime;
|
if (end_time > Day.Date.AddDays(1))
|
end_time = Day.Date.AddDays(1);
|
vm_span.EndTime = end_time;
|
vm_span.Duration = (end_time - vm_span.StartTime).TotalSeconds;
|
}
|
else
|
{
|
vm_span.EndTime = record.DataTime;
|
var vm_span_next = new MonitorRunSpan();
|
vm_span_next.RunStatus = run_status;
|
vm_span_next.StartTime = record.DataTime;
|
var end_time = record.DataTime;
|
if (end_time > Day.Date.AddDays(1))
|
end_time = Day.Date.AddDays(1);
|
vm_span_next.EndTime = end_time;
|
vm_span_next.Duration += (end_time - record.DataTime).TotalSeconds;
|
vm_item.Spans.Add(vm_span_next);
|
}
|
}
|
}
|
|
return vm_list;
|
}
|
|
/// <summary>
|
/// 通过日期获取泵站下运行区间Kpi信息
|
/// </summary>
|
[Route("GetKpiInfoByStationIDOfDay")]
|
[HttpGet]
|
public MonitorRunSpanKpiInfo GetKpiInfoByStationIDOfDay
|
(
|
[Required, Range(1, long.MaxValue, ErrorMessage = "CorpID 必须大于0")]
|
long CorpID,
|
[Required, Range(1, long.MaxValue, ErrorMessage = "StationID 必须大于0")]
|
long StationID,
|
[Required]
|
DateTime Day,
|
int KpiCount = 2
|
)
|
{
|
var station = new Service.Station().GetByID(CorpID, StationID);
|
if (station == null)
|
{
|
return default;
|
}
|
|
var group_list = new Service.MonitorPointGroup().GetByBelongTypeAndBelongID(CorpID, IStation.ObjectType.Station, StationID);
|
group_list = group_list?.Where(x => x.Flags != null && x.Flags.Contains(LogicFlags.机泵))
|
.OrderBy(x => x.ParentIds == null ? 0 : x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
|
var monitor_list = new Service.MonitorPoint()
|
.GetExSignalWithSignalTypeByBelongTypeAndBelongID
|
(CorpID, IStation.ObjectType.Station, StationID, Model.eMonitorType.General, Model.Monitor.eCronType.Real);
|
|
var service_record = new Service.MonitorRealRecord();
|
|
var vm = new MonitorRunSpanKpiInfo();
|
vm.CorpID = station.CorpID;
|
vm.ObjectType = IStation.ObjectType.Station;
|
vm.ObjectID = station.ID;
|
vm.ObjectName = station.Name;
|
vm.KpiItems = new List<MonitorKpiRecordListItem>();
|
vm.SpanItems = new List<MonitorRunSpanItem>();
|
|
var monitor_kpi_list = monitor_list?.Where(x => x.Flags != null && x.Flags.Contains(LogicFlags.KPI))
|
.OrderBy(x => x.ImportanceIndex == null ? int.MaxValue : x.ImportanceIndex.Value).ToList();
|
if (monitor_kpi_list != null)
|
{
|
var take_count = monitor_kpi_list.Count > KpiCount ? KpiCount : monitor_kpi_list.Count;
|
monitor_kpi_list = monitor_kpi_list.Take(take_count).ToList();
|
|
foreach (var monitor_kpi in monitor_kpi_list)
|
{
|
var vm_item = new MonitorKpiRecordListItem();
|
vm_item.CorpID = monitor_kpi.CorpID;
|
vm_item.MonitorPointID = monitor_kpi.ID;
|
vm_item.SignalID = monitor_kpi.SignalList.First().ID;
|
vm_item.Name = monitor_kpi.Name;
|
vm_item.Unit = monitor_kpi.SignalList.First().SignalType.GetEnUnitName();
|
vm_item.Records = service_record.GetContentBySignalIDOfDay(monitor_kpi.CorpID, monitor_kpi.ID, monitor_kpi.SignalList.First().ID, Day)
|
?.Select(x => new MonitorKpiRecordContent(x)).ToList();
|
vm.KpiItems.Add(vm_item);
|
}
|
}
|
|
if (group_list != null && group_list.Count > 0)
|
{
|
foreach (var group in group_list)
|
{
|
var vm_item = new MonitorRunSpanItem();
|
vm_item.CorpID = group.CorpID;
|
vm_item.ObjectType = IStation.ObjectType.MonitorPointGroup;
|
vm_item.ObjectID = group.ID;
|
vm_item.ObjectName = group.Name;
|
vm_item.Spans = new List<MonitorRunSpan>();
|
vm.SpanItems.Add(vm_item);
|
|
var monitor_run_list = monitor_list?.Where(x =>x.GroupID==group.ID && x.SignalList.First().SignalType.Identifier == IStation.SignalType.运行状态).ToList();
|
var monitor_run_default = monitor_run_list?.Find(x => x.Flags != null && x.Flags.Contains(LogicFlags.默认));
|
if (monitor_run_default == null)
|
monitor_run_default = monitor_run_list?.FirstOrDefault();
|
|
List<Model.MonitorRealRecordContent> record_list = null;
|
if (monitor_run_default != null)
|
{
|
record_list = service_record.GetContentBySignalIDOfDay(monitor_run_default.CorpID, monitor_run_default.ID, monitor_run_default.SignalList.First().ID, Day);
|
}
|
|
if (record_list == null || record_list.Count < 1)
|
{
|
var vm_span = new MonitorRunSpan();
|
vm_span.RunStatus = IStation.RunStatus.Shut;
|
vm_span.StartTime = Day.Date;
|
var end_time = Day.Date.AddDays(1);
|
if (end_time > DateTime.Now)
|
end_time = DateTime.Now;
|
vm_span.EndTime = end_time;
|
vm_span.Duration = (end_time - Day.Date).TotalSeconds;
|
vm_item.Spans.Add(vm_span);
|
continue;
|
}
|
|
foreach (var record in record_list)
|
{
|
var run_status = 0;
|
if (double.TryParse(record.DataValue, out double data_value))
|
{
|
run_status = data_value > 0 ? 1 : 0;
|
}
|
var vm_span = vm_item.Spans.LastOrDefault();
|
if (vm_span == null)
|
{
|
vm_span = new MonitorRunSpan();
|
vm_span.RunStatus = run_status;
|
vm_span.StartTime = record.DataTime;
|
vm_item.Spans.Add(vm_span);
|
}
|
if (run_status == vm_span.RunStatus)
|
{
|
var end_time = record.DataTime;
|
if (end_time > Day.Date.AddDays(1))
|
end_time = Day.Date.AddDays(1);
|
vm_span.EndTime = end_time;
|
vm_span.Duration = (end_time - vm_span.StartTime).TotalSeconds;
|
}
|
else
|
{
|
vm_span.EndTime = record.DataTime;
|
var vm_span_next = new MonitorRunSpan();
|
vm_span_next.RunStatus = run_status;
|
vm_span_next.StartTime = record.DataTime;
|
var end_time = record.DataTime;
|
if (end_time > Day.Date.AddDays(1))
|
end_time = Day.Date.AddDays(1);
|
vm_span_next.EndTime = end_time;
|
vm_span_next.Duration += (end_time - record.DataTime).TotalSeconds;
|
vm_item.Spans.Add(vm_span_next);
|
}
|
}
|
}
|
}
|
|
return vm;
|
}
|
|
|
|
|
|
}
|
}
|
