package com.cloud.attendance.service.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.cloud.attendance.dao.AttDayDao;
import com.cloud.attendance.dao.AttRuleDao;
import com.cloud.attendance.model.AttDay;
import com.cloud.attendance.model.AttRule;
import com.cloud.attendance.model.PersonForEs;
import com.cloud.attendance.service.QueryEsService;
import com.cloud.attendance.service.TokenService;
//import com.cloud.attendance.util.HttpClient;
import com.cloud.attendance.service.UserService;
import com.cloud.attendance.utils.EnumStr;
import com.cloud.attendance.utils.HttpClient;
import com.cloud.model.sys.LoginAppUser;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

@Slf4j
@Component
@Configurable
@EnableScheduling      //   主要 3 个 定时任务
public class ScheduledDayData {

    @Autowired
    private AttDayDao attDayDao;

    @Autowired
    private AttRuleDao attRuleDao;

    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private EnumStr enumStr;
    @Autowired
    private UserService userService;

    private static  final  String terms = "{\"terms\":{\"videoReqNum\":reqList}}";

    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
    private  SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    private  SimpleDateFormat sdfTime = new SimpleDateFormat("HH:mm:ss");
    //每3分钟执行一次
    @Scheduled(cron = "0 0/3 1-22 * * *")
    public void reportCurrentByCron(){
        // 调用 http es 接口 查询 数据
        ArrayList<AttDay> attDays = new ArrayList<>();
//        signDate，inTime ，outTime ，inDeviceId ，inDeviceName，outDeviceId ，outDeviceName ，isNotSign ，isLate ，isLeaveEarly，
//        isLeave ，isRepair， revJson ，updateBy

        HttpHeaders headers = new HttpHeaders();
        MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
        headers.setContentType(type);
        headers.add("Accept", MediaType.APPLICATION_JSON.toString());
        String esJson = HttpClient.getEsJson();
                AttRule attRule = attRuleDao.selectAttRule();   // 获取考勤规则
        if (attRule == null){
            log.info("考勤规则暂无，考勤暂时做不了");
//                throw  new RuntimeException("请先调整考勤规则,然后才会 依据规则 调整考勤数据。");
            attRule = new AttRule();
            attRule.setInTime("09:00");
            attRule.setOutTime("18:00");
            attRule.setInTimeMin(5);
            attRule.setOutTimeMin(5);
        }
        String deviceIds = attRule.getDeviceIds();
        //  设备列表 起作用
        if (StringUtils.isBlank(deviceIds)){
            esJson = esJson.replace(",videoReqFilter","");
        }else {
            String[] devIds = deviceIds.split(",");
            String reqList = terms.replace("reqList",JSONObject.toJSONString(devIds));
            esJson = esJson.replace("videoReqFilter",reqList);
        }
        log.info("汇总语句："+esJson);
        HttpEntity<String> formEntity = new HttpEntity<String>(esJson, headers); // json 启动 赋值
        ResponseEntity<JSONObject> responseEntity = restTemplate.postForEntity("http://" + enumStr.getEsHOSTNAME()
                        + ":" + enumStr.getEsHTTP_PORT() + "/"+EnumStr.esIndexField+"/_search",
                formEntity, JSONObject.class);
        if (!responseEntity.getStatusCode().is2xxSuccessful()){
                // 报错 非200状态
            throw new RuntimeException("es json 返回失败！~");
        }else {
            JSONObject resp = responseEntity.getBody();
//                HttpClient.HttpPostWithJson("/cananaserman/_search", HttpClient.getEsJson());
//        JSONObject resp = JSONObject.parseObject(esRtnJson);  // 返回json
//            JSONObject signtimes = new Date(); // 签到 集合
            JSONArray sources = resp.getJSONObject("aggregations").getJSONObject("aggs_bucket").getJSONArray("buckets");   //   buckets 数据集合
            try {
                Date signDate = new Date();  //      考勤日期
                log.info(signDate+"signDate:考勤日期");
                Date inTime = getInTimeMin(attRule,null);     //  考勤迟到截止
            Date outTime = getOutTimeMin(attRule,null); // 考勤早退截止
                LoginAppUser loginAppUser =  null;  // tokenService.currentUser();
                if (loginAppUser==null|| loginAppUser.getUsername()==null){
                    loginAppUser = new LoginAppUser();loginAppUser.setUsername("basic-wp");
                }
                for (Object source : sources) {
                    JSONObject jsonSource = (JSONObject) source;   //
                    AttDay attDay = new AttDay();  // personId
                    attDay.setSignDate(signDate);      // 签到日期   2018-10-30  只是在下方代码判定需要、、是否签到，为null，则迟到早退给定null
                    attDay.preUpdate(loginAppUser);      // 更新日期
//                    log.info(jsonSource+":source 每个人的每天记录汇总");
                    attDay.setEmployeeId (jsonSource.getString("key"));
                    JSONArray inTimesource = jsonSource.getJSONObject("top_min_hits").getJSONObject("hits").getJSONArray("hits");
                    JSONObject _source = null;
                    if (inTimesource.size()>0){
                        _source =  ((JSONObject) inTimesource.get(0)).getJSONObject("_source");         // hits 中元素  _source
                          attDay.setIsNotSign(0);
                        attDay.setInTime(_source.getDate(EnumStr.picDateField));  // 切记时 getDate  不是 getSqlDate
                        attDay.setInDeviceId(_source.getString(EnumStr.devIdField));
                        attDay.setInDeviceName(_source.getString(EnumStr.devAddressField)); // 11-30 设备名称 修改为 地址
                    }else{ attDay.setSignDate(null);}
                    JSONArray outTimesource = jsonSource.getJSONObject("top_max_hits").getJSONObject("hits").getJSONArray("hits");
                    if (outTimesource.size()>0){
                         _source   =  ((JSONObject) outTimesource.get(0)).getJSONObject("_source");         // hits 中元素  _source
                        attDay.setOutTime(_source.getDate(EnumStr.picDateField));
                        attDay.setOutDeviceId(_source.getString(EnumStr.devIdField));
                        attDay.setOutDeviceName(_source.getString(EnumStr.devAddressField));  // 11-30 devNameField 修改为 devAddressField
                    }else{ attDay.setSignDate(null); }
                if (attDay.getSignDate() == null){
                    attDay.setSignDate(new Date());
                    attDay.setIsNotSign(1);attDay.setIsLate(null);attDay.setIsLeaveEarly(null);
                }else{            // 时间 比较 验证 迟到早退
                    attDay.setIsNotSign(0);   //  0 已签  1 未签
                    if (inTime.after(attDay.getInTime())){  //迟到 0否 1是',
                        attDay.setIsLate(0);
                    }else{ attDay.setIsLate(1);}
                    log.info(outTime.toString()+"--》outTime"+new Date());
                    log.info(outTime.before(new Date())+"确认状态信息");
                    if (outTime.before(new Date())){   // 如果 考勤 未到 迟到之前 不做记录
                        if (outTime.before(attDay.getOutTime())){ // 是否早退 0否 1是',
                            attDay.setIsLeaveEarly(0);
                        }else {attDay.setIsLeaveEarly(1); }
                    }
                }
// 考勤规则 如果是未启用  ，则 迟到和早退 置 0 为 否
                if (attDay.getSignDate() != null && (attRule.getEnable() == null || attRule.getEnable()==0)){
                    attDay.setIsLate(0);
                    attDay.setIsLeaveEarly(0);
                }
                attDays.add(attDay);
            }
            log.info(attDays.size()+"查询将修改人数");
                String ids = "";
                for (AttDay attDay : attDays) {
                    ids += (","+attDay.getEmployeeId());
                }
                int i = 0 ;
                if (attDays.size()>0){
                     i = attDayDao.updateByMorePerId(attDays);//  修改考勤记录
                }
                log.info(i+"修改内容。。。"+"ids:"+ids);
            }catch (ParseException e){
            e.printStackTrace();
        }catch (Exception e){
            e.printStackTrace();
        }
        }
    }
    // 获取 迟到 截止时间  09:05:00
    public Date getInTimeMin(AttRule attRule,Date mouthDate) throws ParseException {
        String inTime = attRule.getInTime();
        if (inTime==null)inTime = "09:00:00";
        String[] intimes = inTime.split(" ");
        inTime = intimes[intimes.length-1];
        if (mouthDate == null){
            mouthDate = new Date();
        }
        if(!isTime(inTime)){
            log.info(inTime+"inTime 验证09:00验证失败!~");
            if (inTime.split(":").length==2){
                inTime = inTime+":00";
            }
        }else{
            log.info(inTime+"  验证验证成功!~");
        }
        long time = attRule.getInTimeMin()*60*1000;//5 分钟
        Date beforeDate = new Date(sdfDate.parse(sdf.format(mouthDate)+" "+inTime).getTime() + time);//30分钟前的时间
        log.info("本次考勤规则 判断迟到截止时间"+sdfDate.format(beforeDate));
        return beforeDate;
    }
    // 获取 早退 截止时间
    public Date getOutTimeMin(AttRule attRule,Date mouthDate) throws ParseException {
        String outTime = attRule.getOutTime();
        if(outTime == null) outTime = "2019-03-07 18:30:00";
        String[] outimes = outTime.split(" ");
        outTime = outimes[outimes.length-1];
        if (mouthDate == null){
            mouthDate = new Date();
        }
        if(!isTime(outTime)){
            log.info(outTime+" 验证验证失败!~");
            if (outTime.split(":").length==2){
                outTime = outTime+":00";
            }
        }else {
            log.info(outTime + "  验证验证成功!~");
        }
        long time = attRule.getOutTimeMin()*60*1000;//5 分钟
        Date afterDate = new Date(sdfDate.parse(sdf.format(mouthDate)+" "+outTime).getTime() - time);//5分钟后的时间
        log.info("本次考勤规则 判断早退截止时间"+sdfDate.format(afterDate ));
        return afterDate;
    }
    // 时间 验证  15:30:30
    public static boolean isTime(String time){
        Pattern p = Pattern.compile("((((0?[0-9])|([1][0-9])|([2][0-4]))\\:([0-5]?[0-9])((\\s)|(\\:([0-5]?[0-9])))))?$");
        return p.matcher(time).matches();
    }

    //每天晚上十点30触发   创建 第二天 所有人员 的空表数据
    @Scheduled(cron = "0 50 22 * * ?")
    public void reportTomByDay(){
        System.out.println ("Scheduling Tasks Examples By Day: The time is now " + sdfTime.format (new Date ()));
       // orgid  employeeid  employeename createby  remarks  createdate可null
 ///        调用 人员项目的查询所有人员

//        attDayDao.insertEmployData("basic-wp-quarz");    // nickname  正式数据库 人员使用
// 查询 所有人员 加入 考勤库
        JSONArray persons = userService.queryAllPersonList();
        attDayDao.insertMoreData(persons,new Date(new Date().getTime()+1000*60*60*24),null,null);
    }
    //每天5分钟触发   创建 当天 所有人员 的空表数据
    @Scheduled(cron = "0 0/5 2-22 * * ?")
    public void reportCurrentByDay(){
        System.out.println ("2小时触发创建当天所有人员 的空表数据: The time is now " + sdfTime.format (new Date ()));
        // orgid  employeeid  employeename createby  remarks  createdate可null
        ///        直接sql 查询所有人员
//        attDayDao.startInsertEmployData("basic-wp-quarz",null);    // nickname  正式数据库 人员使用

        ///        调用 人员项目的查询所有人员
        Map<String,JSONObject> persons = userService.queryAllPersonId();
        List<String> existPer = attDayDao.selectPersonByDate(new Date());
        existPer.forEach(userId -> {
            persons.remove(userId);
        });
        // 去除存在人员
        Collection<JSONObject> valueCollection2 = persons.values();
        List<Object> valueList= new ArrayList<Object>(valueCollection2);//map转list
        if (valueList .size() > 0){
            attDayDao.insertMoreData(valueList,null,null,null);
        }
    }

    //从 es 查询人员 然后加入 数据库 的空表数据 ，人员查询可以后，注释掉====================以下不用看了
//   @Scheduled(cron = "0 30 * * * ?")
    public void addEsPersonByDay(){
        System.out.println ("从 es 查询人员 然后加入 数据库addEsPersonByDay Day: time is now " + sdfTime.format (new Date ()));
        // id; Integer orgId;Integer officeId;
        //    name; gender; type; photos;
        ///        调用 人员项目的查询所有人员
        List<PersonForEs> persons = queryEsService.queryPersonIdFromEs();
        log.info(persons.size()+"人员将被加入person_es库中");
        for (PersonForEs person : persons){
            try {
                int i = attDayDao.insertEsPerson(person);
                log.info(i+"将被加入"+person);
            }catch (RuntimeException ex) {
                log.info("添加es人员异常:"+ex.getLocalizedMessage());
            }
        }
    }
    //每2分钟执行一次  测试
//    @Scheduled(cron = "0/5 42-50 * * * *")
    public void reportCurrentTest(){
             //   经测试 可以
        log.info( sdfTime.format (new Date ())+"时间");
    }

    @Autowired
    QueryEsService queryEsService;
    //每3秒执行一次  给前台 推数据
//    @Scheduled(cron = "0/1 * * * * *")
    public void reportEswebSocket() {

        List<JSONObject> jsonObjects = queryEsService.queryAttRecordBySecond();
        try {
            if (jsonObjects.size() > 0){
                MyWebSocket.sendInfo( jsonObjects.toString());
            }
        }catch (IOException e) {
            e.printStackTrace();
        }
        log.info( sdfTime.format (new Date ())+"query es 时间");
    }
    //每3秒执行一次  测试 是否可以传参数  --- 不可以
//    @Scheduled(cron = "0/3 * * * * *")
    public void testParam() {

       log.info("--===--测试 是否可以接收参数");
        log.info( sdfTime.format (new Date ())+"query es 时间");
    }

}