# ============================================================ # MODULE: Agent Launchpad & Workflow Templates — FASE 4 # HSEQ Intelligence Dashboard # ============================================================ import json import sqlite3 from datetime import datetime from flask import jsonify, request from indexer import DB_PATH from search import search_documents, get_db def init_db_agents(): conn = sqlite3.connect(DB_PATH) c = conn.cursor() c.execute('''CREATE TABLE IF NOT EXISTS agent_tasks ( id INTEGER PRIMARY KEY AUTOINCREMENT, agent_id TEXT NOT NULL, agent_name TEXT NOT NULL, workflow_id TEXT, task_description TEXT NOT NULL, context TEXT, status TEXT DEFAULT 'pending', result TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP, started_at TEXT, completed_at TEXT, metadata TEXT )''') conn.commit() conn.close() AGENTS = [ {"id": "hseq_specialist", "name": "HSEQ Specialist", "emoji": "🔬", "description": "Health, Safety, Environment & Quality — expert in BRZO, Arbowet, Milieu", "skills": ["BRZO compliance", "Risicoanalyse", "Inspectievoorbereiding", "HSEQ advies"], "deliverable_note": "DOCX rapport + XLSX risicotabel + HTML dashboard"}, {"id": "compliance_auditor", "name": "Compliance Auditor", "emoji": "⚖️", "description": "Compliance & auditing specialist — wet- en regelgeving", "skills": ["Compliance audits", "Wetgeving interpretatie", "Gap-analyses", "Certificering"], "deliverable_note": "DOCX rapport + XLSX gap-analyse + HTML overzicht"}, {"id": "risk_management", "name": "Risk Management Specialist", "emoji": "📊", "description": "Risicomanagement — HAZOP, LOPA, QRA, Bow-Tie", "skills": ["HAZOP", "LOPA", "QRA", "Bow-Tie analyse", "Risicomatrix"], "deliverable_note": "DOCX rapport + XLSX risicomatrix + HTML dashboard"}, {"id": "qa_engineer", "name": "QA Engineer", "emoji": "✅", "description": "Quality Assurance — ISO 9001, KAM, procesvalidatie", "skills": ["ISO 9001", "KAM", "Procesvalidatie", "Kwaliteitscontrole"], "deliverable_note": "DOCX rapport + XLSX checklist + HTML overzicht"}, {"id": "technical_writer", "name": "Technical Writer", "emoji": "📝", "description": "Technische documentatie — procedures, handleidingen, rapporten", "skills": ["Procedures", "Handleidingen", "Technische rapporten"], "deliverable_note": "DOCX procedure + XLSX bijlagen + HTML preview"}, {"id": "environmental_compliance", "name": "Environmental Compliance Manager", "emoji": "🌍", "description": "Milieu & omgeving — emissies, vergunningen, Omgevingswet", "skills": ["Emissies", "Vergunningen", "Omgevingswet", "Milieurapportage"], "deliverable_note": "DOCX rapport + XLSX data + HTML dashboard"}, {"id": "training_generator", "name": "Training Generator", "emoji": "🎓", "description": "Training ontwikkeling — toolbox talks, e-learning, VCA", "skills": ["Toolbox talks", "Training ontwerp", "VCA", "E-learning"], "deliverable_note": "DOCX inhoud + HTML presentatie + HTML quiz"}, {"id": "presentation_specialist", "name": "Presentation Specialist", "emoji": "📊", "description": "Presentaties & document design — PPTX, rapportages", "skills": ["PPTX generatie", "Rapportage design", "Data visualisatie"], "deliverable_note": "DOCX rapport + HTML presentatie + HTML dashboard"}, {"id": "software_architect", "name": "Software Architect", "emoji": "💻", "description": "Software ontwikkeling & systeemarchitectuur", "skills": ["Python", "Flask", "Database design", "API ontwikkeling"], "deliverable_note": "DOCX documentatie + XLSX schema + HTML preview"}, {"id": "project_manager", "name": "Project Manager", "emoji": "📋", "description": "Projectmanagement — planning, resources, voortgang", "skills": ["Planning", "Resource management", "Risicomanagement"], "deliverable_note": "DOCX rapport + XLSX planning + HTML dashboard"}, ] WORKFLOWS = [ {"id": "rie_opstellen", "name": "RI&E Opstellen", "description": "Volledige Risico-Inventarisatie & Evaluatie opstellen", "agents": ["hseq_specialist", "risk_management"], "questions": [ {"id": "company", "label": "Bedrijfsnaam", "type": "text"}, {"id": "sector", "label": "Sector", "type": "select", "options": ["Petrochemie", "Chemie", "Oil & Gas", "Offshore", "Bouw", "Industrie", "Overig"]}, {"id": "employees", "label": "Aantal medewerkers", "type": "select", "options": ["1-10", "11-50", "51-200", "200+"]}, {"id": "activities", "label": "Hoofdactiviteiten", "type": "textarea"}, {"id": "hazardous_substances", "label": "Worden er gevaarlijke stoffen gebruikt?", "type": "select", "options": ["Ja", "Nee", "Onbekend"]}, {"id": "existing_rie", "label": "Is er al een RI&E?", "type": "select", "options": ["Ja, moet geactualiseerd", "Nee, moet nieuw", "Onbekend"]}, ], "output": "RI&E document (DOCX)"}, {"id": "tra_maken", "name": "TRA Maken", "description": "Taakrisicoanalyse opstellen voor specifieke werkzaamheden", "agents": ["hseq_specialist", "qa_engineer"], "questions": [ {"id": "task", "label": "Taak/werkzaamheid", "type": "text"}, {"id": "location", "label": "Locatie", "type": "text"}, {"id": "frequency", "label": "Frequentie", "type": "select", "options": ["Dagelijks", "Wekelijks", "Maandelijks", "Incidenteel"]}, {"id": "hazards", "label": "Bekende gevaren", "type": "textarea"}, {"id": "ppe", "label": "Vereiste PBM", "type": "text"}, ], "output": "TRA document"}, {"id": "training_prep", "name": "Training Prep", "description": "Training voorbereiden met presentatie en quiz", "agents": ["training_generator", "presentation_specialist"], "questions": [ {"id": "topic", "label": "Onderwerp", "type": "text"}, {"id": "target_audience", "label": "Doelgroep", "type": "select", "options": ["Operateurs", "Supervisors", "Management", "Contractors", "Alle medewerkers"]}, {"id": "duration", "label": "Duur", "type": "select", "options": ["30 min", "1 uur", "2 uur", "Halve dag", "Hele dag"]}, {"id": "level", "label": "Niveau", "type": "select", "options": ["Basis", "Gevorderd", "Specialist"]}, ], "output": "PPTX + Quiz"}, {"id": "compliance_check", "name": "Compliance Check", "description": "Uitgebreide compliance check tegen relevante wetgeving", "agents": ["compliance_auditor"], "questions": [ {"id": "company", "label": "Bedrijfsnaam", "type": "text"}, {"id": "regulations", "label": "Relevante wetgeving", "type": "multiselect", "options": ["BRZO", "Seveso", "Arbowet", "Omgevingswet", "PGS", "REACH/CLP", "ISO 45001", "ISO 14001"]}, {"id": "scope", "label": "Scope van de check", "type": "textarea"}, ], "output": "Rapport + aanbevelingen"}, {"id": "audit_prep", "name": "Audit Voorbereiding", "description": "Voorbereiding op interne of externe audit", "agents": ["qa_engineer", "compliance_auditor"], "questions": [ {"id": "audit_type", "label": "Type audit", "type": "select", "options": ["ISO 45001", "ISO 14001", "ISO 9001", "VCA", "ILT inspectie", "BRZO inspectie", "Interne audit"]}, {"id": "scope", "label": "Auditscope", "type": "textarea"}, {"id": "date", "label": "Geplande datum", "type": "text"}, {"id": "previous_findings", "label": "Eerdere bevindingen", "type": "textarea"}, ], "output": "Checklist + voorbereiding"}, {"id": "incident_analyse", "name": "Incident Analyse", "description": "Uitgebreide analyse van een incident met verbetermaatregelen", "agents": ["hseq_specialist"], "questions": [ {"id": "incident_type", "label": "Type incident", "type": "select", "options": ["Lekkage", "Brand/ontploffing", "Blessure", "Milieu-incident", "Near miss", "Bruikbare afwijking"]}, {"id": "description", "label": "Beschrijving van het incident", "type": "textarea"}, {"id": "location", "label": "Locatie", "type": "text"}, {"id": "date", "label": "Datum", "type": "text"}, {"id": "immediate_actions", "label": "Genomen directe maatregelen", "type": "textarea"}, ], "output": "Analyse + verbetermaatregelen"}, ] def register_agent_routes(flask_app, page_func, BASE_PATH="/hseq-dashboard"): @flask_app.route(BASE_PATH + '/agents') def agents_page(): body = '''

🤖 Agent Launchpad

Start gespecialiseerde HSEQ-agents voor complexe taken.

{% for agent in agents %}
{{agent.emoji}}
{{agent.name}}
{{agent.description}}
{% for skill in agent.skills[:3] %} {{skill}} {% endfor %}
{% if agent.deliverable_note %}
📦 {{agent.deliverable_note}}
{% endif %}
{% endfor %}

📋 Workflow Templates

{% for wf in workflows %}
{{wf.name}}
{{wf.description}}
Agents: {{wf.agents|length}} 📦 {{wf.output}}
{% endfor %}

📊 Taak Historie

⏳ Executor status laden...
Laden...
''' return page_func(body, page_title='Agent Launchpad', active='agents', agents=AGENTS, workflows=WORKFLOWS, agents_json=json.dumps(AGENTS), workflows_json=json.dumps(WORKFLOWS)) @flask_app.route(BASE_PATH + '/api/agents') def api_agents_list(): return jsonify({'agents': AGENTS}) @flask_app.route(BASE_PATH + '/api/agents/task', methods=['POST']) def api_agents_task_create(): d = request.get_json() agent_id = d.get('agent_id', '') agent_name = d.get('agent_name', agent_id) task_desc = d.get('task_description', '') context = d.get('context', '') workflow_id = d.get('workflow_id') if not agent_id or not task_desc: return jsonify({'error': 'Agent en taakbeschrijving zijn verplicht'}), 400 kb_context = '' try: results = search_documents(task_desc, limit=5) if results and results.get('results'): for r in results['results'][:3]: kb_context += "\n--- %s ---\n%s\n" % (r.get('title',''), r.get('content','')[:500]) except: pass conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO agent_tasks (agent_id, agent_name, workflow_id, task_description, context, status, metadata) VALUES (?,?,?,?,?,?,?)', (agent_id, agent_name, workflow_id, task_desc, context or kb_context, 'pending', json.dumps({'kb_context': kb_context[:2000], 'submitted_context': context}))) conn.commit() task_id = conn.execute('SELECT last_insert_rowid()').fetchone()[0] conn.close() return jsonify({'ok': True, 'task_id': task_id, 'message': 'Taak gestart voor %s' % agent_name}) @flask_app.route(BASE_PATH + '/api/agents/tasks') def api_agents_tasks_list(): conn = sqlite3.connect(DB_PATH) rows = conn.execute('SELECT id, agent_id, agent_name, workflow_id, task_description, status, created_at, completed_at FROM agent_tasks ORDER BY created_at DESC LIMIT 50').fetchall() conn.close() return jsonify({'tasks': [ {'id':r[0],'agent_id':r[1],'agent_name':r[2],'workflow_id':r[3], 'task_description':r[4],'status':r[5],'created_at':r[6],'completed_at':r[7]} for r in rows]}) @flask_app.route(BASE_PATH + '/api/agents/task/') def api_agents_task_get(task_id): conn = sqlite3.connect(DB_PATH) row = conn.execute('SELECT id, agent_id, agent_name, workflow_id, task_description, context, status, result, created_at, started_at, completed_at, metadata, deliverable_file FROM agent_tasks WHERE id=?', (task_id,)).fetchone() conn.close() if not row: return jsonify({'error': 'Taak niet gevonden'}), 404 return jsonify({'id':row[0],'agent_id':row[1],'agent_name':row[2],'workflow_id':row[3], 'task_description':row[4],'context':row[5],'status':row[6],'result':row[7], 'created_at':row[8],'started_at':row[9],'completed_at':row[10],'metadata':row[11], 'deliverable_file':row[12]}) @flask_app.route(BASE_PATH + '/api/agents/workflows') def api_agents_workflows_list(): return jsonify({'workflows': WORKFLOWS}) @flask_app.route(BASE_PATH + '/api/agents/workflow//run', methods=['POST']) def api_agents_workflow_run(workflow_id): wf = next((w for w in WORKFLOWS if w['id'] == workflow_id), None) if not wf: return jsonify({'error': 'Workflow niet gevonden'}), 404 d = request.get_json() or {} conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO agent_tasks (agent_id, agent_name, workflow_id, task_description, context, status, metadata) VALUES (?,?,?,?,?,?,?)', (wf['agents'][0], wf['name'], workflow_id, wf['name']+': '+json.dumps(d), json.dumps(d), 'pending', json.dumps({'workflow_answers': d}))) conn.commit() task_id = conn.execute('SELECT last_insert_rowid()').fetchone()[0] conn.close() return jsonify({'ok': True, 'task_id': task_id, 'workflow': wf['name']}) @flask_app.route(BASE_PATH + '/api/kb/search') def api_kb_search(): q = request.args.get('q', '').strip() if not q: return jsonify({'results': []}) try: results = search_documents(q, limit=10) items = [] for r in results.get('results', [])[:10]: items.append({'id': r.get('id'), 'title': r.get('title') or r.get('filename', ''), 'category': r.get('category', '')}) return jsonify({'results': items}) except: return jsonify({'results': []})