using System;
using System.Text;
using System.Collections.Generic;
using Shared;
//1440
namespace SuperGateWay
{
    public class SendAndReceiveDatas
    {
        public static PacketInfo CurrentPacketInfo;
      

        /// <summary>
        /// 接收数据的缓冲区
        /// </summary>
        static List<PacketInfo> receiveDataList = new List<PacketInfo> ();//接收分段，接收完毕之后要拼起来

        public static void Recevice (byte subnetId, byte deviceId, byte [] bytes)
        {
            var packetInfo = CurrentPacketInfo;
            if (packetInfo == null ) {
                return;
            }
            if (packetInfo.Command != 0) {
                if (packetInfo.Command != bytes [0]) {
                    return;
                } 
            }

            if (subnetId != packetInfo.SubnetID || deviceId != packetInfo.DeviceID) return;
            System.Console.WriteLine ("接收到新数据");
            switch (bytes [0]) {
            case 0:
                packetInfo.ResponeBytes = bytes;
                break;
            case 1:
                if (packetInfo.Command != 0 || packetInfo.FileBytes == null) {
                    return;
                }
                uint index = bytes [4] + (uint)bytes [3] * 256 + (uint)bytes [2] * 256 * 256 + (uint)bytes [1] * 256 * 256 * 256;
                uint lenght = bytes [6] + (uint)bytes [5] * 256;
                //如果请求的文件过大，当成无效数据
                if (1024 * 1.5 < lenght) {
                    return;
                }
                //如果请求的数据大于当前文件的长度，就以当前文件的最大长度为请求长度
                if (packetInfo.FileBytes.Length <= index + lenght) {
                    lenght = (uint)packetInfo.FileBytes.Length - index;
                    System.Console.WriteLine ("发送数据完成");
                    packetInfo.IsUploadFinish = true;
                }
                var buffer = new byte [1 + 4 + 2 + lenght];
                buffer [0] = bytes [0];
                buffer [1] = bytes [1];
                buffer [2] = bytes [2];
                buffer [3] = bytes [3];
                buffer [4] = bytes [4];
                buffer [5] = (byte)((lenght >> 8) & 0xFF);
                buffer [6] = (byte)((lenght >> 0) & 0xFF);
                System.Array.Copy (packetInfo.FileBytes, index, buffer, 7, lenght);
                System.Console.WriteLine ("发送数据长度"+lenght);
                Shared.Control.ControlBytesSend (Command.SuperGatewayAgent, subnetId, deviceId, buffer, Shared.SendCount.Zero);
                break;
            case 2: break;
            case 3:
                packetInfo.ResponeBytes = bytes;
                break;
            case 4:
                for (int i = 1; i < 5; i++) {
                    if (bytes [i] != packetInfo.Buffer [i]) {
                        //如果不是当前发送的命令，就反馈回去
                        return;
                    }
                }
                packetInfo.ResponeBytes = bytes;
                break;
            case 5: 
                packetInfo.ResponeBytes = bytes;
              break;
            case 6:
                for (int i = 5; i < packetInfo.Buffer.Length; i++) {
                    if (bytes [i] != packetInfo.Buffer [i]) {
                        //如果不是当前发送的命令，就反馈回去
                        return;
                    }
                }
                packetInfo.ResponeBytes = bytes;
                break;
            case 7: break;
            case 8: break;
            }
        }

       
    }

    public class PacketInfo
    {
        //  /scene   /device   /logic

        /// <summary>
        /// 上传是App传数据到高级网关
        /// 下载是高级网关从App下载文件
        /// 0 通知上传
        /// 1 请求上传
        /// 2 请求上传完毕
        /// 3 通知下载
        /// 4 请求下载
        /// 5 请求下载完毕
        /// 6 浏览文件
        /// 7 获取文件大小
        /// 8 删除文件
        /// </summary>
        public int Command;

        public byte [] Buffer = { };//json数据集合，发送的时候要分包发送

        [System.NonSerialized]
        //发送数据了之后当前线程等待或者运行的信号
        public System.Threading.ManualResetEvent ManualResetEvent = new System.Threading.ManualResetEvent (false);
        /// <summary>
        /// 回复的数据
        /// </summary>
        public byte [] ResponeBytes;
        public bool IsFinish {
            get {
                return ResponeBytes != null;
            }
        }
        /// <summary>
        /// 重发并次数
        /// </summary>
        public int ReSendCount = 3;
        public byte SubnetID =ScenePage.SubnetID;
        public byte DeviceID= ScenePage.DeviceID;
        public byte [] FileBytes;
        public bool IsUploadFinish;



      
    }
}