result = {'widgettype': 'Error', 'options': {'title': 'Error', 'message': '', 'timeout': 3}}

try:
    source_upappid = params_kw.get('source_upappid', '')
    target_upappid = params_kw.get('target_upappid', '')

    if not source_upappid:
        raise Exception('请选择源上位系统')
    if not target_upappid:
        raise Exception('请选择目标上位系统')
    if source_upappid == target_upappid:
        raise Exception('源和目标上位系统不能相同')

    db = DBPools()
    dbname = get_module_dbname('uapi')
    async with db.sqlorContext(dbname) as sor:
        sql = 'select * from uapi where upappid = ${upappid}$'
        source_uapis = await sor.sqlExe(sql, {'upappid': source_upappid})

        if not source_uapis:
            raise Exception('源上位系统中没有API记录')

        existing_recs = await sor.sqlExe(sql, {'upappid': target_upappid})
        existing_names = {r['name'] for r in existing_recs}

        copied = 0
        skipped = 0
        for api in source_uapis:
            if api['name'] in existing_names:
                skipped += 1
                continue

            new_id = getID()
            await sor.C('uapi', {
                'id': new_id,
                'upappid': target_upappid,
                'name': api.get('name', ''),
                'title': api.get('title', ''),
                'description': api.get('description', ''),
                'need_auth': api.get('need_auth', '0'),
                'stream': api.get('stream', ''),
                'path': api.get('path', ''),
                'httpmethod': api.get('httpmethod', 'GET'),
                'chunk_match': api.get('chunk_match', ''),
                'headers': api.get('headers', ''),
                'params': api.get('params', ''),
                'data': api.get('data', ''),
                'response': api.get('response', ''),
                'ioid': api.get('ioid', ''),
                'callbackurl': api.get('callbackurl', '')
            })
            copied += 1

    msg = f'成功复制 {copied} 条API记录'
    if skipped > 0:
        msg += f'，跳过 {skipped} 条（API名称已存在）'

    result = {'widgettype': 'Message', 'options': {'title': '复制完成', 'message': msg, 'timeout': 3, 'type': 'success'}}

except Exception as e:
    debug(f'copy_uapi error: {format_exc()}')
    result = {'widgettype': 'Error', 'options': {'title': '复制失败', 'message': str(e), 'timeout': 5}}

return result