From 0f4d5613dfa24493612e84d3b4537b91e0771cc3 Mon Sep 17 00:00:00 2001 From: zhouxiunai <154707516@qq.com> Date: Mon, 21 Jan 2019 18:03:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=97=A5=E5=BF=97=E8=BE=93?= =?UTF-8?q?=E5=87=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java b/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java index d4ad55aa..97953c33 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java @@ -10,7 +10,6 @@ import org.elasticsearch.index.query.QueryBuilders; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -67,6 +66,8 @@ public class FlightHisScheduled { return ; //没有要转的航班历史 } + logger.info("获取到历史动态航班数据:{}条,准备转历史",fltrsHistory.size()); + //往 elasticsearch中放入历史数据 通过FLID + SODT 判断唯一 (航班ID+计划时间) if(!ElasticsearchUtil.isIndexExist(INDEX_NAME)){ ElasticsearchUtil.createIndex(INDEX_NAME);