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 index 47d01837..938c712d 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/msghandler/flop/ROUTHandler.java @@ -23,7 +23,19 @@ public class ROUTHandler extends FlopBaseHandler { { fltr.getROUT().clear(); fltr.getERUT().clear(); - + + //完整航线要加上CTU , 要区分离港还是到港 + Boolean isDepart = "D".equalsIgnoreCase(flop.getFFID().split("-")[2]); + + //离港 + if(isDepart){ + ROUTEDAILY ctuRoute = new ROUTEDAILY(); + ctuRoute.setAPCD("CTU"); + ctuRoute.setSCAT(""); + ctuRoute.setSCDT(""); + fltr.getERUT().add(ctuRoute); + } + for(ROUTEDAILY optRouteDaily : flop.getROUT() ) { ROUTEDAILY routeDaily = new ROUTEDAILY(); @@ -33,7 +45,23 @@ public class ROUTHandler extends FlopBaseHandler { //完整航线,要加上CTU 成都机场 fltr.getERUT().add(routeDaily); - } //添加新数据 + } //添加新数据 + + //到港 + if(!isDepart){ + ROUTEDAILY ctuRoute = new ROUTEDAILY(); + ctuRoute.setAPCD("CTU"); + ctuRoute.setSCAT(""); + ctuRoute.setSCDT(""); + fltr.getERUT().add(ctuRoute); + } + + //重新调整完整航线的RNO + for(int i = 0;i < fltr.getERUT().size();i++){ + ROUTEDAILY optRouteDaily = fltr.getERUT().get(i); + optRouteDaily.setRTNO(i); + } + return fltr; } }