package com.dahua.netsdk.lib;

import com.dahua.netsdk.lib.NetSDKLib.*;
import com.dahua.netsdk.lib.enumeration.LastErrorNew;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.Structure;
import com.sun.jna.ptr.IntByReference;

import java.io.*;
import java.math.BigInteger;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;
import java.security.MessageDigest;

public class ToolKits {
    static NetSDKLib netsdkapi = NetSDKLib.NETSDK_INSTANCE;
    static NetSDKLib configapi = NetSDKLib.CONFIG_INSTANCE;

    public ToolKits() {

    }

    /***************************************************************************************************
     *     CLIENT_GetNewDevConfig CLIENT_ParseData 和 CLIENT_PacketData  CLIENT_SetNewDevConfig 封装        *
     ***************************************************************************************************/
    /**
     * 获取多个配置
     *
     * @param hLoginHandle 登陆句柄
     * @param nChn         通道号，-1 表示全通道
     * @param strCmd       配置名称
     * @param cmdObjects   配置对应的结构体对象
     * @return 成功返回实际获取到的配置个数
     */
    public static int GetDevConfig(LLong hLoginHandle, int nChn, String strCmd, Structure[] cmdObjects) {
        IntByReference error = new IntByReference(0);
        int nBufferLen = 2 * 1024 * 1024;
        byte[] strBuffer = new byte[nBufferLen];

        if (!netsdkapi.CLIENT_GetNewDevConfig(hLoginHandle, strCmd, nChn, strBuffer, nBufferLen, error, 5000,null)) {
            System.err.printf("Get %s Config Failed!Last Error = %x\n", strCmd, netsdkapi.CLIENT_GetLastError());
            return -1;
        }

        IntByReference retLength = new IntByReference(0);
        int memorySize = cmdObjects.length * cmdObjects[0].size();
        Pointer objectsPointer = new Memory(memorySize);
        objectsPointer.clear(memorySize);

        SetStructArrToPointerData(cmdObjects, objectsPointer);

        if (!configapi.CLIENT_ParseData(strCmd, strBuffer, objectsPointer, memorySize, retLength.getPointer())) {
            System.err.println("Parse " + strCmd + " Config Failed!");
            return -1;
        }

        GetPointerDataToStructArr(objectsPointer, cmdObjects);

        return (retLength.getValue() / cmdObjects[0].size());
    }

    /**
     * 获取单个配置
     *
     * @param hLoginHandle 登陆句柄
     * @param nChn         通道号，-1 表示全通道
     * @param strCmd       配置名称
     * @param cmdObject    配置对应的结构体对象
     * @return 成功返回 true
     */
    public static boolean GetDevConfig(LLong hLoginHandle, int nChn, String strCmd, Structure cmdObject) {
        IntByReference error = new IntByReference(0);
        IntByReference retLen = new IntByReference(0);
        int nBufferLen = 2 * 1024 * 1024;
        byte[] strBuffer = new byte[nBufferLen];
        if (!netsdkapi.CLIENT_GetNewDevConfig(hLoginHandle, strCmd, nChn, strBuffer, nBufferLen, error, 5000,null)) {
            System.err.printf("Get %s Config Failed!Last Error = %x\n", strCmd, netsdkapi.CLIENT_GetLastError());
            return false;
        }
        cmdObject.write();
        if (!configapi.CLIENT_ParseData(strCmd, strBuffer, cmdObject.getPointer(), cmdObject.size(), retLen.getPointer())) {
            System.err.println("Parse " + strCmd + " Config Failed!" + ToolKits.getErrorCode());
            return false;
        }
        cmdObject.read();
        return true;
    }

    /**
     * 设置多个配置
     *
     * @param hLoginHandle 登陆句柄
     * @param nChn         通道号，-1 表示全通道
     * @param strCmd       配置名称
     * @param cmdObjects   配置对应的结构体对象
     * @return 成功返回 true
     */
    public static boolean SetDevConfig(LLong hLoginHandle, int nChn, String strCmd, Structure[] cmdObjects) {
        int nBufferLen = 2 * 1024 * 1024;
        byte[] szBuffer = new byte[nBufferLen];
        for (int i = 0; i < nBufferLen; i++) szBuffer[i] = 0;
        IntByReference error = new IntByReference(0);
        IntByReference restart = new IntByReference(0);

        int memorySize = cmdObjects.length * cmdObjects[0].size();
        Pointer objectsPointer = new Memory(memorySize);
        objectsPointer.clear(memorySize);

        SetStructArrToPointerData(cmdObjects, objectsPointer);

        if (!configapi.CLIENT_PacketData(strCmd, objectsPointer, memorySize, szBuffer, nBufferLen)) {
            System.err.println("Packet " + strCmd + " Config Failed!");
            return false;
        }

        String strOut = new String(szBuffer).trim();
        System.out.println(strOut);

        if (!netsdkapi.CLIENT_SetNewDevConfig(hLoginHandle, strCmd, nChn, szBuffer, nBufferLen, error, restart, 5000)) {
            System.err.printf("Set %s Config Failed! Last Error = %x\n", strCmd, netsdkapi.CLIENT_GetLastError());
            return false;
        }
        return true;
    }

    /**
     * 设置单个配置
     *
     * @param hLoginHandle 登陆句柄
     * @param nChn         通道号，-1 表示全通道
     * @param strCmd       配置名称
     * @param cmdObject    配置对应的结构体对象
     * @return 成功返回 true
     */
    public static boolean SetDevConfig(LLong hLoginHandle, int nChn, String strCmd, Structure cmdObject) {
        boolean result = false;
        int nBufferLen = 2 * 1024 * 1024;
        byte szBuffer[] = new byte[nBufferLen];
        for (int i = 0; i < nBufferLen; i++) szBuffer[i] = 0;
        IntByReference error = new IntByReference(0);
        IntByReference restart = new IntByReference(0);

        cmdObject.write();
        if (configapi.CLIENT_PacketData(strCmd, cmdObject.getPointer(), cmdObject.size(),
                szBuffer, nBufferLen)) {
            cmdObject.read();
            if (netsdkapi.CLIENT_SetNewDevConfig(hLoginHandle, strCmd, nChn, szBuffer, nBufferLen, error, restart, 5000)) {
                result = true;
            } else {
                System.err.printf("Set %s Config Failed! Last Error = %x\n", strCmd, netsdkapi.CLIENT_GetLastError());
                result = false;
            }
        } else {
            System.err.println("Packet " + strCmd + " Config Failed!");
            result = false;
        }

        return result;
    }

    public static void GetPointerData(Pointer pNativeData, Structure pJavaStu) {
        GetPointerDataToStruct(pNativeData, 0, pJavaStu);
    }

    public static void GetPointerDataToStruct(Pointer pNativeData, long OffsetOfpNativeData, Structure pJavaStu) {
        pJavaStu.write();
        Pointer pJavaMem = pJavaStu.getPointer();
        pJavaMem.write(0, pNativeData.getByteArray(OffsetOfpNativeData, pJavaStu.size()), 0,
                pJavaStu.size());
        pJavaStu.read();
    }

    public static void GetPointerDataToStructArr(Pointer pNativeData, Structure[] pJavaStuArr) {
        long offset = 0;
        for (int i = 0; i < pJavaStuArr.length; ++i) {
            GetPointerDataToStruct(pNativeData, offset, pJavaStuArr[i]);
            offset += pJavaStuArr[i].size();
        }
    }

    /**
     * 将结构体数组拷贝到内存
     *
     * @param pNativeData
     * @param pJavaStuArr
     */
    public static void SetStructArrToPointerData(Structure[] pJavaStuArr, Pointer pNativeData) {
        long offset = 0;
        for (int i = 0; i < pJavaStuArr.length; ++i) {
            SetStructDataToPointer(pJavaStuArr[i], pNativeData, offset);
            offset += pJavaStuArr[i].size();
        }
    }

    public static void SetStructDataToPointer(Structure pJavaStu, Pointer pNativeData, long OffsetOfpNativeData) {
        pJavaStu.write();
        Pointer pJavaMem = pJavaStu.getPointer();
        pNativeData.write(OffsetOfpNativeData, pJavaMem.getByteArray(0, pJavaStu.size()), 0, pJavaStu.size());
    }

    public static void ByteArrToStructure(byte[] pNativeData, Structure pJavaStu) {
        pJavaStu.write();
        Pointer pJavaMem = pJavaStu.getPointer();
        pJavaMem.write(0, pNativeData, 0, pJavaStu.size());
        pJavaStu.read();
    }

    public static void ByteArrZero(byte[] dst) {
        // 清零
        for (int i = 0; i < dst.length; ++i) {
            dst[i] = 0;
        }
    }

    //byte转换为byte[2]数组
    public static byte[] getByteArray(byte b) {
        byte[] array = new byte[8];
        for (int i = 0; i < 8; i++) {
            array[i] = (byte) ((b & (1 << i)) > 0 ? 1 : 0);
        }

        return array;
    }

    public static byte[] getByteArrayEx(byte b) {
        byte[] array = new byte[8];
        for (int i = 7; i >= 0; i--) {
            array[i] = (byte) (b & 1);
            b = (byte) (b >> 1);
        }
        return array;
    }

    public static void StringToByteArr(String src, byte[] dst) {
        try {
            byte[] GBKBytes = src.getBytes("GBK");
            for (int i = 0; i < GBKBytes.length; i++) {
                dst[i] = (byte) GBKBytes[i];
            }
        } catch (Exception e1) {
            e1.printStackTrace();
        }
    }

    public static long GetFileSize(String filePath) {
        File f = new File(filePath);
        if (f.exists() && f.isFile()) {
            return f.length();
        } else {
            return 0;
        }
    }

    public static boolean ReadAllFileToMemory(String file, Memory mem) {
        if (mem != Memory.NULL) {
            long fileLen = GetFileSize(file);
            if (fileLen <= 0) {
                return false;
            }

            try {
                File infile = new File(file);
                if (infile.canRead()) {
                    FileInputStream in = new FileInputStream(infile);
                    int buffLen = 1024;
                    byte[] buffer = new byte[buffLen];
                    long currFileLen = 0;
                    int readLen = 0;
                    while (currFileLen < fileLen) {
                        readLen = in.read(buffer);
                        mem.write(currFileLen, buffer, 0, readLen);
                        currFileLen += readLen;
                    }

                    in.close();
                    return true;
                } else {
                    System.err.println("Failed to open file %s for read!!!\n");
                    return false;
                }
            } catch (Exception e) {
                System.err.println("Failed to open file %s for read!!!\n");
                e.printStackTrace();
            }
        }

        return false;
    }

    public static void savePicture(byte[] pBuf, String sDstFile) {
        try {
            FileOutputStream fos = new FileOutputStream(sDstFile);
            fos.write(pBuf);
            fos.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void savePicture(Pointer pBuf, int dwBufSize, String sDstFile) {
        try {
            DataOutputStream out = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(sDstFile)));
            out.write(pBuf.getByteArray(0, dwBufSize), 0, dwBufSize);
            out.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void savePicture(Pointer pBuf, int dwBufOffset, int dwBufSize, String sDstFile) {
        try {
            DataOutputStream out = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(sDstFile)));
            out.write(pBuf.getByteArray(dwBufOffset, dwBufSize), 0, dwBufSize);
            out.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 读取本地图片到byte[]
    public static byte[] readPictureToByteArray(String filename) {
        File file = new File(filename);
        if (!file.exists()) {
            System.err.println("picture is not exist!");
            return null;
        }

        ByteArrayOutputStream byteOutStream = new ByteArrayOutputStream((int) file.length());
        BufferedInputStream byteInStream = null;
        try {
            byteInStream = new BufferedInputStream(new FileInputStream(file));
            byte[] buf = new byte[1024];
            int len = 0;
            while ((len = byteInStream.read(buf)) != -1) {
                byteOutStream.write(buf, 0, len);
            }
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                byteInStream.close();
                byteOutStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        return byteOutStream.toByteArray();
    }

    // 将一位数组转为二维数组
    public static byte[][] ByteArrToByteArrArr(byte[] byteArr, int count, int length) {
        if (count * length != byteArr.length) {
            System.err.println(count * length + " != " + byteArr.length);
            return null;
        }
        byte[][] byteArrArr = new byte[count][length];

        for (int i = 0; i < count; i++) {
            System.arraycopy(byteArr, i * length, byteArrArr[i], 0, length);
        }

        return byteArrArr;
    }

    /**
     * 获取接口错误码
     *
     * @return
     */
    public static String getErrorCode() {
        return " { error code: ( 0x80000000|" + (netsdkapi.CLIENT_GetLastError() & 0x7fffffff) + " ). 参考  LastError.java }";
    }

    public static String getLastError() {
        int lastError = netsdkapi.CLIENT_GetLastError();
        return   "FinalVar.java 对应的错误码 ：[0x80000000|" + (lastError & 0x7fffffff) + "]" + "\n" +
                "十六进制错误码 ：[" + String.format("%x", lastError) + "]" + "\n" +
                "对应中文错误信息为 ：[" + LastErrorNew.getChnNoteByValue(lastError) + "]"+ "\n" +
                "The corresponding English error message is ：[" + LastErrorNew.getEngNoteByValue(lastError) + "]"+ "\n";
    }
    /**
     * 显示目录中文件和子目录
     *
     * @param lLoginID 登陆句柄
     * @param szPath   查询的文件路径
     * @param stOut    出参
     * @return 返回文件/目录信息数组
     */
    public static SDK_REMOTE_FILE_INFO[] ListRemoteFile(LLong lLoginID, String szPath, NET_OUT_LIST_REMOTE_FILE stOut) {
        NET_IN_LIST_REMOTE_FILE stIn = new NET_IN_LIST_REMOTE_FILE();
        stIn.pszPath = "/mnt/sdcard/" + szPath;
        stIn.bFileNameOnly = 1;  // 只获取文件名称, 不返回文件夹信息, 文件信息中只有文件名有效
        stIn.emCondition = NET_REMOTE_FILE_COND.NET_REMOTE_FILE_COND_NONE;

        int maxFileCount = 50;  // 每次查询的文件个数
        SDK_REMOTE_FILE_INFO[] remoteFileArr;
        while (true) {
            remoteFileArr = new SDK_REMOTE_FILE_INFO[maxFileCount];
            for (int i = 0; i < maxFileCount; i++) {
                remoteFileArr[i] = new SDK_REMOTE_FILE_INFO();
            }

            stOut.nMaxFileCount = maxFileCount;
            stOut.pstuFiles = new Memory(remoteFileArr[0].size() * maxFileCount);   // Pointer初始化
            stOut.pstuFiles.clear(remoteFileArr[0].size() * maxFileCount);

            ToolKits.SetStructArrToPointerData(remoteFileArr, stOut.pstuFiles);    // 将数组内存拷贝给Pointer

            if (netsdkapi.CLIENT_ListRemoteFile(lLoginID, stIn, stOut, 3000)) {
                if (maxFileCount > stOut.nRetFileCount) {
                    ToolKits.GetPointerDataToStructArr(stOut.pstuFiles, remoteFileArr);    // 将Pointer的信息输出到结构体
                    break;
                } else {
                    maxFileCount += 50;
                }
            } else {
                return null;
            }
        }
        return remoteFileArr;
    }

    /**
     * 显示目录中文件和子目录
     *
     * @param lLoginID 登陆句柄
     * @param szPath   查询的文件路径
     * @param stOut    出参
     * @return 返回文件/目录信息数组
     */
    public static SDK_REMOTE_FILE_INFO[] ListAudioFile(LLong lLoginID, String szPath, NET_OUT_LIST_REMOTE_FILE stOut) {
        NET_IN_LIST_REMOTE_FILE stIn = new NET_IN_LIST_REMOTE_FILE();
        stIn.pszPath = szPath;
        stIn.bFileNameOnly = 1;  // 只获取文件名称, 不返回文件夹信息, 文件信息中只有文件名有效
        stIn.emCondition = NET_REMOTE_FILE_COND.NET_REMOTE_FILE_COND_NONE;

        int maxFileCount = 50;  // 每次查询的文件个数
        SDK_REMOTE_FILE_INFO[] remoteFileArr;
        while (true) {
            remoteFileArr = new SDK_REMOTE_FILE_INFO[maxFileCount];
            for (int i = 0; i < maxFileCount; i++) {
                remoteFileArr[i] = new SDK_REMOTE_FILE_INFO();
            }

            stOut.nMaxFileCount = maxFileCount;
            stOut.pstuFiles = new Memory(remoteFileArr[0].size() * maxFileCount);   // Pointer初始化
            stOut.pstuFiles.clear(remoteFileArr[0].size() * maxFileCount);

            ToolKits.SetStructArrToPointerData(remoteFileArr, stOut.pstuFiles);    // 将数组内存拷贝给Pointer

            if (netsdkapi.CLIENT_ListRemoteFile(lLoginID, stIn, stOut, 3000)) {
                if (maxFileCount > stOut.nRetFileCount) {
                    ToolKits.GetPointerDataToStructArr(stOut.pstuFiles, remoteFileArr);    // 将Pointer的信息输出到结构体
                    break;
                } else {
                    maxFileCount += 50;
                }
            } else {
                return null;
            }
        }
        return remoteFileArr;
    }

    /**
     * 删除文件或目录,删除具体的文件或者一类文件
     *
     * @param lLoginID 登陆句柄
     * @param szPath   删除的文件名称
     */
    public static boolean RemoveRemoteFilesEx(LLong lLoginID, String szPath) {
        boolean bRet = false;
        if (szPath.indexOf("*") != -1) {    // 删除一类文件
            String[] szPathStr = szPath.split("[*]");

            String szFindPath = szPathStr[0];                // 查询文件路径
            String szFileType = szPathStr[1].substring(1);  // 文件类型

            // 查询当前路径下的文件
            NET_OUT_LIST_REMOTE_FILE stOut = new NET_OUT_LIST_REMOTE_FILE();

            SDK_REMOTE_FILE_INFO[] remoteFile = ToolKits.ListRemoteFile(lLoginID, szFindPath, stOut);
            if (remoteFile != null) {
                for (int i = 0; i < stOut.nRetFileCount; i++) {
                    // 过滤并删除
                    if (new String(remoteFile[i].szPath).trim().indexOf(szFileType) != -1) {
                        bRet = RemoveRemoteFiles(lLoginID, szFindPath + new String(remoteFile[i].szPath).trim());
                    }
                }
            }
        } else { // 删除具体的文件
            bRet = RemoveRemoteFiles(lLoginID, szPath);
        }
        return bRet;
    }

    /**
     * 删除多个文件或目录
     *
     * @param lLoginID 登陆句柄
     * @param szPath   删除的文件名称
     * @return true 成功; false 失败
     */
    public static boolean RemoveRemoteFilesArr(LLong lLoginID, String[] szPath) {
        FILE_PATH[] filePath = new FILE_PATH[szPath.length];
        for (int i = 0; i < szPath.length; i++) {
            filePath[i] = new FILE_PATH();
        }

        for (int i = 0; i < szPath.length; i++) {
            filePath[i].pszPath = "/mnt/sdcard/" + szPath[i];
            System.out.println("/mnt/sdcard/" + szPath[i]);
        }

        // 入参
        NET_IN_REMOVE_REMOTE_FILES stIn = new NET_IN_REMOVE_REMOTE_FILES();
        stIn.nFileCount = szPath.length;
        stIn.pszPathPointer = new Memory(filePath[0].size() * szPath.length);
        stIn.pszPathPointer.clear(filePath[0].size() * szPath.length);

        ToolKits.SetStructArrToPointerData(filePath, stIn.pszPathPointer);

        // 出参
        NET_OUT_REMOVE_REMOTE_FILES stOut = new NET_OUT_REMOVE_REMOTE_FILES();

        boolean bRet = netsdkapi.CLIENT_RemoveRemoteFiles(lLoginID, stIn, stOut, 3000);

        return bRet;
    }

    /**
     * 删除单个文件或目录
     *
     * @param lLoginID 登陆句柄
     * @param szPath   删除的文件名称
     * @return true 成功; false 失败
     */
    public static boolean RemoveAudioFiles(LLong lLoginID, String szPath) {
        FILE_PATH filePath = new FILE_PATH();
        filePath.pszPath = szPath;

        // 入参
        NET_IN_REMOVE_REMOTE_FILES stIn = new NET_IN_REMOVE_REMOTE_FILES();
        stIn.nFileCount = 1;
        stIn.pszPathPointer = filePath.getPointer();

        // 出参
        NET_OUT_REMOVE_REMOTE_FILES stOut = new NET_OUT_REMOVE_REMOTE_FILES();

        filePath.write();
        boolean bRet = netsdkapi.CLIENT_RemoveRemoteFiles(lLoginID, stIn, stOut, 3000);
        filePath.read();

        return bRet;
    }

    /**
     * 删除单个文件或目录
     *
     * @param lLoginID 登陆句柄
     * @param szPath   删除的文件名称
     * @return true 成功; false 失败
     */
    public static boolean RemoveRemoteFiles(LLong lLoginID, String szPath) {
        FILE_PATH filePath = new FILE_PATH();
        filePath.pszPath = "/mnt/sdcard/" + szPath;

        // 入参
        NET_IN_REMOVE_REMOTE_FILES stIn = new NET_IN_REMOVE_REMOTE_FILES();
        stIn.nFileCount = 1;
        stIn.pszPathPointer = filePath.getPointer();

        // 出参
        NET_OUT_REMOVE_REMOTE_FILES stOut = new NET_OUT_REMOVE_REMOTE_FILES();

        filePath.write();
        boolean bRet = netsdkapi.CLIENT_RemoveRemoteFiles(lLoginID, stIn, stOut, 3000);
        filePath.read();

        return bRet;
    }

    /**
     * 获取播放盒上全部节目信息
     *
     * @param lLoginID d登陆句柄
     * @param stOut    出参
     * @return 返回播放盒节目信息数组
     */
    public static NET_PROGRAM_ON_PLAYBOX[] GetAllProgramOnPlayBox(LLong lLoginID, NET_OUT_GET_ALL_PLAYBOX_PROGRAM stOut) {
        // 入参
        NET_IN_GET_ALL_PLAYBOX_PROGRAM stIn = new NET_IN_GET_ALL_PLAYBOX_PROGRAM();

        NET_PROGRAM_ON_PLAYBOX[] playboxArr;
        int maxProgramCount = 10; // 每次查询的节目信息个数
        while (true) {
            playboxArr = new NET_PROGRAM_ON_PLAYBOX[maxProgramCount];
            for (int i = 0; i < maxProgramCount; i++) {
                playboxArr[i] = new NET_PROGRAM_ON_PLAYBOX();
                for (int j = 0; j < NetSDKLib.MAX_WINDOWS_COUNT; j++) {
                    // 申请一块内存，自己设置，设置大点
                    playboxArr[i].stuOrdinaryInfo.stuWindowsInfo[j].pstElementsBuf = new Memory(100 * 1024);
                    playboxArr[i].stuOrdinaryInfo.stuWindowsInfo[j].pstElementsBuf.clear(100 * 1024);
                    playboxArr[i].stuOrdinaryInfo.stuWindowsInfo[j].nBufLen = 100 * 1024;
                }
            }

            // 出参
            stOut.nMaxProgramCount = maxProgramCount;
            stOut.pstProgramInfo = new Memory(playboxArr[0].size() * maxProgramCount);
            stOut.pstProgramInfo.clear(playboxArr[0].size() * maxProgramCount);

            ToolKits.SetStructArrToPointerData(playboxArr, stOut.pstProgramInfo);   // 将数组内存拷贝给Pointer

            if (netsdkapi.CLIENT_GetAllProgramOnPlayBox(lLoginID, stIn, stOut, 3000)) {
                if (maxProgramCount > stOut.nRetProgramCount) {
                    ToolKits.GetPointerDataToStructArr(stOut.pstProgramInfo, playboxArr);    // 将Pointer的信息输出到结构体
                    break;
                } else {
                    maxProgramCount += 10;
                }
            } else {
                return null;
            }
        }

        return playboxArr;
    }

    /**
     * 批量删除节目信息
     *
     * @param lLoginID          登陆句柄
     * @param szProGrammeIdList 需要删除的节目ID
     * @return true 成功; false 失败
     */
    public static boolean DelMultiProgrammesById(LLong lLoginID, String[] szProGrammeIdList) {
        // 入参
        NET_IN_DEL_PROGRAMMES stIn = new NET_IN_DEL_PROGRAMMES();
        stIn.nProgrammeID = szProGrammeIdList.length;  // 需要删除的节目ID个数

        for (int i = 0; i < szProGrammeIdList.length; i++) {
            System.arraycopy(szProGrammeIdList[i].getBytes(), 0, stIn.szProGrammeIdListArr[i].szProGrammeIdList, 0, szProGrammeIdList[i].getBytes().length);
        }

        // 出参
        NET_OUT_DEL_PROGRAMMES stOut = new NET_OUT_DEL_PROGRAMMES();

        return netsdkapi.CLIENT_DelMultiProgrammesById(lLoginID, stIn, stOut, 5000);
    }

    /**
     * 删除多个节目计划
     *
     * @param lLoginID 登陆句柄
     * @param szPlanID 需要删除的计划ID
     * @return true 成功; false 失败
     */
    public static boolean DelMultiProgrammePlans(LLong lLoginID, String[] szPlanID) {
        // 入参
        NET_IN_DEL_PROGRAMMEPLANS stIn = new NET_IN_DEL_PROGRAMMEPLANS();
        stIn.nPlanID = szPlanID.length;  // 节目计划ID个数

        for (int i = 0; i < szPlanID.length; i++) {
            System.arraycopy(szPlanID[i].getBytes(), 0, stIn.szPlanIDArr[i].szPlanID, 0, szPlanID[i].getBytes().length);
        }

        // 出参
        NET_OUT_DEL_PROGRAMMEPLANS stOut = new NET_OUT_DEL_PROGRAMMEPLANS();

        return netsdkapi.CLIENT_DelMultiProgrammePlans(lLoginID, stIn, stOut, 5000);
    }

    /**
     * 获取所有节目计划信息
     *
     * @param lLoginID 登陆句柄
     * @param stOut    出参
     * @return NET_PROGRAMME_PLANS_INFO 结构体
     */
    public static NET_PROGRAMME_PLANS_INFO GetAllProgrammePlans(LLong lLoginID, NET_OUT_GET_ALL_PROGRAMMEPLANS stOut) {
        // 入参
        NET_IN_GET_ALL_PROGRAMMEPLANS stIn = new NET_IN_GET_ALL_PROGRAMMEPLANS();

        NET_PROGRAMME_PLANS_INFO planInfo;
        int maxPlanCnt = 10; // 每次查询的计划个数
        while (true) {
            planInfo = new NET_PROGRAMME_PLANS_INFO(maxPlanCnt);

            // 出参
            stOut.nMaxPlanCnt = maxPlanCnt;
            stOut.pstImmePlan = new Memory(stOut.nMaxPlanCnt * planInfo.szImmePlan[0].size());
            stOut.pstImmePlan.clear(stOut.nMaxPlanCnt * planInfo.szImmePlan[0].size());

            stOut.pstTimerPlan = new Memory(stOut.nMaxPlanCnt * planInfo.szTimerPlan[0].size());
            stOut.pstTimerPlan.clear(stOut.nMaxPlanCnt * planInfo.szTimerPlan[0].size());

            ToolKits.SetStructArrToPointerData(planInfo.szImmePlan, stOut.pstImmePlan);       // 将数组内存拷贝给Pointer
            ToolKits.SetStructArrToPointerData(planInfo.szTimerPlan, stOut.pstTimerPlan);     // 将数组内存拷贝给Pointer

            if (netsdkapi.CLIENT_GetAllProgrammePlans(lLoginID, stIn, stOut, 3000)) {
                if (maxPlanCnt > stOut.nRetImmCnt && maxPlanCnt > stOut.nRetTimerCnt) {
                    ToolKits.GetPointerDataToStructArr(stOut.pstImmePlan, planInfo.szImmePlan);  // 将Pointer的值输出到数组
                    ToolKits.GetPointerDataToStructArr(stOut.pstTimerPlan, planInfo.szTimerPlan);  // 将Pointer的值输出到数组
                    break;
                } else {
                    maxPlanCnt += 10;
                }
            } else {
                return null;
            }
        }
        return planInfo;
    }

    // Win下，将GBK String类型的转为Pointer
    public static Pointer GetGBKStringToPointer(String src) {
        Pointer pointer = null;
        try {
            byte[] b = src.getBytes("GBK");

            pointer = new Memory(b.length + 1);
            pointer.clear(b.length + 1);

            pointer.write(0, b, 0, b.length);
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        return pointer;
    }

    // win下，将Pointer值转为 GBK String
    public static String GetPointerDataToGBKString(Pointer pointer) {
        String str = "";
        if (pointer == null) {
            return str;
        }

        int length = 0;
        byte[] bufferPlace = new byte[1];

        for (int i = 0; i < 2048; i++) {
            pointer.read(i, bufferPlace, 0, 1);
            if (bufferPlace[0] == '\0') {
                length = i;
                break;
            }
        }

        if (length > 0) {
            byte[] buffer = new byte[length];
            pointer.read(0, buffer, 0, length);
            try {
                str = new String(buffer, "GBK").trim();
            } catch (UnsupportedEncodingException e) {
                return str;
            }
        }

        return str;
    }

    // win下，将Pointer值转为 GBK String
    public static String GetPointerDataToGBKString(Pointer pointer, int length) {
        String str = "";
        if (pointer == null) {
            return str;
        }

        if (length > 0) {
            byte[] buffer = new byte[length];
            pointer.read(0, buffer, 0, length);
            try {
                str = new String(buffer, "GBK").trim();
            } catch (UnsupportedEncodingException e) {
                return str;
            }
        }

        return str;
    }

    public static void StringToByteArray(String src, byte[] dst) {
        for (int i = 0; i < dst.length; i++) {
            dst[i] = 0;
        }

        System.arraycopy(src.getBytes(), 0, dst, 0, src.getBytes().length);
    }

    /**
     * 生成MD5
     *
     * @param path 图片路径
     * @return MD5
     * @throws FileNotFoundException
     */
    public static String GetStringMD5(String path) {
        File file = new File(path);

        String value = "";
        FileInputStream inputStream = null;

        try {
            inputStream = new FileInputStream(file);
            MappedByteBuffer byteBuffer = inputStream.getChannel().map(FileChannel.MapMode.READ_ONLY, 0, file.length());
            MessageDigest md5 = MessageDigest.getInstance("MD5");
            md5.update(byteBuffer);
            BigInteger bi = new BigInteger(1, md5.digest());
            value = bi.toString(16);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (null != inputStream) {
                try {
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return value;
    }

    /**
     * 写入流数据
     *
     * @param stream
     * @return
     */
    public static Pointer setStreamToPointer(InputStream stream) {
        Pointer pointer = null;
        try {
            int size = stream.available();
            pointer = new Memory(size);
            byte[] data = new byte[size];
            stream.read(data);
            pointer.write(0, data, 0, size);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            return pointer;
        }

    }
}