package com.ruoyi.activeMQ;

/**
 * 消息的消费者
 * @author Administrator
 */

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.aibrain.domain.AiAlarmInfo;
import com.ruoyi.aibrain.domain.AiCamera;
import com.ruoyi.aibrain.service.IAiAlarmInfoService;
import com.ruoyi.aibrain.service.IAiCameraService;
import com.ruoyi.common.config.RuoYiConfig;
import com.ruoyi.common.constant.Constants;
import com.ruoyi.framework.web.service.UserDetailsServiceImpl;
import com.ruoyi.framework.websocket.WebSocketServer;
import com.ruoyi.framework.websocket.WebSocketUsers;
import com.ruoyi.system.domain.AiRule;
import com.ruoyi.system.service.IAiRuleService;
import com.ruoyi.utils.Base64Util;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;

import javax.websocket.EncodeException;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.Writer;
import java.text.SimpleDateFormat;
import java.util.Date;


/**
 * Created by beyondLi
 * Date 2017/12/21
 * Desc 生产者rest .
 */
@Service
public class CustomerRest {

    private static final Logger log = LoggerFactory.getLogger(UserDetailsServiceImpl.class);

    @Autowired
    private IAiCameraService aiCameraService;

    @Autowired
    private IAiRuleService aiRuleService;

    @Autowired
    private IAiAlarmInfoService aiAlarmInfoService;

    public static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");


    /**
     * 监听 - 摄像头控制结果队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
//    @JmsListener(destination = "VideoRealTopic1921683036",containerFactory="jmsListenerContainerTopic")
//    public void VideoRealTopic(String info) {
//
//        log.info("CameraResultTopic接收到的json字符串{}",info);
//    }


    /**
     * 监听 - 摄像头控制结果队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    @JmsListener(destination = "CameraResultTopic",containerFactory="jmsListenerContainerTopic")
    public void cameraControlResultTopic(String info) {
        log.info("CameraResultTopic接收到的json字符串{}",info);
        JSONObject json = JSON.parseObject(info);
        long id = Long.parseLong(json.getString("cameraId"));//摄像头ID
        String success = json.getString("success");//是否成功 1连接中 2成功 3失败 4连接中断

        AiCamera camera = aiCameraService.selectAiCameraById(id);
        JSONObject result = new JSONObject();
        if(success.equals("1")){
            result.put("nowMessage",camera.getRegionName()+"AI识别设备"+camera.getName()+"连接成功。");
            camera.setStatus("1");//在线
        }else if(success.equals("2")){
            result.put("nowMessage",camera.getRegionName()+"AI识别设备"+camera.getName()+"连接失败。");
            camera.setStatus("0");//离线
        }else if(success.equals("3")){
            result.put("nowMessage",camera.getRegionName()+"AI识别设备"+camera.getName()+"连接中断。");
            camera.setStatus("0");//离线
        }
        camera.setUpdateBy("cameraControlResultTopic");
        aiCameraService.updateAiCameraStatus(camera);
//        WebSocketUsers.sendMessageToUsersByText(result.toJSONString());
    }

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    @JmsListener(destination = "AlarmResultTopic",containerFactory="jmsListenerContainerTopic")
    public void alarmInfoTopic(String info) {
        log.info("AlarmResultTopic接收到的json字符串{}",info);
        JSONObject json = JSON.parseObject(info);
        long cameraId = Long.parseLong(json.getString("cameraId"));//摄像头ID
        long ruleId = Long.parseLong(json.getString("ruleId"));//算法ID
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        String path = json.getString("path");//报警抓拍片段路径
        String newPath = path.substring(0, path.lastIndexOf("."))+"N.mp4";

        Date time = new Date(json.getLong("time"));//当前时间戳

        AiCamera camera = aiCameraService.selectAiCameraById(cameraId);
        AiRule rule = aiRuleService.selectAiRuleById(ruleId);
        toCompressFile(path,newPath);
        String picture = Base64Util.base64ToJpg(pictureBase64, camera.getCameraNum());
        String video = newPath.replaceAll(RuoYiConfig.getProfile(), Constants.RESOURCE_PREFIX);

        AiAlarmInfo alarm = new AiAlarmInfo();
        alarm.setCameraId(cameraId);
        alarm.setRegion(camera.getRegion());
        alarm.setRuleId(ruleId);
        alarm.setContent(rule.getContent());
        alarm.setSmallClass(rule.getRuleType());
        alarm.setAlarmTime(time);
        //10分钟内相同的报警不再新增
        AiAlarmInfo aiAlarmInfo = aiAlarmInfoService.selectAlarmInfo(alarm);
        if(aiAlarmInfo==null){
            alarm.setVideo(video);
            alarm.setPicture(picture);
            aiAlarmInfoService.insertAiAlarmInfo(alarm);
        }else{
            Date alarmTime = aiAlarmInfo.getAlarmTime();
            if((time.getTime()-alarmTime.getTime())>600000){
                //间隔超过10分钟
                alarm.setVideo(video);
                alarm.setPicture(picture);
                aiAlarmInfoService.insertAiAlarmInfo(alarm);
            }
        }
    }

    /*
     *  视频转码
     * @param convertFile  待转换的文件
     * @param targetFile  转换后的目标文件
     */
    private static  void toCompressFile(String convertFile,String targetFile){
        try{
            Runtime runtime = Runtime.getRuntime();
            runtime.exec("ffmpeg -version");
            //ffmpeg -i C:\mpeg4record\2022-10-15\192.168.1.64_01_0_20221015_120508_1.mp4 -vcodec libx264  E:\test\test.mp4
            String cutCmd="ffmpeg -i " + convertFile + " -vcodec libx264 "+ targetFile;
            System.out.println("cutCmd:"+cutCmd);
            runtime.exec(cutCmd);
            System.out.println("文件："+convertFile+" 正在转换中。。。");
        }catch(Exception e){
            e.printStackTrace();
            System.out.println("压缩文件出现异常："+e.getMessage());
        }
    }
    public static void main(String[] args) {

        toCompressFile("","");

    }

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683036",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683036(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683036{}");
        //WebSocketServer.sendPicMessage(pictureBase64, "1921683036");

        writeLogInFile(sdf.format(new Date())+"======="+pictureBase64);

    }*/

    public static void writeLogInFile(String content){
        File file = new File("/home/aiModel.txt");
        if(!file.exists()){
            try {
                file.createNewFile();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        Writer writer = null;
        StringBuilder outputString = new StringBuilder();
        try {
            outputString.append(content+"\r\n");
            writer = new FileWriter(file,true);
            writer.write(outputString.toString());
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                writer.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }


    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683041",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683041(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683041开始{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683041");
        log.info("VideoRealTopic1921683041结束{}");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683042",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683042(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683042{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683042");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683043",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683043(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683043{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683043");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683044",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683044(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683044{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683044");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683045",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683045(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683045{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683045");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683046",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683046(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683046{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683046");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683047",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683047(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683047{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683047");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683048",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683048(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683048{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683048");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683049",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683049(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683049{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683049");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683050",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683050(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683050{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683050");
    }*/

    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683051",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683051(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683051{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683051");
    }
*/
    /**
     * 监听 - 报警信息队列
     * destination：监听的队列名称
     * containerFactory:监听模式
     *      jmsListenerContainerFactory P2P模式
     *      jmsListenerContainerTopic 订阅模式
     */
    /*@JmsListener(destination = "VideoRealTopic1921683052",containerFactory="jmsListenerContainerTopic")
    public void VideoRealTopic1921683052(String info) throws EncodeException, IOException {
        JSONObject json = JSON.parseObject(info);
        String pictureBase64 = json.getString("pictureBase64");//报警现场图片
        log.info("VideoRealTopic1921683052{}");
        WebSocketServer.sendPicMessage(pictureBase64, "1921683052");
    }*/

}