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();
        }

    }
}