-
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