|
@@ -349,17 +349,19 @@ public class BizObjMetricsServiceImpl implements IBizObjMetricsService {
|
|
|
mList.stream().filter(om -> !"1".equals(om.getMetricsDef().getMetricsType())).forEach(om -> {
|
|
|
//非pinpoint
|
|
|
Float value = prometheusService.query(om.getDataExp());
|
|
|
- String alarmLevel = getAlarmLevel(value, om);
|
|
|
- om.setDValue(BigDecimal.valueOf(value));
|
|
|
+ if (value != null) {
|
|
|
+ String alarmLevel = getAlarmLevel(value, om);
|
|
|
+ om.setDValue(BigDecimal.valueOf(value));
|
|
|
|
|
|
- if (alarmLevel != null) {
|
|
|
- insertAlarm(om, alarmLevel);
|
|
|
+ if (alarmLevel != null) {
|
|
|
+ insertAlarm(om, alarmLevel);
|
|
|
+ }
|
|
|
+ BizObjMetricsData data = new BizObjMetricsData();
|
|
|
+ data.setObjMetricsId(om.getObjMetricsId());
|
|
|
+ data.setdValue(om.getDValue());
|
|
|
+ metricsDataService.insertBizObjMetricsData(data);
|
|
|
+ metricsToUpdate.add(om);
|
|
|
}
|
|
|
- BizObjMetricsData data = new BizObjMetricsData();
|
|
|
- data.setObjMetricsId(om.getObjMetricsId());
|
|
|
- data.setdValue(om.getDValue());
|
|
|
- metricsDataService.insertBizObjMetricsData(data);
|
|
|
- metricsToUpdate.add(om);
|
|
|
});
|
|
|
// 更新所有需要更新的BizObjMetrics对象
|
|
|
metricsToUpdate.forEach(this::updateBizObjMetrics);
|