修复由于错误引入的SODT格式,带了秒 。 导致所有后续的历史航班记录无法入历史库的问题。
This commit is contained in:
+9
-9
@@ -124,16 +124,16 @@ public class FlightHisServiceImpl {
|
|||||||
public boolean save(List<FLTR> fltrs)
|
public boolean save(List<FLTR> fltrs)
|
||||||
{
|
{
|
||||||
for(FLTR fltr : 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<Map<String, Object>> listInEs = ElasticsearchUtil.searchListData(INDEX_NAME, ES_TYPE, boolQuery, null, "FLID", null, null, null);
|
|
||||||
|
|
||||||
try {
|
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<Map<String, Object>> listInEs = ElasticsearchUtil.searchListData(INDEX_NAME, ES_TYPE, boolQuery, null, "FLID", null, null, null);
|
||||||
|
|
||||||
if(!CollectionUtils.isEmpty(listInEs)){
|
if(!CollectionUtils.isEmpty(listInEs)){
|
||||||
//更新
|
//更新
|
||||||
Map<String, Object> map = listInEs.get(0);
|
Map<String, Object> map = listInEs.get(0);
|
||||||
|
|||||||
Reference in New Issue
Block a user