package com.cloud.retrieve.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.cloud.common.utils.RestTemplateUtil;
import com.cloud.model.common.Result;
import com.cloud.retrieve.dao.CulOrDevDao;
import com.cloud.retrieve.service.AnalyDevService;
import com.cloud.retrieve.service.DeviceService;
import com.cloud.retrieve.utils.EnumStr;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;

import java.io.UnsupportedEncodingException;
import java.util.Map;

@Service
@Slf4j
public class AnalyDevServiceImpl implements AnalyDevService {

    @Autowired
    private EnumStr enumStr;
    @Autowired
    private RestTemplateUtil restTemplateUtil;
    @Autowired
    private CulOrDevDao culOrDevDao;
    @Autowired
    private DeviceService deviceService;
    @Override
    public JSONObject getVideo(String videoNum, String picDate, String videoIp, String indeviceid,String imgKey) {

        String reqIp = null;
        Integer videoPort = 80;
        String videoPublicIp = "";
        //    nodeIp,   videoPublicPort
        if (StringUtils.isNotEmpty(videoNum)) {
            //  Map<String, Object> byIndeviceId = culOrDevDao.findByIndeviceId(indeviceid);

            JSONObject nodeJson = getNodeByVideoNum(videoNum);
            if(nodeJson !=null){
                reqIp = nodeJson.getString("nodeIp");
                videoPort = nodeJson.getInteger("videoPort");
                videoPublicIp = nodeJson.getString("videoPublicIp");
            }
        } else {
            reqIp = videoIp;
        }
        if (imgKey == null) {
            imgKey = "";
        }   //  兼容旧数据
        String bsUrl = "http://" + reqIp + ":" + enumStr.getCServerPort();
        String esBaseUrl = enumStr.getCServerGetVideoUrl();
        String reqJson = "{\"videoNum\": \"" + videoNum +
                "\",\"picDate\": \"" + picDate + "\",\"imgKey\": \"" + imgKey + "\"}";
        JSONObject dataBaseParams = JSONObject.parseObject(reqJson);
        String respData = restTemplateUtil.post(bsUrl + esBaseUrl,
                dataBaseParams, MediaType.APPLICATION_JSON_UTF8, String.class, false);
        JSONObject cResult = new JSONObject();
        if (respData != null) {
            try {
                respData = new String(respData.getBytes("ISO-8859-1"), "utf-8");
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
            cResult = JSONObject.parseObject(respData);
            if (StringUtils.isNotEmpty(videoPublicIp) && cResult.getString("file_path") != null) {
                cResult.put("filepath", "http://" + videoPublicIp + ":" + videoPort + "/videosource" + cResult.getString("file_path").split("/cut")[1]);
            }
        }
        return cResult;
    }

    @Override
    public JSONObject getBigPic(String videoNum, String picDate, String videoIp, String indeviceid, String imgKey) {

        // 获取 服务ip
        String reqIp = null;
        Integer videoPort = 80;
        //    publicIp,   videoPublicPort
        if (StringUtils.isNotEmpty(videoNum)) {
//            Map<String, Object> byIndeviceId = culOrDevDao.findByIndeviceId(indeviceid);
            JSONObject nodeJson = getNodeByVideoNum(videoNum);
            if(nodeJson !=null){
                reqIp = nodeJson.getString("nodeIp");
                videoPort = nodeJson.getInteger("videoPort");
            }
//            log.info("数据库查询nodeIp:" + reqIp + "videoPort:" + videoPort);
            if (videoPort == null) videoPort = 80;
        } else {
            reqIp = videoIp;
        }
        if (imgKey == null) {
            imgKey = "";
        }   //  兼容旧数据
        log.info("reqIp:" + reqIp);
        String bsUrl = "http://" + reqIp + ":" + enumStr.getCServerPort();
        String esBaseUrl = enumStr.getCServerGetBigPicUrl();
        String reqJson = "{\"videoNum\": \"" + videoNum +
                "\",\"picDate\": \"" + picDate + "\",\"imgKey\": \"" + imgKey + "\"}";
        JSONObject dataBaseParams = JSONObject.parseObject(reqJson);
//        log.info("查看大图：reqJson:" + dataBaseParams + ",请求地址：" + bsUrl + esBaseUrl);
        String respData = restTemplateUtil.post(bsUrl + esBaseUrl,
                dataBaseParams, MediaType.APPLICATION_JSON_UTF8, String.class, false);
        JSONObject cResult = new JSONObject();
        if (respData != null) {
//            log.info("查看大图c返回：" + respData);
            cResult = JSONObject.parseObject(respData);
        }
        return cResult;
    }

    /**
     * 根据摄像机编号获取节点信息
     * @param videoNum
     * @return
     */
    private JSONObject getNodeByVideoNum(String videoNum){
        JSONObject jsonResult = null;
        Result result = deviceService.getNodeByDeviceId(videoNum);
        if (result.isSuccess()) {
            JSONObject data = (JSONObject) result.getData();
            JSONObject node = data.getJSONObject("node");
            if (node == null) {
                throw new RuntimeException("设备(摄像机)查找不到所在节点信息。");
            }
            jsonResult = new JSONObject();
            jsonResult.put("nodeIp",node.getString("nodeIp"));
            jsonResult.put("videoPort", node.getInteger("videoPublicPort"));
            jsonResult.put("videoPublicIp",node.getString("publicIp"));
        }
        return jsonResult;
    }

    @Override
    public Result getDevSnapshot(String devId) {
        return deviceService.getDevSnapshot(devId);
    }

    public Map<String, Object> findByIndeviceId(String devId) {
        return deviceService.getNodeByDevId(devId);
    }

}