package com.example.demo.utils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.example.demo.dao.ArticleRepository;
import com.example.demo.dao.WeatherRepository;
import com.example.demo.service.WeatherService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import xyz.erupt.core.util.DateUtil;

import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.TimeUnit;


@Component
public class SchedulerUtil {

    private static Logger logger = LoggerFactory.getLogger(SchedulerUtil.class);

    @Autowired
    private ArticleRepository articleRepository;

    @Autowired
    private WeatherService weatherService;

    @Autowired
    private RestTemplate restTemplate;

    @Value("${gis.staturl}")
    private String staturl;

    @Value("${gis.cacu_cover_rate_url}")
    private String cacuCoverRateUrl;

    @Value("${gis.recordurl}")
    private String recordurl;

    @Value("${gis.getfreqsurl}")
    private String getfreqsurl;

    @Value("${gis.dealdataurl}")
    private String dealdataurl;


//  @Scheduled(fixedDelay = 300*1000)
    public void checkUsermlTask() {

    }

    @Scheduled(cron = "00 05 * * * ?")
    public void updateUserTokenTask() {
        logger.info("-------------Scheduled---------------getWeather");
        weatherService.getWeather();
    }

    /**
     * 统计频率指标 每小时的1分30秒执行一次
     */
    @Scheduled(cron = "30 01 * * * ?")
//    @Scheduled(fixedDelay = 20*1000)
    public void getRemoteToken() {
        logger.info("-------------Scheduled---------------statByHour");
//        ?bid=statByHour&starttime=#{starttime}&endtime=#{endtime}
        String strength_stat_url = staturl + "?bid=statByHour&starttime=#{starttime}&endtime=#{endtime}";
        LocalDateTime localDateTime = LocalDateTime.now();
        String timeStr2= localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:00:00"));
        String timeStr1= localDateTime.plusHours(-1L).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:00:00"));
        RestTemplateUtil.getDataByRestTemplate(strength_stat_url.replace("#{starttime}",timeStr1).replace("#{endtime}",timeStr2), restTemplate);
    }

    /**
     * 计算频率压制覆盖率 每小时的1分01秒执行一次
     */
    @Scheduled(cron = "01 01 * * * ?")
//    @Scheduled(fixedDelay = 20*1000)
    public void setFreqCoverRate() {
        logger.info("-------------Scheduled---------------cacuCoverRate");
//        ?bid=statByHour&starttime=#{starttime}&endtime=#{endtime}
        RestTemplateUtil.getDataByRestTemplate(cacuCoverRateUrl, restTemplate);
    }

    /**
     * 创建评分任务
     */
//    @Scheduled(cron = "30 10 1 * * ?")
    @Scheduled(fixedDelay = 300*1000)
    public void createAssessTask() {
        logger.info("-------------Scheduled---------------autoCreateAssessTask");
        String strength_stat_url = staturl + "?bid=autoCreateAssessTask&starttime=#{starttime}&endtime=#{endtime}";
        LocalDateTime localDateTime = LocalDateTime.now();
        String timeStr2= localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:00:00"));
        String timeStr1= localDateTime.plusMinutes(-5L).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:00:00"));
        RestTemplateUtil.getDataByRestTemplate(strength_stat_url.replace("#{starttime}",timeStr1).replace("#{endtime}",timeStr2), restTemplate);
    }

    @Scheduled(fixedDelay = 300*1000)
    public void autoRecordTask() {
        logger.info("-------------Scheduled---------------autoRecordTask     \\r\\n");
        String strength_stat_url = staturl + "?bid=toRecordList";
        JSONObject retjson = RestTemplateUtil.getDataByRestTemplate(strength_stat_url, restTemplate);
        JSONArray jsonArr = retjson.getJSONObject("data").getJSONArray("data").getJSONArray(0);
        if(jsonArr.size() == 0) {
            return ;
        }
        StringBuffer monitorpoint_ids = new StringBuffer();
        StringBuffer ids = new StringBuffer();
        StringBuffer feqs = new StringBuffer();
        for (int i = 0; i < jsonArr.size(); i++) {
            JSONObject jsonObject = jsonArr.getJSONObject(i);
            feqs.append(i==0 ? "" :",").append(jsonObject.getString("frequency"));
            String monitorpoint_id = jsonObject.getString("monitorpoint_id");
            monitorpoint_ids.append(i==0 ? "" :",").append(monitorpoint_id);
            ids.append(i==0 ? "" :",").append(jsonObject.get("id").toString());
        }
        logger.info("record points："+monitorpoint_ids.toString());
        String recordUrl_ = recordurl + "&method=record"+"&frequencyValue="+feqs.toString()+"&monitorpointId="+monitorpoint_ids.toString()+"&isUnderWay=0&recordTimeLength=1";
        JSONObject retjson_ = RestTemplateUtil.getDataByRestTemplate(recordUrl_, restTemplate);
        JSONArray jsons = retjson_.getJSONArray("data");
        for (int i = 0; i < jsons.size(); i++) {
            JSONObject recordResult = jsons.getJSONObject(i);
            Map<String, String> params = new HashMap<String, String>();
            params.put("bid","setChannelRecord");
            params.put("frequency",recordResult.getString("frequencyValue"));
            params.put("monitorpointId",recordResult.getString("monitorpointId"));
            params.put("userid","admin");
            params.put("requesturl",recordUrl_);
            params.put("success",recordResult.getBoolean("success").toString());
            params.put("msg",recordResult.getString("msg"));
            params.put("flvurl","");
            RestTemplateUtil.postDataByRestTemplate(dealdataurl,params, restTemplate);
            if(recordResult.getBoolean("success")) {
                String nowTime = DateUtil.getSimpleFormatDate(new Date());
                RestTemplateUtil.getDataByRestTemplate(staturl + "?bid=updateRecordTime&recordtime="+nowTime+"&id="+ids.toString(), restTemplate);
            }
        }

        logger.info("--------------------------------over-----------------------------");
    }

//    @Scheduled(cron = "01 00 * * * ?")
    @Scheduled(fixedDelay = 18000*1000)
    public void autoRecordAllFreqs() {   //getfreqsurl
        logger.info("-------------Scheduled---------------autoRecordAllFreqs     \\r\\n");
        LocalDateTime localDateTime = LocalDateTime.now();
        String wdate = localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
        String whour = localDateTime.getHour()<10 ? "0"+localDateTime.getHour() : ""+localDateTime.getHour();
        String getPoints_url = staturl+"?bid=getPointData&frequency=1557&wdate="+wdate+"&whour="+whour+"&userid=admin";
        JSONObject retjson = RestTemplateUtil.getDataByRestTemplate(getPoints_url, restTemplate);
        JSONArray jsonArr = retjson.getJSONObject("data").getJSONArray("data").getJSONArray(0);
        StringBuffer feqs = new StringBuffer();
        StringBuffer pointIds = new StringBuffer();
        for (int i = 0; i < jsonArr.size(); i++) {
            JSONObject jsonObject = jsonArr.getJSONObject(i);
            pointIds.append(i==0 ? "" :",").append(jsonObject.getString("monitorpointId"));
            feqs.append(i==0 ? "" :",").append("aa");
        }
        //获取频率
        JSONObject freqsjson = RestTemplateUtil.getDataByRestTemplate(getfreqsurl, restTemplate);
        JSONArray freqs_array = freqsjson.getJSONObject("data").getJSONArray("data").getJSONArray(0);
        String frequency = "";
        logger.info("record points："+pointIds.toString());
        for (int i = 0; i < freqs_array.size(); i++) {
            JSONObject freqJson = freqs_array.getJSONObject(i);
            frequency = freqJson.getString("frequencyValue");
            String recordUrl_ = recordurl + "&method=record"+"&frequencyValue="+feqs.toString().replaceAll("aa",frequency)+"&monitorpointId="+pointIds.toString()+"&isUnderWay=4&recordTimeLength=4";
            JSONObject retjson_ = RestTemplateUtil.getDataByRestTemplate(recordUrl_, restTemplate);
            //记录录制日志
            JSONArray jsons = retjson_.getJSONArray("data");
            for (int j = 0; j < jsons.size(); j++) {
                JSONObject recordResult = jsons.getJSONObject(j);
                Map<String, String> params = new HashMap<String, String>();
                params.put("bid","setTempRecord");
                params.put("frequency",recordResult.getString("frequencyValue"));
                params.put("monitorpointId",recordResult.getString("monitorpointId"));
                params.put("userid","admin");
                params.put("requesturl",recordUrl_);
                params.put("success",recordResult.getBoolean("success").toString());
                params.put("msg",recordResult.getString("msg"));
                params.put("flvurl","");
                RestTemplateUtil.postDataByRestTemplate(dealdataurl,params, restTemplate);
            }
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        logger.info("-------------Scheduled---------------autoRecordAllFreqs over");
    }

    public Boolean sendCMDtoDevice(String url) {
        Boolean isSuccess = false;
        JSONObject retjson = RestTemplateUtil.getDataByRestTemplate(url, restTemplate);
        if(retjson != null && retjson.getJSONArray("data") !=null && retjson.getJSONArray("data").getJSONObject(0) != null) {
            logger.info(retjson.getJSONArray("data").getJSONObject(0).toJSONString());
            isSuccess = retjson.getJSONArray("data").getJSONObject(0).getBoolean("success");
        }
        return isSuccess;
    }


}