package com.ruoyi;

import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.IdUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.station.domain.*;
import com.ruoyi.station.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.util.Date;
import java.util.List;

@RestController
@RequestMapping("iclock/")
public class AllController {

    @Autowired
    private IMjWorkUserService workUserService;
    @Autowired
    private IMjHeadsUsersService headsUsersService;
    @Autowired
    private IMjWorkOrderService workOrderService;
    @Autowired
    private IMjUserAxService userAxService;
    @Autowired
    private IMjFingerprintReadHeadService fingerprintReadHeadService;
    @Autowired
    private IMjDoorService doorService;
    @Autowired
    private IMjOpenHnweService openHnweService;
    @Autowired
    private IMjVisitLogService visitLogService;
    @Autowired
    private IMjStatisticService statisticService;

    //判断是否开这个门。
    //@RequestMapping(value = "/open")
    public int open(String userId,String ip){
        int openNum = 0;
//        MjVisitLog visitLog3 = new MjVisitLog();
//        visitLog3.setId(IdUtils.fastSimpleUUID());
//        visitLog3.setUserName(userId+" "+ip);
//        visitLog3.setDelFlag(1);
//        visitLogService.insertMjVisitLog(visitLog3);
//        MjWorkUser workUser = new MjWorkUser();
//        workUser.setUserId(userId);
        MjWorkUser mjWorkUsers = workUserService.selectMjWorkUserById(Long.valueOf(userId));

        MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
        fingerprintReadHead.setIpOrOther(ip);
        List<MjFingerprintReadHead> mjFingerprintReadHeads = fingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
        if(mjFingerprintReadHeads.size()==0){
            return -1;
        }
        String headId = mjFingerprintReadHeads.get(0).getId();
        if(StringUtils.isEmpty(headId)){
            //System.out.println("没找到读头");
            return -1;
        }

        if(mjWorkUsers!=null){
            MjHeadsUsers mjHeadsUsers = new MjHeadsUsers();
            mjHeadsUsers.setUserId(Long.valueOf(mjWorkUsers.getId()));
            mjHeadsUsers.setHeadId(headId);
            List<MjHeadsUsers> mjHeadsUsers1 = headsUsersService.selectMjHeadsUsersList(mjHeadsUsers);//找到读头用户表中的

            int flag1=0;
            int flag2=0;
            for(MjHeadsUsers user:mjHeadsUsers1){
                if(user.getAuthorizeType()==1){//如果是临时授权
                    flag1++;
                    if(user.getMainUser()==1){//如果是负责人
                        flag2++;
                    }
                }
            }
            if(flag2>0){//有A权限，则不考虑组授权
                int flag2Open = 0;
                for(MjHeadsUsers user:mjHeadsUsers1){
                    if(user.getAuthorizeType()==1){//如果是临时授权
                        if(user.getMainUser()==1){//如果是负责人
                            MjWorkOrder mjWorkOrder = workOrderService.selectMjWorkOrderById(user.getOrderId());
                            if(mjWorkOrder.getOpenMode()!=1){//如果是A模式
                                if(flag2Open==0){
                                    //System.out.println("临时授权A模式直接开门");
                                    flag2Open++;
                                    openDoor(user);
                                    openNum++;
                                    addStatis(2);
                                }
                            }else{
                                /*********如果是AX模式，且这个人是A，则把X的人员全部放到一个中间表，等待X人员按指纹********/
                                addUserAx(user,ip);
                            }
                        }else{
                            /*********是AX模式，且这个人是X，则在临时表找找是否有此人********/
                            //findUserAx(user,ip);

                            MjUserAx userAx = new MjUserAx();
                            userAx.setHeadIp(ip);
                            userAx.setXuserId(user.getUserId().toString());
                            List<MjUserAx> mjUserAxes = userAxService.selectMjUserAxList(userAx);
                            if(mjUserAxes.size()>0){
                                if(flag2Open==0) {
                                    //System.out.println("如果是X，在临时库里找到后开门");
                                    flag2Open++;
                                    openDoor(user);
                                    openNum++;
                                    addStatis(3);
                                }
                            }
                        }
                    }
                }
            }else{
                if(flag1>0){//只有X权限,也不考虑组授权
                    int flag2Open = 0;
                    for(MjHeadsUsers user:mjHeadsUsers1){
                        if(user.getAuthorizeType()==1){//如果是临时授权
                            /*********是AX模式，且这个人是X，则在临时表找找是否有此人********/
                            //findUserAx(user,ip);
                            if(user.getAuthorizeStatus()==0){
                                if(flag2Open==0){
                                    //System.out.println("临时授权A模式直接开门");
                                    flag2Open++;
                                    openDoor(user);
                                    openNum++;
                                    addStatis(2);
                                }
                            }else{
                                MjUserAx userAx = new MjUserAx();
                                userAx.setHeadIp(ip);
                                userAx.setXuserId(user.getUserId().toString());
                                List<MjUserAx> mjUserAxes = userAxService.selectMjUserAxList(userAx);
                                if(mjUserAxes.size()>0){
                                    if(flag2Open>0) {
                                        break;
                                    }else{
                                        //System.out.println("如果是X，在临时库里找到后开门");
                                        flag2Open++;
                                        openDoor(user);
                                        openNum++;
                                        addStatis(3);
                                    }
                                }
                            }
                        }
                    }
                }else{
                    MjHeadsUsers mjHeadsUsers5 = new MjHeadsUsers();
                    mjHeadsUsers5.setUserId(Long.valueOf(mjWorkUsers.getId()));
                    mjHeadsUsers5.setAuthorizeType(1);
                    List<MjHeadsUsers> zu = headsUsersService.selectMjHeadsUsersList(mjHeadsUsers5);//找到读头用户表中的
                    if(zu.size()==0){
                        for(MjHeadsUsers user:mjHeadsUsers1){
                            if(user.getAuthorizeType()==0){//是组授权
                                //System.out.println("组授权开门");
                                openDoor(user);
                                openNum++;
                                addStatis(1);
                                break;
                            }
                        }
                    }
                }
            }
            //}
        }
        return openNum;
    }

    private void addVistisLog(MjWorkUser mjWorkUsers, MjFingerprintReadHead mjFingerprintReadHead,MjHeadsUsers headsUsers) {
        MjVisitLog visitLog = new MjVisitLog();
        visitLog.setId(IdUtils.fastSimpleUUID());
        visitLog.setUserName(mjWorkUsers.getUserName());
        visitLog.setDeptId(mjWorkUsers.getDeptId());
        visitLog.setDeptName(mjWorkUsers.getDeptName());
        visitLog.setDoorId(mjFingerprintReadHead.getDoorId());
        visitLog.setDoorName(mjFingerprintReadHead.getDoorName());
        visitLog.setDirection(mjFingerprintReadHead.getDirection());
        visitLog.setAreaName(mjFingerprintReadHead.getAreaName());
        visitLog.setOrganizationId(mjWorkUsers.getOrganizationId());
        visitLog.setOrganizationName(mjWorkUsers.getOrganizationName());
        visitLog.setWorkOrderId(headsUsers.getOrderId());
        if(headsUsers.getAuthorizeType()==1){
            MjWorkOrder mjWorkOrder = workOrderService.selectMjWorkOrderById(headsUsers.getOrderId());
            visitLog.setWorkOrderName(mjWorkOrder.getTaskName());
        }
        visitLogService.insertMjVisitLog(visitLog);
    }

    //把X人员加入临时表
    public void addUserAx(MjHeadsUsers headsUsers,String ip){
        MjHeadsUsers shu = new MjHeadsUsers();
        shu.setOrderId(headsUsers.getOrderId());
        shu.setMainUser(0);
        List<MjHeadsUsers> headUserList = headsUsersService.selectMjHeadsUsersList(shu);//找到读头用户表中的
        for(MjHeadsUsers hu:headUserList){
            MjUserAx userAx = new MjUserAx();
            userAx.setId(IdUtils.fastSimpleUUID());
            userAx.setXuserId(hu.getUserId().toString());
            userAx.setHeadIp(ip);
            userAxService.insertMjUserAx(userAx);
        }
    }

    //在临时表找找有没有X这个人
    public void findUserAx(MjHeadsUsers headsUsers,String ip){
        MjUserAx userAx = new MjUserAx();
        userAx.setHeadIp(ip);
        userAx.setXuserId(headsUsers.getUserId().toString());
        List<MjUserAx> mjUserAxes = userAxService.selectMjUserAxList(userAx);
        if(mjUserAxes.size()>0){
            //System.out.println("如果是X，在临时库里找到后开门");
            openDoor(headsUsers);
            addStatis(3);
        }
    }

    //开门
    public void openDoor(MjHeadsUsers headsUsers){
        String headId = headsUsers.getHeadId();
        MjFingerprintReadHead mjFingerprintReadHead = fingerprintReadHeadService.selectMjFingerprintReadHeadById(headId);
        MjDoor mjDoor = doorService.selectMjDoorById(mjFingerprintReadHead.getDoorId());
        MjOpenHnwe openHnwe = new MjOpenHnwe();
        openHnwe.setId(IdUtils.fastSimpleUUID());
        openHnwe.setHnweId(mjDoor.getHnweId());
        openHnwe.setHnweIp(mjDoor.getHnweIp());
        openHnweService.insertMjOpenHnwe(openHnwe);

        MjWorkUser workUser = workUserService.selectMjWorkUserById(headsUsers.getUserId());
        addVistisLog(workUser,mjFingerprintReadHead,headsUsers);
    }

    public void addStatis(int type){
        //List<MjStatistic> mjStatistics = statisticService.selectMjStatisticList(null);
        MjStatistic mjStatistic = statisticService.selectMjStatisticById("1");
        if(mjStatistic!=null){
            //MjStatistic mjStatistic = mjStatistics.get(0);
            if(type==1){//组
                mjStatistic.setTeamopen(mjStatistic.getTeamopen()+1);
            }
            if(type==2){//临
                mjStatistic.setOrderopen1(mjStatistic.getOrderopen1()+1);
            }
            if(type==3){//Ax
                mjStatistic.setOrderopen2(mjStatistic.getOrderopen2()+1);
            }
            statisticService.updateMjStatistic(mjStatistic);
        }
    }

    @GetMapping("cdata")
    public void findByType(String SN, String options, String pushver, String language, String pushcommkey, HttpServletResponse response, String PushOptionsFlag) throws IOException {
        //System.out.println("信息交互");
        String s = initOptions(SN,null);
        response.getWriter().write(s);
    }

    @RequestMapping(value = "/cdata")
    public void handleRtData(HttpServletRequest request, HttpServletResponse response, String SN, String table) throws UnsupportedEncodingException {
        //System.out.println("设备上传上来的数据...."+data+"....table..."+table);
        request.setCharacterEncoding("gbk");
        String data = "";
        //System.out.println("设备的实时记录是......."+data+"....table名字为:"+table);

        ByteArrayOutputStream bos = null;
        byte[] b= new byte[1024];
        try {
            InputStream is = request.getInputStream();
            bos = new ByteArrayOutputStream();
            int len = 0;
            while((len=is.read(b))!=-1){
                bos.write(b,0,len);
            }

            data = new String(bos.toByteArray(),"gbk");
        } catch (IOException e) {
            e.printStackTrace();
        }
        if(data.indexOf("xFace600")!=-1){
            return;
        }
        MjVisitLog visitLog3 = new MjVisitLog();
        visitLog3.setId(IdUtils.fastSimpleUUID());
        visitLog3.setUserName(request.getRemoteHost()+"==="+data+" table="+table);
        visitLog3.setDelFlag(1);
        visitLogService.insertMjVisitLog(visitLog3);
        //System.out.println("设备的实时记录是......."+data);
        String[] dataArray = data.split("\n");
//        int num = dataArray.length;
//
//        System.out.println("获取到的考勤记录数量为.,.............."+num);
        //System.out.println("读头ip："+request.getRemoteHost());
        for(String datas:dataArray){
            String[] s = datas.split("\t");
//            //System.out.println("用户id："+s[0]);
//            String logTime = s[1];
//            Date date = DateUtils.dateTime("yyyy-MM-dd HH:mm:ss",logTime);
//            Date date2 = new Date();
//            long l = date2.getTime() - date.getTime();
            //if(l<1000*60){
            int open = 0;
            try {
                open = open(s[0], request.getRemoteHost());//判断是否开门

            } catch (Exception e) {

            }finally {
                //visitLog3.setDoorId(open+"次"+Long.valueOf(l).toString());
                visitLog3.setDoorId(open+"次");
                visitLogService.updateMjVisitLog(visitLog3);
            }
            //}
        }
        try {
            response.getWriter().write("OK");
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    public static byte[] getRequestPostBytes(HttpServletRequest request)
            throws IOException {
        int contentLength = request.getContentLength();
        if(contentLength<0){
            return null;
        }
        byte buffer[] = new byte[contentLength];
        for (int i = 0; i < contentLength;) {

            int readlen = request.getInputStream().read(buffer, i,
                    contentLength - i);
            if (readlen == -1) {
                break;
            }
            i += readlen;
        }
        return buffer;
    }
    /***
     * Get request query string, form method : post
     *
     * @param request
     * @return
     * @throws IOException
     */
    public static String getRequestPostStr(HttpServletRequest request)
            throws IOException {
        byte buffer[] = getRequestPostBytes(request);
        String charEncoding = request.getCharacterEncoding();
        if (charEncoding == null) {
            charEncoding = "UTF-8";
        }
        String s = new String(buffer, charEncoding);
        return s;
    }

    private String initOptions(String sn,String PushOptionsFlag) {
        StringBuffer devOptions = new StringBuffer();
        devOptions.append("GET OPTION FROM: "+sn);
        // + "\nStamp=" + devInfo.devInfoJson.getString("Stamp")
        devOptions.append("\nATTLOGStamp=0");
        devOptions.append("\nOPERLOGStamp=0");
        devOptions.append("\nBIODATAStamp=0");
        devOptions.append("\nATTPHOTOStamp=0");
        devOptions.append("\nErrorDelay=10");//断网重连
        devOptions.append("\nDelay=30");//心跳间隔
        devOptions.append("\nTimeZone=8");//时区
        devOptions.append("\nRealtime=1");//实时上传
        devOptions.append("\nServerVer=3.0.1");//这个必须填写
        devOptions.append("\nPushProtVer=2.4.1");
        devOptions.append("\nTransFlag=100000000000");//  1-12二进制位 分别代表以上含义
        //System.out.println("PushOptionsFlag============="+PushOptionsFlag);
        if (PushOptionsFlag!=null&&PushOptionsFlag.equals("1"))
        {
            // 支持参数单独获取的才要把需要获取的参数回传给设备 modifeid by max 20170926
            devOptions.append("\nPushOptions=RegDeviceType,FingerFunOn,FaceFunOn,FPVersion,FaceVersion,NetworkType,HardwareId3,HardwareId5,HardwareId56,LicenseStatus3,LicenseStatus5,LicenseStatus56");
        }
        devOptions.append("\n");
        return devOptions.toString();
    }

/*********只有一个人的情况下********/
//            if(mjHeadsUsers1.size()==1){
//                    MjHeadsUsers mjHeadsUsers2 = mjHeadsUsers1.get(0);
//
//                    if(mjHeadsUsers2.getAuthorizeType()==0){
//                    System.out.println("组授权开门");
//                    }else{
//                    MjWorkOrder mjWorkOrder = workOrderService.selectMjWorkOrderById(mjHeadsUsers2.getOrderId());
//                    if(mjWorkOrder.getOpenMode()==0){
//                    System.out.println("临时授权A模式直接开门");
//                    }else{
//                    if(mjHeadsUsers2.getMainUser()==1){
//                    /*********如果是AX模式，且这个人是A，则把X的人员全部放到一个中间表，等待X人员按指纹********/
//                    addUserAx(mjHeadsUsers2,ip);
//                    }else{
//                    /*********如果是AX模式，且这个人是X，则在临时表找找是否有此人********/
//                    findUserAx(mjHeadsUsers2,ip);
//                    }
//                    }
//                    }
//                    }else{
//                    /*********多个人的情况下********/
}