package com.ld.igds.protocol.hikmedia;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.camera.CameraUtil;
import com.ld.igds.camera.data.ApiCameraData;
import com.ld.igds.camera.data.ApiCameraResp;
import com.ld.igds.camera.data.ApiSnapReq;
import com.ld.igds.data.ConfigHikMedia;
import com.ld.igds.data.HikMediaProp;
import com.ld.igds.protocol.hikmedia.data.*;
import com.ld.igds.protocol.snap.SnapPluginService;
import com.ld.igds.sec.dto.SecCameraDto;
import com.ld.igds.camera.ApiCameraService;
import com.ld.igds.sec.service.CoreSecCameraService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.List;

/**
 * 海康流媒体服务接口
 */
@Slf4j
@Component
public class HikMediaService implements ApiCameraService {

    @Autowired
    private SnapPluginService snapPluginService;
    @Autowired
    private CoreSecCameraService cameraService;
    @Autowired
    private ConfigHikMedia configHikMedia;

    @Override
    public String getPlayType() {
        return CameraUtil.PLAY_TYPE_MEDIA_HIK;
    }

    @Override
    public ApiCameraResp getPlayAddr(ApiCameraData apiCameraDto) {

        if(StringUtils.isEmpty(apiCameraDto.getCompanyId()) || StringUtils.isEmpty(apiCameraDto.getSn())){
            return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "调用流媒体服务器异常：请联系管理员查看原因");
        }
        HikMediaProp prop = configHikMedia.getHikProp(apiCameraDto.getCompanyId());
        try {
            ApiCameraPreview apiCameraPreview = ApiCameraPreview.getInstance();
            ApiHikParam param = new ApiHikParam();
            param.setIp(prop.getIp());
            param.setWanIp(prop.getWanIp());
            param.setPort(prop.getPort() + "");
            param.setAppKey(prop.getAppKey());
            param.setAppSecret(prop.getAppSecret());
            param.setArtemisPath(prop.getContextPath());

            param.setDeviceCode(apiCameraDto.getSn());

            HikRespData<CameraPlay> result = apiCameraPreview.apiPreview(param);

            log.info("-------获取多媒体播放信息--------{}-", result);

            if (HikUtil.RESP_CODE_0.equals(result.getCode())) {
                CameraPlay cameraPlay = JSONObject.parseObject(JSONObject.toJSONString(result.getData()), CameraPlay.class);
                String url = cameraPlay.getUrl();
                url = url.replace(param.getIp(), param.getWanIp());
                log.info("-------获取播放url------={}", url);
                return new ApiCameraResp(ApiCameraResp.CODE_SUCCESS,
                        url, result.getMsg());
            }

            return new ApiCameraResp(ApiCameraResp.CODE_ERROR,
                    null, result.getMsg());

        } catch (Exception e) {
            log.debug("调用流媒体服务器异常：{}", e);
            return new ApiCameraResp(ApiCameraResp.CODE_ERROR,
                    "调用流媒体服务器异常：请联系管理员查看原因");
        }
    }

    /**
     * 云台控制
     * 执行命令 1=上，2=下，3=左，4=右，5=左上，6=左下，7=右上，8=右下，0=停止，9=变倍小，10 = 变倍加
     * <p>
     * LEFT 左转
     * RIGHT右转
     * UP 上转
     * DOWN 下转
     * ZOOM_IN 焦距变大
     * ZOOM_OUT 焦距变小
     * LEFT_UP 左上
     * LEFT_DOWN 左下
     * RIGHT_UP 右上
     * RIGHT_DOWN 右下
     * FOCUS_NEAR 焦点前移
     * FOCUS_FAR 焦点后移
     * IRIS_ENLARGE 光圈扩大
     * IRIS_REDUCE 光圈缩小
     * WIPER_SWITCH 接通雨刷开关
     * START_RECORD_TRACK 开始记录轨迹
     * STOP_RECORD_TRACK 停止记录轨迹
     * START_TRACK 开始轨迹
     * STOP_TRACK 停止轨迹；
     * 以下命令presetIndex不可为空：
     * GOTO_PRESET到预置点
     *
     * @param dto
     * @return
     */
    @Override
    public ApiCameraResp ptzMedia(ApiCameraData dto) {
        if(StringUtils.isEmpty(dto.getCompanyId()) || StringUtils.isEmpty(dto.getSn())){
            return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "调用流媒体服务器异常：请联系管理员查看原因");
        }
        HikMediaProp prop = configHikMedia.getHikProp(dto.getCompanyId());
        try {

            if ("1".equals(dto.getCommand())) {
                dto.setCommand("UP");
            }
            if ("2".equals(dto.getCommand())) {
                dto.setCommand("DOWN");
            }
            if ("3".equals(dto.getCommand())) {
                dto.setCommand("LEFT");
            }
            if ("4".equals(dto.getCommand())) {
                dto.setCommand("RIGHT");
            }
            if ("5".equals(dto.getCommand())) {
                dto.setCommand("LEFT_UP");
            }
            if ("6".equals(dto.getCommand())) {
                dto.setCommand("LEFT_DOWN");
            }
            if ("7".equals(dto.getCommand())) {
                dto.setCommand("RIGHT_UP");
            }
            if ("8".equals(dto.getCommand())) {
                dto.setCommand("RIGHT_DOWN");
            }
            if ("9".equals(dto.getCommand())) {
                dto.setCommand("ZOOM_IN");
            }
            if ("10".equals(dto.getCommand())) {
                dto.setCommand("ZOOM_OUT");
            }

            int action = 0;
            if ("0".equals(dto.getCommand())) {
                action = 1;
            }

            ApiHikParam param = new ApiHikParam();
            param.setIp(prop.getIp());
            param.setWanIp(prop.getWanIp());
            param.setPort(prop.getPort() + "");
            param.setAppKey(prop.getAppKey());
            param.setAppSecret(prop.getAppSecret());
            param.setArtemisPath(prop.getContextPath());

            param.setDeviceCode(dto.getSn());
            param.setAction(action);
            param.setCommand(dto.getCommand());

            //预置位
            if (param.getPresetIndex() > 0) {
                param.setPresetIndex(param.getPresetIndex());
                param.setCommand("GOTO_PRESET");
            }

            ApiCameraControl apiCameraControl = ApiCameraControl.getInstance();
            HikRespData<String> result = apiCameraControl.ptz(param);

            if (HikUtil.RESP_CODE_0.equals(result.getCode())) {

                return new ApiCameraResp(ApiCameraResp.CODE_SUCCESS, "执行成功");
            } else {

                return new ApiCameraResp(ApiCameraResp.CODE_ERROR, result.getMsg());
            }

        } catch (Exception e) {

            log.error("调用流媒体服务器异常：{}", e);
            return new ApiCameraResp(ApiCameraResp.CODE_ERROR, "调用流媒体服务器异常：请联系管理员查看原因");
        }
    }

    @Override
    public ApiCameraResp ptzPreset(ApiCameraData apiCameraDto) {
        //TODO
        return null;
    }

    @Override
    public ApiCameraResp keepAlive(ApiCameraData apiCameraDto) {
        //TODO
        return null;
    }

    @Override
    public List<SecCameraDto> searchCamera(ApiCameraData apiCameraDto) {
        if(StringUtils.isEmpty(apiCameraDto.getCompanyId())){
            return null;
        }
        HikMediaProp prop = configHikMedia.getHikProp(apiCameraDto.getCompanyId());
        ApiCameraSearch apiCameraSearch = ApiCameraSearch.getInstance();
        ApiHikParam param = new ApiHikParam();
        param.setIp(prop.getIp());
        param.setWanIp(prop.getWanIp());
        param.setPort(prop.getPort() + "");
        param.setAppKey(prop.getAppKey());
        param.setAppSecret(prop.getAppSecret());
        param.setArtemisPath(prop.getContextPath());
        param.setRegionIndexCodes(prop.getRegionIndexCodes().split(","));
        HikRespData<CameraMainDto> result = apiCameraSearch.apiSearchDevice(param);

        if (!HikUtil.RESP_CODE_0.equals(result.getCode())) {
            log.error("---------同步远程摄像头配置列表失败------{}", result.getMsg());
            return null;
        }

        log.info("-------同步远程摄像头配置信息-----{}", result.getData());

        CameraMainDto data = JSONObject.parseObject(JSONObject.toJSONString(result.getData()), CameraMainDto.class);

        List<CameraDto> list = data.getList();

        if (list != null && list.size() > 0) {
            SecCameraDto dto;
            for (CameraDto cameraDto : list) {
                dto = new SecCameraDto();
                dto.setId(cameraDto.getIndexCode());
                dto.setSn(cameraDto.getIndexCode());
                dto.setCompanyId(apiCameraDto.getCompanyId());
                dto.setDeptId(apiCameraDto.getDeptId());
                dto.setType(HikUtil.getCameraType(cameraDto.getCameraType()));
                dto.setPlayType(CameraUtil.PLAY_TYPE_MEDIA_HIK);
                dto.setName(cameraDto.getName());
                dto.setChanNum(cameraDto.getChanNum());
                dto.setBrand("海康");
                cameraService.updateCamera(dto);
            }
        }
        return new ArrayList<SecCameraDto>();
    }

    @Override
    public ApiCameraResp snapImg(ApiSnapReq apiCameraDto) {
        if (CameraUtil.SNAP_TYPE_FZZY_PLUGIN.equals(apiCameraDto.getSnapType())) {
            return snapPluginService.snapImg(apiCameraDto);
        }
        return null;
    }
}