Authored by FengRuwei

改为由前端拆分,后端直接处理

... ... @@ -74,7 +74,7 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
public JavaApiStaticsModel selectlatestJavaApiStatics(String influxDBName, JavaApiStatusReq param) {
int api_id = param.getServiceId();
int mobj_id = param.getMObjectId();
String sql = "select * from " + InfluxDBContants.YOMO_TB_JAVAAPI + " where time > now() - 1h ";
String sql = "select * from " + InfluxDBContants.YOMO_TB_JAVAAPI + " where time > now() - 10m ";
sql += " and api_id=" + api_id;
sql += " and mobj_id=" + mobj_id;
sql += " order by time desc limit 1";
... ... @@ -135,19 +135,20 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
List<JavaApiStaticsModel> javaApiStaticsModels = new ArrayList<JavaApiStaticsModel>();
List<JavaApiStatusReq> splitReqList = new ArrayList<JavaApiStatusReq>();
for (JavaApiStatusReq param : paramList) {
splitReqList.add(param);
if (splitReqList.size() >= 15) {
javaApiStaticsModels.addAll(selectlatestJavaApiStaticsList_batch_split(influxDBName, splitReqList));
splitReqList.clear();
}
}
if (splitReqList.size() > 0) {
javaApiStaticsModels.addAll(selectlatestJavaApiStaticsList_batch_split(influxDBName, splitReqList));
}
// List<JavaApiStatusReq> splitReqList = new ArrayList<JavaApiStatusReq>();
// for (JavaApiStatusReq param : paramList) {
// splitReqList.add(param);
// if (splitReqList.size() >= 15) {
// javaApiStaticsModels.addAll(selectlatestJavaApiStaticsList_batch_split(influxDBName, splitReqList));
// splitReqList.clear();
// }
// }
// if (splitReqList.size() > 0) {
// javaApiStaticsModels.addAll(selectlatestJavaApiStaticsList_batch_split(influxDBName, splitReqList));
// }
return javaApiStaticsModels;
// return javaApiStaticsModels;
return selectlatestJavaApiStaticsList_batch_split(influxDBName,paramList);
}
... ... @@ -159,7 +160,7 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
for (JavaApiStatusReq param : paramList) {
int api_id = param.getServiceId();
int mobj_id = param.getMObjectId();
sb.append("select api_id,mobj_id,start_time,end_time,is_exception,exception from " + InfluxDBContants.YOMO_TB_JAVAAPI + " where time > now() - 1h ");
sb.append("select api_id,mobj_id,start_time,end_time,is_exception,exception from " + InfluxDBContants.YOMO_TB_JAVAAPI + " where time > now() - 10m ");
sb.append(" and api_id=" + api_id);
sb.append(" and mobj_id=" + mobj_id);
sb.append(" order by time desc limit 1;");
... ...