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;
using System.Net;
using System.Text;

namespace SplitterSingle
{
    public partial class Form1 : Form
    {
        int cnt1 = 0;
        int cnt10 = 4;
        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 Form1_Load(object sender, EventArgs e)
        {

        }

        //addevent logs

        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++;
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            var request = WebRequest.Create("https://onesignal.com/api/v1/notifications") as HttpWebRequest;
            String mURL = "";

            request.KeepAlive = true;
            request.Method = "POST";
            request.ContentType = "application/json; charset=utf-8";

            request.Headers.Add("authorization", "Basic ZGY2MGIyNWUtOTJkMy00MDBlLWI5NDctYWVlZTU5M2NmNzA1");

            label3.Text = DateTime.Now.ToString("yyyy/MM/d HH:mm:ss");
            // AddEvent("Nosa Osahon is here, what about you");
            //Database connection
            long serial ;
            server = "localhost";
            database = "smartsmsrouter";
            uid = "smsEngine";
            password = "guEnaR28T";
            string connectionString;
            string name ="";
            string  timediff="";
            string messout ="";
            String lastseen = "";
           
            connectionString = "SERVER=" + server + ";" + "DATABASE=" +
            database + ";" + "UID=" + uid + ";" + "PASSWORD=" + password + ";";

            MySqlConnection connection = new MySqlConnection(connectionString);

            using (connection)
            {
                MySqlCommand command = new MySqlCommand(
                  "select sn,name, lastseen,TIMESTAMPDIFF(minute,lastseen, now()) from penpal where TIMESTAMPDIFF(minute,lastseen, now()) > 3 and userStatus ='online'",
                  connection);
                connection.Open();

                MySqlDataReader reader = command.ExecuteReader();

                if (reader.HasRows)
                {
                   // cnt10 = 3;
                    while (reader.Read())
                    {
                        serial = reader.GetInt64(0);
                        nickname = reader.GetString(1);
                        lastseen = reader.GetString(2);
                        timediff = reader.GetString(3)
                     

                        messout = nname + " "+ lastseen + " " + timediff 

                        query = "update penpal set userStatus ='offline'   where sn ="+serial;
                        UpdateQuery(query);

                        //messout = nickname + " " + country + " " + messout;
                        AddEvent(messout);

                    }
                    //update messagesentsingle

                }
            }

            //timer1 ends here
        }




                private void timer2_Tick(object sender, EventArgs e)
                {
        
                    //timer2 ends here
                }




                private void timer3_Tick(object sender, EventArgs e)
                {
                    //timer3 ends here
                }





                private void timer4_Tick(object sender, EventArgs e)
                {
                    //timer4 ends here
                }





        private void button1_Click(object sender, EventArgs e)
        {
            timer2.Tick += new EventHandler(timer2_Tick);
            timer3.Tick += new EventHandler(timer3_Tick);
            timer4.Tick += new EventHandler(timer4_Tick);
            timer1.Enabled = true;
            timer2.Enabled =true;
	    timer3.Enabled =true;
	    timer4.Enabled =true;
            timer2.Interval =5000;
            timer2.Start();
            timer3.Interval =5000;
            timer3.Start();
            timer4.Interval =5000;
            timer4.Start();



        }

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

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

            }
        }
        //addvent events ends here


        //updateQuery starrs here

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

        }

        private void button4_Click(object sender, EventArgs e)
        {
            string country = "";
            string engine = "";
            //string shortcode = "";
            if (radioButton1.Checked == true)
            {
                country = "Nigeria";
                sender = "33811";
                engine = "2";

            }

            if (radioButton2.Checked == true)
            {
                country = "Ghana";
                sender = "Test";
                engine = "1";

            }


            if (radioButton3.Checked == true)
            {
                country = "South Africa";
                sender = "33282";
                engine = "3";

            }
            label1.Text = DateTime.Now.ToString("yyyy/MM/d HH:mm:ss");
            // AddEvent("Nosa Osahon is here, what about you");
            //Database connection
            long serial;
            server = "localhost";
            database = "smartsmsrouter";
            uid = "smsEngine";
            password = "guEnaR28T";
            string connectionString;
            string msisdn = "";
            string message = "";
            string messout = "";
            connectionString = "SERVER=" + server + ";" + "DATABASE=" +
            database + ";" + "UID=" + uid + ";" + "PASSWORD=" + password + ";";

            MySqlConnection connection = new MySqlConnection(connectionString);

            using (connection)
            {
                query = "SELECT distinct msisdn FROM ghanatest where msisdn like '233%' and  msisdn !='" + textBox2.Text + "';";


                MySqlCommand command = new MySqlCommand(query, connection);
                connection.Open();

                MySqlDataReader reader = command.ExecuteReader();

                if (reader.HasRows)
                {
                    // cnt10 = 3;
                    while (reader.Read())
                    {
                       // serial = reader.GetInt64(0);
                        msisdn = reader.GetString(0);
                        //message = reader.GetString(2);

                        string insertvalues = "'" + msisdn + "','" + sender + "','" + textBox1.Text + "','0','" + engine + "'";
                        query = "Insert into penpalmessagesent (msisdn,sender,Message,flag,engine) values (" + insertvalues + ")";
                        UpdateQuery(query);
                        cnt10++;
                        messout = msisdn + " " + query;
                        AddEvent(messout);
                        if (cnt10 > 1)
                        {
                            System.Threading.Thread.Sleep(12000);
                            cnt10 = 0;

                        }

                    }
                    //update messagesentsingle

                }
            }
            MessageBox.Show("Done");

        }

        private void button5_Click(object sender, EventArgs e)
        {

                        var request = WebRequest.Create("https://onesignal.com/api/v1/notifications") as HttpWebRequest;
                        String mURL = "http://www.penpalafrica.com/penpal/assets/img/subscribers/2341/gallery/2341.jpg";

                        request.KeepAlive = true;
                        request.Method = "POST";
                        request.ContentType = "application/json; charset=utf-8";

                        request.Headers.Add("authorization", "Basic ZGY2MGIyNWUtOTJkMy00MDBlLWI5NDctYWVlZTU5M2NmNzA1");

                        byte[] byteArray = Encoding.UTF8.GetBytes("{"
                                                                + "\"app_id\": \"3ddfb68d-b5e8-4630-90ea-494229489c52\","
                                                                + "\"contents\": {\"en\": \"English Message\"},"
                                                                + "\"large_icon\": \"" + mURL + "\","
                                                                + "\"include_player_ids\": [\"0592058e-2c29-434a-b766-1c7137d1e8d8\"]}");

                        string responseContent = null;

                        try {
                            using (var writer = request.GetRequestStream()) {
                                writer.Write(byteArray, 0, byteArray.Length);
                            }

                            using (var response = request.GetResponse() as HttpWebResponse) {
                                using (var reader = new StreamReader(response.GetResponseStream())) {
                                    responseContent = reader.ReadToEnd();
                                }
                            }
                        }
                        catch (WebException ex) {
                            System.Diagnostics.Debug.WriteLine(ex.Message);
                            System.Diagnostics.Debug.WriteLine(new StreamReader(ex.Response.GetResponseStream()).ReadToEnd());
                        }

                        System.Diagnostics.Debug.WriteLine(responseContent);



        }

        private void button6_Click(object sender, EventArgs e)
        {


                                        var request = WebRequest.Create("https://onesignal.com/api/v1/notifications") as HttpWebRequest;
                                        String mURL ="http://www.penpalafrica.com/penpal/assets/img/subscribers/2341/gallery/2341.jpg";
                                        String oneSignal = "";
                                        String mess ="Just Testing";
                                        request.KeepAlive = true;
                                        request.Method = "POST";
                                        request.ContentType = "application/json; charset=utf-8";

                                        request.Headers.Add("authorization", "Basic NmIwMGJhMmMtZTRmZC00OWRhLWFkOTYtNDBlNWRlZmNhODEx");
                                        oneSignal = "{"
                                                                     + "\"app_id\": \"4cf9e2f1-2e0b-457c-94ca-a8de441895ca\","
                                                                                + "\"contents\": {\"en\": \""+mess+"\"},"

                                                                                + "\"large_icon\": \"" +mURL+ "\","

                                                                                + "\"included_segments\": [\"All\"]}";
                                        //String newMessage = "Test URL";




                                        byte[] byteArray = Encoding.UTF8.GetBytes(oneSignal);

                                    string responseContent = null;

                                    try {
                                        using (var writer = request.GetRequestStream()) {
                                            writer.Write(byteArray, 0, byteArray.Length);
                                        }

                                        using (var response = request.GetResponse() as HttpWebResponse) {
                                            using (var reader = new StreamReader(response.GetResponseStream())) {
                                                responseContent = reader.ReadToEnd();
                                            }
                                        }
                                    }
                                    catch (WebException ex) {
                                        System.Diagnostics.Debug.WriteLine(ex.Message);
                                        System.Diagnostics.Debug.WriteLine(new StreamReader(ex.Response.GetResponseStream()).ReadToEnd());
                                   }

                                    System.Diagnostics.Debug.WriteLine(responseContent);






        }


        public string getQuery1(string query)
        {
            string result = "#";
            //Database connection
            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)
            {
                MySqlCommand command2 = new MySqlCommand(query, connection2);
                connection2.Open();

                MySqlDataReader reader2 = command2.ExecuteReader();

                if (reader2.HasRows)
                {
                    while (reader2.Read())
                    {

                        result = reader2.GetString(0);
                    }
                }

            }
            connection2.Close();
            return result;
        }


        public void Update(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();
                    //if (reader2 == 0)
                    //{
                    //    timer1.Enabled = false;

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

                    //    }


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

        }



    }
    //main class ends here
}