import json

vendor = params_kw.get('vendor', '')

if not vendor:
    return json.dumps({
        "widgettype": "Message",
        "options": {"message": "请选择供应商", "type": "error"}
    })

org_id = (await get_userorgid()) or '0'
user_id = (await get_user()) or ''
project_name = org_id  # 直接用客户的orgid作为project_name

result = await rl_verify_user(org_id, user_id, vendor, project_name)

if result.get('success'):
    h5_link = result.get('h5_link', '')
    msg = "认证会话已创建，请在新窗口中完成真人认证"
    return json.dumps({
        "widgettype": "Message",
        "options": {"title": "真人认证", "message": msg},
        "subwidgets": [
            {
                "widgettype": "Button",
                "options": {
                    "label": "打开认证页面",
                    "action": {
                        "actiontype": "urlwidget",
                        "target": "NewWindow",
                        "url": h5_link
                    }
                }
            }
        ]
    })
else:
    return json.dumps({
        "widgettype": "Message",
        "options": {"message": result.get('message', '认证创建失败'), "type": "error"}
    })