namespace IStation.Scada
|
{
|
internal class Program
|
{
|
static readonly IStation.Service.ScheduleScada _service_schedule_scada = new();
|
|
static void Main(string[] args)
|
{
|
Console.WriteLine("启动实时数据采集...");
|
var timer = new System.Timers.Timer();
|
timer.Interval = 10 * 1000;
|
timer.Elapsed += (s, e) =>
|
{
|
var dt_now = DateTime.Now;
|
var dt_now_str = dt_now.ToString("G");
|
var get_msg = GlobalHelper.GetRealTimeZyScadaList(out List<Model.ZyScada> scada_list);
|
if (!string.IsNullOrEmpty(get_msg))
|
{
|
Console.WriteLine($"{dt_now_str}:{get_msg}");
|
}
|
else
|
{
|
var schedule_scada_list = scada_list.Select(x => new Model.ScheduleScada()
|
{
|
RequestID = 0,
|
Time = dt_now,
|
Code = x.Code,
|
Tag = x.Tag,
|
Value = x.Value,
|
}).ToList();
|
|
var bol = _service_schedule_scada.Inserts(schedule_scada_list);
|
if (bol)
|
{
|
Console.WriteLine($"{dt_now_str}:采集成功!");
|
}
|
else
|
{
|
Console.WriteLine($"{dt_now_str}:采集失败!");
|
}
|
}
|
};
|
timer.AutoReset = true;
|
timer.Start();
|
|
Console.ReadKey();
|
}
|
|
}
|
}
|