)
}
+ log.debug "getFile($etablissement, $nomFichier, $etat"
+
if (etat != ImportEtat.TRAITE) {
File fileDossierEtablissementEtat = getFileDossierForEtablissementAndEtat(
etablissement,
File fileRacineImportSts = new File("$uriRacineTraitement/$traitementCode")
+ log.debug "piocheEtablissementEnAttenteImport $uriRacineTraitement/$traitementCode"
+
if (!fileRacineImportSts.exists()) {
+ log.debug "Le fichier n'existe pas."
return null
}
"${etablissement.uai}"
)
}
+
+ log.debug "prepareDonneesAImporter $etablissement"
// Récupère un pointeur sur le fichier StsEmp en attente
File fileStsEmpEnAttente = getFileStsEmp(
public File getFileStsEmp(Etablissement etablissement,
ImportEtat etat,
Date dateTraiment = null) {
+ log.debug "getFileStsEmp"
return getFile(etablissement, NOM_FICHIER_STS_EMP, etat, dateTraiment)
}
environments {
development {
- eliot.scolarite.import.sts.racineDossiers = '/tmp'
+ eliot.scolarite.import.sts.racineDossiers = '/tmp/sts'
eliot.scolarite.import.udt.racineDossiers = '/tmp'
}
}
grails.serverURL = "http://localhost:8080/${appName}"
//Expression cron définissant la fréquence de lancement de l'import sts
- eliot.scolarite.import.sts.heuredebut.cronexpression = '* * 0 * * ?'
+ eliot.scolarite.import.sts.heuredebut.cronexpression = '0 0/3 * 1/1 * ? *'
//Indique si l'import UDT doit être lancé
- eliot.scolarite.import.udt.actif = true
+ eliot.scolarite.import.udt.actif = false
//Délai, en jours, au-delà duquel les évènements et enseignements UDT sont supprimés de la table temporaire
eliot.scolarite.import.udt.dureePeremption = 30
//La taille des lots de suppression
* @author jtra
*/
class StsImportJob {
+
static triggers = {
// Job désactivé en mode maintenance
if (ConfigurationHolder.config.eliot.mode.maintenance) {return}
heuredebut.cronexpression
)
}
- def concurrent = false
StsImportProcessManagerService stsImportProcessManagerService
private final static String FORMAT_DATE_HEURE = 'dd/MM/yyyy HH:mm:ss'
- String identifiantJob
def execute() {
stsImportProcessManagerService.lanceProcessusImport(calculeIdentifiantJob())