tenant_id = (await get_userorgid()) or '0'
task_id = params_kw.get('task_id', '')
step_name = params_kw.get('step_name', '')
reviewer_id = await get_user()
comments = params_kw.get('comments', '')
rollback_to = params_kw.get('rollback_to', None)

if not task_id or not step_name:
    return json.dumps({"success": False, "message": "缺少task_id或step_name"}, ensure_ascii=False)

try:
    result = await approval_reject(tenant_id, task_id, step_name, reviewer_id, comments, rollback_to)
    return result
except Exception as e:
    return json.dumps({"success": False, "message": str(e)}, ensure_ascii=False)