using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO.Ports;
using FirebirdSql.Data.FirebirdClient;
using System.Collections;
using System.Threading;
using System.Runtime.Remoting.Contexts;


namespace GateConsole
{
    class Program
    {       
        static FbConnection connection;
        static Mutex mutexObj = new Mutex();
        static void Main(string[] args)
        {           
            List<Contr> ContrList = new List<Contr>();
            FbConnectionStringBuilder cs = new FbConnectionStringBuilder();
            
            cs.DataSource = "192.168.0.220";
            cs.Database = "FITNESS";
            cs.UserID = "SYSDBA";
            cs.Password = "metalink";
            cs.Charset = "NONE";
            cs.Pooling = false;
            connection = new FbConnection(cs.ToString());
            GatePort.InitializationPort();
            GatePort._serialPort.Open();
            connection.Open();
            ///////////////////////////////////////////////////////////////////
            FbRemoteEvent revent = new FbRemoteEvent(connection);
            revent.AddEvents(new string[] { "EDIT_GATEKEY"/*, "NEW_EVENT", "new_visit"*/ });
            //Добавить функцию обратного вызова для Firebird событий
            revent.RemoteEventCounts += new FbRemoteEventEventHandler(WriteKey);
            revent.QueueEvents();
            ////////////////////////////////////////////////////////////////////            
            FbCommand com = new FbCommand("select contrid,addr from contr", connection);
            FbDataReader reader = com.ExecuteReader();
            if (reader.HasRows)
            {
                while (reader.Read())
                {
                    ContrList.Add(new Contr(Convert.ToInt32(reader.GetValue(0)), Convert.ToByte(reader.GetValue(1))));
                }
            }
            ReadEvent(ContrList);
            Console.WriteLine("Достигнута конечная точка программы");     
            Console.ReadLine(); 
            connection.Close();
            GatePort._serialPort.Close();
           
        }

      
        static void WriteKey(object sender, FbRemoteEventEventArgs args)
        {
            List<Key> ListKey = new List<Key>();
            byte[] dataRead;
            //Console.WriteLine("Предъмьютекс");
            try
            {
                //получить ключи и контроллеры
                //записать их в конроллеры
                FbCommand com = new FbCommand("select * from eventbufer", connection);
                FbDataReader reader = com.ExecuteReader();
                if (reader.HasRows)
                {
                    while (reader.Read())
                    {
                        ListKey.Add(new Key()
                        {
                            KeyId = (int)reader.GetValue(0),
                            AddresContr = (int)reader.GetValue(1),
                            AddresKey = (int)reader.GetValue(2),
                            KeySeries = (int)reader.GetValue(3),
                            KeyNumber = (int)reader.GetValue(4)
                        });
                    }

                    foreach (var i in ListKey)
                    {
                        Console.WriteLine("Контроллер {0} карта {1},{2}", i.AddresContr, i.KeySeries, i.KeyNumber);
                        dataRead = i.WriteKey(0x01);//Запись ключа в банк 1

                        dataRead = i.WriteKey(0x02);//Запись ключа в банк 2
                        
                        com = new FbCommand("delete  from eventbufer where id=" + i.KeyId, connection);
                        Console.WriteLine("Удалено {0} строк", com.ExecuteNonQuery());
                    }
                };
            }
            catch (Exception ex)
            {
                Console.WriteLine("ИСКЛЮЧЕНИЕ!!! {0}", ex);
            }
           
        }

        static public string Win1251ToUTF8(string source)
        {
            var fromEncodind = Encoding.GetEncoding("Windows-1251");//из какой кодировки
            var bytes = fromEncodind.GetBytes(source);
            var toEncoding = Encoding.UTF8;//в какую кодировку
            source = toEncoding.GetString(bytes);
            return source;
        }

        static void ReadEvent(Object controller)
        {
            List<Contr> ContrList = (List<Contr>)controller;
            int PointerUp = 0;
            int PointerDown = 0;
            List<ValueEvent> EventContr = new List<ValueEvent>();
            FbCommand com = new FbCommand("select * from eventscode", connection);
            FbDataReader reader = com.ExecuteReader();
            if (reader.HasRows)
            {
                while (reader.Read())
                {
                    EventContr.Add(new ValueEvent((int)reader.GetValue(0), Win1251ToUTF8((string)reader.GetValue(1))));
                }
            }
      
            byte[] dataRead, data;
            dataRead = new byte[] { 0x00 };

            while (true)
            {
                
                foreach (var cont in ContrList)
                {                   
                    dataRead = GatePort.RequestContr(0x09, cont.AdressContr, new byte[] { });//Номер версии контроллера                   
                    cont.VersionNumber = dataRead[6] >> 4;
                    //Console.WriteLine("Номер Версии:{0}", dataRead[6] >> 4);
                    switch (cont.VersionNumber)
                    {
                        //GATE-4 (адреса 0-7FFFh)
                        //GATE-8000 (адреса 0-FFFFh).
                        case 8:
                            cont.MaxAddrByte = 65535;
                            break;
                        case 4:
                            cont.MaxAddrByte = 32767;
                            break;
                    }

                    do
                    {
                        System.Threading.Thread.Sleep(100);
                       
                        dataRead = GatePort.RequestContr(0x04,cont.AdressContr, new byte[] { 0x00, 0xD0, 0x04, 0x00, 0x08, });//Нижняя и верхняя границы
                       
                        //Console.WriteLine("\nПоложение указателей");
                        //foreach (var i in dataRead)
                        //{
                        //    Console.Write(Convert.ToString(i, 16) + " ");
                        //}
                        Array.Reverse(dataRead);
                        PointerUp = BitConverter.ToInt16(dataRead, 4);
                        PointerDown = BitConverter.ToInt16(dataRead, 2);
                        Console.ForegroundColor = ConsoleColor.Green;
                        Console.WriteLine("\nАдрес нижней границы:{0}, адрес верхней границы: {1}", PointerDown, PointerUp);
                        Console.ResetColor();

                        if (PointerDown != PointerUp)
                        {
                            byte[] BufByte = BitConverter.GetBytes(PointerDown);//убрал+8, 2 байта-нижняя граница                            
                            dataRead = GatePort.RequestContr(0x04, cont.AdressContr, new byte[] { 0x02, 0xA0, 0x08, BufByte[1], BufByte[0] });
                            Console.WriteLine("Ответ сервера с событием");
                            foreach (var i in dataRead)
                            {
                                Console.Write(Convert.ToString(i, 16) + " ");
                            }
                            Console.WriteLine("\nНовое событие события:{0}, сдвиг на 1 разряд:{1}", dataRead[6], (dataRead[6] & 127));

                            foreach (ValueEvent i in EventContr)
                            {
                                if (i.ValueEventId == (dataRead[6] & 127))
                                {
                                    Console.ForegroundColor = ConsoleColor.Red;
                                    Console.WriteLine("Контроллер {5} Наименование события {0}, Месяц:{1:X}, Дата: {2:X}, Часы: {3:X}, Минуты:{4:X}", i.Name.ToString(), (int)dataRead[9], (int)dataRead[10], (int)dataRead[11], (int)dataRead[12],cont.AdressContr);
                                    Console.ResetColor();
                                    string date = String.Format("{0:X}.{1:X}.{2}", (int)dataRead[10], (int)dataRead[9],DateTime.Now.Year);
                                    string time = String.Format("{0:X}:{1:X}:{2:X}", (int)dataRead[11], (int)dataRead[12],(int)dataRead[13]);
                                    com = new FbCommand("insert into events (rearerid,eventscode,ddate,ttime,ser,number,contrid,client) values (" + cont.ContrId + "," + (dataRead[6] & 127) + "," + date + "," + time + "," + null+","+null+","+cont.ContrId+")", connection);
                                
                                }
                            }

                            //увелчить на 8 нижнюю границу  
                            if ((PointerDown + 8) >= cont.MaxAddrByte)
                            { PointerDown = -8; }
                            byte[] data11 = BitConverter.GetBytes(PointerDown + 8);                        
                            dataRead = GatePort.RequestContr(0x05, cont.AdressContr, new byte[] { 0x00, 0xD0, 0x02, 0x00, 0x0A, data11[1], data11[0] });
                            Console.WriteLine("Ответ после изменения нижней границы");
                            foreach (var i in dataRead)
                            {
                                Console.Write(Convert.ToString(i, 16) + " ");
                            }
                        }
                    } while (PointerDown != PointerUp);
                    Console.ForegroundColor = ConsoleColor.DarkBlue;
                    Console.WriteLine("Все события контроллера {0} считаны, переход к следующемуу контроллеру", cont.AdressContr);
                    Console.ResetColor();
                    System.Threading.Thread.Sleep(100);
                }
            }
        }
    }

        class Key
        {
            public int KeyId { get; set; }
            public int KeySeries { get; set; }
            public int KeyNumber { get; set; }
            public int AddresKey { get; set; }
            public int AddresContr { get; set; }

            public byte[] WriteKey(byte bank)
            {
                byte[] buf = BitConverter.GetBytes(AddresKey);
                byte[] BufKeyNumber = BitConverter.GetBytes(KeyNumber);
                byte[] Request = GatePort.RequestContr(0x05, (byte)AddresContr, new byte[] { bank, 0xA0, 0x08, buf[1], buf[0],
                    0x00,
                    0x00,
                    0x00,
                    (byte)KeySeries,
                    BufKeyNumber[1],
                    BufKeyNumber[0],
                    0x00,
                    0x80,//16 байт
                });               
                return Request;
            }
    }

        class Contr
        {
            public int ContrId { get; set; }
            public byte AdressContr { get; set; }
            public string ContrName { get; set; }
            public int VersionNumber { get; set; }
            public int MaxAddrByte { get; set; }//максимальный адрес буфера событий
            //IEnumerable<Key> Keys { get; set; }

            public Contr(int contrid, byte adres)
            {
                ContrId = contrid;
                AdressContr = adres;
            }         
        }


        class ValueEvent
        {
            public int ValueEventId { get; set; }
            public string Name { get; set; }
            public ValueEvent(int id, string name)
            {
                ValueEventId = id;
                Name = name;
            }

        }

    static class GatePort
    {
        public static SerialPort _serialPort;
        public static byte[] Data, DataRead;
        static byte ContrSumma;
        static int ErrorCount;

        public static void InitializationPort()
        {
            _serialPort = new SerialPort("COM4", 19200, Parity.None, 8, StopBits.One);
            _serialPort.Handshake = Handshake.None;
            _serialPort.ReadTimeout = 1500;
        }

        public static byte[] RequestContr(byte CodeRead, byte AddressContr, byte[] BodyCommand)
        {
            ErrorCount = 0;
            ContrSumma = CodeRead;
            Data = new byte[] { 0xFA, 0x01, AddressContr, CodeRead };
            //Сначала обработать bodycommand на предмет наличия FF,F5
            foreach (var i in BodyCommand)
            {
                Array.Resize(ref Data, Data.Length + CheckByte(i).Length);
                CheckByte(i).CopyTo(Data, Data.Length - CheckByte(i).Length);
            }
            for (int i = 4; i < Data.Length; i++)
            {
                ContrSumma = (byte)(ContrSumma ^ Data[i]);
            }
           // ContrSumma = 0xF5;
            switch (CheckByte(ContrSumma).Length)
            {
                case 1:
                    Array.Resize(ref Data, Data.Length + 2);
                    Data[Data.Length - 2] = ContrSumma;
                    Data[Data.Length - 1] = 0xF5;
                    break;
                case 2:
                    Array.Resize(ref Data, Data.Length + 3);
                    Data[Data.Length - 3] = CheckByte(ContrSumma)[0];
                    Data[Data.Length - 2] = CheckByte(ContrSumma)[1];
                    Data[Data.Length - 1] = 0xF5;
                    break;
            }
            //Console.WriteLine("Запрос на сервер:");
            //foreach(var i in Data)
            //{
            //    Console.Write("{0} ",i);
            //}
            do
            {
                try
                {
                    _serialPort.Write(Data, 0, Data.Length);
                    System.Threading.Thread.Sleep(100);
                    DataRead = new byte[255];
                    int KollByte = _serialPort.Read(DataRead, 0, DataRead.Length);
                    Array.Resize(ref DataRead, KollByte);
                    ErrorCount = 0;
                }
                catch (TimeoutException)
                {
                    ErrorCount++;
                    if (ErrorCount >= 10)
                    { ErrorCount = 0; }
                    Console.WriteLine("Контроллер не ответил");
                }
            } while (ErrorCount != 0);
            return DataRead;
            //Console.WriteLine("Результат:");
            //foreach (var i in DataRead)
            //{
            //    Console.Write("{0} ", i);
            //}

        }


        static byte[] CheckByte(byte b)
        {
            byte[] buf;
            switch (b)
            {
                case 0xFA:
                    buf = new byte[] { 0xFF, 0x01 };
                    break;
                case 0xF5:
                    buf = new byte[] { 0xFF, 0x02 };
                    break;

                case 0xFF:
                    buf = new byte[] { 0xFF, 0x03 };
                    break;
                default:
                    buf = new byte[] { b };
                    break;
            }
            return buf;
        }
    }
}