* @throws IllegalStateException si les données n'existent pas, ou ne sont pas
* dans le dossier prévu, ou que le format des données n'est pas valide
*/
+ @SuppressWarnings('CatchException')
TextesImportRapport importAllCahier(SecuriteSession securiteSession,
InputStream fluxDonnesCdtParse,
InputStream fluxRoot,
/**
* Exécution transactionnelle
*/
+ @SuppressWarnings('CatchException')
private void executeDansTransaction(TextesImportRapport rapportPrincipal,
CahierDeTextesInfo cdt,
Closure closure) {
* Les exceptions éventuelles sont catchées et loggées
* @param file le fichier à supprimer
*/
+ @SuppressWarnings('CatchException')
protected void safeDelete(File file) {
if (file.exists()) {
try {
* @return true si les données de l'établissement ont pu être vérouillées,
* false sinon
*/
+ @SuppressWarnings('CatchException')
boolean verrouilleEtablissement(Etablissement etablissement) {
File fileVerrou = getFileVerrouForEtablissement(etablissement)
try {
fileVerrou.createNewFile()
- if (log.infoEnabled) {log.info("Pose du verrou pour l'établissement ${etablissement?.uai}")}
+ if (log.infoEnabled) {
+ log.info("Pose du verrou pour l'établissement ${etablissement?.uai}")
+ }
return true // Le verrou a été posé
}
catch (Exception e) {
* @return l'établissement en attente d'un import depuis le plus longtemps,
* ou null si aucun établissement n'est en attente d'un import STS
*/
+ @SuppressWarnings('CatchException')
public Etablissement piocheEtablissementEnAttenteImport(String identifiantJob,
List<Etablissement> etablissementExclus = []) {
File fileRacineImportSts = new File("$uriRacineTraitement/$traitementCode")
- if (log.debugEnabled) {log.debug "piocheEtablissementEnAttenteImport $uriRacineTraitement/$traitementCode"}
+ if (log.debugEnabled) {
+ log.debug "piocheEtablissementEnAttenteImport $uriRacineTraitement/$traitementCode"
+ }
if (!fileRacineImportSts.exists()) {
- if (log.debugEnabled) {log.debug "Le fichier n'existe pas."}
+ if (log.debugEnabled) {
+ log.debug "Le fichier n'existe pas."
+ }
return null
}
/**
* Retourne tous les rapports d'import pour un établissement
*/
+ @SuppressWarnings('CatchException')
public List<ImportRapportInfo> getListeRapportFichierInfo(Etablissement etablissement) {
List<ImportRapportInfo> listeRapportFichierInfo = (List) []
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)"
+ }
}
}