package com.ruoyi.doublePrevention.service.impl;
|
|
import com.ruoyi.doublePrevention.entity.DoublePreventDept;
|
import com.ruoyi.doublePrevention.entity.dto.DataCountDangerLevelRectifiedRespDO;
|
import com.ruoyi.doublePrevention.entity.dto.DataCountDangerLevelRespDO;
|
import com.ruoyi.doublePrevention.entity.dto.DataCountDangerResultRespDO;
|
import com.ruoyi.doublePrevention.entity.dto.req.SPIDataCountReqDTO;
|
import com.ruoyi.doublePrevention.entity.dto.resp.SPIDataCountRespDTO;
|
import com.ruoyi.doublePrevention.repository.param.DataCountStartAndEndTimeParams;
|
import com.ruoyi.doublePrevention.service.SPIDataCountService;
|
import com.ruoyi.doublePrevention.service.baseService.DoublePreventionDeptService;
|
import com.ruoyi.doublePrevention.service.baseService.PreventRiskDangerInfoService;
|
import com.ruoyi.doublePrevention.service.baseService.TrHiddenDangerCheckPointService;
|
import com.ruoyi.doublePrevention.vo.ResultVO;
|
import io.swagger.models.auth.In;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service("SPIDataCountService")
|
public class SPIDataCountServiceImpl implements SPIDataCountService {
|
|
|
@Autowired
|
private DoublePreventionDeptService doublePreventionDeptService;
|
|
@Autowired
|
private PreventRiskDangerInfoService preventRiskDangerInfoService;
|
|
@Autowired
|
private TrHiddenDangerCheckPointService checkPointService;
|
|
|
/**
|
* 数据统计-隐患数据统计-根据月或者年
|
*/
|
@Override
|
public ResultVO<SPIDataCountRespDTO> listDangerResultCountByMonthOrYear(SPIDataCountReqDTO spiDataCountReqDTO) {
|
ResultVO<SPIDataCountRespDTO> parameterVerificationResult = parameterVerification(spiDataCountReqDTO);
|
if ("400".equals(parameterVerificationResult.getCode())){
|
return parameterVerificationResult;
|
}
|
Integer month = spiDataCountReqDTO.getMonth();
|
Integer year = spiDataCountReqDTO.getYear();
|
|
Long depId = spiDataCountReqDTO.getDepId();
|
//获取部门信息
|
DoublePreventDept depInfoByDepId = doublePreventionDeptService.getDepInfoByDepId(depId);
|
//获取部门及所有子部门信息
|
//祖级列表
|
String ancestors = depInfoByDepId.getAncestors();
|
ancestors = ancestors + ",";
|
List<Long> depIds = doublePreventionDeptService.listDepAndSubDepIds(ancestors);
|
depIds.add(depId);
|
if (CollectionUtils.isEmpty(depIds)){
|
throw new RuntimeException("部门不存在");
|
}
|
|
DataCountDangerResultRespDO resultCountByTime = null;
|
DataCountDangerLevelRespDO levelCountByTime = null;
|
DataCountDangerLevelRectifiedRespDO levelRectifiedCountByTime = null;
|
|
if (ObjectUtils.isNotEmpty(month) && ObjectUtils.isNotEmpty(year)){
|
DataCountStartAndEndTimeParams params = timeInterval(month, year);
|
// 月-统计时间段内所有、死亡、重伤、轻伤的隐患数量
|
resultCountByTime = preventRiskDangerInfoService.listDangerResultCountByTime(params.getStartTime(), params.getEndTime(), depIds);
|
|
// 月-统计时间段内一般、重大的隐患数量
|
levelCountByTime = checkPointService.listDangerLevelCountByTime(params.getStartTime(), params.getEndTime(), depIds);
|
|
// 月-统计时间段内一般已整改、重大已整改的隐患数量
|
levelRectifiedCountByTime = checkPointService.listDangerLevelRectifiedCountByTime(params.getStartTime(), params.getEndTime(), depIds);
|
}else {
|
DataCountStartAndEndTimeParams params = timeInterval(null, year);
|
// 年-统计时间段内所有、死亡、重伤、轻伤的隐患数量
|
resultCountByTime = preventRiskDangerInfoService.listDangerResultCountByTime(params.getStartTime(), params.getEndTime(), depIds);
|
|
// 年-统计时间段内一般、重大的隐患数量
|
levelCountByTime = checkPointService.listDangerLevelCountByTime(params.getStartTime(), params.getEndTime(), depIds);
|
|
// 年-统计时间段内一般已整改、重大已整改的隐患数量
|
levelRectifiedCountByTime = checkPointService.listDangerLevelRectifiedCountByTime(params.getStartTime(), params.getEndTime(), depIds);
|
}
|
if (resultCountByTime == null || levelCountByTime == null || levelRectifiedCountByTime == null){
|
parameterVerificationResult.setCode("400");
|
parameterVerificationResult.setMsg("数据统计异常");
|
return parameterVerificationResult;
|
}
|
SPIDataCountRespDTO spiDataCountRespDTO = new SPIDataCountRespDTO();
|
BeanUtils.copyProperties(resultCountByTime,spiDataCountRespDTO);
|
BeanUtils.copyProperties(levelCountByTime,spiDataCountRespDTO);
|
BeanUtils.copyProperties(levelRectifiedCountByTime,spiDataCountRespDTO);
|
BeanUtils.copyProperties(spiDataCountReqDTO,spiDataCountRespDTO);
|
spiDataCountRespDTO.setDep(depInfoByDepId.getDeptName());
|
parameterVerificationResult.setData(spiDataCountRespDTO);
|
return parameterVerificationResult;
|
}
|
|
|
/**
|
* @description 参数校验
|
*/
|
private ResultVO<SPIDataCountRespDTO> parameterVerification(SPIDataCountReqDTO spiDataCountReqDTO){
|
ResultVO resultVO = new ResultVO<>();
|
resultVO.setCode("200");
|
resultVO.setMsg("查询成功");
|
if (ObjectUtils.isEmpty(spiDataCountReqDTO)){
|
resultVO.setCode("400");
|
resultVO.setMsg("参数为空，查询失败");
|
return resultVO;
|
}
|
|
if (ObjectUtils.isEmpty(spiDataCountReqDTO.getMonth())){
|
if (ObjectUtils.isEmpty(spiDataCountReqDTO.getYear())){
|
resultVO.setCode("400");
|
resultVO.setMsg("查询年份不能为空");
|
return resultVO;
|
}
|
}else {
|
if (ObjectUtils.isEmpty(spiDataCountReqDTO.getYear())){
|
resultVO.setCode("400");
|
resultVO.setMsg("查询年份不能为空");
|
return resultVO;
|
}
|
}
|
|
if (ObjectUtils.isNotEmpty(spiDataCountReqDTO.getDepId())){
|
DoublePreventDept depInfoByDepId = doublePreventionDeptService.getDepInfoByDepId(spiDataCountReqDTO.getDepId());
|
if (depInfoByDepId == null){
|
resultVO.setCode("400");
|
resultVO.setMsg("查询的部门不存在");
|
return resultVO;
|
}
|
}
|
return resultVO;
|
}
|
|
|
|
/**
|
* 数据统计-统计时间处理:根据传参判断是否为统计月还是统计年,月份为空表明是统计年 月份不为空表明是统计月
|
*/
|
private DataCountStartAndEndTimeParams timeInterval(Integer month, Integer year){
|
|
//确定结束时间
|
Calendar calendar = Calendar.getInstance();
|
int nowYear = calendar.get(Calendar.YEAR);
|
Date startTime = null;
|
Date endTime = null;
|
if (month == null){
|
//说明统计的是当前年份
|
if (nowYear == year){
|
endTime =calendar.getTime();
|
|
calendar.clear();
|
calendar.set(Calendar.YEAR,nowYear);
|
startTime = calendar.getTime();
|
|
}else {
|
calendar.clear();
|
calendar.set(Calendar.YEAR,year);
|
startTime = calendar.getTime();
|
|
calendar.set(Calendar.YEAR,year+1);
|
calendar.set(Calendar.DAY_OF_YEAR,-1);
|
calendar.set(Calendar.SECOND,59);
|
calendar.set(Calendar.MINUTE,59);
|
calendar.set(Calendar.HOUR_OF_DAY,23);
|
endTime = calendar.getTime();
|
|
}
|
//统计的是指定月份
|
}else{
|
calendar.set(year, month - 1, 1);
|
calendar.set(Calendar.SECOND,0);
|
calendar.set(Calendar.MINUTE,0);
|
calendar.set(Calendar.HOUR_OF_DAY,0);
|
startTime = calendar.getTime();
|
|
calendar.set(Calendar.DATE,calendar.getActualMaximum(Calendar.DATE)); //指定月份的最后一天
|
calendar.set(Calendar.SECOND,59);
|
calendar.set(Calendar.MINUTE,59);
|
calendar.set(Calendar.HOUR_OF_DAY,23);
|
endTime = calendar.getTime();
|
|
}
|
DataCountStartAndEndTimeParams params = new DataCountStartAndEndTimeParams();
|
params.setStartTime(startTime);
|
params.setEndTime(endTime);
|
return params;
|
}
|
|
|
}
|
