优化日志输出
This commit is contained in:
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user