From 6bf7393860954e20b230d55149adb83607bbaddd Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Mon, 10 Dec 2018 14:33:06 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86=E5=80=BC=E6=9C=BA=E6=9F=9C?=
 =?UTF-8?q?=E5=8F=B0=E4=BA=8B=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/flop/CKDTHandler.java          | 20 ++++++++++++++++++-
 src/main/resources/application-dev.yml        |  2 +-
 2 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java
index ab457d36..59282247 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CKDTHandler.java
@@ -4,7 +4,9 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
+import com.gzzn.omms.msgexchangeapi.entity.msg.DESKDATA;
 import com.gzzn.omms.msgexchangeapi.entity.msg.MSG;
+import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDESKDATA;
 import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
 import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
 
@@ -22,8 +24,24 @@ public class CKDTHandler   extends FlopBaseHandler {
 		SCHD.FLTR  fltr =  flightInfoService.getByFlid(ckdtMsg.getFLOP().get(0).getFLID().toString());
 		if(null != fltr)
 		{
-			//TODO: update ckdt 
 			//save
+			fltr.getCKDT().clear(); //清空旧数据
+			for(OPTDESKDATA optdeskdata : ckdtMsg.getFLOP().get(0).getCKDT() ) 
+			{
+				DESKDATA deskdata = new DESKDATA();
+				deskdata.setCCLS(optdeskdata.getCCLS());
+				deskdata.setCCTM(optdeskdata.getCCTM());
+				deskdata.setCHKC(optdeskdata.getCHKC());
+				deskdata.setCKNO(optdeskdata.getCKNO());
+				deskdata.setCOTM(optdeskdata.getCOTM());
+				deskdata.setCTYP(optdeskdata.getCTYP());
+				deskdata.setPCCT(optdeskdata.getPCCT());
+				deskdata.setPCOT(optdeskdata.getPCOT());
+				
+				fltr.getCKDT().add(deskdata);
+			} //添加新数据
+			
+			
 			flightInfoService.saveFltr(fltr);
 			
 			//send and update
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index 19fa3c60..082739aa 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -50,7 +50,7 @@ kafka:
     topic: test
     concurrency: 10
     group:
-      id: test1
+      id: test
 msgExchange:
   intervalSeconds: 5
       
\ No newline at end of file