修改获取数据量

src/main/java/com/zhiwei/manage/util/ESUtil.java

@@ -189,11 +189,15 @@ public class ESUtil {
 		Calendar endTime = Calendar.getInstance();
 		endTime.setTime(end);
 //		endTime.add(Calendar.HOUR, -8);
+		Client esClient=null;
 		try {
-			Client esClient = new ESClient(ser.getDbName(), ser.getDbHost(), ser.getDbPort()).getClient();
+			if (DbDepot.esClients.get(ser.getPt()) == null) {
+				esClient = new ESClient(ser.getDbName(), ser.getDbHost(), ser.getDbPort()).getClient();
+				DbDepot.esClients.put(ser.getPt(), esClient);
+			} else {
+				esClient = (Client) DbDepot.esClients.get(ser.getPt());
+			}
 			// 搜索数据
-			System.out.println(pt);
-			System.out.println(ser.getCollection());
 			SearchRequestBuilder srb = esClient.prepareSearch(ser.getCollection());
 			BoolQueryBuilder bb = new BoolQueryBuilder();
 			srb.setQuery(bb);
@@ -203,7 +207,6 @@ public class ESUtil {
 			srb.setSize(1);
 			SearchResponse response = srb.execute().actionGet();
 			SearchHits searchHits = response.getHits();
-			esClient.close();
 			return (int) searchHits.getTotalHits();
 		} catch (Exception e) {
 			log.error("es检索出错，错误信息【{}】", e);
@@ -227,8 +230,14 @@ public class ESUtil {
 		Calendar endTime = Calendar.getInstance();
 		endTime.setTime(end);
 		endTime.add(Calendar.HOUR, -8);
+		Client esClient=null;
 		try {
-			Client esClient = new ESClient(ser.getDbName(), ser.getDbHost(), ser.getDbPort()).getClient();
+			if (DbDepot.esClients.get(ser.getPt()) == null) {
+				esClient = new ESClient(ser.getDbName(), ser.getDbHost(), ser.getDbPort()).getClient();
+				DbDepot.esClients.put(ser.getPt(), esClient);
+			} else {
+				esClient = (Client) DbDepot.esClients.get(ser.getPt());
+			}
 			// 搜索数据
 			SearchRequestBuilder srb = esClient.prepareSearch(ser.getCollection());
 			BoolQueryBuilder bb = new BoolQueryBuilder();