org_id = (await get_userorgid()) or '0'
user_id = await get_user()
vendor = params_kw.get('vendor', '')
callback_url = params_kw.get('callback_url', '')
project_name = params_kw.get('project_name', 'default')

if not vendor:
    return {"success": False, "message": "请选择供应商"}
if not callback_url:
    return {"success": False, "message": "callback_url 不能为空"}

result = await rl_create_validate_session(
    org_id, vendor, callback_url, project_name,
    user_id=user_id
)

return json.dumps({
    "widgettype": "Message",
    "options": {
        "message": f"认证链接已生成: {result.get('h5_link', '')}",
        "type": "success" if result.get('success') else "error"
    }
})