| | |
|---|
| | | if (reqDTO == null && reqDTO .getCountTime() == null) |
|---|
| | | throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL,"参数不能为空"); |
|---|
| | | Integer countTime = reqDTO.getCountTime(); |
|---|
| | | WindRoseTimeSlotQuery query = WindRoseEnum.getQueryObject(countTime).getTimeSlotByStrategy(); |
|---|
| | | List<GasConcentration> gasConcentrations; |
|---|
| | | if (reqDTO.getCountTime().equals(WindRoseEnum.CUSTOM_TIME.getState())){ |
|---|
| | | if (reqDTO.getStartTime() == null && reqDTO.getEndTime() == null) |
|---|
| | | throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL,"参数不能为空"); |
|---|
| | | gasConcentrations = gasConcentrationRepository.findAllByDataReceivingTimeBetweenOrderByDataReceivingTimeDesc(reqDTO.getStartTime(), reqDTO.getEndTime()); |
|---|
| | | }else { |
|---|
| | | WindRoseTimeSlotQuery query = WindRoseEnum.getQueryObject(countTime).getTimeSlotByStrategy(); |
|---|
| | | gasConcentrations = gasConcentrationRepository.findAllByDataReceivingTimeBetweenOrderByDataReceivingTimeDesc(query.getStartTime(), query.getEndTime()); |
|---|
| | | } |
|---|
| | | Result result = Result.success(); |
|---|
| | | List<GasConcentration> gasConcentrations = gasConcentrationRepository.findAllByDataReceivingTimeBetweenOrderByDataReceivingTimeDesc(query.getStartTime(), query.getEndTime()); |
|---|
| | | if (CollectionUtils.isEmpty(gasConcentrations)) |
|---|
| | | return result; |
|---|
| | | List<WindRoseByTimeRespDTO> collect = gasConcentrations.stream().map(gasConcentration -> { |
|---|
