Update app.py

app.py

@@ -32,12 +32,14 @@ class TaskManager:
             'total': 470,
             'results_file': f'results_{task_id}.txt',
             'start_time': datetime.now(),
-            'errors': []
+            'errors': [],
+            'last_update': datetime.now()
         }
     
     def update_progress(self, task_id, progress):
         if task_id in self.tasks:
             self.tasks[task_id]['progress'] = progress
+            self.tasks[task_id]['last_update'] = datetime.now()
     
     def add_error(self, task_id, error):
         if task_id in self.tasks:
@@ -46,6 +48,7 @@ class TaskManager:
     def complete_task(self, task_id):
         if task_id in self.tasks:
             self.tasks[task_id]['status'] = 'completed'
+            self.tasks[task_id]['last_update'] = datetime.now()
     
     def get_task(self, task_id):
         return self.tasks.get(task_id)
@@ -85,7 +88,7 @@ def generate_synthetic_data(file_path, task_id):
                     f.write(f"--- Requête {i+1}/470 ---\n")
                     f.write(response.text)
                     f.write("\n" + "="*60 + "\n\n")
-                    f.flush()  # Forcer l'écriture
+                    f.flush()  # Forcer l'écriture immédiate
                     
                     # Mettre à jour le progrès
                     task_manager.update_progress(task_id, i + 1)
@@ -100,6 +103,7 @@ def generate_synthetic_data(file_path, task_id):
                     task_manager.add_error(task_id, error_msg)
                     f.write(f"ERREUR - Requête {i+1}: {str(e)}\n")
                     f.write("="*60 + "\n\n")
+                    f.flush()  # Forcer l'écriture même en cas d'erreur
                     print(error_msg)
         
         task_manager.complete_task(task_id)
@@ -112,7 +116,9 @@ def generate_synthetic_data(file_path, task_id):
 
 @app.route('/')
 def index():
-    return render_template('index.html')
+    # Servir directement le HTML depuis le même dossier
+    with open('index.html', 'r', encoding='utf-8') as f:
+        return f.read()
 
 @app.route('/upload', methods=['POST'])
 def upload_file():
@@ -160,7 +166,8 @@ def get_status(task_id):
         'total': task['total'],
         'percentage': round((task['progress'] / task['total']) * 100, 2),
         'errors_count': len(task['errors']),
-        'start_time': task['start_time'].strftime('%Y-%m-%d %H:%M:%S')
+        'start_time': task['start_time'].strftime('%Y-%m-%d %H:%M:%S'),
+        'last_update': task['last_update'].strftime('%Y-%m-%d %H:%M:%S')
     })
 
 @app.route('/download/<task_id>')
@@ -174,10 +181,40 @@ def download_results(task_id):
     if not os.path.exists(results_file):
         return jsonify({'error': 'Fichier de résultats non trouvé'}), 404
     
+    # Vérifier si c'est un téléchargement partiel
+    is_partial = request.args.get('partial', 'false').lower() == 'true'
+    
+    if is_partial and task['status'] == 'running':
+        # Créer un fichier temporaire avec les données actuelles
+        temp_file = os.path.join(RESULTS_FOLDER, f'temp_results_{task_id}.txt')
+        
+        # Copier le contenu actuel vers le fichier temporaire
+        try:
+            with open(results_file, 'r', encoding='utf-8') as original:
+                content = original.read()
+            
+            with open(temp_file, 'w', encoding='utf-8') as temp:
+                temp.write(content)
+                temp.write(f"\n\n--- TÉLÉCHARGEMENT PARTIEL ---\n")
+                temp.write(f"Téléchargé le: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n")
+                temp.write(f"Progrès: {task['progress']}/{task['total']} ({round((task['progress'] / task['total']) * 100, 2)}%)\n")
+                temp.write("Génération en cours... Ce fichier contient les données générées jusqu'à présent.\n")
+            
+            return send_file(
+                temp_file,
+                as_attachment=True,
+                download_name=f'donnees_synthetiques_partiel_{task_id}.txt'
+            )
+        except Exception as e:
+            return jsonify({'error': f'Erreur lors de la création du fichier partiel: {str(e)}'}), 500
+    
+    # Téléchargement normal (complet)
+    download_name = f'donnees_synthetiques_{"complet" if task["status"] == "completed" else "actuel"}_{task_id}.txt'
+    
     return send_file(
         results_file,
         as_attachment=True,
-        download_name=f'donnees_synthetiques_{task_id}.txt'
+        download_name=download_name
     )
 
 @app.route('/tasks')
@@ -192,10 +229,34 @@ def list_tasks():
             'total': task_info['total'],
             'percentage': round((task_info['progress'] / task_info['total']) * 100, 2),
             'start_time': task_info['start_time'].strftime('%Y-%m-%d %H:%M:%S'),
+            'last_update': task_info['last_update'].strftime('%Y-%m-%d %H:%M:%S'),
             'errors_count': len(task_info['errors'])
         })
     
+    # Trier par heure de début (plus récent en premier)
+    task_list.sort(key=lambda x: x['start_time'], reverse=True)
+    
     return jsonify(task_list)
 
+@app.route('/cleanup')
+def cleanup_temp_files():
+    """Nettoyer les fichiers temporaires (optionnel)"""
+    try:
+        temp_files_deleted = 0
+        for filename in os.listdir(RESULTS_FOLDER):
+            if filename.startswith('temp_results_'):
+                file_path = os.path.join(RESULTS_FOLDER, filename)
+                os.remove(file_path)
+                temp_files_deleted += 1
+        
+        return jsonify({
+            'message': f'{temp_files_deleted} fichiers temporaires supprimés'
+        })
+    except Exception as e:
+        return jsonify({'error': f'Erreur lors du nettoyage: {str(e)}'}), 500
+
 if __name__ == '__main__':
+    print("🚀 Démarrage du serveur...")
+    print("📂 Dossiers créés:", UPLOAD_FOLDER, RESULTS_FOLDER)
+    print("🌐 Application disponible sur: http://localhost:5000")
     app.run(debug=True, threaded=True)