|
@@ -47,7 +47,6 @@ import static cn.com.taiji.constants.EsIndexConstants.*;
|
|
|
* @author xhl
|
|
|
* @date 2023/2/6
|
|
|
*/
|
|
|
-@Slf4j
|
|
|
@Service
|
|
|
public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
|
|
@@ -67,10 +66,10 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder.query(boolQueryBuilder);
|
|
|
TermsAggregationBuilder aggBuilder = AggregationBuilders.terms("ship_field_agg")
|
|
|
.field("mergeTarget")
|
|
|
- .size(0)
|
|
|
+ .size(1000000)
|
|
|
.subAggregation(
|
|
|
AggregationBuilders.topHits("ship_field_agg_top1")
|
|
|
- .size(0)
|
|
|
+ .size(100)
|
|
|
.sort(
|
|
|
SortBuilders.fieldSort("mergeTime").order(SortOrder.ASC)
|
|
|
)
|
|
@@ -78,7 +77,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder
|
|
|
.trackTotalHits(true)
|
|
|
.aggregation(aggBuilder)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request.source(searchSourceBuilder);
|
|
|
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
|
|
|
Aggregations aggregations = search.getAggregations();
|
|
@@ -120,7 +119,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
.doWrite(list);
|
|
|
} catch (Exception e) {
|
|
|
// 重置response
|
|
|
- log.info("导出识别融合数据率波动问题excel失败:{}" + e.getMessage() + e);
|
|
|
+ System.out.println("导出识别融合数据率波动问题excel失败:{}" + e.getMessage() + e);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -137,17 +136,17 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder.query(boolQueryBuilder);
|
|
|
TermsAggregationBuilder aggBuilder = AggregationBuilders.terms("ship_field_agg")
|
|
|
.field("mergeTarget")
|
|
|
- .size(0)
|
|
|
+ .size(1000000)
|
|
|
.subAggregation(
|
|
|
AggregationBuilders.terms("ship_field_agg_one")
|
|
|
.field("targetCourse")
|
|
|
- .size(0)
|
|
|
+ .size(1000000)
|
|
|
.subAggregation(
|
|
|
AggregationBuilders.terms("ship_field_agg_two")
|
|
|
.field("targetSpeed")
|
|
|
- .size(0)
|
|
|
+ .size(1000000)
|
|
|
.subAggregation(AggregationBuilders.topHits("ship_field_agg_top1")
|
|
|
- .size(0)
|
|
|
+ .size(100)
|
|
|
.sort(
|
|
|
SortBuilders.fieldSort("mergeTime").order(SortOrder.ASC)
|
|
|
))
|
|
@@ -156,7 +155,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder
|
|
|
.trackTotalHits(true)
|
|
|
.aggregation(aggBuilder)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request.source(searchSourceBuilder);
|
|
|
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
|
|
|
Aggregations aggregations = search.getAggregations();
|
|
@@ -204,7 +203,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
.doWrite(list);
|
|
|
} catch (Exception e) {
|
|
|
// 重置response
|
|
|
- log.info("导出虚假推送问题excel失败:{}" + e.getMessage() + e);
|
|
|
+ System.out.println("导出虚假推送问题excel失败:{}" + e.getMessage() + e);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -222,11 +221,11 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder.query(boolQueryBuilder);
|
|
|
TermsAggregationBuilder aggBuilder = AggregationBuilders.terms("ship_field_agg")
|
|
|
.field("fusionBatchNum")
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
searchSourceBuilder
|
|
|
.trackTotalHits(true)
|
|
|
.aggregation(aggBuilder)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request.source(searchSourceBuilder);
|
|
|
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
|
|
|
Aggregations aggregations = search.getAggregations();
|
|
@@ -248,7 +247,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
boolQueryBuilder2.filter(QueryBuilders.termsQuery("mergeType","RADAR","AIS_RADAR","BEIDOU_RADAR","AIS_BEIDOU_RADAR"));
|
|
|
searchSourceBuilder2.query(boolQueryBuilder2)
|
|
|
.trackTotalHits(true)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request2.source(searchSourceBuilder2);
|
|
|
try {
|
|
|
SearchResponse search2 = client.search(request, RequestOptions.DEFAULT);
|
|
@@ -280,7 +279,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
.doWrite(list);
|
|
|
} catch (Exception e) {
|
|
|
// 重置response
|
|
|
- log.info("导出天奥轨迹数据遗漏excel失败:{}" + e.getMessage() + e);
|
|
|
+ System.out.println("导出天奥轨迹数据遗漏excel失败:{}" + e.getMessage() + e);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -298,11 +297,11 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder.query(boolQueryBuilder);
|
|
|
TermsAggregationBuilder aggBuilder = AggregationBuilders.terms("ship_field_agg")
|
|
|
.field("devideNo")
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
searchSourceBuilder
|
|
|
.trackTotalHits(true)
|
|
|
.aggregation(aggBuilder)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request.source(searchSourceBuilder);
|
|
|
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
|
|
|
Aggregations aggregations = search.getAggregations();
|
|
@@ -324,7 +323,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
boolQueryBuilder2.filter(QueryBuilders.termsQuery("mergeType","BEIDOU","AIS_BEIDOU","BEIDOU_RADAR","AIS_BEIDOU_RADAR"));
|
|
|
searchSourceBuilder2.query(boolQueryBuilder2)
|
|
|
.trackTotalHits(true)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request2.source(searchSourceBuilder2);
|
|
|
try {
|
|
|
SearchResponse search2 = client.search(request, RequestOptions.DEFAULT);
|
|
@@ -356,7 +355,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
.doWrite(list);
|
|
|
} catch (Exception e) {
|
|
|
// 重置response
|
|
|
- log.info("导出北斗轨迹数据遗漏excel失败:{}" + e.getMessage() + e);
|
|
|
+ System.out.println("导出北斗轨迹数据遗漏excel失败:{}" + e.getMessage() + e);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -374,11 +373,11 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder.query(boolQueryBuilder);
|
|
|
TermsAggregationBuilder aggBuilder = AggregationBuilders.terms("ship_field_agg")
|
|
|
.field("targetID")
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
searchSourceBuilder
|
|
|
.trackTotalHits(true)
|
|
|
.aggregation(aggBuilder)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request.source(searchSourceBuilder);
|
|
|
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
|
|
|
Aggregations aggregations = search.getAggregations();
|
|
@@ -400,7 +399,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
boolQueryBuilder2.filter(QueryBuilders.termsQuery("mergeType","AIS","RADAR","AIS_BEIDOU","AIS_RADAR","BEIDOU_RADAR","AIS_BEIDOU_RADAR"));
|
|
|
searchSourceBuilder2.query(boolQueryBuilder2)
|
|
|
.trackTotalHits(true)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request2.source(searchSourceBuilder2);
|
|
|
try {
|
|
|
SearchResponse search2 = client.search(request, RequestOptions.DEFAULT);
|
|
@@ -432,7 +431,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
.doWrite(list);
|
|
|
} catch (Exception e) {
|
|
|
// 重置response
|
|
|
- log.info("导出海兰信1级融合轨迹数据遗漏excel失败:{}" + e.getMessage() + e);
|
|
|
+ System.out.println("导出海兰信1级融合轨迹数据遗漏excel失败:{}" + e.getMessage() + e);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -451,11 +450,11 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
searchSourceBuilder.query(boolQueryBuilder);
|
|
|
TermsAggregationBuilder aggBuilder = AggregationBuilders.terms("ship_field_agg")
|
|
|
.field("fusionBatchNum")
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
searchSourceBuilder
|
|
|
.trackTotalHits(true)
|
|
|
.aggregation(aggBuilder)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request.source(searchSourceBuilder);
|
|
|
SearchResponse search = client.search(request, RequestOptions.DEFAULT);
|
|
|
Aggregations aggregations = search.getAggregations();
|
|
@@ -478,7 +477,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
boolQueryBuilder2.filter(QueryBuilders.termsQuery("mergeType","RADAR","AIS_RADAR","BEIDOU_RADAR","AIS_BEIDOU_RADAR"));
|
|
|
searchSourceBuilder2.query(boolQueryBuilder2)
|
|
|
.trackTotalHits(true)
|
|
|
- .size(0);
|
|
|
+ .size(1000000);
|
|
|
request2.source(searchSourceBuilder2);
|
|
|
try {
|
|
|
SearchResponse search2 = client.search(request, RequestOptions.DEFAULT);
|
|
@@ -503,7 +502,7 @@ public class FusionAnalysisServiceImpl implements FusionAnalysisService {
|
|
|
.doWrite(list);
|
|
|
} catch (Exception e) {
|
|
|
// 重置response
|
|
|
- log.info("导出天奥静态数据与动态轨迹融合excel失败:{}" + e.getMessage() + e);
|
|
|
+ System.out.println("导出天奥静态数据与动态轨迹融合excel失败:{}" + e.getMessage() + e);
|
|
|
}
|
|
|
}
|
|
|
}
|