prometheus数据入库

jjt-biz/src/main/java/com/jjt/biz/service/impl/BizObjMetricsServiceImpl.java

@@ -355,7 +355,10 @@ public class BizObjMetricsServiceImpl implements IBizObjMetricsService {
             if (alarmLevel != null) {
                 insertAlarm(om, alarmLevel);
             }
-
+            BizObjMetricsData data = new BizObjMetricsData();
+            data.setObjMetricsId(om.getObjMetricsId());
+            data.setdValue(om.getDValue());
+            metricsDataService.insertBizObjMetricsData(data);
             metricsToUpdate.add(om);
         });
         // 更新所有需要更新的BizObjMetrics对象

jjt-biz/src/main/java/com/jjt/biz/service/impl/PrometheusServiceImpl.java

@@ -44,13 +44,12 @@ public class PrometheusServiceImpl implements IPrometheusService {
     @Override
     public Float query(String param) {
         if (StringUtils.isNotEmpty(param)) {
-
             String uri = baseUri() + "/api/v1/query?query=";
             uri += UriEncoder.encode(param);
             String result = HttpUtils.sendGet(uri);
             JSONObject jsonObject = JSONObject.parseObject(result);
-            JSONArray array = jsonObject.getJSONObject("data").getJSONArray("result");
             try {
+                JSONArray array = jsonObject.getJSONObject("data").getJSONArray("result");
                 JSONArray value = array.getJSONObject(0).getJSONArray("value");
                 DecimalFormat df = new DecimalFormat("#0.00");
                 return Float.parseFloat(df.format(value.getFloat(1)));