using Hanhe.iWCS.Factroy;
using Hanhe.iWCS.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Hanhe.iWCS.IndonesiaGLMTCP
{
    public class SessionInstance
    {
        private static readonly SessionInstance instance = new SessionInstance();

        public List<WCSSession> WCSSessionList = new List<WCSSession>();

        /// <summary>
        /// 设备授权数量
        /// </summary>
        private const int DeviceAuthNumber = 100;

        /// <summary>
        /// 设备协议接口实例化
        /// </summary>
        public IProtocolAnalysis _IProtocolAnalysis;


        /// <summary>
        /// 获取单实例
        /// </summary>
        public static SessionInstance Instance {
            get {
                return instance;
            }
        }

        /// <summary>
        /// 构造函数
        /// </summary>
        public SessionInstance() {

        }

        /// <summary>
        /// 初始化
        /// </summary>
        public void Initialize() {
            _IProtocolAnalysis = DataAccess.CreateProtocolAnalysis();
        }

        /// <summary>
        /// 增加会话到内存队列
        /// </summary>
        /// <param name="session"></param>
        public void AddSession(WCSSession session) {
            if (!WCSSessionList.Exists(p => p.SessionID == session.SessionID)) {
                WCSSessionList.RemoveAll(a => a.RemoteEndPoint.Address == session.RemoteEndPoint.Address);
                var _wcsSession = WCSSessionList.Where(p => p.RemoteEndPoint.Address == session.RemoteEndPoint.Address);
                foreach (var sessionIns in _wcsSession) {

                    WCSSessionList.Remove(sessionIns);
                }
                if (WCSSessionList.Count <= DeviceAuthNumber) {
                    WCSSessionList.Add(session);
                }
            }
        }
        private void PrintSession() {
            WCSSessionList.ForEach(a => Console.WriteLine($"{a.RemoteEndPoint.Address}:{a.RemoteEndPoint.Port}"));
        }
        /// <summary>
        /// 给指定客户端发送消息(只匹配IP地址)
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public bool PLCSend(string ip, int port, string msg) {
            bool iRtn = false;
            //PrintSession();
            //对当前已连接的所有会话进行广播
            WCSSession wcsSession = WCSSessionList.Find(p => p.RemoteEndPoint.Address.ToString() == ip && p.RemoteEndPoint.Port == port);
            if (wcsSession != null) {
                var data = Encoding.UTF8.GetBytes(msg);
                wcsSession.Send(data, 0, data.Length);
                //Console.WriteLine($"{ip}:{port} 发送消息{msg}");
                iRtn = true;
            }
            else {
                Console.WriteLine($"{ip}:{port}连接不存在");
            }
            return iRtn;
        }

        public bool PLCSend(string ip, int port, byte[] data) {
            bool iRtn = false;
            //PrintSession();
            //对当前已连接的所有会话进行广播
            
            WCSSession wcsSession = WCSSessionList.Find(p => p.RemoteEndPoint.Address.ToString() == ip && p.RemoteEndPoint.Port == port);
            if (wcsSession != null) {
                wcsSession.Send(data, 0, data.Length);
                //Console.WriteLine($"{ip}:{port} 发送消息{msg}");
                iRtn = true;
            }
            else {
                Console.WriteLine($"{ip}:{port}连接不存在");
            }
            return iRtn;
        }
        /// <summary>
        /// 给指定客户端发送消息(匹配IP地址)
        /// </summary>
        /// <param name="ip">IP地址</param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public bool PLCSend(string ip, string msg) {
            bool iRtn = false;
            //对当前已连接的所有会话进行广播
            WCSSession wcsSession = WCSSessionList.Find(p => p.RemoteEndPoint.Address.ToString() == ip);
            if (wcsSession != null) {
                //var data = Encoding.Default.GetBytes(msg);
                var data = Encoding.UTF8.GetBytes(msg);
                wcsSession.Send(data, 0, data.Length);
                iRtn = true;
            }
            return iRtn;
        }

        /// <summary>
        /// 通过会话句柄ID找到客户端对象发送数据
        /// </summary>
        /// <param name="sessionID">会话句柄ID</param>
        /// <param name="msg">发送数据</param>
        /// <returns></returns>
        public bool PLCSendForSessionID(string sessionID, string msg) {
            bool iRtn = false;
            WCSSession wcsSession = WCSSessionList.Find(p => p.SessionID == sessionID);
            if (wcsSession != null) {
                Hanhe.iWCS.Common.CMMLog.Info("PLC IP=" + wcsSession.RemoteEndPoint.Address.ToString());
                var data = Encoding.UTF8.GetBytes(msg);
                wcsSession.Send(data, 0, data.Length);
                iRtn = true;
            }
            return iRtn;
        }


        /// <summary>
        /// 删除一个会话
        /// </summary>
        /// <param name="sessionID">会话ID</param>
        public void SessionRemove(string sessionID) {
            if (WCSSessionList.Count > 0) {
                WCSSession wcsSession = WCSSessionList.Find(p => p.SessionID == sessionID);
                if (wcsSession != null) WCSSessionList.Remove(wcsSession);
            }
        }

        /// <summary>
        /// 移除重复的会话（同一个设备编号在Session重复）
        /// </summary>
        /// <param name="sessionID">会话SessionID</param>
        /// <param name="deviceCode">设备编号</param>
        public void RemoveRepeatDeviceCodeForSession(string sessionID, string deviceCode) {
            IEnumerable<WCSSession> wcsSessionList = WCSSessionList.Where(p => p.SessionID != sessionID && p.deviceCode == deviceCode);
            foreach (var wcsSession in wcsSessionList) {
                WCSSessionList.Remove(wcsSession);
            }
        }

        /// <summary>
        /// 移除会话
        /// </summary>
        /// <param name="ip">会话ip</param>
        public void RemoveSessionExcludeFromIP(string ip) {
            IEnumerable<WCSSession> wcsSessionList = WCSSessionList.Where(p => p.RemoteEndPoint.Address.ToString() != ip);
            foreach (var wcsSession in wcsSessionList) {
                WCSSessionList.Remove(wcsSession);
            }
        }

        /// <summary>
        /// 根据心跳会话，更新会话与设备编号的对应关系
        /// </summary>
        /// <param name="sessionID">会话ID</param>
        /// <param name="deviceCode">设备编号</param>
        public void UpdateDeviceCodeForSessionID(string sessionID, string deviceCode) {
            WCSSession wcsSession = WCSSessionList.Find(p => p.SessionID == sessionID);
            if (wcsSession != null) {
                wcsSession.deviceCode = deviceCode;
            }
        }
    }
}