package com.fzzy.igds.camera.impl;

import com.alibaba.fastjson.JSONObject;
import com.fzzy.igds.camera.AbstractApiCameraService;
import com.fzzy.igds.camera.data.*;
import com.fzzy.igds.camera.data.ydqly.YdQlyCamera;
import com.fzzy.igds.camera.data.ydqly.YdQlyDto;
import com.fzzy.igds.camera.data.ydqly.YdQlyNode;
import com.fzzy.igds.camera.data.ydqly.YdQlyResp;
import com.fzzy.igds.constant.CameraPlayType;
import com.fzzy.igds.constant.Constant;
import com.fzzy.igds.constant.RedisConst;
import com.fzzy.igds.domain.Camera;
import com.fzzy.igds.domain.CameraMedia;
import com.fzzy.igds.service.CameraMediaService;
import com.fzzy.igds.service.SecCameraService;
import com.fzzy.igds.utils.ContextUtil;
import com.fzzy.igds.utils.HttpUtils;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.*;
import java.util.concurrent.TimeUnit;
import org.apache.commons.codec.binary.Hex;
import org.apache.commons.codec.digest.DigestUtils;
import java.security.*;
import java.security.spec.PKCS8EncodedKeySpec;

/**
 * @Desc 移动千里眼播放
 * @Author CZT
 * @Date 2026/01/04 16:09
 */
@Slf4j
@Component
public class ApiPlayYdQlyService extends AbstractApiCameraService {

    /**
     * 获取accessToken接口路径
     */
    private static final String URL_ACCESS_TOKEN = "https://open.qly.cmviot.cn/v3/open/api/token";
    private static final String URL_PLAY_LIVE = "https://open.qly.cmviot.cn/v3/open/api/websdk/live";
    private static final String URL_CAMERA_LIST = "https://open.qly.cmviot.cn/v3/open/api/node/tree";

    @Resource
    private CameraMediaService cameraMediaService;
    @Resource
    private SecCameraService cameraService;
    @Resource
    private RedisCache redisCache;

    @Override
    public String getType() {
        return CameraPlayType.PLAY_TYPE_YD_QLY.getCode();
    }

    @Override
    public ApiCameraResp getPlayAddr(ApiCameraData apiCameraDto) {

        if (StringUtils.isBlank(apiCameraDto.getCameraId())) {
            log.error("获取摄像头信息失败，监控ID为空！");
            return null;
        }

        if (StringUtils.isBlank(apiCameraDto.getDeptId())) {
            log.error("获取摄像头信息失败，库区编码为空！");
            return null;
        }

        //查询库区流媒体配置，获取库区节点
        CameraMedia cameraMedia = cameraMediaService.getByDeptId(apiCameraDto.getDeptId(), apiCameraDto.getCompanyId());
        if(null == cameraMedia || StringUtils.isBlank(cameraMedia.getYdStoreId())){
            log.error("获取摄像头信息失败，库区节点未配置！");
            return null;
        }

        //接口获取播放地址
        YdQlyResp resp = getPlayUrl(cameraMedia, apiCameraDto.getCameraId());

        if("11503".equals(resp.getResultCode()) || "11504".equals(resp.getResultCode())){
            delAccessToken();

            resp = getPlayUrl(cameraMedia, apiCameraDto.getCameraId());
        }

        if(!"000000".equals(resp.getResultCode())){
            return new ApiCameraResp(ApiCameraResp.CODE_ERROR, resp.getResultMsg());
        }
        YdQlyDto dto = JSONObject.parseObject(resp.getData(), YdQlyDto.class);
        if (null == dto || StringUtils.isBlank(dto.getUrl())) {
            return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "未获取到摄像头播放地址！");
        }

        return new ApiCameraResp(dto.getUrl());
    }

    @Override
    public List<Camera> searchCamera(ApiCameraData apiCameraDto) {

        if (StringUtils.isEmpty(apiCameraDto.getDeptId())) {
            log.error("获取摄像头信息失败，库区编码为空！");
            return null;
        }

        //查询库区流媒体配置，获取库区节点
        CameraMedia cameraMedia = cameraMediaService.getByDeptId(apiCameraDto.getDeptId(), apiCameraDto.getCompanyId());
        if(null == cameraMedia || StringUtils.isEmpty(cameraMedia.getYdStoreId())){
            log.error("同步失败，库区节点未配置，请到库区配置->流媒体配置！");
            return null;
        }

        //接口获取播放地址
        YdQlyResp resp = getCameraList(cameraMedia);

        if("11503".equals(resp.getResultCode()) || "11504".equals(resp.getResultCode())){
            delAccessToken();

            resp = getCameraList(cameraMedia);
        }

        if(!"000000".equals(resp.getResultCode())){
            return null;
        }

        YdQlyDto ydQlyDto = JSONObject.parseObject(resp.getData(), YdQlyDto.class);

        if(null== ydQlyDto || null == ydQlyDto.getDevice()){
            log.error("获取摄像头信息失败，库区节点未配置！");
            return null;
        }

        //持久化
        List<Camera> listCamera = new ArrayList<>();
        Camera camera;
        for (YdQlyCamera dto : ydQlyDto.getDevice()) {
            camera = new Camera();
            camera.setId(dto.getDeviceId());
            camera.setCompanyId(cameraMedia.getCompanyId());
            camera.setDeptId(cameraMedia.getDeptId());
            camera.setSn(dto.getDeviceId());
            camera.setName(dto.getDeviceName());
            camera.setType("01");
            camera.setPlayType(CameraPlayType.PLAY_TYPE_YD_QLY.getCode());
            cameraService.pullUpdateCamera(camera);
        }
        return listCamera;
    }

    /**
     * 清除token
     */
    private void delAccessToken() {
        //请清除token
        String key = RedisConst.buildKey(ContextUtil.getCompanyId(), Constant.KEY_ACCESS_TOKEN_YD_QLY);
        redisCache.deleteObject(key);
    }

    /**
     * 获取accessToken
     *
     * @param cameraMedia
     * @return
     */
    private String getAccessToken(CameraMedia cameraMedia) {
        //默认先从缓存获取
        String key = RedisConst.buildKey(ContextUtil.getCompanyId(), Constant.KEY_ACCESS_TOKEN_YD_QLY);
        String accessToken = (String) redisCache.getCacheObject(key);

        //若缓存获取为空，则通过接口请求获取
        if (null == accessToken) {
            String result = getAccessTokenApi(cameraMedia);

            YdQlyDto dto = JSONObject.parseObject(result, YdQlyDto.class);
            if (null == dto) {
                return null;
            }
            accessToken = dto.getToken();
            Integer expiresIn = dto.getExpires_in();

            //将token存入缓存，默认7天
            redisCache.setCacheObject(key, accessToken, 7*60*24, TimeUnit.MINUTES);
        }

        return accessToken;
    }

    /**
     * 接口获取授权accessToken
     * @param cameraMedia
     * @return
     */
    private String getAccessTokenApi(CameraMedia cameraMedia) {
        try {
            String timestamp = String.valueOf(System.currentTimeMillis());
            String sig =  Hex.encodeHexString(MessageDigest.getInstance("MD5").digest(StringUtils.getBytes(cameraMedia.getYdAppKey()+cameraMedia.getYdAppSecret(),"UTF-8")));
            JSONObject requestBody = new JSONObject();
            requestBody.put("operatorType", 1);
            requestBody.put("sig", sig);
            String requestBodyStr = requestBody.toString();

            // 2. 计算请求体MD5
            String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));

            // 3. 构建签名字符串
            LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();
            herderParams.put("appid", cameraMedia.getYdAppKey());
            herderParams.put("md5", md5);
            herderParams.put("timestamp", timestamp);
            herderParams.put("version", "1.0.0");
            String jsonString = JSONObject.toJSONString(herderParams);

            // 4. RSA签名
            byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
            PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
            PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);

            Signature signature = Signature.getInstance("SHA1WithRSA");
            signature.initSign(priKey);
            signature.update(jsonString.getBytes("UTF-8"));
            String signatureString = Base64.getEncoder().encodeToString(signature.sign());

            herderParams.put("signature", signatureString);
            herderParams.put("content-type", "application/json");

            // 5. 发送请求
            String response = HttpUtils.doPost(URL_ACCESS_TOKEN, herderParams, requestBodyStr);

            YdQlyResp ydQlyResp = JSONObject.parseObject(response, YdQlyResp.class);
            if(!"000000".equals(ydQlyResp.getResultCode())){
                return null;
            }
            return ydQlyResp.getData();
        } catch (Exception e) {
            log.error("-----获取身份认证异常-----，原因={}", e.toString());
            return null;
        }
    }

    /**
     * 接口获取播放地址
     * @param cameraMedia
     * @param cameraId
     * @return
     */
    private YdQlyResp getPlayUrl(CameraMedia cameraMedia, String cameraId) {
        try {

            String timestamp = String.valueOf(System.currentTimeMillis());

            JSONObject requestBody = new JSONObject();
            requestBody.put("deviceId", cameraId);

            String requestBodyStr = requestBody.toString();

            // 2. 计算请求体MD5
            String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));

            // 3. 构建签名字符串
            LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();

            herderParams.put("appid", cameraMedia.getYdAppKey());
            herderParams.put("md5", md5);
            herderParams.put("timestamp", timestamp);
            herderParams.put("token", getAccessToken(cameraMedia));
            herderParams.put("version", "1.0.0");
            String jsonString = JSONObject.toJSONString(herderParams);

            // 4. RSA签名
            byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
            PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
            PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);

            Signature signature = Signature.getInstance("SHA1WithRSA");
            signature.initSign(priKey);
            signature.update(jsonString.getBytes("UTF-8"));
            String signatureString = Base64.getEncoder().encodeToString(signature.sign());

            herderParams.put("signature", signatureString);
            herderParams.put("content-type", "application/json");

            // 5. 发送请求
            String response = HttpUtils.doPost(URL_PLAY_LIVE, herderParams, requestBodyStr);

            YdQlyResp ydQlyResp = JSONObject.parseObject(response, YdQlyResp.class);

            return ydQlyResp;
        } catch (Exception e) {
            return null;
        }
    }

    /**
     * 接口获取播放地址
     * @param cameraMedia
     * @return
     */
    private YdQlyResp getCameraList(CameraMedia cameraMedia) {
        try {

            String timestamp = String.valueOf(System.currentTimeMillis());

            JSONObject requestBody = new JSONObject();
            requestBody.put("queryType", 0);
            requestBody.put("page", 1);
            requestBody.put("pageSize", 100);
            requestBody.put("nodeId", cameraMedia.getYdStoreId());

            String requestBodyStr = requestBody.toString();

            // 2. 计算请求体MD5
            String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));

            // 3. 构建签名字符串
            LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();

            herderParams.put("appid", cameraMedia.getYdAppKey());
            herderParams.put("md5", md5);
            herderParams.put("timestamp", timestamp);
            herderParams.put("token", getAccessToken(cameraMedia));
            herderParams.put("version", "1.0.0");
            String jsonString = JSONObject.toJSONString(herderParams);

            // 4. RSA签名
            byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
            PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
            PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);

            Signature signature = Signature.getInstance("SHA1WithRSA");
            signature.initSign(priKey);
            signature.update(jsonString.getBytes("UTF-8"));
            String signatureString = Base64.getEncoder().encodeToString(signature.sign());

            herderParams.put("signature", signatureString);
            herderParams.put("content-type", "application/json");

            // 5. 发送请求
            String response = HttpUtils.doPost(URL_CAMERA_LIST, herderParams, requestBodyStr);

            YdQlyResp ydQlyResp = JSONObject.parseObject(response, YdQlyResp.class);
            return ydQlyResp;
        } catch (Exception e) {
            return null;
        }
    }

    /**
     * 获取监控所在节点编码
     * @param cameraMedia
     * @return
     */
    public List<YdQlyNode> getNodeId(CameraMedia cameraMedia) {
        try {

            String timestamp = String.valueOf(System.currentTimeMillis());

            JSONObject requestBody = new JSONObject();
            requestBody.put("queryType", 0);
            if(StringUtils.isNotBlank(cameraMedia.getYdStoreId())){
                requestBody.put("nodeId", cameraMedia.getYdStoreId());
            }

            String requestBodyStr = requestBody.toString();

            // 2. 计算请求体MD5
            String md5 = DigestUtils.md5Hex(String.valueOf(requestBody));

            // 3. 构建签名字符串
            LinkedHashMap<String, String> herderParams = new LinkedHashMap<>();

            herderParams.put("appid", cameraMedia.getYdAppKey());
            herderParams.put("md5", md5);
            herderParams.put("timestamp", timestamp);
            herderParams.put("token", getAccessToken(cameraMedia));
            herderParams.put("version", "1.0.0");
            String jsonString = JSONObject.toJSONString(herderParams);

            // 4. RSA签名
            byte[] keyBytes = Base64.getDecoder().decode(cameraMedia.getYdRsa());
            PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(keyBytes);
            PrivateKey priKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);

            Signature signature = Signature.getInstance("SHA1WithRSA");
            signature.initSign(priKey);
            signature.update(jsonString.getBytes("UTF-8"));
            String signatureString = Base64.getEncoder().encodeToString(signature.sign());

            herderParams.put("signature", signatureString);
            herderParams.put("content-type", "application/json");

            // 5. 发送请求
            String response = HttpUtils.doPost(URL_CAMERA_LIST, herderParams, requestBodyStr);

            YdQlyResp resp = JSONObject.parseObject(response, YdQlyResp.class);

            if(!"000000".equals(resp.getResultCode())){
                return null;
            }

            YdQlyDto ydQlyDto = JSONObject.parseObject(resp.getData(), YdQlyDto.class);
            if(null == ydQlyDto || null == ydQlyDto.getNode() || ydQlyDto.getNode().isEmpty()){
                return null;
            }
            return ydQlyDto.getNode();
        } catch (Exception e) {
            return null;
        }
    }

    /**
     * 获取所有节点
     * @param cameraMedia
     */
    public void getAllNodeId(CameraMedia cameraMedia) {

        List<YdQlyNode> nodeList = this.getNodeId(cameraMedia);
        if(null != nodeList && !nodeList.isEmpty()){
            for (YdQlyNode node : nodeList) {
                if(node.getHasChild() == 1){
                    cameraMedia.setYdStoreId(node.getNodeId());
                    this.getAllNodeId(cameraMedia);
                }else {
                    ContextUtil.nodeList.add(node);
                }
            }
        }
    }
}