From cd209ee926e1474282ae57e5a17abb4a38e0a676 Mon Sep 17 00:00:00 2001
From: zhouxiunai <154707516@qq.com>
Date: Tue, 11 Dec 2018 11:59:07 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E8=88=AA=E7=8F=AD=E8=AE=A1=E5=88=92?=
 =?UTF-8?q?=E4=B8=8B=E8=BD=BD=E4=BA=8B=E4=BB=B6=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../msghandler/HandlerResult.java             |  8 +++
 .../msghandler/schd/DNLDHandler.java          | 32 ++++++++++
 .../msghandler/schd/base/SchdBaseHandler.java | 58 +++++++++++++++++++
 3 files changed, 98 insertions(+)
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java
 create mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java

diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/HandlerResult.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/HandlerResult.java
index e40a8302..ebbd469f 100644
--- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/HandlerResult.java
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/HandlerResult.java
@@ -22,6 +22,14 @@ public class HandlerResult {
 		this.fltrs = fltrs;
 	}
 	
+	public static HandlerResult success()
+	{
+		HandlerResult handlerResult = new HandlerResult();
+		handlerResult.isSuccess = true;
+		
+		return handlerResult;
+	}//end function
+	
 	
 	public static HandlerResult success(SCHD.FLTR fltr)
 	{
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java
new file mode 100644
index 00000000..f55f1496
--- /dev/null
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/DNLDHandler.java
@@ -0,0 +1,32 @@
+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;
+
+/**
+ * 航班计划下载事件 download
+ * @author zhouxiunai
+ *
+ */
+public class DNLDHandler  extends SchdBaseHandler{
+	private static  Logger logger = LoggerFactory.getLogger(DNLDHandler.class);
+	
+	@Override
+	public HandlerResult run(Cminmsg cminmsg) {
+		Boolean updateResult = flightInfoService.updateByDaySchd(cminmsg);
+		if(false == updateResult)
+		{
+			//航班计划更新失败
+			logger.error("航班计划更新失败");
+			return HandlerResult.failure();
+		}
+
+		//日航班计划第二天的，不需要通知前端
+		this.updateCminmsgToProcessed(cminmsg);
+		return HandlerResult.success();
+	} //end function
+}
diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java
new file mode 100644
index 00000000..daa17a93
--- /dev/null
+++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/schd/base/SchdBaseHandler.java
@@ -0,0 +1,58 @@
+package com.gzzn.omms.msgexchangeapi.msghandler.schd.base;
+
+import java.util.Arrays;
+
+import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
+import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
+import com.gzzn.omms.msgexchangeapi.msghandler.IBaseHandler;
+import com.gzzn.omms.msgexchangeapi.service.ICminmsgService;
+import com.gzzn.omms.msgexchangeapi.service.IKafkaService;
+import com.gzzn.omms.msgexchangeapi.service.exchange.IExchangeService;
+import com.gzzn.omms.msgexchangeapi.service.flightInfo.IFlightInfoService;
+import com.gzzn.omms.msgexchangeapi.utils.SpringUtil;
+
+/**
+ * Schd 计划消息处理基类
+ * @author zhouxiunai
+ *
+ */
+public class SchdBaseHandler  implements IBaseHandler{
+	protected IExchangeService exchangeService;
+	protected  IFlightInfoService flightInfoService;
+	protected IKafkaService kafkaservice;
+	protected ICminmsgService cminmsgService;
+	
+	public SchdBaseHandler()
+	{
+		 exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService");
+		 flightInfoService =  (IFlightInfoService) SpringUtil.getBean("flightInfoService");
+	}
+
+	@Override
+	public HandlerResult run(Cminmsg cminmsg) {		
+		return null;
+	}
+
+	
+	/**
+	 * 仅发送动态消息
+	 * @param cminmsg
+	 */
+	protected void sendMsg(Cminmsg cminmsg)
+	{
+		//send msg
+		String msg = exchangeService.xmlstrToJson(
+				cminmsg.getCminmsgsClobMsg()
+                );
+        kafkaservice.msgSend("msg", msg);
+	}
+
+	/**
+	 * 更新Cminmsg状态为已处理
+	 * @param cminmsg
+	 */
+	protected void updateCminmsgToProcessed(Cminmsg cminmsg)
+	{
+		 cminmsgService.updateBatchProcessed(Arrays.asList(cminmsg));
+	}
+}