using Dapper;
|
using IStation.Model;
|
using System;
|
using System.Collections.Generic;
|
using System.Data.SqlClient;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.DataDockingMiddleLib
|
{
|
public class HandleHelper : IDataDockingMiddleLib.IHandleHelper
|
{
|
|
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("YS 中间库数据对接中，缺少对接配置文件！");
|
return;
|
}
|
List<IDictionary<string, object>> dynamic_list = null;
|
using (var conn = new SqlConnection(appParas.ConnectionString))
|
{
|
conn.Open();
|
var strSql = string.Format("SELECT * FROM {0} ", appParas.TableName);
|
var list = conn.Query(strSql)?.ToList();
|
if (list == null || list.Count < 1)
|
return;
|
dynamic_list = list.Select(x => x as IDictionary<string, object>).ToList();
|
}
|
|
if (dynamic_list != null && dynamic_list.Count > 0)
|
{
|
var receiveList = new List<Model.MonitorDataDockingReceiveRecord>();
|
foreach (var mapper in mappers)
|
{
|
var src = dynamic_list.Find(x => x[appParas.SignColumnName]?.ToString() == mapper.SignId);
|
if (src != null)
|
{
|
var record = new Model.MonitorDataDockingReceiveRecord();
|
record.SysId = mapper.SysId;
|
record.RecordType = Model.eMonitorType.General;
|
var srcTime = src[appParas.DataTimeColumnName]?.ToString();
|
if (!string.IsNullOrEmpty(srcTime))
|
record.SrcTime = Convert.ToDateTime(srcTime);
|
record.SrcValue = src[appParas.DataValueColumnName]?.ToString();
|
receiveList.Add(record);
|
}
|
}
|
receive(receiveList);
|
}
|
|
if (appParas.Debug)
|
{
|
DebugHelper.Debug(dynamic_list);
|
}
|
}
|
|
//Data Source =10.197.10.113; Initial Catalog = SCADA_DATA; UID=sa; PWD=p@ssw0rd;
|
//server=10.197.10.113;database=SCADA_DATA;integrated security=true;
|
}
|
|
|
}
|
