package com.gkhy.safePlatform.riskCtrl.service.impl;
|
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.date.DateUtil;
|
import com.gkhy.safePlatform.account.rpc.apimodel.AccountDepartmentService;
|
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.DepInfoRPCRespDTO;
|
import com.gkhy.safePlatform.commons.enums.ResultCodes;
|
import com.gkhy.safePlatform.commons.exception.BusinessException;
|
import com.gkhy.safePlatform.commons.utils.idService.IdGenerateUtil;
|
import com.gkhy.safePlatform.commons.vo.ResultVO;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
import com.gkhy.safePlatform.riskCtrl.entity.EmergencyPracticeReportItem;
|
import com.gkhy.safePlatform.riskCtrl.entity.IncidentMonthReportItem;
|
import com.gkhy.safePlatform.riskCtrl.entity.PreventMonthReportDetail;
|
import com.gkhy.safePlatform.riskCtrl.entity.RiskMonthReport;
|
import com.gkhy.safePlatform.riskCtrl.enums.ReportBizEnum;
|
import com.gkhy.safePlatform.riskCtrl.model.bo.EmergencyDataBO;
|
import com.gkhy.safePlatform.riskCtrl.model.bo.IncidentDataBO;
|
import com.gkhy.safePlatform.riskCtrl.model.bo.RiskDataBO;
|
import com.gkhy.safePlatform.riskCtrl.model.dto.resp.EmergencyPracticeReportItemRespDTO;
|
import com.gkhy.safePlatform.riskCtrl.model.dto.resp.IncidentMonthReportItemRespDTO;
|
import com.gkhy.safePlatform.riskCtrl.model.dto.resp.PreventMonthReportDetailRespDTO;
|
import com.gkhy.safePlatform.riskCtrl.model.dto.resp.RiskMonthReportRespDTO;
|
import com.gkhy.safePlatform.riskCtrl.service.RiskReportService;
|
import com.gkhy.safePlatform.riskCtrl.service.baseService.EmergencyPracticeReportItemService;
|
import com.gkhy.safePlatform.riskCtrl.service.baseService.IncidentMonthReportItemService;
|
import com.gkhy.safePlatform.riskCtrl.service.baseService.PreventMonthReportDetailService;
|
import com.gkhy.safePlatform.riskCtrl.service.baseService.RiskMonthReportService;
|
import com.gkhy.safePlatform.riskCtrl.utils.RiskReportAnalysisHandler;
|
import org.apache.dubbo.config.annotation.DubboReference;
|
import org.redisson.api.RLock;
|
import org.redisson.api.RedissonClient;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.ZoneId;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.concurrent.TimeUnit;
|
|
@Service
|
public class RiskReportServiceImpl implements RiskReportService {
|
|
@DubboReference(check = false)
|
private AccountDepartmentService departmentService;
|
|
@Autowired
|
private CollectReportDataService collectReportDataService;
|
|
@Autowired
|
private RiskMonthReportService riskMonthReportService;
|
|
@Autowired
|
private PreventMonthReportDetailService preventMonthReportDetailService;
|
|
@Autowired
|
private EmergencyPracticeReportItemService emergencyPracticeReportItemService;
|
|
@Autowired
|
private IncidentMonthReportItemService incidentMonthReportItemService;
|
|
@Autowired
|
private RedissonClient redissonClient;
|
|
/**
|
* 生成企业月度风险报表
|
* @param depId
|
* @param year
|
* @param month
|
* @return
|
*/
|
@Transactional
|
@Override
|
public ResultVO generateDepartmentMonthRiskReport(Long depId, Integer year, Integer month) {
|
|
ResultVO resultVO = new ResultVO<>();
|
//step1、检查该月报表是否已经生成
|
RiskMonthReport prevReport = riskMonthReportService.findByMonth(ReportBizEnum.PREVENT_RISK.getType(),depId,year, month);
|
RiskMonthReport incidentReport = riskMonthReportService.findByMonth(ReportBizEnum.INCIDENT_COUNT.getType(),depId, year, month);
|
RiskMonthReport emgcReport = riskMonthReportService.findByMonth(ReportBizEnum.EMERGENCY_PRACTICE.getType(),depId, year, month);
|
if(prevReport != null || incidentReport != null || emgcReport != null){
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("月度报表已存在");
|
return resultVO;
|
}
|
//step2、获取各系统数据
|
if(year == null || year < 0 || year > 9999){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg(ResultCodes.CLIENT_PARAM_ERROR.getDesc());
|
return resultVO;
|
}
|
if(month != null && (month < 0 || month > 12)){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg(ResultCodes.CLIENT_PARAM_ERROR.getDesc());
|
return resultVO;
|
}
|
ResultVO<DepInfoRPCRespDTO> depInfoRpcResult = departmentService.getDepInfoByDepId(depId);
|
if(!depInfoRpcResult.getCode().equals(ResultCodes.OK.getCode())){
|
throw new RuntimeException("RPC调用出错");
|
}
|
DepInfoRPCRespDTO depInfo = (DepInfoRPCRespDTO) depInfoRpcResult.getData();
|
if(depInfo == null){
|
throw new RuntimeException("部门不存在");
|
}
|
|
RiskDataBO riskDataBO = collectReportDataService.getPreventRiskData(depInfo,year,month);
|
|
IncidentDataBO incidentDataBO = collectReportDataService.getIncidentCountData(depInfo,year,month);
|
|
EmergencyDataBO emergencyDataBO = collectReportDataService.getEmergencyCountData(depInfo,year,month);
|
|
//step3、处理数据
|
//3.1、报表POJO
|
RiskMonthReport riskMonthReport = new RiskMonthReport();
|
IdGenerateUtil idGenerateUtil = new IdGenerateUtil();
|
riskMonthReport.setId(idGenerateUtil.nextId());
|
riskMonthReport.setDepId(depId);
|
riskMonthReport.setYear(year);
|
riskMonthReport.setMonth(month);
|
riskMonthReport.setDepLevel(depInfo.getDepLevel());
|
LocalDateTime beginTime = LocalDateTime.of(year,month,1,0,0,0);
|
DateTime dt = DateUtil.beginOfMonth(Date.from(beginTime.atZone(ZoneId.systemDefault()).toInstant()));
|
riskMonthReport.setBeginDate(dt.toLocalDateTime().toLocalDate());
|
dt = DateUtil.endOfMonth(Date.from(beginTime.atZone(ZoneId.systemDefault()).toInstant()));
|
riskMonthReport.setEndDate(dt.toLocalDateTime().toLocalDate());
|
riskMonthReport.setGmtCreate(LocalDateTime.now());
|
|
RiskReportAnalysisHandler riskReportAnalysisHandler = new RiskReportAnalysisHandler();
|
|
//3.2、双重预防报表POJO
|
PreventMonthReportDetail preventMonthReportDetail =
|
riskReportAnalysisHandler.analysisPrevReportData(riskDataBO);
|
preventMonthReportDetail.setReportId(riskMonthReport.getId());
|
|
//3.3、应急管理报表POJO
|
List<EmergencyPracticeReportItem> emergencyReportItemList =
|
riskReportAnalysisHandler.analysisEmgcReportData(emergencyDataBO);
|
|
//3.4、事故管理报表POJO
|
List<IncidentMonthReportItem> incidentMonthReportItemList =
|
riskReportAnalysisHandler.analysisIncidentReportDate(incidentDataBO);
|
|
//step4、保存入库
|
if(riskMonthReportService.save(riskMonthReport) == false){
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
if(preventMonthReportDetail != null){
|
if(preventMonthReportDetailService.save(preventMonthReportDetail) == false){
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
}
|
if(emergencyReportItemList != null && !emergencyReportItemList.isEmpty()){
|
for(EmergencyPracticeReportItem item : emergencyReportItemList){
|
item.setId(idGenerateUtil.nextId());
|
item.setReportId(riskMonthReport.getId());
|
}
|
if(emergencyPracticeReportItemService.saveBatch(emergencyReportItemList) == false){
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
}
|
if(incidentMonthReportItemList != null && !incidentMonthReportItemList.isEmpty()){
|
for(IncidentMonthReportItem i : incidentMonthReportItemList){
|
i.setId(idGenerateUtil.nextId());
|
i.setReportId(riskMonthReport.getId());
|
}
|
if(incidentMonthReportItemService.saveBatch(incidentMonthReportItemList) == false){
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
}
|
|
resultVO.setCode(ResultCodes.OK.getCode());
|
return resultVO;
|
}
|
|
@Transactional
|
@Override
|
public ResultVO generateDepartmentMonthRiskReport(Byte biz, Long depId, Integer year, Integer month) {
|
ResultVO resultVO = new ResultVO<>();
|
//1、参数校验
|
if(biz == null || ReportBizEnum.parse(biz) == null){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务类型不支持");
|
return resultVO;
|
}
|
if(depId == null || depId < 1 || year == null || year < 2000 || year > 9999 || month == null || month < 1 || month > 12){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("参数错误");
|
return resultVO;
|
}
|
|
//加分布式锁
|
String lockName = "LOCK_RISK_MONTH_REPORT_GENERATE_"+depId+"_"+biz;
|
RLock lock = redissonClient.getLock(lockName);
|
lock.lock(30L, TimeUnit.SECONDS);
|
|
//2、检查报表是否已经存在
|
RiskMonthReport report = riskMonthReportService.findByMonth(biz,depId,year,month);
|
if(report != null && report.getId() > 0){
|
lock.unlock();
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("报表已经生成");
|
return resultVO;
|
}
|
//3、校验部门是否存在
|
ResultVO<DepInfoRPCRespDTO> depInfoRpcResult = departmentService.getDepInfoByDepId(depId);
|
if(!depInfoRpcResult.getCode().equals(ResultCodes.OK.getCode())){
|
lock.unlock();
|
throw new RuntimeException("RPC调用出错");
|
}
|
DepInfoRPCRespDTO depInfo = (DepInfoRPCRespDTO) depInfoRpcResult.getData();
|
if(depInfo == null){
|
lock.unlock();
|
throw new RuntimeException("部门不存在");
|
}
|
//4、生成报表项
|
RiskMonthReport riskMonthReport = new RiskMonthReport();
|
IdGenerateUtil idGenerateUtil = new IdGenerateUtil();
|
riskMonthReport.setId(idGenerateUtil.nextId());
|
riskMonthReport.setDepId(depId);
|
riskMonthReport.setBiz(biz);
|
riskMonthReport.setYear(year);
|
riskMonthReport.setMonth(month);
|
riskMonthReport.setDepLevel(depInfo.getDepLevel());
|
LocalDateTime beginTime = LocalDateTime.of(year,month,1,0,0,0);
|
DateTime dt = DateUtil.beginOfMonth(Date.from(beginTime.atZone(ZoneId.systemDefault()).toInstant()));
|
riskMonthReport.setBeginDate(dt.toLocalDateTime().toLocalDate());
|
dt = DateUtil.endOfMonth(Date.from(beginTime.atZone(ZoneId.systemDefault()).toInstant()));
|
riskMonthReport.setEndDate(dt.toLocalDateTime().toLocalDate());
|
riskMonthReport.setGmtCreate(LocalDateTime.now());
|
|
if(riskMonthReportService.save(riskMonthReport) == false){
|
lock.unlock();
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
|
RiskReportAnalysisHandler riskReportAnalysisHandler = new RiskReportAnalysisHandler();
|
|
//5、获取对应业务系统的数据，生成业务报表
|
if(biz.equals(ReportBizEnum.PREVENT_RISK.getType())){
|
//双重预防
|
RiskDataBO riskDataBO = collectReportDataService.getPreventRiskData(depInfo,year,month);
|
PreventMonthReportDetail preventMonthReportDetail =
|
riskReportAnalysisHandler.analysisPrevReportData(riskDataBO);
|
preventMonthReportDetail.setReportId(riskMonthReport.getId());
|
if(preventMonthReportDetail != null){
|
if(preventMonthReportDetailService.save(preventMonthReportDetail) == false){
|
lock.unlock();
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
}
|
}else if(biz.equals(ReportBizEnum.EMERGENCY_PRACTICE.getType())){
|
//应急管理
|
EmergencyDataBO emergencyDataBO = collectReportDataService.getEmergencyCountData(depInfo,year,month);
|
List<EmergencyPracticeReportItem> emergencyReportItemList =
|
riskReportAnalysisHandler.analysisEmgcReportData(emergencyDataBO);
|
if(emergencyReportItemList != null && !emergencyReportItemList.isEmpty()){
|
for(EmergencyPracticeReportItem item : emergencyReportItemList){
|
item.setId(idGenerateUtil.nextId());
|
item.setReportId(riskMonthReport.getId());
|
}
|
if(emergencyPracticeReportItemService.saveBatch(emergencyReportItemList) == false){
|
lock.unlock();
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
}
|
}else if(biz.equals(ReportBizEnum.INCIDENT_COUNT.getType())){
|
//事故管理
|
IncidentDataBO incidentDataBO = collectReportDataService.getIncidentCountData(depInfo,year,month);
|
List<IncidentMonthReportItem> incidentMonthReportItemList =
|
riskReportAnalysisHandler.analysisIncidentReportDate(incidentDataBO);
|
if(incidentMonthReportItemList != null && !incidentMonthReportItemList.isEmpty()){
|
for(IncidentMonthReportItem i : incidentMonthReportItemList){
|
i.setId(idGenerateUtil.nextId());
|
i.setReportId(riskMonthReport.getId());
|
}
|
if(incidentMonthReportItemService.saveBatch(incidentMonthReportItemList) == false){
|
lock.unlock();
|
throw new BusinessException(ResultCodes.BUSINESS_ERROR);
|
}
|
}
|
}
|
lock.unlock();
|
resultVO.setCode(ResultCodes.OK.getCode());
|
return resultVO;
|
}
|
|
/**
|
* 获取指定部门指定月份指定业务的月报
|
* @param depId
|
* @param biz
|
* @param year
|
* @param month
|
* @return
|
*/
|
@Override
|
public SearchResultVO<RiskMonthReportRespDTO> getReportByMonth(Long depId, Byte biz, Integer year, Integer month) {
|
SearchResultVO<RiskMonthReportRespDTO> resultVO = new SearchResultVO<>();
|
resultVO.setUsePage(false);
|
//1、参数校验
|
if(depId == null || depId < 1 || biz == null || year == null || month == null || year < 2000 || year > 9999 || month < 1|| month > 12){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("参数错误");
|
return resultVO;
|
}
|
if(ReportBizEnum.parse(biz) == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务不支持");
|
return resultVO;
|
}
|
//2、部门校验
|
ResultVO<DepInfoRPCRespDTO> depSearchResult = departmentService.getDepInfoByDepId(depId);
|
if(depSearchResult == null || !depSearchResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("系统调用错误");
|
return resultVO;
|
}
|
if(depSearchResult.getData() == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("部门不存在");
|
return resultVO;
|
}
|
//3、判断查询实时当月数据，还是往期数据
|
LocalDate checkDate = LocalDate.of(year,month,1);
|
LocalDate nowDate = LocalDate.now();
|
LocalDate offsetDate = LocalDate.of(nowDate.getYear(),nowDate.getMonthValue(),1);
|
if(checkDate.isAfter(offsetDate)){
|
//查询将来的数据
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("超出查询范围");
|
return resultVO;
|
}else if(checkDate.isBefore(offsetDate)){
|
//查询固化报表
|
RiskMonthReport riskMonthReport = riskMonthReportService.findByMonth(biz,depId,year,month);
|
if(riskMonthReport == null){
|
ResultVO genResult = generateDepartmentMonthRiskReport(biz,depId,year,month);
|
if(genResult == null || !genResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg(genResult.getMsg());
|
return resultVO;
|
}else {
|
//重新获取固化报表
|
riskMonthReport = riskMonthReportService.findByMonth(biz,depId,year,month);
|
}
|
}
|
if(riskMonthReport == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("查询失败");
|
return resultVO;
|
}
|
//封装后返回
|
RiskMonthReportRespDTO dto = packageRiskMonthReportData(riskMonthReport);
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setCount(1);
|
resultVO.setData(dto);
|
return resultVO;
|
}else {
|
//查询当月数据
|
RiskMonthReportRespDTO reportRespDTO = getNowMonthRiskReport((DepInfoRPCRespDTO) depSearchResult.getData(),biz);
|
if(reportRespDTO == null || reportRespDTO.getDetail() == null){
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("未获取到当前月份数据");
|
return resultVO;
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setCount(1);
|
resultVO.setData(reportRespDTO);
|
return resultVO;
|
}
|
}
|
|
/**
|
* 获取指定部门的指定年度报表
|
* @param depId
|
* @param biz
|
* @param year
|
* @return
|
*/
|
@Override
|
public SearchResultVO<List<RiskMonthReportRespDTO>> getDepartmentReportByYear(Long depId, Byte biz, Integer year) {
|
SearchResultVO resultVO = new SearchResultVO<>();
|
if(depId == null || biz == null || year == null){
|
resultVO.setCode(ResultCodes.SERVER_PARAM_NULL.getCode());
|
resultVO.setMsg(ResultCodes.SERVER_PARAM_NULL.getDesc());
|
}
|
if(ReportBizEnum.parse(biz) == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务不支持");
|
return resultVO;
|
}
|
//部门校验
|
ResultVO<DepInfoRPCRespDTO> depSearchResult = departmentService.getDepInfoByDepId(depId);
|
if(depSearchResult == null || !depSearchResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("系统调用错误");
|
return resultVO;
|
}
|
if(depSearchResult.getData() == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("部门不存在");
|
return resultVO;
|
}
|
//判断是否为当前年度
|
Integer maxMonth = 12;
|
if(year == LocalDate.now().getYear()){
|
maxMonth = LocalDate.now().getMonthValue();
|
}
|
List<RiskMonthReportRespDTO> reportRespDTOS = new ArrayList<>();
|
for(int month = 1;month<= maxMonth;month++){
|
SearchResultVO<RiskMonthReportRespDTO> searchResultVO = getReportByMonth(depId,biz,year,month);
|
if(searchResultVO != null && searchResultVO.getCode().equals(ResultCodes.OK.getCode()) && searchResultVO.getData() != null){
|
reportRespDTOS.add((RiskMonthReportRespDTO) searchResultVO.getData());
|
}
|
}
|
|
resultVO.setCode(ResultCodes.OK.getCode());
|
if(!reportRespDTOS.isEmpty()){
|
resultVO.setData(reportRespDTOS);
|
resultVO.setCount(reportRespDTOS.size());
|
}
|
return resultVO;
|
}
|
|
/**
|
* 获取指定部门连续多个月的报表
|
* @param depId
|
* @param biz
|
* @param beginYear
|
* @param beginMonth
|
* @param endYear
|
* @param endMonth
|
* @return
|
*/
|
@Override
|
public SearchResultVO<List<RiskMonthReportRespDTO>> getDepartmentReportByMultipleMonth(Long depId, Byte biz, Integer beginYear, Integer beginMonth, Integer endYear, Integer endMonth) {
|
SearchResultVO resultVO = new SearchResultVO<>();
|
if(depId == null || biz == null || beginYear == null || beginMonth == null || endYear == null || endMonth == null){
|
resultVO.setCode(ResultCodes.SERVER_PARAM_NULL.getCode());
|
resultVO.setMsg(ResultCodes.SERVER_PARAM_NULL.getDesc());
|
}
|
if(ReportBizEnum.parse(biz) == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务不支持");
|
return resultVO;
|
}
|
LocalDate beginDate = LocalDate.of(beginYear,beginMonth,1);
|
LocalDate endDate = LocalDate.of(endYear,endMonth,1);
|
if(beginDate.isAfter(endDate)){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("查询日期错误");
|
return resultVO;
|
}
|
//部门校验
|
ResultVO<DepInfoRPCRespDTO> depSearchResult = departmentService.getDepInfoByDepId(depId);
|
if(depSearchResult == null || !depSearchResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("系统调用错误");
|
return resultVO;
|
}
|
if(depSearchResult.getData() == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("部门不存在");
|
return resultVO;
|
}
|
List<RiskMonthReportRespDTO> reportRespDTOS = new ArrayList<>();
|
while (!beginDate.isAfter(endDate)){
|
SearchResultVO<RiskMonthReportRespDTO> searchResultVO = getReportByMonth(depId,biz,beginDate.getYear(),
|
beginDate.getMonthValue());
|
if(searchResultVO != null && searchResultVO.getCode().equals(ResultCodes.OK.getCode()) && searchResultVO.getData() != null){
|
reportRespDTOS.add((RiskMonthReportRespDTO) searchResultVO.getData());
|
}
|
beginDate = beginDate.plusMonths(1);
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
if(!reportRespDTOS.isEmpty()){
|
resultVO.setData(reportRespDTOS);
|
resultVO.setCount(reportRespDTOS.size());
|
}
|
|
return resultVO;
|
}
|
|
|
/**
|
* 获取指定部门的子部门连续多个月的报表
|
* @param depId
|
* @param biz
|
* @param beginYear
|
* @param beginMonth
|
* @param endYear
|
* @param endMonth
|
* @return
|
*/
|
@Override
|
public SearchResultVO<List<RiskMonthReportRespDTO>> getSubDepartmentReportByMultipleMonth(Long depId, Byte biz, Integer beginYear, Integer beginMonth, Integer endYear, Integer endMonth) {
|
SearchResultVO resultVO = new SearchResultVO<>();
|
if(depId == null || biz == null || beginYear == null || beginMonth == null || endYear == null || endMonth == null){
|
resultVO.setCode(ResultCodes.SERVER_PARAM_NULL.getCode());
|
resultVO.setMsg(ResultCodes.SERVER_PARAM_NULL.getDesc());
|
}
|
if(ReportBizEnum.parse(biz) == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务不支持");
|
return resultVO;
|
}
|
LocalDate beginDate = LocalDate.of(beginYear,beginMonth,1);
|
LocalDate endDate = LocalDate.of(endYear,endMonth,1);
|
if(beginDate.isAfter(endDate)){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("查询日期错误");
|
return resultVO;
|
}
|
//部门校验
|
ResultVO<DepInfoRPCRespDTO> depSearchResult = departmentService.getDepInfoByDepId(depId);
|
if(depSearchResult == null || !depSearchResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("系统调用错误");
|
return resultVO;
|
}
|
if(depSearchResult.getData() == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("部门不存在");
|
return resultVO;
|
}
|
|
//获取子部门列表
|
ResultVO<List<DepInfoRPCRespDTO>> subDepListResult = departmentService.listSubDepsByDepId(depId);
|
if(subDepListResult == null || !subDepListResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("获取子部门出错");
|
return resultVO;
|
}
|
|
List<DepInfoRPCRespDTO> subDepList = (List<DepInfoRPCRespDTO>) subDepListResult.getData();
|
if(subDepList == null || subDepList.isEmpty()){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setMsg("子部门数据未找到");
|
return resultVO;
|
}
|
|
//获取子部门报表
|
List<RiskMonthReportRespDTO> reportRespDTOS = new ArrayList<>();
|
while (!beginDate.isAfter(endDate)){
|
for(DepInfoRPCRespDTO subDep : subDepList){
|
if(subDep == null)
|
continue;
|
SearchResultVO<RiskMonthReportRespDTO> searchResultVO = getReportByMonth(subDep.getDepId(),biz, beginDate.getYear(), beginDate.getMonthValue());
|
if(searchResultVO != null && searchResultVO.getCode().equals(ResultCodes.OK.getCode()) && searchResultVO.getData() != null){
|
reportRespDTOS.add((RiskMonthReportRespDTO) searchResultVO.getData());
|
}
|
}
|
beginDate = beginDate.plusMonths(1);
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
if(!reportRespDTOS.isEmpty()){
|
resultVO.setData(reportRespDTOS);
|
resultVO.setCount(reportRespDTOS.size());
|
}
|
|
return resultVO;
|
|
}
|
|
/**
|
* 获取公司指定年份的报表
|
* @param year
|
* @return
|
*/
|
@Override
|
public SearchResultVO<List<RiskMonthReportRespDTO>> getCompanyReportByYear(Byte biz,Integer year) {
|
SearchResultVO resultVO = new SearchResultVO<>();
|
|
//公司所在部门ID
|
//todo:需从数据库读取
|
Long companyDepId = 1L;
|
|
if(ReportBizEnum.parse(biz) == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务不支持");
|
return resultVO;
|
}
|
//部门校验
|
ResultVO<DepInfoRPCRespDTO> depSearchResult = departmentService.getDepInfoByDepId(companyDepId);
|
if(depSearchResult == null || !depSearchResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("系统调用错误");
|
return resultVO;
|
}
|
if(depSearchResult.getData() == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("未获取到公司信息");
|
return resultVO;
|
}
|
//判断是否为当前年度
|
Integer maxMonth = 12;
|
if(year == LocalDate.now().getYear()){
|
maxMonth = LocalDate.now().getMonthValue();
|
}
|
List<RiskMonthReportRespDTO> reportRespDTOS = new ArrayList<>();
|
for(int month = 1;month<= maxMonth;month++){
|
SearchResultVO<RiskMonthReportRespDTO> searchResultVO = getReportByMonth(companyDepId,biz,year,month);
|
if(searchResultVO != null && searchResultVO.getCode().equals(ResultCodes.OK.getCode()) && searchResultVO.getData() != null){
|
reportRespDTOS.add((RiskMonthReportRespDTO) searchResultVO.getData());
|
}
|
}
|
|
resultVO.setCode(ResultCodes.OK.getCode());
|
if(!reportRespDTOS.isEmpty()){
|
resultVO.setData(reportRespDTOS);
|
resultVO.setCount(reportRespDTOS.size());
|
}
|
return resultVO;
|
}
|
|
/**
|
* 获取公司在指定年月的报表
|
* @param year
|
* @return
|
*/
|
@Override
|
public SearchResultVO<RiskMonthReportRespDTO> getCompanyReportByMonth(Byte biz,Integer year,Integer month) {
|
SearchResultVO<RiskMonthReportRespDTO> resultVO = new SearchResultVO<>();
|
resultVO.setUsePage(false);
|
|
//公司所在部门ID
|
//todo:需从数据库读取
|
Long companyDepId = 1L;
|
|
//1、参数校验
|
if(biz == null || year == null || month == null || year < 2000 || year > 9999 || month < 1|| month > 12){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("参数错误");
|
return resultVO;
|
}
|
if(ReportBizEnum.parse(biz) == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_ERROR.getCode());
|
resultVO.setMsg("业务不支持");
|
return resultVO;
|
}
|
//2、部门校验
|
ResultVO<DepInfoRPCRespDTO> depSearchResult = departmentService.getDepInfoByDepId(companyDepId);
|
if(depSearchResult == null || !depSearchResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("系统调用错误");
|
return resultVO;
|
}
|
if(depSearchResult.getData() == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("未获取到公司信息");
|
return resultVO;
|
}
|
//3、判断查询实时当月数据，还是往期数据
|
LocalDate checkDate = LocalDate.of(year,month,1);
|
LocalDate nowDate = LocalDate.now();
|
LocalDate offsetDate = LocalDate.of(nowDate.getYear(),nowDate.getMonthValue(),1);
|
if(checkDate.isAfter(offsetDate)){
|
//查询将来的数据
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("超出查询范围");
|
return resultVO;
|
}else if(checkDate.isBefore(offsetDate)){
|
//查询固化报表
|
RiskMonthReport riskMonthReport = riskMonthReportService.findByMonth(biz,companyDepId,year,month);
|
if(riskMonthReport == null){
|
ResultVO genResult = generateDepartmentMonthRiskReport(biz,companyDepId,year,month);
|
if(genResult == null || !genResult.getCode().equals(ResultCodes.OK.getCode())){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg(genResult.getMsg());
|
return resultVO;
|
}else {
|
//重新获取固化报表
|
riskMonthReport = riskMonthReportService.findByMonth(biz,companyDepId,year,month);
|
}
|
}
|
if(riskMonthReport == null){
|
resultVO.setCount(0);
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("查询失败");
|
return resultVO;
|
}
|
//封装后返回
|
RiskMonthReportRespDTO dto = packageRiskMonthReportData(riskMonthReport);
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setCount(1);
|
resultVO.setData(dto);
|
return resultVO;
|
}else {
|
//查询当月数据
|
RiskMonthReportRespDTO reportRespDTO = getNowMonthRiskReport((DepInfoRPCRespDTO) depSearchResult.getData(),biz);
|
if(reportRespDTO == null || reportRespDTO.getDetail() == null){
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("未获取到当前月份数据");
|
return resultVO;
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setCount(1);
|
resultVO.setData(reportRespDTO);
|
return resultVO;
|
}
|
}
|
|
/**
|
* 包装报表数据，获取报表详情信息
|
* @param report
|
* @return
|
*/
|
private RiskMonthReportRespDTO packageRiskMonthReportData(RiskMonthReport report){
|
if(report == null || report.getId() == null)
|
return null;
|
RiskMonthReportRespDTO respDTO = new RiskMonthReportRespDTO();
|
BeanUtils.copyProperties(report,respDTO);
|
if(report.getBiz().equals(ReportBizEnum.PREVENT_RISK.getType())){
|
PreventMonthReportDetailRespDTO detail = getPreventReportDetail(report.getId());
|
respDTO.setDetail(detail);
|
}else if(report.getBiz().equals(ReportBizEnum.INCIDENT_COUNT.getType())){
|
List<IncidentMonthReportItemRespDTO> details = getIncidentReportDetail(report.getId());
|
respDTO.setDetail(details);
|
}else if(report.getBiz().equals(ReportBizEnum.EMERGENCY_PRACTICE.getType())){
|
List<EmergencyPracticeReportItemRespDTO> details = getEmergencyReportDeatil(report.getId());
|
respDTO.setDetail(details);
|
}
|
return respDTO;
|
}
|
|
/**
|
* 获取隐患报表详情数据
|
* @param reportId
|
* @return
|
*/
|
private PreventMonthReportDetailRespDTO getPreventReportDetail(Long reportId){
|
if(reportId == null || reportId < 0)
|
return null;
|
PreventMonthReportDetail detail = preventMonthReportDetailService.getById(reportId);
|
if(detail == null)
|
return null;
|
PreventMonthReportDetailRespDTO dto = new PreventMonthReportDetailRespDTO();
|
BeanUtils.copyProperties(detail,dto);
|
return dto;
|
}
|
|
/**
|
* 获取应急演练报表详情数据
|
* @param reportId
|
* @return
|
*/
|
private List<EmergencyPracticeReportItemRespDTO> getEmergencyReportDeatil(Long reportId){
|
if(reportId == null || reportId < 0)
|
return null;
|
List<EmergencyPracticeReportItem> itemList = emergencyPracticeReportItemService.listByReportId(reportId);
|
if(itemList == null || itemList.isEmpty())
|
return null;
|
|
List<EmergencyPracticeReportItemRespDTO> dtoList = new ArrayList<>();
|
for(EmergencyPracticeReportItem item : itemList){
|
if(item == null)
|
continue;
|
EmergencyPracticeReportItemRespDTO dto = new EmergencyPracticeReportItemRespDTO();
|
BeanUtils.copyProperties(item,dto);
|
dtoList.add(dto);
|
}
|
|
return dtoList;
|
}
|
|
/**
|
* 获取事故管理报表详情数据
|
* @param reportId
|
* @return
|
*/
|
private List<IncidentMonthReportItemRespDTO> getIncidentReportDetail(Long reportId){
|
if(reportId == null || reportId < 0)
|
return null;
|
List<IncidentMonthReportItem> itemList = incidentMonthReportItemService.listByReportId(reportId);
|
if(itemList == null || itemList.isEmpty())
|
return null;
|
|
List<IncidentMonthReportItemRespDTO> dtoList = new ArrayList<>();
|
for(IncidentMonthReportItem item : itemList){
|
if(item == null)
|
continue;
|
IncidentMonthReportItemRespDTO dto = new IncidentMonthReportItemRespDTO();
|
BeanUtils.copyProperties(item,dto);
|
dtoList.add(dto);
|
}
|
|
return dtoList;
|
}
|
|
/**
|
* 获取当月的风险报告数据
|
* @param depInfo
|
* @param biz
|
* @return
|
*/
|
private RiskMonthReportRespDTO getNowMonthRiskReport(DepInfoRPCRespDTO depInfo,Byte biz){
|
if(depInfo == null || biz == null || depInfo.getDepId() == null || ReportBizEnum.parse(biz) == null){
|
return null;
|
}
|
LocalDate nowDate = LocalDate.now();
|
//生成报表对象
|
RiskMonthReportRespDTO reportRespDTO = new RiskMonthReportRespDTO();
|
reportRespDTO.setBiz(biz);
|
reportRespDTO.setDepId(depInfo.getDepId());
|
reportRespDTO.setDepLevel(depInfo.getDepLevel());
|
reportRespDTO.setYear(nowDate.getYear());
|
reportRespDTO.setMonth(nowDate.getMonthValue());
|
reportRespDTO.setBeginDate(DateUtil.beginOfMonth(Date.from(nowDate.atStartOfDay().atZone(ZoneId.systemDefault()).toInstant())).toLocalDateTime().toLocalDate());
|
reportRespDTO.setEndDate(DateUtil.endOfMonth(Date.from(nowDate.atStartOfDay().atZone(ZoneId.systemDefault()).toInstant())).toLocalDateTime().toLocalDate());
|
RiskReportAnalysisHandler riskReportAnalysisHandler = new RiskReportAnalysisHandler();
|
//获取报表详细数据，并打包数据
|
if(biz.equals(ReportBizEnum.PREVENT_RISK.getType())){
|
//双重预防隐患统计
|
RiskDataBO riskDataBO = collectReportDataService.getPreventRiskData(depInfo,nowDate.getYear(), nowDate.getMonthValue());
|
PreventMonthReportDetail reportDetail = riskReportAnalysisHandler.analysisPrevReportData(riskDataBO);
|
PreventMonthReportDetailRespDTO detailRespDTO = packagePreventReportDetailDto(reportDetail);
|
reportRespDTO.setDetail(detailRespDTO);
|
}else if(biz.equals(ReportBizEnum.EMERGENCY_PRACTICE.getType())){
|
//应急管理统计
|
EmergencyDataBO emergencyDataBO = collectReportDataService.getEmergencyCountData(depInfo, nowDate.getYear(), nowDate.getMonthValue());
|
List<EmergencyPracticeReportItem> reportItemList =
|
riskReportAnalysisHandler.analysisEmgcReportData(emergencyDataBO);
|
List<EmergencyPracticeReportItemRespDTO> itemRespDTOList = packageEmergencyReportDetailDto(reportItemList);
|
reportRespDTO.setDetail(itemRespDTOList);
|
}else if(biz.equals(ReportBizEnum.INCIDENT_COUNT.getType())){
|
//事故管理统计
|
IncidentDataBO incidentDataBO = collectReportDataService.getIncidentCountData(depInfo,nowDate.getYear(), nowDate.getMonthValue());
|
List<IncidentMonthReportItem> reportItemList =
|
riskReportAnalysisHandler.analysisIncidentReportDate(incidentDataBO);
|
List<IncidentMonthReportItemRespDTO> reportItemRespDTOS = packageIncidentReportDetailDto(reportItemList);
|
reportRespDTO.setDetail(reportItemRespDTOS);
|
}
|
return reportRespDTO;
|
}
|
|
/**
|
* 打包应急管理统计数据
|
* @param reportItemList
|
* @return
|
*/
|
private List<EmergencyPracticeReportItemRespDTO> packageEmergencyReportDetailDto(List<EmergencyPracticeReportItem> reportItemList){
|
if(reportItemList == null || reportItemList.isEmpty())
|
return null;
|
List<EmergencyPracticeReportItemRespDTO> itemRespDTOList = new ArrayList<>();
|
for(EmergencyPracticeReportItem item : reportItemList){
|
if(item == null)
|
continue;
|
EmergencyPracticeReportItemRespDTO itemRespDTO = new EmergencyPracticeReportItemRespDTO();
|
BeanUtils.copyProperties(item,itemRespDTO);
|
itemRespDTOList.add(itemRespDTO);
|
}
|
return itemRespDTOList;
|
}
|
|
/**
|
* 打包事故管理统计数据
|
* @param reportItemList
|
* @return
|
*/
|
private List<IncidentMonthReportItemRespDTO> packageIncidentReportDetailDto(List<IncidentMonthReportItem> reportItemList){
|
if(reportItemList == null || reportItemList.isEmpty())
|
return null;
|
List<IncidentMonthReportItemRespDTO> itemRespDTOList = new ArrayList<>();
|
for(IncidentMonthReportItem item : reportItemList){
|
if(item == null)
|
continue;
|
IncidentMonthReportItemRespDTO dto = new IncidentMonthReportItemRespDTO();
|
BeanUtils.copyProperties(item,dto);
|
itemRespDTOList.add(dto);
|
}
|
return itemRespDTOList;
|
}
|
|
/**
|
* 打包双重预防隐患统计数据
|
* @param reportDetail
|
* @return
|
*/
|
private PreventMonthReportDetailRespDTO packagePreventReportDetailDto(PreventMonthReportDetail reportDetail){
|
if(reportDetail == null)
|
return null;
|
PreventMonthReportDetailRespDTO dto = new PreventMonthReportDetailRespDTO();
|
BeanUtils.copyProperties(reportDetail,dto);
|
return dto;
|
}
|
}
|
