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<Model.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;
|
if (appParas.istoken)
|
{
|
token = TokenHelper.Get();
|
if (string.IsNullOrEmpty(token))
|
{
|
LogHelper.Error("上海城投制水 Api 数据对接中，获取Token失败");
|
return;
|
}
|
}
|
|
var list_external = mappers.Where(x => !string.IsNullOrEmpty(x.SignId)).Select(x => x.SignId).Distinct().ToList();
|
|
var data = JsonHelper.Object2Json(list_external);
|
var responseText = HttpRequestHelper.Post(appParas.url.last, token, data);
|
var result = JsonHelper.Json2Object<Result<List<Record>>>(responseText);
|
if (!result.success)
|
{
|
LogHelper.Info("上海城投制水 Api 数据对接中，获取实时数据失败（返回false）");
|
return;
|
}
|
var apiModel = result.data;
|
if (apiModel == null || apiModel.Count < 1)
|
{
|
LogHelper.Info("上海城投制水 Api 数据对接中，获取实时数据失败(返回结构为空)");
|
return;
|
}
|
|
var record_receive_list = new List<Model.MonitorDataDockingReceiveRecord>();
|
foreach (var mapper in mappers)
|
{
|
var src = apiModel.Find(x => x.mpId == mapper.SignId);
|
if (src != null && src.data != null && src.data.Count > 0)
|
{
|
var timeZone = TimeHelper.Convert(long.Parse(src.data[0][0].ToString()));
|
var time = DateTime.SpecifyKind(timeZone, DateTimeKind.Unspecified);
|
var record = new Model.MonitorDataDockingReceiveRecord
|
{
|
SysId = mapper.SysId,
|
RecordType = Model.eMonitorType.General,
|
SrcTime = time,
|
SrcValue = src.data[0][1].ToString()
|
};
|
record_receive_list.Add(record);
|
}
|
}
|
receive(record_receive_list);
|
|
if (appParas.debug)
|
{
|
DebugHelper.Debug(apiModel);
|
}
|
}
|
|
|
}
|
|
}
|
