新增 动态消息转历史数据 定时器功能

src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/FlightInfoServiceImpl.java

@@ -1,7 +1,9 @@
 package com.gzzn.omms.msgexchangeapi.service.flightInfo;
 
+import java.math.BigInteger;
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -84,4 +86,16 @@ public class FlightInfoServiceImpl implements IFlightInfoService {
 		redisService.hdel(redisKey, fltr.getFLID());
 		return true;
 	}
+	
+	@Override
+	public boolean batchDeleteFltr(List<BigInteger> flids) {
+		if(null!=flids){
+			flids.removeAll(Collections.singleton(null));
+		}
+		if(null==flids || flids.size()<=0){
+			return true;
+		}
+		redisService.hdel(redisKey, flids.toArray());
+		return true;
+	}
 }

src/main/java/com/gzzn/omms/msgexchangeapi/service/flightInfo/IFlightInfoService.java

@@ -1,5 +1,6 @@
 package com.gzzn.omms.msgexchangeapi.service.flightInfo;
 
+import java.math.BigInteger;
 import java.util.List;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
@@ -38,4 +39,11 @@ public interface IFlightInfoService {
    * @return
    */
   public boolean deleteFltr(SCHD.FLTR fltr);
+
+  /**
+   * 批量物理删除动态航班信息
+   * @param flids
+   * @return
+   */
+  public boolean batchDeleteFltr(List<BigInteger> flids);
 }