using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.ServiceProcess;
using System.Text;
///////////-------
using System.IO.Ports;
using System.Net;          //tcp
using System.Net.Sockets;  //tcp
using NLog;
using System.Xml; //xml
using Npgsql;  //pg
using System.Threading;
using System.Text.RegularExpressions;  //regexp

namespace Srvc_DOF_TCP
{
    public partial class Service1 : ServiceBase
    {
        #region global
        XmlDocument xml = new XmlDocument();    //xml
        static List<string> list = new List<string>(); //xml
        static private DataSet ds = new DataSet(); //pg com
        static private DataTable dt = new DataTable(); //pg com
        private System.Timers.Timer timer2;
        static String Mystr = null; //pg_query
        static int min = 5000; //time
        private static Logger logger = LogManager.GetCurrentClassLogger(); //log
        object[,] arr = new object[2, 2];
        static List<object[,]> listTcp = new List<object[,]>(); //xml
        string[,] myArr = new string[9, 2];
        static List<DoWork> allListeners; //list_of_com
        string my_name = Environment.MachineName;
        #endregion


        public Service1()
        {
            InitializeComponent();
            XMLReader();
        }


        #region Xml
        public void XMLReader()
        {
            try
            {
                xml.Load("c:\\DATA\\server_info_dof.xml");
                foreach (XmlNode n in xml.SelectNodes("/server_info"))
                {
                    list = new List<string>();
                    list.Add(n.SelectSingleNode("server").InnerText);
                    list.Add(n.SelectSingleNode("port").InnerText);
                    list.Add(n.SelectSingleNode("user_id").InnerText);
                    list.Add(n.SelectSingleNode("password").InnerText);
                    list.Add(n.SelectSingleNode("database").InnerText);
                    list.Add(n.SelectSingleNode("table").InnerText);        //5
                    list.Add(n.SelectSingleNode("tcpenable").InnerText);    //6
                    list.Add(n.SelectSingleNode("opcenable").InnerText);    //7
                    list.Add(n.SelectSingleNode("comenable").InnerText);    //8
                    list.Add(n.SelectSingleNode("value").InnerText);        //9
                    list.Add(n.SelectSingleNode("debug_mode").InnerText);        //10
                    list.Add(n.SelectSingleNode("name_in_db").InnerText);        //11
                }
            }
            catch (Exception msg)
            {
                logger.Trace(msg);
                return;
            }
        }
        #endregion

        #region tcpconnect
        private void SelectCom()  //com port
        {
            try
            {
                if (list[11] != "0")
                {
                    my_name = list[11].ToString();
                }
                NpgsqlConnection conn = new NpgsqlConnection(("Server=" + list[0] + ";Port=" + list[1] + ";User Id=" + list[2] + ";Password=" + list[3] + ";Database=" + list[4] + ";"));
                string sql = " SELECT   \"ID_TagName\" as id, \"F_ComPortIPAdress\",  \"F_ComQuery\", \"F_ComPort\",  \"F_ParseFunction\", \"F_TagReadTime\"  ,  \"F_AnswerLenght\"       FROM ";
                sql += "\"SC_Tag\".\"T_TagName\" as tn,\"SC_Tag\".\"T_HardWareTag\" as hw , \"SC_Tag\".\"T_RealHardWare\" as rh            where  rh.\"ID_RealHardWare\" =   ";
                sql += "hw.\"F_RealHardWare_ID\"   and tn.\"F_HardWare_ID\" = hw.\"F_TagName_ID\"    and \"F_ServerName\"  =\'" + my_name + "\' and \"F_ComPortIPAdress\" != '127.0.0.1' ";
                if (list[10] == "1")
                {
                    logger.Trace("start select " + sql);
                }
                NpgsqlDataAdapter da = new NpgsqlDataAdapter(sql, conn);
                ds.Reset();
                da.Fill(ds);
                dt = ds.Tables[0];
                if (list[10] == "1")
                {
                    logger.Trace(dt.Rows[0][2]);
                }
                if (ds.Tables[0] != null)
                {
                    InitAll();
                }

            }
            catch (Exception msg)
            {
                logger.Trace(msg);
                return;
            }
        }

        private void InitAll()
        {
            try
            {
                allListeners = new List<DoWork>();

                for (int xx = 0; xx < ds.Tables[0].Rows.Count; ++xx)
                {

                    string server = dt.Rows[xx][1].ToString();
                    string message = dt.Rows[xx][2].ToString() + "\r";
                    int port = Convert.ToInt32(dt.Rows[xx][3]);
                    int idcom = Convert.ToInt32(dt.Rows[xx][0]);
                    string parse = dt.Rows[xx][4].ToString();
                    int dlina = Convert.ToInt32(dt.Rows[xx][6]);
                    allListeners.Add(new DoWork(server, message, port, idcom, parse, dlina));
                }

                min = Convert.ToInt32(dt.Rows[0][5]);
                for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
                {
                    if (Convert.ToInt32(dt.Rows[i][5]) < min)
                        min = Convert.ToInt32(dt.Rows[i][5]);
                }

                this.timer2 = new System.Timers.Timer();
                this.timer2.Enabled = true;
                this.timer2.Interval = min;

                this.timer2.Elapsed += new System.Timers.ElapsedEventHandler(this.timer2_Elapsed);
                this.timer2.AutoReset = true;
                this.timer2.Start();

            }
            catch (Exception msg)
            {
                logger.Trace(msg);
                return;
            }
        }
        private void timer2_Elapsed(object sender, EventArgs e)
        {
            try
            {
                if (list[10] == "1")
                {
                    logger.Trace("timer2_Elapsed  OPCTagIntoNPG();");
                }

                foreach (DoWork comListener in allListeners)
                {
                    comListener.ThreadStart();
                    Thread.Sleep(2000);
                    comListener.ThreadStop();
                }

            }
            catch (Exception msg)
            {
                logger.Trace(msg);
                return;
            }

        }

        internal class DoWork
        {
            string SERV, MES, ParseGlob;
            private bool doWork;
            private System.Threading.Thread thread;
            readonly EventWaitHandle wh = new AutoResetEvent(false);
            int IdCom, Port, ansLen;
            Regex rxNums = new Regex(@"^\d+$");

            internal DoWork(String server, String message, Int32 port, Int32 idcom, String Parse, Int32 dlina)
            {
                SERV = server;
                MES = message;
                Port = port;
                IdCom = idcom;
                ansLen = dlina;
                if (Parse != "")
                    ParseGlob = Parse;
            }
            public void ThreadStart()
            {
                doWork = true;
                thread = new Thread(Execute);
                thread.Start();
            }
            public void ThreadStop()
            {
                doWork = false;
                wh.Set();
            }
            void Execute()
            {
                try
                {
                    if (doWork)
                        Connect(SERV, MES, Port);
                }
                catch (Exception msg)
                {
                    logger.Trace("Execute() " + msg);
                    return;
                }
            }

            public void Connect(String server, String message, Int32 port)
            {
                try
                {
                    // Create a TcpClient.
                    // Note, for this client to work you need to have a TcpServer 
                    // connected to the same address as specified by the server, port
                    // combination.

                    // Int32 port = 4007;
                    TcpClient client = new TcpClient(server, port);

                    // Translate the passed message into ASCII and store it as a Byte array.
                    Byte[] data = System.Text.Encoding.ASCII.GetBytes(message);

                    // Get a client stream for reading and writing.
                    //  Stream stream = client.GetStream();

                    NetworkStream stream = client.GetStream();

                    // Send the message to the connected TcpServer. 
                    stream.Write(data, 0, data.Length);

                    //   logger.Trace("Sent: {0}", message);
                    if (list[10] == "1")
                    {
                        logger.Trace("Sent: {0}", message);
                    }
                    doWork = false;
                    // Receive the TcpServer.response.
                    //  Thread.Sleep(2000);   
                    // Buffer to store the response bytes.
                    data = new Byte[256];

                    // String to store the response ASCII representation.
                    String responseData = String.Empty;

                    // Read the first batch of the TcpServer response bytes.
                    Int32 bytes = stream.Read(data, 0, data.Length);
                    responseData = System.Text.Encoding.ASCII.GetString(data, 0, bytes);
                    responseData = responseData.Substring(0, responseData.Length - 1);
                    string isdig = null;
                    isdig = responseData.Substring(7);
                    string hash = responseData.Substring(1, 3);
                    string hash2 = message.Substring(1, 3);
                    string end = responseData.Substring(responseData.Length - 1, 1);

                    if (list[10] == "1")
                    {
                        logger.Trace("Received: {0} ", responseData);
                    }
                    if (responseData[0] == '$' && responseData.Length <= ansLen)
                    {
                        //   logger.Trace("e " + end + String.Equals(end, "Y"));
                        if (String.Equals(end, "Y"))
                        {
                            // logger.Trace("ok");
                            NpgsqlConnection conn = new NpgsqlConnection(("Server=" + list[0] + ";Port=" + list[1] + ";User Id=" + list[2] + ";Password=" + list[3] + ";Database=" + list[4] + ";"));
                            conn.Open();
                            Mystr = ("INSERT INTO " + list[5] + "(\"F_TagName_ID\"," + list[9] + ",\"F_Date\")  VALUES (" + IdCom.ToString() + ",0,\'" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\')");
                            //MessageBox.Show(Mystr);

                            if (list[10] == "1")
                            {
                                logger.Trace("0 " + Mystr);
                            }
                            NpgsqlCommand command = new NpgsqlCommand(Mystr, conn);
                            int rowsaffected;
                            rowsaffected = command.ExecuteNonQuery();
                            conn.Close();

                            doWork = true;
                            // Close everything.
                            stream.Close();
                        }
                        if (rxNums.IsMatch(isdig))
                        {
                            NpgsqlConnection conn = new NpgsqlConnection(("Server=" + list[0] + ";Port=" + list[1] + ";User Id=" + list[2] + ";Password=" + list[3] + ";Database=" + list[4] + ";"));
                            conn.Open();
                            if (ParseGlob != "")
                                Mystr = ("INSERT INTO " + list[5] + "(\"F_TagName_ID\"," + list[9] + ",\"F_Date\")  VALUES (" + IdCom.ToString() + ",(SELECT * FROM " + ParseGlob + "(\'" + responseData + "\')),\'" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\'   )");
                            else Mystr = ("INSERT INTO " + list[5] + "(\"F_TagName_ID\"," + list[9] + ",\"F_Date\")  VALUES (" + IdCom.ToString() + ",\'" + responseData + "\',\'" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\'   )");


                            if (list[10] == "1")
                            {
                                logger.Trace(Mystr);
                            }
                            NpgsqlCommand command = new NpgsqlCommand(Mystr, conn);
                            int rowsaffected;
                            rowsaffected = command.ExecuteNonQuery();
                            conn.Close();

                            doWork = true;
                            // Close everything.
                            stream.Close();
                            client.Close();
                        }
                    }
                    else
                    {                        
                        stream.Close();
                        client.Close();
                        logger.Trace("port_DataReceived " + responseData);
                        responseData = "";
                        return;
                    }


                }
                catch (ArgumentNullException e)
                {
                    logger.Trace("ArgumentNullException: {0}", e);
                    return;
                }
                catch (SocketException e)
                {
                    logger.Trace("SocketException: {0}", e);
                    return;
                }
            }
            public bool ThreadState()
            {
                if (doWork)
                    return true;
                else return false;
            }
        }

        #endregion


        #region start\stop
        protected override void OnStart(string[] args)
        {
            try
            {
                if (list[6] == "1")
                    SelectCom();
                if (list[10] == "1")
                {
                    logger.Trace("start");
                }
            }

            catch (Exception msg)
            {
                logger.Trace(msg);
                return;
            }
        }

        protected override void OnStop()
        {
            try
            {
                if (list[6] == "1")
                {
                    foreach (DoWork comLisener in allListeners)
                    {
                        comLisener.ThreadStop();
                    }
                }
                base.OnStop();
                if (list[10] == "1")
                {
                    logger.Trace("stop");
                }
            }
            catch (Exception msg)
            {
                logger.Trace(msg);
                return;
            }
        }
        #endregion
    }
}