package com.whyc.schedule;

import com.whyc.constant.YamlProperties;
import com.whyc.dto.*;
import com.whyc.factory.ThreadPoolExecutorFactory;
import com.whyc.pojo.db_power_rt.BattStationTemp;
import com.whyc.service.BattStationTempService;
import com.whyc.service.VideoService;
import com.whyc.util.DateUtil;
import com.whyc.util.FileUtil;
import com.whyc.util.HikTempUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.File;
import java.util.*;
import java.util.stream.Collectors;

@EnableScheduling
@Component
@Slf4j
public class BattStationTempScheduleService {

    @Autowired
    private BattStationTempService service;

    /**
     * 温度实时
     * */
    @Scheduled(fixedRate = 4000,initialDelay = 2000)
    public void startRecordAndCheck(){
        List<IpInfo> ipInfoList = HikTempUtil.ipInfoList;
        for (int i = 0; i < ipInfoList.size(); i++) {
            IpInfo ipInfo = ipInfoList.get(i);
            ThreadPoolExecutorFactory.getPoolExecutor().execute(()-> {
                String ip = ipInfo.getIp();
                String cameraId = ipInfo.getCameraId();

                Response response = HikTempUtil.getTempPoint(ip);
                if ((Boolean) response.getData()){
                    Map<String, Object> tempMap = (Map<String, Object>) response.getData2();
                    int pixelX = (int) tempMap.get("pixelX");
                    int pixelY = (int) tempMap.get("pixelY");
                    TempPoint minTempPoint = (TempPoint) tempMap.get("minTempPoint");
                    TempPoint maxTempPoint = (TempPoint) tempMap.get("maxTempPoint");

                    BattStationTemp battStationTemp = new BattStationTemp();
                    battStationTemp.setPixelX(pixelX);
                    battStationTemp.setPixelY(pixelY);
                    //最大温度点位
                    battStationTemp.setMaxTemp(maxTempPoint.getTemp());
                    List<Point> maxTempPoints = maxTempPoint.getPoints();
                    //对points,里面的x,y进行x*y的字符串转换,并将所有元素用逗号隔开
                    List<String> maxPointsStr = maxTempPoints.stream().map(item -> item.getX() + "*" + item.getY()).collect(Collectors.toList());
                    String maxPoints = String.join(",", maxPointsStr);
                    battStationTemp.setMaxTempPoint(maxPoints);
                    //最小温度点位
                    battStationTemp.setMinTemp(minTempPoint.getTemp());
                    List<Point> minTempPoints = minTempPoint.getPoints();
                    //对points,里面的x,y进行x*y的字符串转换,并将所有元素用逗号隔开
                    List<String> minPointsStr = minTempPoints.stream().map(item -> item.getX() + "*" + item.getY()).collect(Collectors.toList());
                    String minPoints = String.join(",", minPointsStr);
                    battStationTemp.setMinTempPoint(minPoints);

                    battStationTemp.setCameraId(cameraId);
                    Date date = new Date();
                    battStationTemp.setRecordTime(date);

                    service.addOrUpdate(battStationTemp);

                }else{
                    String msg = response.getMsg();
                    // TODO 报错日志记录
                }
            });
        }

    }


}