Téléchargement des études dans la db

beequick/bqHarvest.py

-from BeequickClient import BeequickClient
-import sqlite3
-
-bq = BeequickClient.admin()
-
-etude = bq.getAllEtudes()[0]
-
-print(etude)
-
-print(bq.getEtudeActions(etude["id"]))
\ No newline at end of file

beequick/bqHarvest_etudes.py

+from BeequickClient import BeequickClient
+import sqlite3
+
+con = sqlite3.connect("../CNE.db")
+db = con.cursor()
+
+insert_req = 	"INSERT INTO etudes VALUES(" \
+				":id, :nom, :numero, :objectif, :suiveur_id, " \
+				":contact_id, :etude_interne, :frais, :montant_facture_frais, " \
+				":duree_semaine, :prix, :nb_jeh, :phases_count, :etat_id, " \
+				":created_at, :date_derniere_action, :date_signature)"
+update_req =	"UPDATE etudes SET " \
+				"nom = :nom, numero = :numero, objectif = :objectif, suiveur_id = :suiveur_id, " \
+				"contact_id = :contact_id, etude_interne = :etude_interne, frais = :frais, " \
+				"montant_facture_frais = :montant_facture_frais, duree_semaine = :duree_semaine, " \
+				"prix = :prix, nb_jeh = :nb_jeh, nb_phases = :phases_count, etat_id = :etat_id " \
+				"created_at = :created_at, date_derniere_action = :date_derniere_action, date_signature = :date_signature" \
+				"WHERE id = :id"
+
+bq = BeequickClient.admin()
+
+etudes = bq.getAllEtudes()
+
+for etude in etudes:
+	id = etude["id"]
+	data = bq.getEtudeInformations(id)
+	new = db.execute("SELECT * FROM etudes WHERE id = :id", {"id":id}).fetchone() == None
+	req = insert_req if new else update_req
+	db.execute(req, data)
+
+con.commit()
+con.close()
\ No newline at end of file

facebook/fbHarvest.py

@@ -52,8 +52,8 @@ for post in posts:
 	}
 	for r in reactions:
 		data.update({"reactions_" + r : results["post_reactions_"+r+"_total"]})
-	already = db.execute("SELECT * FROM fb_posts WHERE fb_id = :fb_id", {"fb_id":fb_id}).fetchall()
-	req = insert_req if len(already) == 0 else update_req
+	already = db.execute("SELECT * FROM fb_posts WHERE fb_id = :fb_id", {"fb_id":fb_id}).fetchone()
+	req = insert_req if already == None else update_req
 	db.execute(req,data)
 	print(data)