From 7e33b4e0a31b70e6aa7a2b0e786547792e6fc82e Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Wed, 19 Dec 2018 16:56:59 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=88=AA=E7=8F=AD=E8=AE=A1?=
 =?UTF-8?q?=E5=88=92=E8=BF=94=E5=9B=9E=E6=B6=88=E6=81=AF=E5=A4=84=E7=90=86?=
 =?UTF-8?q?SCHD=20=20,=20RESP?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/schd/RESPHandler.java          | 34 +++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/RESPHandler.java

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/RESPHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/RESPHandler.java
new file mode 100644
index 00000000..83abab0e
--- /dev/null
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/RESPHandler.java
@@ -0,0 +1,34 @@
+package com.gzzn.omms.msgexchangeapi.msghandler.schd;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
+import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
+import com.gzzn.omms.msgexchangeapi.msghandler.schd.base.SchdBaseHandler;
+
+/**
+ * 处理请求返回的日航班计划，一般用于日航班计划同步
+ * @author zhouxiunai
+ *
+ */
+public class RESPHandler extends SchdBaseHandler {
+	private static  Logger logger = LoggerFactory.getLogger(RESPHandler.class);
+	
+	@Override
+	public HandlerResult run(Cminmsg cminmsg) {
+		Boolean updateResult = flightInfoService.updateByDaySchd(cminmsg);
+		if(false == updateResult)
+		{
+			//航班计划更新失败
+			logger.error("航班计划更新失败");
+			return HandlerResult.failure();
+		}
+
+		//发送日计划到kafka队列
+		this.sendDschd(cminmsg);
+		
+		this.updateCminmsgToProcessed(cminmsg);
+		return HandlerResult.success();
+	} //end function
+}