debug(f'{params_kw=}')
orgid = await get_userorgid()

if not orgid:
    return UiError(
        title='授权错误',
        message='请先登录'
    )

fiids = params_kw.fiids
query = params_kw.query
limit = params_kw.limit

if not query or not fiids or not limit:
    return UiError(
        title='无效输入',
        message='请输入查询文本并选择至少一个知识库'
    )

try:
    env = DictObject(**globals())
    keys = [k for k in env.keys()]
    debug(f'{keys=}')
    result = await rfexe('fusedsearch', request, params_kw)
    debug(f'fusedsearch result: {result}')
    return {
        "widgettype":"MdWidget",
        "options":{
            "width": "100%",
            "mdtext": json.dumps(result, ensure_ascii=False)
        }
    }
except Exception as e:
    return UiError(title='search failed', message=f'召回失败，failed({e})')