新增延误信息消息处理

2018-12-10 17:11:50 +08:00
parent c24d30b5d2
commit ad7f34f48d
1 changed files with 41 additions and 0 deletions
@@ -0,0 +1,41 @@
+package com.gzzn.omms.msgexchangeapi.msghandler.flop;
+
+import org.springframework.beans.BeanUtils;
+import org.springframework.util.CollectionUtils;
+
+import com.gzzn.omms.msgexchangeapi.entity.msg.DELAYDATA;
+import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
+import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDELAYDATA;
+import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
+
+/**
+ * 航班延误消息处理
+ * @author zhouxiunai
+ *
+ */
+public class DELYHandler  extends FlopBaseHandler  {
+	
+	@Override
+	protected SCHD.FLTR  updateFltr(FLOP flop,SCHD.FLTR  fltr)
+	{
+		//update
+		if(CollectionUtils.isEmpty(flop.getDELY()) )
+		{
+			//清空延误信息
+			fltr.getDELY().clear();
+		}
+		else {
+			//延误信息只新增
+			for (OPTDELAYDATA optdelaydata : flop.getDELY() ) {
+				
+				DELAYDATA delaydata = new DELAYDATA();
+				BeanUtils.copyProperties(optdelaydata, delaydata);
+				
+				fltr.getDELY().add(delaydata);
+			}
+		} 
+		
+		
+		return fltr;
+	}
+}