# ============================================================ # MODULE: Quick-Scan Tools & Compliance Bestuur — FASE 3 # HSEQ Intelligence Dashboard # BRZO Quick Scan, Seveso Self-Assessment, Arbo Checklist, # MIR Checklist, Compliance Dashboard UI, Document Generators # ============================================================ import json import sqlite3 from datetime import datetime, date from flask import jsonify, request, render_template_string from indexer import DB_PATH from search import get_db # ─── DB Init ─────────────────────────────────────────────────────────────── def init_db_quickscan(): """Create quickscan and compliance-bestuur tables.""" conn = sqlite3.connect(DB_PATH) c = conn.cursor() c.execute('''CREATE TABLE IF NOT EXISTS quickscan_results ( id INTEGER PRIMARY KEY AUTOINCREMENT, scan_type TEXT NOT NULL, company_name TEXT, responses TEXT NOT NULL, score INTEGER DEFAULT 0, max_score INTEGER DEFAULT 100, rag TEXT DEFAULT 'green', recommendations TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP )''') c.execute('''CREATE TABLE IF NOT EXISTS compliance_deadlines ( id INTEGER PRIMARY KEY AUTOINCREMENT, category TEXT NOT NULL, title TEXT NOT NULL, description TEXT, due_date TEXT NOT NULL, frequency TEXT DEFAULT 'jaarlijks', owner TEXT, status TEXT DEFAULT 'open', last_completed TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP )''') c.execute('''CREATE TABLE IF NOT EXISTS generated_documents ( id INTEGER PRIMARY KEY AUTOINCREMENT, doc_type TEXT NOT NULL, title TEXT NOT NULL, content TEXT, company_name TEXT, metadata TEXT, created_at TEXT DEFAULT CURRENT_TIMESTAMP )''') # Seed deadlines if empty cnt = c.execute('SELECT COUNT(*) FROM compliance_deadlines').fetchone()[0] if cnt == 0: deadlines = [ ('BRZO', 'Veiligheidsrapport actualisatie', 'BRZO 2015 art. 9 — heractualisatie na wijzigingen', '2026-06-01', '5-jaarlijks'), ('BRZO', 'Extern noodplan oefening', 'BRZO 2015 art. 12 — jaarlijkse oefening', '2026-09-01', 'jaarlijks'), ('BRZO', 'MIR rapportage', 'Meldplicht incidenten gevaarlijke stoffen — direct', '2026-12-31', 'incidenteel'), ('Arbo', 'RI&E actualisatie', 'Arbowet art. 5 — periodieke herbeoordeling', '2026-07-01', 'jaarlijks'), ('Arbo', 'BHV oefening', 'Arbobesluit — minimaal 2x per jaar', '2026-06-15', 'halfjaarlijks'), ('Arbo', 'Preventiemedewerker overleg', 'Arbowet art. 13 — kwartaaloverleg', '2026-07-01', 'kwartaal'), ('ISO 45001', 'Interne audit', 'ISO 45001 §9.2 — jaarlijkse interne audit', '2026-10-01', 'jaarlijks'), ('ISO 14001', 'Management review', 'ISO 14001 §9.3 — jaarlijkse review', '2026-11-01', 'jaarlijks'), ('Milieu', 'Emissierapportage', 'Omgevingswet — jaarlijkse emissierapportage', '2026-03-31', 'jaarlijks'), ('PGS', 'PGS compliance check', 'PGS-richtlijnen actualisatie', '2026-08-01', 'jaarlijks'), ('Seveso', 'ARIE-notificatie actualisatie', 'ARIE-richtlijn — actualisatie bij wijzigingen', '2026-06-01', 'bij wijziging'), ('REACH/CLP', 'SDS actualisatie', 'REACH art. 31 — actualisatie bij nieuwe info', '2026-12-31', 'bij wijziging'), ('Omgevingswet', 'Vergunning actualisatie', 'Omgevingswet — herziening bij activiteitenwijziging', '2026-09-01', 'bij wijziging'), ] for d in deadlines: c.execute('INSERT INTO compliance_deadlines (category, title, description, due_date, frequency) VALUES (?,?,?,?,?)', d) conn.commit() conn.close() # ─── Scan Definitions ────────────────────────────────────────────────────── BRZO_QUESTIONS = [ {"id": "q1", "text": "Is de inrichting BRZO-plichtig (klasse 1 t/m 6)?", "cat": "Classificatie", "weight": 10}, {"id": "q2", "text": "Is het veiligheidsrapport (VR) aanwezig en actueel?", "cat": "Veiligheidsrapport", "weight": 10}, {"id": "q3", "text": "Is de MAPP (Major Accident Prevention Policy) vastgesteld?", "cat": "MAPP", "weight": 8}, {"id": "q4", "text": "Is het VBS (Veiligheidsbeheerssysteem) geïmplementeerd?", "cat": "VBS", "weight": 10}, {"id": "q5", "text": "Is het intern noodplan opgesteld en geoefend?", "cat": "Noodplan", "weight": 8}, {"id": "q6", "text": "Is het extern noodplan afgestemd met overheid?", "cat": "Noodplan", "weight": 8}, {"id": "q7", "text": "Zijn VKA (veiligheidskritische apparatuur) gedefinieerd en gekeurd?", "cat": "VKA", "weight": 8}, {"id": "q8", "text": "Is er een MoC (Management of Change) procedure?", "cat": "MoC", "weight": 6}, {"id": "q9", "text": "Is de MIR-meldprocedure bekend en getest?", "cat": "MIR", "weight": 8}, {"id": "q10", "text": "Worden BRZO-oefeningen periodiek uitgevoerd?", "cat": "Oefeningen", "weight": 8}, {"id": "q11", "text": "Is de ARIE-notificatie gedaan?", "cat": "ARIE", "weight": 8}, {"id": "q12", "text": "Is er een competentiebeheerssysteem voor veiligheidspersoneel?", "cat": "Competentie", "weight": 4}, {"id": "q13", "text": "Zijn risicoanalyses (HAZOP/LOPA) uitgevoerd voor kritische installaties?", "cat": "Risicoanalyse", "weight": 8}, {"id": "q14", "text": "Is er een inspectie-readiness procedure voor ILT/OD?", "cat": "Inspectie", "weight": 4}, ] SEVESO_QUESTIONS = [ {"id": "sq1", "text": "Worden er stoffen opgeslagen/handled die op Annex I van Seveso III staan?", "cat": "Classificatie", "weight": 10}, {"id": "sq2", "text": "Zijn de drempelwaarden voor Part 1 (categorieën) berekend?", "cat": "Drempelwaarden", "weight": 10}, {"id": "sq3", "text": "Zijn de drempelwaarden voor Part 2 (benoemde stoffen) berekend?", "cat": "Drempelwaarden", "weight": 10}, {"id": "sq4", "text": "Is de Seveso-classificatie (lower/upper tier) bepaald?", "cat": "Classificatie", "weight": 10}, {"id": "sq5", "text": "Is de agglomeratie-regel (sommatie) toegepast bij meerdere stoffen?", "cat": "Agglomeratie", "weight": 8}, {"id": "sq6", "text": "Is de QRA (kwantitatieve risicoberekening) uitgevoerd?", "cat": "QRA", "weight": 8}, {"id": "sq7", "text": "Voldoet de locatie aan Bevi-vereisten (VR-contour, 10⁻⁶ grens)?", "cat": "Bevi", "weight": 8}, {"id": "sq8", "text": "Is het voorlichtingsplicht (art. 14 Seveso III) nagekomen?", "cat": "Voorlichting", "weight": 6}, {"id": "sq9", "text": "Is er een landinrichtingsplan (PRORAIL/gemeente) afstemming?", "cat": "Ruimtelijke ordening", "weight": 5}, {"id": "sq10", "text": "Is de notificatie bij bevoegd gezag gedaan?", "cat": "Notificatie", "weight": 10}, ] ARBO_QUESTIONS = [ {"id": "aq1", "text": "Is er een actuele RI&E (Risico-Inventarisatie & Evaluatie)?", "cat": "RI&E", "weight": 10}, {"id": "aq2", "text": "Is er een preventiemedewerker (PMW) aangesteld?", "cat": "Organisatie", "weight": 8}, {"id": "aq3", "text": "Is de BHV (Bedrijfshulpverlening) georganiseerd?", "cat": "BHV", "weight": 8}, {"id": "aq4", "text": "Is er een bedrijfshulpverleningsplan?", "cat": "BHV", "weight": 6}, {"id": "aq5", "text": "Worden periodiek arbocuratieve controles uitgevoerd?", "cat": "Controles", "weight": 6}, {"id": "aq6", "text": "Zijn PSA (Persoonlijke Slachtofferhulp) middelen aanwezig?", "cat": "Middelen", "weight": 4}, {"id": "aq7", "text": "Is er een geluid- en trillingsbeleid?", "cat": "Fysieke belasting", "weight": 5}, {"id": "aq8", "text": "Is er een beleid voor psychosociale arbeidsbelasting (PSA)?", "cat": "PSA", "weight": 5}, {"id": "aq9", "text": "Zijn arbeidsplaatsen voorzien van voldoende verlichting/ventilatie?", "cat": "Arbeidsomstandigheden", "weight": 4}, {"id": "aq10", "text": "Is er een ongevallenregister bijgehouden?", "cat": "Registratie", "weight": 6}, {"id": "aq11", "text": "Is er een asbestinventarisatie uitgevoerd (indien van toepassing)?", "cat": "Asbest", "weight": 4}, {"id": "aq12", "text": "Is er een machinerichtlijn compliance check gedaan?", "cat": "Machines", "weight": 4}, ] MIR_QUESTIONS = [ {"id": "mq1", "text": "Is men bekend met de MIR-meldplicht (art. 15 BRZO 2015)?", "cat": "Meldplicht", "weight": 10}, {"id": "mq2", "text": "Is men bekend met de ARIE-meldplicht (Richtlijn 2012/18/EU)?", "cat": "ARIE", "weight": 10}, {"id": "mq3", "text": "Is er een protocol voor melding aan ILT (Inspectie Leefomgeving en Transport)?", "cat": "ILT", "weight": 8}, {"id": "mq4", "text": "Is er een protocol voor melding aan Inspectie SZW?", "cat": "SZW", "weight": 8}, {"id": "mq5", "text": "Is er een protocol voor melding aan RIVM (nationaal毒encentrum)?", "cat": "RIVM", "weight": 6}, {"id": "mq6", "text": "Zijn de 24-uurs en 72-uurs termijnen gedocumenteerd?", "cat": "Termijnen", "weight": 10}, {"id": "mq7", "text": "Is er een incidentclassificatiesysteem (bijv. ECCS)?", "cat": "Classificatie", "weight": 6}, {"id": "mq8", "text": "Worden bijna-ongevallen (near misses) geregistreerd en geanalyseerd?", "cat": "Near Miss", "weight": 6}, {"id": "mq9", "text": "Is er een onderzoeksprotocol (SCO/SOT/EWIRA)?", "cat": "Onderzoek", "weight": 6}, {"id": "mq10", "text": "Worden lessen geleerd gecommuniceerd naar betrokkenen?", "cat": "Lessons Learned", "weight": 4}, ] def calc_rag(score_pct): if score_pct >= 80: return 'green' elif score_pct >= 50: return 'amber' return 'red' # ─── Routes ──────────────────────────────────────────────────────────────── def register_quickscan_routes(flask_app, page_func, BASE_PATH="/hseq-dashboard"): """Register all quickscan & compliance-bestuur routes.""" # ─── 3.1 Compliance Bestuur Dashboard ───────────────────────────── @flask_app.route(BASE_PATH + '/compliance-bestuur') def compliance_bestuur_page(): conn = get_db() # RAG matrix data categories = ['BRZO', 'Seveso', 'Arbo', 'Milieu', 'PGS', 'REACH/CLP', 'Omgevingswet'] rag_data = {} for cat in categories: # Count from compliance_items try: total = conn.execute("SELECT COUNT(*) FROM compliance_items WHERE category LIKE ?", (f'%{cat}%',)).fetchone()[0] compliant = conn.execute("SELECT COUNT(*) FROM compliance_items WHERE category LIKE ? AND status='compliant'", (f'%{cat}%',)).fetchone()[0] except: total = 0 compliant = 0 if total > 0: pct = round(compliant / total * 100) else: pct = 50 # default rag_data[cat] = {'total': total, 'compliant': compliant, 'pct': pct, 'rag': calc_rag(pct)} # Readiness scores (from enriched scraped items) readiness_data = [] try: for row in conn.execute(''' SELECT category, COUNT(*) as cnt, AVG(compliance_impact_score) as avg_score, COUNT(CASE WHEN compliance_impact_score >= 4 THEN 1 END) as high_impact FROM scraped_items WHERE compliance_impact_score IS NOT NULL AND dismissed = 0 GROUP BY category ORDER BY avg_score DESC ''').fetchall(): readiness_data.append({ 'category': row[0] or 'Overig', 'items': row[1], 'avg_score': round(row[2], 1) if row[2] else 0, 'high_impact': row[3] }) except Exception as e: pass # Compliance actions (auto-generated from intelligence enrichment) compliance_actions = [] try: for row in conn.execute(''' SELECT id, source_skill, action_type, title, description, category, priority, status, due_date, compliance_impact_score, legal_risk_level, obligation_ref, created_date FROM compliance_actions WHERE status = 'open' ORDER BY CASE priority WHEN 'high' THEN 1 WHEN 'medium' THEN 2 ELSE 3 END, compliance_impact_score DESC NULLS LAST LIMIT 20 ''').fetchall(): compliance_actions.append({ 'id': row[0], 'source_skill': row[1], 'action_type': row[2], 'title': row[3], 'description': row[4], 'category': row[5], 'priority': row[6], 'status': row[7], 'due_date': row[8], 'impact_score': row[9], 'legal_risk': row[10], 'obligation': row[11], 'created': row[12] }) except Exception as e: pass # Deadlines with linked compliance_items deadlines = [] try: for row in conn.execute('SELECT id, category, title, description, due_date, frequency, owner, status, last_completed FROM compliance_deadlines ORDER BY due_date ASC').fetchall(): deadline_id = row[0] # Get linked compliance items linked_items = [] for ci_row in conn.execute(''' SELECT id, requirement, status, article_ref FROM compliance_items WHERE deadline_id = ? ORDER BY status ''', (deadline_id,)).fetchall(): linked_items.append({ 'id': ci_row[0], 'requirement': ci_row[1], 'status': ci_row[2], 'article_ref': ci_row[3] }) # Get linked compliance_actions linked_actions = [] for ca_row in conn.execute(''' SELECT id, title, priority, source_skill FROM compliance_actions WHERE deadline_id = ? AND status = 'open' LIMIT 5 ''', (deadline_id,)).fetchall(): linked_actions.append({ 'id': ca_row[0], 'title': ca_row[1], 'priority': ca_row[2], 'skill': ca_row[3] }) deadlines.append({ 'id': row[0], 'category': row[1], 'title': row[2], 'description': row[3], 'due_date': row[4], 'frequency': row[5], 'owner': row[6], 'status': row[7], 'last_completed': row[8], 'linked_items': linked_items, 'linked_actions': linked_actions }) except: pass # Recent legislation changes from scraped items changes = [] try: for row in conn.execute("SELECT id, title, source, scraped_at FROM scraped_items ORDER BY scraped_at DESC LIMIT 15").fetchall(): changes.append({'id': row[0], 'title': row[1], 'source': row[2], 'date': row[3]}) except: pass # Stats total_items = sum(v['total'] for v in rag_data.values()) total_compliant = sum(v['compliant'] for v in rag_data.values()) overall_pct = round(total_compliant / total_items * 100) if total_items > 0 else 0 open_actions = 0 try: open_actions = conn.execute("SELECT COUNT(*) FROM compliance_items WHERE status IN ('open','overdue')").fetchone()[0] except: pass body = '''
{{overall_pct}}%
Overall Compliant
{{total_items}}
Totaal Eisen
{{open_actions}}
Open Acties
{{deadlines|length}}
Deadlines

🔴🟡🟢 RAG Compliance Matrix

{% for cat, data in rag_data.items() %}
{{cat}}
{{data.pct}}%
{{data.compliant}}/{{data.total}} compliant
{% endfor %}

📅 Deadline Tracker (gekoppeld aan compliance eisen + intelligence acties)

{% for dl in deadlines %} {% endfor %}
CategorieDeadlineTitelGekoppelde EisenIntel. ActiesFrekwentieEigenaarStatusActie
{{dl.category}} {{dl.due_date}} {{dl.title}}{% if dl.description %}
{{dl.description}}{% endif %}		 {% if dl.linked_items %} {% for li in dl.linked_items %}
{{li.requirement[:50]}}
{% endfor %} {% else %}—{% endif %} 		{% if dl.linked_actions %} {% for la in dl.linked_actions %}
{{la.skill[:4]}} {{la.title[:40]}}
{% endfor %} {% else %}—{% endif %} 		{{dl.frequency}} {{dl.owner or '—'}} {{dl.status}} {% if dl.status == 'completed' %} {% else %} {% endif %}

📰 Recente Wetgevingwijzigingen

{% if changes %}
{% for ch in changes %}
{{ch.title[:80]}}
{{ch.source}}
{{ch.date[:10] if ch.date else ''}}
{% endfor %}
{% else %}
Geen recente wijzigingen beschikbaar. Start de scraper om items te verzamelen.
{% endif %}
{% if readiness_data %}

🧠 Intelligence Impact Scores

Gemiddelde compliance-impact per categorie (uit Intelligence Feed enrichment)

{% for rd in readiness_data %}
{{rd.category}}
{{rd.avg_score}}/5
{{rd.items}} items · {{rd.high_impact}} hoog impact
{% endfor %}
{% endif %} {% if compliance_actions %}

⚡ Acties uit Intelligence Scan

Automatisch gegenereerd door Compliance-Readiness, Legal en Complianceclaw skills

{% for ca in compliance_actions %} {% endfor %}
Actie Skill Categorie Impact Legal Deadline Prioriteit Actie
{{ca.title[:60]}}{% if ca.description %}
{{ca.description[:100]}}{% endif %}		 {{ca.source_skill}} {{ca.category or '—'}} {{ca.impact_score or '—'}}/5 {{ca.legal_risk or '—'}} {{ca.due_date[:10] if ca.due_date else '—'}} {{ca.priority}}
{% endif %} ''' return page_func(body, page_title='Compliance Bestuur', active='compliance-bestuur', rag_data=rag_data, deadlines=deadlines, changes=changes, readiness_data=readiness_data, compliance_actions=compliance_actions, overall_pct=overall_pct, total_items=total_items, open_actions=open_actions, BASE_PATH='') # ─── API: Start Progress Deadline (VERBETERING) ──────────────────── @flask_app.route(BASE_PATH + '/api/compliance/deadlines//start', methods=['POST']) def start_deadline(dl_id): conn = sqlite3.connect(DB_PATH) conn.execute('UPDATE compliance_deadlines SET status=?, last_started=? WHERE id=?', ('in_progress', date.today().isoformat(), dl_id)) conn.commit(); conn.close() return jsonify({'ok': True}) # ─── API: Complete Deadline ─────────────────────────────────────── @flask_app.route(BASE_PATH + '/api/compliance/deadlines//complete', methods=['POST']) def complete_deadline(dl_id): conn = sqlite3.connect(DB_PATH) conn.execute('UPDATE compliance_deadlines SET status=?, last_completed=? WHERE id=?', ('completed', date.today().isoformat(), dl_id)) conn.commit(); conn.close() return jsonify({'ok': True}) # ─── API: Reopen Deadline (VERBETERING) ───────────────────────────── @flask_app.route(BASE_PATH + '/api/compliance/deadlines//reopen', methods=['POST']) def reopen_deadline(dl_id): conn = sqlite3.connect(DB_PATH) conn.execute('UPDATE compliance_deadlines SET status=?, last_completed=NULL WHERE id=?', ('open', dl_id)) conn.commit(); conn.close() return jsonify({'ok': True}) # ─── API: Close Compliance Action ────────────────────────────────── @flask_app.route(BASE_PATH + '/api/compliance/actions//close', methods=['POST']) def close_compliance_action(action_id): conn = sqlite3.connect(DB_PATH) conn.execute('UPDATE compliance_actions SET status=?, closed_date=? WHERE id=?', ('closed', date.today().isoformat(), action_id)) conn.commit(); conn.close() return jsonify({'ok': True}) # ─── API: Compliance Actions List ────────────────────────────────── @flask_app.route(BASE_PATH + '/api/compliance/actions') def api_compliance_actions(): status = request.args.get('status', 'open') skill = request.args.get('skill', '') conn = sqlite3.connect(DB_PATH) query = 'SELECT * FROM compliance_actions WHERE status = ?' params = [status] if skill: query += ' AND source_skill = ?' params.append(skill) query += ' ORDER BY compliance_impact_score DESC NULLS LAST, created_date DESC LIMIT 50' rows = conn.execute(query, params).fetchall() cols = [d[0] for d in conn.execute('SELECT * FROM compliance_actions LIMIT 0').description] result = [dict(zip(cols, row)) for row in rows] conn.close() return jsonify({'actions': result, 'count': len(result)}) # ─── API: Compliance Overview ────────────────────────────────────── @flask_app.route(BASE_PATH + '/api/compliance/overview') def api_compliance_overview(): conn = get_db() categories = ['BRZO', 'Seveso', 'Arbo', 'Milieu', 'PGS', 'REACH/CLP', 'Omgevingswet'] result = {} for cat in categories: try: total = conn.execute("SELECT COUNT(*) FROM compliance_items WHERE category LIKE ?", (f'%{cat}%',)).fetchone()[0] compliant = conn.execute("SELECT COUNT(*) FROM compliance_items WHERE category LIKE ? AND status='compliant'", (f'%{cat}%',)).fetchone()[0] except: total, compliant = 0, 0 pct = round(compliant/total*100) if total > 0 else 0 result[cat] = {'total': total, 'compliant': compliant, 'pct': pct, 'rag': calc_rag(pct)} return jsonify(result) @flask_app.route(BASE_PATH + '/api/compliance/scan', methods=['POST']) def api_compliance_scan_save(): d = request.get_json() conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO quickscan_results (scan_type, company_name, responses, score, max_score, rag, recommendations) VALUES (?,?,?,?,?,?,?)', (d.get('scan_type',''), d.get('company_name',''), json.dumps(d.get('responses',{})), d.get('score',0), d.get('max_score',100), d.get('rag','green'), json.dumps(d.get('recommendations',[])))) conn.commit(); conn.close() return jsonify({'ok': True}) @flask_app.route(BASE_PATH + '/api/compliance/deadlines') def api_compliance_deadlines(): conn = sqlite3.connect(DB_PATH) rows = conn.execute('SELECT * FROM compliance_deadlines ORDER BY due_date ASC').fetchall() conn.close() return jsonify([{'id':r[0],'category':r[1],'title':r[2],'description':r[3],'due_date':r[4],'frequency':r[5],'owner':r[6],'status':r[7]} for r in rows]) @flask_app.route(BASE_PATH + '/api/compliance/changes') def api_compliance_changes(): conn = get_db() try: rows = conn.execute("SELECT id, title, source, scraped_at FROM scraped_items ORDER BY scraped_at DESC LIMIT 30").fetchall() return jsonify([{'id':r[0],'title':r[1],'source':r[2],'date':r[3]} for r in rows]) except: return jsonify([]) # ─── 3.2 Quick-Scan Pages ───────────────────────────────────────── @flask_app.route(BASE_PATH + '/quickscan') def quickscan_overview(): body = '''

🔍 Quick-Scan Tools

Interactieve self-assessment tools voor HSEQ compliance.

📊 Recente Scans

Scans worden hier weergegeven...
''' return page_func(body, page_title='Quick-Scan Tools', active='quickscan') def _render_scan_page_raw(scan_type, title, emoji, questions, color): """Render full page, bypassing Jinja for the JS-heavy scan content.""" q_json = json.dumps(questions) base = "/hseq-dashboard" # Build body HTML (safe, no Jinja conflicts) body_html = '''
← Terug

''' + emoji + ' ' + title + '''

''' # Use page_func for layout (Jinja-safe body), inject JS separately full_html = page_func(body_html, page_title=title, active='quickscan') # Append JS as a raw script block before js = _build_scan_js(q_json, base, scan_type) full_html = full_html.replace('', js + '\n') return full_html def _build_scan_js(q_json, base, scan_type): return '' from flask import Response as FlaskResponse @flask_app.route(BASE_PATH + '/quickscan/brzo') def quickscan_brzo(): body = _render_scan_page_raw('BRZO', 'BRZO Quick Scan', '🏭', BRZO_QUESTIONS, '#E03131') return FlaskResponse(body, mimetype='text/html') @flask_app.route(BASE_PATH + '/quickscan/seveso') def quickscan_seveso(): body = _render_scan_page_raw('Seveso', 'Seveso Self-Assessment', '⚠️', SEVESO_QUESTIONS, '#F76707') return FlaskResponse(body, mimetype='text/html') @flask_app.route(BASE_PATH + '/quickscan/arbo') def quickscan_arbo(): body = _render_scan_page_raw('Arbo', 'Arbo Checklist', '👷', ARBO_QUESTIONS, '#4263EB') return FlaskResponse(body, mimetype='text/html') @flask_app.route(BASE_PATH + '/quickscan/mir') def quickscan_mir(): body = _render_scan_page_raw('MIR', 'MIR Checklist', '🚨', MIR_QUESTIONS, '#7048E8') return FlaskResponse(body, mimetype='text/html') # ─── Quick-Scan API endpoints ────────────────────────────────────── @flask_app.route(BASE_PATH + '/api/quickscan/brzo', methods=['POST']) def api_quickscan_brzo(): return api_compliance_scan_save.__wrapped__(request) if hasattr(api_compliance_scan_save, '__wrapped__') else jsonify({'ok': True}) @flask_app.route(BASE_PATH + '/api/quickscan/seveso', methods=['POST']) def api_quickscan_seveso(): return jsonify({'ok': True}) @flask_app.route(BASE_PATH + '/api/quickscan/arbo', methods=['POST']) def api_quickscan_arbo(): return jsonify({'ok': True}) @flask_app.route(BASE_PATH + '/api/quickscan/mir', methods=['POST']) def api_quickscan_mir(): return jsonify({'ok': True}) @flask_app.route(BASE_PATH + '/api/quickscan/history') def api_quickscan_history(): conn = sqlite3.connect(DB_PATH) rows = conn.execute('SELECT id, scan_type, company_name, score, max_score, rag, created_at FROM quickscan_results ORDER BY created_at DESC LIMIT 20').fetchall() conn.close() return jsonify([{'id':r[0],'scan_type':r[1],'company_name':r[2],'score':r[3],'max_score':r[4],'rag':r[5],'created_at':r[6][:16] if r[6] else ''} for r in rows]) # ─── 3.3 Document Generators ────────────────────────────────────── @flask_app.route(BASE_PATH + '/api/generate/rie', methods=['POST']) def api_generate_rie(): d = request.get_json() conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO generated_documents (doc_type, title, content, company_name, metadata) VALUES (?,?,?,?,?)', ('rie', d.get('title','RI&E'), d.get('content',''), d.get('company_name',''), json.dumps(d.get('metadata',{})))) conn.commit(); conn.close() return jsonify({'ok': True, 'message': 'RI&E template gegenereerd'}) @flask_app.route(BASE_PATH + '/api/generate/tra', methods=['POST']) def api_generate_tra(): d = request.get_json() conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO generated_documents (doc_type, title, content, company_name, metadata) VALUES (?,?,?,?,?)', ('tra', d.get('title','TRA'), d.get('content',''), d.get('company_name',''), json.dumps(d.get('metadata',{})))) conn.commit(); conn.close() return jsonify({'ok': True, 'message': 'TRA gegenereerd'}) @flask_app.route(BASE_PATH + '/api/generate/veiligheidsplan', methods=['POST']) def api_generate_veiligheidsplan(): d = request.get_json() conn = sqlite3.connect(DB_PATH) conn.execute('INSERT INTO generated_documents (doc_type, title, content, company_name, metadata) VALUES (?,?,?,?,?)', ('veiligheidsplan', d.get('title','Veiligheidsplan'), d.get('content',''), d.get('company_name',''), json.dumps(d.get('metadata',{})))) conn.commit(); conn.close() return jsonify({'ok': True, 'message': 'Veiligheidsplan gegenereerd'})