package com.sincere.weigeng.utils;


import com.sincere.common.dto.smartCampus.UserDto;
import com.sincere.common.dto.xiaoan.CheckInDto;
import com.sincere.common.dto.xiaoan.CheckOutDto;
import com.sincere.common.dto.xiaoan.PassFailDto;
import com.sincere.common.dto.xiaoan.SendMessageDto;
import com.sincere.common.util.DateUtils;
import com.sincere.weigeng.feign.SmFeign;
import com.sincere.weigeng.feign.XaFeign;
import com.sincere.weigeng.logs.LogName;
import com.sincere.weigeng.logs.LoggerUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.transport.socket.DatagramSessionConfig;
import org.apache.mina.transport.socket.nio.NioDatagramAcceptor;
import org.slf4j.Logger;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @author chen
 * @version 1.0
 * @date 2019/10/12 0012 16:57
 */
public class WatchServer {

    private static final Logger Log_orderSuccess = LoggerUtils.Logger(LogName.orderSuccess);
    private static final Logger Log_orderFail = LoggerUtils.Logger(LogName.orderFail);
    private static final Logger Log_kaoInfo = LoggerUtils.Logger(LogName.kaoInfo);
    private static final Logger Log_heartBeat = LoggerUtils.Logger(LogName.heartBeat);
    private static final Logger Log_error = LoggerUtils.Logger(LogName.error);

    private static List<Long> snoList = new ArrayList<>();
    private static List<Long> indexList = new ArrayList<>();
    private static WatchingShortHandler watchingShortHandler ;
    private static Queue<byte[]> queue = new LinkedList<>();
    private static Map<Long , IoSession> sessionMap = new ConcurrentHashMap<>();

    // 进入服务器监控状态
    public static int WatchingServerRunning(String watchServerIP,int watchServerPort,
        SmFeign smFeign ,XaFeign xaFeign) {
        watchingShortHandler = new WatchingShortHandler(queue,sessionMap);
        // 创建UDP数据包NIO
        NioDatagramAcceptor acceptor = new NioDatagramAcceptor();
        // NIO设置底层IOHandler
        acceptor.setHandler(watchingShortHandler);

        // 设置是否重用地址？ 也就是每个发过来的udp信息都是一个地址？
        DatagramSessionConfig dcfg = acceptor.getSessionConfig();
        dcfg.setReuseAddress(false);
        // 绑定端口地址
        try {
            acceptor.bind(new InetSocketAddress(watchServerIP, watchServerPort));
        } catch (IOException e) {
            Log_orderSuccess.info("绑定接收服务器失败....");
            e.printStackTrace();
            return 0;
        }
        Log_orderSuccess.info("绑定接收服务器成功....");
        long recordIndex = 0;
        while(true) {
            if (!queue.isEmpty()) {
                byte[] recvBuff;
                synchronized (queue) {
                    recvBuff= queue.poll();
                }
                if (recvBuff[1]== 0x20) {
                    long sn = WgUdpCommShort.getLongByByte(recvBuff, 4, 4);
                    smFeign.updateLinkTime(sn+"");
                    Log_heartBeat.info("设备"+sn);
                    boolean isExist = true ;
                    long recordIndexGet = WgUdpCommShort.getLongByByte(recvBuff, 8, 4);
                    if(snoList.indexOf(sn) >= 0){
                        int number = snoList.indexOf(sn);
                        recordIndex = indexList.get(number);
                        indexList.set(number,recordIndexGet);
                    }else {
                        snoList.add(sn);
                        recordIndex = 0 ;
                        indexList.add(recordIndexGet);
                        System.out.println("设备"+sn+"上线");
                        isExist = false ;
                    }
                    if(isExist){
                        if (recordIndex < recordIndexGet || (recordIndexGet - recordIndex) < -5) {
                            watching(recvBuff,smFeign,xaFeign);
                        }
                    }
                }else {
                    push(recvBuff,xaFeign);
                }
            } else {
                long times = 100;
                try {
                    Thread.sleep(times);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    private static void watching(byte[] recv,SmFeign smFeign ,XaFeign xaFeign){
        long res = 0;
        //8-11	记录的索引号
        //(=0表示没有记录)	4	0x00000000
        int recordIndex = 0;
        recordIndex = WGUtils.byteToInt(recv, 8, 4);
        //12	记录类型**********************************************
        //0=无记录
        //1=刷卡记录
        //2=门磁,按钮, 设备启动, 远程开门记录
        //3=报警记录	1
        //0xFF=表示指定索引位的记录已被覆盖掉了.  请使用索引0, 取回最早一条记录的索引值
        int recordType = recv[12];

        //13	有效性(0 表示不通过, 1表示通过)	1
        int recordValid = recv[13];

        //14	门号(1,2,3,4)	1	  业务需要-->1出2进
        int recordDoorNO = recv[14];

        //15	进门/出门(1表示进门, 2表示出门)	1	0x01
        //int recordInOrOut = recv[15];

        //16-19	卡号(类型是刷卡记录时)
        //或编号(其他类型记录)	4
        String cardNo = WGUtils.getCardNo(recv, 16, 4);

        //20-26	刷卡时间:
        //年月日时分秒 (采用BCD码)见设置时间部分的说明
        String recordTime = "2000-01-01 00:00:00";
        recordTime = String.format("%02X%02X-%02X-%02X %02X:%02X:%02X",
                recv[20], recv[21], recv[22], recv[23], recv[24], recv[25], recv[26]);
        //2012.12.11 10:49:59	7
        //27	记录原因代码(可以查 “刷卡记录说明.xls”文件的ReasonNO)
        //处理复杂信息才用	1
        int reason = recv[27];
        if (recordType == 0) {
            Log_orderSuccess.info(String.format("索引位={0}  无记录", recordIndex));
        }else if (recordType == 0xff) {
            Log_orderSuccess.info("指定索引位的记录已被覆盖掉了,请使用索引0, 取回最早一条记录的索引值");
        } else if (recordType == 1) {
            long sno = 0;
            sno = WgUdpCommShort.getLongByByte(recv, 4, 4);//解析设备号
            String msg = "索引位=" + recordIndex
                    + ",卡号=" + cardNo
                    +"进出=" + (recordDoorNO == 1 ? "出门" : "进门")
                    + ",有效=" + (recordValid == 1 ? "通过" : "禁止")
                    + ",时间=" + recordTime
                    + ",描述=" + WGUtils.getReasonDetailChinese(reason) + "";
            Log_orderSuccess.info("控制器：" + sno + msg);
            if(recordValid == 1) {
                //有效刷卡调考勤存储过程
                CheckInDto checkIn = new CheckInDto();
                checkIn.setDeviceId(sno+"");
                checkIn.setCardNo(cardNo);
                checkIn.setFunNo(8);
                checkIn.setFlag(recordDoorNO == 1 ? 1 : 0);
                checkIn.setCheckTime(recordTime);
                CheckOutDto checkOutDto = xaFeign.checkIn(checkIn);
                if(checkOutDto.getIsSuccess() == 1){
                    //考勤成功
                    Log_kaoInfo.info("考勤成功！，设备："+sno+"卡号："+cardNo+"方向："+(recordDoorNO == 1 ? "出门" : "进门")+"______"+ recordTime);
                }else {
                    //考勤失败
                    Log_orderFail.error("考勤失败！，设备："+sno+"卡号："+cardNo + "---"+ checkOutDto.getOut());
                }
            }else {
                //判断是否请假
                String studentNum = smFeign.checkLeave(cardNo);
                if (StringUtils.isNotBlank(studentNum)) {
                    int outOf = recordDoorNO == 1 ? 1 : 0;
                    //远程开门
                    openDoor(xaFeign,sno,"64",recordDoorNO,cardNo);
                    Log_orderSuccess.info("请假开门成功"+cardNo);
                } else {
                    //没有请假不做任何处理,则是刷卡异常，入库
                    UserDto user = smFeign.selectUserByCardNum(cardNo);
                    PassFailDto passFail = new PassFailDto();
                    passFail.setCardNum(cardNo);
                    passFail.setDeviceId(sno+"");
                    passFail.setDirection((recordDoorNO == 1 ? "出门" : "进门"));
                    passFail.setResultIntro(WGUtils.getReasonDetailChinese(reason));
                    passFail.setInTime(DateUtils.string2Date(recordTime, DateUtils.format2));
                    passFail.setCreateTime(new Date());
                    passFail.setSchoolId(user.getSchoolId());
                    xaFeign.insertPassFail(passFail);
                }
            }
        }
    }

    private static void push(byte[] recv,XaFeign xaFeign){
        long index = WgUdpCommShort.getXidOfCommand(recv);
        long sno = WgUdpCommShort.getLongByByte(recv, 4, 4);
        String functionId = WGUtils.byte2Hex(recv[1]);
        SendMessageDto sendMessage = xaFeign.selectMessage(sno+"",index,functionId);
        if(sendMessage != null){
            if(recv[8] == 1){
                sendMessage.setCorrect(1);
            }else {
                sendMessage.setCorrect(0);
            }
            StringBuffer result = new StringBuffer();
            for(byte b : recv){
                result.append(WGUtils.byte2Hex(b)).append("-");
            }
            sendMessage.setResult(result.toString().substring(0,result.toString().length()-1));
            xaFeign.updateMessage(sendMessage.getId(),sendMessage.getResult(),sendMessage.getCorrect());
        }
    }

    //远程开门
    public static long openDoor(XaFeign xaFeign,long sno , String outsideOrderId,int doorNo , String cardNo){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            int doorNO =doorNo;
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            pkt.data[0] =(byte) (doorNO & 0xff);
            if(StringUtils.isNotBlank(cardNo)){
                pkt.data[20] = WGUtils.toHex(cardNo.substring(0,2));
                pkt.data[21] = WGUtils.toHex(cardNo.substring(2,4));
                pkt.data[22] = WGUtils.toHex(cardNo.substring(4,6));
                pkt.data[23] = WGUtils.toHex(cardNo.substring(6,8));
            }
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,cardNo,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0L;
    }

    //重置控制板时间
    public static long setTime(XaFeign xaFeign,long sno , String outsideOrderId){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            Calendar cal = (Calendar.getInstance());
            pkt.data[0] = WGUtils.toHex(String.valueOf(cal.get(Calendar.YEAR)).substring(0,2));
            pkt.data[1] = WGUtils.toHex(String.valueOf(cal.get(Calendar.YEAR)).substring(2,4));
            pkt.data[2] = WGUtils.toHex(String.valueOf(cal.get(Calendar.MONTH)+1));
            pkt.data[3] = WGUtils.toHex(String.valueOf(cal.get(Calendar.DATE)));
            pkt.data[4] =WGUtils.toHex(String.valueOf(cal.get(Calendar.HOUR_OF_DAY)));
            pkt.data[5] =WGUtils.toHex(String.valueOf(cal.get(Calendar.MINUTE)));
            pkt.data[6] = WGUtils.toHex(String.valueOf(cal.get(Calendar.SECOND)));
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,null,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0L;
    }



    //设置考勤时段
    public static List<Long> SetAttendanceTime(XaFeign xaFeign,long sno ,String outsideOrderId, int shiduan , Date begin ,Date end ,
                                            int isMonDay ,int isTuesDay , int isWednesDay ,int isThursDay , int isFriday ,
                                            int isSaturDay , int isWeekend , String shiqu){
        List<Long> resultList = new ArrayList<>();
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            String[] shiQuArray = shiqu.split(",");
            int shiDuanCount = shiQuArray.length / 6 ;
            for (int i = 0; i < shiDuanCount; i++){
                if (i == 0) {
                    pkt.data[0] = WGUtils.toHex(shiduan+"");
                } else {
                    pkt.data[0] = WGUtils.toHex((shiduan+20*i)+"");
                }
                Calendar c = Calendar.getInstance();
                c.setTime(begin);
                //开始时间 20 19 01 01
                pkt.data[1] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(0,2));
                pkt.data[2] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(2,4));
                pkt.data[3] = WGUtils.toHex(String.valueOf(c.get(Calendar.MONTH)+1));
                pkt.data[4] = WGUtils.toHex(String.valueOf(c.get(Calendar.DATE)));
                //结束时间
                c.setTime(end);
                pkt.data[5] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(0,2));
                pkt.data[6] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(2,4));
                pkt.data[7] = WGUtils.toHex(String.valueOf(c.get(Calendar.MONTH)+1));
                pkt.data[8] = WGUtils.toHex(String.valueOf(c.get(Calendar.DATE)));
                //星期几 有效
                pkt.data[9] = WGUtils.toHex(String.valueOf(isMonDay));
                pkt.data[10] = WGUtils.toHex(String.valueOf(isTuesDay));
                pkt.data[11] = WGUtils.toHex(String.valueOf(isWednesDay));
                pkt.data[12] = WGUtils.toHex(String.valueOf(isThursDay));
                pkt.data[13] = WGUtils.toHex(String.valueOf(isFriday));
                pkt.data[14] = WGUtils.toHex(String.valueOf(isSaturDay));
                pkt.data[15] = WGUtils.toHex(String.valueOf(isWeekend));
                //有效时区
                pkt.data[16] = WGUtils.toHex(shiQuArray[i * 6 + 0].substring(0, 2));
                pkt.data[17] = WGUtils.toHex(shiQuArray[i * 6 + 0].substring(3, 5));

                pkt.data[18] = WGUtils.toHex(shiQuArray[i * 6 + 1].substring(0, 2));
                pkt.data[19] = WGUtils.toHex(shiQuArray[i * 6 + 1].substring(3, 5));

                pkt.data[20] = WGUtils.toHex(shiQuArray[i * 6 + 2].substring(0, 2));
                pkt.data[21] = WGUtils.toHex(shiQuArray[i * 6 + 2].substring(3, 5));

                pkt.data[22] = WGUtils.toHex(shiQuArray[i * 6 + 3].substring(0, 2));
                pkt.data[23] = WGUtils.toHex(shiQuArray[i * 6 + 3].substring(3, 5));

                pkt.data[24] = WGUtils.toHex(shiQuArray[i * 6 + 4].substring(0, 2));
                pkt.data[25] = WGUtils.toHex(shiQuArray[i * 6 + 4].substring(3, 5));

                pkt.data[26] = WGUtils.toHex(shiQuArray[i * 6 + 5].substring(0, 2));
                pkt.data[27] = WGUtils.toHex(shiQuArray[i * 6 + 5].substring(3, 5));
                if (shiDuanCount != 1) {
                    //需要链接时段
                    if (i != shiDuanCount - 1) {
                        //只要不是最后一个时段
                        pkt.data[28] = WGUtils.toHex((shiduan+20*(i+1)+""));
                    } else {
                        pkt.data[28] = 0;
                    }
                } else {
                    pkt.data[28] = 0;
                }
                byte[] bytes = pkt.toByte();
                long index = WgUdpCommShort.getXidOfCommand(bytes);
                long result = insert(xaFeign,sno+"",outsideOrderId,null,index,bytes);
                pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
                resultList.add(result);
            }
            return resultList ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return resultList;
    }


    //设置权限
    public static long SetSignalCardInfo(XaFeign xaFeign,long sno , String outsideOrderId, String cardNo , int shiduan , Date begin , Date end){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            pkt.iDevSn = sno;
            //0D D7 37 00
            pkt.data[0] = WGUtils.toHex(cardNo.substring(0,2));
            pkt.data[1] = WGUtils.toHex(cardNo.substring(2,4));
            pkt.data[2] = WGUtils.toHex(cardNo.substring(4,6));
            pkt.data[3] = WGUtils.toHex(cardNo.substring(6,8));

            //20 10 01 01 起始日期:  2010年01月01日   (必须大于2001年)
            Calendar c = Calendar.getInstance();
            c.setTime(begin);
            pkt.data[4] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(0,2));
            pkt.data[5] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(2,4));
            pkt.data[6] = WGUtils.toHex(String.valueOf(c.get(Calendar.MONTH)+1));
            pkt.data[7] = WGUtils.toHex(String.valueOf(c.get(Calendar.DATE)));
            //20 29 12 31 截止日期:  2029年12月31日
            c.setTime(end);
            pkt.data[8] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(0,2));
            pkt.data[9] = WGUtils.toHex(String.valueOf(c.get(Calendar.YEAR)).substring(2,4));
            pkt.data[10] = WGUtils.toHex(String.valueOf(c.get(Calendar.MONTH)+1));
            pkt.data[11] = WGUtils.toHex(String.valueOf(c.get(Calendar.DATE)));
            //01 允许通过 一号门 [对单门, 双门, 四门控制器有效]
            pkt.data[12] = WGUtils.toHex(shiduan+"");
            //01 允许通过 二号门 [对双门, 四门控制器有效]
            pkt.data[13] = WGUtils.toHex(shiduan+"");
            //01 允许通过 三号门 [对四门控制器有效]
            pkt.data[14] = WGUtils.toHex(shiduan+"");
            //01 允许通过 四号门 [对四门控制器有效]
            pkt.data[15] = WGUtils.toHex(shiduan+"");
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,cardNo,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0l;
    }

    //删除单张卡权限
    public static long clearSinglePower(XaFeign xaFeign,long sno ,String outsideOrderId, String cardNo){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            pkt.iDevSn = sno;
            pkt.data[0] = WGUtils.toHex(cardNo.substring(0,2));
            pkt.data[1] = WGUtils.toHex(cardNo.substring(2,4));
            pkt.data[2] = WGUtils.toHex(cardNo.substring(4,6));
            pkt.data[3] = WGUtils.toHex(cardNo.substring(6,8));
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,cardNo,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0l;
    }

    //删除全部权限
    public static long clearAllPower(XaFeign xaFeign,long sno ,String outsideOrderId){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            pkt.iDevSn = sno;
            pkt.data[0] = (byte) 0x55 ;
            pkt.data[1] = (byte) 0xAA ;
            pkt.data[2] = (byte) 0xAA ;
            pkt.data[3] = (byte) 0x55 ;
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,null,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0l;
    }

    //查询卡权限
    public static long searchPower(XaFeign xaFeign,long sno ,String outsideOrderId, String cardNo){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            pkt.iDevSn = sno;
            pkt.data[0] = WGUtils.toHex(cardNo.substring(0,2));
            pkt.data[1] = WGUtils.toHex(cardNo.substring(2,4));
            pkt.data[2] = WGUtils.toHex(cardNo.substring(4,6));
            pkt.data[3] = WGUtils.toHex(cardNo.substring(6,8));
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,cardNo,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0l;
    }

    //删除时段
    public static long clearShiDuan(XaFeign xaFeign,long sno , String outsideOrderId){
        WgUdpCommShort pkt = new WgUdpCommShort();
        pkt.iDevSn = sno;
        try{
            pkt.Reset();
            pkt.functionID = WGUtils.toFunctionHex(outsideOrderId);
            pkt.iDevSn = sno;
            pkt.data[0] = (byte) 0x55 ;
            pkt.data[1] = (byte) 0xAA ;
            pkt.data[2] = (byte) 0xAA ;
            pkt.data[3] = (byte) 0x55 ;
            byte[] bytes = pkt.toByte();
            long index = WgUdpCommShort.getXidOfCommand(bytes);
            long result = insert(xaFeign,sno+"",outsideOrderId,null,index,bytes);
            pkt.run(watchingShortHandler.getSessionMap().get(sno),bytes);
            return result ;
        }catch (Exception e){
            Log_error.error(e.toString());
        }
        return 0l;
    }

    private static long insert(XaFeign xaFeign ,String sn ,String functionId , String cardNo , long index , byte[] recv){

        StringBuffer send = new StringBuffer();
        for(byte b : recv){
            send.append(WGUtils.byte2Hex(b)).append("-");
        }
        SendMessageDto sendMessage = new SendMessageDto();
        sendMessage.setDeviceId(sn);
        sendMessage.setFunctionId(Integer.toHexString(Integer.valueOf(functionId)));
        sendMessage.setIndex(index);
        sendMessage.setCardNo(cardNo);
        sendMessage.setCreateTime(new Date());
        sendMessage.setSend(send.toString().substring(0,send.toString().length()-1));
        xaFeign.insertMessage(sendMessage);
        return sendMessage.getId();
    }
}