package com.gkhy.safePlatform.riskCtrl.service.impl;
|
|
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.vo.ResultVO;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
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.emergency.rpc.api.EmergencyRpcAPi;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.req.EmergencyExecuteCountRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.req.EmergencyExecuteNumRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.req.EmergencyExecuteTimeRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.req.EmergencydrillTimeRPCReq;
|
import com.gkhy.safePlatform.emergency.rpc.api.model.dto.resp.*;
|
import com.gkhy.safePlatform.incidentManage.rpc.api.IncidentManageRpcAPi;
|
import com.gkhy.safePlatform.incidentManage.rpc.api.model.dto.req.IncidentManageCountRPCReq;
|
import com.gkhy.safePlatform.incidentManage.rpc.api.model.dto.resp.*;
|
import com.gkhy.safePlatform.riskCtrl.model.bo.*;
|
import org.apache.dubbo.config.annotation.DubboReference;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class CollectReportDataService {
|
@DubboReference(check = false)
|
private AccountDepartmentService departmentService;
|
|
@DubboReference(check = false)
|
private PreventRPCDataCountService preventRPCDataCountService;
|
|
@DubboReference(check = false)
|
private IncidentManageRpcAPi incidentManageRpcAPi;
|
|
@DubboReference(check = false)
|
private EmergencyRpcAPi emergencyRpcAPi;
|
|
/**
|
* 获取双重预防的隐患单月统计数据
|
* @param depInfo
|
* @param year
|
* @param month
|
* @return
|
*/
|
@Transactional
|
public RiskDataBO getPreventRiskData(DepInfoRPCRespDTO depInfo, Integer year, Integer month){
|
//获取I1数据
|
RPCDataCountI1ReqDTO riskSearchReqDTO = new RPCDataCountI1ReqDTO();
|
riskSearchReqDTO.setDepId(depInfo.getDepId());
|
riskSearchReqDTO.setYear(year);
|
riskSearchReqDTO.setMonth(month);
|
if(month != null)
|
riskSearchReqDTO.setType((byte)1);
|
else
|
riskSearchReqDTO.setType((byte)2);
|
ResultVO<RPCDataCountI1RespDTO> riskI1RpcResult = preventRPCDataCountService.listMonthDangerResultCountI1(riskSearchReqDTO);
|
if(riskI1RpcResult == null || !riskI1RpcResult.getCode().equals(ResultCodes.OK.getCode())){
|
throw new RuntimeException("RPC调用出错");
|
}
|
RPCDataCountI1RespDTO i1RpcData = (RPCDataCountI1RespDTO) riskI1RpcResult.getData();
|
//获取I2数据
|
RPCDataCountI2ReqDTO riskI2SearchReqDto = new RPCDataCountI2ReqDTO();
|
riskI2SearchReqDto.setDepId(depInfo.getDepId());
|
riskI2SearchReqDto.setYear(year);
|
riskI2SearchReqDto.setMonth(month);
|
if(month != null)
|
riskI2SearchReqDto.setType((byte)1);
|
else
|
riskI2SearchReqDto.setType((byte)2);
|
ResultVO<RPCDataCountI2RespDTO> riskI2RpcResult = preventRPCDataCountService.listMonthDangerLevelCountI2(riskI2SearchReqDto);
|
if(riskI2RpcResult == null || !riskI2RpcResult.getCode().equals(ResultCodes.OK.getCode())){
|
throw new RuntimeException("RPC调用出错");
|
}
|
RPCDataCountI2RespDTO i2RpcData = (RPCDataCountI2RespDTO) riskI2RpcResult.getData();
|
|
//处理数据
|
if(i1RpcData == null || i2RpcData == null){
|
return null;
|
}
|
|
RiskDataBO riskDataBO = new RiskDataBO();
|
riskDataBO.setDepId(depInfo.getDepId());
|
riskDataBO.setDepLevel(depInfo.getDepLevel());
|
riskDataBO.setDepName(depInfo.getDepName());
|
riskDataBO.setYear(year);
|
riskDataBO.setMonth(month);
|
|
riskDataBO.setCauseDeathCount(i1RpcData.getDeathCount());
|
riskDataBO.setCauseHeavyInjureCount(i1RpcData.getHeavyInjureCount());
|
riskDataBO.setCauseLightInjureCount(i1RpcData.getLightInjureCount());
|
|
//重大隐患数据
|
RiskCountBO majorRiskData = new RiskCountBO();
|
majorRiskData.setRiskCount(i2RpcData.getHeavyRiskCount());
|
majorRiskData.setRectifyCount(i2RpcData.getHeavyRiskRectifyCount());
|
riskDataBO.setMajorRiskData(majorRiskData);
|
//一般隐患数据
|
RiskCountBO generalRiskData = new RiskCountBO();
|
generalRiskData.setRiskCount(i2RpcData.getLightRiskCount());
|
generalRiskData.setRectifyCount(i2RpcData.getLightRiskRectifyCount());
|
riskDataBO.setGeneralRiskData(generalRiskData);
|
|
return riskDataBO;
|
}
|
|
@Transactional
|
public IncidentDataBO getIncidentCountData(DepInfoRPCRespDTO depInfo, Integer year, Integer month){
|
//获取事故统计数据
|
IncidentManageCountRPCReq req = new IncidentManageCountRPCReq();
|
req.setDeptId(depInfo.getDepId());
|
req.setYear(year);
|
req.setMonth(month);
|
ResultVO<List<StatisticsDepLevelMonthAccidentRPCRespDTO>> incidentSearchResultVO =
|
incidentManageRpcAPi.getAccidentCountByDeptIdsAndMonth(req);
|
if(incidentSearchResultVO == null || !incidentSearchResultVO.getCode().equals(ResultCodes.OK.getCode()) || incidentSearchResultVO.getData() == null){
|
return null;
|
}
|
|
//定义业务数据包装对象
|
IncidentDataBO incidentDataBO = new IncidentDataBO();
|
incidentDataBO.setDepId(depInfo.getDepId());
|
incidentDataBO.setDepLevel(depInfo.getDepLevel());
|
incidentDataBO.setDepName(depInfo.getDepName());
|
incidentDataBO.setYear(year);
|
incidentDataBO.setMonth(month);
|
|
//特大事故数据
|
IncidentCauseCountBO l1DateBO = new IncidentCauseCountBO();
|
l1DateBO.init();
|
l1DateBO.setLevel((byte)1);
|
//重大事故数据
|
IncidentCauseCountBO l2DateBO = new IncidentCauseCountBO();
|
l2DateBO.init();
|
l2DateBO.setLevel((byte)2);
|
//较大事故数据
|
IncidentCauseCountBO l3DateBO = new IncidentCauseCountBO();
|
l3DateBO.init();
|
l3DateBO.setLevel((byte)3);
|
//一般事故数据
|
IncidentCauseCountBO l4DateBO = new IncidentCauseCountBO();
|
l4DateBO.init();
|
l4DateBO.setLevel((byte)4);
|
//未遂事故数据
|
IncidentCauseCountBO l5DateBO = new IncidentCauseCountBO();
|
l5DateBO.init();
|
l5DateBO.setLevel((byte)5);
|
|
List<StatisticsDepLevelMonthAccidentRPCRespDTO> rpcRespDTOList = (List<StatisticsDepLevelMonthAccidentRPCRespDTO>) incidentSearchResultVO.getData();
|
for(StatisticsDepLevelMonthAccidentRPCRespDTO respDTO : rpcRespDTOList){
|
if(respDTO.getAccidentLevelList() == null || respDTO.getAccidentLevelList().isEmpty())
|
continue;
|
for(AccidentLevelResultCountRPCRespDTO accidentLevelCountDto : respDTO.getAccidentLevelList()){
|
if(accidentLevelCountDto == null)
|
continue;
|
if(accidentLevelCountDto.getAccidentLevel().equals((byte)1)){
|
l1DateBO.setAccidentCount(l1DateBO.getAccidentCount()+accidentLevelCountDto.getAccidentCount());
|
l1DateBO.setCauseDeathCount(l1DateBO.getCauseDeathCount()+accidentLevelCountDto.getDeathCount());
|
l1DateBO.setCauseHeavyInjureCount(l1DateBO.getCauseHeavyInjureCount()+accidentLevelCountDto.getSeriousInjuryCount());
|
l1DateBO.setCauseLightInjureCount(l1DateBO.getCauseLightInjureCount()+accidentLevelCountDto.getMinorInjuryCount());
|
l1DateBO.setLoss(l1DateBO.getLoss().add(accidentLevelCountDto.getEconomicLoss()));
|
}else if(accidentLevelCountDto.getAccidentLevel().equals((byte)2)){
|
l2DateBO.setAccidentCount(l2DateBO.getAccidentCount()+accidentLevelCountDto.getAccidentCount());
|
l2DateBO.setCauseDeathCount(l2DateBO.getCauseDeathCount()+accidentLevelCountDto.getDeathCount());
|
l2DateBO.setCauseHeavyInjureCount(l2DateBO.getCauseHeavyInjureCount()+accidentLevelCountDto.getSeriousInjuryCount());
|
l2DateBO.setCauseLightInjureCount(l2DateBO.getCauseLightInjureCount()+accidentLevelCountDto.getMinorInjuryCount());
|
l2DateBO.setLoss(l2DateBO.getLoss().add(accidentLevelCountDto.getEconomicLoss()));
|
}else if(accidentLevelCountDto.getAccidentLevel().equals((byte)3)){
|
l3DateBO.setAccidentCount(l3DateBO.getAccidentCount()+accidentLevelCountDto.getAccidentCount());
|
l3DateBO.setCauseDeathCount(l3DateBO.getCauseDeathCount()+accidentLevelCountDto.getDeathCount());
|
l3DateBO.setCauseHeavyInjureCount(l3DateBO.getCauseHeavyInjureCount()+accidentLevelCountDto.getSeriousInjuryCount());
|
l3DateBO.setCauseLightInjureCount(l3DateBO.getCauseLightInjureCount()+accidentLevelCountDto.getMinorInjuryCount());
|
l3DateBO.setLoss(l3DateBO.getLoss().add(accidentLevelCountDto.getEconomicLoss()));
|
}else if(accidentLevelCountDto.getAccidentLevel().equals((byte)4)){
|
l4DateBO.setAccidentCount(l4DateBO.getAccidentCount()+accidentLevelCountDto.getAccidentCount());
|
l4DateBO.setCauseDeathCount(l4DateBO.getCauseDeathCount()+accidentLevelCountDto.getDeathCount());
|
l4DateBO.setCauseHeavyInjureCount(l4DateBO.getCauseHeavyInjureCount()+accidentLevelCountDto.getSeriousInjuryCount());
|
l4DateBO.setCauseLightInjureCount(l4DateBO.getCauseLightInjureCount()+accidentLevelCountDto.getMinorInjuryCount());
|
l4DateBO.setLoss(l4DateBO.getLoss().add(accidentLevelCountDto.getEconomicLoss()));
|
}else if(accidentLevelCountDto.getAccidentLevel().equals((byte)5)){
|
l5DateBO.setAccidentCount(l5DateBO.getAccidentCount()+accidentLevelCountDto.getAccidentCount());
|
l5DateBO.setCauseDeathCount(l5DateBO.getCauseDeathCount()+accidentLevelCountDto.getDeathCount());
|
l5DateBO.setCauseHeavyInjureCount(l5DateBO.getCauseHeavyInjureCount()+accidentLevelCountDto.getSeriousInjuryCount());
|
l5DateBO.setCauseLightInjureCount(l5DateBO.getCauseLightInjureCount()+accidentLevelCountDto.getMinorInjuryCount());
|
l5DateBO.setLoss(l5DateBO.getLoss().add(accidentLevelCountDto.getEconomicLoss()));
|
}
|
}
|
}
|
|
incidentDataBO.setL1AccidentData(l1DateBO);
|
incidentDataBO.setL2AccidentData(l2DateBO);
|
incidentDataBO.setL3AccidentData(l3DateBO);
|
incidentDataBO.setL4AccidentData(l4DateBO);
|
incidentDataBO.setL5AccidentData(l5DateBO);
|
|
return incidentDataBO;
|
}
|
|
/**
|
* 获取事故管理单月统计数据
|
* @param depInfo
|
* @param year
|
* @param month
|
* @return
|
*/
|
@Transactional
|
public IncidentDataBO getIncidentCountData_old(DepInfoRPCRespDTO depInfo, Integer year, Integer month){
|
IncidentManageCountRPCReq req = new IncidentManageCountRPCReq();
|
req.setDeptId(depInfo.getDepId());
|
req.setYear(year);
|
req.setMonth(month);
|
SearchResultVO<List<IncidentManageRPCResp>> incidentRpcSearchResultVO =
|
incidentManageRpcAPi.getCountByDeptIds(req);
|
if(incidentRpcSearchResultVO == null || !incidentRpcSearchResultVO.getCode().equals(ResultCodes.OK.getCode())){
|
throw new RuntimeException("RPC调用出错");
|
}
|
List<IncidentManageRPCResp> incidentManageRPCRespList = (List<IncidentManageRPCResp>) incidentRpcSearchResultVO.getData();
|
|
if(incidentManageRPCRespList == null || incidentManageRPCRespList.isEmpty()){
|
return null;
|
}
|
|
IncidentDataBO incidentDataBO = new IncidentDataBO();
|
incidentDataBO.setDepId(depInfo.getDepId());
|
incidentDataBO.setDepLevel(depInfo.getDepLevel());
|
incidentDataBO.setDepName(depInfo.getDepName());
|
incidentDataBO.setYear(year);
|
incidentDataBO.setMonth(month);
|
|
//特大事故数据
|
IncidentCauseCountBO l1DateBO = new IncidentCauseCountBO();
|
l1DateBO.init();
|
l1DateBO.setLevel((byte)1);
|
//重大事故数据
|
IncidentCauseCountBO l2DateBO = new IncidentCauseCountBO();
|
l2DateBO.init();
|
l2DateBO.setLevel((byte)2);
|
//较大事故数据
|
IncidentCauseCountBO l3DateBO = new IncidentCauseCountBO();
|
l3DateBO.init();
|
l3DateBO.setLevel((byte)3);
|
//一般事故数据
|
IncidentCauseCountBO l4DateBO = new IncidentCauseCountBO();
|
l4DateBO.init();
|
l4DateBO.setLevel((byte)4);
|
//未遂事故数据
|
IncidentCauseCountBO l5DateBO = new IncidentCauseCountBO();
|
l5DateBO.init();
|
l5DateBO.setLevel((byte)5);
|
|
for(IncidentManageRPCResp resp : incidentManageRPCRespList){
|
if(resp == null)
|
continue;
|
for(IncidentManageCountRPCResp countData : resp.getData()){
|
if(countData == null)
|
continue;
|
for(IncidentManageCountDetailRPCResp detail : countData.getDetail()){
|
if(detail == null)
|
continue;
|
switch (detail.getLevel()){
|
case "1" : {
|
l1DateBO.setAccidentCount(l1DateBO.getAccidentCount()+detail.getNum());
|
l1DateBO.setCauseDeathCount(l1DateBO.getCauseDeathCount()+detail.getDeathNum());
|
l1DateBO.setCauseHeavyInjureCount(l1DateBO.getCauseHeavyInjureCount()+detail.getSeriousInjuryNum());
|
l1DateBO.setCauseLightInjureCount(l1DateBO.getCauseLightInjureCount()+detail.getMinorInjuryNum());
|
l1DateBO.setLoss(l1DateBO.getLoss().add(detail.getEconomicLoss()));
|
break;
|
}
|
case "2" : {
|
l2DateBO.setAccidentCount(l2DateBO.getAccidentCount()+detail.getNum());
|
l2DateBO.setCauseDeathCount(l2DateBO.getCauseDeathCount()+detail.getDeathNum());
|
l2DateBO.setCauseHeavyInjureCount(l2DateBO.getCauseHeavyInjureCount()+detail.getSeriousInjuryNum());
|
l2DateBO.setCauseLightInjureCount(l2DateBO.getCauseLightInjureCount()+detail.getMinorInjuryNum());
|
l2DateBO.setLoss(l2DateBO.getLoss().add(detail.getEconomicLoss()));
|
break;
|
}
|
case "3" : {
|
l3DateBO.setAccidentCount(l3DateBO.getAccidentCount()+detail.getNum());
|
l3DateBO.setCauseDeathCount(l3DateBO.getCauseDeathCount()+detail.getDeathNum());
|
l3DateBO.setCauseHeavyInjureCount(l3DateBO.getCauseHeavyInjureCount()+detail.getSeriousInjuryNum());
|
l3DateBO.setCauseLightInjureCount(l3DateBO.getCauseLightInjureCount()+detail.getMinorInjuryNum());
|
l3DateBO.setLoss(l3DateBO.getLoss().add(detail.getEconomicLoss()));
|
break;
|
}
|
case "4" : {
|
l4DateBO.setAccidentCount(l4DateBO.getAccidentCount()+detail.getNum());
|
l4DateBO.setCauseDeathCount(l4DateBO.getCauseDeathCount()+detail.getDeathNum());
|
l4DateBO.setCauseHeavyInjureCount(l4DateBO.getCauseHeavyInjureCount()+detail.getSeriousInjuryNum());
|
l4DateBO.setCauseLightInjureCount(l4DateBO.getCauseLightInjureCount()+detail.getMinorInjuryNum());
|
l4DateBO.setLoss(l4DateBO.getLoss().add(detail.getEconomicLoss()));
|
break;
|
}
|
case "5" : {
|
l5DateBO.setAccidentCount(l5DateBO.getAccidentCount()+detail.getNum());
|
l5DateBO.setCauseDeathCount(l5DateBO.getCauseDeathCount()+detail.getDeathNum());
|
l5DateBO.setCauseHeavyInjureCount(l5DateBO.getCauseHeavyInjureCount()+detail.getSeriousInjuryNum());
|
l5DateBO.setCauseLightInjureCount(l5DateBO.getCauseLightInjureCount()+detail.getMinorInjuryNum());
|
l5DateBO.setLoss(l5DateBO.getLoss().add(detail.getEconomicLoss()));
|
break;
|
}
|
default:
|
break;
|
}
|
}
|
}
|
}
|
|
incidentDataBO.setL1AccidentData(l1DateBO);
|
incidentDataBO.setL2AccidentData(l2DateBO);
|
incidentDataBO.setL3AccidentData(l3DateBO);
|
incidentDataBO.setL4AccidentData(l4DateBO);
|
incidentDataBO.setL5AccidentData(l5DateBO);
|
|
return incidentDataBO;
|
}
|
|
@Transactional
|
public EmergencyDataBO getEmergencyCountData(DepInfoRPCRespDTO depInfo, Integer year, Integer month){
|
EmergencyExecuteCountRPCReq req = new EmergencyExecuteCountRPCReq();
|
req.setDeptId(depInfo.getDepId());
|
req.setYear(year);
|
req.setMonth(month);
|
//查询演练次数
|
ResultVO<List<StatisticsDepLevelMonthEexcuteRPCRespDTO>> emgcExecCountResultVO =
|
emergencyRpcAPi.getExecuteCountByDeptIdsAndMonth(req);
|
if(emgcExecCountResultVO == null || !emgcExecCountResultVO.getCode().equals(ResultCodes.OK.getCode())
|
|| emgcExecCountResultVO.getData() == null){
|
return null;
|
}
|
//查询演练时间
|
EmergencydrillTimeRPCReq timeRPCReq = new EmergencydrillTimeRPCReq();
|
timeRPCReq.setDeptId(depInfo.getDepId());
|
timeRPCReq.setYear(year);
|
timeRPCReq.setMonth(month);
|
ResultVO<List<EmergencyExecuteDepLevelLasTimeRPCRespDTO>> emgcExecTimeSearchResultVO =
|
emergencyRpcAPi.getExecuteLastTimeByDeptIdsAndTime(timeRPCReq);
|
if(emgcExecTimeSearchResultVO == null || !emgcExecTimeSearchResultVO.getCode().equals(ResultCodes.OK.getCode())
|
|| emgcExecTimeSearchResultVO.getData() == null){
|
return null;
|
}
|
|
EmergencyDataBO emergencyDataBO = new EmergencyDataBO();
|
emergencyDataBO.setDepId(depInfo.getDepId());
|
emergencyDataBO.setDepLevel(depInfo.getDepLevel());
|
emergencyDataBO.setDepName(depInfo.getDepName());
|
emergencyDataBO.setYear(year);
|
emergencyDataBO.setMonth(month);
|
|
//解析数据
|
// - 解析演练次数
|
Map<Byte,EmergencyCountBO> depLevelEmgcDataMap = new HashMap<>();
|
List<StatisticsDepLevelMonthEexcuteRPCRespDTO> emgcExecCountRespDtoList =
|
(List<StatisticsDepLevelMonthEexcuteRPCRespDTO>) emgcExecCountResultVO.getData();
|
for(StatisticsDepLevelMonthEexcuteRPCRespDTO emgcExecCountRespDto : emgcExecCountRespDtoList){
|
EmergencyCountBO dataBO = depLevelEmgcDataMap.get(emgcExecCountRespDto.getDepLevel());
|
if(dataBO == null){
|
dataBO = new EmergencyCountBO();
|
dataBO.setDepLevel(emgcExecCountRespDto.getDepLevel());
|
depLevelEmgcDataMap.put(emgcExecCountRespDto.getDepLevel(),dataBO);
|
}
|
dataBO.setPracticeCount(emgcExecCountRespDto.getExecuteCount());
|
depLevelEmgcDataMap.put(emgcExecCountRespDto.getDepLevel(), dataBO);
|
}
|
|
// - 解析演练时间
|
List<EmergencyExecuteDepLevelLasTimeRPCRespDTO> timeRPCRespList = (List<EmergencyExecuteDepLevelLasTimeRPCRespDTO>) emgcExecTimeSearchResultVO.getData();
|
for(EmergencyExecuteDepLevelLasTimeRPCRespDTO resp : timeRPCRespList){
|
if(depLevelEmgcDataMap.containsKey(resp.getDepLevel())){
|
EmergencyCountBO countBO = depLevelEmgcDataMap.get(resp.getDepLevel());
|
LocalDateTime lastTime = DateUtil.parseLocalDateTime(resp.getLastPricateTime());
|
if(countBO.getLastPracticeTime() == null){
|
countBO.setLastPracticeTime(lastTime);
|
}else if(countBO.getLastPracticeTime().isBefore(lastTime)){
|
countBO.setLastPracticeTime(lastTime);
|
}
|
}
|
}
|
|
emergencyDataBO.setPracticeData(new ArrayList<>());
|
depLevelEmgcDataMap.forEach((depLevel,dataBO)->{
|
if(dataBO != null){
|
emergencyDataBO.getPracticeData().add(dataBO);
|
}
|
});
|
|
return emergencyDataBO;
|
}
|
|
/**
|
* 获取应急演练单月统计数据
|
* @param depInfo
|
* @param year
|
* @param month
|
* @return
|
*/
|
@Transactional
|
public EmergencyDataBO getEmergencyCountData_old(DepInfoRPCRespDTO depInfo, Integer year, Integer month){
|
//获取应急演练次数数据
|
EmergencyExecuteNumRPCReq numRPCReq = new EmergencyExecuteNumRPCReq();
|
numRPCReq.setDeptId(depInfo.getDepId());
|
numRPCReq.setYear(year);
|
numRPCReq.setMonth(month);
|
SearchResultVO<List<EmergencyExecuteNumRPCResp>> emergencyRpcSearchResultVO =
|
emergencyRpcAPi.getNumByDeptIds(numRPCReq);
|
if(emergencyRpcSearchResultVO == null || !emergencyRpcSearchResultVO.getCode().equals(ResultCodes.OK.getCode())){
|
throw new RuntimeException("RPC调用出错");
|
}
|
List<EmergencyExecuteNumRPCResp> emgcExecRespList = (List<EmergencyExecuteNumRPCResp>) emergencyRpcSearchResultVO.getData();
|
//获取应急演练时间数据
|
EmergencyExecuteTimeRPCReq timeRPCReq = new EmergencyExecuteTimeRPCReq();
|
timeRPCReq.setDeptId(depInfo.getDepId());
|
SearchResultVO<List<EmergencyExecuteTimeRPCResp>> emergencyTimeRpcSearchResultVO =
|
emergencyRpcAPi.getTimeByDeptIds(timeRPCReq);
|
if(emergencyTimeRpcSearchResultVO == null || !emergencyTimeRpcSearchResultVO.getCode().equals(ResultCodes.OK.getCode())){
|
throw new RuntimeException("RPC调用出错");
|
}
|
List<EmergencyExecuteTimeRPCResp> emgcExecTimeRespList = (List<EmergencyExecuteTimeRPCResp>) emergencyTimeRpcSearchResultVO.getData();
|
|
if(emgcExecRespList == null || emgcExecRespList.isEmpty() || emgcExecTimeRespList == null || emgcExecTimeRespList.isEmpty()){
|
return null;
|
}
|
|
EmergencyDataBO emergencyDataBO = new EmergencyDataBO();
|
emergencyDataBO.setDepId(depInfo.getDepId());
|
emergencyDataBO.setDepLevel(depInfo.getDepLevel());
|
emergencyDataBO.setDepName(depInfo.getDepName());
|
emergencyDataBO.setYear(year);
|
emergencyDataBO.setMonth(month);
|
|
Map<Byte,EmergencyCountBO> depLevelEmgcDataMap = new HashMap<>();
|
for(EmergencyExecuteNumRPCResp resp : emgcExecRespList){
|
if(resp == null || resp.getDetail() == null)
|
continue;
|
if(!depLevelEmgcDataMap.containsKey(resp.getDeptLevel())){
|
EmergencyCountBO emergencyCountBO = new EmergencyCountBO();
|
emergencyCountBO.setDepLevel(resp.getDeptLevel());
|
depLevelEmgcDataMap.put(resp.getDeptLevel(), emergencyCountBO);
|
}
|
EmergencyCountBO dataBO = depLevelEmgcDataMap.get(resp.getDeptLevel());
|
for(EmergencyExecuteNumDetailRPCResp detail : resp.getDetail()){
|
if(detail == null)
|
continue;
|
dataBO.setPracticeCount(dataBO.getPracticeCount()+detail.getNum());
|
}
|
}
|
for(EmergencyExecuteTimeRPCResp resp : emgcExecTimeRespList){
|
if(resp == null)
|
continue;
|
if(!depLevelEmgcDataMap.containsKey(resp.getDeptLevel())){
|
EmergencyCountBO emergencyCountBO = new EmergencyCountBO();
|
emergencyCountBO.setDepLevel(resp.getDeptLevel());
|
depLevelEmgcDataMap.put(resp.getDeptLevel(), emergencyCountBO);
|
}
|
EmergencyCountBO dataBO = depLevelEmgcDataMap.get(resp.getDeptLevel());
|
LocalDateTime lastTime = DateUtil.parseLocalDateTime(resp.getLastTime());
|
if(dataBO.getLastPracticeTime() == null){
|
dataBO.setLastPracticeTime(lastTime);
|
}else if(dataBO.getLastPracticeTime().isBefore(lastTime)){
|
dataBO.setLastPracticeTime(lastTime);
|
}
|
}
|
emergencyDataBO.setPracticeData(new ArrayList<>());
|
depLevelEmgcDataMap.forEach((depLevel,dataBO)->{
|
if(dataBO != null){
|
emergencyDataBO.getPracticeData().add(dataBO);
|
}
|
});
|
return emergencyDataBO;
|
}
|
|
}
|
