package com.ruoyi.quartz.task;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.common.constant.UrlConstant;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.IdUtils;
import com.ruoyi.station.domain.*;
import com.ruoyi.station.model.TmpDataModel;
import com.ruoyi.station.model.WorkUserModel;
import com.ruoyi.station.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.List;

/**
 * 定时扫描读头，判断是否在线
 */
@Component("readHeadStatusTask")
public class ReadHeadStatusTask {

    private static String ipAndPort = "http://192.168.136.20:8099";

    @Autowired
    private IMjFingerprintReadHeadService iMjFingerprintReadHeadService;
    @Autowired
    private IMjEquipmentService iMjEquipmentService;

    @Autowired
    private IMjVisitLogService visitLogService;
    @Autowired
    private IMjHnweEventService hnweEventService;

    public void pushUser() {
        visitLogService.delete7days();
        hnweEventService.delete7days();
//        MjEquipment eq = new MjEquipment();
//        eq.setEquipmentType(0);
//        List<MjEquipment> mjEquipments = iMjEquipmentService.selectMjEquipmentList(eq);
//        for(MjEquipment e : mjEquipments){
//            //iMjEquipmentService.deleteMjEquipmentById(e.getId());
//        }

        List<MjFingerprintReadHead> list = iMjFingerprintReadHeadService.selectMjFingerprintReadHeadList(null);
        for(MjFingerprintReadHead head:list){
//            Thread t = new Thread(new Runnable(){
//                public void run(){
                    boolean b = connectionStatus(head.getIpOrOther(), head.getPort());
                    if(b){
                        head.setShowStatus(1);
                        MjEquipment eq = new MjEquipment();
                        eq.setEquipmentType(0);
                        eq.setUpdateBy(head.getId());
                        List<MjEquipment> mjEquipments = iMjEquipmentService.selectMjEquipmentList(eq);
                        for(MjEquipment e:mjEquipments){
                            if(e.getStatus()==0){
                                MjEquipment equipment =  new MjEquipment();
                                equipment.setCreateTime(DateUtils.getNowDate());
                                equipment.setId(IdUtils.fastSimpleUUID());
                                equipment.setEquipmentType(0);
                                String faxiang = "";
                                if(head.getDirection()!=null){
                                    if(head.getDirection()==0){
                                        faxiang = "进门";
                                    }
                                    if(head.getDirection()==1){
                                        faxiang = "出门";
                                    }
                                }
                                equipment.setStatus(1);
                                equipment.setUpdateBy(head.getId());
                                equipment.setContent(DateUtils.parseDateToStr("MM-dd HH:mm",equipment.getCreateTime())+" "+head.getDoorName()+" "+faxiang);
                                iMjEquipmentService.insertMjEquipment(equipment);
                            }
                            break;
                        }
                    }else{
                        head.setShowStatus(0);
                        MjEquipment eq = new MjEquipment();
                        eq.setEquipmentType(0);
                        eq.setUpdateBy(head.getId());
                        List<MjEquipment> mjEquipments = iMjEquipmentService.selectMjEquipmentList(eq);
                        if(mjEquipments.size()==0){
                            MjEquipment equipment =  new MjEquipment();
                            equipment.setCreateTime(DateUtils.getNowDate());
                            equipment.setId(IdUtils.fastSimpleUUID());
                            equipment.setEquipmentType(0);
                            String faxiang = "";
                            if(head.getDirection()!=null){
                                if(head.getDirection()==0){
                                    faxiang = "进门";
                                }
                                if(head.getDirection()==1){
                                    faxiang = "出门";
                                }
                            }
                            equipment.setStatus(0);
                            equipment.setUpdateBy(head.getId());
                            equipment.setContent(DateUtils.parseDateToStr("MM-dd HH:mm",equipment.getCreateTime())+" "+head.getDoorName()+" "+faxiang);
                            iMjEquipmentService.insertMjEquipment(equipment);
                        }
                        for(MjEquipment e:mjEquipments){
                            if(e.getStatus()==1){
                                MjEquipment equipment =  new MjEquipment();
                                equipment.setCreateTime(DateUtils.getNowDate());
                                equipment.setId(IdUtils.fastSimpleUUID());
                                equipment.setEquipmentType(0);
                                String faxiang = "";
                                if(head.getDirection()!=null){
                                    if(head.getDirection()==0){
                                        faxiang = "进门";
                                    }
                                    if(head.getDirection()==1){
                                        faxiang = "出门";
                                    }
                                }
                                equipment.setStatus(0);
                                equipment.setUpdateBy(head.getId());
                                equipment.setContent(DateUtils.parseDateToStr("MM-dd HH:mm",equipment.getCreateTime())+" "+head.getDoorName()+" "+faxiang);
                                iMjEquipmentService.insertMjEquipment(equipment);
                            }
                            break;
                        }
                    }
                    iMjFingerprintReadHeadService.updateMjFingerprintReadHead(head);
                }
//            });
//            t.start();
        //}
    }

    public boolean connectionStatus(String ip,String port){
        RestTemplate restTemplate = new RestTemplate();
        String url = ipAndPort+"/api/SDZ/ZktIsAlive";
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
        map.add("ip",ip);
        map.add("port",port);

        Boolean isAlive  = false;
        try
        {
            HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(map, headers);
            ResponseEntity<String> response = restTemplate.postForEntity( url, request , String.class );
            //System.out.println(response.getBody());
            JSONObject jsonObject = JSONObject.parseObject(response.getBody());
            JSONObject result = jsonObject.getJSONObject("result");
            isAlive = result.getBoolean("isAlive");
            //System.out.println(isAlive);
        }
        catch (Exception e)
        {
            isAlive=false;
        }

        return isAlive;
    }
}