From 0414ddb0b2b3a7199ae6181a770f97ac140dbd73 Mon Sep 17 00:00:00 2001 From: zhangf <1603559716@qq.com> Date: 星期三, 08 五月 2024 16:46:22 +0800 Subject: [PATCH] spi统计 --- emergency/emergency-service/src/main/java/com/gkhy/safePlatform/emergency/service/baseService/impl/EmergencyDrillExecuteInfoServiceImpl.java | 77 ++++++++++++++++++++++++++++++++++++-- 1 files changed, 73 insertions(+), 4 deletions(-) diff --git a/emergency/emergency-service/src/main/java/com/gkhy/safePlatform/emergency/service/baseService/impl/EmergencyDrillExecuteInfoServiceImpl.java b/emergency/emergency-service/src/main/java/com/gkhy/safePlatform/emergency/service/baseService/impl/EmergencyDrillExecuteInfoServiceImpl.java index 9f48ac1..1627f7e 100644 --- a/emergency/emergency-service/src/main/java/com/gkhy/safePlatform/emergency/service/baseService/impl/EmergencyDrillExecuteInfoServiceImpl.java +++ b/emergency/emergency-service/src/main/java/com/gkhy/safePlatform/emergency/service/baseService/impl/EmergencyDrillExecuteInfoServiceImpl.java @@ -2,10 +2,10 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.gkhy.safePlatform.emergency.entity.EmergencyDrillExecuteCountData; -import com.gkhy.safePlatform.emergency.entity.EmergencyDrillExecuteInfo; -import com.gkhy.safePlatform.emergency.entity.EmergencyDrillExecuteInfoDetailDO; -import com.gkhy.safePlatform.emergency.entity.EmergencyDrillExecuteInfoPageDO; +import com.gkhy.safePlatform.commons.utils.StringUtils; +import com.gkhy.safePlatform.emergency.entity.*; +import com.gkhy.safePlatform.emergency.enums.EmergencyResultCodes; +import com.gkhy.safePlatform.emergency.excepiton.EmergencyException; import com.gkhy.safePlatform.emergency.query.db.EmergencyDrillExecuteDBQuery; import com.gkhy.safePlatform.emergency.repository.EmergencyDrillExecuteInfoRepository; import com.gkhy.safePlatform.emergency.service.baseService.EmergencyDrillExecuteInfoService; @@ -65,4 +65,73 @@ return emergencyDrillExecuteInfoRepository.selectByYearAndDept(startTime,endTime,deptIds); } + @Override + public List<EmergencyDrillExecuteCountRPC> selectByDayAndDept(String startTime, String endTime, List<Long> deptIds) { + return emergencyDrillExecuteInfoRepository.selectByDayAndDept(startTime,endTime,deptIds); + } + + @Override + public List<EmergencyDrillExecuteCountRPC> selectByMonthAndDeptForIntegerMonth(String startTime, String endTime, List<Long> deptIds) { + return emergencyDrillExecuteInfoRepository.selectByMonthAndDeptForIntegerMonth(startTime,endTime,deptIds); + } + + @Override + public String selectEmergencyDrillExecuteIntervalTimeByDeptId(Long deptId) { + return emergencyDrillExecuteInfoRepository.selectEmergencyDrillExecuteIntervalTimeByDeptId(deptId); + } + + @Override + public String getLastTimeByDeptId(Long deptId) { + if(null == deptId){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getLastTimeByDeptId(deptId); + } + + @Override + public List<EmergencyDrillExecuteLastTimeDO> getLastTimeByDeptIds(List<Long> deptIdList) { + if(null == deptIdList || deptIdList.size() == 0){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getLastTimeByDeptIds(deptIdList); + } + @Override + public List<EmergencyDrillExecuteLastTimeDO> getLastTimeByDeptIdsAndTime(List<Long> deptIdList,String startTime,String endTime) { + if(null == deptIdList || deptIdList.size() == 0 || StringUtils.isBlank(startTime) || StringUtils.isBlank(endTime)){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getLastTimeByDeptIdsAndTime(deptIdList,startTime,endTime); + } + + @Override + public String getLastTimeByDeptIdAndTime(Long deptId, String startTime, String endTime) { + if(null == deptId || StringUtils.isBlank(startTime) || StringUtils.isBlank(endTime)){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getLastTimeByDeptIdAndTime(deptId,startTime,endTime); + } + + @Override + public List<EmergencyExecuteCountDO> getCountByDeptIdsAndTime(String startTime, String endTime, List<Long> deptIds) { + if(null == deptIds || StringUtils.isBlank(startTime) || StringUtils.isBlank(endTime) || deptIds.size() == 0){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getCountByDeptIdsAndTime(startTime,endTime,deptIds); + } + @Override + public EmergencyExecuteCountDO getCountByDeptIdAndMonth(Integer year,Integer month, Long deptId) { + if(null == deptId || null == year || null == month ){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getCountByDeptIdAndMonth(year,month,deptId); + } + + @Override + public List<EmergencyExecuteCountDO> getCountByDeptIdAndYear(Integer year, Long deptId) { + if(null == deptId || null == year){ + throw new EmergencyException(EmergencyResultCodes.SUPPLIES_PARAM_NULL); + } + return baseMapper.getCountByDeptIdAndYear(year,deptId); + } + } -- Gitblit v1.9.2