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.Authorization;
|
using IStation.Calculation;
|
using IStation.Calculation.PlanAna;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
/// ShysPlanAna
|
/// </summary>
|
[Route("OpenApi/PlanAna/SHYS")]
|
[ApiDescriptionSettings("OpenApi", Name = "上海原水计划分析", Order = 1000)]
|
public class PlanAna_ShysController : IDynamicApiController
|
{
|
private const long _corpId = 4;
|
|
/// <summary>
|
/// 计算
|
/// </summary>
|
[AllowAnonymous]
|
[NonUnify]
|
[Route("Calculate")]
|
[HttpPost]
|
public List<PlanAnaDto> Calculate([Required] List<PlanAnaInput> inputList)
|
{
|
if (inputList == null || inputList.Count < 1)
|
{
|
LogHelper.Error("上海原水能耗计划分析计算接口入参为空");
|
return default;
|
}
|
//debug
|
LogHelper.Debug(JsonHelper.Object2Json(inputList));
|
|
var url_sg = Settings.WebApi.OpenApi.SanGaoPlanUrl;
|
var responseText = HttpRequestHelper.Post(url_sg, JsonHelper.Object2Json(inputList));
|
//debug
|
LogHelper.Debug(responseText);
|
|
var planDataList = JsonHelper.Json2Object<List<PlanAnaData>>(responseText);
|
if (planDataList == null||planDataList.Count<1)
|
{
|
LogHelper.Error("上海原水能耗计划分析计算三高返回接口出参为空");
|
return default;
|
}
|
if (planDataList.Exists(x => x.datas == null || x.datas.Count < 1))
|
{
|
LogHelper.Error("上海原水能耗计划分析计算三高返回接口出参格式错误");
|
return default;
|
}
|
|
var factoryIds = planDataList.SelectMany(x=>x.datas).Select(x => x.factory).Distinct().ToList();
|
var vmList = new List<PlanAnaDto>();
|
foreach (var factoryId in factoryIds)
|
{
|
//构造计算入参
|
var sumRecordList = new List<MonthSumRecord>();
|
foreach (var planData in planDataList)
|
{
|
var sumRecord = new MonthSumRecord();
|
sumRecord.Month = planData.timeflag;
|
sumRecord.HourRecords = new List<HourSumRecord>();
|
var factoryData = planData.datas.Find(t=>t.factory==factoryId);
|
for (int i = 0; i <= 23; i++)
|
{
|
var hourSumRecord = new HourSumRecord();
|
hourSumRecord.Hour = i;
|
hourSumRecord.Records = new List<Calculation.PlanAna.MonitorRecord>();
|
if (factoryData.scada != null && factoryData.scada.Count > 0)
|
{
|
foreach (var scadaItem in factoryData.scada)
|
{
|
var scadaRecord = new Calculation.PlanAna.MonitorRecord();
|
scadaRecord.MonitorId = PlanAnaConstant.MonitorDict[scadaItem.tagname];
|
scadaRecord.RecordValue = scadaItem.values.Find(t => t.datetime.Trim() == PlanAnaConstant.HourDict[i]).value;
|
hourSumRecord.Records.Add(scadaRecord);
|
}
|
}
|
if (factoryData.result != null && factoryData.result.Count > 0)
|
{
|
foreach (var resultItem in factoryData.result)
|
{
|
var resultRecord = new Calculation.PlanAna.MonitorRecord();
|
resultRecord.MonitorId = PlanAnaConstant.MonitorDict[resultItem.tagname];
|
resultRecord.RecordValue = resultItem.values.Find(t => t.datetime.Trim() == PlanAnaConstant.HourDict[i]).value;
|
hourSumRecord.Records.Add(resultRecord);
|
}
|
}
|
sumRecord.HourRecords.Add(hourSumRecord);
|
}
|
sumRecordList.Add(sumRecord);
|
}
|
|
//找到相关泵站，并进行计算
|
var stationId = PlanAnaConstant.FactoryDict[factoryId];
|
var station = new Service.Station().GetByID(_corpId, stationId);
|
var calculator = PlanAnaCalculatorFactory.CreateCalculator(_corpId, ObjectType.Station, stationId);
|
var resultList = calculator.Calculate(sumRecordList);
|
if (resultList == null || resultList.Count < 1)
|
{
|
LogHelper.Error($"上海原水能耗计划分析计算中，泵站名称:{station.Name} 泵站id:{stationId},计算错误");
|
continue;
|
}
|
|
//生成返回结果
|
var vmItem = new PlanAnaDto();
|
vmItem.factory = factoryId;
|
vmItem.name = station.Name;
|
vmItem.values = new List<List<double>>();
|
for (int i = 1; i <= 12; i++)
|
{
|
var result = resultList.Find(t => t.Month == i);
|
if (result == null)
|
{
|
vmItem.values.Add(new List<double>() { 0, 0, 0 });
|
}
|
else
|
{
|
vmItem.values.Add(new List<double>() {result.Qt,result.Dt,result.WP});
|
}
|
}
|
vmList.Add(vmItem);
|
}
|
return vmList;
|
}
|
|
/// <summary>
|
/// 计算-调试
|
/// </summary>
|
[AllowAnonymous]
|
[NonUnify]
|
[Route("Calculate@Debug")]
|
[HttpPost]
|
public List<PlanAnaDto> Calculate_debug()
|
{
|
var responseText = System.IO.File.ReadAllText(@"D:\result.txt");//(测试用的)
|
var planDataList = JsonHelper.Json2Object<List<PlanAnaData>>(responseText);
|
|
var factoryIds = planDataList.SelectMany(x => x.datas).Select(x => x.factory).Distinct().ToList();
|
var vmList = new List<PlanAnaDto>();
|
foreach (var factoryId in factoryIds)
|
{
|
//构造计算入参
|
var sumRecordList = new List<MonthSumRecord>();
|
foreach (var planData in planDataList)
|
{
|
var sumRecord = new MonthSumRecord();
|
sumRecord.Month = planData.timeflag;
|
sumRecord.HourRecords = new List<HourSumRecord>();
|
var factoryData = planData.datas.Find(t => t.factory == factoryId);
|
for (int i = 0; i <= 23; i++)
|
{
|
var hourSumRecord = new HourSumRecord();
|
hourSumRecord.Hour = i;
|
hourSumRecord.Records = new List<Calculation.PlanAna.MonitorRecord>();
|
if (factoryData.scada != null && factoryData.scada.Count > 0)
|
{
|
foreach (var scadaItem in factoryData.scada)
|
{
|
var scadaRecord = new Calculation.PlanAna.MonitorRecord();
|
scadaRecord.MonitorId = PlanAnaConstant.MonitorDict[scadaItem.tagname];
|
scadaRecord.RecordValue = scadaItem.values.Find(t => t.datetime.Trim() == PlanAnaConstant.HourDict[i]).value;
|
hourSumRecord.Records.Add(scadaRecord);
|
}
|
}
|
if (factoryData.result != null && factoryData.result.Count > 0)
|
{
|
foreach (var resultItem in factoryData.result)
|
{
|
var resultRecord = new Calculation.PlanAna.MonitorRecord();
|
resultRecord.MonitorId = PlanAnaConstant.MonitorDict[resultItem.tagname];
|
resultRecord.RecordValue = resultItem.values.Find(t => t.datetime.Trim() == PlanAnaConstant.HourDict[i]).value;
|
hourSumRecord.Records.Add(resultRecord);
|
}
|
}
|
sumRecord.HourRecords.Add(hourSumRecord);
|
}
|
sumRecordList.Add(sumRecord);
|
}
|
|
//找到相关泵站，并进行计算
|
var stationId = PlanAnaConstant.FactoryDict[factoryId];
|
var station = new Service.Station().GetByID(_corpId, stationId);
|
var calculator = PlanAnaCalculatorFactory.CreateCalculator(_corpId, ObjectType.Station, stationId);
|
var resultList = calculator.Calculate(sumRecordList);
|
if (resultList == null || resultList.Count < 1)
|
{
|
LogHelper.Error($"上海原水能耗计划分析计算中，泵站名称:{station.Name} 泵站id:{stationId},计算错误");
|
continue;
|
}
|
|
//生成返回结果
|
var vmItem = new PlanAnaDto();
|
vmItem.factory = factoryId;
|
vmItem.name = station.Name;
|
vmItem.values = new List<List<double>>();
|
for (int i = 1; i <= 12; i++)
|
{
|
var result = resultList.Find(t => t.Month == i);
|
if (result == null)
|
{
|
vmItem.values.Add(new List<double>() { 0, 0, 0 });
|
}
|
else
|
{
|
vmItem.values.Add(new List<double>() { result.Qt, result.Dt, result.WP });
|
}
|
}
|
vmList.Add(vmItem);
|
}
|
return vmList;
|
}
|
|
|
|
|
|
|
|
|
|
|
}
|
}
|
