org_id = (await get_userorgid()) or '0'
group_id = params_kw.get('group_id', '')

if not group_id:
    return {"success": False, "message": "请选择素材组合"}

result = await rl_sync_assets_from_vendor(org_id, group_id)

return json.dumps({
    "widgettype": "Message",
    "options": {
        "message": f"素材同步完成，共 {result.get('synced', 0)} 条记录",
        "type": "success" if result.get('success') else "error"
    }
})