using IStation.Model;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.DataDockingApi
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class HandleHelper : IDataDockingApi.IHandleHelper
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public void HandleData(List<DataDockingConfigure.Mapper> mappers, Action<List<Model.MonitorDataDockingReceiveRecord>> receive)
|
{
|
if (mappers == null || mappers.Count < 1)
|
return;
|
var appParas = AppParasHelper.Get();
|
if (appParas == null)
|
{
|
LogHelper.Error("苏州金庭仪表 Api 数据对接中，缺少对接配置文件");
|
}
|
string token = null;
|
token = TokenHelper.Get();
|
if (string.IsNullOrEmpty(token))
|
{
|
LogHelper.Error("苏州金庭仪表 Api 数据对接中，获取Token失败");
|
return;
|
}
|
|
var url_history = appParas.url.history;
|
url_history = $"{url_history}?pageNumber=1&startTime={DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd")}&endTime={DateTime.Now.AddDays(1).ToString("yyyy-MM-dd")}";
|
|
var result_history = HttpRequestHelper.History(url_history, token);
|
if (result_history == null)
|
{
|
LogHelper.Info("苏州金庭仪表 Api 数据对接中，获取实时数据失败");
|
return;
|
}
|
if (result_history.status != "SUCCESS")
|
{
|
LogHelper.Info("苏州金庭仪表 Api 数据对接中，获取实时数据失败（status!= SUCCESS）");
|
return;
|
}
|
if (result_history.content.result == null || result_history.content.result.Count() < 1)
|
{
|
LogHelper.Info("苏州金庭仪表 Api 数据对接中，获取实时数据失败(数据为空)");
|
return;
|
}
|
|
var items = result_history.content.result.OrderByDescending(x => x.reportTime).ToList();
|
var code_list = items.Select(x => x.meterCode).Distinct().ToList();
|
var src_list = new List<Model.MonitorDataDockingSrcRecord>();
|
foreach (var metercode in code_list)
|
{
|
var record = items.Find(t => t.meterCode == metercode);
|
if (record != null)
|
{
|
if (record.instantFlow != null)
|
{
|
var src_item_q = new Model.MonitorDataDockingSrcRecord();
|
src_item_q.SignId = $"{metercode}_q";
|
src_item_q.RecordType = eMonitorType.General;
|
src_item_q.SrcTime = record.reportTime;
|
src_item_q.SrcValue = record.instantFlow.Value.ToString();
|
src_list.Add(src_item_q);
|
}
|
if (record.cumulativeFlow != null)
|
{
|
var src_item_ql = new Model.MonitorDataDockingSrcRecord();
|
src_item_ql.SignId = $"{metercode}_ql";
|
src_item_ql.RecordType = eMonitorType.General;
|
src_item_ql.SrcTime = record.reportTime;
|
src_item_ql.SrcValue = record.cumulativeFlow.Value.ToString();
|
src_list.Add(src_item_ql);
|
}
|
if (record.pressure != null)
|
{
|
var src_item_pr = new Model.MonitorDataDockingSrcRecord();
|
src_item_pr.SignId = $"{metercode}_pr";
|
src_item_pr.RecordType = eMonitorType.General;
|
src_item_pr.SrcTime = record.reportTime;
|
src_item_pr.SrcValue = record.pressure.Value.ToString();
|
src_list.Add(src_item_pr);
|
}
|
}
|
}
|
|
if (src_list != null && src_list.Count > 0)
|
{
|
var record_receive_list = new List<Model.MonitorDataDockingReceiveRecord>();
|
foreach (var mapper in mappers)
|
{
|
var src = src_list.Find(x=>x.SignId==mapper.SignId);
|
if (src != null)
|
{
|
var record = new Model.MonitorDataDockingReceiveRecord() {
|
SysId=mapper.SysId,
|
RecordType=src.RecordType,
|
SrcTime=src.SrcTime,
|
SrcValue=src.SrcValue
|
};
|
record_receive_list.Add(record);
|
}
|
}
|
receive(record_receive_list);
|
}
|
|
if (appParas.debug)
|
{
|
DebugHelper.Debug(src_list);
|
}
|
|
}
|
}
|
|
}
|
