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