using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using Common;
using Dao;
using RCUHost.Protocols;
using CommonEntity;

namespace RCUHost.Implement
{
    public abstract class GenericReceiverBase : IReceiver
    {

        #region Static Memberss

        private static log4net.ILog logger = log4net.LogManager.GetLogger(typeof(GenericReceiverBase));
        private static readonly Object _locker = new object();
        protected static ushort frameNo = 0;

        #endregion

        #region Privates Properties

        private IHostServer hostServer;
        private ISysSettingRepository sysSettingRepository;
        public ISysSystemLogsRepository SysSystemLogsRepository { get; set; }
        /// <summary>
        /// 服务器通信IP
        /// </summary>
        private string messageIP = "0.0.0.0";
        /// <summary>
        /// 服务器通信端口
        /// </summary>
        private int messagePort = 3389;
        /// <summary>
        /// 组播地址
        /// </summary>
        private string multicastIP = "239.7.8.9";
        /// <summary>
        /// RCU主机通信端口，组播端口
        /// </summary>
        private int mulitcastPort = 3341;
        private string ftpServer = "106.75.37.225";
        private ushort ftpPort = 21;
        private string ftpName = "blw";
        private string ftpPassword = "blw@123";


        #endregion

        #region Public Properties

        public IHostServer HostServer
        {
            get { return this.hostServer; }
            set
            {
                this.hostServer = value;
                //this.hostServer.BeforeStart += new EventHandler(hostServer_BeforeStart);
                //this.hostServer.AfterStart += new EventHandler(hostServer_AfterStart);
            }
        }
        public ISysSettingRepository SysSettingRepository
        {
            get { return this.sysSettingRepository; }
            set
            {
                this.sysSettingRepository = value;
                this.multicastIP = SysSettingRepository.GetValue("MulticastIP").ToString();
                this.mulitcastPort = Convert.ToInt32(SysSettingRepository.GetValue("MulticastPort"));
                this.messageIP = SysSettingRepository.GetValue("MessageIP").ToString();
                this.messagePort = Convert.ToInt32(SysSettingRepository.GetValue("MessagePort"));

                this.ftpServer = SysSettingRepository.GetValue("FTPServer").ToString();
                this.ftpPort = Convert.ToUInt16(SysSettingRepository.GetValue("FTPPort"));
                this.ftpName = SysSettingRepository.GetValue("FTPName").ToString();
                this.ftpPassword = SysSettingRepository.GetValue("FTPPassword").ToString();
            }
        }

        /// <summary>
        /// 服务器通信IP，默认 0.0.0.0
        /// </summary>
        public string MessageIP
        {
            get { return this.messageIP; }
        }
        /// <summary>
        /// 服务器通信端口，默认3389
        /// </summary>
        public int MessagePort
        {
            get { return this.messagePort; }
        }
        /// <summary>
        /// 组播地址，默认 239.7.8.9
        /// </summary>
        public string MulticastIP
        {
            get { return this.multicastIP; }
        }
        /// <summary>
        /// RCU主机通信端口，组播端口，默认 3341
        /// </summary>
        public int MulticastPort
        {
            get { return this.mulitcastPort; }
        }
        public string FTPServer
        {
            get { return this.ftpServer; }
        }
        public ushort FTPPort
        {
            get { return this.ftpPort; }
        }
        public string FTPName
        {
            get { return this.ftpName; }
        }
        public string FTPPassword
        {
            get { return this.ftpPassword; }
        }
        /// <summary>
        /// 命令类型
        /// </summary>
        public abstract CommandType CommandType { get; }

        #endregion

        /// <summary>
        /// 处理数据
        /// </summary>
        /// <param name="context"></param>
        public virtual void Process(ReceiverContext context)
        {

        }

        public static bool DealWwith(ReceiverContext context)
        {
            string HostNumberOnly = context.SystemHeader.Value.HostNumber.ToString();
            var UUU = context.SystemHeader.Value;
            string IP_PORTStr = context.RemoteEndPoint.ToString();
            if (UUU.CmdType == 0x02)
            {
                //如果公告的帧号和要处理的不一致就直接返回
                //ushort CurrentFrameNO = context.SystemHeader.Value.FrameNo;
                //string PublicPop = CacheKey.PublicKeyboard + "_" + IP_PORTStr;
                //object ooo = MemoryCacheHelper.Get(PublicPop);
                //if (ooo != null)
                //{
                //    ushort Newlast = Convert.ToUInt16(ooo);
                //    if (Newlast != CurrentFrameNO)
                //    {
                //        return false;
                //    }
                //}
                //如果超过2秒就不再处理了
                //string ShiJianLanJie = CacheKey.SyncTimeIntercept + "_" + HostNumberOnly;
                string ShiJianLanJie = CacheKey.TimeIntercept + "_" + HostNumberOnly;
                object VVV = MemoryCacheHelper.Get(ShiJianLanJie);
                if (VVV == null)
                {
                    string hotelCode = context.SystemHeader.Value.HostNumber.ToHotelCode().ToString();//获取酒店编码
                    string RegisterKey1 = "RoomStatusTimeOutDrop";
                    RCUHost.RCUHostCommon.tools.LanJieData(RegisterKey1, hotelCode);
                    return false;
                }
            }
            return true;
        }
        /// <summary>
        /// 获取下一个帧号：小于32767
        /// </summary>
        /// <returns></returns>
        protected ushort GetNextFrameNo()
        {
            lock (_locker)
            {
                if (frameNo >= 0x7EFF)//32767
                {
                    frameNo = 0;
                }
                else
                {
                    frameNo++;
                }
            }
            return frameNo;
        }
        /// <summary>
        /// HostServer 启动之前调用
        /// </summary>
        /// <param name="hostServer"></param>
        protected virtual void HostServer_BeforeStart(HostServer hostServer)
        {
        }
        /// <summary>
        /// HostServer 启动之后调用
        /// </summary>
        /// <param name="hostServer"></param>
        protected virtual void HostServer_AfterStart(HostServer hostServer)
        {
        }
        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="data"></param>
        /// <param name="hostNumber"></param>
        protected void Send(byte[] data, string hostNumber, string mac)
        {
            string ipAndPort = CSRedisCacheHelper.Get<string>(hostNumber, mac);
            if (!string.IsNullOrEmpty(ipAndPort))
            {
                //if (HostServer!=null)
                //{
                //    logger.Error("1111111111");
                //}
                //else
                //{
                //    logger.Error("222222222222222222222");
                //}
                HostServer.Send(data, ipAndPort.ToString().Split(':')[0], int.Parse(ipAndPort.ToString().Split(':')[1]));
            }
        }
        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="data"></param>
        /// <param name="endPoint"></param>
        protected void Send(byte[] data, IPEndPoint endPoint)
        {
            HostServer.Send(data, endPoint);
        }
        /// <summary>
        /// 发送数据并添加到队列
        /// </summary>
        /// <param name="data"></param>
        /// <param name="hostNumber"></param>
        protected void SendAndPushCommandQueue(byte[] data, string hostNumber, string mac)
        {
            string ipAndPort = CSRedisCacheHelper.Get<string>(hostNumber, mac);
            if (!string.IsNullOrEmpty(ipAndPort))
            {
                HostServer.SendAndPushCommandQueue(data, ipAndPort.ToString().Split(':')[0], Convert.ToInt32(ipAndPort.ToString().Split(':')[1]));
            }
        }
        /// <summary>
        /// 回复下位机命令
        /// </summary>
        /// <param name="context"></param>
        protected void Reply(ReceiverContext context)
        {
            var headerLen = StructConverter.SizeOf(context.SystemHeader);
            var headerData = new byte[headerLen + 2];
            Array.Copy(context.Data, headerData, headerLen);
            headerData[2] = 0x11;
            headerData[3] = 0x00;
            Send(headerData, context.RemoteEndPoint);
        }

        /// <summary>
        /// 创建 SystemHeader
        /// </summary>
        /// <returns></returns>
        protected SystemHeader CreateSystemHeader()
        {
            return CreateSystemHeader(0);
        }
        /// <summary>
        /// 创建 SystemHeader
        /// </summary>
        /// <param name="dataLength">数据包长度，不包含头部长度</param>
        /// <returns></returns>
        protected SystemHeader CreateSystemHeader(int dataLength)
        {
            return CreateSystemHeader(CommandType, dataLength);
        }
        /// <summary>
        /// 创建 SystemHeader
        /// </summary>
        /// <param name="commandType">命令类型</param>
        /// <param name="dataLength">数据包长度，不包含头部长度</param>
        /// <returns></returns>
        protected SystemHeader CreateSystemHeader(CommandType commandType, int dataLength)
        {
            var systemHeader = new SystemHeader();
            systemHeader.Signature = SystemHeader.SIGNATURE;
            systemHeader.FrameLength = (ushort)(StructConverter.SizeOf(systemHeader) + dataLength);
            systemHeader.SystemID = SystemHeader.SYSTEM_ID.ToCharArray();
            systemHeader.CmdType = (byte)commandType;
            systemHeader.FrameNo = GetNextFrameNo();
            systemHeader.HostNumber = new HostNumber { NBuild = 0xFF, NFloor = 0xFF, NRoom = 0xFF, NUnit = 0xFF };
            return systemHeader;
        }
        /// <summary>
        /// 创建 DeviceHeader
        /// </summary>
        /// <returns></returns>
        protected DeviceHeader CreateDeviceHeader()
        {
            return new DeviceHeader
            {
                NodeAddr = 0x00,
                CmdType = (ushort)IPAddress.HostToNetworkOrder((short)this.CommandType),
                AskAck = 0x01,
                RoomNumber = new HostNumber
                {
                    NBuild = 0xff,
                    NFloor = 0xff,
                    NRoom = 0xff,
                    NUnit = 0xff
                }
            };
        }
        /// <summary>
        /// 记录操作日志
        /// </summary>
        /// <param name="authorityID">权限ID</param>
        /// <param name="action">动作</param>
        /// <param name="detail">详细</param>
        /// <param name="result">操作结果</param>
        /// <param name="account">帐号</param>
        /// <param name="hotelID">所属酒店ID</param>
        protected void SaveSystemLog(int authorityID, string action, string detail, string result, string account, string ip, int hotelID)
        {
            try
            {
                Domain.SysSystemLogs entity = new Domain.SysSystemLogs();
                entity.ID = 0;
                entity.AuthorityID = authorityID;
                entity.Action = action;
                entity.Detail = detail;
                entity.Result = result;
                entity.Account = account;
                entity.IP = ip;
                entity.Time = DateTime.Now;
                entity.HotelID = hotelID;

                SysSystemLogsRepository.Save(entity);
            }
            catch (Exception ex) { logger.Error("保存操作日志失败：" + ex.ToString()); }
        }

        #region Private Methods

        private void hostServer_BeforeStart(object sender, EventArgs e)
        {
            HostServer_BeforeStart(sender as HostServer);
        }

        private void hostServer_AfterStart(object sender, EventArgs e)
        {
            HostServer_AfterStart(sender as HostServer);
        }

        #endregion
    }
}