From 4a8c145677edd696cf7865ee384751323edb7c15 Mon Sep 17 00:00:00 2001
From: fanghongchao <601470458@qq.com>
Date: Thu, 20 Dec 2018 15:33:37 +0800
Subject: [PATCH] =?UTF-8?q?redis=E4=B8=AD=E7=9A=84key=20=E9=83=BD=E6=98=AF?=
 =?UTF-8?q?string=E7=B1=BB=E5=9E=8B=E7=9A=84=E6=AD=A4=E5=A4=84=E8=BF=9B?=
 =?UTF-8?q?=E8=A1=8C=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../omms/msgexchangeapi/scheduled/FlightHisScheduled.java  | 7 +++----
 .../service/flightInfo/FlightInfoServiceImpl.java          | 3 +--
 .../service/flightInfo/IFlightInfoService.java             | 3 +--
 3 files changed, 5 insertions(+), 8 deletions(-)

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 dd059039..1507767b 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FlightHisScheduled.java
@@ -1,6 +1,5 @@
 package com.gzzn.omms.msgexchangeapi.scheduled;
 
-import java.math.BigInteger;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Locale;
@@ -78,7 +77,7 @@ public class FlightHisScheduled {
 		logger.info("开始采集历史数据...");
         //1.从redis中获取 当前的动态消息
 		List<FLTR> fltrs = flightInfoService.findAll();
-		List<BigInteger> fltrIdForHistory = new ArrayList<BigInteger>();
+		List<String> fltrIdForHistory = new ArrayList<String>();
 		List<FLTR> fltrsHistory = new ArrayList<FLTR>();
 		
 		//遍历   查找出已经 可以作为历史数据的动态消息
@@ -161,11 +160,11 @@ public class FlightHisScheduled {
 						Map<String, Object> map = listInEs.get(0);
 						String id = (String) map.get("id");
 						ElasticsearchUtil.updateDataById(jsondata, INDEX_NAME, ES_TYPE, id);
-						fltrIdForHistory.add(fltr.getFLID());
+						fltrIdForHistory.add(fltr.getFLID().toString());
 					}else{
 						//新增历史数据
 						ElasticsearchUtil.addData(jsondata, INDEX_NAME, ES_TYPE);
-						fltrIdForHistory.add(fltr.getFLID());
+						fltrIdForHistory.add(fltr.getFLID().toString());
 					}
 				}
 			}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java
index 86208b8b..4b5b9f62 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java
@@ -1,6 +1,5 @@
 package com.gzzn.omms.msgexchangeapi.service.flightInfo;
 
-import java.math.BigInteger;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
@@ -88,7 +87,7 @@ public class FlightInfoServiceImpl implements IFlightInfoService {
 	}
 	
 	@Override
-	public boolean batchDeleteFltr(List<BigInteger> flids) {
+	public boolean batchDeleteFltr(List<String> flids) {
 		if(null!=flids){
 			flids.removeAll(Collections.singleton(null));
 		}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java
index 3b044383..aa8204c8 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java
@@ -1,6 +1,5 @@
 package com.gzzn.omms.msgexchangeapi.service.flightInfo;
 
-import java.math.BigInteger;
 import java.util.List;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
@@ -45,5 +44,5 @@ public interface IFlightInfoService {
    * @param flids
    * @return
    */
-  public boolean batchDeleteFltr(List<BigInteger> flids);
+  public boolean batchDeleteFltr(List<String> flids);
 }