package com.hdl.sdk.ttl.HDLDeviceManger.Bean;

import java.util.ArrayList;
import java.util.Calendar;

import com.hdl.sdk.ttl.Config.Global;
import com.hdl.sdk.ttl.HDLDeviceManger.Core.Crc;

import java.net.InetAddress;

public class SendDatas {
    // finish
    public static final int FINISH = 10;
    public static final int SEND_ONLY_ONCE = 0;
    public static final int SEND_MAX = 3;
    /**
     * 重发列表
     */
    private static ArrayList<SendDatas> RetransmissionDateList = new ArrayList<SendDatas>();
    /**
     * 只发送一次，发送完就移除
     */
    public static ArrayList<SendDatas> sendDataArrayList = new ArrayList<SendDatas>(100);
    // 已经发送出去的次数
    public int SendCount = 0;
    public Calendar StartCalendar =null;
    // 子网号
    public int DesSubnetID;
    // 设备号
    public int DesDeviceID;
    // 发送出去的附加数据
    public byte[] AddBytes = new byte[]{};
    // 获取发送出去的数据,每调用这个方法的时候，数据都会重新排列一下，得到真实的数据
    public InetAddress InetAddress;
    public int Port;
    public InetAddress TargetAddress;

    /**
     * 设备协议类型
     */
    public int protocolType;

    public byte[] GetSendBytes() {

        // 要计算CRC的数据和CRC两个字节
        byte[] crcBytes = new byte[9 + this.AddBytes.length + 2];

        // 发送出去的数据
        byte[] sendBytes = new byte[16 + crcBytes.length];

        /*String[] ip = Net.CurrentNet.getPsdnIp().split("\\.");
        // IP地址
        sendBytes[0] = (byte) GetStringToInteger(ip[0]);
        sendBytes[1] = (byte) GetStringToInteger(ip[1]);
        sendBytes[2] = (byte) GetStringToInteger(ip[2]);
        sendBytes[3] = (byte) GetStringToInteger(ip[3]);*/

        // HDL--HOTEL
        if (this.Port == 6006) {

            sendBytes[4] = (byte) 0x48;
            sendBytes[5] = (byte) 0x44;
            sendBytes[6] = (byte) 0x4c;
            sendBytes[7] = (byte) 0x4d;
            sendBytes[8] = (byte) 0x49;
            sendBytes[9] = (byte) 0x52;
            sendBytes[10] = (byte) 0x41;
            sendBytes[11] = (byte) 0x43;
            sendBytes[12] = (byte) 0x4c;
            sendBytes[13] = (byte) 0x45;
        } else {
            // HDLMIRACLE
            sendBytes[4] = (byte) 0x48;
            sendBytes[5] = (byte) 0x44;
            sendBytes[6] = (byte) 0x4c;
            sendBytes[7] = (byte) 0x4d;
            sendBytes[8] = (byte) 0x49;
            sendBytes[9] = (byte) 0x52;
            sendBytes[10] = (byte) 0x41;
            sendBytes[11] = (byte) 0x43;
            sendBytes[12] = (byte) 0x4c;
            sendBytes[13] = (byte) 0x45;
        }
        // 引导码
        sendBytes[14] = (byte) 0xAA;
        sendBytes[15] = (byte) 0xAA;

        // 16 数据包长度 11-78
        crcBytes[0] = (byte) crcBytes.length;
        // 17 源子网地址 0-254
        crcBytes[1] = (byte) Global.subnetID;
        // 18 源设备地址 0-254
        crcBytes[2] = (byte) Global.deviceID;
        // 19 源设备类型高位
        crcBytes[3] = (byte) (Global.DeviceType / 256);
        // 20 源设备类型低位
        crcBytes[4] = (byte) (Global.DeviceType % 256);
        // 21 操作码高位
        crcBytes[5] = (byte) (this.Command / 256);
        // 22 操作码低位
        crcBytes[6] = (byte) (this.Command % 256);
        // 23 目标子网地址 0-254
        crcBytes[7] = (byte) this.DesSubnetID;
        // 24 目标设备地址 0-254
        crcBytes[8] = (byte) this.DesDeviceID;
        // 25~n附加数据
        System.arraycopy(this.AddBytes, 0, crcBytes, 9, this.AddBytes.length);
        // CRC校验
        Crc.ConCRC(crcBytes, crcBytes.length - 2);

        // 复制CRC数据到发送数据里面
        System.arraycopy(crcBytes, 0, sendBytes, 16, crcBytes.length);

        /*
         * int sss[] = new int[sendBytes.length]; for(int i
         * =0;i<sendBytes.length;i++){ sss[i] =
         * Global.GetByteToUbyte(sendBytes[i]); }
         */

        return sendBytes;

    }

    /**
     * 获取串口发送数据
     *
     * @return -
     */
    public byte[] GetSerialPortSendBytes() {

        //Data and to compute the CRC of CRC two bytes
        byte[] crcBytes = new byte[9 + this.AddBytes.length + 2];

        //Send out the data
        byte[] sendBytes = new byte[2 + crcBytes.length];

        //Boot code
        sendBytes[0] = (byte) 0xAA;
        sendBytes[1] = (byte) 0xAA;

        //16	The length of the packet   11-78
        crcBytes[0] = (byte) crcBytes.length;
        //17	Source subnet addresses  0-254
        crcBytes[1] = (byte) Global.subnetID;// Global.subnetId;/
        //18	source device address   0-254
        crcBytes[2] = (byte) Global.deviceID;//Global.deviceId;
        //19	High source device type
        crcBytes[3] = (byte) (Global.DeviceType / 256);
        //20	The source device type low
        crcBytes[4] = (byte) (Global.DeviceType % 256);
        //21	Opcode high
        crcBytes[5] = (byte) (this.Command / 256);
        //22	Opcode low
        crcBytes[6] = (byte) (this.Command % 256);
        //23	The target subnet addresses  0-254
        crcBytes[7] = (byte) this.DesSubnetID;
        //24	The destination address  0-254
        crcBytes[8] = (byte) this.DesDeviceID;
        //25~n  Additional data
        System.arraycopy(this.AddBytes, 0, crcBytes, 9, this.AddBytes.length);
        //Check CRC
        Crc.ConCRC(crcBytes, crcBytes.length - 2);

        //Copy the CRC data to send data
        System.arraycopy(crcBytes, 0, sendBytes, 2, crcBytes.length);

        return sendBytes;

    }

    // 操作码
    public int Command;
    // 每个字节对应是否已经发送出去的数次
    public boolean[] HaveSend = new boolean[]{false, false, false};
    // 临时表示发送出去的数据的引用
    private static SendDatas currentSendBytesInfo = null;

    // 这个函数可以增加一个标识，选择当前这条数据需要发送多少次，这亲使用起来就比较方便点
    // 有可能还需要加入哪条数据的发送优先级，这亲需要先发送的数据就发送快点。
    // 增加要发送的数据
    public static void AddSendData(int command, int desSubnetID, int desDeviceID, byte[] addBytes, int sendCount,
                                   InetAddress ip, int port, int _protocolType) {
        SendDatas sendDatas = new SendDatas();
        sendDatas.Command = command; // 这里的操作码最好是用枚举，这样才不会出错又方便
        sendDatas.DesSubnetID = desSubnetID;
        sendDatas.DesDeviceID = desDeviceID;
        sendDatas.AddBytes = addBytes;
        sendDatas.SendCount = sendCount; // 如果这个值
        // 大于等于500表示只需要发送两次，如果大于等于1000表示只需要发送一次，如果大于等于1500，表示不需要再发送数据了
        sendDatas.InetAddress = ip;
        sendDatas.Port = port;
        sendDatas.protocolType = _protocolType;
        synchronized (SendDatas.sendDataArrayList) {
            sendDataArrayList.add(sendDatas);// 加入到发送缓冲区，等待发送线程来发送数据
        }
    }

    public static void AddSendData(int command, int desSubnetID, int desDeviceID, byte[] addBytes) {
        SendDatas sendDatas = new SendDatas();
        sendDatas.Command = command; // 这里的操作码最好是用枚举，这样才不会出错又方便
        sendDatas.DesSubnetID = desSubnetID;
        sendDatas.DesDeviceID = desDeviceID;
        sendDatas.AddBytes = addBytes;
        sendDatas.SendCount = 0; // 如果这个值大于2表示不需要重发了
        sendDatas.Port = 6000;
        synchronized (SendDatas.sendDataArrayList) {
            sendDataArrayList.add(sendDatas);// 加入到发送缓冲区，等待发送线程来发送数据
        }
    }

    public static void AddSendData(int command, int desSubnetID, int desDeviceID, byte[] addBytes, int sendCount) {
        SendDatas sendDatas = new SendDatas();
        sendDatas.Command = command; // 这里的操作码最好是用枚举，这样才不会出错又方便
        sendDatas.DesSubnetID = desSubnetID;
        sendDatas.DesDeviceID = desDeviceID;
        sendDatas.AddBytes = addBytes;
        sendDatas.SendCount = sendCount; // 如果这个值大于2表示不需要重发了
        sendDatas.Port = 6000;
        synchronized (SendDatas.sendDataArrayList) {
            sendDataArrayList.add(sendDatas);// 加入到发送缓冲区，等待发送线程来发送数据
        }
    }

    public static void AddSendData(int command, int desSubnetID, int desDeviceID, byte[] addBytes, int sendCount, InetAddress ip, int port) {
        SendDatas sendDatas = new SendDatas();
        sendDatas.Command = command; // 这里的操作码最好是用枚举，这样才不会出错又方便
        sendDatas.DesSubnetID = desSubnetID;
        sendDatas.DesDeviceID = desDeviceID;
        sendDatas.AddBytes = addBytes;
        sendDatas.SendCount = sendCount; // 如果这个值大于2表示不需要重发了
        sendDatas.InetAddress = ip;
        sendDatas.Port = port;
        synchronized (SendDatas.sendDataArrayList) {
            sendDataArrayList.add(sendDatas);// 加入到发送缓冲区，等待发送线程来发送数据
        }
    }

    /**
     * 更新发送是否成功的信息
     *
     * @param command
     * @param subnetID
     * @param deviceID
     * @param usefulBytes
     */
    public static void ReceiveBytes(int command, int subnetID, int deviceID, byte[] usefulBytes) {

        try {

            if (usefulBytes.length < 1) return;

            for (int i = 0; i < SendDatas.sendDataArrayList.size(); i++) {

                currentSendBytesInfo = sendDataArrayList.get(i);

                if (currentSendBytesInfo.DesSubnetID != subnetID || currentSendBytesInfo.DesDeviceID != deviceID || currentSendBytesInfo.Command + 1 != command)
                    continue;

                switch (command) {
                    case 0x0032:// 单路调节控制反馈
                    case 0x1939:// 模块空调读取反馈
                    case 0x193B:// 空调模块控制反馈
                    case 0xE01D:// 通用开关回复
                    case 0xE3D9:// 面板控制反馈
                    case 0xE3E3:// 窗帘开关读取回复
                    case 0xE45D:// 逻辑灯RGB控制返回
                    case 0xE473:// 逻辑灯RGB读取反馈
                    case 0x1c5f:// 地热m模块读取反馈
                    case 0x1c5d:// 地热模块控制反馈
                        if (currentSendBytesInfo.AddBytes[0] == usefulBytes[0]) {
                            currentSendBytesInfo.SendCount = FINISH;
                        }
                        break;
                    case 0x0003:// 场景控制反馈
                    case 0x001B:// 序列控制反馈
                    case 0x0034:// 灯光读取反馈
                    case 0x16A7:// 通用控制反馈
                    case 0xE3E1:// 窗帘开关回复
                    case 0x1945:// 地热面板读取反馈
                    case 0x1947:// 地热面板控制反馈
                        currentSendBytesInfo.SendCount = FINISH;
                        break;
                }
            }
        } catch (Exception e) {
            e.getMessage();
        }
    }

    // 加入重发列表
    public static void AddSendDataList(SendDatas sendDatas) {

        synchronized (RetransmissionDateList) {

            for (int i = 0; i < RetransmissionDateList.size(); i++) {

                SendDatas _data = RetransmissionDateList.get(i);

                switch (_data.Command) {
                    case 0x0031:// 单路调节控制反馈
                    case 0xE45C:// 逻辑灯RGB控制返回
                    case 0xE472:// 逻辑灯RGB读取反馈
                    case 0xE01C:// 通用开关回复
                    case 0xE3E0:// 窗帘开关回复
                    case 0x193A:// 空调模块控制反馈
                    case 0x1938:// 模块空调读取反馈
                    case 0xE3D8:// 面板控制反馈
                    case 0xE3E2:// 窗帘开关读取回复
                        if (_data.DesSubnetID == sendDatas.DesSubnetID && _data.DesDeviceID == sendDatas.DesDeviceID
                                && _data.Command == sendDatas.Command && _data.AddBytes[0] == sendDatas.AddBytes[0]) {
                            return;
                        }
                        break;
                    case 0x192E://音乐控制
                    case 0x1970:
                        return;
                    case 0x0034:// 灯光读取反馈
                    case 0x0003:// 场景控制反馈
                    case 0x001B:// 序列控制反馈
                    case 0x16A7:// 通用控制反馈
                    default:
                        if (_data.DesSubnetID == sendDatas.DesSubnetID && _data.DesDeviceID == sendDatas.DesDeviceID
                                && _data.Command == sendDatas.Command) {
                            return;
                        }
                        break;
                }
            }
            RetransmissionDateList.add(sendDatas);
        }
    }

    public static ArrayList<SendDatas> GetSendDataList() {
        return RetransmissionDateList;
    }


    /**
     * 字符串转换为整数
     *
     * @param s
     * @return
     */
    public static int GetStringToInteger(String s) {

        try {
            return Integer.parseInt(s);
        } catch (Exception e) {
            return 0;
        }
    }
}