Allineamento Fix DBCFX_SM_681

gnpdev/dbcfx/src/it/valueteam/gnp/systemcontroller/formatcontroller/dbss/DBSSController.java

@@ -322,6 +322,10 @@ public class DBSSController extends SystemController {
                     // Annullamento
                     invioNotifica(gnpCrmNotifyDonorOut);
                     log.write("9999", "invio [Annullamento] a DBSS - id: " + ((UniqueIdNotificationMessage) messaggio).getUnique_id() + " - FINE");
+                } else if (DBSSMap.EVENTO_ESPLETAMENTO_KO.equals(gnpCrmNotifyDonorOut.getTipoEvento())) {
+                    // Espletamento KO
+                    invioNotifica(gnpCrmNotifyDonorOut);
+                    log.write("9999", "invio [Espletamento KO] a DBSS - id: " + ((UniqueIdNotificationMessage) messaggio).getUnique_id() + " - FINE");
                 } else if (DBSSMap.EVENTO_CESSAZIONECONRIENTRO.equals(gnpCrmNotifyDonorOut.getTipoEvento())) {
                     // Cessazione con rientro
                     //invioNotificaCessazioneConRientro(gnpCrmNotifyDonorOut);
@@ -689,6 +693,39 @@ public class DBSSController extends SystemController {
 
                 }
 
+                notifica.setDaScodare((long) 0);
+                notifica.setDataInvioMessaggio(new Date());
+            }
+            else if (notifica.getTipoEvento().equalsIgnoreCase(DBSSMap.EVENTO_ESPLETAMENTO_KO)) {
+                log.write("9999", "invioNotifica Espletamento KO - codice richiesta: " + notifica.getCodiceRichiesta());
+
+                /*
+                 * DBCFX_RU_363 - Offerta Open Fiber FTTH (Business): Implement FASE3
+                 * Nuovo servizio da richiamare CustomerOrderMgmt (InFlightCancelRequest) per le notifiche di Espletamento KO provenienti da NOW.
+                 */
+                notifica.setBusinessId(businessID);
+                notifica.setTransactionId(transactionID);
+
+                //NOTE:Se il codice Ordine OLO non e valorizzato non e possibile invocare il servizio di inFlighCancel
+                log.write("9999", "CodiceOrdineOlo : " + notifica.getCodiceOrdineOlo());
+                if (checkCodiceOrdineOlo(notifica)) {
+                    try {
+                        //L'annullamento viene notificato con l'operation requestFlightCancel
+                        CustomerOrderMgmtClient clientMgmt = new CustomerOrderMgmtClient();
+                        InFlightCancelRequest requestFlight = creaRequestFlightCancel(notifica);
+                        InFlightCancelResponse responseFlight = clientMgmt.inFlightCancel(requestFlight, businessID, transactionID);
+
+                        log.write("9999", "Response inFlightCancel: " + responseFlight);
+
+                        //SM_512 WA momentaneo in modo da non far riciclare la coda
+                        checkResponseInFlightCancel(responseFlight, notifica.getCodiceOrdineOlo());
+                    } catch (Exception ex) {
+                        log.write("9999", "SM_512 Errore invocazione servizio InFlightCancel: momentaneamente l'applicativo non effettuera' nessuna"
+                                + "logica di riciclo in modo da non appesantire la coda DN : " + notifica.getDirectoryNumber());
+                    }
+
+                }
+
                 notifica.setDaScodare((long) 0);
                 notifica.setDataInvioMessaggio(new Date());
             }

gnpdev/dbcfx/src/it/valueteam/gnp/systemcontroller/formatcontroller/dbss/DBSSFormatController.java

@@ -1713,9 +1713,11 @@ public class DBSSFormatController extends FormatController {
         if(null != nowIn.getNote()) {
             notifyOut.setNote(nowIn.getNote());
         }
+        /*
         else if (DBSSMap.EVENTO_ANNULLAMENTO.equals(notifyOut.getTipoEvento())){
             notifyOut.setNote(Resources.getNOW_CAMPO_NOTE_DEFAULT_SR_DBSS());
         }
+        */
 
         String aggiuntivi = "";
         if (!Func.isNull(nowIn.getNpDn2())) aggiuntivi += nowIn.getNpDn2() + ";";
@@ -1750,6 +1752,7 @@ public class DBSSFormatController extends FormatController {
         notifyOut.setCodiceOloRecipient(nowIn.getCodiceOperatoreRecipient());
         notifyOut.setCor(richiesta.getCor());
         notifyOut.setCodiceSessione(richiesta.getCodiceSessione());
+
         return notifyOut;
     }