package com.sincere.haikangface;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.sincere.haikangface.bean.*;
import com.sincere.haikangface.bean.xiaoan.Face_Recoder;
import com.sincere.haikangface.dao.DeviceDao;
import com.sincere.haikangface.dao.UserDao;
import com.sincere.haikangface.haikanglibs.HCEHomeAlarm;
import com.sincere.haikangface.haikanglibs.HCEHomeCMS;
import com.sincere.haikangface.haikanglibs.HCEHomeSS;
import com.sincere.haikangface.mqtt.MqtUtils;
import com.sincere.haikangface.utils.*;
import com.sincere.haikangface.xiananDao.SendRecordDao;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.io.*;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.nio.ByteBuffer;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

@Component
public class CMSServer implements ApplicationRunner {

    @Autowired
    DeviceDao deviceDao;

    @Autowired
    UserDao userDao;


    @Autowired
    SendRecordDao sendRecordDao;

    private String ip;

    {
        try {
            ip = InetAddress.getLocalHost().getHostAddress();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run(ApplicationArguments args) {

        if (null == sendRecoderUtils) sendRecoderUtils = new SendRecoderUtils();

        //注册服务初始化
        initCMS();

        //图片服务初始化
        initSS();

        //初始化报警监听
        initAlarm();

    }

    static HCEHomeCMS hCEhomeCMS = HCEHomeCMS.INSTANCE;
    FRegisterCallBack fRegisterCallBack;//注册回调函数实现
    //    NativeLong lLoginID;//用户句柄
    HCEHomeCMS.NET_EHOME_CMS_LISTEN_PARAM struCMSListenPara = new HCEHomeCMS.NET_EHOME_CMS_LISTEN_PARAM();
    Map<String, NativeLong> map = new HashMap<>();

    private void initCMS() {

        ////////////////////////////////////////////////////////////////////////
        //CMS注册和预览请求

        //CMS注册模块初始化
        boolean binit = hCEhomeCMS.NET_ECMS_Init();

        //注册监听参数
        if (fRegisterCallBack == null) {
            fRegisterCallBack = new FRegisterCallBack();
        }
        hCEhomeCMS.NET_ECMS_SetLogToFile(3, "C:/Ehomejavademo/EHomeSDKLog", false);

        struCMSListenPara.struAddress.szIP = ip.getBytes();
        struCMSListenPara.struAddress.wPort = 7660;
        struCMSListenPara.fnCB = fRegisterCallBack;

        //启动监听，接收设备注册信息
        NativeLong lListen = hCEhomeCMS.NET_ECMS_StartListen(struCMSListenPara);
        if (lListen.longValue() < -1) {
            System.out.println("注册模块初始化失败:" + hCEhomeCMS.NET_ECMS_GetLastError());
            hCEhomeCMS.NET_ECMS_Fini();
            return;
        }
        System.out.println("启动注册监听成功!");
    }

    /**
     * 判断设备是否在线
     *
     * @param deviceId
     */
    public boolean getIsDeviceOnline(String deviceId) {
        return map.containsKey(deviceId) ? true : false;
    }

    public class FRegisterCallBack implements HCEHomeCMS.DEVICE_REGISTER_CB {
        public boolean invoke(NativeLong lUserID, int dwDataType, Pointer pOutBuffer, int dwOutLen, HCEHomeCMS.NET_EHOME_SERVER_INFO pInBuffer, int dwInLen, Pointer pUser) {
            String deviceId = "";
            System.out.println("dwDataType:" + dwDataType);
            if (dwDataType == 0) {
                HCEHomeCMS.NET_EHOME_DEV_REG_INFO strDevRegInfo = new HCEHomeCMS.NET_EHOME_DEV_REG_INFO();
                strDevRegInfo.write();
                Pointer pDevRegInfo = strDevRegInfo.getPointer();
                pDevRegInfo.write(0, pOutBuffer.getByteArray(0, strDevRegInfo.size()), 0, strDevRegInfo.size());
                strDevRegInfo.read();
                try {
                    deviceId = new String(strDevRegInfo.byDeviceID, "utf-8").trim();
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
                pInBuffer.dwSize = pInBuffer.size();
                System.err.println("注册成功：" + deviceId);
                AttendanceBean attendanceBean = new AttendanceBean();
                attendanceBean.setClint_id(deviceId);
                attendanceBean.setClint_type("18");
                attendanceBean.setIntime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
                attendanceBean.setIsConnection(1);
                attendanceBean.setSchool_id("-1");
                attendanceBean.setState(1);
                if (deviceDao.selectDevice(deviceId) != null) {
                    deviceDao.updateDeviceStatu(1, deviceId);
                } else {
                    deviceDao.addDevide(attendanceBean.getClint_id(), attendanceBean.getClint_type(), attendanceBean.getIntime(),
                            attendanceBean.getSchool_id(), attendanceBean.getState() + "", attendanceBean.getIsConnection() + "");
                }
                /*这里加判断即可，可以通过byDeviceID、sDeviceSerial、sDevName 进行判断
                if(strDevRegInfo.dwDevType == 1)
                {
                    pInBuffer.dwAlarmServerType = 3;
                }
                else
                {
                    pInBuffer.dwAlarmServerType = 1;
                }
                */

                byte[] byIP = ip.getBytes();
                System.arraycopy(byIP, 0, pInBuffer.struUDPAlarmSever.szIP, 0, byIP.length);
                pInBuffer.dwAlarmServerType = 0; //报警服务器类型：0- 只支持UDP协议上报，1- 支持UDP、TCP两种协议上报
                pInBuffer.struTCPAlarmSever.wPort = 7661;
                pInBuffer.struUDPAlarmSever.wPort = 7662;

                pInBuffer.dwPicServerType = 3;
                System.arraycopy(byIP, 0, pInBuffer.struPictureSever.szIP, 0, byIP.length);
                pInBuffer.struPictureSever.wPort = 8081;
                pInBuffer.write();
                dwInLen = pInBuffer.size();
//                lLoginID = lUserID;
                map.put(deviceId, lUserID);

               /* try {
                    Thread.sleep(1000);
                    for (int i = 0; i < 7; i++) {
                        SetCardWeekPlan(deviceId, HKXmlUtils.getInstance().SetCardWeekPlanTime("00:00:00", "23:00:00",""+i), "设置卡权限周计划时间");
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }*/

            } //设备下线
            return true;
        }
    }

    static HCEHomeSS hCEhomeSS = HCEHomeSS.INSTANCE;
    String PSS_CLIENT_FILE_PATH_PARAM_NAME = "File-Path"; //图片文件路径
    String PSS_CLIENT_VRB_FILENAME_CODE = "Filename-Code";//VRB协议的FilenameCode
    String PSS_CLIENT_KMS_USER_NAME = "KMS-Username"; //KMS图片服务器用户名
    String PSS_CLIENT_KMS_PASSWIRD = "KMS-Password"; //KMS图片服务器密码
    String PSS_CLIENT_CLOUD_AK_NAME = "Access-Key"; //云存储协议AcessKey
    String PSS_CLIENT_CLOUD_SK_NAME = "Secret-Key"; //云存储协议SecretKey
    String SS_STORAGE_PATH = "C:\\EhomePicServer"; //文件保存路径
    PSS_Message_Callback pSS_Message_Callback;// 信息回调函数(上报)
    PSS_Storage_Callback pSS_Storage_Callback;// 文件保存回调函数(下载)
    HCEHomeSS.NET_EHOME_SS_LISTEN_PARAM pSSListenParam = new HCEHomeSS.NET_EHOME_SS_LISTEN_PARAM();
    NativeLong listenSS = new NativeLong(-1);

    private void initSS() {
        boolean sinit = hCEhomeSS.NET_ESS_Init();
        if (!sinit) {
            System.out.println("NET_ESS_Init失败!");
        }
        boolean logToFile = hCEhomeSS.NET_ESS_SetLogToFile(3, "C:/Ehomejavademo/EHomeSDKLog", false);

        if (pSS_Message_Callback == null) {
            pSS_Message_Callback = new PSS_Message_Callback();
        }

        if (pSS_Storage_Callback == null) {
            pSS_Storage_Callback = new PSS_Storage_Callback();
        }

        String strIP = ip;
        System.arraycopy(strIP.getBytes(), 0, pSSListenParam.struAddress.szIP, 0, strIP.length());

        pSSListenParam.struAddress.wPort = 8081;

        String strKMS_UserName = "test";
        System.arraycopy(strKMS_UserName.getBytes(), 0, pSSListenParam.szKMS_UserName, 0, strKMS_UserName.length());

        String strKMS_Password = "12345";
        System.arraycopy(strKMS_Password.getBytes(), 0, pSSListenParam.szKMS_Password, 0, strKMS_Password.length());

        String strAccessKey = "test";
        System.arraycopy(strAccessKey.getBytes(), 0, pSSListenParam.szAccessKey, 0, strAccessKey.length());

        String strSecretKey = "12345";
        System.arraycopy(strSecretKey.getBytes(), 0, pSSListenParam.szSecretKey, 0, strSecretKey.length());

        pSSListenParam.byHttps = 0;
        pSSListenParam.fnSSMsgCb = pSS_Message_Callback;
        pSSListenParam.fnSStorageCb = pSS_Storage_Callback;

        pSSListenParam.write();

        listenSS = hCEhomeSS.NET_ESS_StartListen(pSSListenParam);
        if (listenSS.intValue() == -1) {
            int err = hCEhomeSS.NET_ESS_GetLastError();
            System.err.println("图片服务启动注册监听失败,错误号:" + err);
            return;
        } else {
            System.out.println("图片服务启动注册监听成功!");
        }
    }

    //信息回调函数(上报)
    public class PSS_Message_Callback implements HCEHomeSS.EHomeSSMsgCallBack {

        public boolean invoke(NativeLong iHandle, int enumType, Pointer pOutBuffer, int dwOutLen, Pointer pInBuffer,
                              int dwInLen, Pointer pUser) {
            System.out.println("信息回调函数");
            if (1 == enumType) {
                HCEHomeSS.NET_EHOME_SS_TOMCAT_MSG pTomcatMsg = new HCEHomeSS.NET_EHOME_SS_TOMCAT_MSG();
                String szDevUri = new String(pTomcatMsg.szDevUri).trim();
                int dwPicNum = pTomcatMsg.dwPicNum;
                String pPicURLs = pTomcatMsg.pPicURLs;
//                System.out.println("szDevUri = " + szDevUri + "   dwPicNum= " + dwPicNum + "   pPicURLs=" + pPicURLs);
            } else if (2 == enumType) {

                //				int type = pInBuffer.dwAlarmServerType;
                //				int picServerType = pInBuffer.dwPicServerType;
                //				System.out.println("type=" + type + "   picType=" + picServerType);

            } else if (3 == enumType) {

            }
            return true;
        }
    }

    //文件保存回调函数(下载)
    public class PSS_Storage_Callback implements HCEHomeSS.EHomeSSStorageCallBack {

        public boolean invoke(NativeLong iHandle, String pFileName, Pointer pFileBuf, int dwFileLen, Pointer pFilePath, Pointer pUser) {
            String strPath = "C://EhomePicServer/";
            System.out.println("pFileName:" + pFileName);
            pFileName = pFileName.replace("_", "");
            boolean isZhuaPai = false;
            if (pFileName.contains("-")) {//人脸抓拍机抓拍到的图片
                if (!ip.contains("172.16"))
                    strPath = "E://wwwhtdocs//SmartCampus//face17e5//School16//Student//";//测试服务器
                pFileName = pFileName.split("T")[0] + ".jpg";
                isZhuaPai = true;
            }
            String strFilePath = strPath + pFileName;
            FileUtils.getInstance().writeLogs("文件名:" + pFileName, FileUtils.fileName);
            //保存抓拍到的人脸图片，比对通过后的图片资源

//            System.out.println("文件保存回调函数：" + strFilePath);
            //若此目录不存在，则创建之
            File myPath = new File(strPath);
            if (!myPath.exists()) {
                myPath.mkdir();
                System.out.println("创建文件夹路径为：" + strPath);
            }

            File strFilePathFile = new File(strFilePath);
            if (!strFilePathFile.exists()) {
                try {
                    strFilePathFile.createNewFile();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (dwFileLen > 0 && pFileBuf != null) {
                FileOutputStream fout;
                try {
                    fout = new FileOutputStream(strFilePath);
                    //将字节写入文件
                    long offset = 0;
                    ByteBuffer buffers = pFileBuf.getByteBuffer(offset, dwFileLen);
                    byte[] bytes = new byte[dwFileLen];
                    buffers.rewind();
                    buffers.get(bytes);
                    fout.write(bytes);
                    fout.close();
                } catch (FileNotFoundException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }

            pFilePath.write(0, strFilePath.getBytes(), 0, strFilePath.getBytes().length);

            if (isZhuaPai) {
//                MqtUtils.getInstance().sendMsg("http://campus.myjxt.com//face17e5/School16/Student/" + pFileName);
            }

            return true;
        }
    }

    HCEHomeAlarm.NET_EHOME_ALARM_LISTEN_PARAM net_ehome_alarm_listen_param = new HCEHomeAlarm.NET_EHOME_ALARM_LISTEN_PARAM();
    EHomeMsgCallBack cbEHomeMsgCallBack;
    ;//报警监听回调函数实现

    private void initAlarm() {

        HCEHomeAlarm mHCEHomeAlarm = HCEHomeAlarm.INSTANCE;
        boolean bRet = mHCEHomeAlarm.NET_EALARM_Init();
        if (!bRet) {
            System.out.println("NET_EALARM_Init failed!");
        }
        System.out.println("NET_EALARM_Init!");
        if (cbEHomeMsgCallBack == null) {
            cbEHomeMsgCallBack = new EHomeMsgCallBack();
        }

        net_ehome_alarm_listen_param.struAddress.szIP = ip.getBytes();
        net_ehome_alarm_listen_param.struAddress.wPort = 7662;
        net_ehome_alarm_listen_param.fnMsgCb = cbEHomeMsgCallBack;
        net_ehome_alarm_listen_param.pUserData = null;
        net_ehome_alarm_listen_param.byProtocolType = 1; //协议类型：0- TCP，1- UDP
        net_ehome_alarm_listen_param.byUseCmsPort = 0; //是否复用CMS端口：0- 不复用，非0- 复用
        //如果复用cms端口，协议类型字段无效，此时AMS的本地监听信息struAddress填本地回环地址，
        //本地回环地址通过NET_ECMS_GetSDKLocalCfg、NET_ECMS_SetSDKLocalCfg获取和设置）

        NativeLong ARMListen = mHCEHomeAlarm.NET_EALARM_StartListen(net_ehome_alarm_listen_param);
        if (ARMListen.byteValue() < 0) {
            System.out.println("NET_EALARM_StartListen失败, error code:" + hCEhomeCMS.NET_ECMS_GetLastError());
            return;
        } else {
            /*复用CMS端口接收设备上传报警信息的时候需要调用以下接口配置
            HCEHomeCMS.NET_EHOME_AMS_ADDRESS struAMSAddr= new HCEHomeCMS.NET_EHOME_AMS_ADDRESS();
            struAMSAddr.dwSize = struAMSAddr.size();
            struAMSAddr.byEnable = 1;//是否启用：0-关闭CMS接收报警功能，1-开启CMS接收报警功能
            String strAmsAddr = "10.17.36.25";
            System.arraycopy(strAmsAddr.getBytes(), 0, struAMSAddr.struAddress.szIP, 0, strAmsAddr.length());
            struAMSAddr.struAddress.wPort = 7662; //和报警服务器监听端口需要一致
            struAMSAddr.write();

            if(!hCEhomeCMS.NET_ECMS_SetSDKLocalCfg(1, struAMSAddr.getPointer()))
            {
                JOptionPane.showMessageDialog(null, "NET_ECMS_SetSDKLocalCfg failed, error code:" + hCEhomeCMS.NET_ECMS_GetLastError());
            }*/
            System.out.println("启动报警监听成功");
        }
        System.out.println("NET_EALARM_StartListen:" + ARMListen);
    }

    private AlarmUtils alarmUtils;//报警工具类

    /**
     * 报警监听回调
     */
    class EHomeMsgCallBack implements HCEHomeAlarm.EHomeMsgCallBack {
        @Override
        public boolean invoke(NativeLong iHandle, HCEHomeAlarm.NET_EHOME_ALARM_MSG pAlarmMsg, Pointer pUser) {

            if (pAlarmMsg.dwXmlBufLen != 0) {
                HCEHomeAlarm.BYTE_ARRAY strXMLData = new HCEHomeAlarm.BYTE_ARRAY(pAlarmMsg.dwXmlBufLen);
                strXMLData.write();
                Pointer pPlateInfo = strXMLData.getPointer();
                pPlateInfo.write(0, pAlarmMsg.pXmlBuf.getByteArray(0, strXMLData.size()), 0, strXMLData.size());
                strXMLData.read();

                String strXML = new String(strXMLData.byValue);
//                System.out.println(strXML);

                if (null == alarmUtils) {
                    alarmUtils = new AlarmUtils(deviceDao);
                    alarmUtils.setCallBack(new AlarmUtils.AlarmCallBack() {
                        @Override
                        public void callBack(String minorType, String deviceID, String cardNo, String time, String picDataUrlId) {
                            switch (minorType) {
                                case "0x4b"://人脸认证通过
//                                    sendSMS(cardNo, deviceID, time);
                                    saveFaceRecoder(deviceID, cardNo, time, picDataUrlId);
                                    break;
                                case "0x426"://人证设备在线

                                    break;
                                case "0x427"://人证设备离线
                                    map.remove(deviceID);
                                    deviceDao.updateDeviceStatu(0, deviceID);
                                    break;
                                case "0x69"://人证比对通过
                                    saveFaceRecoder(deviceID, cardNo, time, picDataUrlId);
                                    break;
                            }
                        }
                    });
                } else {
                    //处理报警事件
                    alarmUtils.deleAlarm(strXML);
                }

            }
            return true;
        }
    }


    /**
     * @param deviceID
     * @param cardNo       十进制卡号
     * @param time
     * @param picDataUrlId
     */
    private void saveFaceRecoder(String deviceID, String cardNo, String time, String picDataUrlId) {

        if (!StringUtils.isEmpty(cardNo)) {
            Face_Recoder face_recoder = new Face_Recoder();

            //卡号逆转
            cardNo = sendRecoderUtils.getCard(splicingZero(Long.toHexString(Long.parseLong(cardNo)), 8).toUpperCase());

            StudentBean studentBean = userDao.getStudentWithCard(cardNo);

            if (null != studentBean) {
                FileUtils.getInstance().writeLogs(studentBean.getName() + " " + cardNo, FileUtils.facerecoder);

                face_recoder.setCardNum(cardNo);
                face_recoder.setDeviceId(deviceID);
                face_recoder.setTime(time);
                face_recoder.setName(studentBean.getName());
                //114.55.30.100
//                String imgUrl = "http://120.26.116.253:8081/kms/services/rest/dataInfoService/downloadFile?id=" + picDataUrlId;
                String imgUrl = "http://114.55.30.100:8081/kms/services/rest/dataInfoService/downloadFile?id=" + picDataUrlId;
                face_recoder.setImgurl(imgUrl);
                face_recoder.setUser_id(studentBean.getUser_id());
                face_recoder.setInOrOut(1);

                sendRecordDao.addFaceRecoder(face_recoder.getDeviceId(), face_recoder.getUser_id(), face_recoder.getName(),
                        face_recoder.getImgurl(), face_recoder.getInOrOut(), face_recoder.getTime(), face_recoder.getCardNum());
            }
        }

    }

    /**
     * 生成图片服务路径
     *
     * @param picUrl
     * @param deviceId
     * @return
     */
    public boolean createImgPath(String srcFile, String picUrl, String card, String startTime, String endTime, int validTimeEnabled, String name, String deviceId, String userType, String employeeNo) {

        if (map.containsKey(deviceId)) {
            HCEHomeSS.NET_EHOME_SS_CLIENT_PARAM pClientParam = new HCEHomeSS.NET_EHOME_SS_CLIENT_PARAM();
            pClientParam.enumType = HCEHomeSS.NET_EHOME_SS_CLIENT_TYPE_KMS;
            pClientParam.struAddress.szIP = ip.getBytes();
            pClientParam.struAddress.wPort = 8081;
            pClientParam.byHttps = 0;
            String url = "";
            NativeLong client = hCEhomeSS.NET_ESS_CreateClient(pClientParam);
            if (client.intValue() < 0) {
                int err = hCEhomeSS.NET_ESS_GetLastError();
                System.out.println("创建图片上传/下载客户端出错,错误号：" + err + "  ,client=" + client);
            } else {
                if (!hCEhomeSS.NET_ESS_ClientSetTimeout(client, 6000, 6000)) {
                    int err = hCEhomeSS.NET_ESS_GetLastError();
                    System.out.println("NET_ESS_ClientSetTimeout失败,错误号：" + err);
                }
                boolean bSetParam = hCEhomeSS.NET_ESS_ClientSetParam(client, PSS_CLIENT_FILE_PATH_PARAM_NAME, picUrl);

                boolean bCloud_AK = hCEhomeSS.NET_ESS_ClientSetParam(client, PSS_CLIENT_KMS_USER_NAME, "test");
                boolean bCloud_SK = hCEhomeSS.NET_ESS_ClientSetParam(client, PSS_CLIENT_KMS_PASSWIRD, "12345");

                byte[] szUrl = null;
                szUrl = new byte[HCEHomeSS.MAX_URL_LEN_SS];

                boolean doUpload = hCEhomeSS.NET_ESS_ClientDoUpload(client, szUrl, HCEHomeSS.MAX_URL_LEN_SS - 1);
                if (!doUpload) {
                    int err = hCEhomeSS.NET_ESS_GetLastError();
                    System.out.println("NET_ESS_ClientDoUpload失败，错误号：" + err);
                } else {
                    url = "http://120.26.116.253:" + 8081 + new String(szUrl).trim();
//                    System.err.println("NET_ESS_ClientDoUpload成功！:" + url);
                }
                hCEhomeSS.NET_ESS_DestroyClient(client);//释放资源
            }
            return sendInfo(srcFile, url, card, startTime, endTime, validTimeEnabled, name, deviceId, userType, employeeNo);
        }
        sendRecoderUtils.sendFail(sendRecordDao, card, srcFile, deviceId, userDao, "设备不在线", userType);
        return false;
    }

    /**
     * 下发用户信息
     *
     * @Param picUrl 原图
     */
    public boolean sendInfo(String srcFile, String url, String card, String startTime, String endTime, int validTimeEnabled, String name, String deviceId, String userType, String employeeNo) {
//        deleteCard(deviceId, card);
//        editCard(startTime, endTime, 0, name, card, deviceId, employeeNo);
        editCard(startTime, endTime, 1, name, card, deviceId, employeeNo);
        String strRequest = "/ISAPI/AccessControl/SetFaceParamCfg";
        String strConfigXML = "<SetFaceParamCfg version=\"2.0\" xmlns=\"http://www.isapi.org/ver20/XMLSchema\">\n" +
                "<cardNo>" + card + "</cardNo>\n" +
                "<cardReaderNo>1</cardReaderNo>\n" +
                "<facePicUrl>" + url + "</facePicUrl>\n" +
                "<faceID>1</faceID>\n" +
                "<faceDataType>1</faceDataType>\n" +
                "</SetFaceParamCfg>";
        return editFace(srcFile, url, card, strRequest, strConfigXML, "下发人脸", deviceId, 1, userType);
    }

    /**
     * 编辑卡号
     */
    private void editCard(String startTime, String endTime, int validTimeEnabled, String name, String card, String deviceId, String employeeNo) {
        HCEHomeCMS.NET_EHOME_XML_CFG struXMLCard = new HCEHomeCMS.NET_EHOME_XML_CFG();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringRequestCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringRequestCard.read();
        String strRequestCard = "SETDEVICECONFIG";
        stringRequestCard.byString = strRequestCard.getBytes();
        stringRequestCard.write();

        struXMLCard.pCmdBuf = stringRequestCard.getPointer();
        struXMLCard.dwCmdLen = stringRequestCard.byString.length;
        struXMLCard.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER struConfigXMLCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        struConfigXMLCard.read();
//        String password  = "123456";
//        if (!StringUtils.isEmpty(employeeNo))password="MTIzNDU2";
        String strConfigXMLCard = "<Params>\r\n" +
                "<ConfigCmd>SetCardCfg</ConfigCmd>\r\n" +
                "<ConfigParam1>" + card + "</ConfigParam1>\r\n" +
                "<ConfigParam2>1</ConfigParam2>\r\n" +
//                "<ConfigParam3>0</ConfigParam3>\r\n" +
//                "<ConfigParam4>0</ConfigParam4>\r\n" +
                "<ConfigXML>\r\n" +
                "<CardCfg>\r\n" +
                "<valid>1</valid>\r\n" +
                "<cardType>1</cardType>\r\n" +
                "<leaderCardEnabled>1</leaderCardEnabled>\r\n" +
                "<validTimeEnabled>" + validTimeEnabled + "</validTimeEnabled>\r\n" +
                "<ValidTime>\r\n" +
                "<startTime>" + startTime + "</startTime>\r\n" +
                "<endTime>" + endTime + "</endTime>\r\n" +
                "</ValidTime>\r\n" +
                "<password>MTIzNDU2</password>\r\n" +
                "<maxSwipeTime></maxSwipeTime>\r\n" +
                "<swipeTime></swipeTime>\r\n" +
                "<groupNo></groupNo>\r\n" +
                "<employeeNo>" + employeeNo + "</employeeNo>\r\n" +
                "<name>";
        String nameAfter = "</name>\r\n" +
                "<departmentNo></departmentNo>\r\n" +
                "<schedulePlanNo></schedulePlanNo>\r\n" +
                "<schedulePlanType></schedulePlanType>\r\n" +
                "</CardCfg>\r\n" +
                "</ConfigXML>\r\n" +
                "</Params>";
//        System.out.println("strConfigXMLCard:" + strConfigXMLCard + name + nameAfter);
        byte[] nameBeforBy = null;
        byte[] resultBy = null;
        try {
            nameBeforBy = strConfigXMLCard.getBytes("utf-8");
            byte[] nameBy = name.getBytes("utf-8");

            byte[] nameAfterBy = nameAfter.getBytes("utf-8");

            int xmlLength = nameBeforBy.length + nameBy.length + nameAfterBy.length;//字节总长度

            resultBy = new byte[xmlLength];

            System.arraycopy(nameBeforBy, 0, resultBy, 0, nameBeforBy.length);

            System.arraycopy(nameBy, 0, resultBy, nameBeforBy.length, nameBy.length);

            System.arraycopy(nameAfterBy, 0, resultBy, nameBeforBy.length + nameBy.length, nameAfterBy.length);
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }

        struConfigXMLCard.byString = resultBy;
        struConfigXMLCard.write();

        struXMLCard.pInBuf = struConfigXMLCard.getPointer();
        struXMLCard.dwInSize = struConfigXMLCard.byString.length;
        struXMLCard.dwRecvTimeOut = 5000;
        struXMLCard.dwSendTimeOut = 5000;
        struXMLCard.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringOutCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringOutCard.write();
        struXMLCard.pOutBuf = stringOutCard.getPointer();
        struXMLCard.dwOutSize = stringOutCard.size();
        struXMLCard.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringStatusCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringStatusCard.write();
        struXMLCard.pStatusBuf = stringStatusCard.getPointer();
        struXMLCard.dwStatusSize = stringStatusCard.size();
        struXMLCard.write();

        int i = struXMLCard.size();
        if (!hCEhomeCMS.NET_ECMS_XMLConfig(map.get(deviceId), struXMLCard, struXMLCard.size())) {
            int iErr = hCEhomeCMS.NET_ECMS_GetLastError();
            if (validTimeEnabled == 0) System.err.println("删除卡号失败，错误号：" + iErr + "card:" + card);
            else System.err.println("下发卡号失败，错误号：" + iErr + "card:" + card);
            if (iErr==10)map.remove(deviceId);
        } else {
            if (validTimeEnabled == 0) System.out.println("删除卡号成功");
            else System.out.println("下发卡号成功");
        }

    }

    /**
     * 设置卡权限周计划使能
     *
     * @param clint_id
     */
    public void SetCardWeekPlan(String clint_id, String strConfigXMLCard, String content) {
        HCEHomeCMS.NET_EHOME_XML_CFG struXMLCard = new HCEHomeCMS.NET_EHOME_XML_CFG();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringRequestCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringRequestCard.read();
        String strRequestCard = "SETDEVICECONFIG";
        stringRequestCard.byString = strRequestCard.getBytes();
        stringRequestCard.write();

        struXMLCard.pCmdBuf = stringRequestCard.getPointer();
        struXMLCard.dwCmdLen = stringRequestCard.byString.length;
        struXMLCard.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER struConfigXMLCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        struConfigXMLCard.read();
        struConfigXMLCard.byString = strConfigXMLCard.getBytes();
        struConfigXMLCard.write();

        struXMLCard.pInBuf = struConfigXMLCard.getPointer();
        struXMLCard.dwInSize = struConfigXMLCard.byString.length;
        struXMLCard.dwRecvTimeOut = 5000;
        struXMLCard.dwSendTimeOut = 5000;
        struXMLCard.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringOutCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringOutCard.write();
        struXMLCard.pOutBuf = stringOutCard.getPointer();
        struXMLCard.dwOutSize = stringOutCard.size();
        struXMLCard.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringStatusCard = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringStatusCard.write();
        struXMLCard.pStatusBuf = stringStatusCard.getPointer();
        struXMLCard.dwStatusSize = stringStatusCard.size();
        struXMLCard.write();

        int i = struXMLCard.size();
        if (!hCEhomeCMS.NET_ECMS_XMLConfig(map.get(clint_id), struXMLCard, struXMLCard.size())) {
            int iErr = hCEhomeCMS.NET_ECMS_GetLastError();
            System.err.println(content + "失败：" + iErr);
        } else {
            System.out.println(content + "成功");
        }
    }


    /**
     * 删除卡号
     *
     * @param deviceId
     * @param card
     */
    public boolean deleteCard(String deviceId, String card) {
        String strRequest = "/ISAPI/AccessControl/DelFaceParamCfg";
        String strConfigXML = "<DelFaceParamCfg>" +
                "<cardNo>" + card + "</cardNo><cardReaderNo>1</cardReaderNo>" +
                "<faceID>1</faceID></DelFaceParamCfg>";
        return editFace("", "", card, strRequest, strConfigXML, "删除人脸", deviceId, 2, "");
    }

    /**
     * 获取人脸是否存在
     *
     * @param deviceId
     * @param card
     * @return
     */
    public boolean getFace(String deviceId, String card) {
        String strRequest = "/ISAPI/AccessControl/GetFaceParamCfg";
        String strConfigXML = "<GetFaceParamCfgCond version=\"2.0\" xmlns=\"http://www.isapi.org/ver20/XMLSchema\">" +
                "<cardNo>" + card + "</cardNo><cardReaderNo>1</cardReaderNo>" +
                "<faceID>1</faceID></GetFaceParamCfgCond>";
        return editFace("", "", card, strRequest, strConfigXML, "获取人脸信息", deviceId, 3, "");
    }

    SendRecoderUtils sendRecoderUtils;

    private boolean editFace(String srcFile, String faceUrl, String card, String strRequest, String strConfigXML, String content, String deviceId, int type, String userType) {

//        deleteCard(deviceId, card);
//        lLoginID = map.get(deviceId);

        HCEHomeCMS.NET_EHOME_PTXML_PARAM struISAPXML = new HCEHomeCMS.NET_EHOME_PTXML_PARAM();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringRequest = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        stringRequest.read();
        stringRequest.byString = strRequest.getBytes();
        stringRequest.write();

        struISAPXML.pRequestUrl = stringRequest.getPointer();
        struISAPXML.dwRequestUrlLen = stringRequest.byString.length;
        struISAPXML.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER struConfigXML = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        struConfigXML.read();
        struConfigXML.byString = strConfigXML.getBytes();
        struConfigXML.write();

        struISAPXML.pInBuffer = struConfigXML.getPointer();
        struISAPXML.dwInSize = struConfigXML.byString.length;
        struISAPXML.write();

        HCEHomeCMS.NET_DVR_STRING_POINTER stringXMLOut = new HCEHomeCMS.NET_DVR_STRING_POINTER();
        struISAPXML.pOutBuffer = stringXMLOut.getPointer();
        struISAPXML.dwOutSize = stringXMLOut.size();

        if (type == 1) {//下发人脸
            if (!hCEhomeCMS.NET_ECMS_PostPTXMLConfig(map.get(deviceId), struISAPXML)) {
                int iErr = hCEhomeCMS.NET_ECMS_GetLastError();
                System.err.println(content + "失败，错误号：" + iErr+"---"+strConfigXML+"\n");
                sendRecoderUtils.sendFail(sendRecordDao, card, srcFile, deviceId, userDao, content + "失败，错误号：" + iErr, userType);
            } else {
                stringXMLOut.read();
                String strOutXML = new String(stringXMLOut.byString).trim();
                sendRecoderUtils.sendSuccess(sendRecordDao, card, faceUrl, deviceId, userDao, userType);
                System.out.println(content + "成功:"+card);
            }
        } else if (type == 2) {//删除人脸
            if (!hCEhomeCMS.NET_ECMS_PutPTXMLConfig(map.get(deviceId), struISAPXML)) {
                int iErr = hCEhomeCMS.NET_ECMS_GetLastError();
                System.err.println(content + "失败，错误号：" + iErr);
                return false;
            } else {
                stringXMLOut.read();
                String strOutXML = new String(stringXMLOut.byString).trim();
                System.out.println(content + "成功:"+card);
                return true;
            }
        } else if (type == 3) {//获取人脸信息
            if (!hCEhomeCMS.NET_ECMS_PostPTXMLConfig(map.get(deviceId), struISAPXML)) {
                int iErr = hCEhomeCMS.NET_ECMS_GetLastError();
                System.err.println(content + "失败，错误号：" + iErr);
            } else {
                stringXMLOut.read();
                String strOutXML = new String(stringXMLOut.byString).trim();
                System.out.println(content + "成功:" + strOutXML);
            }
        }
        return false;
    }

    @Value("${attendanceHost}")
    private String host;

   /* private boolean sendSMS(String cardNo, String deviceID, String time) {
        if (deviceID != null && !deviceID.isEmpty() && !StringUtils.isEmpty(cardNo)) {
            cardNo = sendRecoderUtils.getCard(splicingZero(Long.toHexString(Long.parseLong(cardNo)), 8).toUpperCase());

            System.out.println(String.format("设备号:%s 卡号:%s 时间:%s", deviceID, cardNo, time));
            PlaceAttendance placeAttendance = deviceDao.getPlaceAttendance(deviceID);
            AttendanceBean attendanceBean = deviceDao.selectDevice(deviceID);
            QianDaoManager qianDaoManager = deviceDao.getQianDaoMnager(attendanceBean.getSchool_id());
            if (null != qianDaoManager) {
                SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                String info = String.format("<AttendanceInfo submitTime=\"%s\"><Info device=\"%s\" card=\"%s\" operTime=\"%s\" direc=\"%s\"></Info></AttendanceInfo>",
                        simpleDateFormat.format(new Date()), deviceID, cardNo, time, "-1");

                AttendanceInfoBean attendanceInfoBean = new AttendanceInfoBean();
                attendanceInfoBean.setInfo(info);
                attendanceInfoBean.setIsControl(0);
                attendanceInfoBean.setPwd(qianDaoManager.getPwd());
                attendanceInfoBean.setUsername(qianDaoManager.getAccount());

                String jsonResult = JSON.toJSONString(attendanceInfoBean);
                System.out.println(jsonResult);

                if (placeAttendance == null) {//出入校
                    String urlXST = host + "api/XiaoAnCommon/SendXST";
                    String result1 = ApiHelper.doPost(urlXST, new HashMap<String, String>(), jsonResult);
                    JSONObject jsonObject = JSONObject.parseObject(result1);
                    System.out.println("urlXST:" + result1);//{"status":1,"message":null,"data":"0"}
                    if ((int) jsonObject.get("status") == 1) {
                        FileUtils.getInstance().writeLogs("出入校签到成功:" + deviceID + " 卡号:" + cardNo, FileUtils.qiandaoSuccess);
                        return true;
                    } else {
                        FileUtils.getInstance().writeLogs("出入校签到失败:" + deviceID + " 卡号:" + cardNo + " result1:" + result1, FileUtils.qiandaoErr);
                        return false;
                    }
                } else {//出入寝室
                    String urlHXY = host + "api/XiaoAnCommon/SendHXY";
                    String result2 = ApiHelper.doPost(urlHXY, new HashMap<String, String>(), jsonResult);
                    JSONObject jsonObject = JSONObject.parseObject(result2);
                    System.out.println("urlHXY:" + result2);
                    if ((int) jsonObject.get("status") == 1) {
                        FileUtils.getInstance().writeLogs("出入寝签到成功:" + deviceID + " 卡号:" + cardNo, FileUtils.qiandaoSuccess);
                        return true;
                    } else {
                        FileUtils.getInstance().writeLogs("出入寝签到失败:" + deviceID + " 卡号:" + cardNo + " result1:" + result2, FileUtils.qiandaoErr);
                        return false;
                    }
                }

            } else {
                FileUtils.getInstance().writeLogs("schoolId:" + attendanceBean.getSchool_id(), FileUtils.sms);
            }
        }
        return false;
    }*/

    /**
     * 字符串前面补零操作
     *
     * @param str         字符串本体
     * @param totalLenght 需要的字符串总长度
     * @return
     */
    public static String splicingZero(String str, int totalLenght) {
        int strLenght = str.length();
        String strReturn = str;
        for (int i = 0; i < totalLenght - strLenght; i++) {
            strReturn = "0" + strReturn;
        }
        return strReturn;
    }

}