using OnlineStore.Common;
using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading;

namespace OnlineStore.DeviceLibrary
{

    partial class ACServerManager
    {

        private static Dictionary<int, Dictionary<string, RegisterInfo>> LastDataMap = new Dictionary<int, Dictionary<string, RegisterInfo>>();

        //private static SerialBean bean = null;
        private static string strFromat = "{0:X2}";
        private static Dictionary<string, AcSerialBean> serialBeanMap = new Dictionary<string, AcSerialBean>();

        private static AcSerialBean GetSerialBean(string portName)
        {
            if (serialBeanMap.ContainsKey(portName))
            {
                return serialBeanMap[portName];
            }
            return null;
        }


        //public static void RunBlock(string portName, int slvAddr, int index)
        //{
        //    //运动
        //    byte[] data = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteRegisters, ACCMDManager.BlockNo, index.ToString(), 2);
        //    SendData(portName, data);
        //    Thread.Sleep(100);
        //    CloseSTB(portName, slvAddr);
        //    Thread.Sleep(100);
        //    OnlyOpenSTB(portName, slvAddr);
        //}
        public static void SendStrAndSleep(string portName, string str, int sleepS)
        {
            byte[] data = SerialBean.StringToByte(str);
            data[data.Length - 1] = 0x00;
            data[data.Length - 2] = 0x00;
            data = ACCMDManager.buildCheckData(data, data.Length - 2);
            SendData(portName, data);
            System.Threading.Thread.Sleep(sleepS);
        }
        public static void SendStr(string portName, string str)
        {
            byte[] data = SerialBean.StringToByte(str);
            data[data.Length - 1] = 0x00;
            data[data.Length - 2] = 0x00;
            data = ACCMDManager.buildCheckData(data, data.Length - 2);
            SendData(portName, data);
        }
        private static void DataReceived(string portName, object sender, SerialDataReceivedEventArgs e, byte[] bits)
        {
            string strSend = "";
            for (int i = 0; i < bits.Length; i++)
            {
                strSend += string.Format("{0:X2} ", bits[i]);
            }
            if (IsShowMsg)
            {
                LogUtil.info( "串口" + portName + " 收到数据：" + strSend + "");
            }
            string str = "";
            string strFromat = "{0:X2}";
            byte slvAddr = bits[0];
            int lenth = bits[2];
            byte cmd = bits[1];
            if (cmd.Equals(ACCMDManager.CMD_ReadRegisters) && bits.Length > 6)
            {
                if (PreReadAddr.Equals(ACCMDManager.TargetPostion))
                {
                    if (lenth == 4)
                    {
                        str = string.Format(strFromat, bits[5]) + string.Format(strFromat, bits[6]) + string.Format(strFromat, bits[3]) + string.Format(strFromat, bits[4]);
                        int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                        SaveData(portName, slvAddr, ACCMDManager.TargetPostion, value);
                    }
                }
                else if (PreReadAddr.Equals(ACCMDManager.ActualPosition))
                {
                    if (lenth == 4)
                    {
                        str = string.Format(strFromat, bits[5]) + string.Format(strFromat, bits[6]) + string.Format(strFromat, bits[3]) + string.Format(strFromat, bits[4]);
                        int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);

                        SaveData(portName, slvAddr, ACCMDManager.ActualPosition, value);
                    }
                }
                else
                {
                    for (int i = 3; i < 3 + lenth; i++)
                    {
                        str += string.Format("{0:X2} ", bits[i]);
                    }
                    str = str.Replace(" ", "");
                    int value = Convert.ToInt32(str, 16);
                    LogUtil.info("转换后结果：" + value + "");
                    //this.richTextBox1.AppendText("转换后结果：" + value + "");
                    //Console.WriteLine("转换后结果：" + value);
                }
                //MessageBox.Show("收到数据："+value);
            }
            else if (cmd.Equals(ACCMDManager.CMD_ReadCoil) && bits.Length >= 6)
            {
                if (PreReadCoilAddr.Equals(ACCMDManager.ServerOn_Addr))
                {
                    if (lenth == 1)
                    {
                        str = string.Format(strFromat, bits[3]);
                        int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                        SaveData(portName, slvAddr, ACCMDManager.ServerOn_Addr, value);
                    }
                }
                else
                if (PreReadCoilAddr.Equals(ACCMDManager.Alarm_Status))
                {
                    if (lenth == 1)
                    {
                        str = string.Format(strFromat, bits[3]);
                        int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                        SaveData(portName, slvAddr, ACCMDManager.Alarm_Status, value);
                    }
                }
                else if (PreReadCoilAddr.Equals(ACCMDManager.BUSYStatus))
                {
                    if (lenth == 1)
                    {
                        str = string.Format(strFromat, bits[3]);
                        int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                        SaveData(portName, slvAddr, ACCMDManager.BUSYStatus, value);
                    }
                }
                else if (PreReadCoilAddr.Equals(ACCMDManager.HOME_CMP_Status))
                {
                    if (lenth == 1)
                    {
                        str = string.Format(strFromat, bits[3]);
                        int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                        SaveData(portName, slvAddr, ACCMDManager.HOME_CMP_Status, value);
                    }
                }

            }
            if (strSend.Equals(""))
            {
                return;
            }
        }

        public static void SaveData(string portName, byte slvAddr, string regAddr, int value)
        {
            if (LastDataMap.ContainsKey(slvAddr))
            {
                if (LastDataMap[slvAddr].ContainsKey(regAddr))
                {
                    LastDataMap[slvAddr][regAddr] = new RegisterInfo(slvAddr, regAddr, value);
                }
                else
                {
                    LastDataMap[slvAddr].Add(regAddr, new RegisterInfo(slvAddr, regAddr, value));
                }
            }
            else
            {
                Dictionary<string, RegisterInfo> map = new Dictionary<string, RegisterInfo>();
                map.Add(regAddr, new RegisterInfo(slvAddr, regAddr, value));
                LastDataMap.Add(slvAddr, map);
            }
        }
        public static RegisterInfo GetData(string portName, byte slvAddr, string regAddr)
        {
            if (LastDataMap.ContainsKey(slvAddr))
            {
                if (LastDataMap[slvAddr].ContainsKey(regAddr))
                {
                    return LastDataMap[slvAddr][regAddr];
                }
            }
            return null;
        }

        public static void SendData(string portName, byte[] data, int reviceLength)
        {
            if (data == null)
            {
                return;
            }

            byte[] returnData = SendCommand(portName, data, 50, reviceLength);
            string strSend = "";
            for (int i = 0; i < returnData.Length; i++)
            {
                strSend += string.Format("{0:X2} ", returnData[i]);
            }
            if (IsShowMsg)
            {
                LogUtil.info( "串口" + portName + " 收到数据：" + strSend + "");
            }
        }
        public static void SendData(string portName, byte[] data)
        {
            if (data == null)
            {
                return;
            }
            byte[] returnData = SendCommand(portName, data, 50, 8);
            if (returnData != null)
            {
                string strSend = "";
                for (int i = 0; i < returnData.Length; i++)
                {
                    strSend += string.Format("{0:X2} ", returnData[i]);
                }
                if (IsShowMsg)
                {
                    LogUtil.info("串口" + portName + " 收到数据：" + strSend + "");
                }
            }
        }
        /// <summary>
        /// 发送数据并获取返回值
        /// </summary>
        /// <param name="data">发送的数据</param>
        /// <param name="outTime">超时时间</param>
        /// <returns>返回值的长度</returns>
        public static byte[] SendCommand(string portName, byte[] data, int outTime, int reviceLength)
        {
            if (outTime > 80)
            {
                outTime = 80;
            }
            byte[] returnData = null;

            try
            {
                if (data == null)
                {
                    return returnData;
                }
                string strSend = "";
                for (int i = 0; i < data.Length; i++)
                {
                    strSend += string.Format("{0:X2} ", data[i]);
                }
                if (strSend.Equals(""))
                {
                    return returnData;
                }
                if (IsShowMsg)
                {
                    LogUtil.info( "串口" + portName + " 写入数据：" + strSend + "");
                }
                AcSerialBean bean = GetSerialBean(portName);
                if (bean == null)
                {
                    LogUtil.debug("ACServerManager SendCommand  试图向未打开串口【" + portName + "】写入数据：" + strSend + "。");
                }
                else
                {
                    bean.SendCommand(data, ref returnData, outTime, reviceLength);
                }
            }
            catch (Exception ex)
            {
                LogUtil.info(ex.ToString());
            }
            return returnData;
        }


        public static void WriteData(string portName, int slvAddr, string addr, string data, byte cmd, int length)
        {
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, cmd, addr, data, length);
            SendData(portName, dataArray);
        }
        public static void SendStr(string portName, int slvAddr, string str)
        {
            //string str = txtSendStr.Text;
            byte[] data = SerialBean.StringToByte(str);
            data[data.Length - 1] = 0x00;
            data[data.Length - 2] = 0x00;
            data = ACCMDManager.buildCheckData(data, data.Length - 2);
            SendData(portName, data);
        }

        public static void Stop(string portName, int slvAddr)
        {
            //RunBlock(6);
            string addr = ACCMDManager.Stop_Addr;
            string data = "FF00";
            //byte cmd = 0x05;
            int length = 2;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);

            System.Threading.Thread.Sleep(1000);
            data = "0000";
            dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
        }

        public static void SuddenStop(string portName, int slvAddr)
        {
            // RunBlock(7);
            string addr = ACCMDManager.SDStop_Addr;
            string data = "FF00";
            //byte cmd = 0x05;

            int length = 2;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
            System.Threading.Thread.Sleep(1000);
            data = "0000";
            dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
        }


        public static void OpenAndCloseSTB(string portName, int slvAddr)
        {
            OnlyOpenSTB(portName, slvAddr);
            System.Threading.Thread.Sleep(100);
            CloseSTB(portName, slvAddr);
        }

        public static void OnlyOpenSTB(string portName, int slvAddr)
        {
            string addr = ACCMDManager.STB_Addr;
            string data = "FF00";
            int length = 2;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
        }
        public static void CloseSTB(string portName, int slvAddr)
        {
            string addr = ACCMDManager.STB_Addr;
            string data = "0000";
            int length = 2;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
        }

        public static void UpdateBlock(string portName, int slvAddr, string blockNum)
        {
            int preNum = GetAddrValue(portName, ACCMDManager.BlockNo);
            if (preNum.Equals(-1) || (!preNum.ToString().Equals(blockNum)))
            {
                byte[] data = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteRegisters, ACCMDManager.BlockNo, blockNum , 2);
                SendData(portName, data);
                int value = Convert.ToInt16(blockNum);
                UpdateAddrValue(portName, ACCMDManager.BlockNo, value);
                Thread.Sleep(SleepMSendons);
            }
        }

        public static void AlarmClear(string portName, int slvAddr)
        {
            string addr = ACCMDManager.Clear_Alarm_Addr;
            string data = "FF00";
            //byte cmd = 0x05;
            int length = 2;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
            System.Threading.Thread.Sleep(100);
            data = "0000";
            dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
        }
        public static void CloseAlarmClear(string portName, int slvAddr)
        {
            string addr = ACCMDManager.Clear_Alarm_Addr;
            string data = "0000";
            //byte cmd = 0x05;
            int length = 2;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_WriteCoil, addr, data, length);
            SendData(portName, dataArray);
        }

        private static string PreReadAddr = "";
        private static string PreReadCoilAddr = "";

        public static int GetRegisterData(string portName, byte[] reviceData, string Address)
        {
            if (reviceData != null && reviceData.Length > 0)
            {
                string strSend = "";
                for (int i = 0; i < reviceData.Length; i++)
                {
                    strSend += string.Format("{0:X2} ", reviceData[i]);
                }
                if (IsShowMsg)
                {
                    LogUtil.info( "串口" + portName + " 收到数据：" + strSend + "");
                }
                string strFromat = "{0:X2}";
                byte slvAddrR = reviceData[0];

                int lenth = reviceData[2];
                byte cmd = reviceData[1];
                if (cmd.Equals(ACCMDManager.CMD_ReadRegisters) && reviceData.Length > 6 && lenth == 4)
                {
                    string str = string.Format(strFromat, reviceData[5]) + string.Format(strFromat, reviceData[6]) + string.Format(strFromat, reviceData[3]) + string.Format(strFromat, reviceData[4]);
                    int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                    SaveData(portName, slvAddrR, Address, value);
                    return value;
                }
            }
            return -1;
        }
        public static int GetTargetPosition(string portName, int slvAddr)
        {
            PreReadAddr = ACCMDManager.TargetPostion;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_ReadRegisters, ACCMDManager.TargetPostion, "0000", 2);
            //  SendData(portName,dataArray);
            byte[] reviceData = SendCommand(portName, dataArray, 100, 9);

            return GetRegisterData(portName, reviceData, ACCMDManager.TargetPostion);
        }
        public static int GetActualtPosition(string portName, int slvAddr)
        {
            PreReadAddr = ACCMDManager.ActualPosition;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_ReadRegisters, ACCMDManager.ActualPosition, "0000", 2);
            //  SendData(portName,dataArray);
            byte[] reviceData = SendCommand(portName, dataArray, 100, 9);

            return GetRegisterData(portName, reviceData, ACCMDManager.ActualPosition);
        }

        public static int GetCoilData(string portName, byte[] reviceData, string Address)
        {
            if (reviceData != null && reviceData.Length > 0)
            {
                string strSend = "";
                for (int i = 0; i < reviceData.Length; i++)
                {
                    strSend += string.Format("{0:X2} ", reviceData[i]);
                }

                if (IsShowMsg)
                {
                    LogUtil.info( "串口" + portName + " 收到数据：" + strSend + "");
                }
                string strFromat = "{0:X2}";
                byte slvAddrR = reviceData[0];

                int lenth = reviceData[2];
                byte cmd = reviceData[1];
                if (cmd.Equals(ACCMDManager.CMD_ReadCoil) && reviceData.Length >= 6 && lenth == 1)
                {
                    string str = string.Format(strFromat, reviceData[3]);
                    int value = Convert.ToInt32(str.Trim().Replace(" ", ""), 16);
                    SaveData(portName, slvAddrR, Address, value);
                    return value;
                }
            }
            return -1;
        }
        public static int GetAlarmStatus(string portName, int slvAddr)
        {
            PreReadCoilAddr = ACCMDManager.Alarm_Status;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_ReadCoil, PreReadCoilAddr, "0000", 1);
            //SendData(portName,dataArray); 
            byte[] reviceData = SendCommand(portName, dataArray, 100, 6);
            return GetCoilData(portName, reviceData, PreReadCoilAddr);
        }

        public static int GetBusyStatus(string portName, int slvAddr)
        {
            PreReadCoilAddr = ACCMDManager.BUSYStatus;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_ReadCoil, ACCMDManager.BUSYStatus, "0000", 1);
            //SendData(portName,dataArray); 
            byte[] reviceData = SendCommand(portName, dataArray, 100, 6);
            return GetCoilData(portName, reviceData, ACCMDManager.BUSYStatus);
        }

        public static int GetHomeEndStatus(string portName, int slvAddr)
        {
            PreReadCoilAddr = ACCMDManager.HOME_CMP_Status;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_ReadCoil, ACCMDManager.HOME_CMP_Status, "0000", 1);
            //SendData(portName,dataArray); 
            byte[] reviceData = SendCommand(portName, dataArray, 100, 6);
            return GetCoilData(portName, reviceData, ACCMDManager.HOME_CMP_Status);
        }

        public static int GetHomeSingle(string portName, int slvAddr)
        {
            PreReadCoilAddr = ACCMDManager.Home_Single;
            byte[] dataArray = ACCMDManager.GetWriteData(slvAddr, ACCMDManager.CMD_ReadCoil, ACCMDManager.Home_Single, "0000", 1);
            byte[] reviceData = SendCommand(portName, dataArray, 100, 6);
            return GetCoilData(portName, reviceData, ACCMDManager.Home_Single);
        }

    }
    /// <summary>
    /// 记录最后一次获得的寄存器的值
    /// </summary>
    public class RegisterInfo
    {
        public RegisterInfo(int slv, string addr, int data)
        {
            this.SlvAddr = slv;
            this.RegisterAddr = addr;
            this.LastData = data;
            this.LastTime = new DateTime();
        }
        public int SlvAddr { get; set; }

        public string RegisterAddr { get; set; }

        public int LastData { get; set; }

        public DateTime LastTime { get; set; }
    }

}