• fremontzhang's avatar
    Merge loopwm/account 与 ai-loop/loop-account-pool 分叉历史:合并双数据源迁移功能 · 7a0dcf48
    fremontzhang authored
    合并两条并行演进的迁移账号实现,最终支持 center + ad_flow 双数据源:
    
    保留 loopwm/account(姬博鹏)侧功能:
    - 源库注册表架构(source_registry.go),支持 center / ad_flow 双源库
    - ad_flow 源库(DB3_*,火山引擎 RDS)迁移支持,含 user_id→agent_id 字段映射、fb_group_id 过滤
    - 完整迁移流程:social/team/pool 三类行迁移、旧→新 ID 映射、缺失 pool 行初始化
    - INSERT IGNORE 规避唯一键冲突(Error 1062)+ social_account_id 重复预检
    - account_language / account_type 返回参数
    - 迁移账号前端页面拆分为 MigrateDialog / ProdAccountTable / ProdFilterPanel 组件
    
    保留 ai-loop/loop-account-pool 侧功能:
    - Kafka 采用 IBM/sarama + MQ 抽象层(kafka/db_poll/redis/noop),已与 account-mark 完成端到端验证
    - 打标完成事件消费(tagging_event_handler,消费组 tagging-event-handler)
    - GET /api/v1/accounts/:social_id 单账号查询端点(供 account-mark 调用)
    - 迁移成功后通过统一 MQ Producer 发送 account.migrated 事件
    
    DB 语义统一:
    - DB_* = 主库 loop_account_pool(迁移目标库)
    - DB2_* = center 源库(原 loop 库,5404 条账号)
    - DB3_* = ad_flow 源库(丁昊授权库)
    7a0dcf48