...
|
...
|
@@ -2,6 +2,7 @@ package com.monitor.influxdb.mapper.impl; |
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.monitor.common.contants.InfluxDBContants;
|
|
|
import com.monitor.common.util.DateFormatUtil;
|
|
|
import com.monitor.influxdb.InluxDBSingle;
|
|
|
import com.monitor.influxdb.mapper.IJavaApiStaticsMapper;
|
|
|
import com.monitor.model.domain.JavaApiStaticsModel;
|
...
|
...
|
@@ -91,9 +92,20 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper { |
|
|
QueryResult.Series series = rel.getSeries().get(0);
|
|
|
|
|
|
Boolean is_exception = (Boolean) series.getValues().get(0).get(series.getColumns().indexOf("is_exception"));
|
|
|
long startTime = Math.round((Double) series.getValues().get(0).get(series.getColumns().indexOf("start")));
|
|
|
long endTime = Math.round((Double) series.getValues().get(0).get(series.getColumns().indexOf("end")));
|
|
|
long costTime = (endTime - startTime);
|
|
|
|
|
|
String exception = (String) series.getValues().get(0).get(series.getColumns().indexOf("exception"));
|
|
|
|
|
|
javaApiStaticsModel.setStartTime(DateFormatUtil.parseLongTo14(startTime));
|
|
|
javaApiStaticsModel.setEndTime(DateFormatUtil.parseLongTo14(endTime));
|
|
|
|
|
|
javaApiStaticsModel.setCostTime((int) costTime);
|
|
|
|
|
|
if (is_exception == true) {
|
|
|
javaApiStaticsModel.setStatus(0);
|
|
|
javaApiStaticsModel.setException(exception);
|
|
|
} else
|
|
|
javaApiStaticsModel.setStatus(1);
|
|
|
|
...
|
...
|
|