ConformSight Enterprise v3.0

Healthcare Inspection Processing System - Production Dashboard

Processing Status

IDLE

Files Progress

0 / 6509

0.0%
Violations Found

0

Vectors Created

0

Recent Processed Files

No processed files yet

System Logs

System logs will appear here

Domain:
conformsight.com
SSL Status:
Secure
Last Update:
2025-11-08T01:29:15.891293
Version:
Enterprise v3.0
from flask import Flask, render_template, request, jsonify, send_file, redirect, url_for import os import subprocess import json import time from datetime import datetime from pathlib import Path app = Flask(__name__) # Configuration ENTERPRISE_OUTPUT_DIR = '/home/ubuntu/conformsight-processor/enterprise_output' PDF_INPUT_DIR = '/home/ubuntu/conformsight-processor/test_pdfs' LOG_DIR = f'{ENTERPRISE_OUTPUT_DIR}/logs' @app.route('/') def dashboard(): """ConformSight Enterprise Dashboard""" stats = get_processing_stats() recent_files = get_recent_processed_files() return render_template('dashboard.html', stats=stats, recent_files=recent_files) @app.route('/api/start-processing', methods=['POST']) def start_processing(): """Start ConformSight Enterprise processing""" try: config = request.json or {} # Check if already running if is_processing_running(): return jsonify({ 'status': 'error', 'message': 'ConformSight processing is already running' }) # Start processing in background cmd = ['python3', 'conformsight-enterprise-v3-FIXED.py'] subprocess.Popen(cmd, cwd='/home/ubuntu/conformsight-processor') return jsonify({ 'status': 'started', 'message': 'ConformSight Enterprise processing started successfully' }) except Exception as e: return jsonify({'status': 'error', 'message': str(e)}) @app.route('/api/status') def processing_status(): """Get current processing status""" stats = get_processing_stats() return jsonify(stats) @app.route('/api/files') def list_files(): """List processed files""" files = [] if os.path.exists(ENTERPRISE_OUTPUT_DIR): for milestone_dir in ['milestone1_ocr', 'milestone2_extraction', 'milestone3_embeddings', 'milestone4_qdrant', 'milestone5_discord']: milestone_path = os.path.join(ENTERPRISE_OUTPUT_DIR, milestone_dir) if os.path.exists(milestone_path): for file in os.listdir(milestone_path): if file.endswith('.json'): file_path = os.path.join(milestone_path, file) stat = os.stat(file_path) files.append({ 'name': file, 'milestone': milestone_dir, 'size': stat.st_size, 'modified': datetime.fromtimestamp(stat.st_mtime).isoformat(), 'download_url': f'/download/{milestone_dir}/{file}' }) return jsonify(files) @app.route('/download/') def download_file(filename): """Download processed files""" file_path = os.path.join(ENTERPRISE_OUTPUT_DIR, filename) if os.path.exists(file_path): return send_file(file_path, as_attachment=True) return "File not found", 404 def get_processing_stats(): """Get current processing statistics""" stats = { 'status': 'idle', 'files_processed': 0, 'total_files': 0, 'success_rate': 0, 'violations_found': 0, 'vectors_created': 0, 'last_update': datetime.now().isoformat(), 'processing_time': 0 } try: # Count PDF files if os.path.exists(PDF_INPUT_DIR): stats['total_files'] = len([f for f in os.listdir(PDF_INPUT_DIR) if f.endswith('.pdf')]) # Count processed files if os.path.exists(f'{ENTERPRISE_OUTPUT_DIR}/milestone1_ocr'): stats['files_processed'] = len([f for f in os.listdir(f'{ENTERPRISE_OUTPUT_DIR}/milestone1_ocr') if f.endswith('.json')]) # Calculate success rate if stats['total_files'] > 0: stats['success_rate'] = (stats['files_processed'] / stats['total_files']) * 100 # Check if processing is running if is_processing_running(): stats['status'] = 'running' elif stats['files_processed'] > 0: stats['status'] = 'completed' # Get latest log info if os.path.exists(LOG_DIR): log_files = [f for f in os.listdir(LOG_DIR) if f.endswith('.log')] if log_files: latest_log = max(log_files, key=lambda x: os.path.getmtime(os.path.join(LOG_DIR, x))) stats['last_update'] = datetime.fromtimestamp( os.path.getmtime(os.path.join(LOG_DIR, latest_log)) ).isoformat() except Exception as e: print(f"Error getting stats: {e}") return stats def get_recent_processed_files(): """Get recently processed files""" files = [] try: milestone_dirs = ['milestone1_ocr', 'milestone2_extraction', 'milestone3_embeddings', 'milestone4_qdrant', 'milestone5_discord'] for milestone_dir in milestone_dirs: milestone_path = os.path.join(ENTERPRISE_OUTPUT_DIR, milestone_dir) if os.path.exists(milestone_path): for file in os.listdir(milestone_path)[:5]: # Latest 5 files if file.endswith('.json'): files.append({ 'name': file, 'milestone': milestone_dir.replace('_', ' ').title(), 'time': datetime.fromtimestamp( os.path.getmtime(os.path.join(milestone_path, file)) ).strftime('%Y-%m-%d %H:%M:%S') }) files.sort(key=lambda x: x['time'], reverse=True) return files[:10] # Return latest 10 files except Exception as e: print(f"Error getting recent files: {e}") return [] def is_processing_running(): """Check if ConformSight processing is currently running""" try: result = subprocess.run(['pgrep', '-f', 'conformsight-enterprise'], capture_output=True, text=True) return len(result.stdout.strip()) > 0 except: return False if __name__ == '__main__': app.run(host='127.0.0.1', port=5000, debug=False)