abstract AbstractImportDonneesManager getImportDonneesManagerService()
+ @SuppressWarnings('CatchException')
ImportProcessResultat lanceProcessusImport(String identifiantJob) {
ImportProcessResultat importProcessResultat = new ImportProcessResultat()
Boolean synchroEnCours = executionService.isSynchroEnCours()
while (synchroEnCours && resteDuTemps(heureLancement)) {
- if (log.infoEnabled) {log.info "Synchro est en cours. Le job d'import attend ${PERIODE_ATTENTE / 1000} seconds. $traitementNom : $identifiantJob"}
+
+ if (log.infoEnabled) {
+ log.info "Synchro est en cours. Le job d'import attend ${PERIODE_ATTENTE / 1000} seconds. $traitementNom : $identifiantJob"
+ }
+
sleep(PERIODE_ATTENTE)
synchroEnCours = executionService.isSynchroEnCours()
}
return importProcessResultat
}
-
-
lanceProcessusImport(etablissement, identifiantJob)
importProcessResultat.nbEtablissementsTraites++
importProcessResultat.causeArret =
CauseArret.PLUS_D_ETABLISSEMENT_A_TRAITER
- if (log.infoEnabled) {log.info "Fin de l'import. Tous les établissements ont été traités. (Job : $identifiantJob)"}
+ if (log.infoEnabled) {
+ log.info "Fin de l'import. Tous les établissements ont été traités. (Job : $identifiantJob)"
+ }
}
}