package com.gkhy.safePlatform.doublePrevent.rpc;

import com.gkhy.safePlatform.account.rpc.apimodel.AccountDepartmentService;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.DepInfoRPCRespDTO;
import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.doublePrevent.rpc.apimodel.PreventRPCDataCountService;
import com.gkhy.safePlatform.doublePrevent.rpc.apimodel.model.req.RPCDataCountI1ReqDTO;
import com.gkhy.safePlatform.doublePrevent.rpc.apimodel.model.req.RPCDataCountI2ReqDTO;
import com.gkhy.safePlatform.doublePrevent.rpc.apimodel.model.resp.RPCDataCountI1RespDTO;
import com.gkhy.safePlatform.doublePrevent.rpc.apimodel.model.resp.RPCDataCountI2RespDTO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.DataCountI1ReqDTO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.DataCountI2ReqDTO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.resp.DataCountI1RespDTO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.resp.DataCountI2RespDTO;
import com.gkhy.safePlatform.doublePrevention.service.DataCountService;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;

import java.text.ParseException;
import java.util.List;

@DubboService
public class PreventRPCDataCountProvider implements PreventRPCDataCountService {

    @Autowired
    private DataCountService dataCountService;

    @DubboReference(check = false)
    private AccountDepartmentService accountDepartmentService;

    /**
     * 数据统计-隐患数据统计-I1计算 - 月
     */
    @Override
    public ResultVO<RPCDataCountI1RespDTO> listMonthDangerResultCountI1(RPCDataCountI1ReqDTO rpcDataCountI1ReqDTO){
        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg("查询成功");
        if (ObjectUtils.isEmpty(rpcDataCountI1ReqDTO)){
            resultVO.setCode("400");
            resultVO.setMsg("参数为空，查询失败");
            return resultVO;
        }
        if (ObjectUtils.isEmpty(rpcDataCountI1ReqDTO.getYear())){
            resultVO.setCode("400");
            resultVO.setMsg("查询年份不能为空");
            return resultVO;
        }
        if (ObjectUtils.isEmpty(rpcDataCountI1ReqDTO.getMonth())){
            resultVO.setCode("400");
            resultVO.setMsg("查询月份不能为空");
            return resultVO;
        }
        if (ObjectUtils.isNotEmpty(rpcDataCountI1ReqDTO.getDepId())){
            ResultVO<DepInfoRPCRespDTO> depInfoByDepId = accountDepartmentService.getDepInfoByDepId(rpcDataCountI1ReqDTO.getDepId());
            DepInfoRPCRespDTO depInfo = (DepInfoRPCRespDTO) depInfoByDepId.getData();
            if (ObjectUtils.isEmpty(depInfo)){
                resultVO.setCode("400");
                resultVO.setMsg("查询的部门不存在");
                return resultVO;
            }
        }
        //拷贝参数
        DataCountI1ReqDTO params = BeanCopyUtils.copyBean(rpcDataCountI1ReqDTO, DataCountI1ReqDTO.class);

        DataCountI1RespDTO dataCountI1RespDTO = dataCountService.listMonthDataCountI1(params);

        RPCDataCountI1RespDTO rpcDataCountI1RespDTO = BeanCopyUtils.copyBean(dataCountI1RespDTO, RPCDataCountI1RespDTO.class);

        resultVO.setData(rpcDataCountI1RespDTO);

        return resultVO;
    }
    /**
     * 数据统计-隐患数据统计-I1计算 - 年
     */
    @Override
    public ResultVO<List<RPCDataCountI1RespDTO>> listYearDangerResultCountI1(RPCDataCountI1ReqDTO rpcDataCountI1ReqDTO){
        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg("查询成功");
        if (ObjectUtils.isEmpty(rpcDataCountI1ReqDTO)){
            resultVO.setCode("400");
            resultVO.setMsg("参数为空，查询失败");
            return resultVO;
        }
        if (ObjectUtils.isEmpty(rpcDataCountI1ReqDTO.getYear())){
            resultVO.setCode("400");
            resultVO.setMsg("查询年份不能为空");
            return resultVO;
        }
        if (ObjectUtils.isNotEmpty(rpcDataCountI1ReqDTO.getDepId())){
            ResultVO<DepInfoRPCRespDTO> depInfoByDepId = accountDepartmentService.getDepInfoByDepId(rpcDataCountI1ReqDTO.getDepId());
            DepInfoRPCRespDTO depInfo = (DepInfoRPCRespDTO) depInfoByDepId.getData();
            if (ObjectUtils.isEmpty(depInfo)){
                resultVO.setCode("400");
                resultVO.setMsg("查询的部门不存在");
                return resultVO;
            }
        }

        List<RPCDataCountI1RespDTO> list = null;
        //拷贝参数
        DataCountI1ReqDTO params = BeanCopyUtils.copyBean(rpcDataCountI1ReqDTO, DataCountI1ReqDTO.class);
        //查询
        List<DataCountI1RespDTO> RespDTOS = dataCountService.listYearDataCountI1(params);

        List<RPCDataCountI1RespDTO> rpcDataCountI1RespDTOS = BeanCopyUtils.copyBeanList(RespDTOS, RPCDataCountI1RespDTO.class);

        resultVO.setData(rpcDataCountI1RespDTOS);
        return resultVO;
    }

    /**
     * 数据统计-隐患数据统计-I2计算 - 月
     */
    @Override
    public ResultVO<RPCDataCountI2RespDTO> listMonthDangerLevelCountI2(RPCDataCountI2ReqDTO rpcDataCountI2ReqDTO){
        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg("查询成功");
        if (ObjectUtils.isEmpty(rpcDataCountI2ReqDTO)){
            resultVO.setCode("400");
            resultVO.setMsg("参数为空，查询失败");
            return resultVO;
        }
        if (ObjectUtils.isEmpty(rpcDataCountI2ReqDTO.getYear())){
            resultVO.setCode("400");
            resultVO.setMsg("查询年份不能为空");
            return resultVO;
        }
        if (ObjectUtils.isEmpty(rpcDataCountI2ReqDTO.getMonth())){
            resultVO.setCode("400");
            resultVO.setMsg("查询月份不能为空");
            return resultVO;
        }
        if (ObjectUtils.isNotEmpty(rpcDataCountI2ReqDTO.getDepId())){
            ResultVO<DepInfoRPCRespDTO> depInfoByDepId = accountDepartmentService.getDepInfoByDepId(rpcDataCountI2ReqDTO.getDepId());
            DepInfoRPCRespDTO depInfo = (DepInfoRPCRespDTO) depInfoByDepId.getData();
            if (ObjectUtils.isEmpty(depInfo)){
                resultVO.setCode("400");
                resultVO.setMsg("查询的部门不存在");
                return resultVO;
            }
        }
        //拷贝参数
        DataCountI2ReqDTO params = BeanCopyUtils.copyBean(rpcDataCountI2ReqDTO, DataCountI2ReqDTO.class);
        //查询
        DataCountI2RespDTO respDTO = dataCountService.listMonthDataCountI2(params);

        RPCDataCountI2RespDTO rpcDataCountI2RespDTO = BeanCopyUtils.copyBean(respDTO, RPCDataCountI2RespDTO.class);

        resultVO.setData(rpcDataCountI2RespDTO);

        return resultVO;
    }

    /**
     * 数据统计-隐患数据统计-I2计算 - 年
     */
    @Override
    public ResultVO<List<RPCDataCountI2RespDTO>> listYearDangerLevelCountI2(RPCDataCountI2ReqDTO rpcDataCountI2ReqDTO){
        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg("查询成功");
        if (ObjectUtils.isEmpty(rpcDataCountI2ReqDTO)){
            resultVO.setCode("400");
            resultVO.setMsg("参数为空，查询失败");
            return resultVO;
        }
        if (ObjectUtils.isEmpty(rpcDataCountI2ReqDTO.getYear())){
            resultVO.setCode("400");
            resultVO.setMsg("查询年份不能为空");
            return resultVO;
        }
        if (ObjectUtils.isNotEmpty(rpcDataCountI2ReqDTO.getDepId())){
            ResultVO<DepInfoRPCRespDTO> depInfoByDepId = accountDepartmentService.getDepInfoByDepId(rpcDataCountI2ReqDTO.getDepId());
            DepInfoRPCRespDTO depInfo = (DepInfoRPCRespDTO) depInfoByDepId.getData();
            if (ObjectUtils.isEmpty(depInfo)){
                resultVO.setCode("400");
                resultVO.setMsg("查询的部门不存在");
                return resultVO;
            }
        }

        List<RPCDataCountI2RespDTO> list = null;
        //拷贝参数
        DataCountI2ReqDTO params = BeanCopyUtils.copyBean(rpcDataCountI2ReqDTO, DataCountI2ReqDTO.class);
        //查询
        List<DataCountI2RespDTO> respDTOS = dataCountService.listYearDataCountI2(params);

        List<RPCDataCountI2RespDTO> rpcDataCountI2RespDTOS = BeanCopyUtils.copyBeanList(respDTOS, RPCDataCountI2RespDTO.class);

        resultVO.setData(rpcDataCountI2RespDTOS);

        return resultVO;
    }
}