package com.thhy.materials.modules.biz.helmet.scheduled;

import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.util.StringUtil;
import com.thhy.materials.modules.biz.helmet.entity.*;
import com.thhy.materials.modules.biz.helmet.service.HelmetService;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.logging.SimpleFormatter;
import java.util.stream.Collectors;

@Component
public class PictureScheduled {


    @Resource
    private HelmetService helmetService;
    //图片记录
    @Scheduled(fixedRate = 2000000) // 每隔3秒执行一次任务
    public void task() {
        String token = token();
        List<THelmetDevice> helmetDevices = helmetService.helmetServiceList();
        System.out.println(helmetDevices);

        for (THelmetDevice device : helmetDevices){
            RestTemplate restTemplate = new RestTemplate();
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity = new HttpEntity<>(null, headers);
            String s = restTemplate.postForObject("https://caps.runde.pro/api/index.php?ctl=report&act=get_user_image&user_id="+device.getUserId()+"&p=1"+"&token="+token, mapHttpEntity, String.class);
            JSONObject jsonObject = JSONObject.parseObject(s);
//            System.out.println("----------------------------------------------");
//            System.out.println("----------------------------------------------");
//            System.out.println("----------------------------------------------");
//            System.out.println("----------------------------------------------");
//            System.out.println("----------------------------------------------");
//            System.out.println(jsonObject);
            if(jsonObject.get("status").toString().equals("true")){
                //图片值
                List<Map<String,Object>> data = (List<Map<String, Object>>) jsonObject.get("data");
//                System.out.println("----------map------------");
//                System.out.println(data);

                for (Integer i =data.size()-1;i!=0;i--){
                    Integer iId = helmetService.userIdIid(Integer.valueOf(data.get(i).get("user_id").toString()));
                    if((iId!=null && Integer.valueOf(data.get(i).get("i_id").toString())>iId)||iId==null){
                        THelmetPicture tHelmetPicture = new THelmetPicture();
                        tHelmetPicture.setUserId(Integer.valueOf(data.get(i).get("user_id").toString()));
                        tHelmetPicture.setIId(Integer.valueOf(data.get(i).get("i_id").toString()));
                        tHelmetPicture.setCreTime(data.get(i).get("time").toString());
                        tHelmetPicture.setXPoint(data.get(i).get("x_point").toString());
                        tHelmetPicture.setYPoint(data.get(i).get("y_point").toString());
                        tHelmetPicture.setImageUrl(data.get(i).get("image_url").toString());
                        Date date = new Date(Long.valueOf(data.get(i).get("time").toString()+"000"));
                        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                        tHelmetPicture.setSmTime(sdf.format(date));
                        helmetService.helmetPictureInsert(tHelmetPicture);
                    }
                }
            }
        }
    }


    //报警记录
    @Scheduled(fixedRate = 3000000) // 每隔3秒执行一次任务
    public void taskReport() {
        String token = token();
       // System.out.println(token);
        List<THelmetDevice> helmetDevices = helmetService.helmetServiceList();
        for (THelmetDevice device : helmetDevices){
            RestTemplate restTemplate = new RestTemplate();
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity = new HttpEntity<>(null, headers);
            String s = restTemplate.postForObject("https://caps.runde.pro/api/index.php?ctl=task&act=get_sos_list&admin_id=8630&user_id="+device.getUserId()+"&p=1"+"&token="+token, mapHttpEntity, String.class);
            JSONObject jsonObject = JSONObject.parseObject(s);
//            System.out.println("-----------------------------------报警--------------------------");
//            System.out.println(jsonObject);

            List<Map<String,Object>> data = (List<Map<String, Object>>) jsonObject.get("data");
            if(data.size()>0){
                for(int i=data.size()-1;i>0;i--){
                    Integer sId = helmetService.userIdReport(Integer.valueOf(data.get(i).get("user_id").toString()));
                    if((sId!=null && Integer.valueOf(data.get(i).get("s_id").toString())>sId)||sId==null){
                        THelmetReport tHelmetReport = new THelmetReport();
                        tHelmetReport.setSId(Integer.valueOf(data.get(i).get("s_id").toString()));
                        tHelmetReport.setUserId(Integer.valueOf(data.get(i).get("user_id").toString()));
                        tHelmetReport.setUserName(data.get(i).get("user_name").toString());
                        tHelmetReport.setDeviceId(data.get(i).get("device_id").toString());
                        tHelmetReport.setXPoint(data.get(i).get("x_point").toString());
                        tHelmetReport.setYPoint(data.get(i).get("y_point").toString());
                        tHelmetReport.setCTime(data.get(i).get("c_time").toString());
                        tHelmetReport.setSosType(data.get(i).get("sos_type").toString());
                        tHelmetReport.setMsg(data.get(i).get("msg").toString());
                        //tHelmetReport.setImgurl(data.get(i).get("msg").toString());
                        tHelmetReport.setMobile(data.get(i).get("mobile").toString());
                        Date date = new Date(Long.valueOf(data.get(i).get("c_time").toString()+"000"));
                        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                        tHelmetReport.setSmTime(sdf.format(date));
                        helmetService.helmetReportInsert(tHelmetReport);
                    }
                }
            }
        }
    }

    //轨迹记录
    @Scheduled(fixedRate = 3000000) // 每隔3秒执行一次任务
    public void taskTrajectory() throws ParseException {
        String token = token();
        //System.out.println(token);
        List<THelmetDevice> helmetDevices = helmetService.helmetServiceList();

        Date date = new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
        SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd 23:59:59");
        String format = simpleDateFormat.format(date);
        String format1 = simpleDateFormat1.format(date);
        Date str = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(format);
        Date end = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(format1);
        long time = str.getTime();
        long time1 = end.getTime();
        System.out.println();
        String strTime = String.valueOf(time).substring(0, 10);
        String endTime = String.valueOf(time1).substring(0, 10);

        for(THelmetDevice helmetDevice : helmetDevices){
            RestTemplate restTemplate = new RestTemplate();
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity = new HttpEntity<>(null, headers);
            String s = restTemplate.postForObject("https://caps.runde.pro/api/index.php?ctl=device&act=get_devices_online_time_days&admin_id=8630&user_id="+helmetDevice.getUserId()+"&stime="+strTime+"&etime="+endTime+"&token="+token, mapHttpEntity, String.class);
            JSONObject jsonObject = JSONObject.parseObject(s);
            //Object data = jsonObject.get("data");
//            System.out.println("-----------轨迹回放--------------");
//            System.out.println("-----------轨迹回放--------------");
//            System.out.println("-----------轨迹回放--------------");
//            System.out.println("-----------轨迹回放--------------");
//            System.out.println("-----------轨迹回放--------------");
//            System.out.println(jsonObject);
            Object date1 = jsonObject.get("data");
            JSONObject jsonObject1 = JSONObject.parseObject(date1.toString());
            List<Map<String,Object>> list = (List<Map<String, Object>>) jsonObject1.get("list");
            for (Map<String,Object> map : list){
                THelmetTrajectory helmetTrajectory = helmetService.trajectory(helmetDevice.getUserId(),map.get("ctime").toString());
                if(helmetTrajectory==null){
                    THelmetTrajectory helmetTrajectory1 = new THelmetTrajectory();
                    helmetTrajectory1.setCtime(map.get("ctime").toString());
                    helmetTrajectory1.setUserId(helmetDevice.getUserId());
                    helmetTrajectory1.setLtime(map.get("ltime").toString());
                    helmetTrajectory1.setSec(map.get("sec").toString());
                    helmetService.helmetTrajectoryInsert(helmetTrajectory1);
                }else {
                    helmetTrajectory.setLtime(map.get("ltime").toString());
                    helmetTrajectory.setSec(map.get("sec").toString());
                    helmetService.helmetTrajectoryUpdate(helmetTrajectory);
                }
            }


            RestTemplate restTemplate1 = new RestTemplate();
            HttpHeaders headers1 = new HttpHeaders();
            headers1.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity1 = new HttpEntity<>(null, headers1);
            String s1 = restTemplate1.postForObject("https://caps.runde.pro/api/index.php?ctl=location&act=get_user_path_web&admin_id=8630&user_id="+helmetDevice.getUserId()+"&start="+strTime+"&end="+endTime+"&token="+token, mapHttpEntity1, String.class);
            JSONObject jsonObject11 = JSONObject.parseObject(s1);
            System.out.println("--------------------------轨迹 坐标点----------------------");
            System.out.println("--------------------------轨迹 坐标点----------------------");
            System.out.println("--------------------------轨迹 坐标点----------------------");
            System.out.println("--------------------------轨迹 坐标点----------------------");
            System.out.println("--------------------------轨迹 坐标点----------------------");
            System.out.println("--------------------------轨迹 坐标点----------------------");
            System.out.println(jsonObject11);
            if(jsonObject11.get("status").toString().equals("true")){
                List<Map<String,Object>> data = (List<Map<String, Object>>) jsonObject11.get("data");
                if(data.size()>0){
                    for (Map<String,Object> map :data){
                        String times = helmetService.helmetMotion(helmetDevice.getUserId());
                        if(StringUtil.isEmpty(times) || (!StringUtil.isEmpty(times)&& Integer.valueOf(map.get("time").toString())>Integer.valueOf(times))){
                            THelmetMotion tHelmetMotion = new THelmetMotion();
                            tHelmetMotion.setUserId(helmetDevice.getUserId());
                            tHelmetMotion.setXPoint(map.get("x_point").toString());
                            tHelmetMotion.setYPoint(map.get("y_point").toString());
                            tHelmetMotion.setTimes(map.get("time").toString());
                            tHelmetMotion.setCAngle(map.get("c_angle").toString());
                            tHelmetMotion.setCSpeed(map.get("c_speed").toString());
                            tHelmetMotion.setCTrust(map.get("c_trust").toString());
                            Date date2 = new Date(Long.valueOf(map.get("time").toString()+"000"));
                            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                            tHelmetMotion.setSmTime(sdf.format(date2));
                            helmetService.helmetMotionInsert(tHelmetMotion);
                        }
                    }
                }
            }
        }

    }







    public String token(){
            //用户token
            RestTemplate restTemplate = new RestTemplate();
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity = new HttpEntity<>(null, headers);
            String s = restTemplate.postForObject("https://caps.runde.pro/api/index.php?ctl=tool&act=get_pkey&user_name=NJBBT8204&pwd=Bbt162534@", mapHttpEntity, String.class);
            JSONObject jsonObject = JSONObject.parseObject(s);
            Object data = jsonObject.get("data");

            RestTemplate restTemplate1 = new RestTemplate();
            HttpHeaders headers1 = new HttpHeaders();
            headers1.setContentType(MediaType.valueOf(MediaType.APPLICATION_FORM_URLENCODED_VALUE));
            HttpEntity<Map<String, Object>> mapHttpEntity1 = new HttpEntity<>(null, headers1);
            String s1 = restTemplate1.postForObject("https://caps.runde.pro/api/index.php?ctl=tool&act=get_token&user_name=NJBBT8204&pkey="+data.toString(), mapHttpEntity1, String.class);
            JSONObject jsonObject1 = JSONObject.parseObject(s1);
            Object data1 = jsonObject1.get("token");
            return  data1.toString();
        }





}