Examples of EntDbLoadPaxX

com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX
@author SCH

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    String selectStr = "";
    String idFlightStr ="";
    
    try{
    if (data instanceof EntDbLoadPaxX){
      EntDbLoadPaxX loadPax = (EntDbLoadPaxX) data;
//      fld.add(Integer.toString(loadPax.getIdFlight()));
      tabName = "LOAD_PAX";
      selectStr = "WHERE ID = '"+loadPax.getUuid()+"'";
      idFlightStr = Integer.toString(loadPax.getIdFlight());
      ld.add(loadPax.getUuid());
      // add fields
//      fld.add("ID");
       fld.add("INTFLID");
       fld.add("INTREFNUMBER");
       fld.add("DATA_SOURCE");
       fld.add("ID_FLIGHT");
       fld.add("ID_LOAD_PAX_CONNECT");
       fld.add("BAGNOOFPIECES");
       fld.add("BAGTAGPRINT");
       fld.add("BAGWEIGHT");
       fld.add("BOARDINGPASSPRINT");
       fld.add("BOARDINGSTATUS");
       fld.add("BOOKEDCLASS");
       fld.add("CABINCLASS");
       fld.add("UPGRADE_INDICATOR");
       fld.add("TRANSIT_INDICATOR");
       fld.add("CANCELLED");
       fld.add("JTOP_PAX");
       fld.add("TRANSIT_BAG_INDICATOR");
       fld.add("E_TICKET_ID");
       fld.add("TICKET_NUMBER");
       fld.add("COUPON_NUMBER");
       fld.add("APD_TYPE");
       fld.add("DOCUMENT_TYPE");
       fld.add("DOCUMENT_NUMBER");
       fld.add("DOCUMENT_EXPIRY_DATE");
       fld.add("DOCUMENT_ISSUED_DATE");
       fld.add("DOCUMENT_ISSUED_COUNTRY");
       fld.add("COUNTRY_OF_BIRTH");
       fld.add("COUNTRY_OF_RESIDENCE");
       fld.add("ITN_EMBARKATION");
       fld.add("ITN_DISEMBARKATION");
       fld.add("PAX_STATUS");
       fld.add("CHECKINDATETIME");
       fld.add("DESTINATION");
       fld.add("DOB");
       fld.add("ETKTYPE");
       fld.add("GENDER");
       fld.add("HANDICAPPED");
       fld.add("INFANTINDICATOR");
       fld.add("INTID");
       fld.add("NATIONALITY");
       fld.add("OFFLOADEDPAX");
       fld.add("PAXBOOKINGSTATUS");
       fld.add("PAXGROUPCODE");
       fld.add("PAXNAME");
       fld.add("PAXTYPE");
       fld.add("PRIORITYPAX");
       fld.add("STATUSONBOARD");
       fld.add("TRAVELLEDCLASS");
       fld.add("SEAT_NUMBER");
       fld.add("UNACCOMPANIEDMINOR");
       fld.add("BAGTAGINFO");
       fld.add("SCANLOCATION");
       fld.add("SCANDATETIME");
       fld.add("CHECKINAGENTCODE");
       fld.add("CHECKINHANDLINGAGENT");
       fld.add("CHECKINSEQUENCE");
       fld.add("CHECKINCITY");
       fld.add("BOARDINGDATETIME");
       fld.add("BOARDINGAGENTCODE");
       fld.add("BOARDINGHANDLINGAGENT");
       fld.add("ID_CONX_FLIGHT");  // ADDED BY 2013-12-23
      // populate data
//      dat.add(loadPax.getUuid());
       dat.add(loadPax.getIntFlId());
       dat.add(loadPax.getIntRefNumber());
       dat.add(loadPax.getIntSystem());
       dat.add(loadPax.getIdFlight());
       dat.add(loadPax.getIdLoadPaxConnect());
       dat.add(loadPax.getBagNoOfPieces());
       dat.add(loadPax.getBagTagPrint());
       dat.add(loadPax.getBagWeight());
       dat.add(loadPax.getBoardingPassprint());
       dat.add(loadPax.getBoardingStatus());
       dat.add(loadPax.getBookedClass());
       dat.add(loadPax.getCabinClass());
       dat.add(loadPax.getUpgradeIndicator());
       dat.add(loadPax.getTransitIndicator());
       dat.add(loadPax.getCancelled());
       dat.add(loadPax.getJtopPax());
       dat.add(loadPax.getTransitBagIndicator());
       dat.add(loadPax.getETickedId());
       dat.add(loadPax.getTicketNumber());
       dat.add(loadPax.getCouponNumber());
       dat.add(loadPax.getApdType());
       dat.add(loadPax.getDocumentType());
       dat.add(loadPax.getDocumentNumber());
       dat.add(loadPax.getDocumentExpiryDate());
       dat.add(loadPax.getDocumentIssuedDate());
       dat.add(loadPax.getDocumentIssuedCountry());
       dat.add(loadPax.getCountryOfBirth());
       dat.add(loadPax.getCountryOfResidence());
       dat.add(loadPax.getItnEmbarkation());
       dat.add(loadPax.getItnDisembarkation());
       dat.add(loadPax.getPaxStatus());
       dat.add(loadPax.getCheckInDateTime());
       dat.add(loadPax.getDestination());
       dat.add(loadPax.getDob());
       dat.add(loadPax.getEtkType());
       dat.add(loadPax.getGender());
       dat.add(loadPax.getHandicapped());
       dat.add(loadPax.getInfantIndicator());
       dat.add(loadPax.getIntId());
       dat.add(loadPax.getNationality());
       dat.add(loadPax.getOffLoadedPax());
       dat.add(loadPax.getPaxBookingStatus());
       dat.add(loadPax.getPaxGroupCode());
       dat.add(loadPax.getPaxName());
       dat.add(loadPax.getPaxType());
       dat.add(loadPax.getPriorityPax());
       dat.add(loadPax.getStatusOnboard());
       dat.add(loadPax.getTravelledClass());
       dat.add(loadPax.getSeatNumber());
       dat.add(loadPax.getUnAccompaniedMinor());
       dat.add(loadPax.getBagTagInfo());
       dat.add(loadPax.getScanLocation());
       dat.add(loadPax.getScanDateTime());
       dat.add(loadPax.getCheckInAgentCode());
       dat.add(loadPax.getCheckInHandlingAgent());
       dat.add(loadPax.getCheckInSequence());
       dat.add(loadPax.getCheckInCity());
       dat.add(loadPax.getBoardingDateTime());
       dat.add(loadPax.getBoardingAgentCode());
       dat.add(loadPax.getBoardingHandlingAgent());
       dat.add(loadPax.getIdConxFlight()); // ADDED BY 2013-12-23
       
       if (oldData != null && oldData instanceof EntDbLoadPaxX){
        EntDbLoadPaxX oloadPax = (EntDbLoadPaxX) oldData;
//         odat.add(oloadPax.getUuid());
         odat.add(oloadPax.getIntFlId());
         odat.add(oloadPax.getIntRefNumber());
         odat.add(oloadPax.getIntSystem());
         odat.add(oloadPax.getIdFlight());
         odat.add(oloadPax.getIdLoadPaxConnect());
         odat.add(oloadPax.getBagNoOfPieces());
         odat.add(oloadPax.getBagTagPrint());
         odat.add(oloadPax.getBagWeight());
         odat.add(oloadPax.getBoardingPassprint());
         odat.add(oloadPax.getBoardingStatus());
         odat.add(oloadPax.getBookedClass());
         odat.add(oloadPax.getCabinClass());
         odat.add(oloadPax.getUpgradeIndicator());
         odat.add(oloadPax.getTransitIndicator());
         odat.add(oloadPax.getCancelled());
         odat.add(oloadPax.getJtopPax());
         odat.add(oloadPax.getTransitBagIndicator());
         odat.add(oloadPax.getETickedId());
         odat.add(oloadPax.getTicketNumber());
         odat.add(oloadPax.getCouponNumber());
         odat.add(oloadPax.getApdType());
         odat.add(oloadPax.getDocumentType());
         odat.add(oloadPax.getDocumentNumber());
         odat.add(oloadPax.getDocumentExpiryDate());
         odat.add(oloadPax.getDocumentIssuedDate());
         odat.add(oloadPax.getDocumentIssuedCountry());
         odat.add(oloadPax.getCountryOfBirth());
         odat.add(oloadPax.getCountryOfResidence());
         odat.add(oloadPax.getItnEmbarkation());
         odat.add(oloadPax.getItnDisembarkation());
         odat.add(oloadPax.getPaxStatus());
         odat.add(oloadPax.getCheckInDateTime());
         odat.add(oloadPax.getDestination());
         odat.add(oloadPax.getDob());
         odat.add(oloadPax.getEtkType());
         odat.add(oloadPax.getGender());
         odat.add(oloadPax.getHandicapped());
         odat.add(oloadPax.getInfantIndicator());
         odat.add(oloadPax.getIntId());
         odat.add(oloadPax.getNationality());
         odat.add(oloadPax.getOffLoadedPax());
         odat.add(oloadPax.getPaxBookingStatus());
         odat.add(oloadPax.getPaxGroupCode());
         odat.add(oloadPax.getPaxName());
         odat.add(oloadPax.getPaxType());
         odat.add(oloadPax.getPriorityPax());
         odat.add(oloadPax.getStatusOnboard());
         odat.add(oloadPax.getTravelledClass());
         odat.add(oloadPax.getSeatNumber());
         odat.add(oloadPax.getUnAccompaniedMinor());
         odat.add(oloadPax.getBagTagInfo());
         odat.add(oloadPax.getScanLocation());
         odat.add(oloadPax.getScanDateTime());
         odat.add(oloadPax.getCheckInAgentCode());
         odat.add(oloadPax.getCheckInHandlingAgent());
         odat.add(oloadPax.getCheckInSequence());
         odat.add(oloadPax.getCheckInCity());
         odat.add(oloadPax.getBoardingDateTime());
         odat.add(oloadPax.getBoardingAgentCode());
         odat.add(oloadPax.getBoardingHandlingAgent());
         odat.add(oloadPax.getIdConxFlight());    // ADDED BY 2013-12-23
       }
       
    }else if(data instanceof EntDbLoadPaxConnX){
      EntDbLoadPaxConnX loadPaxConn = (EntDbLoadPaxConnX) data;
//      fld.add(Integer.toString(loadPaxConn.getIdFlight()));

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    case "paxDetails":
      try {


        if ( msgString.contains("PaxDetails")) {
          Object o = blHandleMacsPax.unMarshal(name, msgString, irmtabRef, message);
          EntDbLoadPaxX entDbLoadPax =null;
          if (o != null ){
            entDbLoadPax =  (EntDbLoadPaxX)o;
          }
          
//          long startTime = System.currentTimeMillis();

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    protected EntityManager getEntityManager() {
        return em;
    }
    
    public EntDbLoadPaxX findByPkIdX(String intFlId, String intRefNumber){
      EntDbLoadPaxX result = null;
  
    CriteriaBuilder cb = em.getCriteriaBuilder();
     CriteriaQuery<EntDbLoadPaxX> cq = cb.createQuery(EntDbLoadPaxX.class);
    Root<EntDbLoadPaxX> r = cq.from(EntDbLoadPaxX.class);
    cq.select(r);

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    
    return result;
    }
    
    public EntDbLoadPaxX findByIdLoadPax(String uuid){
      EntDbLoadPaxX result = null;
      
    CriteriaBuilder cb = em.getCriteriaBuilder();
     CriteriaQuery<EntDbLoadPaxX> cq = cb.createQuery(EntDbLoadPaxX.class);
     Root<EntDbLoadPaxX> r = cq.from(EntDbLoadPaxX.class);
    cq.select(r);

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    String selectStr = "";
    String idFlightStr ="";
    
    try{
    if (data instanceof EntDbLoadPaxX){
      EntDbLoadPaxX loadPax = (EntDbLoadPaxX) data;
//      fld.add(Integer.toString(loadPax.getIdFlight()));
      tabName = "LOAD_PAX";
      selectStr = "WHERE ID = '"+loadPax.getUuid()+"'";
      idFlightStr = Integer.toString(loadPax.getIdFlight());
      ld.add(loadPax.getUuid());
      // add fields
//      fld.add("ID");
       fld.add("INTFLID");
       fld.add("INTREFNUMBER");
       fld.add("DATA_SOURCE");
       fld.add("ID_FLIGHT");
       fld.add("ID_LOAD_PAX_CONNECT");
       fld.add("BAGNOOFPIECES");
       fld.add("BAGTAGPRINT");
       fld.add("BAGWEIGHT");
       fld.add("BOARDINGPASSPRINT");
       fld.add("BOARDINGSTATUS");
       fld.add("BOOKEDCLASS");
       fld.add("CABINCLASS");
       fld.add("UPGRADE_INDICATOR");
       fld.add("TRANSIT_INDICATOR");
       fld.add("CANCELLED");
       fld.add("JTOP_PAX");
       fld.add("TRANSIT_BAG_INDICATOR");
       fld.add("E_TICKET_ID");
       fld.add("TICKET_NUMBER");
       fld.add("COUPON_NUMBER");
       fld.add("APD_TYPE");
       fld.add("DOCUMENT_TYPE");
       fld.add("DOCUMENT_NUMBER");
       fld.add("DOCUMENT_EXPIRY_DATE");
       fld.add("DOCUMENT_ISSUED_DATE");
       fld.add("DOCUMENT_ISSUED_COUNTRY");
       fld.add("COUNTRY_OF_BIRTH");
       fld.add("COUNTRY_OF_RESIDENCE");
       fld.add("ITN_EMBARKATION");
       fld.add("ITN_DISEMBARKATION");
       fld.add("PAX_STATUS");
       fld.add("CHECKINDATETIME");
       fld.add("DESTINATION");
       fld.add("DOB");
       fld.add("ETKTYPE");
       fld.add("GENDER");
       fld.add("HANDICAPPED");
       fld.add("INFANTINDICATOR");
       fld.add("INTID");
       fld.add("NATIONALITY");
       fld.add("OFFLOADEDPAX");
       fld.add("PAXBOOKINGSTATUS");
       fld.add("PAXGROUPCODE");
       fld.add("PAXNAME");
       fld.add("PAXTYPE");
       fld.add("PRIORITYPAX");
       fld.add("STATUSONBOARD");
       fld.add("TRAVELLEDCLASS");
       fld.add("SEAT_NUMBER");
       fld.add("UNACCOMPANIEDMINOR");
       fld.add("BAGTAGINFO");
       fld.add("SCANLOCATION");
       fld.add("SCANDATETIME");
       fld.add("CHECKINAGENTCODE");
       fld.add("CHECKINHANDLINGAGENT");
       fld.add("CHECKINSEQUENCE");
       fld.add("CHECKINCITY");
       fld.add("BOARDINGDATETIME");
       fld.add("BOARDINGAGENTCODE");
       fld.add("BOARDINGHANDLINGAGENT");
       fld.add("ID_CONX_FLIGHT");  // ADDED BY 2013-12-23
      // populate data
//      dat.add(loadPax.getUuid());
       dat.add(loadPax.getIntFlId());
       dat.add(loadPax.getIntRefNumber());
       dat.add(loadPax.getIntSystem());
       dat.add(loadPax.getIdFlight());
       dat.add(loadPax.getIdLoadPaxConnect());
       dat.add(loadPax.getBagNoOfPieces());
       dat.add(loadPax.getBagTagPrint());
       dat.add(loadPax.getBagWeight());
       dat.add(loadPax.getBoardingPassprint());
       dat.add(loadPax.getBoardingStatus());
       dat.add(loadPax.getBookedClass());
       dat.add(loadPax.getCabinClass());
       dat.add(loadPax.getUpgradeIndicator());
       dat.add(loadPax.getTransitIndicator());
       dat.add(loadPax.getCancelled());
       dat.add(loadPax.getJtopPax());
       dat.add(loadPax.getTransitBagIndicator());
       dat.add(loadPax.getETickedId());
       dat.add(loadPax.getTicketNumber());
       dat.add(loadPax.getCouponNumber());
       dat.add(loadPax.getApdType());
       dat.add(loadPax.getDocumentType());
       dat.add(loadPax.getDocumentNumber());
       dat.add(loadPax.getDocumentExpiryDate());
       dat.add(loadPax.getDocumentIssuedDate());
       dat.add(loadPax.getDocumentIssuedCountry());
       dat.add(loadPax.getCountryOfBirth());
       dat.add(loadPax.getCountryOfResidence());
       dat.add(loadPax.getItnEmbarkation());
       dat.add(loadPax.getItnDisembarkation());
       dat.add(loadPax.getPaxStatus());
       dat.add(loadPax.getCheckInDateTime());
       dat.add(loadPax.getDestination());
       dat.add(loadPax.getDob());
       dat.add(loadPax.getEtkType());
       dat.add(loadPax.getGender());
       dat.add(loadPax.getHandicapped());
       dat.add(loadPax.getInfantIndicator());
       dat.add(loadPax.getIntId());
       dat.add(loadPax.getNationality());
       dat.add(loadPax.getOffLoadedPax());
       dat.add(loadPax.getPaxBookingStatus());
       dat.add(loadPax.getPaxGroupCode());
       dat.add(loadPax.getPaxName());
       dat.add(loadPax.getPaxType());
       dat.add(loadPax.getPriorityPax());
       dat.add(loadPax.getStatusOnboard());
       dat.add(loadPax.getTravelledClass());
       dat.add(loadPax.getSeatNumber());
       dat.add(loadPax.getUnAccompaniedMinor());
       dat.add(loadPax.getBagTagInfo());
       dat.add(loadPax.getScanLocation());
       dat.add(loadPax.getScanDateTime());
       dat.add(loadPax.getCheckInAgentCode());
       dat.add(loadPax.getCheckInHandlingAgent());
       dat.add(loadPax.getCheckInSequence());
       dat.add(loadPax.getCheckInCity());
       dat.add(loadPax.getBoardingDateTime());
       dat.add(loadPax.getBoardingAgentCode());
       dat.add(loadPax.getBoardingHandlingAgent());
       dat.add(loadPax.getIdConxFlight()); // ADDED BY 2013-12-23
       
       if (oldData != null && oldData instanceof EntDbLoadPaxX){
        EntDbLoadPaxX oloadPax = (EntDbLoadPaxX) oldData;
//         odat.add(oloadPax.getUuid());
         odat.add(oloadPax.getIntFlId());
         odat.add(oloadPax.getIntRefNumber());
         odat.add(oloadPax.getIntSystem());
         odat.add(oloadPax.getIdFlight());
         odat.add(oloadPax.getIdLoadPaxConnect());
         odat.add(oloadPax.getBagNoOfPieces());
         odat.add(oloadPax.getBagTagPrint());
         odat.add(oloadPax.getBagWeight());
         odat.add(oloadPax.getBoardingPassprint());
         odat.add(oloadPax.getBoardingStatus());
         odat.add(oloadPax.getBookedClass());
         odat.add(oloadPax.getCabinClass());
         odat.add(oloadPax.getUpgradeIndicator());
         odat.add(oloadPax.getTransitIndicator());
         odat.add(oloadPax.getCancelled());
         odat.add(oloadPax.getJtopPax());
         odat.add(oloadPax.getTransitBagIndicator());
         odat.add(oloadPax.getETickedId());
         odat.add(oloadPax.getTicketNumber());
         odat.add(oloadPax.getCouponNumber());
         odat.add(oloadPax.getApdType());
         odat.add(oloadPax.getDocumentType());
         odat.add(oloadPax.getDocumentNumber());
         odat.add(oloadPax.getDocumentExpiryDate());
         odat.add(oloadPax.getDocumentIssuedDate());
         odat.add(oloadPax.getDocumentIssuedCountry());
         odat.add(oloadPax.getCountryOfBirth());
         odat.add(oloadPax.getCountryOfResidence());
         odat.add(oloadPax.getItnEmbarkation());
         odat.add(oloadPax.getItnDisembarkation());
         odat.add(oloadPax.getPaxStatus());
         odat.add(oloadPax.getCheckInDateTime());
         odat.add(oloadPax.getDestination());
         odat.add(oloadPax.getDob());
         odat.add(oloadPax.getEtkType());
         odat.add(oloadPax.getGender());
         odat.add(oloadPax.getHandicapped());
         odat.add(oloadPax.getInfantIndicator());
         odat.add(oloadPax.getIntId());
         odat.add(oloadPax.getNationality());
         odat.add(oloadPax.getOffLoadedPax());
         odat.add(oloadPax.getPaxBookingStatus());
         odat.add(oloadPax.getPaxGroupCode());
         odat.add(oloadPax.getPaxName());
         odat.add(oloadPax.getPaxType());
         odat.add(oloadPax.getPriorityPax());
         odat.add(oloadPax.getStatusOnboard());
         odat.add(oloadPax.getTravelledClass());
         odat.add(oloadPax.getSeatNumber());
         odat.add(oloadPax.getUnAccompaniedMinor());
         odat.add(oloadPax.getBagTagInfo());
         odat.add(oloadPax.getScanLocation());
         odat.add(oloadPax.getScanDateTime());
         odat.add(oloadPax.getCheckInAgentCode());
         odat.add(oloadPax.getCheckInHandlingAgent());
         odat.add(oloadPax.getCheckInSequence());
         odat.add(oloadPax.getCheckInCity());
         odat.add(oloadPax.getBoardingDateTime());
         odat.add(oloadPax.getBoardingAgentCode());
         odat.add(oloadPax.getBoardingHandlingAgent());
         odat.add(oloadPax.getIdConxFlight());    // ADDED BY 2013-12-23
       }
       
    }else if(data instanceof EntDbLoadPaxConnX){
      EntDbLoadPaxConnX loadPaxConn = (EntDbLoadPaxConnX) data;
//      fld.add(Integer.toString(loadPaxConn.getIdFlight()));

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    entDbLoadPax.setIdFlight(idFlight);


    // search records form load_pax table
    long startTime = System.currentTimeMillis();
    entDbLoadPax.setIntSystem(HpEKConstants.MACS_PAX_DATA_SOURCE);
    EntDbLoadPaxX entDbLoadPaxFind = _paxbean.findByPkIdX(entDbLoadPax.getIntFlId(), entDbLoadPax.getIntRefNumber());
    LOG.info("1.2.4 search records from loadPax table for paxDetails Msg, takes {} ms",
        System.currentTimeMillis() - startTime);


    // insert or update to LOAD_PAX table
    if (entDbLoadPaxFind != null) {


      EntDbLoadPaxX oldEntDbLoadPax = (EntDbLoadPaxX)SerializationUtils.clone(entDbLoadPaxFind);


      startTime = System.currentTimeMillis();
      // update loadPax
//      // change to static code
      entDbLoadPaxFind.setIntFlId(entDbLoadPax.getIntFlId());

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

//            entDbLoadPaxConnFind.getInterfaceFltid(),
//            entDbLoadPaxConnFind.getIntRefNumber());
//        sendErroNotification(EnumExceptionCodes.WNOPX,irmtabRef);
//    
//      }
      EntDbLoadPaxX paxFoundWithPaxConn = _paxbean.findByIdLoadPax(entDbLoadPaxConnFind.getIdLoadPax());
      


      if (paxFoundWithPaxConn == null) {
//        entDbLoadPaxConnFind.setIdLoadPax("0");
        entDbLoadPaxConnFind.setIdFlight(0);
        entDbLoadPaxConnFind.set_updateUser(HpEKConstants.MACS_PAX_DATA_SOURCE);
        entDbLoadPaxConnFind.set_updatedDate(HpUfisCalendar.getCurrentUTCTime());


        LOG.warn("pax not found for pax connct info and to update IRMTAB");
        startTime = System.currentTimeMillis();


        LOG.debug("1.2.4 pax not found and update IRMTAB, takes {} ms",
            System.currentTimeMillis() - startTime);
      } else {
        LOG.debug("Pax found for pax connect info b");


        entDbLoadPaxConnFind.setIdLoadPax(paxFoundWithPaxConn.getUuid());
        entDbLoadPaxConnFind.setIdFlight(paxFoundWithPaxConn.getIdFlight());
        entDbLoadPaxConnFind.setInterfaceFltid(paxFoundWithPaxConn.getIntFlId());
        paxFoundWithPaxConn.setIdLoadPaxConnect(
            entDbLoadPaxConnFind.getUuid());
        paxFoundWithPaxConn.setIdConxFlight(entDbLoadPaxConnFind.getIdConxFlight()); // added by 2013-12-23
        entDbLoadPaxConnFind
            .set_updateUser(HpEKConstants.MACS_PAX_DATA_SOURCE);
        entDbLoadPaxConnFind.set_updatedDate(HpUfisCalendar.getCurrentUTCTime());


        
        // send notification 
        ufisTopicProducer.sendNotification(true, UfisASCommands.URT,
            String.valueOf(entDbLoadPaxConnFind.getIdFlight()), oldEntDbLoadPaxConn, entDbLoadPaxConnFind);
        
//        entDbLoadPax = entDbLoadPaxConnFind.getPax();
      }


      LOG.info("1.2.5 update PaxConn Msg to database, takes {} ms",
          (System.currentTimeMillis() - startTime));


    } else {
      startTime = System.currentTimeMillis();


      _paxConBean.Persist(entDbLoadPaxConn);


      LOG.info("1.2.4 insert PaxConn Msg to database, takes {} ms",
          (System.currentTimeMillis() - startTime));


      
      // send notification
      ufisTopicProducer.sendNotification(true, UfisASCommands.IRT,
          String.valueOf(entDbLoadPaxConn.getIdFlight()), null, entDbLoadPaxConn);


      startTime = System.currentTimeMillis();
//      LoadPaxPK pkSearch = new LoadPaxPK();
//      pkSearch.setIntflid(entDbLoadPaxConn.getInterfaceFltid());
//      pkSearch.setIntrefnumber(entDbLoadPaxConn.getIntRefNumber());
      EntDbLoadPaxX paxForPaxConn = _paxbean.findByPkIdX(entDbLoadPaxConn.getInterfaceFltid(), entDbLoadPaxConn.getIntRefNumber());
      LOG.info("1.2.4+  search pax for paxConn, takes {} ms",
          (System.currentTimeMillis() - startTime));


      if (paxForPaxConn == null) {
        entDbLoadPaxConn.setIdLoadPax("0");
        entDbLoadPaxConn.setIdFlight(0);


        LOG.warn("pax not found for pax connct info and to update IRMTAB");
//        startTime = System.currentTimeMillis();
//        sendErroNotification(EnumExceptionCodes.WNOPX.name()," SELECT * FROM LOAD_PAX WHERE INTERFACE_FLTID = "+entDbLoadPaxConn.getInterfaceFltid()+" AND INTREFNUMBER = "+entDbLoadPaxConn.getIntRefNumber(),irmtabRef);
          
//        LOG.debug("1.2.4 pax not found and send exception msg, takes {} ms",
//            (System.currentTimeMillis() - startTime));
      } else {
        LOG.debug("Pax found for pax connect info a");


        entDbLoadPaxConn.setIdLoadPax(paxForPaxConn.getUuid());
        entDbLoadPaxConn.setIdFlight(paxForPaxConn.getIdFlight());
        paxForPaxConn.setIdLoadPaxConnect(entDbLoadPaxConn.getUuid());
        paxForPaxConn.setIdConxFlight(entDbLoadPaxConn.getIdConxFlight());
        entDbLoadPaxConn.setInterfaceFltid(paxForPaxConn.getIntFlId());
        
        // added 2013-12-04
        ArrayList<EntDbLoadBag> loadBagList = (ArrayList<EntDbLoadBag>) dlLoadBagUpdateLocal.getBagMoveDetailsByPaxX(entDbLoadPaxConn.getUuid());
        Iterator <EntDbLoadBag> loadBagListIt = loadBagList.iterator();
        while (loadBagListIt.hasNext()){
//          loadBagListIt.next().setBagType(HpEKConstants.BAGTYPE_T);
          EntDbLoadBag loadBag = loadBagListIt.next();
          loadBag.setBagType(HpEKConstants.BAGTYPE_T);
          // added by 2014-01-03
          loadBag.setId_Flight(new BigDecimal(paxForPaxConn.getIdFlight()));
          loadBag.setIdConxFlight(new BigDecimal(paxForPaxConn.getIdConxFlight()));
          loadBag.setUpdatedUser(HpEKConstants.MACS_PAX_DATA_SOURCE);
          loadBag.setUpdatedDate(HpUfisCalendar.getCurrentUTCTime());
          // added by 2013-12-20
          if (HpEKConstants.ARR_DEP_FALG_D.equals(arrDepFlag)){
            loadBag.setIdFlight(entDbLoadPaxConn.getIdConxFlight());

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    if (irmtabRef > 0) {
      msgLogged = Boolean.TRUE;
    }
    


    EntDbLoadPaxX entDbLoadPax = null;


    if (entDbPaxServiceRequest.getIntFlId() != null
        && !"".equals(entDbPaxServiceRequest.getIntFlId().toString()
            .trim())) {
      long startTime = System.currentTimeMillis();
//      LoadPaxPK loadPaxPK = new LoadPaxPK();
//      loadPaxPK.setIntflid(entDbPaxServiceRequest.getIntFlId());
//      loadPaxPK.setIntrefnumber(entDbPaxServiceRequest.getIntRefNumber());
      // loadPaxPK.setIntSystem(HpEKConstants.MACS_PAX_DATA_SOURCE);
      entDbLoadPax = _paxbean.findByPkIdX(entDbPaxServiceRequest.getIntFlId(), entDbPaxServiceRequest.getIntRefNumber());
      LOG.info(
          "1.2.1 search from LoadPax table for Fct Msg, takes {} ms",
          (System.currentTimeMillis() - startTime));
    }


    if (entDbLoadPax != null) {
      entDbPaxServiceRequest.setIdFlight(entDbLoadPax.getIdFlight());
      entDbPaxServiceRequest.setIdLoadPax(entDbLoadPax.getUuid());


      LOG.debug("Pax found for service info");
    } else {
      entDbPaxServiceRequest.setIdFlight(0);
      entDbPaxServiceRequest.setIdLoadPax("0");

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

        // update load_pax
        List<EntDbLoadPaxX> loadPaxList = _paxbean
            .findByIntFltId(intFlId);
        Iterator<EntDbLoadPaxX> loadPaxListIt = loadPaxList.iterator();
        while (loadPaxListIt.hasNext()) {
          EntDbLoadPaxX entDbLoadPax = loadPaxListIt.next();


          if (idFlight != entDbLoadPax.getIdFlight()) {


            EntDbLoadPaxX oldEntDbLoadPax = (EntDbLoadPaxX)SerializationUtils.clone(entDbLoadPax);


            entDbLoadPax.setIdFlight(idFlight);
            entDbLoadPax
                .set_updateUser(HpEKConstants.MACS_PAX_DATA_SOURCE);
            entDbLoadPax.set_updatedDate(HpUfisCalendar

View Full Code Here

Examples of com.ufis_as.ek_if.macs.entities.EntDbLoadPaxX

    }
    return null;
  }


  public EntDbLoadPaxX readStorePax(PaxDetails paxDetails, long irmtabRef, Message message) {
    EntDbLoadPaxX result = null;
    
    if (paxDetails != null) {
      
          logLevel = entStartupInitSingleton.getIrmLogLev();
        
        msgLogged = Boolean.FALSE;
        if (irmtabRef > 0) {
          msgLogged = Boolean.TRUE;
        }
        
        // == START ==
        /* - Added by BTR  - 17Jan2014
         * - Changes    - Reject to process the msg if the pax_status = "PD"
         */
        if("PD".equalsIgnoreCase(paxDetails.getSTATUS())){
          LOG.error("PAX status is PD. PaxDetail msg is rejected.");
        //  sendErroNotification(EnumExceptionCodes.WPXPD.name(), EnumExceptionCodes.WPXPD.toString(), irmtabRef);
          return null;
        }
        // == END ==
        
      HpUfisCalendar ufisCalendar = new HpUfisCalendar();
      ufisCalendar.setCustomFormat(HpEKConstants.MACS_TIME_FORMAT); // 2012-12-18 00:00:00
      SimpleDateFormat macsTimeFormat = new SimpleDateFormat(HpEKConstants.MACS_TIME_FORMAT);


      EntDbLoadPaxX edpiod = new EntDbLoadPaxX();
//      LoadPaxPK paxPk = new LoadPaxPK();


      // check as it's a mandatory field
      if (paxDetails.getMFLID() != null
          && !paxDetails.getMFLID().isEmpty()) {
//        paxPk.setIntflid(paxDetails.getMFLID());
        edpiod.setIntFlId(paxDetails.getMFLID());
      } else {
        LOG.info("Mandatory field MFL_ID is null or empty, PaxDetails Message is rejected");
        sendErroNotification(EnumExceptionCodes.EMAND.name(),"Mandatory field MFL_ID is null or empty, PaxDetails Message is rejected",irmtabRef, message);
         return null;
      }


      // check as it's a mandatory field
      if (paxDetails.getREFERENCENUMBER() != null
          && !paxDetails.getREFERENCENUMBER().isEmpty()) {
        edpiod.setIntRefNumber(paxDetails.getREFERENCENUMBER());
      } else {
        LOG.info("Mandatory field REFERENCE_NUMBER is null or empty, PaxDetails Message is rejected");
        sendErroNotification(EnumExceptionCodes.EMAND.name(),"Mandatory field REFERENCE_NUMBER is null or empty, PaxDetails Message is rejected",irmtabRef, message);
         return null;
      }
      
      // check wrong paxType condition when infant indicator have value I (added new logic by 2013-12-2)
      if ("C".equalsIgnoreCase(paxDetails.getPAXTYPE()) && "I".equalsIgnoreCase(paxDetails.getINFANTINDICATOR())){
        LOG.info("wrong paxType 'C' when infant indicator have value 'I', PaxDetails Message is rejected");
        sendErroNotification(EnumExceptionCodes.EWPTY.name(),"wrong paxType 'C' when infant indicator have value 'I', PaxDetails Message is rejected",irmtabRef, message);
         return null;
      }
      
//      paxPk.setIntSystem("MACS");
      edpiod.setIntSystem(HpEKConstants.MACS_PAX_DATA_SOURCE);
//      edpiod.setPKId(paxPk);
      // edpiod.setpKId(paxPk);


      // check as it's a mandatory field
      if (paxDetails.getPAXID() != null
          && !paxDetails.getPAXID().isEmpty()) {
        edpiod.setIntId(paxDetails.getPAXID());
      } else {
        LOG.info("Mandatory field PAX_ID is null or empty, PaxDetails Message is rejected");
        sendErroNotification(EnumExceptionCodes.EMAND.name(),"Mandatory field PAX_ID is null or empty, PaxDetails Message is rejected",irmtabRef, message);
         return null;
      }


      edpiod.setDestination(paxDetails.getDESTINATION());


      if (paxDetails.getPAXNAME() != null) {
        String paxName = paxDetails.getPAXNAME().replaceAll("/", " ");
        edpiod.setPaxName(paxName);
      }


      edpiod.setCabinClass(paxDetails.getCABINCLASS());
      edpiod.setBookedClass(paxDetails.getBOOKEDCLASS());
      edpiod.setPaxType(paxDetails.getPAXTYPE());
      edpiod.setPaxGroupCode(paxDetails.getPAXGROUPCODE());
      edpiod.setHandicapped(paxDetails.getHANDICAPPED());
      edpiod.setUnAccompaniedMinor(paxDetails.getUNACCOMPANIEDMINOR());
      edpiod.setPriorityPax(paxDetails.getPRIORITYPAX());
      edpiod.setBoardingPassprint(paxDetails.getBOARDINGPASSPRINT());
      // edpiod.setBagTagPrint(paxDetails.get); !!!! there is no this tag
      // in current xsd
      if(!Arrays.asList(bookingStatusList).contains(paxDetails.getPAXBOOKINGSTATUS())){
//        blIrmtabFacade.updateIRMStatus(PaxProcessSingleton.nextUrno, "WNOMD");
        LOG.warn("bookingStatus {} is not in the possible values from paxDetails msg and updated to IRMTAB, intId {}", paxDetails.getPAXBOOKINGSTATUS(), paxDetails.getPAXID());
        sendErroNotification(EnumExceptionCodes.WENUM.name(),"bookingStatus "+paxDetails.getPAXBOOKINGSTATUS()+" is not in the possible values from paxDetails msg and updated to IRMTAB, intId "+paxDetails.getPAXID()+"",irmtabRef, message);
      }
      edpiod.setPaxBookingStatus(paxDetails.getPAXBOOKINGSTATUS());
      edpiod.setTravelledClass(paxDetails.getTRAVELLEDCLASS());
      edpiod.setBagTagInfo(paxDetails.getVARIABLEDATA());
      edpiod.setScanLocation(paxDetails.getSCANNEDLOCATION());


      // set bag weight and piece, original data: e.g 002/0053/00
      String bagPicAndWeight = "";
      if (paxDetails.getNUMBEROFPCSWEIGHT() != null) {
        bagPicAndWeight = paxDetails.getNUMBEROFPCSWEIGHT();
      }
      String numberOfBag = "0";
      String weightOfBag = "0";
      int tagIndex = bagPicAndWeight.indexOf("/");
      int tagIndex2 = bagPicAndWeight.indexOf("/", tagIndex + 1);
      if (bagPicAndWeight != null && !"".equals(bagPicAndWeight)
          && tagIndex > 0 && tagIndex2 > 0) {
        numberOfBag = bagPicAndWeight.substring(0, tagIndex);
        weightOfBag = bagPicAndWeight
            .substring(tagIndex + 1, tagIndex2);
      }else if (bagPicAndWeight != null && bagPicAndWeight.length() > 3 && "PLD".equalsIgnoreCase(bagPicAndWeight.substring(0,3))){
        edpiod.setPooledBagRef(bagPicAndWeight);
      }
      edpiod.setBagWeight(new BigDecimal(weightOfBag));
      edpiod.setBagNoOfPieces(new BigDecimal(numberOfBag));


      // // set check in date time
      // String cheInDate = "";
      // if (paxDetails.getCHECKINDATE() != null){
      // cheInDate = paxDetails.getCHECKINDATE();
      // }
      // String cheInTime = paxDetails.getCHECKINTIME();
      // String cheInDateTime = "";
      // Date cheInDateTimeD = null;
      //
      // int spaceIndex = cheInDate.indexOf(" ");
      //
      // if (spaceIndex > 0 && cheInTime.length() >= 4){
      // cheInDate = cheInDate.substring(0, spaceIndex);
      // cheInDateTime = cheInDate +
      // " "+cheInTime.substring(0,2)+":"+cheInTime.substring(2,4)+":00";
      // try {
      // cheInDateTimeD = new
      // SimpleDateFormat("yyyy-MM-dd hh:mm:ss").parse(cheInDateTime);
      // edpiod.setCheckInDateTime(cheInDateTimeD);
      // } catch (ParseException e) {
      // LOG.debug("set cheInDateTime "+e.toString());
      // }
      // }


      // set check in date time
      if (paxDetails.getCHECKINDATE() != null
          && !paxDetails.getCHECKINDATE().isEmpty()) {
        ufisCalendar.setTime(paxDetails.getCHECKINDATE(),
            ufisCalendar.getCustomFormat());
        if (paxDetails.getCHECKINTIME().length() >= 4) {
          int hour = 0;
          int min = 0;
          try {
            hour = Integer.parseInt(paxDetails.getCHECKINTIME()
                .substring(0, 2));
            min = Integer.parseInt(paxDetails.getCHECKINTIME()
                .substring(2, 4));
          } catch (Exception e) {
            LOG.info("PaxDetails message Checking Time parse erro");
          }
          ufisCalendar.DateAdd(hour, EnumTimeInterval.Hours);
          ufisCalendar.DateAdd(min, EnumTimeInterval.Minutes);
        }
        edpiod.setCheckInDateTime(ufisCalendar.getTime());
      }


      // // set scan date time
      // String scanDate = "";
      // if (paxDetails.getSCANNEDLOCALDATE() != null){
      // scanDate = paxDetails.getSCANNEDLOCALDATE();
      // }
      // String scanTime = paxDetails.getSCANNEDLOCALTIME();
      // String scanDateTime = "";
      // Date scanDateTimeD = null;
      //
      // int scanSpaceIndex = scanDate.indexOf(" ");
      //
      // if (scanSpaceIndex > 0 && scanTime.length() >= 4){
      // scanDate = scanDate.substring(0, scanSpaceIndex);
      // scanDateTime = scanDate +
      // " "+scanTime.substring(0,2)+":"+scanTime.substring(2,4)+":00";
      // try {
      // scanDateTimeD = new
      // SimpleDateFormat("yyyy-MM-dd hh:mm:ss").parse(scanDateTime);
      // edpiod.setScanDateTime(scanDateTimeD);
      // } catch (ParseException e) {
      // LOG.debug("set scanDateTime "+e.toString());
      // }
      // }
      //
      
      edpiod.setBoardingStatus(paxDetails.getBOARDINGSTATUS());
      edpiod.setCancelled(paxDetails.getCANCELLED());
      edpiod.setOffLoadedPax(paxDetails.getOFFLOADEDPAX());
      edpiod.setEtkType(paxDetails.getETKTYPE());


      // set scan date time
      if (paxDetails.getSCANNEDLOCALDATE() != null
          && !paxDetails.getSCANNEDLOCALDATE().isEmpty()) {
        ufisCalendar.setTime(paxDetails.getSCANNEDLOCALDATE(),
            ufisCalendar.getCustomFormat());
        if (paxDetails.getCHECKINTIME().length() >= 4) {
          int hour = 0;
          int min = 0;
          try {
            hour = Integer.parseInt(paxDetails
                .getSCANNEDLOCALTIME().substring(0, 2));
            min = Integer.parseInt(paxDetails.getSCANNEDLOCALTIME()
                .substring(2, 4));
            
//            // added by 2014-01-02
//            // convert local to UTC
//            // search for time difference
//            long startTIme = System.currentTimeMillis();
//            String timeDiffStr =  dlApttabBean.getTDI1(paxDetails.getCHECKINCITY());
//            if (timeDiffStr != null && !"".equals(timeDiffStr)){
//              LOG.debug("parse timeDiffStr {} to int", timeDiffStr);
//              int timeDiffInt = Integer.parseInt(timeDiffStr);
//              min = min - timeDiffInt;
//            }
//            LOG.debug("search tdi1 from apttab table, apc3 {} , takes {}",paxDetails.getCHECKINCITY(), System.currentTimeMillis() - startTIme);
            
          } catch (Exception e) {
            LOG.info("PaxDetails message Scanned Time parse erro, {}" ,e);
          }
          ufisCalendar.DateAdd(hour, EnumTimeInterval.Hours);
          ufisCalendar.DateAdd(min, EnumTimeInterval.Minutes);
        }
        edpiod.setScanDateTime(ufisCalendar.getTime());
      }


      // set date of birth
      Date dob = null;
      try {
        String dobString = paxDetails.getDATEOFBIRTH();
        if (dobString != null && !dobString.isEmpty()) {
          dob = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss")
              .parse(dobString);
        }
        edpiod.setDob(dob);
      } catch (ParseException e) {
        LOG.info("PaxDetails Message, dob parse erro");
      }


      edpiod.setNationality(paxDetails.getNATIONALITY());
      edpiod.setGender(paxDetails.getGENDER());
      if (Arrays.asList(statusOnBoardList).contains(paxDetails.getSTATUSONBOARD())){
//        blIrmtabFacade.updateIRMStatus(PaxProcessSingleton.nextUrno, "WNOMD");
        LOG.warn("statusOnBoard {} is not in the possible values from paxDetails msg and updated to IRMTAB, intId {}", paxDetails.getSTATUSONBOARD(), paxDetails.getPAXID());
        sendErroNotification(EnumExceptionCodes.WENUM.name(),"statusOnBoard "+paxDetails.getSTATUSONBOARD()+" is not in the possible values from paxDetails msg and updated to IRMTAB, intId "+paxDetails.getPAXID()+"",irmtabRef, message);
      }
      edpiod.setStatusOnboard(paxDetails.getSTATUSONBOARD());
      edpiod.setInfantIndicator(paxDetails.getINFANTINDICATOR());
      edpiod.setCheckInAgentCode(paxDetails.getCHECKINAGENTCODE());
      edpiod.setCheckInHandlingAgent(paxDetails.getCHECKINHANDLINGAGENT());
      edpiod.setCheckInSequence(paxDetails.getCHECKINSEQUENCE());
      edpiod.setCheckInCity(paxDetails.getCHECKINCITY());
      edpiod.setBoardingAgentCode(paxDetails.getBOARDINGAGENTCODE());
      edpiod.setBoardingHandlingAgent(paxDetails
          .getBOARDINGHANDLINGAGENT());


      // // set boarding datetime
      // String boardingDate = "";
      // if (paxDetails.getCHECKINDATE() != null){
      // boardingDate = paxDetails.getBOARDINGDATE();
      // }
      // String boardingTime = paxDetails.getBOARDINGTIME();
      // String boardingDateTime = "";
      // Date boardingDateTimeD = null;
      //
      // int boardSpaceIndex = boardingDate.indexOf(" ");
      //
      // if (boardSpaceIndex > 0 && boardingTime.length() >= 4){
      // boardingDate = boardingDate.substring(0, boardSpaceIndex);
      // boardingDateTime = boardingDate +
      // " "+boardingTime.substring(0,2)+":"+boardingTime.substring(2,4)+":00";
      // try {
      // boardingDateTimeD = new
      // SimpleDateFormat("yyyy-MM-dd hh:mm:ss").parse(boardingDateTime);
      // edpiod.setBoardingDateTime(boardingDateTimeD);
      // } catch (ParseException e) {
      // LOG.debug("set boardingDateTime "+e.toString());
      // }
      // }


      // set boarding datetime
      if (paxDetails.getBOARDINGDATE() != null
          && !paxDetails.getBOARDINGDATE().isEmpty()) {
        ufisCalendar.setTime(paxDetails.getBOARDINGDATE(),
            ufisCalendar.getCustomFormat());
        if (paxDetails.getBOARDINGTIME().length() >= 4) {
          int hour = 0;
          int min = 0;
          try {
            hour = Integer.parseInt(paxDetails.getBOARDINGTIME()
                .substring(0, 2));
            min = Integer.parseInt(paxDetails.getBOARDINGTIME()
                .substring(2, 4));
            
//            // added by 2014-01-02
//            // convert local to UTC
//            // search for time difference
//            long startTIme = System.currentTimeMillis();
//            String timeDiffStr =  dlApttabBean.getTDI1(paxDetails.getCHECKINCITY());
//            if (timeDiffStr != null && !"".equals(timeDiffStr)){
//              LOG.debug("parse timeDiffStr {} to int", timeDiffStr);
//              int timeDiffInt = Integer.parseInt(timeDiffStr);
//              min = min - timeDiffInt;
//            }
//            LOG.debug("search tdi1 from apttab table, apc3 {} , takes {}",paxDetails.getCHECKINCITY(), System.currentTimeMillis() - startTIme);
            
          } catch (Exception e) {
            LOG.info("PaxDetails message Boarding Time parse erro");
          }
          ufisCalendar.DateAdd(hour, EnumTimeInterval.Hours);
          ufisCalendar.DateAdd(min, EnumTimeInterval.Minutes);
        }
        edpiod.setBoardingDateTime(ufisCalendar.getTime());
      }


      // added by 2013.10.01 according to the new design document
      edpiod.setUpgradeIndicator(paxDetails.getUPGRADEINDICATOR());
      edpiod.setTransitIndicator(paxDetails.getTRANSITINDICATOR());
      edpiod.setSeatNumber(paxDetails.getSEATNUMBER());
      edpiod.setJtopPax(paxDetails.getJTOPPAXRELATION());
      edpiod.setTransitBagIndicator(paxDetails.getTRANSITBAG());
      edpiod.setETickedId(paxDetails.getETKID());
      edpiod.setTicketNumber(paxDetails.getTICKETNUMBER());
      // edpiod .setChkDigit(paxDetails.getch) !!! there is no CHKDIGIT tag in ICD
      edpiod.setCouponNumber(paxDetails.getCOUPONNUMBER());
      edpiod.setApdType(paxDetails.getAPDTYPE());
      edpiod.setDocumentType(paxDetails.getDOCUMENTTYPE());
      edpiod.setDocumentIssuedCountry(paxDetails.getCOUNTRYOFISSUE());
      edpiod.setCountryOfBirth(paxDetails.getCOUNTRYOFBIRTH());
      edpiod.setCountryOfResidence(paxDetails.getCOUNTRYOFRESIDENCE());
      edpiod.setItnEmbarkation(paxDetails.getITNEMBARKATION());
      edpiod.setItnDisembarkation(paxDetails.getITNDISEMBARKATION());
      // added by 2014-01-02
//      edpiod.setPnr(paxDetails.getPNRID());
      // change mapping to RECLOCATOR()
      edpiod.setPnr(paxDetails.getRECLOCATOR());
//        edpiod.setScanStation(paxDetails.getSCANNEDLOCATION()); 
      // "scan_station" or scan_location ?
      // edpiod.setScanTerminal(paxDetails.getscan)
      // edpiod.setScanTransferArea(scanTransferArea);
      // edpiod.setScannerId(scannerId);
      
      edpiod.setPaxStatus(paxDetails.getSTATUS());
      
      try {
        if(paxDetails.getEXPIRYDATE() != null && !"".equals(paxDetails.getEXPIRYDATE().trim())){
        edpiod.setDocumentExpiryDate(macsTimeFormat.parse(paxDetails.getEXPIRYDATE()));
        }
      } catch (ParseException e) {
        LOG.error("Erro when parsing the expire date from string to date, {}",e);
      }
      try {
        if (paxDetails.getDATEOFISSUE() != null && !"".equals(paxDetails.getDATEOFISSUE())){
        edpiod.setDocumentIssuedDate(macsTimeFormat.parse(paxDetails.getDATEOFISSUE()));
        }
      } catch (ParseException e) {
        LOG.error("Erro when parsing the issue date from string date, {}",e);
      }
//      SimpleDateFormat dateOfBirthDf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.