package com.ruoyi.task;

import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.aibrain.domain.AiAlarmInfo;
import com.ruoyi.aibrain.service.IAiAlarmInfoService;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.Threads;
import com.ruoyi.framework.config.ActiveManager;
import com.ruoyi.framework.websocket.WebSocketUsers;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * 定时任务调度测试
 *
 * @author ruoyi
 */
@EnableScheduling
@Component("aiBrainTask")
public class AiBrainTask {

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

    @Autowired
    private static ActiveManager activeManager;

    @Autowired
    private IAiAlarmInfoService aiAlarmInfoService;

    public void indexWebSocket() {
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        AiAlarmInfo aiAlarmInfo = new AiAlarmInfo();
        Map<String, Object> params = aiAlarmInfo.getParams();
        params.put("beginTime", format.format(DateUtils.getFistDayInYear(Calendar.getInstance().get(Calendar.YEAR))));
        params.put("endTime",format.format(new Date()));
        aiAlarmInfo.setParams(params);
        int alarmSanWei = aiAlarmInfoService.countSanWeiAlarm(aiAlarmInfo);//三违
        int alarmYinHuan = aiAlarmInfoService.countYinHuanAlarm(aiAlarmInfo);//隐患
        int alarmAll = aiAlarmInfoService.countAllAlarm(aiAlarmInfo);//智能识别仪
        int alarmYear = aiAlarmInfoService.countAlarmInYear();//年度报警
        int alarmMonth = aiAlarmInfoService.countAlarmInMonth();//月度报警
        List<Map<String,Object>> alarmTop = aiAlarmInfoService.selectCountAlarmByRegion();//本年区域报警Top排序
        List<Map<String,Object>> alarmSmall = aiAlarmInfoService.selectCountAlarmBySmall();//本年报警类型统计
        List<AiAlarmInfo> aiAlarmInfos = aiAlarmInfoService.selectAlarmInfoNew();//实时报警：未处理的最新十条

        JSONObject indexJson = new JSONObject();
        indexJson.put("alarmSanWei",alarmSanWei);
        indexJson.put("alarmYinHuan",alarmYinHuan);
        indexJson.put("alarmAll",alarmAll);
        indexJson.put("alarmYear",alarmYear);
        indexJson.put("alarmMonth",alarmMonth);
        indexJson.put("alarmTop",alarmTop);
        indexJson.put("alarmSmall",alarmSmall);
        indexJson.put("aiAlarmInfos",aiAlarmInfos);
        WebSocketUsers.sendMessageToUsersByText(indexJson.toJSONString());
    }

//    /**
//     * 启动AI识别设备
//     */
//    @Scheduled(fixedDelay = 50)
//    public static void startCamera1() {
//        activeManager = SpringUtils.getBean(ActiveManager.class);
//        ActiveMQTopic videoRealTopic19216820271 = new ActiveMQTopic("VideoRealTopic1921683036");//P2P模式单个消费者
//        Point point=new Point();
//        try {
//            String s = Base64Util.fileToBase64("C:\\Users\\Administrator\\Desktop\\a.png");
//            point.setCameraId("1");
//            point.setName("大倾角皮带机头");
//            point.setPictureBase64(s);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        activeManager.send(videoRealTopic19216820271, JSON.toJSONString(point));
////        logger.info("cameraControlQueue队列："+JSON.toJSONString(point));
//    }
//
//    /**
//     * 启动AI识别设备
//     */
//    @Scheduled(fixedDelay = 50)
//    public static void startCamera2() {
//        activeManager = SpringUtils.getBean(ActiveManager.class);
//        ActiveMQTopic videoRealTopic19216820271 = new ActiveMQTopic("VideoRealTopic1921683036");//P2P模式单个消费者
//        Point point=new Point();
//        try {
//            String s = Base64Util.fileToBase64("C:\\Users\\Administrator\\Desktop\\b.png");
//            point.setCameraId("1");
//            point.setName("大倾角皮带机头");
//            point.setPictureBase64(s);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        activeManager.send(videoRealTopic19216820271, JSON.toJSONString(point));
////        logger.info("cameraControlQueue队列："+JSON.toJSONString(point));
//    }
//
//    /**
//     * 启动AI识别设备
//     */
//    @Scheduled(fixedDelay = 50)
//    public static void startCamera3() {
//        activeManager = SpringUtils.getBean(ActiveManager.class);
//        ActiveMQTopic videoRealTopic19216820271 = new ActiveMQTopic("VideoRealTopic1921683041");//P2P模式单个消费者
//        Point point=new Point();
//        try {
//            String s = Base64Util.fileToBase64("C:\\Users\\Administrator\\Desktop\\1.png");
//            point.setCameraId("2");
//            point.setName("大倾角皮带机尾");
//            point.setPictureBase64(s);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        activeManager.send(videoRealTopic19216820271, JSON.toJSONString(point));
////        logger.info("cameraControlQueue队列："+JSON.toJSONString(point));
//    }
//
//    /**
//     * 启动AI识别设备
//     */
//    @Scheduled(fixedDelay = 50)
//    public static void startCamera4() {
//        activeManager = SpringUtils.getBean(ActiveManager.class);
//        ActiveMQTopic videoRealTopic19216820271 = new ActiveMQTopic("VideoRealTopic1921683041");//P2P模式单个消费者
//        Point point=new Point();
//        try {
//            String s = Base64Util.fileToBase64("C:\\Users\\Administrator\\Desktop\\2.png");
//            point.setCameraId("2");
//            point.setName("大倾角皮带机尾");
//            point.setPictureBase64(s);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        activeManager.send(videoRealTopic19216820271, JSON.toJSONString(point));
////        logger.info("cameraControlQueue队列："+JSON.toJSONString(point));
//    }


}