|
@@ -471,6 +471,7 @@ public class ProjectDataRecordServiceImpl implements IProjectDataRecordService {
|
|
|
//冷却水组 日均 数据计算
|
|
|
computeTime = computeCoolWaterData(lastComputeTime, todayDate, projectDTO.getProjectId(), objId, indicatorType);
|
|
|
}
|
|
|
+ log.error("项目:"+projectDTO.getProjectId()+"~设备:"+objId+"~指标:"+infoCode+"~日期:"+lastComputeTime);
|
|
|
//计算 运行持续时长
|
|
|
computeAlarmDay(projectDTO.getProjectId(), objId, infoCode, indicatorType, lastComputeTime, todayDate, monitorIndicatorMap);
|
|
|
//更新计算 时间记录
|
|
@@ -548,6 +549,7 @@ public class ProjectDataRecordServiceImpl implements IProjectDataRecordService {
|
|
|
String tempFormula = thresholdConfig.getTempFormula();
|
|
|
if (!StringUtils.isBlank(operator) && !StringUtils.isBlank(tempFormula)) {
|
|
|
//获取报警开始时间
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+start);
|
|
|
Date startAlarmDate = getStartAlarmDate(start, projectId, objId, indicatorId, operator, tempFormula);
|
|
|
if (null != startAlarmDate) {
|
|
|
dayNum = com.persagy.apm.diagnose.utils.DateUtils.getDayNum(startAlarmDate, start);
|
|
@@ -578,19 +580,25 @@ public class ProjectDataRecordServiceImpl implements IProjectDataRecordService {
|
|
|
queryMonitorIndicatorRecordDTO.setTimeFrom(checkStartDate); // >
|
|
|
queryMonitorIndicatorRecordDTO.setTimeTo(alarmDate); // <=
|
|
|
List<MonitorIndicatorRecord> recordList = monitorIndicatorRecordService.queryMonitorIndicatorRecordList(queryMonitorIndicatorRecordDTO);
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+checkStartDate+"~"+alarmDate);
|
|
|
if (!CollectionUtils.isEmpty(recordList) && recordList.size() > 0) {
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+checkStartDate+"~"+alarmDate+"~数据量:"+recordList.size());
|
|
|
//倒序排
|
|
|
recordList.sort(Comparator.comparing(MonitorIndicatorRecord::getDataTime).reversed());
|
|
|
Date checkDate = alarmDate;
|
|
|
for (MonitorIndicatorRecord record : recordList) {
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+checkStartDate+"~"+alarmDate+"~数据值:"+record.getDataValue());
|
|
|
boolean isFlag = isAccordWith(operator, Double.valueOf(tempFormula), record.getDataValue());
|
|
|
if (!isFlag) {
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+checkStartDate+"~"+alarmDate+"~数据值:"+record.getDataValue()+"无报警"+"返回日期:"+record.getDataTime());
|
|
|
return record.getDataTime();
|
|
|
}
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+checkStartDate+"~"+alarmDate+"~数据值:"+record.getDataValue()+"报警"+"赋值日期:"+record.getDataTime());
|
|
|
checkDate = record.getDataTime();
|
|
|
}
|
|
|
+ log.error("项目:"+projectId+"~设备:"+objId+"~指标:"+indicatorId+"~operator:"+operator+"~tempFormula:"+tempFormula+"~日期:"+checkStartDate+"~"+alarmDate+"报警"+"赋值日期:"+checkDate);
|
|
|
//继续往前找报警开始日期
|
|
|
- return getStartAlarmDate(checkDate, projectId, objId, indicatorId, operator, tempFormula);
|
|
|
+ // return getStartAlarmDate(checkDate, projectId, objId, indicatorId, operator, tempFormula);
|
|
|
}
|
|
|
return alarmDate;
|
|
|
}
|