Update app.py

app.py

@@ -24,8 +24,11 @@ competence_questions = [
 competence_responses = []
 current_question_index = 0
 
-def call_api_for_summary(responses):
-    messages = [{"role": "system", "content": "Vous êtes un assistant IA qui génère un résumé des compétences."}]
+def call_api_for_skill_assessment(responses):
+    messages = [
+        {"role": "system", "content": "Vous êtes un assistant IA qui évalue les compétences. Faites un bilan des compétences avec toutes les compétences, appliquez ceci à toutes les compétences de l'utilisateur. Évaluez-les en fonction de l'expérience de l'utilisateur, sans aucun autre commentaire, ni style dans le texte (pas de gras, pas de souligné, pas d'italique). Sous cette forme :\n- Compétence 1\n- Compétence 2\n- Compétence 3\n..."}
+    ]
+
     for i, response in enumerate(responses):
         messages.append({"role": "user", "content": f"{competence_questions[i]} : {response}"})
     
@@ -53,12 +56,29 @@ def call_api_for_summary(responses):
         logger.error(f"Erreur lors de l'appel API: {str(e)}")
         return f"Erreur: {str(e)}"
 
-def call_api_for_skill_assessment(responses):
-    messages = [{"role": "system", "content": "Vous êtes un assistant IA qui évalue les compétences. Faites un bilan des compétences avec toutes les compétences, appliquez ceci à toutes les compétences de l'utilisateur. Évaluez ceci en fonction de l'expérience de l'utilisateur, sans aucun autre commentaire, ni style sur le texte (pas de gras, pas de souligné, pas d'italique), fait une liste sans titre ni style de texte."}]
+def get_enterprise_descriptions():
+    url = f"https://api.airtable.com/v0/{AIRTABLE_BASE_ID}/DescriptionsEntreprises"
+    headers = {
+        "Authorization": f"Bearer {AIRTABLE_API_KEY}",
+        "Content-Type": "application/json"
+    }
     
-    for i, response in enumerate(responses):
-        messages.append({"role": "user", "content": f"{competence_questions[i]} : {response}"})
+    response = requests.get(url, headers=headers)
     
+    if response.status_code == 200:
+        data = response.json()
+        descriptions = [(record['fields'].get('Nom', f"Entreprise {i+1}"), record['fields']['Description entreprises']) for i, record in enumerate(data['records'])]
+        return descriptions
+    else:
+        logger.error(f"Erreur lors de la récupération des descriptions d'entreprises : {response.status_code} - {response.text}")
+        return []
+
+def compare_skills_ai(student_skills, enterprise_skills):
+    messages = [
+        {"role": "system", "content": "Vous êtes un expert en recrutement chargé d'évaluer la correspondance entre les compétences d'un étudiant et celles requises par une entreprise. Votre tâche est d'analyser ces compétences et de fournir une valeur de correspondance entre l'étudiant et les différentes entreprise, je veux simplement la note global pour chaque entreprise. Tenez compte des compétences similaires ou complémentaires, pas seulement des correspondances exactes."},
+        {"role": "user", "content": f"Compétences de l'étudiant :\n{student_skills}\n\nCompétences requises par l'entreprise :\n{enterprise_skills}\n\nVeuillez analyser ces compétences et fournir un chiffre entre 0 et 100 pour la correspondance entre l'etudiant et l'entreprise afin de voir le taux de compatibilité entre l'etudiants et les différentes entreprises. en détaille rien, juste la note global sans le détail. Ecrit juste le nom de l'entreprise puis le score"}
+    ]
+
     try:
         response = requests.post(
             url="https://openrouter.ai/api/v1/chat/completions",
@@ -76,31 +96,29 @@ def call_api_for_skill_assessment(responses):
         
         if response.status_code == 200:
             data = response.json()
-            return data['choices'][0]['message']['content']
+            ai_analysis = data['choices'][0]['message']['content']
+            return ai_analysis
         else:
-            return f"Erreur lors de l'appel à l'API : {response.status_code} - {response.text}"
+            logger.error(f"Erreur lors de l'appel à l'API : {response.status_code} - {response.text}")
+            return "Erreur lors de l'analyse des compétences."
     except Exception as e:
         logger.error(f"Erreur lors de l'appel API: {str(e)}")
-        return f"Erreur: {str(e)}"
+        return f"Erreur lors de l'analyse des compétences : {str(e)}"
 
-def upload_to_airtable(skill_assessment):
-    url = f"https://api.airtable.com/v0/{AIRTABLE_BASE_ID}/{AIRTABLE_TABLE_NAME}"
-    headers = {
-        "Authorization": f"Bearer {AIRTABLE_API_KEY}",
-        "Content-Type": "application/json"
-    }
-    data = {
-        "fields": {
-            "Description Compétences Etudiants": skill_assessment  
-        }
-    }
+def compare_with_enterprises(skill_assessment):
+    enterprise_descriptions = get_enterprise_descriptions()
+    results = []
     
-    response = requests.post(url, headers=headers, json=data)
+    for enterprise_name, enterprise_desc in enterprise_descriptions:
+        analysis = compare_skills_ai(skill_assessment, enterprise_desc)
+        results.append((enterprise_name, analysis))
     
-    if response.status_code == 200:
-        return "Résumé ajouté à Airtable avec succès."
-    else:
-        return f"Erreur lors de l'ajout à Airtable : {response.status_code} - {response.text}"
+    output = ""
+    for enterprise_name, analysis in results:
+        output += f"Analyse pour {enterprise_name}:\n{analysis}\n\n"
+    
+    print(output)
+    return output
 
 def chatbot_response(message, history):
     global competence_responses, current_question_index
@@ -111,9 +129,8 @@ def chatbot_response(message, history):
     if current_question_index < len(competence_questions):
         return competence_questions[current_question_index], None
     else:
-        summary = call_api_for_summary(competence_responses)
         skill_assessment = call_api_for_skill_assessment(competence_responses)
-        return f"Merci pour vos réponses ! Voici votre bilan de compétences :\n\n{summary}", skill_assessment
+        return f"Merci pour vos réponses ! Voici votre bilan de compétences :\n\n{skill_assessment}", skill_assessment
 
 def start_conversation():
     global current_question_index, competence_responses
@@ -137,24 +154,53 @@ def clear_chat():
     current_question_index = 0
     return [], None, None
 
+def upload_to_airtable(skill_assessment):
+    url = f"https://api.airtable.com/v0/{AIRTABLE_BASE_ID}/{AIRTABLE_TABLE_NAME}"
+    headers = {
+        "Authorization": f"Bearer {AIRTABLE_API_KEY}",
+        "Content-Type": "application/json"
+    }
+    data = {
+        "fields": {
+            "Description Compétences Etudiants": skill_assessment  
+        }
+    }
+    
+    try:
+        response = requests.post(url, headers=headers, json=data)
+        
+        if response.status_code == 200:
+            return "Données envoyées avec succès à Airtable."
+        else:
+            logger.error(f"Erreur lors de l'envoi à Airtable : {response.status_code} - {response.text}")
+            return f"Erreur lors de l'enregistrement dans Airtable : {response.status_code}"
+    
+    except Exception as e:
+        logger.error(f"Erreur lors de l'envoi à Airtable : {str(e)}")
+        return f"Erreur lors de l'enregistrement dans Airtable : {str(e)}"
+
+def submit_and_compare(skill_assessment_output):
+    # Remplissage de la BDD Airtable avec le bilan des compétences
+    airtable_response = upload_to_airtable(skill_assessment_output)
+    
+    # Comparaison avec les entreprises
+    comparison_result = compare_with_enterprises(skill_assessment_output)
+    
+    return f"Résultat de l'enregistrement dans Airtable: {airtable_response}\n\n{comparison_result}"
+
 with gr.Blocks(theme=gr.themes.Soft()) as demo:
     chatbot = gr.Chatbot(label="Historique de la conversation")
     msg = gr.Textbox(label="Votre message", placeholder="Tapez votre message ici...")
     clear = gr.Button("Effacer la conversation")
-    summary_output = gr.Textbox(label="Résumé des compétences", interactive=False)
     skill_assessment_output = gr.Textbox(label="Bilan des compétences", interactive=False)
-    submit_button = gr.Button("Soumettre")
+    submit_button = gr.Button("Soumettre et comparer")
+    comparison_output = gr.Textbox(label="Résultat de la comparaison", interactive=False)
 
     demo.load(start_conversation, inputs=None, outputs=[chatbot, skill_assessment_output])
     msg.submit(user, [msg, chatbot], [msg, chatbot], queue=False).then(
         bot, [chatbot], [chatbot, skill_assessment_output]
     )
-    clear.click(clear_chat, None, [chatbot, skill_assessment_output, summary_output], queue=False)
-
-    def submit_summary(skill_assessment_output):
-        airtable_response = upload_to_airtable(skill_assessment_output)
-        return f"Résumé soumis : {skill_assessment_output}\n{airtable_response}"
-
-    submit_button.click(submit_summary, skill_assessment_output, summary_output)
+    clear.click(clear_chat, None, [chatbot, skill_assessment_output, comparison_output], queue=False)
+    submit_button.click(submit_and_compare, skill_assessment_output, comparison_output)
 
 demo.launch()