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.IO;
using System.Net.Sockets;
using System.Net;
using System.Threading;
//using System.Data.SqlClient;
using System.Net.NetworkInformation;
using System.Runtime.InteropServices;
using System.Windows;

namespace Peredacha
{
    public partial class Form1 : Form
    {
        String IP;
        int combo;
        public Form1()
        {
            InitializeComponent();
            //Создаем поток для приема сообщений
            new Thread(new ThreadStart(Receiver)).Start();
            new Thread(new ThreadStart(FileReceiver)).Start();
        }
        //Метод потока
        protected void Receiver()
        {
            //Создаем Listener на порт "по умолчанию"
            TcpListener Listen = new TcpListener(7000);
            //Начинаем прослушку
            Listen.Start();
            //и заведем заранее сокет
            Socket ReceiveSocket;
            while (true)
            {
                try
                {
                    //Пришло сообщение
                    ReceiveSocket = Listen.AcceptSocket();
                    Byte[] Receive = new Byte[256];
                    //Читать сообщение будем в поток
                    using (MemoryStream MessageR = new MemoryStream())
                    {
                        //Количество считанных байт
                        Int32 ReceivedBytes;
                        do
                        {//Собственно читаем
                            ReceivedBytes = ReceiveSocket.Receive(Receive, Receive.Length, 0);
                            //и записываем в поток
                            MessageR.Write(Receive, 0, ReceivedBytes);
                            //Читаем до тех пор, пока в очереди не останется данных
                        } while (ReceiveSocket.Available > 0);
                        //Добавляем изменения в ChatBox
                        ChatBox.BeginInvoke(AcceptDelegate, new object[] { "Получаю: " + Encoding.Default.GetString(MessageR.ToArray()), ChatBox });

                    }
                }
                catch (System.Exception ex)
                {
                    MessageBox.Show(ex.Message);
                }

            }
        }

        //Метод потока
        protected void FileReceiver()
        {
            //Создаем Listener на порт "по умолчанию"
            TcpListener Listen = new TcpListener(6999);
            //Начинаем прослушку
            Listen.Start();
            //и заведем заранее сокет
            Socket ReceiveSocket;
            while (true)
            {
                try
                {
                    string name;
                    //Пришло сообщение
                    ReceiveSocket = Listen.AcceptSocket();
                    Byte[] Receive = new Byte[256];
                    //Читать сообщение будем в поток
                    using (MemoryStream MessageR = new MemoryStream())
                    {

                        //Количество считанных байт
                        Int32 ReceivedBytes;
                        Int32 Firest256Bytes = 0;
                        String FilePath = "";
                        do
                        {//Собственно читаем
                            ReceivedBytes = ReceiveSocket.Receive(Receive, Receive.Length, 0);
                            //Разбираем первые 256 байт
                            if (Firest256Bytes < 256)
                            {
                                Firest256Bytes += ReceivedBytes;
                                Byte[] ToStr = Receive;
                                //Учтем, что может возникнуть ситуация, когда они не могу передаться "сразу" все
                                if (Firest256Bytes > 256)
                                {
                                    Int32 Start = Firest256Bytes - ReceivedBytes;
                                    Int32 CountToGet = 256 - Start;
                                    Firest256Bytes = 256;
                                    //В случае если было принято >256 байт (двумя сообщениями к примеру)
                                    //Остаток (до 256) записываем в "путь файла"
                                    ToStr = Receive.Take(CountToGet).ToArray();
                                    //А остальную часть - в будующий файл
                                    Receive = Receive.Skip(CountToGet).ToArray();
                                    MessageR.Write(Receive, 0, ReceivedBytes);
                                }
                                //Накапливаем имя файла
                                FilePath += Encoding.Default.GetString(ToStr);
                            }
                            else

                                //и записываем в поток
                                MessageR.Write(Receive, 0, ReceivedBytes);
                            //Читаем до тех пор, пока в очереди не останется данных
                        } while (ReceivedBytes == Receive.Length);
                        //Убираем лишние байты
                        String resFilePath = FilePath.Substring(0, FilePath.IndexOf(''));
                        using (var File = new FileStream(resFilePath, FileMode.Create))
                        {//Записываем в файл
                            File.Write(MessageR.ToArray(), 0, MessageR.ToArray().Length);
                        }//Уведомим пользователя
                        ChatBox.BeginInvoke(AcceptDelegate, new object[] { "Получено: " + resFilePath, ChatBox });
                        name = resFilePath;
                    }
                /*   DataRow workRow = bD1DataSet.Tables[0].NewRow();//BD1DataSet1.Tables[0].NewRow();
                    workRow["id"] = 1;
                    workRow["data"] = System.DateTime.Now.ToLongDateString();
                    workRow["time"] = System.DateTime.Now.ToLongTimeString();
                    workRow["nazv"] = name;
                    bD1DataSet.Tables[0].Rows.Add(workRow);
                    this.Validate();
                    this.ipadressBindingSource.EndEdit();
                    this.tableAdapterManager1.UpdateAll(this.bD1DataSet);*/
}
                catch (System.Exception ex)
                {
                    MessageBox.Show(ex.Message);
                }

            }
        }

        /// <summary>
        /// Отправляет сообщение в потоке на IP, заданный в контроле IP
        /// </summary>
        /// <param name="Message">Передаваемое сообщение</param>
        void ThreadSend(object Message)
        {
            try
            {
                //Проверяем входной объект на соответствие строке
                String MessageText = "";
                if (Message is String)
                {
                    MessageText = Message as String;
                }
                else
                    throw new Exception("На вход необходимо подавать строку");

                Byte[] SendBytes = Encoding.Default.GetBytes(MessageText);
                //Создаем сокет, коннектимся
                IPEndPoint EndPoint = new IPEndPoint(IPAddress.Parse(IP), 7000);
                Socket Connector = new Socket(EndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
                Connector.Connect(EndPoint);
                Connector.Send(SendBytes);
                Connector.Close();
                //Изменяем поле сообщений (уведомляем, что отправили сообщение)

                ChatBox.BeginInvoke(AcceptDelegate, new object[] { "Отправлено " + MessageText, ChatBox });
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }

        }

        //Делегат доступа к контролам формы
        delegate void SendMsg(String Text, RichTextBox Rtb);

        SendMsg AcceptDelegate = (String Text, RichTextBox Rtb) =>
        {
            Rtb.Text += Text + "n";
        };

        private void button1_Click(object sender, EventArgs e)
        {
            IP = comboBox1.Text;
            Ping ping = new Ping();
            PingReply reply = ping.Send(IP);
            if (reply.Status != IPStatus.Success)
            {
                MessageBox.Show("Не удаётся подключиться!");
                button2.Enabled = false;
            }
            else {
                button2.Enabled = true;
                //Отправляем файл
                //Добавим на форму OpenFileDialog и вызовем его
                if (openFileDialog1.ShowDialog() == DialogResult.OK)
                {
                    //Коннектимся
                    IPEndPoint EndPoint = new IPEndPoint(IPAddress.Parse(IP), 6999);
                    Socket Connector = new Socket(EndPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
                    Connector.Connect(EndPoint);
                    //Получаем имя из полного пути к файлу
                    StringBuilder FileName = new StringBuilder(openFileDialog1.FileName);
                    //Выделяем имя файла
                    int index = FileName.Length - 1;
                    while (FileName[index] != '\' && FileName[index] != '/')
                    {
                        index--;
                    }
                    //Получаем имя файла
                    String resFileName = "";
                    for (int i = index + 1; i < FileName.Length; i++)
                        resFileName += FileName[i];
                    //Записываем в лист
                    List<Byte> First256Bytes = Encoding.Default.GetBytes(resFileName).ToList();
                    Int32 Diff = 256 - First256Bytes.Count;
                    //Остаток заполняем нулями
                    for (int i = 0; i < Diff; i++)
                        First256Bytes.Add(0);
                    //Начинаем отправку данных
                     System.IO.FileInfo file = new System.IO.FileInfo(openFileDialog1.FileName);
                      long size = file.Length;
                    Byte[] ReadedBytes = new Byte[256];
                    using (var FileStream = new FileStream(openFileDialog1.FileName, FileMode.Open))
                    {
                        using (var Reader = new BinaryReader(FileStream))
                        {
                            Int32 CurrentReadedBytesCount;
                            //Вначале отправим название файла
                            Connector.Send(First256Bytes.ToArray());
                            do
                            {
                                //Затем по частям - файл
                                CurrentReadedBytesCount = Reader.Read(ReadedBytes, 0, ReadedBytes.Length);
                                Connector.Send(ReadedBytes, CurrentReadedBytesCount, SocketFlags.None);
                            }
                            while (CurrentReadedBytesCount == ReadedBytes.Length);
                        }
                    }
                    //Завершаем передачу данных
                    Connector.Close();

                }



            }
        }

        private void button2_Click(object sender, EventArgs e)
        {
            // переместить на клавишу отправки связать с progressBar
           // System.IO.FileInfo file = new System.IO.FileInfo(openFileDialog1.FileName);
          //  long size = file.Length;
           // MessageBox.Show(size.ToString()); // для проверки вывода размера файла
            new Thread(new ParameterizedThreadStart(ThreadSend)).Start("Получение"); //otpravka
        }

        private void Form1_FormClosed(object sender, FormClosedEventArgs e)
        {
            Environment.Exit(0);
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            // TODO: данная строка кода позволяет загрузить данные в таблицу "bD1DataSet.dannie". При необходимости она может быть перемещена или удалена.
            this.dannieTableAdapter.Fill(this.bD1DataSet.dannie);
            // TODO: данная строка кода позволяет загрузить данные в таблицу "bD1DataSet.ip_adress". При необходимости она может быть перемещена или удалена.
            this.ip_adressTableAdapter.Fill(this.bD1DataSet.ip_adress);

        }

        private void button3_Click(object sender, EventArgs e)
        {
            panel2.Visible = false;
        }

        private void button4_Click(object sender, EventArgs e)
        {
            String stro;
            combo = comboBox1.Items.Count;
            combo = combo + 1;
            stro = IP1.Text + "." + IP2.Text + "." + IP3.Text + "." + IP4.Text;
            bD1DataSet.Tables[1].Rows.Add(combo, textBox1.Text, stro);
            this.Validate();
            this.ipadressBindingSource.EndEdit();
            this.tableAdapterManager1.UpdateAll(this.bD1DataSet);
            panel2.Visible = false;
            panel1.Visible = true;
        }

        private void добавитьКомпьютерToolStripMenuItem_Click(object sender, EventArgs e)
        {
            panel1.Visible = false;
            panel2.Visible = true;
            panel3.Visible = false;
        }

        private void посмотретьВсеКомпьютерыToolStripMenuItem_Click(object sender, EventArgs e)
        {
            // Form2 f = new Form2();
            //f.Show();
            panel3.Visible = true;
            panel1.Visible = false;
            panel2.Visible = false;
            dannieDataGridView.Visible = false;
            ip_adressDataGridView.Visible = true;
            bindingNavigator1.Visible = true;
            bindingNavigator2.Visible = false;
        }

        private void button3_Click_1(object sender, EventArgs e)
        {
            panel2.Visible = false;
            IP1.Text = ""; IP2.Text = ""; IP3.Text = ""; IP4.Text = "";
            textBox1.Text = "";
        }

        private void IP1_TextChanged(object sender, EventArgs e)
        {
            String a;
            int f;
            a = IP1.Text;
            try
            {
                f = int.Parse(a);
                for (int i = 0; i <= 10; i++)
                {
                    if (f == i) { a = i.ToString(); }
                }
            }
            catch
            {
                if (IP1.Text != "") { MessageBox.Show("Не верный символ!"); IP1.Text = ""; }
            }
        }

        private void IP2_TextChanged(object sender, EventArgs e)
        {
            String a;
            int f;
            a = IP2.Text;
            try
            {
                f = int.Parse(a);
                for (int i = 0; i <= 10; i++)
                {
                    if (f == i) { a = i.ToString(); }
                }
            }
            catch
            {
                if (IP2.Text != "") { MessageBox.Show("Не верный символ!"); IP2.Text = ""; }
            }
        }

        private void IP3_TextChanged(object sender, EventArgs e)
        {
            String a;
            int f;
            a = IP3.Text;
            try
            {
                f = int.Parse(a);
                for (int i = 0; i <= 10; i++)
                {
                    if (f == i) { a = i.ToString(); }
                }
            }
            catch
            {
                if (IP3.Text != "") { MessageBox.Show("Не верный символ!"); IP3.Text = ""; }
            }
        }

        private void IP4_TextChanged(object sender, EventArgs e)
        {
            String a;
            int f;
            a = IP4.Text;
            try
            {
                f = int.Parse(a);
                for (int i = 0; i <= 10; i++)
                {
                    if (f == i) { a = i.ToString(); }
                }
            }
            catch
            {
                if (IP4.Text != "") { MessageBox.Show("Не верный символ!"); IP4.Text = ""; }
            }
        }

        private void button5_Click(object sender, EventArgs e)
        {
        }

        private void button6_Click(object sender, EventArgs e)
        {
            panel3.Visible = false;
            panel2.Visible = false;
            panel1.Visible = true;
        }

        private void посмотретьФайлыToolStripMenuItem_Click(object sender, EventArgs e)
        {
            panel3.Visible = true;
            panel1.Visible = false;
            panel2.Visible = false;
            dannieDataGridView.Visible = true;
            ip_adressDataGridView.Visible = false;
            bindingNavigator1.Visible = false;
            bindingNavigator2.Visible = true;
        }

        private void bindingNavigator1_RefreshItems(object sender, EventArgs e)
        {

        }

        private void panel3_Paint(object sender, PaintEventArgs e)
        {

        }

        private void progressBar1_Click(object sender, EventArgs e)
        {

        }

        private void button6_Click_1(object sender, EventArgs e)
        {
            panel3.Visible = false;
            panel2.Visible = false;
            panel1.Visible = true;
        }

        private void comboBox1_KeyPress(object sender, KeyPressEventArgs e)
        {

        }
    }
}

Byte[] ReadedBytes = new Byte[256];

Byte[] ReadedBytes = File.ReadAllBytes(path);