Server+Client: REST-API für Kontaktadresse und CallLog, In-Memory vollständig entfernt, CLI-Musterdaten, Route-Param-Fix
- Server: ORM-Modelle Kontaktadresse (kontaktadressen) und CallLog (call_logs) mit FK projekt_id - Server: Geschäftslogik kontaktadresse.py und call_log.py (get/create/update/delete) - Server: DB-Migration V01_03 (kontaktadressen + call_logs Tabellen) - Server: REST-Endpunkte /xhr/kontaktadresse/* und /xhr/calllog/* mit Autorisierung - Server: CLI init-db legt Muster-Kontaktadressen (1-3/Projekt) und Muster-Gesprächsnotizen (2-5/Projekt) an - Client: kontaktadresse.ts auf REST umgestellt, snake_case, In-Memory entfernt - Client: call_log.ts auf REST umgestellt, snake_case, In-Memory entfernt, Submit-Handler implementiert - Client: projekt.ts In-Memory vollständig entfernt (keine weiteren Verbraucher) - Client: Route-Params projektId → projekt_id korrigiert (3 Stellen in projekt.ts) - Client: addCallLog in projekt.ts Route-Params auf snake_case angepasst - AGENTS.md: Erinnerung client-build-Skill nach .ts-Änderungen hinzugefügt Generated by Mistral Vibe. Co-Authored-By: Mistral Vibe <vibe@mistral.ai>
This commit is contained in:
gg committed
1 parent
e04a52857a
commit
b510c50497
13 files changed
+821
-503
No files matched your search
@@ -12,7 +12,7 @@ erfolgt ausschließlich über __bind_key__.
|
||||
import datetime
|
||||
import decimal
|
||||
|
||||
from sqlalchemy import Column, DateTime, ForeignKey, Integer, String
|
||||
from sqlalchemy import Boolean, Column, DateTime, ForeignKey, Integer, String
|
||||
from sqlalchemy.orm import relationship
|
||||
|
||||
from db import dbapp
|
||||
@@ -154,4 +154,79 @@ class Projekt(dbapp.Model):
|
||||
return result
|
||||
|
||||
|
||||
class Kontaktadresse(dbapp.Model):
|
||||
"""
|
||||
Akquise-Ziel innerhalb eines Projekts. Jede Kontaktadresse ist genau
|
||||
einem Projekt zugeordnet (projekt_id). Der Projektname (projekt_name)
|
||||
ist keine eigene Spalte, sondern wird über die Relationship zu Projekt
|
||||
abgeleitet und nur in to_dict() für die JSON-Serialisierung ergänzt.
|
||||
"""
|
||||
__tablename__ = 'kontaktadressen'
|
||||
__bind_key__ = BINDKEY
|
||||
id = Column(Integer, primary_key=True)
|
||||
projekt_id = Column(Integer, ForeignKey('projekte.id'), nullable=False)
|
||||
anrede = Column(String(30), nullable=True)
|
||||
name = Column(String(200), nullable=False)
|
||||
firma = Column(String(200), nullable=True)
|
||||
telefon = Column(String(100), nullable=True)
|
||||
email = Column(String(200), nullable=True)
|
||||
strasse = Column(String(200), nullable=True)
|
||||
plz = Column(String(20), nullable=True)
|
||||
ort = Column(String(100), nullable=True)
|
||||
land = Column(String(80), nullable=True)
|
||||
notiz = Column(String(2000), nullable=True)
|
||||
|
||||
projekt = relationship('Projekt')
|
||||
|
||||
def to_dict(self):
|
||||
"""
|
||||
Liefert die Kontaktdaten als Dictionary. Die Tabellenspalten werden
|
||||
über columns2dict serialisiert; projekt_name wird zusätzlich aus der
|
||||
Projekt-Relationship eingefügt.
|
||||
"""
|
||||
result = columns2dict(self)
|
||||
result['projekt_name'] = self.projekt.projektname if self.projekt else None
|
||||
return result
|
||||
|
||||
|
||||
class CallLog(dbapp.Model):
|
||||
"""
|
||||
Gesprächsnotiz für ein Projekt. Jede Gesprächsnotiz ist genau einem
|
||||
Projekt zugeordnet (projekt_id). Der Projektname (projekt_name) und
|
||||
der Kundenname (kunden_name) sind keine eigenen Spalten, sondern
|
||||
werden über die Projekt-Relationship abgeleitet und nur in to_dict()
|
||||
für die JSON-Serialisierung ergänzt.
|
||||
"""
|
||||
__tablename__ = 'call_logs'
|
||||
__bind_key__ = BINDKEY
|
||||
id = Column(Integer, primary_key=True)
|
||||
projekt_id = Column(Integer, ForeignKey('projekte.id'), nullable=False)
|
||||
datum = Column(String(20), nullable=True)
|
||||
uhrzeit_beginn = Column(String(10), nullable=True)
|
||||
dauer = Column(String(10), nullable=True)
|
||||
betreff = Column(String(200), nullable=True)
|
||||
name_ansprechpartner = Column(String(200), nullable=True)
|
||||
telefon = Column(String(100), nullable=True)
|
||||
notiz = Column(String(2000), nullable=True)
|
||||
wiedervorlage_datum = Column(String(20), nullable=True)
|
||||
erledigt = Column(Boolean, nullable=False, default=False)
|
||||
|
||||
projekt = relationship('Projekt')
|
||||
|
||||
def to_dict(self):
|
||||
"""
|
||||
Liefert die Gesprächsnotiz als Dictionary. Die Tabellenspalten werden
|
||||
über columns2dict serialisiert; projekt_name und kunden_name werden
|
||||
zusätzlich aus der Projekt-Relationship eingefügt.
|
||||
"""
|
||||
result = columns2dict(self)
|
||||
if self.projekt:
|
||||
result['projekt_name'] = self.projekt.projektname
|
||||
result['kunden_name'] = self.projekt.kunde.name if self.projekt.kunde else None
|
||||
else:
|
||||
result['projekt_name'] = None
|
||||
result['kunden_name'] = None
|
||||
return result
|
||||
|
||||
|
||||
print("########## crm/model importiert")
|
||||
@@ -0,0 +1,117 @@
|
||||
"""
|
||||
Geschäftslogik für die Entität CallLog (Gesprächsnotiz).
|
||||
|
||||
Diese Funktionen kapseln den DB-Zugriff und die fachlichen Validierungen.
|
||||
Aufgerufen werden sie aus crm/routes.py; die Autorisierungsprüfung erfolgt
|
||||
dort über den Decorator authorisation_required.
|
||||
|
||||
:author: Mistral Vibe <vibe@mistral.ai>
|
||||
:date: 2026-09-04
|
||||
:version: 1.0
|
||||
"""
|
||||
from db import dbapp
|
||||
from crm.model import CallLog, Projekt
|
||||
|
||||
from auth.model.errors import ApplicationError, HtmlStatusCode
|
||||
|
||||
session = dbapp.session
|
||||
|
||||
|
||||
def get_call_logs():
|
||||
"""
|
||||
Liefert alle Gesprächsnotizen, sortiert nach Datum absteigend.
|
||||
"""
|
||||
return CallLog.query.order_by(CallLog.datum.desc()).all()
|
||||
|
||||
|
||||
def get_call_log(call_log_id: int) -> CallLog:
|
||||
"""
|
||||
Liefert eine einzelne Gesprächsnotiz anhand ihrer ID.
|
||||
Wirft ApplicationError (404), falls die Notiz nicht existiert.
|
||||
"""
|
||||
call_log = CallLog.query.get(call_log_id)
|
||||
if call_log is None:
|
||||
raise ApplicationError(
|
||||
"Gesprächsnotiz mit der ID {} wurde nicht gefunden.".format(call_log_id),
|
||||
htmlstatus=HtmlStatusCode.Not_Found,
|
||||
)
|
||||
return call_log
|
||||
|
||||
|
||||
def create_call_log(data: dict) -> CallLog:
|
||||
"""
|
||||
Legt eine neue Gesprächsnotiz an. Die vom Client übergebene ID wird
|
||||
ignoriert; die ID wird serverseitig per Auto-Increment vergeben.
|
||||
|
||||
- data: dict mit den Feldern projekt_id, datum, uhrzeit_beginn, dauer,
|
||||
betreff, name_ansprechpartner, telefon, notiz,
|
||||
wiedervorlage_datum, erledigt
|
||||
"""
|
||||
projekt_id = data.get("projekt_id")
|
||||
if projekt_id is None:
|
||||
raise ApplicationError(
|
||||
"Es muss ein Projekt ausgewählt werden.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
projekt = Projekt.query.get(int(projekt_id))
|
||||
if projekt is None:
|
||||
raise ApplicationError(
|
||||
"Das ausgewählte Projekt existiert nicht.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
call_log = CallLog()
|
||||
call_log.projekt_id = int(projekt_id)
|
||||
call_log.datum = (data.get("datum") or "").strip() or None
|
||||
call_log.uhrzeit_beginn = (data.get("uhrzeit_beginn") or "").strip() or None
|
||||
call_log.dauer = (data.get("dauer") or "").strip() or None
|
||||
call_log.betreff = (data.get("betreff") or "").strip() or None
|
||||
call_log.name_ansprechpartner = (data.get("name_ansprechpartner") or "").strip() or None
|
||||
call_log.telefon = (data.get("telefon") or "").strip() or None
|
||||
call_log.notiz = (data.get("notiz") or "").strip() or None
|
||||
call_log.wiedervorlage_datum = (data.get("wiedervorlage_datum") or "").strip() or None
|
||||
call_log.erledigt = bool(data.get("erledigt", False))
|
||||
session.add(call_log)
|
||||
session.commit()
|
||||
return call_log
|
||||
|
||||
|
||||
def update_call_log(data: dict) -> CallLog:
|
||||
"""
|
||||
Aktualisiert eine bestehende Gesprächsnotiz. Die ID im data-Dict
|
||||
bestimmt den zu ändernden Datensatz.
|
||||
"""
|
||||
call_log = get_call_log(data["id"])
|
||||
projekt_id = data.get("projekt_id")
|
||||
if projekt_id is None:
|
||||
raise ApplicationError(
|
||||
"Es muss ein Projekt ausgewählt werden.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
projekt = Projekt.query.get(int(projekt_id))
|
||||
if projekt is None:
|
||||
raise ApplicationError(
|
||||
"Das ausgewählte Projekt existiert nicht.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
call_log.projekt_id = int(projekt_id)
|
||||
call_log.datum = (data.get("datum") or "").strip() or None
|
||||
call_log.uhrzeit_beginn = (data.get("uhrzeit_beginn") or "").strip() or None
|
||||
call_log.dauer = (data.get("dauer") or "").strip() or None
|
||||
call_log.betreff = (data.get("betreff") or "").strip() or None
|
||||
call_log.name_ansprechpartner = (data.get("name_ansprechpartner") or "").strip() or None
|
||||
call_log.telefon = (data.get("telefon") or "").strip() or None
|
||||
call_log.notiz = (data.get("notiz") or "").strip() or None
|
||||
call_log.wiedervorlage_datum = (data.get("wiedervorlage_datum") or "").strip() or None
|
||||
call_log.erledigt = bool(data.get("erledigt", False))
|
||||
session.commit()
|
||||
return call_log
|
||||
|
||||
|
||||
def delete_call_log(call_log_id: int):
|
||||
"""
|
||||
Löscht eine Gesprächsnotiz anhand ihrer ID.
|
||||
Wirft ApplicationError (404), falls die Notiz nicht existiert.
|
||||
"""
|
||||
call_log = get_call_log(call_log_id)
|
||||
session.delete(call_log)
|
||||
session.commit()
|
||||
@@ -67,6 +67,17 @@ def _db_V01_02():
|
||||
session.commit()
|
||||
|
||||
|
||||
def _db_V01_03():
|
||||
"""
|
||||
Legt die Tabellen 'kontaktadressen' und 'call_logs' an. Bei bestehenden
|
||||
Datenbanken, die mit Version 01.02 initialisiert wurden, fehlen diese
|
||||
Tabellen, da die Modelle erst nachträglich ergänzt wurden.
|
||||
"""
|
||||
dbapp.create_all(bind_key=BINDKEY)
|
||||
_updatesysteminfo('01.03')
|
||||
session.commit()
|
||||
|
||||
|
||||
def checkupdates():
|
||||
"""
|
||||
Ermittelt die aktuelle DB-Version aus der Systeminfo-Tabelle und führt alle
|
||||
|
||||
@@ -0,0 +1,128 @@
|
||||
"""
|
||||
Geschäftslogik für die Entität Kontaktadresse.
|
||||
|
||||
Diese Funktionen kapseln den DB-Zugriff und die fachlichen Validierungen.
|
||||
Aufgerufen werden sie aus crm/routes.py; die Autorisierungsprüfung erfolgt
|
||||
dort über den Decorator authorisation_required.
|
||||
|
||||
:author: Mistral Vibe <vibe@mistral.ai>
|
||||
:date: 2026-09-04
|
||||
:version: 1.0
|
||||
"""
|
||||
from db import dbapp
|
||||
from crm.model import Kontaktadresse, Projekt
|
||||
|
||||
from auth.model.errors import ApplicationError, HtmlStatusCode
|
||||
|
||||
session = dbapp.session
|
||||
|
||||
|
||||
def get_kontaktadressen():
|
||||
"""
|
||||
Liefert alle Kontaktadressen, sortiert nach Name.
|
||||
"""
|
||||
return Kontaktadresse.query.order_by(Kontaktadresse.name).all()
|
||||
|
||||
|
||||
def get_kontaktadresse(kontaktadresse_id: int) -> Kontaktadresse:
|
||||
"""
|
||||
Liefert eine einzelne Kontaktadresse anhand ihrer ID.
|
||||
Wirft ApplicationError (404), falls die Kontaktadresse nicht existiert.
|
||||
"""
|
||||
kontaktadresse = Kontaktadresse.query.get(kontaktadresse_id)
|
||||
if kontaktadresse is None:
|
||||
raise ApplicationError(
|
||||
"Kontaktadresse mit der ID {} wurde nicht gefunden.".format(kontaktadresse_id),
|
||||
htmlstatus=HtmlStatusCode.Not_Found,
|
||||
)
|
||||
return kontaktadresse
|
||||
|
||||
|
||||
def create_kontaktadresse(data: dict) -> Kontaktadresse:
|
||||
"""
|
||||
Legt eine neue Kontaktadresse an. Die vom Client übergebene ID wird
|
||||
ignoriert; die ID wird serverseitig per Auto-Increment vergeben.
|
||||
|
||||
- data: dict mit den Feldern projekt_id, anrede, name, firma, telefon,
|
||||
email, strasse, plz, ort, land, notiz
|
||||
"""
|
||||
projekt_id = data.get("projekt_id")
|
||||
if projekt_id is None:
|
||||
raise ApplicationError(
|
||||
"Es muss ein Projekt ausgewählt werden.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
projekt = Projekt.query.get(int(projekt_id))
|
||||
if projekt is None:
|
||||
raise ApplicationError(
|
||||
"Das ausgewählte Projekt existiert nicht.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
if not data.get("name") or not str(data["name"]).strip():
|
||||
raise ApplicationError(
|
||||
"Der Name darf nicht leer sein.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
kontaktadresse = Kontaktadresse()
|
||||
kontaktadresse.projekt_id = int(projekt_id)
|
||||
kontaktadresse.anrede = (data.get("anrede") or "").strip() or None
|
||||
kontaktadresse.name = data["name"].strip()
|
||||
kontaktadresse.firma = (data.get("firma") or "").strip() or None
|
||||
kontaktadresse.telefon = (data.get("telefon") or "").strip() or None
|
||||
kontaktadresse.email = (data.get("email") or "").strip() or None
|
||||
kontaktadresse.strasse = (data.get("strasse") or "").strip() or None
|
||||
kontaktadresse.plz = (data.get("plz") or "").strip() or None
|
||||
kontaktadresse.ort = (data.get("ort") or "").strip() or None
|
||||
kontaktadresse.land = (data.get("land") or "").strip() or None
|
||||
kontaktadresse.notiz = (data.get("notiz") or "").strip() or None
|
||||
session.add(kontaktadresse)
|
||||
session.commit()
|
||||
return kontaktadresse
|
||||
|
||||
|
||||
def update_kontaktadresse(data: dict) -> Kontaktadresse:
|
||||
"""
|
||||
Aktualisiert eine bestehende Kontaktadresse. Die ID im data-Dict
|
||||
bestimmt den zu ändernden Datensatz.
|
||||
"""
|
||||
kontaktadresse = get_kontaktadresse(data["id"])
|
||||
projekt_id = data.get("projekt_id")
|
||||
if projekt_id is None:
|
||||
raise ApplicationError(
|
||||
"Es muss ein Projekt ausgewählt werden.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
projekt = Projekt.query.get(int(projekt_id))
|
||||
if projekt is None:
|
||||
raise ApplicationError(
|
||||
"Das ausgewählte Projekt existiert nicht.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
if not data.get("name") or not str(data["name"]).strip():
|
||||
raise ApplicationError(
|
||||
"Der Name darf nicht leer sein.",
|
||||
htmlstatus=HtmlStatusCode.Bad_Request,
|
||||
)
|
||||
kontaktadresse.projekt_id = int(projekt_id)
|
||||
kontaktadresse.anrede = (data.get("anrede") or "").strip() or None
|
||||
kontaktadresse.name = data["name"].strip()
|
||||
kontaktadresse.firma = (data.get("firma") or "").strip() or None
|
||||
kontaktadresse.telefon = (data.get("telefon") or "").strip() or None
|
||||
kontaktadresse.email = (data.get("email") or "").strip() or None
|
||||
kontaktadresse.strasse = (data.get("strasse") or "").strip() or None
|
||||
kontaktadresse.plz = (data.get("plz") or "").strip() or None
|
||||
kontaktadresse.ort = (data.get("ort") or "").strip() or None
|
||||
kontaktadresse.land = (data.get("land") or "").strip() or None
|
||||
kontaktadresse.notiz = (data.get("notiz") or "").strip() or None
|
||||
session.commit()
|
||||
return kontaktadresse
|
||||
|
||||
|
||||
def delete_kontaktadresse(kontaktadresse_id: int):
|
||||
"""
|
||||
Löscht eine Kontaktadresse anhand ihrer ID.
|
||||
Wirft ApplicationError (404), falls die Kontaktadresse nicht existiert.
|
||||
"""
|
||||
kontaktadresse = get_kontaktadresse(kontaktadresse_id)
|
||||
session.delete(kontaktadresse)
|
||||
session.commit()
|
||||
@@ -21,6 +21,8 @@ from crm.model import KUNDEN_MANAGER, MITARBEITER
|
||||
from crm.model import kunde as kunden
|
||||
from crm.model import kontakt as kontakte
|
||||
from crm.model import projekt as projekte
|
||||
from crm.model import kontaktadresse as kontaktadressen
|
||||
from crm.model import call_log as call_logs
|
||||
|
||||
print("crm-routes")
|
||||
|
||||
@@ -160,4 +162,94 @@ def projekt_delete():
|
||||
return jsonify({}), 200
|
||||
|
||||
|
||||
# --------------------------------------------------------------------------- #
|
||||
# Kontaktadresse #
|
||||
# --------------------------------------------------------------------------- #
|
||||
|
||||
|
||||
@app.get("/xhr/kontaktadresse/list")
|
||||
@authorisation_required([MITARBEITER, KUNDEN_MANAGER])
|
||||
def kontaktadresse_list():
|
||||
"""Liefert alle Kontaktadressen als Liste."""
|
||||
result = [k.to_dict() for k in kontaktadressen.get_kontaktadressen()]
|
||||
return jsonify(result), 200
|
||||
|
||||
|
||||
@app.get("/xhr/kontaktadresse/get")
|
||||
@authorisation_required([MITARBEITER, KUNDEN_MANAGER])
|
||||
def kontaktadresse_get():
|
||||
"""Liefert eine einzelne Kontaktadresse anhand ihrer ID (Query-Param id)."""
|
||||
kontaktadresse = kontaktadressen.get_kontaktadresse(int(request.args.get("id")))
|
||||
return jsonify(kontaktadresse.to_dict()), 200
|
||||
|
||||
|
||||
@app.post("/xhr/kontaktadresse/create")
|
||||
@authorisation_required([KUNDEN_MANAGER])
|
||||
def kontaktadresse_create():
|
||||
"""Legt eine neue Kontaktadresse an. ID wird serverseitig vergeben."""
|
||||
kontaktadresse = kontaktadressen.create_kontaktadresse(request.json)
|
||||
return jsonify(kontaktadresse.to_dict()), 200
|
||||
|
||||
|
||||
@app.put("/xhr/kontaktadresse/update")
|
||||
@authorisation_required([KUNDEN_MANAGER])
|
||||
def kontaktadresse_update():
|
||||
"""Aktualisiert eine bestehende Kontaktadresse."""
|
||||
kontaktadresse = kontaktadressen.update_kontaktadresse(request.json)
|
||||
return jsonify(kontaktadresse.to_dict()), 200
|
||||
|
||||
|
||||
@app.delete("/xhr/kontaktadresse/delete")
|
||||
@authorisation_required([KUNDEN_MANAGER])
|
||||
def kontaktadresse_delete():
|
||||
"""Löscht eine Kontaktadresse anhand ihrer ID (Query-Param id)."""
|
||||
kontaktadressen.delete_kontaktadresse(int(request.args.get("id")))
|
||||
return jsonify({}), 200
|
||||
|
||||
|
||||
# --------------------------------------------------------------------------- #
|
||||
# CallLog (Gesprächsnotiz) #
|
||||
# --------------------------------------------------------------------------- #
|
||||
|
||||
|
||||
@app.get("/xhr/calllog/list")
|
||||
@authorisation_required([MITARBEITER, KUNDEN_MANAGER])
|
||||
def calllog_list():
|
||||
"""Liefert alle Gesprächsnotizen als Liste."""
|
||||
result = [l.to_dict() for l in call_logs.get_call_logs()]
|
||||
return jsonify(result), 200
|
||||
|
||||
|
||||
@app.get("/xhr/calllog/get")
|
||||
@authorisation_required([MITARBEITER, KUNDEN_MANAGER])
|
||||
def calllog_get():
|
||||
"""Liefert eine einzelne Gesprächsnotiz anhand ihrer ID (Query-Param id)."""
|
||||
call_log = call_logs.get_call_log(int(request.args.get("id")))
|
||||
return jsonify(call_log.to_dict()), 200
|
||||
|
||||
|
||||
@app.post("/xhr/calllog/create")
|
||||
@authorisation_required([KUNDEN_MANAGER])
|
||||
def calllog_create():
|
||||
"""Legt eine neue Gesprächsnotiz an. ID wird serverseitig vergeben."""
|
||||
call_log = call_logs.create_call_log(request.json)
|
||||
return jsonify(call_log.to_dict()), 200
|
||||
|
||||
|
||||
@app.put("/xhr/calllog/update")
|
||||
@authorisation_required([KUNDEN_MANAGER])
|
||||
def calllog_update():
|
||||
"""Aktualisiert eine bestehende Gesprächsnotiz."""
|
||||
call_log = call_logs.update_call_log(request.json)
|
||||
return jsonify(call_log.to_dict()), 200
|
||||
|
||||
|
||||
@app.delete("/xhr/calllog/delete")
|
||||
@authorisation_required([KUNDEN_MANAGER])
|
||||
def calllog_delete():
|
||||
"""Löscht eine Gesprächsnotiz anhand ihrer ID (Query-Param id)."""
|
||||
call_logs.delete_call_log(int(request.args.get("id")))
|
||||
return jsonify({}), 200
|
||||
|
||||
|
||||
print("########## crm.routes importiert")
|
||||
Reference in new issue
Block a user