22 lines
851 B
Plaintext
22 lines
851 B
Plaintext
# 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)
|