fix(Statistics)：查询设备管理列表

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/controller/ZLDPStatisticsController.java

@@ -111,4 +111,12 @@ public class ZLDPStatisticsController {
         JSONObject jsonObject = new JSONObject(map);
         return ResponseHelper.buildResponse(statisticsService.queryByKeys(jsonObject));
     }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @PostMapping(value = "/viewEquipPage")
+    @ApiOperation(httpMethod = "POST", value = "查询设备管理列表", notes = "查询设备管理列表")
+    public ResponseModel<Page<JSONObject>> viewEquipPage(@RequestBody DPFilterParamForDetailDto paramDto) {
+        return ResponseHelper.buildResponse(statisticsService.viewEquipPage(paramDto));
+    }
+
 }

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/ZLDPStatisticsServiceImpl.java

@@ -924,4 +924,79 @@ public class ZLDPStatisticsServiceImpl {
         }
         return result;
     }
+
+    public Page<JSONObject> viewEquipPage(DPFilterParamForDetailDto paramDto) {
+        Page<JSONObject> result = new Page<>(paramDto.getCurrent(), paramDto.getSize());
+        SearchRequest request = new SearchRequest();
+        request.indices("idx_biz_view_jg_all");
+        SearchSourceBuilder builder = new SearchSourceBuilder();
+        builder.trackTotalHits(true);
+        BoolQueryBuilder boolMust = QueryBuilders.boolQuery();
+
+        if (!ObjectUtils.isEmpty(paramDto.getCityCode())) {
+            String orgCode = stCommonService.getAndSetOrgCode(paramDto.getCityCode());
+            boolMust.must(QueryBuilders.wildcardQuery("ORG_BRANCH_CODE.keyword", QueryParser.escape(orgCode) + "*"));
+        }
+
+        if (!ObjectUtils.isEmpty(paramDto.getSuperviseUnitName())) {
+            BoolQueryBuilder query = QueryBuilders.boolQuery();
+            String test = QueryParser.escape(paramDto.getSuperviseUnitName());
+            query.must(QueryBuilders.matchPhraseQuery("ORG_BRANCH_NAME", "*" + test + "*"));
+            boolMust.must(query);
+        }
+
+        if (!ObjectUtils.isEmpty(paramDto.getCompanyName())) {
+            BoolQueryBuilder query = QueryBuilders.boolQuery();
+            String test = QueryParser.escape(paramDto.getCompanyName());
+            query.must(QueryBuilders.matchPhraseQuery("USE_UNIT_NAME", "*" + test + "*"));
+            boolMust.must(query);
+        }
+
+        if (!ObjectUtils.isEmpty(paramDto.getTreeValue())) {
+            BoolQueryBuilder meBuilder = QueryBuilders.boolQuery();
+            String test = QueryParser.escape(paramDto.getTreeValue());
+            meBuilder.must(QueryBuilders.matchPhraseQuery("EQU_LIST_CODE", test));
+            boolMust.must(meBuilder);
+        }
+
+        if (!ObjectUtils.isEmpty(paramDto.getEquCategoryCode())) {
+            BoolQueryBuilder meBuilder = QueryBuilders.boolQuery();
+            String test = QueryParser.escape(paramDto.getEquCategoryCode());
+            meBuilder.must(QueryBuilders.matchPhraseQuery("EQU_CATEGORY_CODE", test));
+            boolMust.must(meBuilder);
+        }
+
+        BoolQueryBuilder pBuilder = QueryBuilders.boolQuery();
+        String param = QueryParser.escape("true");
+        pBuilder.must(QueryBuilders.matchQuery(IS_INTO_MANAGEMENT, param));
+        boolMust.must(pBuilder);
+
+        builder.query(boolMust);
+        builder.sort("REC_DATE", SortOrder.DESC);
+        builder.from((paramDto.getCurrent() - 1) * paramDto.getSize());
+        builder.size(paramDto.getSize());
+        request.source(builder);
+        List<JSONObject> list = new LinkedList<>();
+        long totle = 0;
+        try {
+            SearchResponse response = restHighLevelClient.search(request, RequestOptions.DEFAULT);
+            for (SearchHit hit : response.getHits().getHits()) {
+                System.out.println(hit);
+                JSONObject jsonObject = (JSONObject) JSONObject.toJSON(hit);
+                JSONObject dto2 = jsonObject.getJSONObject("sourceAsMap");
+                if (!ValidationUtil.isEmpty(dto2.get(EQU_STATE))) {
+                    Integer integer = Integer.valueOf(dto2.get(EQU_STATE).toString());
+                    String status = EquimentEnum.getName.get(integer);
+                    dto2.put(EQU_STATE, status);
+                }
+                list.add(dto2);
+            }
+            totle = response.getInternalResponse().hits().getTotalHits().value;
+            result.setRecords(list);
+            result.setTotal(totle);
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+        return result;
+    }
 }