SafePlatform.gitlab.git

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;
    }
}