From b222052c95ff8e2fec83fcfe352d0f195f81d8da Mon Sep 17 00:00:00 2001 From: zhouxiunai <154707516@qq.com> Date: Mon, 18 Feb 2019 11:44:07 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=94=B1=E4=BA=8E=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E5=BC=95=E5=85=A5=E7=9A=84SODT=E6=A0=BC=E5=BC=8F?= =?UTF-8?q?=EF=BC=8C=E5=B8=A6=E4=BA=86=E7=A7=92=20=E3=80=82=20=E5=AF=BC?= =?UTF-8?q?=E8=87=B4=E6=89=80=E6=9C=89=E5=90=8E=E7=BB=AD=E7=9A=84=E5=8E=86?= =?UTF-8?q?=E5=8F=B2=E8=88=AA=E7=8F=AD=E8=AE=B0=E5=BD=95=E6=97=A0=E6=B3=95?= =?UTF-8?q?=E5=85=A5=E5=8E=86=E5=8F=B2=E5=BA=93=E7=9A=84=E9=97=AE=E9=A2=98?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../flightInfo/FlightHisServiceImpl.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightHisServiceImpl.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightHisServiceImpl.java index bc2781de..3cad3222 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightHisServiceImpl.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightHisServiceImpl.java @@ -124,16 +124,16 @@ public class FlightHisServiceImpl { public boolean save(List fltrs) { for(FLTR fltr : fltrs){ - JSONObject jsondata = JSONObject.parseObject(JsonUtil.getString(fltr)); - //判断是否已经拥有该历史数据 因es类型原因请注意类型转换 - String SODT = fltr.getSODT(); - Long FLID = fltr.getFLID().longValue(); - BoolQueryBuilder boolQuery = QueryBuilders.boolQuery() - .must(QueryBuilders.termQuery("SODT",SODT)) - .must(QueryBuilders.termQuery("FLID",FLID)); - List> listInEs = ElasticsearchUtil.searchListData(INDEX_NAME, ES_TYPE, boolQuery, null, "FLID", null, null, null); - try { + JSONObject jsondata = JSONObject.parseObject(JsonUtil.getString(fltr)); + //判断是否已经拥有该历史数据 因es类型原因请注意类型转换 + String SODT = fltr.getSODT(); + Long FLID = fltr.getFLID().longValue(); + BoolQueryBuilder boolQuery = QueryBuilders.boolQuery() + .must(QueryBuilders.termQuery("SODT",SODT)) + .must(QueryBuilders.termQuery("FLID",FLID)); + List> listInEs = ElasticsearchUtil.searchListData(INDEX_NAME, ES_TYPE, boolQuery, null, "FLID", null, null, null); + if(!CollectionUtils.isEmpty(listInEs)){ //更新 Map map = listInEs.get(0);