Commit 05b8887c authored by 韩桐桐's avatar 韩桐桐

fix(jg):代码回退

parent bd1a66c6
...@@ -177,29 +177,29 @@ public class JgUseRegistrationManageController extends BaseController { ...@@ -177,29 +177,29 @@ public class JgUseRegistrationManageController extends BaseController {
List<Long> collect = Arrays.stream(sequenceNbrs.split(",")) List<Long> collect = Arrays.stream(sequenceNbrs.split(","))
.map(Long::parseLong) .map(Long::parseLong)
.collect(Collectors.toList()); .collect(Collectors.toList());
return ResponseHelper.buildResponse(jgUseRegistrationManageServiceImpl.queryEquByCertificateSeqList(collect,null,null)); return ResponseHelper.buildResponse(jgUseRegistrationManageServiceImpl.queryEquByCertificateSeqList(collect));
} }
/** // /**
* 根据证的sequenceNbrs 批量查询证下面的所有设备 // * 根据证的sequenceNbrs 批量查询证下面的所有设备
* @param current 非必填,不填不分页,展示全部 // * @param current 非必填,不填不分页,展示全部
* @param size 非必填,不填不分页,展示全部 // * @param size 非必填,不填不分页,展示全部
* @param paramMap **仅仅支持** studio平台传参类似&certificateSeqs[0]=1809032149396975618&certificateSeqs[1]=1809032151141806081 // * @param paramMap **仅仅支持** studio平台传参类似&certificateSeqs[0]=1809032149396975618&certificateSeqs[1]=1809032151141806081
* 如需其他需求使用上面的接口查询 // * 如需其他需求使用上面的接口查询
* @return // * @return
*/ // */
@TycloudOperation(ApiLevel = UserType.AGENCY) // @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/queryEquByCertificateSeqs") // @GetMapping(value = "/queryEquByCertificateSeqs")
@ApiOperation(httpMethod = "GET",value = "根据证的sequenceNbr 批量查询证下面的所有设备", notes = "根据证的sequenceNbr 批量查询证下面的所有设备") // @ApiOperation(httpMethod = "GET",value = "根据证的sequenceNbr 批量查询证下面的所有设备", notes = "根据证的sequenceNbr 批量查询证下面的所有设备")
public ResponseModel<List<JSONObject>> queryEquByCertificateSeqList( @RequestParam(value = "current",required = false) String current, // public ResponseModel<List<JSONObject>> queryEquByCertificateSeqList( @RequestParam(value = "current",required = false) String current,
@RequestParam(value = "size",required = false) String size, // @RequestParam(value = "size",required = false) String size,
@RequestParam MultiValueMap<String, String> paramMap) { // @RequestParam MultiValueMap<String, String> paramMap) {
List<Long> certificateSeqs = new ArrayList<>(); // List<Long> certificateSeqs = new ArrayList<>();
paramMap.forEach((key, value) -> { // paramMap.forEach((key, value) -> {
if (key.startsWith("certificateSeqs[")) { // if (key.startsWith("certificateSeqs[")) {
value.forEach(val -> certificateSeqs.add(Long.parseLong(val))); // value.forEach(val -> certificateSeqs.add(Long.parseLong(val)));
} // }
}); // });
return ResponseHelper.buildResponse(jgUseRegistrationManageServiceImpl.queryEquByCertificateSeqList(certificateSeqs,current,size)); // return ResponseHelper.buildResponse(jgUseRegistrationManageServiceImpl.queryEquByCertificateSeqList(certificateSeqs,current,size));
} // }
} }
...@@ -204,13 +204,13 @@ public class JgUseRegistrationManageServiceImpl extends BaseService<JgUseRegistr ...@@ -204,13 +204,13 @@ public class JgUseRegistrationManageServiceImpl extends BaseService<JgUseRegistr
* 根据证的sequenceNbr,查询证下面的所有设备 * 根据证的sequenceNbr,查询证下面的所有设备
*/ */
public List<JSONObject> queryEquByCertificateSeq(Long sequenceNbr) { public List<JSONObject> queryEquByCertificateSeq(Long sequenceNbr) {
return queryEquByCertificateSeqList(Collections.singletonList(sequenceNbr),null,null); return queryEquByCertificateSeqList(Collections.singletonList(sequenceNbr));
} }
/** /**
* 根据证的sequenceNbr集合,批量查询证下面的所有设备 * 根据证的sequenceNbr集合,批量查询证下面的所有设备
*/ */
public List<JSONObject> queryEquByCertificateSeqList(List<Long> sequenceNbrList,String current,String size) { public List<JSONObject> queryEquByCertificateSeqList(List<Long> sequenceNbrList) {
List<JgUseRegistrationManage> jgUseRegistrationManageList = this.baseMapper.selectList(new LambdaQueryWrapper<JgUseRegistrationManage>() List<JgUseRegistrationManage> jgUseRegistrationManageList = this.baseMapper.selectList(new LambdaQueryWrapper<JgUseRegistrationManage>()
.in(JgUseRegistrationManage::getSequenceNbr, sequenceNbrList) .in(JgUseRegistrationManage::getSequenceNbr, sequenceNbrList)
.eq(JgUseRegistrationManage::getIsDelete, 0)); .eq(JgUseRegistrationManage::getIsDelete, 0));
...@@ -229,17 +229,8 @@ public class JgUseRegistrationManageServiceImpl extends BaseService<JgUseRegistr ...@@ -229,17 +229,8 @@ public class JgUseRegistrationManageServiceImpl extends BaseService<JgUseRegistr
TermsQueryBuilder termsQuery = QueryBuilders.termsQuery("USE_ORG_CODE", useOrgCodes); TermsQueryBuilder termsQuery = QueryBuilders.termsQuery("USE_ORG_CODE", useOrgCodes);
boolQuery.must(termsQuery); boolQuery.must(termsQuery);
builder.query(boolQuery); builder.query(boolQuery);
// 支持分页
if (!StringUtils.isEmpty(current) && !StringUtils.isEmpty(size)) {
try {
builder.from((Integer.parseInt(current) - 1) * Integer.parseInt(size));
builder.size(Integer.parseInt(size));
}catch (Exception e){
log.error("分页参数转化失败");
e.printStackTrace();
}
}
request.source(builder); request.source(builder);
try { try {
SearchResponse response = restHighLevelClient.search(request, RequestOptions.DEFAULT); SearchResponse response = restHighLevelClient.search(request, RequestOptions.DEFAULT);
for (SearchHit hit : response.getHits().getHits()) { for (SearchHit hit : response.getHits().getHits()) {
......
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