Commit 42486b1e authored by tianyiming's avatar tianyiming

气瓶充装和基本信息筛选调整

parent 5f1667e4
...@@ -344,14 +344,14 @@ public class CylinderFillingRecordServiceImpl extends BaseService<CylinderFillin ...@@ -344,14 +344,14 @@ public class CylinderFillingRecordServiceImpl extends BaseService<CylinderFillin
boolMust.must(query); boolMust.must(query);
} }
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat sdf = new SimpleDateFormat(DateUtils.DATE_TIME_PATTERN);
//充装开始时间 //充装开始时间
if (!ObjectUtils.isEmpty(esCylinderFillingRecordDto.getFillingStartTime())) { if (!ObjectUtils.isEmpty(esCylinderFillingRecordDto.getFillingStartTime())) {
flag = false; flag = false;
BoolQueryBuilder query = QueryBuilders.boolQuery(); BoolQueryBuilder query = QueryBuilders.boolQuery();
// query.must(QueryBuilders.matchQuery("fillingStartTime", esCylinderFillingRecordDto.getFillingStartTime()));
try { try {
query.must(QueryBuilders.rangeQuery("inspectionDateMs").gte(sdf.parse(esCylinderFillingRecordDto.getFillingStartTime()).getTime())); String fillingStartTime = esCylinderFillingRecordDto.getFillingStartTime() + " 00:00:00";
query.must(QueryBuilders.rangeQuery("inspectionDateMs").gte(sdf.parse(fillingStartTime).getTime()));
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); e.printStackTrace();
} }
...@@ -362,9 +362,9 @@ public class CylinderFillingRecordServiceImpl extends BaseService<CylinderFillin ...@@ -362,9 +362,9 @@ public class CylinderFillingRecordServiceImpl extends BaseService<CylinderFillin
if (!ObjectUtils.isEmpty(esCylinderFillingRecordDto.getFillingEndTime())) { if (!ObjectUtils.isEmpty(esCylinderFillingRecordDto.getFillingEndTime())) {
flag = false; flag = false;
BoolQueryBuilder query = QueryBuilders.boolQuery(); BoolQueryBuilder query = QueryBuilders.boolQuery();
// query.must(QueryBuilders.matchQuery("fillingEndTime", esCylinderFillingRecordDto.getFillingEndTime()));
try { try {
query.must(QueryBuilders.rangeQuery("inspectionDateAfterMS").lte(sdf.parse(esCylinderFillingRecordDto.getFillingEndTime()).getTime())); String fillingEndTime = esCylinderFillingRecordDto.getFillingEndTime() + " 23:59:59";
query.must(QueryBuilders.rangeQuery("inspectionDateAfterMS").lte(sdf.parse(fillingEndTime).getTime()));
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); e.printStackTrace();
} }
......
...@@ -934,9 +934,34 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind ...@@ -934,9 +934,34 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
if (!ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateStart()) && !ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateEnd())) { if (!ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateStart()) && !ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateEnd())) {
flag = false; flag = false;
BoolQueryBuilder query = QueryBuilders.boolQuery(); BoolQueryBuilder query = QueryBuilders.boolQuery();
// query.must(QueryBuilders.rangeQuery("inspectionDate").from(cylinderInfoDto.getInspectionDateStart()).to(cylinderInfoDto.getInspectionDateEnd()));
try { try {
query.must(QueryBuilders.rangeQuery("inspectionDateMs").gte(sdf.parse(cylinderInfoDto.getInspectionDateStart()).getTime())); String inspectionDateStart = cylinderInfoDto.getInspectionDateStart() + " 00:00:00";
String inspectionDateEnd = cylinderInfoDto.getInspectionDateEnd() + " 23:59:59";
query.must(QueryBuilders.rangeQuery("inspectionDateMs")
.gte(sdf.parse(inspectionDateStart).getTime())
.lte(sdf.parse(inspectionDateEnd).getTime()));
} catch (ParseException e) {
e.printStackTrace();
}
boolMust.must(query);
} else if (!ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateStart()) && ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateEnd())) {
flag = false;
BoolQueryBuilder query = QueryBuilders.boolQuery();
try {
String inspectionDateStart = cylinderInfoDto.getInspectionDateStart() + " 00:00:00";
query.must(QueryBuilders.rangeQuery("inspectionDateMs")
.gte(sdf.parse(inspectionDateStart).getTime()));
} catch (ParseException e) {
e.printStackTrace();
}
boolMust.must(query);
} else if(ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateStart()) && !ObjectUtils.isEmpty(cylinderInfoDto.getInspectionDateEnd())){
flag = false;
BoolQueryBuilder query = QueryBuilders.boolQuery();
try {
String inspectionDateEnd = cylinderInfoDto.getInspectionDateEnd() + " 23:59:59";
query.must(QueryBuilders.rangeQuery("inspectionDateMs")
.lte(sdf.parse(inspectionDateEnd).getTime()));
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); e.printStackTrace();
} }
......
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