package com.ld.igds.quantity.manager;

import com.ld.igds.camera.ApiCameraManager;
import com.ld.igds.camera.CameraUtil;
import com.ld.igds.camera.data.ApiCameraData;
import com.ld.igds.camera.data.ApiCameraResp;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.constant.RespCodeEnum;
import com.ld.igds.data.PageResponse;
import com.ld.igds.file.CoreFileService;
import com.ld.igds.file.dto.FileData;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.request.QuantityRequest;
import com.ld.igds.io.response.BaseResponse;
import com.ld.igds.models.Depot;
import com.ld.igds.models.QuantityConf;
import com.ld.igds.quantity.dto.QuantityConfDto;
import com.ld.igds.quantity.dto.QuantityData;
import com.ld.igds.quantity.dto.QuantityParam;
import com.ld.igds.quantity.io.QuantityRemoteManager;
import com.ld.igds.quantity.io.RemoteQuantityService;
import com.ld.igds.quantity.service.CoreQuantityService;
import com.ld.igds.util.ContextUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestBody;

import java.io.File;
import java.util.List;

/**
 * 逻辑管理，用于实现控制层的逻辑
 */
@Component
public class QuantityManager {

    @Autowired
    private CoreCommonService coreCommonService;
    @Autowired
    private CoreQuantityService coreQuantityService;

    @Autowired
    private QuantityRemoteManager remoteManager;
    @Autowired
    private ApiCameraManager apiCameraManager;

    @Autowired
    private CoreFileService fileService;

    /**
     * 保存数据
     *
     * @param data
     */
    @SuppressWarnings("rawtypes")
    public PageResponse saveData(QuantityData data) {
        coreQuantityService.saveData(data);
        return new PageResponse<>(RespCodeEnum.CODE_0000, null);
    }

    /**
     * 根据仓库编号获取最新一条数据
     *
     * @param param
     * @return
     */
    public PageResponse<QuantityData> getLastData(QuantityParam param) {

        if (StringUtils.isEmpty(param.getDepotId())) {
            return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), "仓库编号为空！");
        }

        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }

        Depot depot = coreCommonService.getCacheDepot(param.getCompanyId(), param.getDepotId());
        if (depot == null) {
            return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), "没有获取到当前仓库信息");
        }

        QuantityData quantityData = coreQuantityService.getLastData(param);
        if (quantityData == null) {
            quantityData = new QuantityData();
        }
        quantityData.setDepotData(depot);

        return new PageResponse<>(RespCodeEnum.CODE_0000, quantityData);
    }


    /**
     * 单仓检测
     *
     * @param param
     * @return
     */
    public BaseResponse checkSingle(QuantityParam param) {
        if (param == null || StringUtils.isEmpty(param.getDepotId())) {
            return new BaseResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }

        QuantityConf conf = coreQuantityService.getCacheQuantityConf(param.getCompanyId(), param.getDepotId());
        if (conf == null) {
            return new BaseResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        Depot depot = coreCommonService.getCacheDepot(param.getCompanyId(), conf.getDepotId());

        if (depot.getBulkWeight() == null || depot.getBulkWeight() <= 0) {
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                    "当前仓库没有配置容重，取消检测！");
        }

        RemoteQuantityService remoteQuantityService = remoteManager.getRemoteQuantityService(conf.getProtocol());

        if (null == remoteQuantityService) {
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                    "系统没有" + conf.getProtocol() + "的协议实现，执行被拒绝！");
        }

        QuantityRequest request = new QuantityRequest();
        BeanUtils.copyProperties(conf, request);
        request.setDensity(depot.getBulkWeight());
        request.setDepotId(conf.getDepotId());
        request.setYtIp(conf.getYtIp());
        request.setIp(conf.getIp());
        request.setPort(conf.getPort());
        request.setCompanyId(conf.getCompanyId());
        request.setDeptId(conf.getDeptId());
        request.setDepotType(depot.getDepotType());
        request.setSn(conf.getSn());
        request.setLength(conf.getLength());

        request.setBatchId(ContextUtil.getDefaultBatchId());

        return remoteQuantityService.checkStart(request);
    }

    public BaseResponse remoteConf(QuantityConf conf) {

        Depot depot = coreCommonService.getCacheDepot(conf.getCompanyId(), conf.getDepotId());

        if (depot.getBulkWeight() == null || depot.getBulkWeight() <= 0) {
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                    "当前仓库没有配置容重，取消检测！");
        }

        RemoteQuantityService remoteQuantityService = remoteManager.getRemoteQuantityService(conf.getProtocol());

        if (null == remoteQuantityService) {
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                    "系统没有" + conf.getProtocol() + "的协议实现，执行被拒绝！");
        }


        QuantityRequest request = new QuantityRequest();
        BeanUtils.copyProperties(conf, request);
        request.setDensity(depot.getBulkWeight());
        request.setDepotId(conf.getDepotId());
        request.setIp(conf.getIp());
        request.setPort(conf.getPort());
        request.setCompanyId(conf.getCompanyId());
        request.setDeptId(conf.getDeptId());
        request.setDepotType(depot.getDepotType());
        request.setSn(conf.getSn());
        request.setLength(conf.getLength());

        return remoteQuantityService.remoteConf(request);
    }


    public BaseResponse closeWarn(QuantityParam param) {
        if (param == null || StringUtils.isEmpty(param.getDepotId())) {
            return new BaseResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }

        QuantityConf conf = coreQuantityService.getCacheQuantityConf(param.getCompanyId(), param.getDepotId());
        if (conf == null) {
            return new BaseResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        RemoteQuantityService remoteQuantityService = remoteManager.getRemoteQuantityService(conf.getProtocol());

        if (null == remoteQuantityService) {
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                    "系统没有" + conf.getProtocol() + "的协议实现，执行被拒绝！");
        }

        QuantityRequest request = new QuantityRequest();
        request.setCompanyId(conf.getCompanyId());
        request.setIp(conf.getIp());
        request.setPort(conf.getPort());
        request.setSn(conf.getSn());
        request.setDeptId(conf.getDeptId());
        request.setDepotId(conf.getDepotId());

        return remoteQuantityService.closeWarn(request);
    }

    public BaseResponse checkStop(QuantityParam param) {
        if (param == null || StringUtils.isEmpty(param.getDepotId())) {
            return new BaseResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }

        QuantityConf conf = coreQuantityService.getCacheQuantityConf(param.getCompanyId(), param.getDepotId());
        if (conf == null) {
            return new BaseResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        RemoteQuantityService remoteQuantityService = remoteManager.getRemoteQuantityService(conf.getProtocol());

        if (null == remoteQuantityService) {
            return new BaseResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                    "系统没有" + conf.getProtocol() + "的协议实现，执行被拒绝！");
        }

        QuantityRequest request = new QuantityRequest();
        request.setCompanyId(conf.getCompanyId());
        request.setIp(conf.getIp());
        request.setPort(conf.getPort());
        request.setSn(conf.getSn());
        request.setDeptId(conf.getDeptId());
        request.setDepotId(conf.getDepotId());

        return remoteQuantityService.checkStop(request);
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    public PageResponse<QuantityConfDto> quantityCamera(@RequestBody QuantityParam param) {
        if (param == null) {
            return new PageResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }
        if (StringUtils.isEmpty(param.getDepotId())) {
            return new PageResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }
        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }
        QuantityConf conf = coreQuantityService.getCacheQuantityConf(param.getCompanyId(), param.getDepotId());
        if (conf == null) {
            return new PageResponse(RespCodeEnum.CODE_1007.getCode(), RespCodeEnum.CODE_1007.getMsg());
        }

        QuantityConfDto quantityConfDto = new QuantityConfDto();
        BeanUtils.copyProperties(conf, quantityConfDto);

        //判断播放方式，如果为vlc则直接返回
        if (CameraUtil.PLAY_TYPE_VLC.equals(conf.getPlayType())) {
            //更新列媒体地址
            String mediaAddr = CameraUtil.updateMediaAddr(quantityConfDto.getMediaAddr(), quantityConfDto.getLoginId(),
                    quantityConfDto.getPwd(), quantityConfDto.getIp(), quantityConfDto.getPortCtrl(), 1);
            quantityConfDto.setMediaAddr(mediaAddr);

            return new PageResponse<QuantityConfDto>(RespCodeEnum.CODE_0000, quantityConfDto);
        }

        quantityConfDto = updateMediaInfo(quantityConfDto);
        if (StringUtils.isNotEmpty(quantityConfDto.getMsg())) {
            return new PageResponse(RespCodeEnum.CODE_1007.getCode(), "获取播放地址失败！");
        }

        return new PageResponse<QuantityConfDto>(RespCodeEnum.CODE_0000, quantityConfDto);
    }


    public QuantityConfDto updateMediaInfo(QuantityConfDto conf) {
        if (StringUtils.isEmpty(conf.getCameraSn())
                && StringUtils.isEmpty(conf.getIp())) {
            conf.setMsg("没有获取到当前摄像机IP/SN，不支持云台控制");
            return conf;
        }

        //通过接口获取播放地址
        ApiCameraData apiCameraData = new ApiCameraData();
        apiCameraData.setCompanyId(conf.getCompanyId());
        apiCameraData.setSn(conf.getSn());
        apiCameraData.setPlayType(conf.getPlayType());
        apiCameraData.setMediaAddr(CameraUtil.updateMediaAddr(conf.getMediaAddr(), conf.getLoginId(), conf.getPwd(), conf.getIp(), conf.getPortCtrl(), conf.getChanNum()));
        ApiCameraResp result = apiCameraManager.getApiCameraService(conf.getPlayType()).getPlayAddr(apiCameraData);

        if (null != result && ApiCameraResp.CODE_SUCCESS.equals(result.getCode())) {
            conf.setPlayAddr(result.getPlayAddr());
        }

        return conf;
    }

    /**
     * 获取图片列表
     *
     * @param param
     * @return
     */
    public PageResponse<List<FileData>> listSnapImg(QuantityParam param) {

        if (null == param) {
            return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), "参数异常！");
        }

        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }

        List<FileData> list = fileService.listFile(ContextUtil.getCompanyId(), param.getBatchId());
        if (null == list || list.isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(), "响应数据为空！");
        }
        String bathPath;
        File imgFile;
        for (FileData dto : list) {
            if (StringUtils.isNotEmpty(dto.getFileName())) {
                bathPath = fileService.getCommonFilePath(dto.getCreateTime());
                imgFile = new File(bathPath + dto.getFileName());
                if (imgFile.exists()) {
                    dto.setFilePath(bathPath + dto.getFileName());
                }
            }
        }
        return new PageResponse<>(RespCodeEnum.CODE_0000, list);
    }


    /**
     * 根据仓库编码获取最近的5条检测记录信息
     *
     * @param param
     * @return
     */
    public PageResponse<List<QuantityData>> getRecordData(QuantityParam param) {
        if (StringUtils.isEmpty(param.getDepotId())) {
            return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), "仓库编号为空！");
        }

        if (StringUtils.isEmpty(param.getCompanyId())) {
            param.setCompanyId(ContextUtil.getCompanyId());
        }
        //指定获取5条
        param.setLimit(5);
        List<QuantityData> list = coreQuantityService.getDataByLimit(param);
        if (null == list || list.isEmpty()) {
            return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(), "获取数据为空！");
        }
        return new PageResponse<>(RespCodeEnum.CODE_0000, list);
    }
}