 hailin
|
454b379f6c
|
feat(mining-blockchain-service): mining_ 前缀隔离，与 blockchain-service 100% 资源分离
mining-blockchain-service 的所有共享资源全部加上 mining_ 前缀，
确保与 1.0 blockchain-service 完全隔离，互不干扰。
## Kafka Topic 隔离 — 生产者 (event-publisher.service.ts)
- source header: 'blockchain-service' → 'mining-blockchain-service'
- topic 映射全部加 mining_ 前缀:
- blockchain.deposits → mining_blockchain.deposits
- blockchain.wallets → mining_blockchain.wallets
- blockchain.transactions → mining_blockchain.transactions
- mpc.SigningRequested → mining_mpc.SigningRequested
- blockchain.market_maker.deposits → mining_blockchain.market_maker.deposits
- 默认 fallback: blockchain.events → mining_blockchain.events
## Domain Event eventType 隔离 (5 个事件类)
- deposit-detected.event.ts: mining_blockchain.deposit.detected
- deposit-confirmed.event.ts: mining_blockchain.deposit.confirmed
- wallet-address-created.event.ts: mining_blockchain.wallet.address.created
- transaction-broadcasted.event.ts: mining_blockchain.transaction.broadcasted
- market-maker-deposit-confirmed.event.ts: mining_blockchain.market_maker.deposit.confirmed
## Kafka Topic 隔离 — 消费者 (3 个 consumer)
- mpc-event-consumer: mining_mpc.KeygenCompleted / SigningCompleted / SessionFailed
- withdrawal-event-consumer: mining_wallet.withdrawals / mining_wallet.system-withdrawals
- 事件类型检查: mining_wallet.withdrawal.requested / mining_wallet.system-withdrawal.requested
- deposit-ack-consumer: mining_wallet.acks
- 事件类型检查: mining_wallet.deposit.credited
- outbox ACK 匹配: mining_blockchain.deposit.confirmed
## Kafka 事件类型 — Event Handlers
- mpc-signing.client.ts:
- MPC_SIGNING_TOPIC → mining_mpc.SigningRequested
- eventType → mining_blockchain.mpc.signing.requested
- withdrawal-requested.handler.ts:
- mining_blockchain.withdrawal.confirmed / failed / status
- system-withdrawal-requested.handler.ts:
- mining_blockchain.system-withdrawal.confirmed / failed
## Redis Key 前缀隔离
- address-cache: blockchain:monitored_addresses: → mining_blockchain:monitored_addresses:
- hot-wallet-balance: hot_wallet:dusdt_balance: → mining_hot_wallet:dusdt_balance:
- hot-wallet-balance: hot_wallet:native_balance: → mining_hot_wallet:native_balance:
## 数据库名称隔离
- docker-compose.yml: rwa_blockchain → rwa_mining_blockchain
- docker-compose.2.0.yml: rwa_blockchain → rwa_mining_blockchain
- deploy-mining.sh: MINING_DATABASES + SERVICE_DB 映射 → rwa_mining_blockchain
## 下游服务需配套更新 (不在本次修改范围)
- mpc-service: 消费 mining_mpc.SigningRequested, 发布 mining_mpc.* 结果
- mining-wallet-service: 发布 mining_wallet.*, 消费 mining_blockchain.*
- trading-service: 消费 mining_blockchain.market_maker.deposits
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
|
2026-01-30 01:58:45 -08:00 |
|
hailin
|
219fb7bb69
|
fix(mining-blockchain): 移除旧的 MARKET_MAKER_* 变量名引用
- main.ts: 使用 EUSDT/FUSDT_MARKET_MAKER_* 验证配置
- blockchain.config.ts: 使用 eusdtMarketMaker/fusdtMarketMaker 配置
- market-maker-deposit-detection.service.ts: 每种代币使用独立的做市商钱包地址
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
|
2026-01-28 19:20:48 -08:00 |
|
hailin
|
1974c43eba
|
feat(market-maker): 实现做市商区块链充值监控功能
- mining-blockchain-service:
- 添加 MarketMakerDeposit 和 MarketMakerBlockCheckpoint 表
- 添加 eUSDT/fUSDT 代币合约配置
- 实现做市商钱包充值检测服务
- 添加启动时配置验证和错误日志
- 发布充值确认事件到 Kafka
- trading-service:
- 添加做市商充提记录表 (MarketMakerDeposit, MarketMakerWithdraw)
- 添加 Kafka 消费者监听充值确认事件
- 实现充值自动入账和流水记录
- 部署配置:
- 更新 docker-compose 添加新环境变量
- 更新 deploy-mining.sh 添加 blockchain 服务
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
|
2026-01-28 17:13:41 -08:00 |
|
hailin
|
042a52550b
|
feat(c2c): 实现C2C Bot自动交易系统
- 创建独立的 mining-blockchain-service 服务 (基于 blockchain-service)
- 添加 dUSDT 转账接口供 C2C Bot 调用
- 实现 C2cBotService 自动购买卖单
- 实现 C2cBotScheduler 每10秒扫描待处理卖单
- 添加 BlockchainClient 和 IdentityClient 客户端
- 更新 C2cOrder 模型添加 Bot 购买相关字段
- 使用 MPC 热钱包签名交易
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
|
2026-01-28 07:10:25 -08:00 |