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; namespace IStation.Application { /// /// RunSpan /// [Route("Run/RunSpan/Mobile")] [ApiDescriptionSettings("Run", Name = "运行区间", Order = 799)] public class RunSpan_MobileController : IDynamicApiController { /// /// 通过 StationID 获取某天的运行区间信息(手机) /// [Route("GetByStationIDOfDay@V1.0")] [HttpGet] public List GetByStationIDOfDay ( [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, ObjectType.Station, StationID, Model.eMonitorType.General, Model.Monitor.eCronType.Real); var vm_list = new List(); foreach (var group in group_list) { var vm_item = new MonitorRunSpanItemMobileDto(); vm_item.Name = group.Name; vm_item.Spans = new List(); vm_list.Add(vm_item); var monitor_run_list = monitor_list?.Where(x =>x.GroupID==group.ID && x.SignalList.First().SignalType.Identifier == 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 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 MonitorRunSpanMobileDto(); vm_span.RunStatus = 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 = Math.Round((end_time - Day.Date).TotalSeconds,1); 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 MonitorRunSpanMobileDto(); 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 = Math.Round((end_time - vm_span.StartTime).TotalSeconds,1); } else { vm_span.EndTime = record.DataTime; var vm_span_next = new MonitorRunSpanMobileDto(); 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 +=Math.Round( (end_time - record.DataTime).TotalSeconds,1); vm_item.Spans.Add(vm_span_next); } } vm_item.RumTime = Math.Round(vm_item.Spans.Where(x => x.RunStatus == RunStatus.Run).Sum(x => x.Duration),1); } return vm_list; } } }