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 Microsoft.AspNetCore.Http;
|
using Furion.DependencyInjection;
|
using Microsoft.AspNetCore.Authorization;
|
using Furion.DataEncryption;
|
using Furion.FriendlyException;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// 生产运营
|
/// </summary>
|
[AllowAnonymous]
|
[Route("LargeScreen/Szjt/Scyy")]
|
[ApiDescriptionSettings("LargeScreen", Name = "苏州金庭(生产运营)", Order = 999)]
|
public class SzjtScyy_Controller : IDynamicApiController, ITransient
|
{
|
private readonly IHttpContextAccessor _httpContextAccessor;
|
|
/// <summary>
|
///
|
/// </summary>
|
public SzjtScyy_Controller(IHttpContextAccessor httpContextAccessor)
|
{
|
_httpContextAccessor = httpContextAccessor;
|
}
|
|
#region const
|
|
private const long _corpid = 3;//客户标识
|
|
private const long _stationId = 23;//泵站标识
|
|
private const long _tlpointid_23 = 1688;//累积流量
|
private const long _tlsignalid_23 = 2388;//累积流量信号
|
|
private const long _lpointid_23 = 1687;//瞬时流量
|
private const long _lsignalid_23 = 2387;//瞬时流量信号
|
|
private const long _zdpointId_23 = 1692;//浊度
|
private const long _zdsignalid_23 = 2392;//浊度信号
|
|
private const long _ylpointid_23 = 1693;//余氯
|
private const long _ylsignalid_23 = 2393;//余氯信号
|
|
private const long _ckylpointid_23 = 1690;//出口压力
|
private const long _ckylsignalid_23 = 2390;//出口压力信号
|
|
|
#endregion
|
|
|
/// <summary>
|
/// 制水生产 (左上部分)
|
/// </summary>
|
[Route("GetLeftTopInfo")]
|
[HttpGet]
|
public SzjtScyyLeftTopInfoDto GetLeftTopInfo()
|
{
|
var info_list = new SzjtScyyLeftTopInfoDto();
|
|
var servive_record = new Service.MonitorRealRecord();
|
|
//昨日累积供水量
|
var tl_yes_firstValue = servive_record.GetFirstBySignalIDOfDay(_corpid,_tlpointid_23,_tlsignalid_23, DateTime.Now.AddDays(-1));
|
var tl_yes_lastVlaue = servive_record.GetLastBySignalIDOfDay(_corpid, _tlpointid_23, _tlsignalid_23, DateTime.Now.AddDays(-1));
|
if (tl_yes_firstValue != null)
|
{
|
if (double.TryParse(tl_yes_firstValue.DataValue, out double tl_yes_first_value))
|
{
|
if (tl_yes_lastVlaue != null)
|
{
|
if (double.TryParse(tl_yes_lastVlaue.DataValue, out double tl_yes_last_value))
|
{
|
info_list.YesterdayTotalSupplyWater = NumberHelper.Round(tl_yes_last_value - tl_yes_first_value, 2);
|
}
|
}
|
}
|
}
|
|
//今日累积供水量
|
var tl_lastValue = servive_record.GetLastRecord(_corpid,_tlpointid_23,_tlsignalid_23);
|
if (tl_lastValue != null)
|
{
|
if (double.TryParse(tl_lastValue.DataValue, out double tl_last_value))
|
{
|
if (tl_yes_lastVlaue != null)
|
{
|
if (double.TryParse(tl_yes_lastVlaue.DataValue, out double tl_yes_last_value))
|
{
|
info_list.TodayTotalSupplyWater = NumberHelper.Round(tl_last_value - tl_yes_last_value, 2);
|
}
|
}
|
}
|
}
|
|
//当前瞬时流量
|
var l_lastValue = servive_record.GetLastRecord(_corpid, _lpointid_23,_lsignalid_23);
|
if (l_lastValue != null)
|
{
|
if (double.TryParse(l_lastValue.DataValue, out double l_last_value))
|
{
|
info_list.CurrentFlow = NumberHelper.Round(l_last_value, 1);
|
}
|
}
|
|
//浊度
|
var zh_lastValue = servive_record.GetLastRecord(_corpid, _zdpointId_23,_zdsignalid_23);
|
if (zh_lastValue != null)
|
{
|
if (double.TryParse(zh_lastValue.DataValue, out double zh_last_value))
|
{
|
info_list.CurrentTurbidity = NumberHelper.Round(zh_last_value, 2);
|
}
|
}
|
|
//余氯
|
var yu_lastValue = servive_record.GetLastRecord(_corpid, _ylpointid_23,_zdsignalid_23);
|
if (yu_lastValue != null)
|
{
|
if (double.TryParse(yu_lastValue.DataValue, out double yl_last_value))
|
{
|
info_list.CurrentResidualChlorine = NumberHelper.Round(yl_last_value, 2);
|
}
|
}
|
|
return info_list;
|
}
|
|
/// <summary>
|
/// 获取当前压力 (左中部分:当前压力)
|
/// </summary>
|
[Route("GetLeftMiddleInfo1")]
|
[HttpGet]
|
public double? GetLeftMiddleInfo1()
|
{
|
var service_record = new Service.MonitorRealRecord();
|
var lastRecord = service_record.GetLastNormalRecord(_corpid, _ckylpointid_23,_ckylsignalid_23);
|
if (lastRecord == null)
|
return default;
|
return NumberHelper.Round(double.Parse(lastRecord.DataValue),3);
|
|
//var r = new Random();
|
//var v = r.Next(2503, 2710) / 1000.0;
|
//return new Result<double>(v);
|
}
|
|
/// <summary>
|
/// 管网压力 (左中部分)
|
/// </summary>
|
[Route("GetLeftMiddleInfo2")]
|
[HttpGet]
|
public SzjtScyyLeftMiddleInfoDto GetLeftMiddleInfo2()
|
{
|
var info = new SzjtScyyLeftMiddleInfoDto();
|
|
var service_record = new Service.MonitorRealRecord();
|
|
//单前压力
|
//var lastValue = service_record.GetLastRecordValue(_ckylpointid_13);
|
//info.Current = lastValue;
|
|
//昨日压力列表
|
var yesterday = service_record.GetBySignalIDOfDay(_corpid, _ckylpointid_23,_ckylsignalid_23, DateTime.Now.AddDays(-1));
|
if (yesterday != null && yesterday.Count > 0)
|
{
|
info.Yesterday = new List<SzjtScyyGeneralRecord>();
|
foreach (var item in yesterday)
|
{
|
var vm = new SzjtScyyGeneralRecord();
|
vm.RecordStatus = 0;
|
vm.RecordTime = item.DataTime;
|
vm.RecordValue = item.DataValue;
|
info.Yesterday.Add(vm);
|
}
|
}
|
|
//今日压力列表
|
var today = service_record.GetBySignalIDOfDay(_corpid, _ckylpointid_23, _ckylsignalid_23, DateTime.Now);
|
if (today != null && today.Count > 0)
|
{
|
info.Today = new List<SzjtScyyGeneralRecord>();
|
foreach (var item in today)
|
{
|
var vm = new SzjtScyyGeneralRecord();
|
vm.RecordStatus = 0;
|
vm.RecordTime = item.DataTime;
|
vm.RecordValue = item.DataValue;
|
info.Today.Add(vm);
|
}
|
}
|
|
return info;
|
|
//var r = new Random();
|
//List<LeftMiddleItemInfo> info_list = new List<LeftMiddleItemInfo>();
|
|
//for (int hour = 0; hour < DateTime.Now.Hour; hour++)
|
//{
|
// LeftMiddleItemInfo item = new LeftMiddleItemInfo();
|
// item.Label = hour.ToString();
|
// item.Yesterday = r.Next(2401, 2705) / 1000.0;
|
// item.Today = r.Next(2402, 2706) / 1000.0;
|
// info_list.Add(item);
|
//}
|
|
// return new Result<List<LeftMiddleItemInfo>>(info_list);
|
}
|
|
/// <summary>
|
/// 泵站分析 (左下部分 )
|
/// </summary>
|
/// <param name="StaticType">汇总类型(1按日 2 按周 3 按月 4 按年)</param>
|
[Route("GetLeftBottomInfo")]
|
[HttpGet]
|
public List<SzjtScyyLeftBottomItemInfoDto> GetLeftBottomInfo(int StaticType)
|
{
|
var info_list = new List<SzjtScyyLeftBottomItemInfoDto>();
|
var service_station = new Service.Station();
|
var service_record = new Service.MonitorRealRecord();
|
|
var station_list = service_station.GetByCorpID(_corpid);
|
|
foreach (var station in station_list)
|
{
|
var item = new SzjtScyyLeftBottomItemInfoDto();
|
item.ID = station.ID;
|
item.Name = station.Name;
|
if (station.ID == _stationId)
|
{
|
item.Flow = NumberHelper.RoundString(double.Parse(service_record.GetLastRecord(_corpid, _lpointid_23, _lsignalid_23).DataValue), 2);
|
item.Press = NumberHelper.RoundString(double.Parse(service_record.GetLastRecord(_corpid, _ckylpointid_23, _ckylsignalid_23).DataValue), 2);
|
item.ResidualChlorine = NumberHelper.RoundString(double.Parse(service_record.GetLastRecord(_corpid, _ylpointid_23, _ylsignalid_23).DataValue), 3);
|
item.Turbidity = NumberHelper.RoundString(double.Parse(service_record.GetLastRecord(_corpid, _zdpointId_23, _zdsignalid_23).DataValue), 3);
|
}
|
info_list.Add(item);
|
}
|
|
//var r = new Random();
|
//List<LeftBottomItemInfo> info_list = new List<LeftBottomItemInfo>();
|
|
//var all_station = new Service.StationBase().GetByCorpID(1);
|
|
//foreach (var station in all_station)
|
//{
|
// LeftBottomItemInfo item = new LeftBottomItemInfo();
|
// item.ID = station.ID;
|
// item.Name = station.Name;
|
// item.Flow = r.Next(2600, 2800) / 100.0;
|
// item.Press = r.Next(211, 225) / 1000.0;
|
// item.WaterQuality = r.Next(210, 225) / 100.0;
|
|
// info_list.Add(item);
|
|
//}
|
return info_list;
|
}
|
|
/// <summary>
|
/// 获取首页报警和信息公告(中间底部)
|
/// </summary>
|
/// <param name="InfoType">信息类型(1信息 2报警)</param>
|
[Route("GetCenterBottomInfo")]
|
[HttpGet]
|
public List<SzjtScyyCenterBottomInfoDto> GetCenterBottomInfo(int InfoType)
|
{
|
var info_list = new List<SzjtScyyCenterBottomInfoDto>();
|
|
if (InfoType == 1)
|
{
|
var service = new Service.RepairRequestForm();
|
var forms = service.GetLastByCorpID(_corpid,8);
|
foreach (var f in forms)
|
{
|
var station_list = new Service.Station().GetByCorpID(_corpid);
|
var product_list = new Service.Product().GetByCorpID(_corpid);
|
var user_list = new Service.User().GetByCorpID(_corpid);
|
if (f.BelongType == ObjectType.Station)
|
{
|
var item1 = new SzjtScyyCenterBottomInfoDto();
|
item1.ID = f.ID;
|
item1.Title = station_list?.Find(t => t.ID == f.BelongID)?.Name;
|
item1.UserName = user_list?.Find(t => t.ID == f.CreateUserID)?.RealName;
|
item1.Content = string.Format("{0} {1}发生:{2}", f.CreateTime.ToString("MM月dd日,HH时"), product_list?.Find(t=>t.ID==f.ProductID)?.Name, f.Question);
|
info_list.Add(item1);
|
}
|
}
|
}
|
else
|
{
|
var service = new Service.MonitorAlarmRecord();
|
var serice_point = new IStation.Service.MonitorPoint();
|
var alarms = service.GetLastByCorpID(_corpid, 8);
|
if (alarms != null&&alarms.Count>0)
|
{
|
var station_list = new Service.Station().GetByCorpID(_corpid);
|
var point_list = new Service.MonitorPoint().GetByCorpID(_corpid);
|
foreach (var alarm in alarms)
|
{
|
var point = point_list?.Find(t=>t.ID==alarm.MonitorPointID);
|
if (point == null)
|
continue;
|
string belong_name = "";
|
if (point.BelongType == IStation.ObjectType.Station)
|
{
|
belong_name = string.Format("{0}的{1}",
|
(from x in station_list where x.ID == point.BelongID select x.Name).FirstOrDefault(),
|
point.Name);
|
}
|
|
var item1 = new SzjtScyyCenterBottomInfoDto();
|
item1.ID = alarm.ID;
|
item1.Title = belong_name;
|
item1.Content = string.Format("{0} {1}的值为:{2},超过设定{3}",
|
alarm.AlarmTime.ToString("MM月dd日,HH时"),
|
point.Name,
|
alarm.DataValue == null ? "" : Math.Round(double.Parse(alarm.DataValue), 4).ToString(),
|
alarm.ThresholdValue);
|
info_list.Add(item1);
|
}
|
}
|
}
|
|
|
return info_list;
|
}
|
|
/// <summary>
|
/// 获取报修(中间底部)
|
/// </summary>
|
/// <param name="ID"> (RequesFormID)</param>
|
[Route("GetRepairRequesFormDetalInfo")]
|
[HttpGet]
|
public SzjtScyyRepairRequesFormDetalInfoDto GetRepairRequesFormDetalInfo(long ID)
|
{
|
|
var service = new Service.RepairRequestForm();
|
var form = service.GetByID(_corpid, ID);
|
if (form == null)
|
{
|
throw new Exception("表单不存在");
|
}
|
var station_list = new Service.Station().GetByCorpID(_corpid);
|
var product_list = new Service.Product().GetByCorpID(_corpid);
|
var user_list=new Service.User().GetByCorpID(_corpid);
|
|
|
var view_model = new SzjtScyyRepairRequesFormDetalInfoDto();
|
view_model.BelongName = (from x in station_list where x.ID == form.BelongID select x.Name).FirstOrDefault();
|
view_model.ReportUserName = (from x in user_list where x.ID == form.CreateUserID select x.RealName).FirstOrDefault();
|
view_model.ObjectName = product_list?.Find(t => t.ID == form.ProductID)?.Name;
|
view_model.ReportTime = form.CreateTime.ToString("yyyy-MM-dd HH:mm:ss") ;
|
view_model.ProblemDescription = form.Question;
|
view_model.FormSource = "小程序";
|
if (form.FormStatus ==Model.Repair.eRequestStatus.Pending)
|
view_model.RequestFormStatus = "待受理";
|
|
if (form.FormStatus == Model.Repair.eRequestStatus.Accepted)
|
view_model.RequestFormStatus = "已受理";
|
|
if (form.FormStatus == Model.Repair.eRequestStatus.Rejected)
|
view_model.RequestFormStatus = "已驳回";
|
|
return view_model;
|
}
|
|
/// <summary>
|
/// 获取报警(中间底部)
|
/// </summary>
|
/// <param name="ID"> (RequesFormID)</param>
|
/// <returns></returns>
|
[Route("GetAlarmDataDetalInfo")]
|
[HttpGet]
|
public SzjtScyyAlarmDetalInfoDto GetAlarmDataDetalInfo(long ID)
|
{
|
var service = new Service.MonitorAlarmRecord();
|
var alarm = service.GetByID(_corpid, ID);
|
if (alarm == null)
|
{
|
throw new Exception("警报不存在");
|
}
|
|
var station_list = new Service.Station().GetByCorpID(_corpid);
|
var point = new Service.MonitorPoint().GetByID(_corpid,alarm.MonitorPointID);
|
|
var view_model = new SzjtScyyAlarmDetalInfoDto();
|
if (point.BelongType == IStation.ObjectType.Station)
|
{
|
view_model.StaionName = (from x in station_list where x.ID == point.BelongID select x.Name).FirstOrDefault();
|
}
|
|
|
view_model.RecordName = point.Name;
|
view_model.AlarmTime = alarm.AlarmTime.ToString("MM月dd日 HH时mm分ss秒");
|
//view_model.RecoveryTime = alarm.RecoveryTime == null?"":((DateTime)alarm.RecoveryTime).ToString("MM月dd日 HH时mm分ss秒");
|
view_model.RecordValue = alarm.DataValue.ToString();
|
view_model.ThresholdValue = alarm.ThresholdValue.ToString();
|
|
|
return view_model;
|
}
|
|
/// <summary>
|
/// 工单数量 (右部上 )
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetRightTopInfo")]
|
[HttpGet]
|
public SzjtScyyRightTopInfoDto GetRightTopInfo()
|
{
|
var start = new DateTime(DateTime.Now.Year,DateTime.Now.Month,1);
|
var taskFormList = new Service.RepairTaskForm().GetFluzzyList(_corpid,null,null,null,null,null,null,null,start,null);
|
var taskFormCount = new Service.RepairTaskForm().GetCountByCorpID(_corpid);
|
var requestPendingCount=new Service.RepairRequestForm().GetPendingCountByCorpID(_corpid);
|
|
var vm = new SzjtScyyRightTopInfoDto();
|
vm.UnProcessingForm = requestPendingCount;
|
if (taskFormList == null || taskFormList.Count < 1)
|
{
|
vm.HistoryTotalForm = taskFormCount;
|
}
|
else
|
{
|
vm.TotalForm = taskFormList.Count;
|
vm.HistoryTotalForm = taskFormCount - vm.TotalForm;
|
vm.ProcessedForm = taskFormList.Where(x => x.Item1.FormStatus == Model.Repair.eTaskStatus.Accepted).Count();
|
vm.ProcessingForm = taskFormList.Where(x => x.Item1.FormStatus > Model.Repair.eTaskStatus.Accepted && x.Item1.FormStatus < Model.Repair.eTaskStatus.Succeed).Count();
|
vm.CheckedForm = taskFormList.Where(x => x.Item1.FormStatus >= Model.Repair.eTaskStatus.Succeed).Count();
|
}
|
|
return vm;
|
|
}
|
|
|
/// <summary>
|
/// 产销差 (右部中)
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetRightCenterInfo")]
|
[HttpGet]
|
public List<SzjtScyyRightCenterInfoDto> GetRightCenterInfo()
|
{
|
var r = new Random();
|
|
List<SzjtScyyRightCenterInfoDto> info_list = new List<SzjtScyyRightCenterInfoDto>();
|
if (DateTime.Now.Month < 2)
|
{
|
for (int month = 1; month <= 12; month++)
|
{
|
SzjtScyyRightCenterInfoDto m = new SzjtScyyRightCenterInfoDto();
|
}
|
}
|
else
|
{
|
for (int month = 1; month <= DateTime.Now.Month; month++)
|
{
|
SzjtScyyRightCenterInfoDto m = new SzjtScyyRightCenterInfoDto();
|
m.Label = month.ToString();
|
m.ThisSupplyWater = r.Next(2000, 3000);
|
m.LastSupplyWater = r.Next(2000, 3000);
|
m.ThisSaleWater = r.Next(1800, 2500);
|
m.LastSaleWater = r.Next(1800, 2500);
|
if (m.ThisSupplyWater < m.ThisSaleWater)
|
{
|
double temp = m.ThisSaleWater;
|
m.ThisSaleWater = m.ThisSupplyWater;
|
m.ThisSupplyWater = temp;
|
}
|
if (m.LastSupplyWater < m.LastSaleWater)
|
{
|
double temp = m.LastSaleWater;
|
m.LastSaleWater = m.LastSupplyWater;
|
m.LastSupplyWater = temp;
|
}
|
m.ThisDistributionLosses = Math.Round(m.ThisSupplyWater * 100 / m.ThisSaleWater, 1);
|
m.LastDistributionLosses = Math.Round(m.LastSupplyWater * 100 / m.LastSaleWater, 1);
|
info_list.Add(m);
|
}
|
}
|
|
|
return info_list;
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
}
|
