CyberX8/Framework/SimulatorCore/Commons/TemperatureControllerSerialPortDevice.cs

using MECF.Framework.Simulator.Core.Driver;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MECF.Framework.Simulator.Core.Commons
{
    public class TemperatureControllerSerialPortDevice : BaseSerialSimulator
    {
        #region 常量
        private const string PORT_NAME = "com12";
        private const byte ADD_FLAG = 0x30;
        #endregion

        #region 内部变量
        /// <summary>
        /// 控制字字典
        /// </summary>
        private Dictionary<byte, string> dic = new Dictionary<byte, string>() 
        {
            { 0x05,"ENQ" },
            { 0x02,"STX" },
            { 0x03,"ETX" },
            { 0x06,"ACK" },
            { 0x0D,"CR" },
            { 0x01,"SOH" }
        };
        /// <summary>
        /// 命令字典
        /// </summary>
        private Dictionary<byte, string> comdic = new Dictionary<byte, string>()
        {
            { 0x31,"Target Temp" },
            { 0x32,"Internal" },
            { 0x33,"External" },
            { 0x34,"Alarm" },
            { 0x35,"Average" },
            { 0x36,"offset" },
            { 0x39,"control" },
            { 0x41,"PB" },
            { 0x42,"ARW" },
            { 0x43,"IConstant" },
            { 0x44,"DConstant" },
            { 0x45,"OutPutRatio" },
            { 0x46,"HeatingLimit" },
            { 0x47,"CoolingLimit" },
            { 0x48,"Saved" }
        };

        private double[] _reserviorValues = { 16.6, 16.6, 16.6, 16.6 };

        private double[] _heatValues = { 16.5, 16.5, 16.5, 16.5 };

        private double[] _targetValues = { 0, 0, 0, 0 };

        private int _controlOperation = 0;

        //private byte[] alarm = new byte[12] { 0,0,0,0,1,0,0,0,0,0,0,0};
        private byte[] alarm = new byte[3] {0x30,0x33,0x30};

        System.Timers.Timer[] _timers = new System.Timers.Timer[4];

        #endregion

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="portName"></param>
        /// <param name="type"></param>
        public TemperatureControllerSerialPortDevice(string port) : base(port, SerialType.BUFFER)
        {
            _timers[0] = new System.Timers.Timer(50);
            _timers[0].Elapsed += Timer_Elapsed0;
            _timers[1] = new System.Timers.Timer(50);
            _timers[1].Elapsed += Timer_Elapsed1;
            _timers[2] = new System.Timers.Timer(50);
            _timers[2].Elapsed += Timer_Elapsed2;
            _timers[3] = new System.Timers.Timer(50);
            _timers[3].Elapsed += Timer_Elapsed3;
        }
        /// <summary>
        /// TC1-1的调温
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Timer_Elapsed0(object sender, System.Timers.ElapsedEventArgs e)
        {
            if (Math.Abs(_heatValues[0] - _targetValues[0]) >=0.2)
            {
                //内部调温
                if(_heatValues[0] < _targetValues[0])
                {
                    _heatValues[0] += 0.1;
                }
                else
                {
                    _heatValues[0] -= 0.1;
                }
                //外部调温
                if(_reserviorValues[0] < _targetValues[0])
                {
                    _reserviorValues[0] += 0.1;
                }
                else
                {
                    _reserviorValues[0] -= 0.1;
                }
            }
            else
            {
                _timers[0].Stop();
            }
        }
        /// <summary>
        /// TC1-2的调温
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Timer_Elapsed1(object sender, System.Timers.ElapsedEventArgs e)
        {
            if (Math.Abs(_heatValues[1] - _targetValues[1]) >= 0.2)
            {
                //内部调温
                if (_heatValues[1] < _targetValues[1])
                {
                    _heatValues[1] += 0.1;
                }
                else
                {
                    _heatValues[1] -= 0.1;
                }
                //外部调温
                if (_reserviorValues[1] < _targetValues[1])
                {
                    _reserviorValues[1] += 0.1;
                }
                else
                {
                    _reserviorValues[1] -= 0.1;
                }
            }
            else
            {
                _timers[1].Stop();
            }
        }
        /// <summary>
        /// TC1-3的调温
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Timer_Elapsed2(object sender, System.Timers.ElapsedEventArgs e)
        {
            if (Math.Abs(_heatValues[2] - _targetValues[2]) >= 0.2)
            {
                //内部调温
                if (_heatValues[2] < _targetValues[2])
                {
                    _heatValues[2] += 0.1;
                }
                else
                {
                    _heatValues[2] -= 0.1;
                }
                //外部调温
                if (_reserviorValues[2] < _targetValues[2])
                {
                    _reserviorValues[2] += 0.1;
                }
                else
                {
                    _reserviorValues[2] -= 0.1;
                }
            }
            else
            {
                _timers[2].Stop();
            }
        }
        /// <summary>
        /// TC1-4的调温
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Timer_Elapsed3(object sender, System.Timers.ElapsedEventArgs e)
        {
            if (Math.Abs(_heatValues[3] - _targetValues[3]) >= 0.2)
            {
                //内部调温
                if (_heatValues[3] < _targetValues[3])
                {
                    _heatValues[3] += 0.1;
                }
                else
                {
                    _heatValues[3] -= 0.1;
                }
                //外部调温
                if (_reserviorValues[3] < _targetValues[3])
                {
                    _reserviorValues[3] += 0.1;
                }
                else
                {
                    _reserviorValues[3] -= 0.1;
                }
            }
            else
            {
                _timers[3].Stop();
            }
        }
        protected override string MessageConvert(byte[] byt)
        {
            string str = "";
            for(int i=0;i<byt.Length;i++)
            {
                byte item = byt[i];
                if(dic.ContainsKey(item))
                {
                    str += dic[item];
                }
                else if(i==1)
                {
                    str += (item - 0x30).ToString("D2");
                }
                else if(i==3&&comdic.ContainsKey(item))
                {
                    str += comdic[item];
                }
                else
                {
                    str += item.ToString("X2");
                }
                str += " ";
            }
            return str;
        }

        protected override void ProcessMessageBuffer(byte[] data)
        {
            if (data[0] == 0x06 && data[2]==0x0D&&data.Length>7)
            {
                byte[] byt = new byte[data.Length - 3];
                Array.Copy(data, 3, byt, 0, byt.Length);
                ProcessNormalCommand(byt);
            }
            else if (data[0] == 0x01)
            {
                ProcessNormalCommand(data);
            }
        }

        private void ProcessNormalCommand(byte[] data)
        {
            if (data[0] == 0x01 && data[data.Length-1]==0x0D)
            {
                if (data.Length == 7)
                {
                    ProcessReadCommand(data);
                }
                else if (data.Length > 7)
                {
                    ProcessSetCommand(data);
                }
            }
        }

        private void ProcessReadCommand(byte[] data)
        {
            switch(data[3])
            {
                case 0x31:
                    ReadTargetValue(data); 
                    break;
                case 0x32:
                    ReadReserviorValue(data);
                    break;
                case 0x33:
                    ReadHeatValue(data); 
                    break;
                case 0x34:
                    ReadAlarmValue(data);
                    break;
                case 0x39:
                    ReadControlOperationValue(data);
                    break;
            }
        }

        private void ProcessSetCommand(byte[] data)
        {
            switch(data[3])
            {
                case 0x31:
                    _targetValues[data[1] - ADD_FLAG - 1] = (data[4] - ADD_FLAG) * 10 + (data[5] - ADD_FLAG) + (data[6]-ADD_FLAG)*0.1;
                    _timers[data[1] - ADD_FLAG -1].Start();
                    break;
                case 0x39:
                    _controlOperation = data[7] - ADD_FLAG;
                    if(_controlOperation == 0)
                    {
                        //停止调温
                        _timers[data[1] - ADD_FLAG - 1].Stop();
                    }
                    else
                    {
                        //继续调温
                        _timers[data[1] - ADD_FLAG - 1].Start();
                    }
                    break;
            }
            WriteConfirmData(data[1]);
        }
        /// <summary>
        /// 回复确认
        /// </summary>
        /// <param name="id"></param>
        private void WriteConfirmData(byte id)
        {
            byte[] confirm = new byte[3];
            confirm[0] = 0x06;
            confirm[1] = id;
            confirm[2] = 0x0d;
            WriteBuffer(confirm);
        }
        private void ReadTargetValue(byte[] data)
        {
            byte[] byt = new byte[12];
            byt[0] = data[0];
            byt[1] = data[1];
            byt[2] = 0x02;
            byt[3] = data[3];
            byte[] decadeByte = GetDecadeBytes(_targetValues[data[1] - ADD_FLAG - 1]);
            Array.Copy(decadeByte, 0, byt, 4, decadeByte.Length);
            byt[5 + decadeByte.Length] = 0;
            byt[6 + decadeByte.Length] = 0;
            byt[11] = 0x0D;

            WriteBuffer(byt);
        }
        private void ReadReserviorValue(byte[] data)
        { 
            byte[] byt = new byte[12];
            byt[0] = data[0];
            byt[1] = data[1];
            byt[2] = 0x02;
            byt[3] = data[3];
            byte[] decadeByte = GetDecadeBytes(_reserviorValues[data[1] - ADD_FLAG - 1]);
            Array.Copy(decadeByte, 0, byt, 4, decadeByte.Length);
            byt[5 + decadeByte.Length] = 0;
            byt[6 + decadeByte.Length] = 0;
            byt[11] = 0x0D;

            WriteBuffer(byt);
        }
        private void ReadHeatValue(byte[] data)
        {
            byte[] byt = new byte[12];
            byt[0] = data[0];
            byt[1] = data[1];
            byt[2] = 0x02;
            byt[3] = data[3];
            byte[] decadeByte = GetDecadeBytes(_heatValues[data[1] - ADD_FLAG - 1]);
            Array.Copy(decadeByte, 0, byt, 4, decadeByte.Length);
            byt[5 + decadeByte.Length] = 0;
            byt[6 + decadeByte.Length] = 0;
            byt[11] = 0x0D;

            WriteBuffer(byt);
        }

        private void ReadControlOperationValue(byte[] data)
        {
            byte[] byt = new byte[12];
            byt[0] = data[0];
            byt[1] = data[1];
            byt[2] = 0x02;
            byt[3] = data[3];
            byte[] decadeByte = GetKilloBytes(_controlOperation);
            Array.Copy(decadeByte, 0, byt, 4, decadeByte.Length);
            byt[5 + decadeByte.Length] = 0;
            byt[6 + decadeByte.Length] = 0;
            byt[11] = 0x0D;

            WriteBuffer(byt);
        }
        private void ReadAlarmValue(byte[] data)
        {
            byte[] byt = new byte[8+alarm.Length];
            byt[0] = data[0];
            byt[1] = data[1];
            byt[2] = 0x02;
            byt[3] = data[3];
            Array.Copy(alarm, 0, byt, 4, alarm.Length);
            byt[5 + alarm.Length] = 0;
            byt[6 + alarm.Length] = 0;
            byt[7+alarm.Length] = 0x0D;

            WriteBuffer(byt);
        }
        /// <summary>
        /// 获取温度数组(10|1|0.1|0.01)
        /// </summary>
        /// <param name="temperature"></param>
        /// <returns></returns>
        private byte[] GetDecadeBytes(double temperature)
        {
            byte decade = GetSendByteData((byte)Math.Floor(temperature / 10));
            byte unit = GetSendByteData((byte)Math.Floor(temperature % 10));
            byte digital = GetSendByteData((byte)Math.Floor(temperature * 10 % 10));
            return new byte[4] { decade, unit, digital, ADD_FLAG };
        }

        /// <summary>
        /// 获取千级数组(1000|100|10|1)
        /// </summary>
        /// <param name="temperature"></param>
        /// <returns></returns>
        private byte[] GetKilloBytes(double temperature)
        {
            byte kilo = GetSendByteData((byte)Math.Floor(temperature / 1000));
            byte hundred = GetSendByteData((byte)Math.Floor(temperature % 1000/100));
            byte decade = GetSendByteData((byte)Math.Floor(temperature % 100 / 10));
            byte unit = GetSendByteData((byte)Math.Floor(temperature % 10));
            return new byte[4] { kilo, hundred, decade, unit };
        }

        /// <summary>
        /// 获取发送位数据
        /// </summary>
        /// <param name="originalData"></param>
        /// <returns></returns>
        private byte GetSendByteData(byte originalData)
        {
            return (byte)(ADD_FLAG + originalData);
        }

        
        
    }
}