using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO;
using System.Windows.Forms;
using MySql.Data.MySqlClient;
using System.Text.RegularExpressions;

namespace schedule
{
    public partial class Form1 : Form
    {
        int cnt1 = 0;
        private MySqlConnection connection;
        private string server;
        private string database;
        private string uid;
        private string password;
        private string query;
        private string serialno;
        private string messtype;
        private string phonenumber;
        private string mymessage;
        private string senderid;
        private string username;
        private string transid;
        private string billcode;
        private string domain;
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            timer1.Enabled = true;
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            timer1.Interval = 30000;
            string bookname = "";
            string flag = "";
            label1.Text = DateTime.Now.ToString("yyyy/MM/d HH:mm:ss");
            // AddEvent("Nosa Osahon is here, what about you");
            //Database connection
            server = "localhost";
            database = "smartsmsrouter";
            uid = "smsEngine";
            password = "guEnaR28T";
            string connectionString;
            connectionString = "SERVER=" + server + ";" + "DATABASE=" +
            database + ";" + "UID=" + uid + ";" + "PASSWORD=" + password + ";";

            MySqlConnection connection = new MySqlConnection(connectionString);

            using (connection)
            {
                query=  "SELECT transid,username,bookname,message,domain,sender,messtype,flag FROM schedule where status ='0' and datedue <='"+DateTime.Now.ToString("yyyy/MM/d HH:mm") +"'";
                MySqlCommand command = new MySqlCommand(query,connection);
                connection.Open();

                MySqlDataReader reader = command.ExecuteReader();

                if (reader.HasRows)
                {
                    while (reader.Read())
                    {
                        transid = reader.GetString(0);
                        username = reader.GetString(1);
                        bookname = reader.GetString(2);
                        mymessage = reader.GetString(3);
                        domain = reader.GetString(4);
                        senderid = reader.GetString(5);
                        messtype = reader.GetString(6);
                        flag = reader.GetString(7);

                        
                        username = username.Replace("'","^");
                        bookname = bookname.Replace("'", "^");
                        mymessage = mymessage.Replace("'", "^");                        
                        senderid = senderid.Replace("'", "^");



                        if (messtype =="1")
                            query = "insert messagesentsingle(transid,username,phonenumber,message,sender,domain,status,dateused) values ('" + transid + "','" + username + "','" + bookname + "','" + mymessage + "','" + senderid + "','" + domain + "','0','" + DateTime.Now.ToString("yyyy/MM/d HH:mm:ss") + "')";
                        else
                            query = "insert messagesentaddressbook(transid,username,bookname,message,sender,domain,flag,status,dateused) values ('" + transid + "','" + username + "','" + bookname + "','" + mymessage + "','" + senderid + "','" + domain + "','"+flag+"','0','" + DateTime.Now.ToString("yyyy/MM/d HH:mm:ss") + "')";
                            UpdateQuery(query);
                            AddEvent(query);
                        }
                    }
                    //update messagesentsingle
                    query = "update schedule set status='1' where transid ='" + transid + "'";
                    UpdateQuery(query);

                }
            
        }

        private void button2_Click(object sender, EventArgs e)
        {
            timer1.Enabled = false;
        }

        private void button3_Click(object sender, EventArgs e)
        {
            if (MessageBox.Show("Exit application?", "Splitter Addressbook",
               MessageBoxButtons.YesNo) == DialogResult.Yes)
            {
                Application.Exit();

            }
        }

        public void AddEvent(String Details)
        {

            String[] Lines;
            int i;
            if (cnt1 > 50)
            {
                txtLog.Text = "";
                cnt1 = 0;
            }
            //txtLog.AppendText(Prefix +  + "\r\n");


            if (Details != "")
            {
                Lines = Details.Split('\r');
                for (i = 0; i < Lines.Length; i++)
                    txtLog.AppendText("       " + Lines[i] + "\r\n");
            }
            cnt1++;
        }

        //end of addevent


        public void UpdateQuery(string query)
        {
            int reader2 = 0;
            server = "localhost";
            database = "smartsmsrouter";
            uid = "smsEngine";
            password = "guEnaR28T";
            string connectionString;
            connectionString = "SERVER=" + server + ";" + "DATABASE=" +
            database + ";" + "UID=" + uid + ";" + "PASSWORD=" + password + ";";

            MySqlConnection connection2 = new MySqlConnection(connectionString);

            using (connection2)
                try
                {
                    MySqlCommand command2 = new MySqlCommand(query, connection2);
                    connection2.Open();


                    reader2 = command2.ExecuteNonQuery();

                }
                catch (Exception ex)
                {

                    timer1.Enabled = false;
                    //timer1.Interval = 0;

                    if (MessageBox.Show("Error updating " + query + " Exit application?" + ex.Message, "SMARTSMS ROUTER",
                                    MessageBoxButtons.YesNo) == DialogResult.Yes)
                    {
                        Application.Exit();

                    }

                }




            connection2.Close();

        }//end of updatequery

    }
}