# human_task_complete.dspy - 处理人类任务（同机构 + 匹配 assignee）

user_id = await get_user()
if not user_id:
    return json.dumps({"success": False, "error": "未登录"}, ensure_ascii=False)

human_task_id = params_kw.get('human_task_id', '').strip()
result_data = params_kw.get('result_data', '')
if isinstance(result_data, str):
    try:
        result_data = json.loads(result_data) if result_data else {}
    except Exception:
        result_data = {"content": result_data}

if not human_task_id:
    return json.dumps({"success": False, "error": "缺少 human_task_id"}, ensure_ascii=False)

ok, msg = await complete_human_task(human_task_id, result_data, operator_id=user_id)
if ok:
    return json.dumps({"success": True, "id": msg}, ensure_ascii=False)
return json.dumps({"success": False, "error": msg}, ensure_ascii=False)