113 lines
3.8 KiB
Python
113 lines
3.8 KiB
Python
# action_item_routes.py
|
||
from flask import Blueprint, request, jsonify
|
||
from flask_jwt_extended import jwt_required
|
||
from datetime import date
|
||
from models import db, User, Meeting, ActionItem
|
||
|
||
action_bp = Blueprint("action_bp", __name__, url_prefix="/api")
|
||
|
||
def _parse_date(s: str | None):
|
||
if not s:
|
||
return None
|
||
try:
|
||
return date.fromisoformat(str(s)[:10])
|
||
except Exception:
|
||
return None
|
||
|
||
def _resolve_owner_id(owner_val: str | None):
|
||
"""把 'owner'(使用者名稱字串) 轉到 ms_users.id，查不到就回 None。"""
|
||
if not owner_val:
|
||
return None
|
||
owner_val = str(owner_val).strip()
|
||
if not owner_val:
|
||
return None
|
||
user = User.query.filter_by(username=owner_val).first()
|
||
return user.id if user else None
|
||
|
||
@action_bp.post("/action-items")
|
||
@jwt_required()
|
||
def create_action_item():
|
||
"""
|
||
建立單筆代辦（會議詳情頁用）
|
||
允許欄位：meeting_id(必) / item(或 context) / action(必) / owner_id or owner(使用者名) / due_date or duedate / status
|
||
"""
|
||
data = request.get_json(force=True) or {}
|
||
meeting_id = data.get("meeting_id")
|
||
if not meeting_id:
|
||
return jsonify({"error": "meeting_id is required"}), 400
|
||
meeting = Meeting.query.get(meeting_id)
|
||
if not meeting:
|
||
return jsonify({"error": "meeting not found"}), 404
|
||
|
||
action_text = (data.get("action") or "").strip()
|
||
if not action_text:
|
||
return jsonify({"error": "action is required"}), 400
|
||
|
||
item_text = (data.get("item") or data.get("context") or "").strip() or None
|
||
owner_id = data.get("owner_id")
|
||
if owner_id is None:
|
||
owner_id = _resolve_owner_id(data.get("owner"))
|
||
due = _parse_date(data.get("due_date") or data.get("duedate"))
|
||
status = (data.get("status") or "pending").strip() or "pending"
|
||
|
||
try:
|
||
ai = ActionItem(
|
||
meeting_id=meeting_id,
|
||
item=item_text,
|
||
action=action_text,
|
||
owner_id=owner_id,
|
||
due_date=due,
|
||
status=status,
|
||
)
|
||
db.session.add(ai)
|
||
db.session.commit()
|
||
return jsonify(ai.to_dict()), 201
|
||
except Exception as e:
|
||
db.session.rollback()
|
||
return jsonify({"error": f"create failed: {e}"}), 400
|
||
|
||
@action_bp.post("/meetings/<int:meeting_id>/action-items/batch")
|
||
@jwt_required()
|
||
def batch_create_action_items(meeting_id: int):
|
||
"""
|
||
批次建立代辦（AI 預覽 → 一鍵儲存）
|
||
Request body: { "items": [ {item/context, action*, owner/owner_id, due_date/duedate}, ... ] }
|
||
"""
|
||
payload = request.get_json(force=True) or {}
|
||
items = payload.get("items") or []
|
||
if not isinstance(items, list) or not items:
|
||
return jsonify({"error": "items must be a non-empty array"}), 400
|
||
|
||
meeting = Meeting.query.get(meeting_id)
|
||
if not meeting:
|
||
return jsonify({"error": "meeting not found"}), 404
|
||
|
||
created = []
|
||
try:
|
||
for r in items:
|
||
action_text = (r.get("action") or "").strip()
|
||
if not action_text:
|
||
continue # 沒有 action 的略過
|
||
|
||
item_text = (r.get("item") or r.get("context") or "").strip() or None
|
||
owner_id = r.get("owner_id")
|
||
if owner_id is None:
|
||
owner_id = _resolve_owner_id(r.get("owner"))
|
||
due = _parse_date(r.get("due_date") or r.get("duedate"))
|
||
|
||
ai = ActionItem(
|
||
meeting_id=meeting_id,
|
||
item=item_text,
|
||
action=action_text,
|
||
owner_id=owner_id,
|
||
due_date=due,
|
||
status="pending",
|
||
)
|
||
db.session.add(ai)
|
||
created.append(ai)
|
||
db.session.commit()
|
||
return jsonify([c.to_dict() for c in created]), 201
|
||
except Exception as e:
|
||
db.session.rollback()
|
||
return jsonify({"error": f"batch create failed: {e}"}), 400
|