处理值机柜台事件

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

src/main/resources/application-dev.yml

@@ -50,7 +50,7 @@ kafka:
     topic: test
     concurrency: 10
     group:
-      id: test1
+      id: test
 msgExchange:
   intervalSeconds: 5