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.Windows.Forms;
using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.IO;
using System.Collections;
using System.Drawing.Imaging;
using System.Xml;

namespace SocketClient
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        #region 参数声明
        /// <summary>
        /// 根据IP:Port 存储值

        /// </summary>
        static Dictionary<string, ServiceState> dic_ip = new Dictionary<string, ServiceState>();
        /// <summary>
        /// 客户端socket
        /// </summary>
        Socket c_socket;

        Thread th_socket;

        int ConnectionResult = -2;
        #endregion

        /// <summary>
        /// 开启Scoket连接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_StartSocket_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrWhiteSpace(this.txt_ip.Text.Trim()) && string.IsNullOrWhiteSpace(this.txt_port.Text.Trim()) && !string.IsNullOrWhiteSpace(this.txt_Monitor.Text.Trim()))
            {
                MessageBox.Show("输入不符合或已经连接");
                return;
            }
            try
            {
                this.txt_ip.Enabled = false;
                this.txt_port.Enabled = false;
                Start();
                th_socket = new Thread(MonitorSocker);
                th_socket.IsBackground = true;
                th_socket.Start();
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message + " " + ex.StackTrace);
                this.txt_ip.Enabled = true;
                this.txt_port.Enabled = true;
            }
        }

        //监听Socket
        void MonitorSocker()
        {
            while (true)
            {
                if (ConnectionResult != 0 && ConnectionResult != -2)//通过错误码判断
                {
                    Start();
                    this.BeginInvoke((MethodInvoker)delegate ()
                    {
                        this.label3.Text = "重连中..";
                        this.txt_Monitor.Text = "errorCode" + ConnectionResult.ToString();
                    });
                    dic_ip = new Dictionary<string, ServiceState>();
                }
                Thread.Sleep(1000);
            }
        }

        /// <summary>
        /// 关闭Socket连接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_StopSocket_Click(object sender, EventArgs e)
        {
            Stop();
        }

        /// <summary>
        /// 发送文本消息

        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_SendMes_Click(object sender, EventArgs e)
        {
            try
            {
                SendSocket send = new SocketClient.SendSocket()
                {
                    Message = this.txt_mes.Text.Trim(),
                };
                Send(dic_ip[this.txt_Monitor.Text.Trim()].serviceSocket, send.ToArray());
                this.txt_mes.Text = "";
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message + " " + ex.StackTrace);
            }
        }

        /// <summary>
        /// 发送震动

        /// </summary>
        private void btn_SendShake_Click(object sender, EventArgs e)
        {
            SendSocket send = new SocketClient.SendSocket()
            {
                SendShake = true,
                Message = "震动",
            };
            Send(dic_ip[this.txt_Monitor.Text.Trim()].serviceSocket, send.ToArray());
        }

        /// <summary>
        /// 发送图片数据

        /// </summary>
        /// <param name="sender"></param>