|
|
@@ -1,3 +1,9 @@
|
|
|
+"""
|
|
|
+ Importe les fichiers xml de suivi d'activité dans la base PDA et la base agrhume
|
|
|
+
|
|
|
+ @author: dominique.freyd et olivier.massot, juillet 2018
|
|
|
+"""
|
|
|
+
|
|
|
import requests
|
|
|
from lxml import etree
|
|
|
from requests_ntlm.requests_ntlm import HttpNtlmAuth
|
|
|
@@ -26,11 +32,11 @@ logconf.start("suiviactivite2pda", logging.DEBUG)
|
|
|
# # POUR TESTER, décommenter les lignes suivantes
|
|
|
##-----------------------------------------------
|
|
|
|
|
|
-PdaDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\PDA\db_PDA.mdb")
|
|
|
-CommunDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\Commun_Data.mdb")
|
|
|
-AgrhumDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\BDD_ParcRH.mdb")
|
|
|
-logger.handlers = [h for h in logger.handlers if (type(h) == logging.StreamHandler)]
|
|
|
-logger.warning("Mode TEST")
|
|
|
+#PdaDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\PDA\db_PDA.mdb")
|
|
|
+#CommunDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\Commun_Data.mdb")
|
|
|
+#AgrhumDb._path = Path(r"\\h2o\local\4-transversal\BDD\mdb_test\BDD_ParcRH.mdb")
|
|
|
+#logger.handlers = [h for h in logger.handlers if (type(h) == logging.StreamHandler)]
|
|
|
+#logger.warning("Mode TEST")
|
|
|
|
|
|
##-----------------------------------------------
|
|
|
|
|
|
@@ -48,7 +54,7 @@ def make_request(url,typeheaders):
|
|
|
def TraiteUnFichier(fichier):
|
|
|
|
|
|
if agrhum_db.exists("select * from tbl_importrh where FichierXml='{}'".format(fichier) ):
|
|
|
- logger.debug(">> Le fichier a déjà été importé, import annulé")
|
|
|
+ logger.debug(">> Le fichier a déjà été importé, import annulé (%s)", fichier)
|
|
|
return
|
|
|
|
|
|
logger.info("Traitement du fichier %s",fichier )
|
|
|
@@ -139,7 +145,7 @@ def TraiteUnFichier(fichier):
|
|
|
CodeLigne +=1
|
|
|
|
|
|
|
|
|
- # traitement des congées
|
|
|
+ # traitement des congés
|
|
|
for conges in tree.xpath("/ArrayOfAction/ArrayOfConges/Conges"):
|
|
|
if "T" in conges.find("DateDebut").text:
|
|
|
DateDebut= datetime.datetime.strptime(conges.find("DateDebut").text, "%Y-%m-%dT%H:%M:%S")
|
|
|
@@ -158,7 +164,6 @@ def TraiteUnFichier(fichier):
|
|
|
CodeLigne,DateDebut,DateFin,Duree,'22MAOE','02',fichier, IdPeriode,'en_cours','Non','scriptauto','22MAOE',CodeAgent
|
|
|
)
|
|
|
CodeLigne +=1
|
|
|
- #print (sql)
|
|
|
pda_db.execute(sql)
|
|
|
|
|
|
# ecrite dans la table suivirh
|
|
|
@@ -166,13 +171,9 @@ def TraiteUnFichier(fichier):
|
|
|
"VALUES ({:text},{},{},'Importé',True)",CodeAgent,moisrh,anneerh)
|
|
|
agrhum_db.execute(sql)
|
|
|
|
|
|
-# traite fichier de la bibliotheque SP contenant les export
|
|
|
-# Param : aucun
|
|
|
-# retour :
|
|
|
-# aucun
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
def main():
|
|
|
+ """ traite fichier de la bibliotheque SP contenant les export """
|
|
|
data = make_request(SHAREPOINTJSON,JSONHEADERS)
|
|
|
for item in data['d']['results']:
|
|
|
filename=item['Nom']
|