From e03df84cbacd67dfa13ca3972b53b2c518b71c43 Mon Sep 17 00:00:00 2001 From: fanghongchao <601470458@qq.com> Date: Wed, 12 Dec 2018 12:01:01 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E5=87=A0=E4=B8=AA=20?= =?UTF-8?q?=E7=AC=AC5=E7=AB=A0=E7=9A=84=20=E5=8A=A8=E6=80=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../msghandler/flop/ABTMHandler.java | 47 ------------- .../msghandler/flop/CHOTHandler.java | 47 ------------- .../msghandler/flop/FLBGHandler.java | 66 ------------------- 3 files changed, 160 deletions(-) delete mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ABTMHandler.java delete mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CHOTHandler.java delete mode 100644 src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FLBGHandler.java diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ABTMHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ABTMHandler.java deleted file mode 100644 index 97dd6055..00000000 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ABTMHandler.java +++ /dev/null @@ -1,47 +0,0 @@ -package com.gzzn.omms.msgexchangeapi.msghandler.flop; - -import java.util.List; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.beans.BeanUtils; - -import com.gzzn.omms.msgexchangeapi.entity.Cminmsg; -import com.gzzn.omms.msgexchangeapi.entity.msg.BRIDGEDATA; -import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; -import com.gzzn.omms.msgexchangeapi.entity.msg.MSG; -import com.gzzn.omms.msgexchangeapi.entity.msg.OPTBRIDGEDATA; -import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; -import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult; -import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler; -import com.gzzn.omms.msgexchangeapi.utils.JsonUtil; - -/** - * 航班登机桥时间事件 - * @author fhc - * - */ -public class ABTMHandler extends FlopBaseHandler { - private static Logger logger = LoggerFactory.getLogger(ABTMHandler.class); - - @Override - public HandlerResult run(Cminmsg cminmsg) { - MSG cldtMsg = exchangeService.xmlstrToObject(cminmsg.getCminmsgsClobMsg(), MSG.class); - FLOP flop = cldtMsg.getFLOP().get(0); - - List optBridgeDatas = flop.getABTM(); - if(optBridgeDatas.size()>1) - { //航班轮档时间事件 一个动态消息只能包含一个航班轮档时间数据记录 - logger.error("航班登机桥时间事件，只能包含一条登机桥靠桥/离桥操作记录:"+JsonUtil.getString(optBridgeDatas)); - return HandlerResult.failure(); - }else { - SCHD.FLTR fltr = flightInfoService.getByFlid(flop.getFLID().toString()); - OPTBRIDGEDATA optBridgeData = optBridgeDatas.get(0); - BRIDGEDATA bridgeData = new BRIDGEDATA(); - BeanUtils.copyProperties(optBridgeData, bridgeData); - fltr.getABTM().clear(); - fltr.getABTM().add(bridgeData); - return HandlerResult.success(fltr); - } - } -} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CHOTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CHOTHandler.java deleted file mode 100644 index fb7078c7..00000000 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/CHOTHandler.java +++ /dev/null @@ -1,47 +0,0 @@ -package com.gzzn.omms.msgexchangeapi.msghandler.flop; - -import java.util.List; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.beans.BeanUtils; - -import com.gzzn.omms.msgexchangeapi.entity.Cminmsg; -import com.gzzn.omms.msgexchangeapi.entity.msg.CHOCKSDATA; -import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; -import com.gzzn.omms.msgexchangeapi.entity.msg.MSG; -import com.gzzn.omms.msgexchangeapi.entity.msg.OPTCHOCKSDATA; -import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; -import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult; -import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler; -import com.gzzn.omms.msgexchangeapi.utils.JsonUtil; - -/** - * 航班轮档时间事件 - * @author fhc - * - */ -public class CHOTHandler extends FlopBaseHandler { - private static Logger logger = LoggerFactory.getLogger(CHOTHandler.class); - - @Override - public HandlerResult run(Cminmsg cminmsg) { - MSG cldtMsg = exchangeService.xmlstrToObject(cminmsg.getCminmsgsClobMsg(), MSG.class); - FLOP flop = cldtMsg.getFLOP().get(0); - - List optChocksDatas = flop.getCHOT(); - if(optChocksDatas.size()>1) - { //航班轮档时间事件 一个动态消息只能包含一个航班轮档时间数据记录 - logger.error("航班轮档时间事件 一个动态消息只能包含一个航班轮档时间数据记录:"+JsonUtil.getString(optChocksDatas)); - return HandlerResult.failure(); - }else { - SCHD.FLTR fltr = flightInfoService.getByFlid(flop.getFLID().toString()); - OPTCHOCKSDATA optChocksData = optChocksDatas.get(0); - CHOCKSDATA chocksData = new CHOCKSDATA(); - BeanUtils.copyProperties(optChocksData, chocksData); - fltr.getCHOT().clear(); - fltr.getCHOT().add(chocksData); - return HandlerResult.success(fltr); - } - } -} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FLBGHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FLBGHandler.java deleted file mode 100644 index 0fb8e5ce..00000000 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/FLBGHandler.java +++ /dev/null @@ -1,66 +0,0 @@ -package com.gzzn.omms.msgexchangeapi.msghandler.flop; - -import java.util.List; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.gzzn.omms.msgexchangeapi.entity.Cminmsg; -import com.gzzn.omms.msgexchangeapi.entity.msg.BELTDATA; -import com.gzzn.omms.msgexchangeapi.entity.msg.CLASSES; -import com.gzzn.omms.msgexchangeapi.entity.msg.FLBGDATA; -import com.gzzn.omms.msgexchangeapi.entity.msg.FLBTCODES; -import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; -import com.gzzn.omms.msgexchangeapi.entity.msg.MSG; -import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; -import com.gzzn.omms.msgexchangeapi.entity.msg.SUBSYSTEMS; -import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult; -import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler; -import com.gzzn.omms.msgexchangeapi.utils.JsonUtil; - -/** - * 首行李/末行李事件 - * @author fhc - * - */ -public class FLBGHandler extends FlopBaseHandler { - private static Logger logger = LoggerFactory.getLogger(FLBGHandler.class); - - @Override - public HandlerResult run(Cminmsg cminmsg) { - MSG cldtMsg = exchangeService.xmlstrToObject(cminmsg.getCminmsgsClobMsg(), MSG.class); - if(!cldtMsg.getMETA().getSNDR().value().equals(SUBSYSTEMS.AODB)){ - logger.error("只发送AODB分配的行李转盘数据，需进行手动处理/更正后发生数据。"); - return HandlerResult.failure(); - } - - FLOP flop = cldtMsg.getFLOP().get(0); - List flbgDatas = flop.getFLBG(); - if(flbgDatas.size()>1) - { // 首行李/末行李事件,一个动态消息只能包含一个行李事件数据记录 - logger.error("首行李/末行李事件,一个动态消息只能包含一个行李事件数据记录:"+JsonUtil.getString(flbgDatas)); - return HandlerResult.failure(); - }else { - SCHD.FLTR fltr = flightInfoService.getByFlid(flop.getFLID().toString()); - FLBGDATA flbgData = flbgDatas.get(0); - String optBlst = flbgData.getBLST(); //到达航班的行李传送带号 - CLASSES optBcls = flbgData.getBCLS(); //行李转盘等级 F:头等 C:商务 Y:经济 X：全部 - List beltDatas = fltr.getCLDT(); - - for(BELTDATA beltData : beltDatas){ - //找到计划中 行李传送带号一致 且等级一致的行李转盘 - if(beltData.getBELT().equals(optBlst) && optBcls.compareTo(beltData.getBCLS())==0){ - if(flbgData.getFLBT().getTYPE().value().equals(FLBTCODES.F)){ //首件行李 - beltData.setFBAG(flbgData.getFLBT().getValue()); - } - if(flbgData.getFLBT().getTYPE().value().equals(FLBTCODES.L)){ //末件行李 - beltData.setLBAG(flbgData.getFLBT().getValue()); - } - break; - } - } - - return HandlerResult.success(fltr); - } - } -}