package com.sincere.quartz.job;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.sincere.common.dto.smartCampus.*;
import com.sincere.common.enums.PushTypeEnums;
import com.sincere.common.util.DateUtils;
import com.sincere.common.util.HttpClientUtils;
import com.sincere.quartz.enums.KqTypeEnums;
import com.sincere.quartz.enums.TypeEnums;
import com.sincere.quartz.feign.ScFeign;
import com.sincere.quartz.model.DingSms;
import com.sincere.quartz.model.ShortMsg;
import com.sincere.quartz.model.WeChatSms;
import com.sincere.quartz.service.ManagerService;
import com.sincere.quartz.service.SmsService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.*;

/**
 * 考勤任务推送调用
 * 主要推送盯盯以及企业号
 * @author chen
 * @version 1.0
 * @date 2019/11/27 0027 17:05
 */
@Service
public class KQJob {

    private Logger logger = LoggerFactory.getLogger(KQJob.class);

    @Autowired
    ScFeign scFeign ;

    @Autowired
    SmsService smsService;

    @Autowired
    ManagerService managerService ;

    private static String iotUrl = "http://60.190.202.57:8035";

    private static String date ;
    private static Map<String , String> map = new HashMap<>();   //学校 考勤推送map

    private static String alarmDate ;
    private static Map<String , String> alarmMap = new HashMap<>();   //考勤告警推送map
    private static Map<String , BigDecimal> templateMap = new HashMap<>(); // 考勤比例

    private static List<String> opexList ;
    private static String integration ;

    static{
        opexList = new ArrayList<>();
        opexList.add("15857566147");  //王汉栋
        opexList.add("13858485977");  //王楠彬

        integration = "18767117554" ;  //林炜
    }

    @Scheduled(cron = "0 0-59 * * * ? ")
    public void kaoQing() {
         String now = DateUtils.date2String(new Date(),DateUtils.format1) ;
        if(StringUtils.isBlank(date)){
            initMap();
            date = now ;
        }
        if(!DateUtils.date2String(new Date(),DateUtils.format1).equals(date)){
            initMap();
            date = DateUtils.date2String(new Date(),DateUtils.format1) ;
        }
        //开始过滤数据  推送
        List<String> keyList = new ArrayList<>();
        for(Map.Entry<String, String> entity : map.entrySet()){
            String endTime = entity.getValue().split("_")[1];
            if(DateUtils.getDateDifference(new Date(),DateUtils.string2Date(now+" "+endTime+":00",DateUtils.format2),"m")>=2
                    && DateUtils.getDateDifference(new Date(),DateUtils.string2Date(now+" "+endTime+":00",DateUtils.format2),"m")<5){
                String key = entity.getKey();
                String[] messageArray = key.split("_");
                if(messageArray[2].contains(PushTypeEnums.QIYEHAO.getType()+"")){
                    logger.info("企业号推送：" + messageArray[0] + "__" + messageArray[1]);
                    weChatBatchPush(messageArray[0],Integer.valueOf(messageArray[1]),entity.getValue());
                }
                if(messageArray[2].contains(PushTypeEnums.DING.getType()+"")){
                    logger.info(("盯盯推送：" + messageArray[0] + "__" + messageArray[1]));
                    dingBatchPush(messageArray[0],Integer.valueOf(messageArray[1]),entity.getValue());
                }
                keyList.add(key);
            }
        }
        for(String key : keyList){
            map.remove(key);
        }
    }

    @Scheduled(cron = "0 0-59 * * * ? ")
    public void alarmKaoQing() {
        String now = DateUtils.date2String(new Date(),DateUtils.format1) ;
        if(StringUtils.isBlank(alarmDate)){
            initAlarmMap();
            alarmDate = now ;
        }
        if(!DateUtils.date2String(new Date(),DateUtils.format1).equals(alarmDate)){
            initAlarmMap();
            alarmDate = DateUtils.date2String(new Date(),DateUtils.format1) ;
        }
        //开始过滤数据  推送
        List<String> keyList = new ArrayList<>();
        for(Map.Entry<String, String> entity : alarmMap.entrySet()){
            String endTime = entity.getValue().split("_")[1];
            if(DateUtils.getDateDifference(new Date(),DateUtils.string2Date(now+" "+endTime+":00",DateUtils.format2),"m")>=2
                    ){
                String key = entity.getKey();
                keyList.add(key);
                //alarm(entity);  //告警
                //insertIOT(entity); //iot
            }
        }
        for(String key : keyList){
            map.remove(key);
        }
    }

    private void initAlarmMap(){
        alarmMap = new HashMap<>();
        List<TemplateDto> list = scFeign.getAllTemplateAlarm();
        logger.info(("------考勤告警模板------"));
        for(TemplateDto templateDto : list){
            String config = templateDto.getConfig();
            String[] array = config.split("<Template");
            for(int i = 1 ; i<array.length ;i++){
                try{
                    String msg = array[i];
                    String beginTime = msg.substring(msg.indexOf("BeginTime")+11,msg.indexOf("BeginTime")+16);
                    String endTime = msg.substring(msg.indexOf("EndTime")+9,msg.indexOf("EndTime")+14);
                    String templateId = msg.substring(msg.indexOf("TemplateID")+12,msg.indexOf("TemplateID")+22);
                    String Week = msg.substring(msg.indexOf("Week")+6,msg.indexOf("Week")+19);
                    String type = msg.substring(msg.indexOf("Type")+6,msg.indexOf("Type")+8);
                    type = type.replace("\"","");
                    int nowWeek = DateUtils.getWeek() ;
                    if(Week.contains(nowWeek+"") && nowWeek != 6 && nowWeek != 0 ){  //周末不告警
                        logger.info((templateId+"_"+templateDto.getSchoolId()+"------"+beginTime+"_"+endTime));
                        alarmMap.put(templateId+"_"+templateDto.getSchoolId()+"_"+templateDto.getTitle() , beginTime+"_"+endTime+"_"+type+"_"+templateDto.getId());
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }
    }

    //告警推送
    private void alarm(Map.Entry<String,String> entry){
        String templateId = entry.getKey().split("_")[0] ;
        String schoolId = entry.getKey().split("_")[1] ;
        String id = entry.getValue().split("_")[3];
        String type = entry.getValue().split("_")[2] ;

        if(DateUtils.getWeek() == 2 || DateUtils.getWeek() == 5){
            //可以相差40%
            BigDecimal percent = getAlarmCensus(Integer.valueOf(id),templateId,Integer.valueOf(schoolId),Integer.valueOf(type));
            if(templateMap.get(templateId) != null){
                if(percent.subtract(templateMap.get(templateId)).compareTo(new BigDecimal(0.4)) > 0
                    || templateMap.get(templateId).subtract(percent).compareTo(new BigDecimal(0.4)) > 0) {
                    alarmPush(Integer.valueOf(schoolId));
                }
            }
            templateMap.put(templateId,percent);
        }else {
            //相差30%
            BigDecimal percent = getAlarmCensus(Integer.valueOf(id),templateId,Integer.valueOf(schoolId),Integer.valueOf(type));
            if(templateMap.get(templateId) != null){
                if(percent.subtract(templateMap.get(templateId)).compareTo(new BigDecimal(0.3)) > 0
                        || templateMap.get(templateId).subtract(percent).compareTo(new BigDecimal(0.3)) > 0) {
                    alarmPush(Integer.valueOf(schoolId));
                }
            }
            templateMap.put(templateId,percent);
        }
    }

    private void insertIOT(Map.Entry<String,String> entry){
        String templateId = entry.getKey().split("_")[0] ;
        String schoolId = entry.getKey().split("_")[1] ;
        String title = entry.getKey().split("_")[2] ;
        String id = entry.getValue().split("_")[3];
        String type = entry.getValue().split("_")[2] ;
        String beginTime = entry.getValue().split("_")[0] ;
        String endTime = entry.getValue().split("_")[1] ;

        List<Integer> list = getIOTCensus(Integer.valueOf(id),templateId,Integer.valueOf(schoolId),Integer.valueOf(type)) ;
        JSONObject object = new JSONObject();
        object.put("strTime",beginTime);
        object.put("endTime",endTime);
        object.put("inTime",DateUtils.date2String(new Date(),DateUtils.format1));
        object.put("noAttendanceCount",list.get(1));
        object.put("attendanceCount",list.get(0));
        object.put("leaveCount",list.get(2));
        object.put("templateName",title);
        object.put("qianDaoIdId",id);
        object.put("schoolId",schoolId);
        object.put("templateId",templateId);
        HttpClientUtils.httpPostJson(iotUrl+"/api/Association/addIntelligenceAttendance",object.toJSONString());
    }

    //初始化要推送的模板
    private void initMap(){
        map = new HashMap<>();
        List<TemplateDto> list = scFeign.getAllTemplate();
        logger.info(("------需要推送的考勤模板------"));
        for(TemplateDto templateDto : list){
            String config = templateDto.getConfig();
            String[] array = config.split("<Template");
            for(int i = 1 ; i<array.length ;i++){
                try{
                    String msg = array[i];
                    String beginTime = msg.substring(msg.indexOf("BeginTime")+11,msg.indexOf("BeginTime")+16);
                    String endTime = msg.substring(msg.indexOf("EndTime")+9,msg.indexOf("EndTime")+14);
                    String templateId = msg.substring(msg.indexOf("TemplateID")+12,msg.indexOf("TemplateID")+22);
                    String Week = msg.substring(msg.indexOf("Week")+6,msg.indexOf("Week")+19);
                    String type = msg.substring(msg.indexOf("Type")+6,msg.indexOf("Type")+8);
                    type = type.replace("\"","");
                    int nowWeek = DateUtils.getWeek() ;
                    if(Week.contains(nowWeek+"")){
                        logger.info((templateId+"_"+templateDto.getSchoolId()+"_"+templateDto.getType()+"------"+beginTime+"_"+endTime));
                        map.put(templateId+"_"+templateDto.getSchoolId()+"_"+templateDto.getType() , beginTime+"_"+endTime+"_"+type+"_"+templateDto.getId());
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }
    }

    //盯盯批量推送
    private void dingBatchPush(String templateId , int schoolId , String key){
        String[] times = key.split("_");
        AppDto appDto = scFeign.getApp(schoolId,1);
        if(Integer.valueOf(times[2])  < 7){
            //出入校   推班主任
            List<KqTeacherDto> list = scFeign.getTeacherList(schoolId);
            for(KqTeacherDto teacher : list){
                 dingSchoolPush(templateId,teacher,key,appDto,0);
            }
        }else {
            //出入寝  推班主任
            List<KqTeacherDto> list = scFeign.getTeacherList(schoolId);
            for(KqTeacherDto teacher : list){
                dingSchoolPush(templateId,teacher, key, appDto,1);
            }
            //推宿管
            List<KqTeacherDto> chamberList = scFeign.selectChamberTeacher(schoolId);
            for(KqTeacherDto teacher : chamberList){
                dingChamberPush(templateId,teacher, key, appDto);
            }
        }
    }

    //企业号批量推送
    private void weChatBatchPush(String templateId , int schoolId , String key){
        String[] times = key.split("_");
        AppDto appDto = scFeign.getApp(schoolId, 0);
        if(Integer.valueOf(times[2])  < 7) {
            //出入校   推班主任
            List<KqTeacherDto> list = scFeign.getTeacherList(schoolId);
            for (KqTeacherDto teacher : list) {
                weChatSchoolPush(templateId,teacher, key, appDto,0);
            }
        }else {
            //出入寝  推班主任
            List<KqTeacherDto> list = scFeign.getTeacherList(schoolId);
            for (KqTeacherDto teacher : list) {
                weChatSchoolPush(templateId,teacher, key, appDto,1);
            }
            //推宿管
            List<KqTeacherDto> chamberList = scFeign.selectChamberTeacher(schoolId);
            for(KqTeacherDto teacher : chamberList){
                weChatChamberPush(templateId,teacher, key, appDto);
            }
        }
    }

    //盯盯推送班主任
    private void dingSchoolPush(String templateId ,KqTeacherDto teacher , String key , AppDto appDto , int type){
        String[] times = key.split("_");
        String tableSuffix = DateUtils.date2String(new Date(), DateUtils.format);
        String thirdOpenId = scFeign.getThirdId(teacher.getUserId(),0);
        if(StringUtils.isNotBlank(thirdOpenId)){
            List<CensusKqDto> censusKqDtos = getCensus(Integer.valueOf(times[3]),templateId,teacher.getSchoolId(),teacher.getUserId(),type);
            if(censusKqDtos != null &&censusKqDtos.size() > 0){
                String message = "";
                for(CensusKqDto censusKqDto : censusKqDtos){
                    message += "[" + censusKqDto.getTargetName() + "]未考勤" + censusKqDto.getNotAttendCount() + "人，请假"+censusKqDto.getLeaveCount()+"人；";
                }
                DingSms dingSms = new DingSms();
                dingSms.setName(teacher.getName());
                dingSms.setTableName("DingSmsNew"+tableSuffix);
                dingSms.setMsg("报告类型："+KqTypeEnums.getName(Integer.valueOf(times[2])) + "出勤报告 \n - "+
                        "签到日期："+DateUtils.date2String(new Date(),DateUtils.format1)+ "("+DateUtils.getWeekName()+") \n - "+
                        "签到时间："+times[0]+"-"+ times[1] +" \n - "+
                        "整体数据：" + message);
                String wapUrl = "http://campus.myjxt.com/studentRecord/znxwwebapp/index.html?" +
                        "schoolid="+teacher.getSchoolId()+"&userId="+teacher.getUserId()+"&name="+teacher.getName()+ "&TemplateId=" + templateId+
                        "&data="+thirdOpenId+"&type=5&stype=4&mobile="+teacher.getMobile()+"&pass="+teacher.getPass()+
                        "&QianDaoId="+times[3]+"&ClassId=0&face=&sourcetype=16&soutype=3&timestamp="+ DateUtils.getDate()+"&time="+DateUtils.date2String(new Date(),DateUtils.format1) ;
                dingSms.setSchoolId(teacher.getSchoolId());
                dingSms.setDingUserId(thirdOpenId);
                dingSms.setAgentId(appDto.getAgentId());
                dingSms.setWapUrl(wapUrl);
                dingSms.setReceiveUserId(teacher.getUserId());
                dingSms.setTdType(TypeEnums.kaoqing.getType());
                this.insertDing(dingSms);
                logger.info("盯盯推送班主任—————" + templateId + "--------" + teacher.getName());
            }
        }
    }

    //盯盯推送宿管
    private void dingChamberPush(String templateId, KqTeacherDto teacher , String key , AppDto appDto){
        String[] times = key.split("_");
        String tableSuffix = DateUtils.date2String(new Date(), DateUtils.format);
        String thirdOpenId = scFeign.getThirdId(teacher.getUserId(),0);
        if(StringUtils.isNotBlank(thirdOpenId)){
            List<CensusKqDto> censusKqDtos = getCensus(Integer.valueOf(times[3]),templateId,teacher.getSchoolId(),teacher.getUserId(),1);
            if(censusKqDtos != null &&censusKqDtos.size() > 0){
                String message = "";
                for(CensusKqDto censusKqDto : censusKqDtos){
                    message += "[" + censusKqDto.getTargetName() + "]未考勤" + censusKqDto.getNotAttendCount() + "人，请假"+censusKqDto.getLeaveCount()+"人；";
                }
                DingSms dingSms = new DingSms();
                dingSms.setName(teacher.getName());
                dingSms.setTableName("DingSmsNew"+tableSuffix);
                dingSms.setMsg("报告类型："+KqTypeEnums.getName(Integer.valueOf(times[2])) + "出勤报告 \n - "+
                        "签到日期："+DateUtils.date2String(new Date(),DateUtils.format1)+ "("+DateUtils.getWeekName()+") \n - "+
                        "签到时间："+times[0]+"-"+ times[1] +" \n - "+
                        "整体数据：" + message);
                String msgUrl = "http://campus.myjxt.com/studentRecord/znxwwebapp/index.html?" +
                        "schoolid=" + teacher.getSchoolId() + "&userId=" + teacher.getUserId() + "&name=" + teacher.getName() +"&TemplateId=" + templateId+
                        "&pass=" + teacher.getPass() + "&type=4&soutype=3&time="+DateUtils.date2String(new Date(),DateUtils.format1);
                dingSms.setSchoolId(teacher.getSchoolId());
                dingSms.setDingUserId(thirdOpenId);
                dingSms.setAgentId(appDto.getAgentId());
                dingSms.setWapUrl(msgUrl);
                dingSms.setReceiveUserId(teacher.getUserId());
                dingSms.setTdType(TypeEnums.kaoqing.getType());
                this.insertDing(dingSms);
                logger.info("盯盯推送宿管—————" + templateId + "--------" + teacher.getName());
            }
        }
    }

    //企业号推送班主任
    private void weChatSchoolPush(String templateId, KqTeacherDto teacher , String key , AppDto appDto , int type){
        String[] times = key.split("_");
        String tableSuffix = DateUtils.date2String(new Date(), DateUtils.format);
        String thirdOpenId = scFeign.getThirdId(teacher.getUserId(),1);
        if (StringUtils.isNotBlank(thirdOpenId)) {
            List<CensusKqDto> censusKqDtos = getCensus(Integer.valueOf(times[3]),templateId,teacher.getSchoolId(),teacher.getUserId(),type);
            if (censusKqDtos != null && censusKqDtos.size() > 0) {
                String message = "";
                for (CensusKqDto censusKqDto : censusKqDtos) {
                    message += "[" + censusKqDto.getTargetName() + "]未考勤" + censusKqDto.getNotAttendCount() + "人，请假"+censusKqDto.getLeaveCount()+"人；";
                }
                WeChatSms weChatSms = new WeChatSms();
                weChatSms.setTableName("qyhSmsNew" + tableSuffix);
                weChatSms.setMsg("报告类型：" + KqTypeEnums.getName(Integer.valueOf(times[2])) + "出勤报告 \n - " +
                        "签到日期：" + DateUtils.date2String(new Date(), DateUtils.format1) + "(" + DateUtils.getWeekName() + ") \n - " +
                        "签到时间：" + times[0] + "-" + times[1] + " \n - " +
                        "整体数据：" + message);
                weChatSms.setSchoolId(teacher.getSchoolId());
                weChatSms.setName(teacher.getName());
                weChatSms.setQiYeHaoUserId(thirdOpenId);
                weChatSms.setReceiveUserId(teacher.getUserId());
                weChatSms.setAppId(appDto.getAgentId());
                weChatSms.setSecret(appDto.getAgentSecret());
                String msgUrl = "http://campus.myjxt.com/studentRecord/znxwwebapp/index.html?" +
                        "schoolid=" + teacher.getSchoolId() + "&userId=" + teacher.getUserId() + "&name=" + teacher.getName() +"&TemplateId=" + templateId+
                        "&data=" + thirdOpenId + "&type=1&stype=3&mobile=" + teacher.getMobile() + "&pass=" + teacher.getPass() +
                        "&face=" + teacher.getFace() + "&sourcetype=16&soutype=2&timestamp=" + DateUtils.getDate()+"&time="+DateUtils.date2String(new Date(),DateUtils.format1)+"&";
                weChatSms.setMsgUrl(msgUrl);
                weChatSms.setTdType(TypeEnums.kaoqing.getType());
                this.insertQYH(weChatSms);
                logger.info("企业号推送班主任—————" + templateId + "--------" + teacher.getName());
            }
        }
    }

    //企业号推送宿管
    private void weChatChamberPush(String templateId, KqTeacherDto teacher , String key , AppDto appDto){
        String[] times = key.split("_");
        String tableSuffix = DateUtils.date2String(new Date(), DateUtils.format);
        String thirdOpenId = scFeign.getThirdId(teacher.getUserId(),1);
        if (StringUtils.isNotBlank(thirdOpenId)) {
            List<CensusKqDto> censusKqDtos = getCensus(Integer.valueOf(times[3]),templateId,teacher.getSchoolId(),teacher.getUserId(),1);
            if (censusKqDtos != null && censusKqDtos.size() > 0) {
                String message = "";
                for (CensusKqDto censusKqDto : censusKqDtos) {
                    message += "[" + censusKqDto.getTargetName() + "]未考勤" + censusKqDto.getNotAttendCount() + "人，请假"+censusKqDto.getLeaveCount()+"人；";
                }
                WeChatSms weChatSms = new WeChatSms();
                weChatSms.setTableName("qyhSmsNew" + tableSuffix);
                weChatSms.setMsg("报告类型：" + KqTypeEnums.getName(Integer.valueOf(times[2])) + "出勤报告 \n - " +
                        "签到日期：" + DateUtils.date2String(new Date(), DateUtils.format1) + "(" + DateUtils.getWeekName() + ") \n - " +
                        "签到时间：" + times[0] + "-" + times[1] + " \n - " +
                        "整体数据：" + message);
                weChatSms.setSchoolId(teacher.getSchoolId());
                weChatSms.setName(teacher.getName());
                weChatSms.setQiYeHaoUserId(thirdOpenId);
                weChatSms.setReceiveUserId(teacher.getUserId());
                weChatSms.setAppId(appDto.getAgentId());
                weChatSms.setSecret(appDto.getAgentSecret());
                String msgUrl = "http://campus.myjxt.com/studentRecord/znxwwebapp/index.html?" +
                        "schoolid=" + teacher.getSchoolId() + "&userId=" + teacher.getUserId() + "&name=" + teacher.getName() +"&TemplateId=" + templateId+
                        "&pass=" + teacher.getPass() + "&type=4&soutype=2&time="+DateUtils.date2String(new Date(),DateUtils.format1)+"&";
                weChatSms.setMsgUrl(msgUrl);
                weChatSms.setTdType(TypeEnums.kaoqing.getType());
                this.insertQYH(weChatSms);
                logger.info("企业号推送宿管—————" + templateId + "--------" + teacher.getName());
            }
        }
    }

    //type  0 出入校 1 出入寝
    private List<CensusKqDto> getCensus(int id , String templateId ,int schoolId , String userId ,int type){
        List<CensusKqDto> list = new ArrayList<>();
        String url = "http://campus.myjxt.com/api/EasyN/GeAttendDetailNew?schoolId="+schoolId+
                "&id="+id+"&templateID="+templateId+"&type="+type+"&userId="+userId+"&time=" + DateUtils.date2String(new Date(),DateUtils.format1);
        JSONObject jsonObject = HttpClientUtils.httpGet(url);
        try{
            JSONArray data = (JSONArray)jsonObject.get("data");
            for(int i = 0 ; i < data.size() ; i++){
                CensusKqDto censusKqDto = new CensusKqDto();
                JSONObject object = data.getJSONObject(i);
                censusKqDto.setLeaveCount((Integer) object.get("leaveCount"));
                censusKqDto.setNotAttendCount((Integer) object.get("noAttendCount"));
                censusKqDto.setTargetName((String)object.get("name"));
                list.add(censusKqDto);
            }
        }catch (Exception e){

        }
        return list ;
    }

    private BigDecimal getAlarmCensus(int id , String templateId ,int schoolId , int type){
        int allNumber = 0 , attendNumber = 0 ;
        List<Integer> list = scFeign.selectClassBySchoolId(schoolId);
        for(Integer classId : list){
            String url = "http://campus.myjxt.com/api/EasyN/GeAttendDetail?classId="+classId+
                    "&id="+id+"&templateID="+templateId+"&type="+type+"&time=" + DateUtils.date2String(new Date(),DateUtils.format1);
            JSONObject jsonObject = HttpClientUtils.httpGet(url);
            try{
                JSONObject data = (JSONObject) jsonObject.get("data");
                attendNumber = attendNumber + (Integer) data.get("stuAttendCount");
                allNumber = allNumber + (Integer) data.get("stuCount");
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        if(allNumber != 0){
            BigDecimal pecrent = new BigDecimal(attendNumber).divide(new BigDecimal(allNumber),10, BigDecimal.ROUND_HALF_DOWN) ;
            return  pecrent ;
        }else {
            return BigDecimal.ZERO ;
        }

    }

    /**
     *
     * @param id
     * @param templateId
     * @param schoolId
     * @param type
     * @return list(0)  出勤 list(1) 未出勤  List(2) 请假
     */
    private List<Integer> getIOTCensus(int id , String templateId ,int schoolId , int type){
        List<Integer> result = new ArrayList<>();
        int attend = 0 , unattend = 0 , leave = 0;
        List<Integer> list = scFeign.selectClassBySchoolId(schoolId);
        for(Integer classId : list){
            String url = "http://campus.myjxt.com/api/EasyN/GeAttendDetail?classId="+classId+
                    "&id="+id+"&templateID="+templateId+"&type="+type+"&time=" + DateUtils.date2String(new Date(),DateUtils.format1);
            JSONObject jsonObject = HttpClientUtils.httpGet(url);
            try{
                JSONObject data = (JSONObject) jsonObject.get("data");
                attend = attend + (Integer) data.get("stuAttendCount");
                unattend = unattend + (Integer) data.get("noAttendCount");
                leave = leave + (Integer) data.get("leaveCount");
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        result.add(attend);
        result.add(unattend);
        result.add(leave);
        return result ;
    }


    private void insertDing(DingSms dingSms){
        try{
            smsService.insertDing(dingSms);
        }catch (Exception e){
            logger.info(e.toString());
        }
    }

    private void insertQYH(WeChatSms weChatSms){
        try{
            smsService.insertWeChat(weChatSms);
        }catch (Exception e){
            logger.info(e.toString());
        }
    }

    private void alarmPush(int schoolId){
        String msg = "【考勤异动】" ;
        try{
            SchoolDto schoolDto = scFeign.selectSchoolBySchoolId(schoolId);
            msg +=  schoolDto.getSchoolName() + "考勤有异动，请关注！" ;
            sendMessage(schoolDto.getSchoolId(),opexList.get(0),msg);
            sendMessage(schoolDto.getSchoolId(),opexList.get(1),msg);
            sendMessage(schoolDto.getSchoolId(),integration,msg);
            String managerPhone = managerService.selectManagerById(schoolDto.getManagerUserId()) ;
            if(StringUtils.isNotBlank(managerPhone)){
                sendMessage(schoolDto.getSchoolId(),managerPhone,msg);
            }
        }catch (Exception e){
            e.printStackTrace();
        }

    }

    private void sendMessage(int schoolId , String mobile , String msg){
        String tableSuffix = DateUtils.date2String(new Date(), DateUtils.format);
        ShortMsg shortMsg = new ShortMsg();
        shortMsg.setTableName("smsNew"+tableSuffix);
        shortMsg.setSchoolId(schoolId);
        shortMsg.setMobile(mobile);
        shortMsg.setMsg(msg);
        smsService.insertSMS(shortMsg);
    }
}