using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;

namespace RichCreator.Utility.InputControl
{
    /// <summary>
    /// 串口连接类
    /// </summary>
    public class SerialPortConnect:IDisposable
    {
        private SerialPort serialPort;
        public Action<byte[]> DataReceiveCallback;
        private string comName;
        //private ManualResetEvent manualLock;

        public SerialPortConnect(string comName)
        {
            this.comName = comName;
            //this.dataReceiveCallback = dataReceiveCallback;
            //manualLock = new ManualResetEvent(false);
        }


        // Methods
        public Boolean Connect()
        {
            try
            {
                if (this.serialPort != null)
                {
                    if (this.serialPort.IsOpen)
                    {
                        return true;
                    }
                }
                else
                {
                    this.serialPort = new SerialPort();
                }
                this.serialPort.WriteTimeout = 1000;
                this.serialPort.PortName = comName;
                this.serialPort.BaudRate = 115200;
                this.serialPort.Parity = Parity.None;
                this.serialPort.StopBits = StopBits.One;
                this.serialPort.Open();
                this.serialPort.DataReceived += new SerialDataReceivedEventHandler(this.SerialPortDataReceived);
                return true;
            }
            catch (Exception)
            {
                return false;
            }
        }


        /// <summary>
        /// 关闭连接
        /// </summary>
        /// <returns></returns>
        public Boolean Disconnect()
        {
            if (this.serialPort == null)
            {
                return false;
            }
            if (this.serialPort.IsOpen)
            {
                this.serialPort.Close();
            }
            return true;
        }


        /// <summary>
        /// 串口状态
        /// </summary>
        public bool SerialPortStatus
        {
            get
            {
                if (this.serialPort == null)
                {
                    return false;
                }
                if (this.serialPort.IsOpen)
                {
                    return true;
                }
                return false;
            }
        }

        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="buf"></param>
        /// <param name="len"></param>
        /// <returns></returns>
        public Boolean Send(byte[] buf, int len)
        {
            if (this.serialPort == null)
            {
                //throw new Exception("串口不存在");
                return false;
            }
            if (!this.serialPort.IsOpen)
            {
                //throw new Exception("串口没打开");
                return false;
            }
            try
            {
                
                this.serialPort.Write(buf, 0, len);
                return true;
            }
            catch (Exception)
            {
                return false;
            }

        }



        /// <summary>
        /// 接收数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void SerialPortDataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            
            if (this.serialPort.IsOpen)
            {
                try
                {
                    if (this.serialPort.BytesToRead <= 0)
                    {
                        return;
                    }

                    byte[] buffer = new byte[this.serialPort.BytesToRead];
                    int num = this.serialPort.Read(buffer, 0, buffer.Length);

                    if (this.DataReceiveCallback != null)
                    {
                        this.DataReceiveCallback(buffer);
                    }
                }
                catch
                { }
            }

        }

        private bool isFinialize = false;
        public void Dispose()
        {
            Close();
        }

        public void Close()
        {
            if (!isFinialize)
            {
                if (serialPort != null)
                {
                    if (serialPort.IsOpen)
                    {
                        serialPort.Close();
                    }
                    serialPort = null;
                }

                //释放锁
                //this.manualLock.Close();
                GC.SuppressFinalize(this);
            }
        }
    }
}