Commit a2e010bb authored by duwei's avatar duwei

空放时长接口开发

parent 2a5e6692
...@@ -277,26 +277,28 @@ public class RunningEvaluateServiceImpl implements RunningEvaluateService { ...@@ -277,26 +277,28 @@ public class RunningEvaluateServiceImpl implements RunningEvaluateService {
RunningEvaluateStatusVO runningEvaluateStatusVO = new RunningEvaluateStatusVO(); RunningEvaluateStatusVO runningEvaluateStatusVO = new RunningEvaluateStatusVO();
String crossId = bo.getCrossId(); String crossId = bo.getCrossId();
int status = statusEnum.getCode(); int status = statusEnum.getCode();
// 构造入参开始和结束时间戳 //1. 构造入参开始和结束时间戳
Date startDate = bo.getStartDate(); Date startDate = bo.getStartDate();
Date endDate = bo.getEndDate(); Date endDate = bo.getEndDate();
endDate = DateUtil.offsetDay(endDate, 1); // 包含最后一天 endDate = DateUtil.offsetDay(endDate, 1); // 包含最后一天
int startStamp = (int) (startDate.getTime() / 1000); // 10位时间戳 int startStamp = (int) (startDate.getTime() / 1000); // 10位时间戳
int endStamp = (int) (endDate.getTime() / 1000); int endStamp = (int) (endDate.getTime() / 1000);
//查询路口统计表 t_cross_data_hist //2. 查询路口统计表 t_cross_data_hist
List<RunningEvaluateIndexStatusVO> runningEvaluateIndexStatusVOS = buildRes(bo, crossId, status); List<RunningEvaluateIndexStatusVO> runningEvaluateIndexStatusVOS = buildRes(bo, crossId, status);
runningEvaluateStatusVO.setRunningEvaluateIndexStatusVOList(runningEvaluateIndexStatusVOS); runningEvaluateStatusVO.setRunningEvaluateIndexStatusVOList(runningEvaluateIndexStatusVOS);
// 获取问题列表 //3. 获取问题列表
// 路口级别全量数据 // 路口级别全量数据
List<MetricHistDTO> crossDTOList = crossDataHistMapper.selectMetricHistDTO( List<MetricHistDTO> crossDTOList = crossDataHistMapper.selectMetricHistDTO(
crossId, startStamp, endStamp); crossId, startStamp, endStamp);
// 过滤有问题的记录
//4. 过滤有问题的记录
List<MetricHistDTO> filteredList = crossDTOList.stream() List<MetricHistDTO> filteredList = crossDTOList.stream()
.filter(metricHistDTO -> metricHistDTO.getStatus() != null && metricHistDTO.getStatus().equals(status)) .filter(metricHistDTO -> metricHistDTO.getStatus() != null && metricHistDTO.getStatus().equals(status))
.collect(Collectors.toList()); .collect(Collectors.toList());
//5. 整合数据
runningEvaluateStatusVO.setProblemStatusList(buildProblemStatusList(filteredList)); runningEvaluateStatusVO.setProblemStatusList(buildProblemStatusList(filteredList));
runningEvaluateStatusVO.setTimeList(TimeArrayUtil.getMinuteSectionArray(5)); runningEvaluateStatusVO.setTimeList(TimeArrayUtil.getMinuteSectionArray(5));
...@@ -614,7 +616,7 @@ public class RunningEvaluateServiceImpl implements RunningEvaluateService { ...@@ -614,7 +616,7 @@ public class RunningEvaluateServiceImpl implements RunningEvaluateService {
Integer duration1 = metricHistDTO.getDuration(); Integer duration1 = metricHistDTO.getDuration();
DateTime endTime = DateUtil.offsetMinute(startTime1, duration1); DateTime endTime = DateUtil.offsetMinute(startTime1, duration1);
problemStatus.setEndTime(endTime); problemStatus.setEndTime(endTime);
problemStatus.setDurationMinutes(duration1/60);// 计算持续时间(分钟) problemStatus.setDurationMinutes(duration1/60);// todo 计算持续时间(分钟)
res.add(problemStatus); res.add(problemStatus);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment