Commit a6d7c4c0 authored by suhuiguang's avatar suhuiguang

1.大屏-监管-左侧设备状态情况统计,统计数量不对bug修改

parent 2ccf72cf
...@@ -689,20 +689,19 @@ public class JGDPStatisticsServiceImpl { ...@@ -689,20 +689,19 @@ public class JGDPStatisticsServiceImpl {
} }
public List<Map<String, Object>> equStateCount(DPFilterParamDto dpFilterParamDto) { public List<Map<String, Object>> equStateCount(DPFilterParamDto dpFilterParamDto) {
List<Map<String, Object>> resultList = new ArrayList<>(); List<Map<String, Object>> resultList;
SearchRequest request = new SearchRequest(); SearchRequest request = new SearchRequest();
request.indices("idx_biz_view_jg_all"); request.indices("idx_biz_view_jg_all");
BoolQueryBuilder boolMust = QueryBuilders.boolQuery(); BoolQueryBuilder boolMust = QueryBuilders.boolQuery();
String orgCode = stCommonService.getAndSetOrgCode(dpFilterParamDto.getCityCode()); String orgCode = stCommonService.getAndSetOrgCode(dpFilterParamDto.getCityCode());
if (orgCode == null) { if (orgCode == null) {
this.setDefaultEquStateCount(resultList); return this.setDefaultEquStateCount();
return resultList;
} }
// 按照管辖机构区域信息模糊查询 // 按照管辖机构区域信息模糊查询
boolMust.must(QueryBuilders.wildcardQuery("ORG_BRANCH_CODE.keyword", QueryParser.escape(orgCode) + "*")); boolMust.must(QueryBuilders.wildcardQuery("ORG_BRANCH_CODE.keyword", QueryParser.escape(orgCode) + "*"));
SearchSourceBuilder builder = new SearchSourceBuilder(); SearchSourceBuilder builder = new SearchSourceBuilder();
builder.query(boolMust); builder.query(boolMust);
TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms("EQU_STATE_COUNT").field("EQU_STATE"); TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms("EQU_STATE_COUNT").field("EQU_STATE").size(20);
builder.aggregation(aggregationBuilder); builder.aggregation(aggregationBuilder);
request.source(builder); request.source(builder);
try { try {
...@@ -714,17 +713,12 @@ public class JGDPStatisticsServiceImpl { ...@@ -714,17 +713,12 @@ public class JGDPStatisticsServiceImpl {
long docCount = bucket.getDocCount(); long docCount = bucket.getDocCount();
dataMap.put(category, docCount); dataMap.put(category, docCount);
} }
/** resultList = Arrays.stream(EquimentEnum.values()).filter(e->e.getCode() > 0).map(e->{
* 3 报废 Map<String, Object> map = new HashMap<>();
* 1 在用 map.put("name", e.getName());
* 2 停用 map.put("value", dataMap.getOrDefault(e.getCode().toString(), 0L));
* 4 注销 return map;
*/ }).collect(Collectors.toList());
for (int i = 0; i < 4; i++) {
Map<String, Object> map = setEquStateNameValue(i);
map.put("value", dataMap.getOrDefault(String.valueOf(i), 0L));
resultList.add(map);
}
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
...@@ -732,26 +726,13 @@ public class JGDPStatisticsServiceImpl { ...@@ -732,26 +726,13 @@ public class JGDPStatisticsServiceImpl {
return resultList; return resultList;
} }
private Map<String, Object> setEquStateNameValue(int i) { private List<Map<String, Object>> setDefaultEquStateCount() {
Map<String, Object> map = new LinkedHashMap<>(); return Arrays.stream(EquimentEnum.values()).filter(e->e.getCode() > 0).map(e->{
if (i == 0) { Map<String, Object> map = new HashMap<>();
map.put("name", "在用"); map.put("name", e.getName());
} else if (i == 1) {
map.put("name", "停用");
} else if (i == 2) {
map.put("name", "报废");
} else {
map.put("name", "注销");
}
return map;
}
private void setDefaultEquStateCount(List<Map<String, Object>> resultList) {
for (int i = 0; i < 4; i++) {
Map<String, Object> map = setEquStateNameValue(i);
map.put("value", 0L); map.put("value", 0L);
resultList.add(map); return map;
} }).collect(Collectors.toList());
} }
public Map<String, Object> equStopStateCount(DPFilterParamDto dpFilterParamDto) { public Map<String, Object> equStopStateCount(DPFilterParamDto dpFilterParamDto) {
......
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