Update main.py

main.py

@@ -177,53 +177,59 @@ def localisation():
     	{ "ID": "972", "Longitude": -61.024174, "Latitude": 14.641528 },
     	{ "ID": "971", "Longitude": -61.551, "Latitude": 16.265 }
     ]
-    longLat = pd.DataFrame(ListCentroids)
-    return longLat
     
-def modele(document):
-    match document:
-        case "Note de composante sectorielle":
-            note = """2. Analyse du système travail
-            2.1 Secteurs en lien avec la discipline
-            2.1.1 Indiquer la nature des secteurs, la répartition des entreprises. Décrire les enjeux pour ce secteur (axes de développement, de transformations). Indiquer les OPérateurs de COmpétences de la branche professionnelle correspondante en France.
-            2.2 Analyses des offres d’emploi
-            2.2.1 Indiquer les statistiques de l’emploi sur une période. Identifier les 5 principales appellations métiers seulement en fonction du contexte, en créer une liste contextualisée, avec les pourcentages du nombre d'offres pour chaque emploi par rapport au nombre total d'offres.
-            2.2.2 missions, activités et compétences demandées (écrites avec un verbe d'action). Décrire le/les profils types des recrutés par les employeurs du système de travail. Lister, au format liste, les évolutions professionnelles ou les exemples de spécialisation, lister, au format liste, les débouchés, lister, au format liste, les avantages du métier, lister, au format liste, les inconvénients du métier, lister, au format liste, les conseils pour réussir dans ce métier.
-            2.2.3 Indiquer si les emplois sont en tension
-            """
-        case "Fiche Potentiel Profil de Sortie":
-            note = """1. Nom de la fiche
-            2. Niveau du diplôme et son Intitulé (nom long plus sigle). Le niveau de qualification
-            3. Le résumé du profil et du potentiel de sortie. Il est composé de plusieurs parties :
-                L'identité/ les spécificités de la composante.  Cette introduction de 5 à 10 lignes est utile pour caractériser le diplôme. Il s'agit d’avoir une description sur les thématiques de recherche de la composante. Elles sont indiquées afin d’établir le lien entre la recherche et des enjeux possibles dans le système travail. Elle facilite la compréhension des domaines de compétences dans lequel s’inscrit le futur diplômé. La culture disciplinaire est à indiquer car elle contribue à caractériser le diplôme.
-                L'identité professionnelle du diplômé. Les informations professionnelles sont organisées par mailles (du plus large au plus précis) secteur, famille de métiers, activités, compétences, compétences transversales. Il est nécessaire d’être attentif au niveau de qualification de sortie. Nous avons des emplois accessibles dès l’obtention du diplôme, d'autres ne le seront qu’avec un une qualification supérieure et/ou avec de l’expérience. Il souhaitable de faire une description globale du profil en apportant des informations sur le niveau d’autonomie et de responsabilité et les caractéristiques d’exercice des emplois (spécialisé ou généraliste, polyvalent ou expert etc).Cette seconde partie de texte de 10 à 15 lignes introduit les domaines et enjeux sectoriels et/ou terrain de mise en œuvre (3 lignes), les principales appellations d’emploi (1 à 2 lignes), les activités professionnelles (employabilité ) et le processus métier  (3 à 4 lignes), les principaux interlocuteurs (1 à 2 lignes), les différents contextes de mise en œuvre (déplacements, langues étrangères). Cette description peut être suivi la liste d’emplois (avec une présentation courte 5 lignes) accessibles en indiquant le cas échéant les spécificités
-            4. La réglementation le cas échéant
-            5. Secteurs d'activité ou types d'emplois accessibles par le détenteur de ce diplôme
-            6. Le type de structure et d’organisations professionnelles
-            7. Listes des suites de parcours académiques ou passerelles de formation
-            8. Codes Rome
-            9. Référence de la fiche RNCP
-            """
-    return note
-
-def definition(document):
-    if document == "activite":
-        meanings = """
-        Définition d'une activité : une activité est un ensemble cohérent d'actions combinées : pour la réaliser, plusieurs compétences et opérations sont nécessaires, soit successivement, soit conjointement. Elles s'inscrivent à des moments clés du processus de réalisation et ne peuvent en aucun cas être occultées, car elles conditionnent le résultat. Plusieurs activités en vue d'une finalité avec une valeur ajoutée à un produit ou un service sont nécessaires pour mettre en œuvre un processus métier. De ce fait, il est essentiel de déterminer pour chaque activité sa propre finalité et de s'assurer que l'ensemble des activités participent bien d'un même processus.
-        """
-    elif document == "competence":
-        meanings = """
-        Définition d'une compétence : la compétence est une combinaison de savoirs en action, mobilisés en vue de réaliser une activité professionnelle. Elle s'apprécie, en tant qu'acquis de l'apprentissage selon des modalités adaptées permettant d'en certifier la possession et au regard de l'atteinte d'un résultat pour un niveau d'exigence prédéterminé. Les compétences peuvent être regroupées par domaines selon la nature et leur liaison subordonnée aux activités. Elles s'écrivent à l'aide de verbe d'action à l'infinitif comme le stipule la taxonomie de Bloom pour marquer une progression dans l'exercice de la compétence.
-        """
-    elif document == "promptLibraryNCS":
-        meanings = """
-        Exemple de requêtes sur la note sectorielle : traitement statistique et génération des codes des objets de datavisualisation\nQuestion1 : donne le dataframe des appellations métiers et de leur pourcentage.\nQuestion2 : donne le plotly.js du dataframe avec les labels des appellations métiers et les labels des pourcentages.\nQuestion3 : convertis en plotly.js au format javascript\nQuestion4 : donne les salaires moyens.\nQuestion5 : donne le résultat des salaires moyens par appellations métiers dans un tableau.\nQuestion6 : donne le plotly du tableau des salaires moyens par appellation métier.\nQuestion7 : convertis en plotly.js au format javascript avec les labels des salaires moyens et les labels des appellations métiers\nQuestion8 : donne le pourcentage des contrats en CDI.\nQuestion9 : donne le résultat dans un tableau\nQuestion10 : donne le plotly du tableau\nQuestion11 : convertis le plotly en plotly.js au format javascript, avec affichage de tous les labels.\nQuestion12 : donne les 10 compétences professionnelles principales avec leur pourcentage.\nQuestion13 : donne le résultat dans un tableau.\nQuestion14 : donne le plotly du tableau\nQuestion15 : convertis le plotly en plotly.js au format javascript, avec affichage de tous les labels.\nQuestion16 : quelles sont les appellations métiers accessibles selon une expérience débutant, en donnant un pourcentage?\nQuestion17 : donne le résultat dans un tableau.\nQuestion18 : donne le plotly du tableau.\nQuestion19 : convertis le plotly en plotly.js au format javascript, avec affichage de tous les labels.\nQuestion20 : quelles sont les appellations métiers accessibles selon un niveau de qualification jusqu'à Bac+2 ou assimilés, en donnant un pourcentage?\nQuestion21 : donne le résultat dans un tableau.\nQuestion22 : donne le plotly du tableau\nQuestion23 : convertis le plotly en plotly.js au format javascript, avec affichage de tous les labels.\nQuestion24 : donne le pourcentage des appellations métiers en fonction des types d'entreprise.\nQuestion25 : construis le tableau en faisant une estimation.\nQuestion26 : donne le plotly du tableau estimé avec les pourcentage évalués par toi-même\nQuestion27 : convertis le plotly en plotly.js au format javascript, avec affichage de tous les labels, issus de votre estimation.
-        """
-    elif document == "promptLibraryFCS":
-        meanings = """
-        Exemple de requêtes sur la fiche synoptique : construction d'un programme de formation complet\nQuestion1 : crée un programme de formation, en 4000 mots, sur 3 ans découpés en 6 semestres, comportant 3 blocs de compétences pédagogiques, dont les intitulés commencent par un verbe d'action, par semestre correspondant à 3 unités d'enseignement par semestre  et 3 cours par unité d'enseignement, en corrélation avec les activités professionnelles et les compétences professionnelles de la fiche synoptique, marquant une progression dans les apprentissages.\nQuestion2 : donne le synopsis du cours1 de l'UE1\nQuestion3 : plus?\nQuestion4 : et les supports pédagogiques?
-        """
-    return meanings
+    return ListCentroids
+    
+def plotDemandeur(dataframe, coderome):
+  df = dataframe.sort_values(by=['Indicateur'])
+  fig_demandeur = px.histogram(df, x='Indicateur', y='Valeur', height=1000, title="Demandeurs d'emploi et offres d'emploi du code ROME : " + coderome, color='Indicateur', labels={'Valeur':'Nombre'}, text_auto=True).update_layout(font=dict(size=9,color="RebeccaPurple"),autosize=True)
+  fig_demandeur.show()
+
+def plotSalaire(dataframe):
+  df = dataframe.sort_values(by=['salaire'])
+  fig_demandeur = px.histogram(df, x='emploi', y='salaire', barmode='group', title="Salaires médians", color='categorie', text_auto=True).update_layout(font=dict(size=9,color="RebeccaPurple"),autosize=True)
+  fig_demandeur.show()
+
+def plotDifficulte(dataframe):
+  if len(dataframe) == 0:
+    title = "Aucune donnée difficulté de recrutement renseignée!"
+  else:
+    title = "Difficulté de recrutement"
+  df = dataframe.sort_values(by=['Valeur'])
+  fig_demandeur = px.histogram(df, x='Indicateur', y='Valeur', title=title, color='Indicateur', labels={'Valeur':'Pourcentage'}, text_auto=True).update_layout(font=dict(size=9,color="RebeccaPurple"),autosize=True)
+  fig_demandeur.show()
+
+def plotRepartition(dataframe,title):
+  df = dataframe.sort_values(by=['Valeur'])
+  fig_repartition = px.pie(df, names='Indicateur', values='Valeur', color='Indicateur', title=title, labels={'Valeur':'pourcentage'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
+  fig_repartition.show()
+
+def removeTags(all):
+  for data in all(['style', 'script']):
+    data.decompose()
+  return ''.join(all.stripped_strings)
+
+def htmlToDataframe(htmlTable):
+  data = []
+  list_header = []
+  soup = BeautifulSoup(htmlTable,'html.parser')
+  header = soup.find_all("table")[0].find("tr")
+  for items in header:
+    try:
+      list_header.append(items.get_text())
+    except:
+      continue
+  HTML_data = soup.find_all("table")[0].find_all("tr")[1:]
+  for element in HTML_data:
+    sub_data = []
+    for sub_element in element:
+      try:
+        sub_data.append(sub_element.get_text())
+      except:
+          continue
+    data.append(sub_data)
+  dataFrame = pd.DataFrame(data = data, columns = list_header)
+  return dataFrame
 
 def listToString(list):
     return str(list)
@@ -289,134 +295,6 @@ async def on_action(action):
         author="Datapcc : 🌐🌐🌐", content="[Lien] 🔗", elements=elements
     ).send()
     await action.remove()
-    
-@cl.action_callback("datavizEmploi")
-async def on_action(action):
-    client = Api(client_id=os.environ['POLE_EMPLOI_CLIENT_ID'],
-                client_secret=os.environ['POLE_EMPLOI_CLIENT_SECRET'])
-    todayDate = datetime.datetime.today()
-    month, year = (todayDate.month-1, todayDate.year) if todayDate.month != 1 else (12, todayDate.year-1)
-    start_dt = todayDate.replace(day=1, month=month, year=year)
-    end_dt = datetime.datetime.today()
-    arraydataframe = []
-    arrayfirstdataframe = []
-    arraylocalisationdataframe = []
-    results = []
-    count = 0
-    listrome = action.value
-    arrayrome = listrome.split(',')
-    for k in arrayrome:
-        params = {"motsCles": k,'minCreationDate': dt_to_str_iso(start_dt),'maxCreationDate': dt_to_str_iso(end_dt),'range':'0-149'}
-        search_on_big_data = client.search(params=params)
-        results += search_on_big_data["resultats"]
-    results_df = pd.DataFrame(results)
-    if results_df.empty == False:
-        count = count + 1
-        finals = results_df[['intitule','typeContratLibelle','experienceLibelle','competences','qualitesProfessionnelles','salaire','lieuTravail','formations']]
-        finals["lieuTravail"] = finals["lieuTravail"].apply(lambda x: np.array(x)).apply(lambda x: x['libelle']).apply(lambda x: x[0:3]).apply(lambda x: x.strip())
-        finals_df = finals
-        finals_df.dropna(subset=['qualitesProfessionnelles','formations','competences'], inplace=True)
-        finals_df["competences"] = finals_df["competences"].apply(lambda x:[str(e['libelle']) for e in x]).apply(lambda x:'; '.join(map(str, x)))
-        finals_df["qualitesProfessionnelles"] = finals_df["qualitesProfessionnelles"].apply(lambda x:[str(e['libelle']) + ": " + str(e['description']) for e in x]).apply(lambda x:'; '.join(map(str, x)))
-        finals_df["formations"] = finals_df["formations"].apply(lambda x:[str(e['niveauLibelle']) for e in x]).apply(lambda x:'; '.join(map(str, x)))
-        finals_df = finals_df.sort_values(by=['lieuTravail'])
-        finals_localisation = results_df[['lieuTravail']]
-        finals_localisation["lieuTravail"] = finals_localisation["lieuTravail"].apply(lambda x: np.array(x)).apply(lambda x: x['libelle']).apply(lambda x: x[0:3]).apply(lambda x: x.strip())
-        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Fra'].index, inplace = True)
-        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'FRA'].index, inplace = True)
-        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Ile'].index, inplace = True)
-        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Mar'].index, inplace = True)
-        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Bou'].index, inplace = True)
-        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == '976'].index, inplace = True)
-        arraylocalisationdataframe.append(finals_localisation)
-        arrayfirstdataframe.append(results_df)
-        if len(finals_df) != 0:
-            arraydataframe.append(finals_df)
-    first_df = pd.concat(arrayfirstdataframe)
-    finals_df = pd.concat(arraydataframe)
-    localisation_df = pd.concat(arraylocalisationdataframe)
-
-    ######## Emplois ########
-    df_intitule = first_df.groupby('intitule').size().reset_index(name='obs')
-    df_intitule = df_intitule.sort_values(by=['obs'])
-    df_intitule = df_intitule.iloc[-25:]
-    fig_intitule = px.bar(df_intitule, x='obs', y='intitule', width=800, height=600, orientation='h', color='obs', title="Les principaux emplois", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df_intitule["intitule"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df_intitule["intitule"]], showlegend=False)
-
-    ######## Types de contrat ########
-    df_contrat = first_df.groupby('typeContratLibelle').size().reset_index(name='obs')
-    fig_contrat = px.pie(df_contrat, names='typeContratLibelle', width=800, height=800, values='obs', color='obs', title="Les types de contrat", labels={'obs':'nombre'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
-
-    df_secteur = first_df.groupby('secteurActiviteLibelle').size().reset_index(name='obs')
-    df_secteur = df_secteur.sort_values(by=['obs'])
-    df_secteur = df_secteur.iloc[-25:]
-    fig_secteur = px.bar(df_secteur, x='obs', y='secteurActiviteLibelle', width=800, height=600, orientation='h', color='obs', title="Les principaux secteurs d'activités", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df_secteur["secteurActiviteLibelle"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df_secteur["secteurActiviteLibelle"]], showlegend=False)
-
-    ######## Compétences professionnelles ########
-    df1 = finals_df
-    df1['competences'] = finals_df['competences'].str.split(';')
-    df2 = df1.explode('competences')
-    df2 = df2.groupby('competences').size().reset_index(name='obs')
-    df2 = df2.sort_values(by=['obs'])
-    df2 = df2.iloc[-20:]
-    fig_competences = px.bar(df2, x='obs', y='competences', width=800, height=550, orientation='h', color='obs', title="Les principales compétences professionnelles", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df2["competences"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df2['competences']], showlegend=False)
-
-    ######## Compétences transversales ########
-    df_transversales = finals_df
-    df_transversales['qualitesProfessionnelles'] = finals_df['qualitesProfessionnelles'].str.split(';')
-    df_comptransversales = df_transversales.explode('qualitesProfessionnelles')
-    df_comptransversales = df_comptransversales.groupby('qualitesProfessionnelles').size().reset_index(name='obs')
-    df_comptransversales = df_comptransversales.sort_values(by=['obs'])
-    df_comptransversales = df_comptransversales.iloc[-20:]
-    fig_transversales = px.bar(df_comptransversales, x='obs', y='qualitesProfessionnelles', width=800, height=550, orientation='h', color='obs', title="Les principales compétences transversales", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df_comptransversales["qualitesProfessionnelles"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df_comptransversales["qualitesProfessionnelles"]], showlegend=False)
-
-    ######## Niveaux de qualification ########
-    df_formations = finals_df.groupby('formations').size().reset_index(name='obs')
-    fig_formations = px.pie(df_formations, names='formations', width=800, height=800, values='obs', color='obs', title="Les niveaux de qualification", labels={'obs':'nombre'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
-
-    ######## Expériences professionnelles ########
-    df_experience = finals_df.groupby('experienceLibelle').size().reset_index(name='obs')
-    fig_experience = px.pie(df_experience, names='experienceLibelle', width=800, height=800, values='obs', color='obs', title="Les expériences professionnelles", labels={'obs':'nombre'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
-
-    res = requests.get(
-        "https://raw.githubusercontent.com/codeforgermany/click_that_hood/main/public/data/spain-provinces.geojson"
-    )
-    ######## localisation ########
-    longLat = localisation()
-    df_localisation = localisation_df.groupby('lieuTravail').size().reset_index(name='obs')
-    df_localisation = df_localisation.sort_values(by=['lieuTravail'])
-    df_localisation['longitude'] = df_localisation['lieuTravail']
-    df_localisation['latitude'] = df_localisation['lieuTravail']
-
-    df_localisation["longitude"] = df_localisation['longitude'].apply(lambda x:longLat.loc[longLat['ID'] == x, 'Longitude'].iloc[0])
-    df_localisation["latitude"] = df_localisation['latitude'].apply(lambda x:longLat.loc[longLat['ID'] == x, 'Latitude'].iloc[0])
-
-    fig_localisation = px.scatter_mapbox(df_localisation, lat="latitude", lon="longitude", height=600,hover_name="lieuTravail", size="obs").update_layout(
-        mapbox={
-            "style": "carto-positron",
-            "center": {"lon": 2, "lat" : 47},
-            "zoom": 4.5,
-            "layers": [
-                {
-                    "source": res.json(),
-                    "type": "line",
-                    "color": "green",
-                    "line": {"width": 0},
-                }
-            ],
-        }
-    )
-    
-    elements.append(cl.Plotly(name="chart_intitule", figure=fig_intitule, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_contrat", figure=fig_contrat, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_competences", figure=fig_competences, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_transversales", figure=fig_transversales, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_formations", figure=fig_formations, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_experience", figure=fig_experience, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_secteur", figure=fig_secteur, display="inline", size="large"))
-    elements.append(cl.Plotly(name="chart_localisation", figure=fig_localisation, display="inline", size="large"))
-    
-    await cl.Message(content="Datavisualisation du marché de l'emploi", elements=elements).send()
-    await action.remove()
 
 @cl.action_callback("saveMemory")
 async def on_action(action):
@@ -517,54 +395,23 @@ async def start():
 @literal_client.step(type="run")
 async def construction_NCS(competenceList):
     context = await contexte(competenceList)
-    emploisST = cl.user_session.get("EmploiST")
-    memory = ConversationBufferMemory(return_messages=True)
-    ### Mistral Completion ###
-    client_llm = await IA()
-    structure = str(modele('Note de composante sectorielle'))
-    definitions = definition('activite') + ' ' + definition('competence')
-    template = """<s>[INST] Vous êtes un spécialiste du marché de l'emploi en fonction du niveau de qualification, des compétences professionnelles, des compétences transversales, du salaire et de l'expérience. Vous êtes doué pour faire des analyses du système travail sur les métiers les plus demandés grâce à votre aptitude à synthétiser les informations en fonction des critères définis ci-avant.
-    
-    En fonction des informations suivantes et du contexte suivant seulement et strictement, répondez à la question ci-dessous à partir du contexte ci-dessous :
-    {context}
-    {question} [/INST] </s>
-    """
-    question_p ="""
-    Peux-tu créer une note sectorielle d'après le modèle de note sectorielle précédent en respectant ses parties : 2., 2.1, 2.1.1, 2.2, 2.2.1, 2.2.2, 2.2.3 et d'après le contexte en vous réferrant strictement aux données du contexte fixé? Réponse sous forme d'un texte généré d'après le modèle et le contexte en 5000 mots et en langue française absolument.
-    """
-    context_p = f"Contexte : {context}. {definitions} Modèle de note sectorielle : {structure}. Réponds en langue française strictement à la question suivante en respectant strictement les données du contexte. Si vous ne pouvez pas répondre à la question sur la base des informations, dites que vous ne trouvez pas de réponse ou que vous ne parvenez pas à trouver de réponse. Essayez donc de comprendre en profondeur le contexte et répondez uniquement en vous basant sur les informations fournies. Ne générez pas de réponses non pertinentes. Si les informations du contexte sont insuffisantes, procédez à une projection sur le secteur, les entreprises et le marché de l'emploi, pour construire la note de composante sectorielle."
-    prompt = PromptTemplate(template=template, input_variables=["question","context"])
-    #llm_chain = LLMChain(prompt=prompt, llm=client_llm)
-    #completion_NCS = llm_chain.run({"question":question_p,"context":context_p}, callbacks=[StreamingStdOutCallbackHandler()])
-    chain = (
-        RunnablePassthrough.assign(
-            history=RunnableLambda(memory.load_memory_variables) | itemgetter("history")
-        )
-        | prompt | client_llm
-    )
-    
-    msg = cl.Message(author="Datapcc : 🌐🌐🌐",content="")
-    async for chunk in chain.astream({"question":question_p,"context":context_p},
-                config=RunnableConfig(callbacks=[cl.AsyncLangchainCallbackHandler(stream_final_answer=True)])):
-        await msg.stream_token(chunk)
-    
-    cl.user_session.set("NCS" + romeListArray[0], msg.content)
-    cl.user_session.set("contextChatBot", context + "\n" + msg.content)
-    await cl.sleep(2)
+    emploisST = context.to_string(index = False)
+    cl.user_session.set("contextChatBot", emploisST)
+    romeListArray = cl.user_session.get("codeRomeArray")
+    listEmplois = context.values.tolist()
+    stringEmplois = ''
+    for i in range(0,len(listEmplois)):
+        stringEmplois += "\n✔️ Emploi : " + listEmplois[i][0] + "; Contrat : " + listEmplois[i][1] + "; Compétences professionnelles : " + arrayToString(listEmplois[i][3]) + "; " + "Salaire : " + listToString(listEmplois[i][5]) + "; Qualification : " + listEmplois[i][4] + "; Localisation : " + listEmplois[i][6] + "; Expérience : " + listEmplois[i][2] + "; Niveau de qualification : " + listToString(listEmplois[i][7]) + "; Description de l'emploi : " + listToString(listEmplois[i][8])) + "\n"
+    await cl.sleep(1)
     listEmplois_name = f"Liste des emplois"
     text_elements = []
     text_elements.append(
-        cl.Text(content="Question : " + romeListArray[0] + "\n\nRéponse :\n" + emploisST.replace('Emploi : ','\n✔️ Emploi : ').replace('Contrat : ','\nContrat : ').replace('Compétences professionnelles : ','\nCompétences professionnelles : ').replace('Salaire : ','\nSalaire : ').replace('Qualification : ','\nQualification : '), name=listEmplois_name)
+        cl.Text(content="Question : " + competenceList + "\n\nRéponse :\n" + stringEmplois, name=listEmplois_name)
     )
-    await cl.Message(author="Datapcc : 🌐🌐🌐",content="👨‍💼 Source Pôle Emploi : " + listEmplois_name, elements=text_elements).send()
-    await cl.sleep(2)
-    datavizEmploi = [
-        cl.Action(name="datavizEmploi", value=romeListArray[0], description="Afficher la datavisualisation du marché de l'emploi")
-    ]
-    await cl.Message(author="Datapcc : 🌐🌐🌐",content="📊 Afficher la datavisualisation du marché de l'emploi", actions=datavizEmploi).send()
-    await cl.sleep(2)
-    if romeListArray[0].find(',') != -1:
-        codeArray = romeListArray[0].split(',')
+    await cl.Message(author="Datapcc : 🌐🌐🌐",content="👨‍💼 Source France Travail : " + listEmplois_name, elements=text_elements).send()
+    await cl.sleep(1)
+    if romeListArray.find(',') != -1:
+        codeArray = romeListArray
         ficheMetiers = []
         for i in range(0,len(codeArray)):
             ficheMetiers = [
@@ -575,86 +422,48 @@ async def construction_NCS(competenceList):
             ).send()
     else:
         ficheMetiers = [
-            cl.File(name= "Fiche métier " + romeListArray[0],url="https://www.soi-tc.fr/assets/fiches_pe/FEM_" + romeListArray[0] + ".pdf",display="inline",)
+            cl.File(name= "Fiche métier " + romeListArray,url="https://www.soi-tc.fr/assets/fiches_pe/FEM_" + romeListArray + ".pdf",display="inline",)
         ]
         await cl.Message(
             author="Datapcc : 🌐🌐🌐", content="[Fiches métiers] 🔗", elements=ficheMetiers
         ).send()
     
-    await cl.sleep(2)
-    listPrompts_name = f"Liste des requêtes sur la note sectorielle"
-    prompt_elements = []
-    prompt_elements.append(
-        cl.Text(content=definition('promptLibraryNCS'), name=listPrompts_name)
+    await cl.sleep(1)
+    ficheClesMetier = await document_chiffres_cles_emplois("https://dataemploi.francetravail.fr/metier/chiffres-cles/NAT/FR/", romeListArray)
+    listClesMetier_name = f"Chiffres clés des emplois"
+    text_ClesMetier = []
+    text_ClesMetier.append(
+        cl.Text(content="Question : " + competenceList + "\n\nRéponse :\n" + ficheClesMetier, name=listClesMetier_name)
     )
-    await cl.Message(author="Datapcc : 🌐🌐🌐",content="📚 Bibliothèque de prompts : " + listPrompts_name, elements=prompt_elements).send()
-    await cl.sleep(2)
-    actions = [
-        cl.Action(name="download", value=msg.content, description="download_note_sectorielle")
-    ]
-    await cl.Message(author="Datapcc : 🌐🌐🌐",content="Télécharger la note", actions=actions).send()
-    await cl.sleep(2)
-    saves = [
-        cl.Action(name="saveToMemory", value=msg.content, description="Mettre en mémoire la note")
-    ]
-    await cl.Message(author="Datapcc : 🌐🌐🌐",content="Mettre en mémoire la note", actions=saves).send()
-    await cl.sleep(2)
-
-    memory.chat_memory.add_user_message(question_p)
-    memory.chat_memory.add_ai_message(msg.content)
-    return "Construction de la Note Sectorielle"
+    await cl.Message(author="Datapcc : 🌐🌐🌐",content="📊 Source France Travail : " + listClesMetier_name, elements=text_ClesMetier).send()
+    
+    return "datavisualisation des statistiques de l'emploi"
 
 @cl.step(type="run")
 async def recuperation_contexte(getNote):
     getContext = cl.user_session.get(getNote)
     return getNote + " :\n" + getContext
 @cl.step(type="retrieval")
-async def contexte(romeListArray):
-    #results = await API_FranceTravail(romeListArray)
-    results = await creation_liste_code_Rome_et_emplois(romeListArray)
-    results_df = results
-    finals = results_df[['intitule','typeContratLibelle','experienceLibelle','competences','qualitesProfessionnelles','salaire','lieuTravail','formations','description']].copy()
-    finals["lieuTravail"] = finals["lieuTravail"].apply(lambda x: x['libelle']).apply(lambda x: x[0:3]).apply(lambda x: x.strip())
-    emplois = results_df.values.tolist()
-
-    listEmplois = []
-    for i in range(0,len(emplois)):
-        listEmplois.append("\nEmploi : " + emplois[i][0] + "; Contrat : " + emplois[i][1] + "; Compétences professionnelles : " + arrayToString(emplois[i][3]) + "; " + "Salaire : " + listToString(emplois[i][5]) + "; Qualification : " + emplois[i][4] + "; Localisation : " + emplois[i][6] + "; Expérience : " + emplois[i][2] + "; Niveau de qualification : " + listToString(emplois[i][7]) + "; Description de l'emploi : " + listToString(emplois[i][8]))
-    #emplois_list = results[0]
-    #context = emplois_list.replace('[','').replace(']','').replace('{','').replace('}','')
-    context = listEmplois
-    ficheMetier = await FicheMetier("https://candidat.francetravail.fr/metierscope/fiche-metier/", romeListArray[0])
-    ficheClesMetier = await ChiffresClesMetier("https://dataemploi.francetravail.fr/metier/chiffres-cles/NAT/FR/", romeListArray[0])
-    #ficheMetiersCompetencesSavoirs = await Fiche_metier_competences_savoirs(romeListArray[0])
-    #metierSecteurContexteTravail = await Metier_secteur_contexte_travail(romeListArray[0])
-    cl.user_session.set("EmploiST", context)
-    return "Fiches Métiers :\n" + ficheMetier + "\nChiifres clés métiers :\n" + ficheClesMetier + "\nListe des emplois issus de France Travail :\n" + context
-    #return "Fiche métier Compétences Savoirs :\n" + ficheMetiersCompetencesSavoirs + "\nMetier secteur contexte au travail :\n" + metierSecteurContexteTravail + "\nListe des emplois issus de France Travail :\n" + context
-    #return "Liste des emplois issus de France Travail :\n" + context
-    #return "\nMetier secteur contexte au travail :\n" + metierSecteurContexteTravail + "\nListe des emplois issus de France Travail :\n" + context
-@cl.step(type="tool")
-async def FicheMetier(url, codes):
-    if codes.find(',') != -1:
-        all = ""
-        codeArray = codes.split(',')
-        for i in range(0,len(codeArray)):
-            response = requests.get(url + codeArray[i])
-            soup = BeautifulSoup(response.text, "html.parser")
-            allmissions = soup.select('div.fm-presentation-text')
-            allcompetences = soup.select('div#part2')
-            allcontextes = soup.select('div#part3')
-            all = all + "Fiche Métier " + codeArray[i] + ":\nLes missions principales : " + removeTags(allmissions[0]) + ". Les compétences recherchées : " + removeTags(allcompetences[0]) + ". Les contextes au travail : " + removeTags(allcontextes[0]) + "."
-    else:
-        response = requests.get(url + codes)
-        soup = BeautifulSoup(response.text, "html.parser")
-        allmissions = soup.select('div.fm-presentation-text')
-        allcompetences = soup.select('div#part2')
-        allcontextes = soup.select('div#part3')
-        all = "Fiche Métier " + codes + ":\nLes missions principales : " + removeTags(allmissions[0]) + ". Les compétences recherchées : " + removeTags(allcompetences[0]) + ". Les contextes au travail : " + removeTags(allcontextes[0]) + "."
-    return all
+async def contexte(competence):
+    results = await creation_liste_code_Rome(competence)
+    await cl.sleep(1)
+    romeListArray = cl.user_session.get("codeRomeArray")
+    df_emplois = await API_France_Travail(romeListArray)
+    await cl.sleep(1)
+    await datavisualisation_statistiques_emplois(df_emplois)
+    await cl.sleep(1)
+    for j in range(0, len(romeListArray)):
+        table = await datavisualisation_chiffres_cles_emplois("https://dataemploi.pole-emploi.fr/metier/chiffres-cles/NAT/FR/" + romeListArray[j])
+        plot_demandeur = plotDemandeur(htmlToDataframe(table[0]), codeRome_list[j])
+        plot_salaire = plotSalaire(htmlToDataframe(table[1]))
+        plot_difficulte = plotDifficulte(htmlToDataframe(table[2]))
+        plot_repartitionContrat = plotRepartition(htmlToDataframe(table[3]), "Répartition des embauches du métier : type de contrat")
+        plot_repartitionEntreprise = plotRepartition(htmlToDataframe(table[4]), "Répartition des embauches du métier : type entreprise")
+        
+    return df_emplois
 
 @cl.step(type="tool")
-async def ChiffresClesMetier(url, codes):
+async def document_chiffres_cles_emplois(url, codes):
     if codes.find(',') != -1:
         all = ""
         codeArray = codes.split(',')
@@ -749,7 +558,198 @@ async def ChiffresClesMetier(url, codes):
     return all
 
 @cl.step(type="tool")
-async def creation_liste_code_Rome_et_emplois(competence):
+async def datavisualisation_chiffres_cles_emplois(url):
+    response = requests.get(url)
+    soup = BeautifulSoup(response.text, "lxml")
+
+    allembauches = soup.select('p.population_category')
+    allnumembauchesfirst = soup.select('p.population_main-num.data')
+    allnumembauches = removeTags(allnumembauchesfirst[0]).split('\xa0')
+    allnumembauches = ''.join(allnumembauches)
+    allnumoffres = removeTags(allnumembauchesfirst[1]).split('\xa0')
+    allnumoffres = ''.join(allnumoffres)
+    alldetailembauches = soup.select('p.hiring_text.ng-star-inserted')
+    allnumevolutionembauches = soup.select('p.main.ng-star-inserted')
+    alldetailevolutionembauches = soup.select('p.population_bubble-title')
+    alldemandeurs = "<table><tr><td>Indicateur</td><td>Valeur</td></tr><tr><td>" + removeTags(allembauches[0]) + " (" + removeTags(alldetailembauches[0]) + ");\nÉvolution demandeurs d'emploi (" + removeTags(alldetailevolutionembauches[0]) + ": " + removeTags(allnumevolutionembauches[0]) + ")</td><td>" + allnumembauches + "</td></tr>"
+    alldemandeurs += "<tr><td>" + removeTags(allembauches[1]) + " (" + removeTags(alldetailembauches[1]) + "); Évolution offres d'emploi (" + removeTags(alldetailevolutionembauches[1]) + ": " + removeTags(allnumevolutionembauches[1]) + ")</td><td>" + allnumoffres + "</td></tr>"
+    alldemandeurs += "</table>"
+
+    allFAP = soup.select('tr.sectorTable__line.ng-star-inserted')
+    allcategorie = soup.select('td.sectorTable__cell')
+    alltypesalaires = soup.select('th.sectorTable__cell')
+    allFAPsalaires = soup.select('p.sectorTable__cellValue')
+    allsalaires = "<table><tr><td>categorie</td><td>emploi</td><td>salaire</td></tr>"
+    allsalaires += "<tr><td>" + removeTags(alltypesalaires[1]) + "</td><td>" + removeTags(allcategorie[0]) + "</td><td>" + removeTags(allFAPsalaires[0]).replace('\xa0','').replace(' ','').replace('€','') + "</td></tr>"
+    allsalaires += "<tr><td>" + removeTags(alltypesalaires[2]) + "</td><td>" + removeTags(allcategorie[0]) + "</td><td>" + removeTags(allFAPsalaires[1]).replace('\xa0','').replace(' ','').replace('€','') + "</td></tr>"
+    allsalaires += "<tr><td>" + removeTags(alltypesalaires[3]) + "</td><td>" + removeTags(allcategorie[0]) + "</td><td>" + removeTags(allFAPsalaires[2]).replace('\xa0','').replace(' ','').replace('€','') + "</td></tr>"
+    if len(allFAP) >= 2:
+        allsalaires += "<tr><td>" + removeTags(alltypesalaires[1]) + "</td><td>" + removeTags(allcategorie[4]) + "</td><td>" + removeTags(allFAPsalaires[3]).replace('\xa0','').replace(' ','').replace('€','') + "</td></tr>"
+        allsalaires += "<tr><td>" + removeTags(alltypesalaires[2]) + "</td><td>" + removeTags(allcategorie[4]) + "</td><td>" + removeTags(allFAPsalaires[4]).replace('\xa0','').replace(' ','').replace('€','') + "</td></tr>"
+        allsalaires += "<tr><td>" + removeTags(alltypesalaires[3]) + "</td><td>" + removeTags(allcategorie[4]) + "</td><td>" + removeTags(allFAPsalaires[5]).replace('\xa0','').replace(' ','').replace('€','') + "</td></tr>"
+    allsalaires += "</table>"
+
+    alltypedifficultes = soup.select('.tabs-main-content_persp-col2-bar.ng-star-inserted')
+    alldifficulte = soup.select('p.horizontal-graph_title')
+    allpcdifficulte = soup.select('div.horizontal-graph_data')
+    alldifficultes = "<table><tr><td>Indicateur</td><td>Valeur</td></tr>"
+    for i in range(0,len(alltypedifficultes)):
+        alldifficultes += "<tr><td>" + removeTags(alldifficulte[i]) + "</td><td>" + removeTags(allpcdifficulte[i]).replace('Pour le territoire principal FRANCE pour les ' + removeTags(alldifficulte[i]),'').replace('%','') + "</td></tr>"
+    alldifficultes += "</table>"
+
+    alltyperepartitions = soup.select('div.hiring-contract_legende_item.ng-star-inserted')
+    allrepartition = soup.select('p.hiring-contract_legende_item_label')
+    allpcrepartition = soup.select('span.hiring-contract_legende_item-first')
+    allrepartitions = "<table><tr><td>Indicateur</td><td>Valeur</td></tr>"
+    for i in range(0,len(alltyperepartitions)):
+        allrepartitions += "<tr><td>" + removeTags(allrepartition[i]).replace('(' + removeTags(allpcrepartition[i]) + ')','') + "</td><td>" + removeTags(allpcrepartition[i]).replace('%','').replace(',','.') + "</td></tr>"
+    allrepartitions += "</table>"
+
+    allentrepriserepartitions = soup.select('div.horizontal-graph_pattern.sm-bubble_wrapper > span')
+    allentreprise = soup.select('span.sr-only')
+    allpcentreprise = soup.select('span.data.ng-star-inserted')
+    allentreprises = "<table><tr><td>Indicateur</td><td>Valeur</td></tr>"
+    for i in range(0,len(allentrepriserepartitions)):
+        allentreprises += "<tr><td>" + removeTags(allentrepriserepartitions[i])[0:-4] + "</td><td>" + removeTags(allentrepriserepartitions[i])[-4:].replace('%','').replace(',','.') + "</td></tr>"
+    allentreprises += "</table>"
+
+    return [alldemandeurs, allsalaires, alldifficultes, allrepartitions, allentreprises]
+    
+@cl.step(type="tool")
+async def datavisualisation_statistiques_emplois(results_df):
+    arraydataframe = []
+    arrayfirstdataframe = []
+    arraylocalisationdataframe = []
+    results = []
+    count = 0
+    if results_df.empty == False:
+        count = count + 1
+        finals = results_df[['intitule','typeContratLibelle','experienceLibelle','competences','qualitesProfessionnelles','salaire','lieuTravail','formations']].copy()
+        finals["lieuTravail"] = finals["lieuTravail"].apply(lambda x: x['libelle']).apply(lambda x: x[0:3]).apply(lambda x: x.strip())
+        finals_df = finals
+        finals_df.dropna(subset=['qualitesProfessionnelles','formations','competences'], inplace=True)
+        finals_df["competences"] = finals_df["competences"].apply(lambda x:[str(e['libelle']) for e in x]).apply(lambda x:'; '.join(map(str, x)))
+        finals_df["qualitesProfessionnelles"] = finals_df["qualitesProfessionnelles"].apply(lambda x:[str(e['libelle']) + ": " + str(e['description']) for e in x]).apply(lambda x:'; '.join(map(str, x)))
+        finals_df["formations"] = finals_df["formations"].apply(lambda x:[str(e['niveauLibelle']) for e in x]).apply(lambda x:'; '.join(map(str, x)))
+        finals_df = finals_df.sort_values(by=['lieuTravail'])
+        finals_localisation = results_df[['lieuTravail']].copy()
+        finals_localisation["lieuTravail"] = finals_localisation["lieuTravail"].apply(lambda x: np.array(x)).apply(lambda x: x['libelle']).apply(lambda x: x[0:3]).apply(lambda x: x.strip())
+        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Fra'].index, inplace = True)
+        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'FRA'].index, inplace = True)
+        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Ile'].index, inplace = True)
+        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Mar'].index, inplace = True)
+        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == 'Bou'].index, inplace = True)
+        finals_localisation.drop(finals_localisation[finals_localisation['lieuTravail'] == '976'].index, inplace = True)
+        arraylocalisationdataframe.append(finals_localisation)
+        arrayfirstdataframe.append(results_df)
+        if len(finals_df) != 0:
+            arraydataframe.append(finals_df)
+    first_df = pd.concat(arrayfirstdataframe)
+    finals_df = pd.concat(arraydataframe)
+    localisation_df = pd.concat(arraylocalisationdataframe)
+    
+    ######## Emplois ########
+    df_intitule = first_df.groupby('intitule').size().reset_index(name='obs')
+    df_intitule = df_intitule.sort_values(by=['obs'])
+    df_intitule = df_intitule.iloc[-25:]
+    fig_intitule = px.bar(df_intitule, x='obs', y='intitule', orientation='h', color='obs', title="Les principaux emplois", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df_intitule["intitule"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df_intitule["intitule"]], showlegend=False)
+    
+    ######## Types de contrat ########
+    df_contrat = first_df.groupby('typeContratLibelle').size().reset_index(name='obs')
+    fig_contrat = px.pie(df_contrat, names='typeContratLibelle', values='obs', color='obs', title="Les types de contrat", labels={'obs':'nombre'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
+    
+    df_secteur = first_df.groupby('secteurActiviteLibelle').size().reset_index(name='obs')
+    df_secteur = df_secteur.sort_values(by=['obs'])
+    df_secteur = df_secteur.iloc[-25:]
+    fig_secteur = px.bar(df_secteur, x='obs', y='secteurActiviteLibelle', orientation='h', color='obs', title="Les principaux secteurs d'activités", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df_secteur["secteurActiviteLibelle"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df_secteur["secteurActiviteLibelle"]], showlegend=False)
+    
+    ######## Compétences professionnelles ########
+    df1 = finals_df
+    df1['competences'] = finals_df['competences'].str.split(';')
+    df2 = df1.explode('competences')
+    df2 = df2.groupby('competences').size().reset_index(name='obs')
+    df2 = df2.sort_values(by=['obs'])
+    df2 = df2.iloc[-20:]
+    fig_competences = px.bar(df2, x='obs', y='competences', orientation='h', color='obs', title="Les principales compétences professionnelles", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df2["competences"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df2['competences']], showlegend=False)
+    
+    ######## Compétences transversales ########
+    df_transversales = finals_df
+    df_transversales['qualitesProfessionnelles'] = finals_df['qualitesProfessionnelles'].str.split(';')
+    df_comptransversales = df_transversales.explode('qualitesProfessionnelles')
+    df_comptransversales = df_comptransversales.groupby('qualitesProfessionnelles').size().reset_index(name='obs')
+    df_comptransversales = df_comptransversales.sort_values(by=['obs'])
+    df_comptransversales = df_comptransversales.iloc[-20:]
+    fig_transversales = px.bar(df_comptransversales, x='obs', y='qualitesProfessionnelles', orientation='h', color='obs', title="Les principales compétences transversales", labels={'obs':'nombre'}, color_continuous_scale="Teal", text_auto=True).update_layout(font=dict(size=10,color="RebeccaPurple"),autosize=True).update_traces(hovertemplate=df_comptransversales["qualitesProfessionnelles"] + ' <br>Nombre : %{x}', y=[y[:100] + "..." for y in df_comptransversales["qualitesProfessionnelles"]], showlegend=False)
+    
+    ######## Niveaux de qualification ########
+    df_formations = finals_df.groupby('formations').size().reset_index(name='obs')
+    fig_formations = px.pie(df_formations, names='formations', values='obs', color='obs', title="Les niveaux de qualification", labels={'obs':'nombre'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
+    
+    ######## Expériences professionnelles ########
+    df_experience = finals_df.groupby('experienceLibelle').size().reset_index(name='obs')
+    fig_experience = px.pie(df_experience, names='experienceLibelle', values='obs', color='obs', title="Les expériences professionnelles", labels={'obs':'nombre'}, color_discrete_sequence=px.colors.qualitative.Safe).update_traces(textposition='inside', textinfo='percent+label').update_layout(font=dict(size=10,color="RebeccaPurple"))
+    
+    res = requests.get(
+        "https://raw.githubusercontent.com/codeforgermany/click_that_hood/main/public/data/spain-provinces.geojson"
+    )
+    ######## localisation ########
+    ListCentroids = localisation()
+    df_localisation = localisation_df.groupby('lieuTravail').size().reset_index(name='obs')
+    df_localisation = df_localisation.sort_values(by=['lieuTravail'])
+    df_localisation['longitude'] = df_localisation['lieuTravail']
+    df_localisation['latitude'] = df_localisation['lieuTravail']
+    
+    
+    df_localisation["longitude"] = df_localisation['longitude'].apply(lambda x:[loc['Longitude'] for loc in ListCentroids if loc['ID'] == x]).apply(lambda x:''.join(map(str, x)))
+    df_localisation["longitude"] = pd.to_numeric(df_localisation["longitude"], downcast="float")
+    df_localisation["latitude"] = df_localisation['latitude'].apply(lambda x:[loc['Latitude'] for loc in ListCentroids if loc['ID'] == x]).apply(lambda x:''.join(map(str, x)))
+    df_localisation["latitude"] = pd.to_numeric(df_localisation["latitude"], downcast="float")
+
+    fig_localisation = px.scatter_mapbox(df_localisation, lat="latitude", lon="longitude", hover_name="lieuTravail", size="obs").update_layout(
+        mapbox={
+            "style": "carto-positron",
+            "center": {"lon": 2, "lat" : 47},
+            "zoom": 4.5,
+            "layers": [
+                {
+                    "source": res.json(),
+                    "type": "line",
+                    "color": "green",
+                    "line": {"width": 0},
+                }
+            ],
+        }
+    )
+        
+    elements = []
+    elements.append(cl.Plotly(name="chart_intitule", figure=fig_intitule, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_contrat", figure=fig_contrat, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_competences", figure=fig_competences, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_transversales", figure=fig_transversales, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_formations", figure=fig_formations, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_experience", figure=fig_experience, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_secteur", figure=fig_secteur, display="inline", size="large"))
+    elements.append(cl.Plotly(name="chart_localisation", figure=fig_localisation, display="inline", size="large"))
+        
+    await cl.Message(content="Datavisualisation du marché de l'emploi", elements=elements).send()
+    
+@cl.step(type="tool")
+async def API_France_Travail(romeListArray):
+    client = await connexion_France_Travail()
+    todayDate = datetime.datetime.today()
+    month, year = (todayDate.month-1, todayDate.year) if todayDate.month != 1 else (12, todayDate.year-1)
+    start_dt = todayDate.replace(day=1, month=month, year=year)
+    end_dt = datetime.datetime.today()
+    results = []
+    for k in romeListArray:
+      params = {"motsCles": k,'minCreationDate': dt_to_str_iso(start_dt),'maxCreationDate': dt_to_str_iso(end_dt),'range':'0-149'}
+      search_on_big_data = client.search(params=params)
+      results += search_on_big_data["resultats"]
+    results_df = pd.DataFrame(results)
+    return results_df
+    
+@cl.step(type="tool")
+async def creation_liste_code_Rome(competence):
     os.environ['PINECONE_API_KEYROME'] = os.environ['PINECONE_API_KEYROME']
     docsearch = await connexion_catalogue_Rome()
     retrieve_comp = docsearch.similarity_search(competence, k=30, filter={"categorie": {"$eq": os.environ['PINECONE_API_KEYROME']}})
@@ -773,7 +773,7 @@ async def creation_liste_code_Rome_et_emplois(competence):
             
     results_df = results_df.drop_duplicates(subset=["codeRome"])
     results_df = results_df.head(5)
-    codeRomeString = results_df["codeRome"].to_string(index = False)
+    codeRomeString = ' | ' + results_df["codeRome"].to_string(index = False) + ' |\n| -------- |'
     codeRome_list = results_df["codeRome"].tolist()
     actionRome = await cl.AskActionMessage(
         content="Etes-vous d'accord avec la sélection des 5 codes Rome automatiques issus de la recherche sémantique ? :" + codeRomeString,
@@ -786,7 +786,6 @@ async def creation_liste_code_Rome_et_emplois(competence):
         await cl.Message(
             content="Connexion à France Travail, et récupération des offres d'emploi",
         ).send()
-        df_emplois = await API_France_Travail(codeRome_list)
         cl.user_session.set("codeRomeArray", codeRome_list)
     else:
         actionsaisierome = await cl.AskUserMessage(content="Saisissez vos codes Rome dans le prompt? ⚠️ Attention, indiquez seulement des codes Rome séparés par des virgules", timeout=3600).send()
@@ -799,14 +798,17 @@ async def creation_liste_code_Rome_et_emplois(competence):
             teststringCodeRome = [ele for ele in stopWords if(ele in stringCodeRome)]
             teststringCodeRome = bool(teststringCodeRome)
             if teststringCodeRome == False:
-                arrayCodeRome = stringCodeRome.spit(',')
+                arrayCodeRome = stringCodeRome.split(',')
             else:
                 arrayCodeRome = codeRome_list
                 await cl.Message(author="Datapcc : 🌐🌐🌐",content="Votre ssaisie est erronée. Nous continuons l'action avec les codes Rome sélectionnés automatiquement pour vous : " + codeRome_list).send()
-            df_emplois = await API_France_Travail(arrayCodeRome)
             cl.user_session.set("codeRomeArray", arrayCodeRome)
-        
-    return df_emplois
+    
+@cl.step(type="tool")
+async def connexion_France_Travail():
+    client = Api(client_id=os.environ['POLE_EMPLOI_CLIENT_ID'],
+                client_secret=os.environ['POLE_EMPLOI_CLIENT_SECRET'])
+    return client
     
 @cl.step(type="tool")
 async def connexion_catalogue_Rome():
@@ -816,22 +818,6 @@ async def connexion_catalogue_Rome():
     docsearch = PineconeVectorStore.from_existing_index(os.environ['PINECONE_INDEX_NAME'], embeddings)
     return docsearch
     
-@cl.step(type="tool")
-async def API_France_Travail(romeListArray):
-    client = Api(client_id=os.environ['POLE_EMPLOI_CLIENT_ID'],
-                client_secret=os.environ['POLE_EMPLOI_CLIENT_SECRET'])
-    todayDate = datetime.datetime.today()
-    month, year = (todayDate.month-1, todayDate.year) if todayDate.month != 1 else (12, todayDate.year-1)
-    start_dt = todayDate.replace(day=1, month=month, year=year)
-    end_dt = datetime.datetime.today()
-    results = []
-    for k in romeListArray:
-      params = {"motsCles": k,'minCreationDate': dt_to_str_iso(start_dt),'maxCreationDate': dt_to_str_iso(end_dt),'range':'0-149'}
-      search_on_big_data = client.search(params=params)
-      results += search_on_big_data["resultats"]
-    results_df = pd.DataFrame(results)
-    return results_df
-
 @cl.step(type="llm")
 async def IA():
     os.environ['HUGGINGFACEHUB_API_TOKEN'] = os.environ['HUGGINGFACEHUB_API_TOKEN']