diff --git a/src/main/java/it/finanze/sanita/fse2/ms/gtw/dispatcher/controller/impl/ValidationCTL.java b/src/main/java/it/finanze/sanita/fse2/ms/gtw/dispatcher/controller/impl/ValidationCTL.java index 5cacfd1..07343d2 100644 --- a/src/main/java/it/finanze/sanita/fse2/ms/gtw/dispatcher/controller/impl/ValidationCTL.java +++ b/src/main/java/it/finanze/sanita/fse2/ms/gtw/dispatcher/controller/impl/ValidationCTL.java @@ -92,10 +92,12 @@ public ResponseEntity validate(final ValidationCDAReqDTO reque message = "Attenzione - รจ stato chiamato l'endpoint di validazione con VERIFICA"; } - kafkaSRV.sendValidationStatus(traceInfoDTO.getTraceID(), workflowInstanceId, EventStatusEnum.SUCCESS,message, jwtPayloadToken); - String typeIdExtension = docT.select("typeId").get(0).attr("extension"); - logger.info(Constants.App.LOG_TYPE_CONTROL,workflowInstanceId, "Validation CDA completed for workflow instance Id " + workflowInstanceId, OperationLogEnum.VAL_CDA2, ResultLogEnum.OK, startDateOperation, CdaUtility.getDocumentType(docT), - jwtPayloadToken,typeIdExtension); + if (!jsonObj.getActivity().equals(ActivityEnum.VERIFICA)) { + kafkaSRV.sendValidationStatus(traceInfoDTO.getTraceID(), workflowInstanceId, EventStatusEnum.SUCCESS,message, jwtPayloadToken); + String typeIdExtension = docT.select("typeId").get(0).attr("extension"); + logger.info(Constants.App.LOG_TYPE_CONTROL,workflowInstanceId, "Validation CDA completed for workflow instance Id " + workflowInstanceId, OperationLogEnum.VAL_CDA2, ResultLogEnum.OK, startDateOperation, CdaUtility.getDocumentType(docT), + jwtPayloadToken,typeIdExtension); + } request.setAttribute("JWT_ISSUER", jwtPayloadToken.getIss()); } catch (final ValidationException e) { errorHandlerSRV.validationExceptionHandler(startDateOperation, traceInfoDTO, workflowInstanceId, jwtPayloadToken, e, CdaUtility.getDocumentType(docT));