From 74cd1400d82157ff429447cc5d01a7501285efc2 Mon Sep 17 00:00:00 2001 From: Arthur ZHU Date: Thu, 2 Jun 2022 21:49:37 +0200 Subject: [PATCH] =?UTF-8?q?suite=20import=20de=20donn=C3=A9es?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/entreprises/app_relations_entreprises.py | 268 +++++++++--------- app/entreprises/forms.py | 4 +- app/entreprises/routes.py | 51 +++- app/scodoc/sco_excel.py | 64 +++++ ...t_entreprises.html => import_donnees.html} | 2 +- 5 files changed, 246 insertions(+), 143 deletions(-) rename app/templates/entreprises/{import_entreprises.html => import_donnees.html} (98%) diff --git a/app/entreprises/app_relations_entreprises.py b/app/entreprises/app_relations_entreprises.py index ff6b3f80..0626aff8 100644 --- a/app/entreprises/app_relations_entreprises.py +++ b/app/entreprises/app_relations_entreprises.py @@ -47,6 +47,51 @@ from app.models import Departement from app.scodoc.sco_permissions import Permission +ENTREPRISES_KEYS = [ + "siret", + "nom_entreprise", + "adresse", + "ville", + "code_postal", + "pays", +] +SITES_KEYS = [ + [ + "siret_entreprise", + "id", + "nom_site", + "adresse", + "ville", + "code_postal", + "pays", + ], + [ + "civilite", + "nom", + "prenom", + "telephone", + "mail", + "poste", + "service", + "origine", + "notes", + ], +] +CORRESPONDANTS_KEYS = [ + "id", + "civilite", + "nom", + "prenom", + "telephone", + "mail", + "poste", + "service", + "origine", + "notes", + "nom_site", +] + + def get_depts(): """ Retourne une liste contenant les l'id des départements des roles de l'utilisateur courant @@ -59,7 +104,7 @@ def get_depts(): return depts -def get_dept_id_by_acronym(acronym): +def get_dept_id_by_acronym(acronym: str): """ Retourne l'id d'un departement a l'aide de son acronym """ @@ -69,14 +114,14 @@ def get_dept_id_by_acronym(acronym): return None -def get_dept_acronym_by_id(id): +def get_dept_acronym_by_id(id: int): dept = Departement.query.filter_by(id=id).first() if dept is not None: return dept.acronym return None -def check_offre_depts(depts, offre_depts): +def check_offre_depts(depts: list, offre_depts: list): """ Retourne vrai si l'utilisateur a le droit de visibilité sur l'offre """ @@ -115,7 +160,7 @@ def get_offre_files_and_depts(offre: EntrepriseOffre, depts: list): return None -def send_email_notifications_entreprise(subject, entreprise: Entreprise): +def send_email_notifications_entreprise(subject: str, entreprise: Entreprise): txt = [ "Une entreprise est en attente de validation", "Entreprise:", @@ -136,6 +181,92 @@ def send_email_notifications_entreprise(subject, entreprise: Entreprise): return txt +def get_excel_book_are(export: bool = False): + entreprises_titles = ENTREPRISES_KEYS[:] + sites_titles = SITES_KEYS[:] + correspondants_titles = CORRESPONDANTS_KEYS[:] + wb = sco_excel.ScoExcelBook() + ws1 = wb.create_sheet("Entreprises") + ws1.append_row( + [ + ws1.make_cell(it, style) + for (it, style) in zip( + entreprises_titles, + [sco_excel.excel_make_style(bold=True)] * len(entreprises_titles), + ) + ] + ) + ws2 = wb.create_sheet("Sites") + ws2.append_row( + [ + ws2.make_cell(it, style) + for (it, style) in zip( + sites_titles[0], + [sco_excel.excel_make_style(bold=True)] * len(sites_titles[0]), + ) + ] + + [ + ws2.make_cell(it, style) + for (it, style) in zip( + sites_titles[1], + [sco_excel.excel_make_style(bold=True, color=sco_excel.COLORS.RED)] + * len(sites_titles[1]), + ) + ] + ) + ws3 = wb.create_sheet("Correspondants") + ws3.append_row( + [ + ws3.make_cell(it, style) + for (it, style) in zip( + correspondants_titles, + [sco_excel.excel_make_style(bold=True)] * len(correspondants_titles), + ) + ] + ) + if export: + entreprises = Entreprise.query.filter_by(visible=True).all() + sites = ( + db.session.query(EntrepriseSite) + .join(Entreprise, EntrepriseSite.entreprise_id == Entreprise.id) + .filter_by(visible=True) + .all() + ) + correspondants = ( + db.session.query(EntrepriseCorrespondant) + .join(Entreprise, EntrepriseCorrespondant.entreprise_id == Entreprise.id) + .filter_by(visible=True) + .all() + ) + entreprises_lines = [ + [entreprise.to_dict().get(k, "") for k in ENTREPRISES_KEYS] + for entreprise in entreprises + ] + sites_lines = [ + [site.to_dict().get(k, "") for k in SITES_KEYS[0]] for site in sites + ] + correspondants_lines = [ + [correspondant.to_dict().get(k, "") for k in CORRESPONDANTS_KEYS] + for correspondant in correspondants + ] + for line in entreprises_lines: + cells = [] + for it in line: + cells.append(ws1.make_cell(it)) + ws1.append_row(cells) + for line in sites_lines: + cells = [] + for it in line: + cells.append(ws2.make_cell(it)) + ws2.append_row(cells) + for line in correspondants_lines: + cells = [] + for it in line: + cells.append(ws3.make_cell(it)) + ws3.append_row(cells) + return wb + + def verif_correspondant_data(correspondant_data): """ Verifie les données d'une ligne Excel (correspondant) @@ -213,132 +344,3 @@ def verif_entreprise_data(entreprise_data): if entreprise is not None: return False return True - - -def get_excel_book_are(export=False): - entreprises_keys = [ - "siret", - "nom_entreprise", - "adresse", - "ville", - "code_postal", - "pays", - ] - sites_keys = [ - [ - "siret_entreprise", - "id", - "nom_site", - "adresse", - "ville", - "code_postal", - "pays", - ], - [ - "civilite", - "nom", - "prenom", - "telephone", - "mail", - "poste", - "service", - "origine", - "notes", - ], - ] - correspondants_keys = [ - "id", - "civilite", - "nom", - "prenom", - "telephone", - "mail", - "poste", - "service", - "origine", - "notes", - "nom_site", - ] - entreprises_titles = entreprises_keys[:] - sites_titles = sites_keys[:] - correspondants_titles = correspondants_keys[:] - wb = sco_excel.ScoExcelBook() - ws1 = wb.create_sheet("Entreprises") - ws1.append_row( - [ - ws1.make_cell(it, style) - for (it, style) in zip( - entreprises_titles, - [sco_excel.excel_make_style(bold=True)] * len(entreprises_titles), - ) - ] - ) - ws2 = wb.create_sheet("Sites") - ws2.append_row( - [ - ws2.make_cell(it, style) - for (it, style) in zip( - sites_titles[0], - [sco_excel.excel_make_style(bold=True)] * len(sites_titles[0]), - ) - ] - + [ - ws2.make_cell(it, style) - for (it, style) in zip( - sites_titles[1], - [sco_excel.excel_make_style(bold=True, color=sco_excel.COLORS.RED)] - * len(sites_titles[1]), - ) - ] - ) - ws3 = wb.create_sheet("Correspondants") - ws3.append_row( - [ - ws3.make_cell(it, style) - for (it, style) in zip( - correspondants_titles, - [sco_excel.excel_make_style(bold=True)] * len(correspondants_titles), - ) - ] - ) - if export: - entreprises = Entreprise.query.filter_by(visible=True).all() - sites = ( - db.session.query(EntrepriseSite) - .join(Entreprise, EntrepriseSite.entreprise_id == Entreprise.id) - .filter_by(visible=True) - .all() - ) - correspondants = ( - db.session.query(EntrepriseCorrespondant) - .join(Entreprise, EntrepriseCorrespondant.entreprise_id == Entreprise.id) - .filter_by(visible=True) - .all() - ) - entreprises_lines = [ - [entreprise.to_dict().get(k, "") for k in entreprises_keys] - for entreprise in entreprises - ] - sites_lines = [ - [site.to_dict().get(k, "") for k in sites_keys[0]] for site in sites - ] - correspondants_lines = [ - [correspondant.to_dict().get(k, "") for k in correspondants_keys] - for correspondant in correspondants - ] - for line in entreprises_lines: - cells = [] - for it in line: - cells.append(ws1.make_cell(it)) - ws1.append_row(cells) - for line in sites_lines: - cells = [] - for it in line: - cells.append(ws2.make_cell(it)) - ws2.append_row(cells) - for line in correspondants_lines: - cells = [] - for it in line: - cells.append(ws3.make_cell(it)) - ws3.append_row(cells) - return wb diff --git a/app/entreprises/forms.py b/app/entreprises/forms.py index 65d503cc..a129c722 100644 --- a/app/entreprises/forms.py +++ b/app/entreprises/forms.py @@ -272,7 +272,7 @@ class OffreCreationForm(FlaskForm): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) - self.correspondant.choices = [ + self.correspondant.choices = [("", "")] + [ (correspondant.id, f"{correspondant.nom} {correspondant.prenom}") for correspondant in EntrepriseCorrespondant.query.filter_by( entreprise_id=self.hidden_entreprise_id.data @@ -318,7 +318,7 @@ class OffreModificationForm(FlaskForm): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) - self.correspondant.choices = [ + self.correspondant.choices = [("", "")] + [ (correspondant.id, f"{correspondant.nom} {correspondant.prenom}") for correspondant in EntrepriseCorrespondant.query.filter_by( entreprise_id=self.hidden_entreprise_id.data diff --git a/app/entreprises/routes.py b/app/entreprises/routes.py index 0f1cefd9..d6536c62 100644 --- a/app/entreprises/routes.py +++ b/app/entreprises/routes.py @@ -58,7 +58,7 @@ from app.scodoc import sco_etud, sco_excel import app.scodoc.sco_utils as scu from app import db -from sqlalchemy import text +from sqlalchemy import text, sql from werkzeug.utils import secure_filename @@ -665,7 +665,9 @@ def add_offre(id): missions=form.missions.data.strip(), duree=form.duree.data.strip(), expiration_date=form.expiration_date.data, - correspondant_id=form.correspondant.data, + correspondant_id=form.correspondant.data + if form.correspondant.data != "" + else None, ) db.session.add(offre) db.session.commit() @@ -728,7 +730,10 @@ def edit_offre(id): offre.missions = form.missions.data.strip() offre.duree = form.duree.data.strip() offre.expiration_date = form.expiration_date.data - offre.correspondant_id = form.correspondant.data + if form.correspondant.data == "": + offre.correspondant_id = sql.null() + else: + offre.correspondant_id = form.correspondant.data if offre_depts_list != form.depts.data: for dept in form.depts.data: if dept not in offre_depts_list: @@ -1415,13 +1420,45 @@ def import_donnees(): Config.SCODOC_VAR_DIR, "tmp", secure_filename(file.filename) ) file.save(file_path) - data = sco_excel.excel_file_to_list(file_path) + diag, lm = sco_excel.excel_file_to_list_are(file_path) os.remove(file_path) - print(data) + if ( + len(lm) < 3 + or lm[0][0] != are.ENTREPRISES_KEYS + or lm[1][0] != are.SITES_KEYS[0] + are.SITES_KEYS[1] + or lm[2][0] != are.CORRESPONDANTS_KEYS + ): + flash("Veuillez utilisez la feuille excel à remplir") + return redirect(url_for("entreprises.import_donnees")) + + # en cours + entreprises_import = [] + siret_list = [] + ligne = 1 + for entreprise_data in lm[0][1:]: + ligne += 1 + if ( + are.verif_entreprise_data(entreprise_data) + and entreprise_data[0].replace(" ", "") not in siret_list + ): + siret_list.append(entreprise_data[0].replace(" ", "")) + entreprise = Entreprise( + siret=entreprise_data[0].replace(" ", ""), + nom=entreprise_data[1].strip(), + adresse=entreprise_data[2].strip(), + ville=entreprise_data[3].strip(), + codepostal=entreprise_data[4].strip(), + pays=entreprise_data[5].strip(), + visible=True, + ) + entreprises_import.append(entreprise) + else: + flash(f"Erreur lors de l'importation") + return redirect(url_for("entreprises.import_donnees")) return redirect(url_for("entreprises.import_donnees")) return render_template( - "entreprises/import_entreprises.html", - title="Importation entreprises", + "entreprises/import_donnees.html", + title="Importation données", form=form, ) diff --git a/app/scodoc/sco_excel.py b/app/scodoc/sco_excel.py index 5d1b2d72..9ba10a30 100644 --- a/app/scodoc/sco_excel.py +++ b/app/scodoc/sco_excel.py @@ -613,6 +613,17 @@ def excel_file_to_list(filename): ) +def excel_file_to_list_are(filename): + try: + return _excel_to_list_are(filename) + except: + raise ScoValueError( + """Le fichier xlsx attendu n'est pas lisible ! + Peut-être avez-vous fourni un fichier au mauvais format (txt, xls, ...) + """ + ) + + def _excel_to_list(filelike): """returns list of list convert_to_string is a conversion function applied to all non-string values (ie numbers) @@ -673,6 +684,59 @@ def _excel_to_list(filelike): return diag, m +def _excel_to_list_are(filelike): + """returns list of list + convert_to_string is a conversion function applied to all non-string values (ie numbers) + """ + try: + wb = load_workbook(filename=filelike, read_only=True, data_only=True) + except: + log("Excel_to_list: failure to import document") + with open("/tmp/last_scodoc_import_failure" + scu.XLSX_SUFFIX, "wb") as f: + f.write(filelike) + raise ScoValueError( + "Fichier illisible: assurez-vous qu'il s'agit bien d'un document Excel !" + ) + diag = [] # liste de chaines pour former message d'erreur + if len(wb.get_sheet_names()) < 1: + diag.append("Aucune feuille trouvée dans le classeur !") + return diag, None + lm = [] + for sheet_name in wb.get_sheet_names(): + # fill matrix + ws = wb.get_sheet_by_name(sheet_name) + sheet_name = sheet_name.encode(scu.SCO_ENCODING, "backslashreplace") + values = {} + for row in ws.iter_rows(): + for cell in row: + if cell.value is not None: + values[(cell.row - 1, cell.column - 1)] = str(cell.value) + if not values: + diag.append( + "Aucune valeur trouvée dans la feuille %s !" + % sheet_name.decode(scu.SCO_ENCODING) + ) + return diag, None + indexes = list(values.keys()) + # search numbers of rows and cols + rows = [x[0] for x in indexes] + cols = [x[1] for x in indexes] + nbcols = max(cols) + 1 + nbrows = max(rows) + 1 + m = [] + for _ in range(nbrows): + m.append([""] * nbcols) + + for row_idx, col_idx in indexes: + v = values[(row_idx, col_idx)] + m[row_idx][col_idx] = v + diag.append( + 'Feuille "%s", %d lignes' % (sheet_name.decode(scu.SCO_ENCODING), len(m)) + ) + lm.append(m) + return diag, lm + + def excel_feuille_listeappel( sem, groupname, diff --git a/app/templates/entreprises/import_entreprises.html b/app/templates/entreprises/import_donnees.html similarity index 98% rename from app/templates/entreprises/import_entreprises.html rename to app/templates/entreprises/import_donnees.html index 833de24c..b0c2f7c1 100644 --- a/app/templates/entreprises/import_entreprises.html +++ b/app/templates/entreprises/import_donnees.html @@ -7,7 +7,7 @@ {% endblock %} {% block app_content %} -

Importation entreprises

+

{{ title }}


Obtenir la feuille excel à remplir