org_id = (await get_userorgid()) or '0'
user_id = await get_user()
vendor_group_id = params_kw.get('vendor_group_id', '')
source_url = params_kw.get('source_url', '')
asset_type = params_kw.get('asset_type', 'Image')
name = params_kw.get('name', '')

if not vendor_group_id:
    return {"success": False, "message": "请提供供应商组合ID"}
if not source_url:
    return {"success": False, "message": "请提供素材URL"}

result = await rl_create_asset(
    org_id, vendor_group_id, source_url,
    asset_type=asset_type, name=name,
    user_id=user_id
)

return json.dumps({
    "widgettype": "Message",
    "options": {
        "message": f"素材上传已提交: {result.get('vendor_asset_id', '')}" if result.get('success') else result.get('message', '上传失败'),
        "type": "success" if result.get('success') else "error"
    }
})