using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks; 
using Windows.Networking.Sockets;
using System.IO;
using Windows.Storage.Streams;
using Windows.Networking;
using System.Runtime.InteropServices.WindowsRuntime;
using Windows.Security.Cryptography.Core;
using Windows.Security.Cryptography;

namespace PlaneGcsSdk.Contract.EhNetUWP
{
    public class PLNet
    {
        #region Properties
        public StreamOBJ MyStreamObj;
        /// <summary>
        /// 连接的IP
        /// </summary>
        public string ServerIP { get; protected set; }
        /// <summary>
        /// 连接的端口
        /// </summary>
        public int TCPPort { get; protected set; }
        public bool IsClosing { get; protected set; }
        public bool IsOpen { get; protected set; }
        /// <summary>
        /// 真实名
        /// </summary>
        public string MyNick { get; protected set; }
        /// <summary>
        /// 获取登录随机码
        /// </summary>
        public string MyRND { get { return sMyTempRnd; } }
        /// <summary>
        /// 发送文件列表 
        /// </summary>
        public List<FileOBJ> SendFileList { get; protected set; }
        /// <summary>
        /// 接收文件列表
        /// </summary>
        public List<FileOBJ> RevFileList { get; protected set; }
        /// <summary>
        /// 用户列表 
        /// </summary>
        public List<UserProperty> FriendList { get; protected set; }
        /// <summary>
        /// 发送流列表
        /// </summary>
        public List<StreamOBJ> SendStreamList { get; protected set; }
        public List<StreamOBJ> RevStreamList { get; protected set; }
        #endregion

        #region Fields
        string sMyTempRnd; //登录随机数
        bool LoginFlag = false; //登录状态
        string sMyID; //登录用户名
        string sMyPassword; //登录密码 
        
        string sMyIP; //用户IP
        Encoding _enconding;
        int iStreamID = -1;
        int iFileID = 0;

        protected StreamSocket _socket; //连接对象
        protected IInputStream _inputStream;
        protected Stream _outputStream;
        protected bool _canFlush = true;
        protected const uint READ_BUFFER_SIZE = 2047;
        #endregion

        #region Events 
        public event EventHandler<LoginEventArgs> Login;
        public event EventHandler<DiscoveredOneUserEventArgs> DiscoveredOneUser;
        public event EventHandler RefreshFriendListCompleted;
        public event EventHandler<UserStateChangeEventArgs> UserStateChange;
        public event EventHandler Disconnect;
        public event EventHandler<CommandArrivalEventArgs> CommandArrival;
        public event EventHandler<ExceptionThrownEventArgs> ExceptionThrown;
        public event EventHandler<StartSendFileEventArgs> StartSendFile;
        #endregion

        public PLNet()
        {
            FriendList = new List<UserProperty>();
            SendFileList = new List<FileOBJ>();
            RevFileList = new List<FileOBJ>();
            SendStreamList = new List<StreamOBJ>();
            RevStreamList = new List<StreamOBJ>();
        }

        #region Public Methods
        /// <summary>
        /// 建立连接
        /// </summary>
        /// <param name="sServerIP"></param>
        /// <param name="sUsername"></param>
        /// <param name="sPassword"></param>
        /// <param name="md5Password"></param>
        /// <returns></returns>
        public async Task Start(string sServerIP, string sUsername, string sPassword, string md5Password = null)
        {
            Close();
            IsClosing = false;

            if (_enconding == null)
            {
                _enconding = await DBCSEncoding.GetDBCSEncoding("GB2312");
            }

            sMyID = sUsername;
            if (md5Password == null)
                sMyPassword = GetStrMd5Hash(sMyID + sPassword);
            else
                sMyPassword = md5Password;

            ServerIP = sServerIP; //登录用户的IP地址
            TCPPort = 52510;  //登录用户的端口

            _socket = new StreamSocket(); //创建连接对象 
            await _socket.ConnectAsync(new HostName(ServerIP), TCPPort.ToString()).AsTask().ConfigureAwait(false); //执行连接操作

            IsOpen = true;
            _inputStream = _socket.InputStream;
            _outputStream = _socket.OutputStream.AsStreamForWrite();
            await Task.Run(() => TCPClientThread());
        }

        /// <summary>
        /// 关闭连接
        /// </summary>
        public void Close()
        {
            IsClosing = true;
            IsOpen = false;
            _inputStream?.Dispose();
            _outputStream?.Dispose();
            _socket?.Dispose();
            if (SendFileList != null)
                SendFileList.Clear();
            if (RevFileList != null)
                RevFileList.Clear();
            Disconnect?.Invoke(this, EventArgs.Empty); //触发事件Disconnect
        }

        /// <summary>
        /// 发送命令
        /// </summary>
        /// <param name="friendIDs"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public async Task SendCommand(string friendIDs, string msg)
        {
            string commandtext = "*" + friendIDs + "|" + msg;
            await SendCmd(commandtext);
        }

        /// <summary>
        /// 发送数据流，给多个用户同时发送数据
        /// </summary>
        /// <param name="friendIDs"></param>
        /// <param name="myData"></param>
        /// <returns></returns>
        public async Task SendStream(string friendIDs, byte[] myData)
        {
            string[] myFriends = friendIDs.Split(',');
            for (int i = 0; i < myFriends.Length; i++)
            {
                iStreamID += 1;
                MyStreamObj = new StreamOBJ();
                MyStreamObj.StreamID = iStreamID;
                MyStreamObj.StreamData = myData;
                MyStreamObj.RevUserID = myFriends[i];
                SendStreamList.Add(MyStreamObj);
                string streamtext = "*" + myFriends[i] + "|SB|" + MyStreamObj.StreamID.ToString() + "|" + MyStreamObj.StreamData.Length.ToString();
                await SendCmd(streamtext);
            }
        }

        /// <summary>
        /// 发送普通文件
        /// </summary>
        /// <param name="friendID"></param>
        /// <param name="sFilenames"></param>
        /// <returns></returns>
        public async Task SendFileCommon(string friendID, string[] sFilenames)
        {
            string filetype = "F";
            await SendFileCommon(friendID, sFilenames, filetype);
        }

        /// <summary>
        /// 发送图片文件
        /// </summary>
        /// <param name="friendID"></param>
        /// <param name="sFilenames"></param>
        /// <returns></returns>
        public async Task SendPicture(string friendID, string[] sFilenames)
        {
            string filetype = "P";
            await SendFileCommon(friendID, sFilenames, filetype);
        }

        /// <summary>
        /// 发送视频文件
        /// </summary>
        /// <param name="friendID"></param>
        /// <param name="sFilenames"></param>
        /// <returns></returns>
        public async Task SendVideo(string friendID, string[] sFilenames)
        {
            string filetype = "V";
            await SendFileCommon(friendID, sFilenames, filetype);
        }

        /// <summary>
        /// 发送文件公共函数
        /// </summary>
        /// <param name="friendID"></param>
        /// <param name="sFilenames"></param>
        /// <param name="filetype"></param>
        /// <returns></returns>
        public async Task SendFileCommon(string friendID, string[] sFilenames, string filetype)
        {
            for (int i = 0; i < sFilenames.Length; i++)
            {
                FileOBJ tmpFileObj = new FileOBJ();
                tmpFileObj.FileID = iFileID;
                iFileID += 1;
                FileInfo MyFileInfo = new FileInfo(sFilenames[i]);
                tmpFileObj.Filename = MyFileInfo.Name;
                tmpFileObj.FilePath = MyFileInfo.DirectoryName;
                tmpFileObj.FileLength = MyFileInfo.Length;
                tmpFileObj.FileModDate = filetype + MyFileInfo.LastWriteTime.ToString(); //filetype表示发送文件的类型
                tmpFileObj.RevUserID = friendID;
                tmpFileObj.State = FileState.WaitConfim;
                tmpFileObj.tmpFileStream = new FileStream(sFilenames[i], FileMode.Open, FileAccess.Read);
                SendFileList.Add(tmpFileObj);
                StartSendFile?.Invoke(this, new StartSendFileEventArgs(SendFileList.Count - 1));
                string filetext = "FB" + friendID + "|" + tmpFileObj.FileID.ToString() + "|" + tmpFileObj.Filename + "|" + tmpFileObj.FileLength.ToString() + "|" + tmpFileObj.FileModDate;
                await SendCmd(filetext);
            }
        }

        /// <summary>
        /// 发送数据公共函数
        /// </summary>
        /// <param name="cmdStr"></param>
        /// <param name="addBytes"></param>
        /// <returns></returns>
        public async Task SendCmd(string cmdStr, byte[] addBytes = null)
        {
            byte[] tmpSendbytes = null;
            tmpSendbytes = _enconding.GetBytes(cmdStr);
            int nret;
            int strLen = LenB(cmdStr);
            if (addBytes == null)
            {
                tmpSendbytes = BitConverter.GetBytes((ushort)strLen);
                Array.Resize(ref tmpSendbytes, strLen + 2);
                nret = _enconding.GetBytes(cmdStr, 0, cmdStr.Length, tmpSendbytes, 2);
            }
            else
            {
                byte[] tmpBytes;
                long allLenth = strLen + addBytes.Length;
                tmpBytes = BitConverter.GetBytes(allLenth);
                Array.Resize(ref tmpBytes, strLen + 2);
                nret = _enconding.GetBytes(cmdStr, 0, cmdStr.Length, tmpBytes, 2);
                tmpSendbytes = AddByte(tmpBytes, addBytes);
            }
            try
            {
                if (tmpSendbytes != null)
                {
                    await _outputStream.WriteAsync(tmpSendbytes, 0, tmpSendbytes.Length).ConfigureAwait(false);
                    if (_canFlush)
                    {
                        await _outputStream.FlushAsync().ConfigureAwait(false);
                    }
                }
            }
            catch (Exception ex)
            {
                _canFlush = false;
                Close();
                ExceptionThrown?.Invoke(this, new ExceptionThrownEventArgs(ex));
            }
        }
        #endregion

        #region Private Methods
        /// <summary>
        /// 启动一个接收数据的线程
        /// </summary>
        private async void TCPClientThread()
        {
            uint i; //接收到的数据的长度
            byte[] byteBuffer = null; //暂存接收到的数据  
            int comLength;
            bool ReadFlag = false;
            bool nRet;
            byte[] Tmpbyte;

            IBuffer tempbuf = new Windows.Storage.Streams.Buffer(READ_BUFFER_SIZE); //建立一个buffer
            await _inputStream.ReadAsync(tempbuf, READ_BUFFER_SIZE, InputStreamOptions.Partial);
            i = tempbuf.Length;
            byteBuffer = new byte[i];
            tempbuf.CopyTo(byteBuffer); //将数据输出 

            while (i != 0)
            {
                if (byteBuffer.Length > 3)
                {
                    comLength = BitConverter.ToUInt16(byteBuffer, 0);
                    if (LoginFlag == false && comLength > 70)
                    {
                        #region
                        if (byteBuffer.Length >= 2)
                        {
                            byte[] firstchar = new byte[1];
                            firstchar[0] = byteBuffer[1];
                            if (_enconding.GetString(firstchar) != "L")
                                i = 0;
                        }
                        else
                        {
                            ReadFlag = true;
                        }
                        #endregion
                    }
                    else
                    {
                        #region
                        if (byteBuffer.Length >= comLength + 1)
                        {
                            Tmpbyte = MidByte(byteBuffer, 3, comLength); //截取字节
                            if (Tmpbyte.Length < 4)
                                nRet = false;
                            nRet = await ProcessData(Tmpbyte);
                            if (nRet == true)
                            {
                                byteBuffer = RightByte(byteBuffer, byteBuffer.Length - comLength - 2); //截取字节
                                if (byteBuffer.Length <= 0)
                                    ReadFlag = true;
                            }
                            else
                            {
                                return;
                            }
                        }
                        else
                        {
                            ReadFlag = true;
                        }
                        #endregion
                    }
                }
                else
                {
                    ReadFlag = true;
                }
                if (ReadFlag == true)
                {
                    #region
                    ReadFlag = false;
                    try
                    {
                        tempbuf = new Windows.Storage.Streams.Buffer(READ_BUFFER_SIZE); //建立一个buffer
                        await _inputStream.ReadAsync(tempbuf, READ_BUFFER_SIZE, InputStreamOptions.Partial);
                        i = tempbuf.Length;
                        byte[] addbyte = new byte[i];
                        tempbuf.CopyTo(addbyte);
                        byteBuffer = AddByte(byteBuffer, addbyte);
                    }
                    catch(Exception ex)
                    {
                        i = 0;
                    }
                    #endregion
                }
            }
        }

        /// <summary>
        /// 处理接收到的数据
        /// </summary>
        /// <param name="tmpbyte"></param>
        /// <returns></returns>
        private async Task<bool> ProcessData(byte[] tmpbyte)
        {
            string recestr = _enconding.GetString(tmpbyte); //这里本应是GBK编码 
            UserProperty tmpUserinfo = new UserProperty();
            int tmpIndex;

            switch (recestr[0])
            {
                case 'R':
                    sMyTempRnd = recestr.Substring(1);
                    await SendCmd("L" + sMyID + "|" + GetStrMd5Hash(sMyPassword + sMyTempRnd));
                    sMyTempRnd = sMyTempRnd.Substring(0, sMyTempRnd.Length - 1);
                    break;
                case 'U': //收到用户信息
                    string sUserinfo = recestr.Substring(1);
                    switch (sUserinfo[0])
                    {
                        #region
                        case 'A': //用户列表
                            #region
                            sUserinfo = sUserinfo.Substring(1);
                            tmpUserinfo.UserID = Fin(1, sUserinfo, "|");
                            tmpUserinfo.UserNick = Fin(2, sUserinfo, "|");
                            tmpUserinfo.UserIndex = FriendList.Count;
                            tmpUserinfo.UserMessage = new List<String>();
                            FriendList.Add(tmpUserinfo);
                            DiscoveredOneUser?.Invoke(this, new DiscoveredOneUserEventArgs(tmpUserinfo));
                            #endregion
                            break;
                        case 'O': //用户上线
                            #region
                            sUserinfo = sUserinfo.Substring(1);
                            tmpIndex = GetUserIndexByID(Fin(1, sUserinfo, "|"));
                            if (tmpIndex >= 0)
                            {
                                tmpUserinfo = FriendList[tmpIndex]; //修改用户在线状态
                                tmpUserinfo.UserOnline = true;
                                FriendList[tmpIndex] = tmpUserinfo;
                                UserStateChange?.Invoke(this, new UserStateChangeEventArgs(tmpUserinfo));
                            }
                            #endregion
                            break;
                        case 'F': //用户下线
                            #region
                            sUserinfo = sUserinfo.Substring(1);
                            string tmpFriendID = Fin(1, sUserinfo, "|");
                            tmpIndex = GetUserIndexByID(tmpFriendID);
                            if (tmpIndex >= 0)
                            {
                                tmpUserinfo = FriendList[tmpIndex];
                                tmpUserinfo.UserOnline = false;
                                FriendList[tmpIndex] = tmpUserinfo;
                                //处理发送文件残留
                                for (int i = 0; i < SendFileList.Count; i--)
                                {
                                    if (SendFileList[i].RevUserID == tmpFriendID)
                                    {
                                        SendFileList[i].tmpFileStream.Dispose();
                                        SendFileList.RemoveAt(i);
                                    }
                                }
                                for (int j = 0; j < RevFileList.Count; j--)
                                {
                                    if (RevFileList[j].RevUserID == tmpFriendID)
                                    {
                                        RevFileList[j].tmpFileStream.Dispose();
                                        RevFileList.RemoveAt(j);
                                    }
                                }
                                UserStateChange?.Invoke(this, new UserStateChangeEventArgs(tmpUserinfo));
                            }
                            #endregion
                            break;
                        case 'D':
                            break;
                        case 'C': //被别人添加为好友时会收到
                            break;
                        case 'E':
                            RefreshFriendListCompleted?.Invoke(this, EventArgs.Empty);
                            break;
                        default:
                            break;
                            #endregion
                    }
                    break;
                case 'L': //登陆
                    recestr = recestr.Substring(1);
                    switch (recestr[0])
                    {
                        #region
                        case 'P':
                            Login?.Invoke(this, new LoginEventArgs(LoginState.LoginPwdError));
                            break;
                        case 'O':
                            LoginFlag = true;
                            MyNick = recestr.Substring(1).Split('|')[0];
                            Login?.Invoke(this, new LoginEventArgs(LoginState.LoginOk));
                            await SendCmd("UG");
                            break;
                        case 'U':
                            Login?.Invoke(this, new LoginEventArgs(LoginState.LoginNoUser));
                            break;
                        case 'E':
                            Login?.Invoke(this, new LoginEventArgs(LoginState.LoginOtherError));
                            break;
                        default:
                            break;
                            #endregion
                    }
                    break;
                case '*':  //收到命令，格式为: *+FriendID+|+Msg
                    string tmpStr = recestr.Substring(1);
                    string tmpstr2 = Fin(2, tmpStr, "|");
                    switch (tmpstr2[0])
                    {
                        #region
                        case 'S':
                            break;
                        default:
                            string friendid = Fin(1, tmpStr, "|");
                            string msgcontent = tmpStr.Substring(tmpStr.IndexOf("|") + 1);
                            CommandArrival?.Invoke(this, new CommandArrivalEventArgs(friendid, msgcontent));
                            break;
                            #endregion
                    }
                    break;
                default:
                    break;
            }
            return true;
        }

        private int LenB(string str)
        {
            return _enconding.GetBytes(str).Count();
        }

        /// <summary>
        /// 获取一个字节数组中的某些字节，从start个字节开始，获取length个字节,第几个是从1开始的
        /// </summary>
        /// <param name="tbyte"></param>
        /// <param name="start"></param>
        /// <param name="length"></param>
        /// <returns></returns>
        private byte[] MidByte(byte[] tbyte, int start, int length)
        {
            byte[] tmpMidByte = new byte[length];
            //for (int i = 0; i < length; i++)
            //{
            //    tmpMidByte[i] = tbyte[i + start - 1];
            //}
            for (int i = start - 1; i <= length - 1 + start - 1; i++)
            {
                tmpMidByte[i - (start - 1)] = tbyte[i];
            }
            return tmpMidByte;
        }

        /// <summary>
        /// 获取某个字节数组的后面的字节，获取length个字节
        /// </summary>
        /// <param name="tbyte"></param>
        /// <param name="length"></param>
        /// <returns></returns>
        private byte[] RightByte(byte[] tbyte, int length)
        {
            byte[] temRightByte = new byte[length];
            temRightByte = MidByte(tbyte, tbyte.Length - length + 1, length);
            return temRightByte;
        }

        /// <summary>
        /// 获取某个字节数组的前面的字节，获取length个字节
        /// </summary>
        /// <param name="tbyte"></param>
        /// <param name="length"></param>
        /// <returns></returns>
        private byte[] LeftByte(byte[] tbyte, int length)
        {
            byte[] temLeftByte = new byte[length];
            temLeftByte = MidByte(tbyte, 1, length);
            return temLeftByte;
        }

        /// <summary>
        /// 拼接两个字节,将addbyte加在srcbyte后面
        /// </summary>
        /// <param name="srcbyte"></param>
        /// <param name="addbyte"></param>
        /// <returns></returns>
        private byte[] AddByte(byte[] srcbyte, byte[] addbyte)
        {
            byte[] resultbyte = new byte[srcbyte.Length + addbyte.Length];
            for (int i = 0; i < srcbyte.Length; i++)
            {
                resultbyte[i] = srcbyte[i];
            }
            for (int j = 0; j < addbyte.Length; j++)
            {
                resultbyte[j + srcbyte.Length] = addbyte[j];
            }
            return resultbyte;
        }

        /// <summary>
        /// 根据ID获取列表中序号
        /// </summary>
        /// <param name="tmpUserID"></param>
        /// <returns></returns>
        protected int GetUserIndexByID(string tmpUserID)
        {
            for (int i = 0; i < FriendList.Count; i++)
            {
                if (FriendList.ElementAt(i).UserID == tmpUserID)
                    return i;
            }
            return -1;
        }

        /// <summary>
        /// 分割字符串，第Xnum个字符，字符串为SrcStr，分割特征为SpStr
        /// </summary>
        /// <param name="xnum"></param>
        /// <param name="srcStr"></param>
        /// <param name="spStr"></param>
        /// <returns></returns>
        private string Fin(int xnum, string srcStr, string spStr)
        {
            string[] tmpStr;
            char[] FF = new char[1];
            FF[0] = spStr[0];
            tmpStr = srcStr.Split(FF);
            if ((xnum > 0) && (xnum <= tmpStr.Length))
                return tmpStr[xnum - 1];
            else
                return "";
        }

        /// <summary>
        /// 计算字符串的MD5哈希值，输入为字符串strtohash，输出为字符串strHash
        /// </summary>
        /// <param name="strtohash"></param>
        /// <returns></returns>
        private string GetStrMd5Hash(string strtohash)
        {

            byte[] tmpbyte = _enconding.GetBytes(strtohash);

            IBuffer buffMsg = CryptographicBuffer.CreateFromByteArray(tmpbyte);

            HashAlgorithmProvider objAlgProv = HashAlgorithmProvider.OpenAlgorithm(HashAlgorithmNames.Md5);

            IBuffer tmpbuffer = objAlgProv.HashData(buffMsg);

            uint i = tmpbuffer.Length;
            byte[] mybyte = new byte[i];
            tmpbuffer.CopyTo(mybyte);

            CryptographicBuffer.CopyToByteArray(tmpbuffer, out mybyte);

            StringBuilder sBuilder = new StringBuilder();
            for (int k = 0; k < mybyte.Length; k++)
            {
                sBuilder.Append(mybyte[k].ToString("x2"));
            }

            string strHash = sBuilder.ToString();

            return strHash;
        }

        #endregion
    }
    #region Nested Type
    /// <summary>
    /// 用户信息结构体
    /// </summary>
    public struct UserProperty
    {
        public string UserID;
        public string UserNick;
        public string UserIP;
        public int UserIndex;
        public bool UserOnline;
        public List<string> UserMessage;
    }

    /// <summary>
    /// 文件状态
    /// </summary>
    public enum FileState
    {
        WaitConfim,
        StartSend, //开始发送，等待确认
        Sending, //正在发送中
        reSend, //断点续传中 
        SendError, //发送错误
        Completed, //发送完成 
        LoginOtherError, //其他错
        StartReveice, //开始接收，等待数据
        Receiving,   //接收中
        ReReceiving, //断点续传中
        ReceiveError
    }

    /// <summary>
    /// 登录状态
    /// </summary>
    public enum LoginState
    {
        LoginPwdError, //密码错
        LoginOk, //登陆成功
        LoginNoUser, //用户不存在
        LoginOtherError, //其他错
    }

    /// <summary>
    /// 文件结构体
    /// </summary>
    public struct FileOBJ
    {
        public string Filename;
        public string FilePath;
        public long FileLength;
        public string FileModDate;
        public int FileID;
        public string SendUserID;
        public string RevUserID;
        public FileStream tmpFileStream;
        public FileState State;
    }

    /// <summary>
    /// 数据流结构体
    /// </summary>
    public struct StreamOBJ
    {
        public byte[] StreamData;
        public ulong CurrPos;
        public int StreamID;
        public ulong Length;
        public string SendUserID;
        public string RevUserID;
    }
    #endregion 
}