Commit 3eb37397 by zhiwei

提交无用字符,目的是重启程序

parent 6d2e7627
......@@ -30,7 +30,7 @@ import com.zhiwei.manage.util.Tools;
/**
* 数据控制
*
* @author admin
* @author admin
*
*/
@Controller
......
......@@ -241,25 +241,28 @@ public class ESUtil {
Calendar endTime = Calendar.getInstance();
endTime.setTime(end);
Client esClient=null;
try {
esClient = getClient(pt, ser);
// 搜索数据
SearchRequestBuilder srb = esClient.prepareSearch(ser.getCollection());
BoolQueryBuilder bb = new BoolQueryBuilder();
srb.setQuery(bb);
srb.setPostFilter(QueryBuilders.rangeQuery("time").gte(getNeedTime(startTime)).lte(getNeedTime(endTime)));
QueryBuilder matchQuery = QueryBuilders.matchPhraseQuery("spyderInfoId", spid);
bb.should(matchQuery);
srb.setSize(1);
SearchResponse response = srb.execute().actionGet();
SearchHits searchHits = response.getHits();
if(searchHits!=null) {
return (int) searchHits.getTotalHits();
for(int i=0;i<3;i++) {
try {
esClient = getClient(pt, ser);
// 搜索数据
SearchRequestBuilder srb = esClient.prepareSearch(ser.getCollection());
BoolQueryBuilder bb = new BoolQueryBuilder();
srb.setQuery(bb);
srb.setPostFilter(QueryBuilders.rangeQuery("time").gte(getNeedTime(startTime)).lte(getNeedTime(endTime)));
QueryBuilder matchQuery = QueryBuilders.matchPhraseQuery("spyderInfoId", spid);
bb.should(matchQuery);
srb.setSize(1);
SearchResponse response = srb.execute().actionGet();
SearchHits searchHits = response.getHits();
if(searchHits!=null) {
return (int) searchHits.getTotalHits();
}
return 0;
} catch (Exception e) {
log.error("es检索出错,错误信息【{}】", e.fillInStackTrace());
continue;
}
return 0;
} catch (Exception e) {
e.fillInStackTrace();
log.error("es检索出错,错误信息【{}】", e.fillInStackTrace());
}
return 0;
}
......@@ -281,23 +284,27 @@ public class ESUtil {
endTime.setTime(end);
endTime.add(Calendar.HOUR, -8);
Client esClient=null;
try {
esClient = getClient(pt, ser);
// 搜索数据
SearchRequestBuilder srb = esClient.prepareSearch(ser.getCollection());
BoolQueryBuilder bb = new BoolQueryBuilder();
srb.setQuery(bb);
addQuerys(pt, startTime, endTime, srb, bb);
srb.setSize(1);
SearchResponse response = srb.execute().actionGet();
SearchHits searchHits = response.getHits();
if(searchHits!=null) {
return (int) searchHits.getTotalHits();
for(int i=0;i<3;i++) {
try {
esClient = getClient(pt, ser);
// 搜索数据
SearchRequestBuilder srb = esClient.prepareSearch(ser.getCollection());
BoolQueryBuilder bb = new BoolQueryBuilder();
srb.setQuery(bb);
addQuerys(pt, startTime, endTime, srb, bb);
srb.setSize(1);
SearchResponse response = srb.execute().actionGet();
SearchHits searchHits = response.getHits();
if(searchHits!=null) {
return (int) searchHits.getTotalHits();
}
return 0;
} catch (Exception e) {
log.error("es检索出错,错误信息【{}】", e.fillInStackTrace());
continue;
}
return 0;
} catch (Exception e) {
log.error("es检索出错,错误信息【{}】", e.fillInStackTrace());
}
return 0;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment