diff --git a/connector-superoffice/README.md b/connector-superoffice/README.md
index ac1b4622..b1918b12 100644
--- a/connector-superoffice/README.md
+++ b/connector-superoffice/README.md
@@ -111,3 +111,23 @@ Der Connector ist der Bote, der diese Daten in das CRM bringt.
Die Prompts für Matrix und Opener liegen in:
* Matrix: `backend/scripts/generate_matrix.py`
* Opener: `backend/services/classification.py` (oder `enrichment.py`)
+
+## Appendix: The "First Sentence" Prompt
+
+This is the core logic used to generate the company-specific opener.
+
+**Goal:** Prove understanding of the business model + imply the pain (positive observation).
+
+```text
+Du bist ein exzellenter B2B-Stratege und Texter mit einem tiefen Verständnis für operative Prozesse.
+Deine Aufgabe ist es, einen hochpersonalisierten, scharfsinnigen und wertschätzenden Einleitungssatz für eine E-Mail an ein potenzielles Kundenunternehmen zu formulieren.
+
+--- Denkprozess & Stilvorgaben ---
+1. **Analysiere den Kontext:** Verstehe das Kerngeschäft. Was ist die kritische, physische Tätigkeit vor Ort? (z.B. 'Betrieb von Hochregallagern', 'Pflege von Patienten').
+2. **Identifiziere den Hebel:** Was ist der Erfolgsfaktor? (z.B. 'reibungslose Abläufe', 'maximale Hygiene').
+3. **Formuliere den Satz (ca. 20-35 Wörter):**
+ - Wähle einen eleganten, aktiven Einstieg wie 'Speziell im Bereich...' oder 'Der reibungslose Betrieb...'.
+ - Verbinde die **spezifische Tätigkeit** mit dem **Hebel** und den **geschäftlichen Konsequenzen**.
+ - **WICHTIG:** Formuliere immer als positive Beobachtung über eine Kernkompetenz. Du implizierst die Herausforderung durch die Betonung der Wichtigkeit.
+ - **VERMEIDE:** Konkrete Zahlen (z.B. "35 Rutschen"), da diese veraltet sein können. Nutze abstrakte Größen ("weitläufige Anlagen").
+```
diff --git a/inspect_sqlite_native.py b/inspect_sqlite_native.py
new file mode 100644
index 00000000..a475c349
--- /dev/null
+++ b/inspect_sqlite_native.py
@@ -0,0 +1,56 @@
+import sqlite3
+import json
+
+DB_PATH = "/app/companies_v3_fixed_2.db"
+
+def inspect(name_part):
+ try:
+ conn = sqlite3.connect(DB_PATH)
+ cursor = conn.cursor()
+
+ print(f"Searching for '{name_part}' in {DB_PATH}...")
+ cursor.execute("SELECT id, name, website, industry_ai, calculated_metric_value, standardized_metric_value FROM companies WHERE name LIKE ?", (f'%{name_part}%',))
+ companies = cursor.fetchall()
+
+ if not companies:
+ print("No hits.")
+ return
+
+ for c in companies:
+ cid, name, website, industry, metric, std_metric = c
+ print("\n" + "="*40)
+ print(f"🏢 {name} (ID: {cid})")
+ print(f" Vertical: {industry}")
+ print(f" Website: {website}")
+ print(f" Metric: {metric} (Std: {std_metric})")
+
+ # Fetch Enrichment Data
+ cursor.execute("SELECT source_type, content FROM enrichment_data WHERE company_id = ?", (cid,))
+ rows = cursor.fetchall()
+ print("\n 📚 Enrichment Data:")
+ for r in rows:
+ stype, content_raw = r
+ print(f" - {stype}")
+ try:
+ content = json.loads(content_raw)
+ if stype == "website_scrape":
+ summary = content.get("summary", "")
+ raw = content.get("raw_text", "")
+ print(f" > Summary: {summary[:150]}...")
+ print(f" > Raw Length: {len(raw)}")
+ if len(raw) > 500:
+ print(f" > Raw Snippet: {raw[:300]}...")
+ elif stype == "wikipedia":
+ print(f" > URL: {content.get('url')}")
+ intro = content.get("intro_text", "") or content.get("full_text", "")
+ print(f" > Intro: {str(intro)[:150]}...")
+ except:
+ print(" > (Content not valid JSON)")
+
+ except Exception as e:
+ print(f"Error: {e}")
+ finally:
+ if conn: conn.close()
+
+if __name__ == "__main__":
+ inspect("Therme Erding")
diff --git a/migrate_opener_native.py b/migrate_opener_native.py
new file mode 100644
index 00000000..1a90e283
--- /dev/null
+++ b/migrate_opener_native.py
@@ -0,0 +1,29 @@
+import sqlite3
+import sys
+
+DB_PATH = "/app/companies_v3_fixed_2.db"
+
+def migrate():
+ try:
+ conn = sqlite3.connect(DB_PATH)
+ cursor = conn.cursor()
+
+ print(f"Checking schema in {DB_PATH}...")
+ cursor.execute("PRAGMA table_info(companies)")
+ columns = [row[1] for row in cursor.fetchall()]
+
+ if "ai_opener" in columns:
+ print("Column 'ai_opener' already exists. Skipping.")
+ else:
+ print("Adding column 'ai_opener' to 'companies' table...")
+ cursor.execute("ALTER TABLE companies ADD COLUMN ai_opener TEXT")
+ conn.commit()
+ print("✅ Migration successful.")
+
+ except Exception as e:
+ print(f"❌ Migration failed: {e}")
+ finally:
+ if conn: conn.close()
+
+if __name__ == "__main__":
+ migrate()
diff --git a/migrate_opener_secondary.py b/migrate_opener_secondary.py
new file mode 100644
index 00000000..90bbd585
--- /dev/null
+++ b/migrate_opener_secondary.py
@@ -0,0 +1,29 @@
+import sqlite3
+import sys
+
+DB_PATH = "/app/companies_v3_fixed_2.db"
+
+def migrate():
+ try:
+ conn = sqlite3.connect(DB_PATH)
+ cursor = conn.cursor()
+
+ print(f"Checking schema in {DB_PATH}...")
+ cursor.execute("PRAGMA table_info(companies)")
+ columns = [row[1] for row in cursor.fetchall()]
+
+ if "ai_opener_secondary" in columns:
+ print("Column 'ai_opener_secondary' already exists. Skipping.")
+ else:
+ print("Adding column 'ai_opener_secondary' to 'companies' table...")
+ cursor.execute("ALTER TABLE companies ADD COLUMN ai_opener_secondary TEXT")
+ conn.commit()
+ print("✅ Migration successful.")
+
+ except Exception as e:
+ print(f"❌ Migration failed: {e}")
+ finally:
+ if conn: conn.close()
+
+if __name__ == "__main__":
+ migrate()