diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java new file mode 100644 index 00000000..9a144971 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java @@ -0,0 +1,33 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.BeanUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.ROUTEDAILY; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班航线事件 + * @author fhc + * + */ +public class ROUTHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(ROUTHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + fltr.getROUT().clear(); + for(ROUTEDAILY optRouteDaily : flop.getROUT() ) + { + ROUTEDAILY routeDaily = new ROUTEDAILY(); + BeanUtils.copyProperties(optRouteDaily, routeDaily); + + fltr.getROUT().add(routeDaily); + } //添加新数据 + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java new file mode 100644 index 00000000..4ec766ca --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/STNDHandler.java @@ -0,0 +1,25 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班当前机位事件 + * @author fhc + * + */ +public class STNDHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(STNDHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + //update + fltr.setSTND(flop.getSTND()); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java new file mode 100644 index 00000000..2a390b99 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TAOPHandler.java @@ -0,0 +1,30 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import java.math.BigInteger; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.util.StringUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班经停事件 + * @author fhc + * + */ +public class TAOPHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(TAOPHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + //update + fltr.setTAOP(flop.getTAOP()); + fltr.setTAFL(flop.getTAFL()); + fltr.setTAID(StringUtils.isEmpty(flop.getTAID())?null:new BigInteger(flop.getTAID())); + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java new file mode 100644 index 00000000..fb3d7f25 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/TRMLHandler.java @@ -0,0 +1,26 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班航站楼事件 + * @author fhc + * + */ +public class TRMLHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(TRMLHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + //update + fltr.setTRML(flop.getTRML()); + + return fltr; + } +} diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java new file mode 100644 index 00000000..142536c1 --- /dev/null +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/VIPPHandler.java @@ -0,0 +1,31 @@ +package com.gzzn.omms.msgexchangeapi.msghandler.flop; + +import java.math.BigInteger; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.util.StringUtils; + +import com.gzzn.omms.msgexchangeapi.entity.msg.FLOP; +import com.gzzn.omms.msgexchangeapi.entity.msg.SCHD; + +/** + * 航班VIP旅客事件 + * @author fhc + * + */ +public class VIPPHandler extends FlopBaseHandler { + + private static Logger logger = LoggerFactory.getLogger(VIPPHandler.class); + + @Override + protected SCHD.FLTR updateFltr(FLOP flop,SCHD.FLTR fltr) + { + //update + //null 表示已有的VIP旅客数删除 + fltr.setVIPP(StringUtils.isEmpty(flop.getVIPP())?null:new BigInteger(flop.getVIPP())); + + fltr.setVIPR(StringUtils.isEmpty(flop.getVIPR())?null:new BigInteger(flop.getVIPR())); + return fltr; + } +}