提取航班动态消息处理基类到具体的base包
This commit is contained in:
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班机型事件
|
* 航班机型事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班实际时间事件
|
* 航班实际时间事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
public class BDPBHandler extends FlopBaseHandler {
|
public class BDPBHandler extends FlopBaseHandler {
|
||||||
private static Logger logger = LoggerFactory.getLogger(BDPBHandler.class);
|
private static Logger logger = LoggerFactory.getLogger(BDPBHandler.class);
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班登机时间事件处理
|
* 航班登机时间事件处理
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.DESKDATA;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDESKDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDESKDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 值机柜台事件处理
|
* 值机柜台事件处理
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.BELTDATA;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTBELTDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTBELTDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 行李转盘事件 carousel
|
* 行李转盘事件 carousel
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 添加航班取消消息
|
* 添加航班取消消息
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.DELAYDATA;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDELAYDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDELAYDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班延误消息处理
|
* 航班延误消息处理
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package com.gzzn.omms.msgexchangeapi.msghandler.flop;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班预计时间处理
|
* 航班预计时间处理
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.MSG;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.MSG;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
|
import com.gzzn.omms.msgexchangeapi.msghandler.HandlerResult;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 处理航班删除事件
|
* 处理航班删除事件
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.DIVERSIONDATA;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDIVERSIONDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTDIVERSIONDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班转场事件
|
* 航班转场事件
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package com.gzzn.omms.msgexchangeapi.msghandler.flop;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 处理航班标识事件
|
* 处理航班标识事件
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package com.gzzn.omms.msgexchangeapi.msghandler.flop;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 处理航班机型事件
|
* 处理航班机型事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班状态事件
|
* 航班状态事件
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.GATEDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.GATEDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTGATEDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTGATEDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班登机门事件
|
* 航班登机门事件
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import org.springframework.util.StringUtils;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班服务代理事件
|
* 航班服务代理事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班最后通知时间事件
|
* 航班最后通知时间事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班前站实际起飞时间事件
|
* 航班前站实际起飞时间事件
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTSTANDDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.OPTSTANDDATA;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.STANDDATA;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.STANDDATA;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班计划机位事件
|
* 航班计划机位事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班注释事件
|
* 航班注释事件
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ import org.springframework.beans.BeanUtils;
|
|||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.ROUTEDAILY;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.ROUTEDAILY;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班航线事件
|
* 航班航线事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班当前机位事件
|
* 航班当前机位事件
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import org.springframework.util.StringUtils;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班经停事件
|
* 航班经停事件
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班航站楼事件
|
* 航班航站楼事件
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import org.springframework.util.StringUtils;
|
|||||||
|
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP;
|
||||||
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD;
|
||||||
|
import com.gzzn.omms.msgexchangeapi.msghandler.flop.base.FlopBaseHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 航班VIP旅客事件
|
* 航班VIP旅客事件
|
||||||
|
|||||||
+2
-2
@@ -1,4 +1,4 @@
|
|||||||
package com.gzzn.omms.msgexchangeapi.msghandler.flop;
|
package com.gzzn.omms.msgexchangeapi.msghandler.flop.base;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
|
|
||||||
@@ -33,7 +33,7 @@ public class FlopBaseHandler implements IBaseHandler {
|
|||||||
protected RedisService redisService;
|
protected RedisService redisService;
|
||||||
protected ICminmsgService cminmsgService;
|
protected ICminmsgService cminmsgService;
|
||||||
|
|
||||||
FlopBaseHandler()
|
public FlopBaseHandler()
|
||||||
{
|
{
|
||||||
exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService");
|
exchangeService = (IExchangeService) SpringUtil.getBean("exchangeService");
|
||||||
flightInfoService = (IFlightInfoService) SpringUtil.getBean("flightInfoService");
|
flightInfoService = (IFlightInfoService) SpringUtil.getBean("flightInfoService");
|
||||||
Reference in New Issue
Block a user