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

if not asset_id:
    return {"success": False, "message": "asset_id 不能为空"}

result = await rl_sync_asset_status(asset_id)

return json.dumps({
    "widgettype": "Message",
    "options": {
        "message": f"状态同步完成: {result.get('status', '')}" if result.get('success') else result.get('message', '同步失败'),
        "type": "success" if result.get('success') else "error"
    }
})