Collecte depuis BQ des labels, actions et membres :)

beequick/bqHarvest_actions.py

+from BeequickClient import BeequickClient
+import sqlite3
+
+con = sqlite3.connect("../CNE.db")
+db = con.cursor()
+
+insert_req = "INSERT INTO etudes_actions VALUES(:id, :etude_id, :user_id, :message, :created_at)"
+update_req = 	"UPDATE etudes_actions SET etude_id = :etude_id, user_id = :user_id, message = :message, created_at = :created_at " \
+				"WHERE id = :id"
+
+bq = BeequickClient.admin()
+etudes = bq.getAllEtudes()
+
+for etude in etudes:
+	id = etude["id"]
+	actions = bq.get("actions", {"etude_id": id}).json()
+	for action in actions:
+		aid = action["id"]
+		print(aid)
+		exists = db.execute("SELECT * FROM etudes_actions WHERE id = :id", {"id" : aid}).fetchone() != None
+		req = update_req if exists else insert_req
+		db.execute(req, action)
+
+con.commit()
+con.close()
\ No newline at end of file

beequick/bqHarvest_labels.py

+from BeequickClient import BeequickClient
+import sqlite3
+
+con = sqlite3.connect("../CNE.db")
+db = con.cursor()
+
+req = "INSERT INTO etudes_labels VALUES(:label_id, :etude_id)"
+
+bq = BeequickClient.admin()
+etudes = bq.getAllEtudes()
+
+for etude in etudes:
+	id = etude["id"]
+	data = bq.getEtudeInformations(id)
+	labels = data["labels"]
+	for label in labels:
+		lid = label["id"]
+		exists = db.execute("SELECT * FROM etudes_labels WHERE label_id = :lid AND etude_id = :eid", {"lid" : lid, "eid" : id}).fetchone() != None
+		if exists:
+			continue
+		db.execute(req, {"label_id": lid, "etude_id": id})
+
+con.commit()
+con.close()
\ No newline at end of file

beequick/bqHarvest_labelsIds.py

+from BeequickClient import BeequickClient
+import sqlite3
+
+con = sqlite3.connect("../CNE.db")
+db = con.cursor()
+
+insert_req = "INSERT INTO etudes_labels_ids VALUES(:id, :nom, :abbreviation, :type)"
+update_req = "UPDATE etudes_labels_ids SET id = :id, nom = :nom, abbreviation = :abbreviation, type = :type) WHERE id = :id"
+
+bq = BeequickClient.admin()
+
+labels = bq.get("config/labels", {"actif":"actif", "pipe_type":"etudes"})
+print(labels)
+labels = labels.json()
+for label in labels:
+	id = label["id"]
+	new = db.execute("SELECT * FROM etudes_labels_ids WHERE id = :id", {"id": id}).fetchone() == None
+	req = insert_req if new else update_req
+	typ = "Provenance" if label["label_type_id"] == 3 else "Business Unit"
+	label.update({"type": typ})
+	db.execute(req, label)
+
+con.commit()
+con.close()
\ No newline at end of file

beequick/bqHarvest_membres.py

@@ -5,7 +5,8 @@ con = sqlite3.connect("../CNE.db")
 db = con.cursor()
 
 insert_req = "INSERT INTO membres VALUES(:id, :email, :nom, :prenom, :portable, :poste_id)"
-update_req = "UPDATE membres SET id = :id, email = :email, nom = :nom, prenom = :prenom, portable = :portable, poste_id = :poste_id)"
+update_req = 	"UPDATE membres SET email = :email, nom = :nom, prenom = :prenom, portable = :portable, poste_id = :poste_id) " \
+				"WHERE id = :id0"
 
 bq = BeequickClient.admin()