liuyu/nofx
1
0
Fork 0
mirror of https://github.com/NoFxAiOS/nofx.git synced 2026-07-13 07:46:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(auto_trader): trader's stop channel isn't set when restarting (#779)

Browse Source 
* fix(auto_trader): trader's stop channel isn't set when restarting

* fix stopping trader immediately

---------

Co-authored-by: zbhan <zbhan@freewheel.tv>
This commit is contained in:
Shui
2025-11-08 13:57:28 -05:00
committed by GitHub
parent c4a1bfa89f
commit edc0f41d76
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
trader/auto_trader.go
View File

@@ -239,10 +239,15 @@ func NewAutoTrader(config AutoTraderConfig, database interface{}, userID string)
// Run 运行自动交易主循环 // Run 运行自动交易主循环
func (at *AutoTrader) Run() error { func (at *AutoTrader) Run() error {
at.isRunning = true at.isRunning = true
at.stopMonitorCh = make(chan struct{})
at.startTime = time.Now()
log.Println("🚀 AI驱动自动交易系统启动") log.Println("🚀 AI驱动自动交易系统启动")
log.Printf("💰 初始余额: %.2f USDT", at.initialBalance) log.Printf("💰 初始余额: %.2f USDT", at.initialBalance)
log.Printf("⚙️ 扫描间隔: %v", at.config.ScanInterval) log.Printf("⚙️ 扫描间隔: %v", at.config.ScanInterval)
log.Println("🤖 AI将全权决定杠杆、仓位大小、止损止盈等参数") log.Println("🤖 AI将全权决定杠杆、仓位大小、止损止盈等参数")
at.monitorWg.Add(1)
defer at.monitorWg.Done()
// 启动回撤监控 // 启动回撤监控
at.startDrawdownMonitor() at.startDrawdownMonitor()
@@ -261,6 +266,9 @@ func (at *AutoTrader) Run() error {
if err := at.runCycle(); err != nil { if err := at.runCycle(); err != nil {
log.Printf("❌ 执行失败: %v", err) log.Printf("❌ 执行失败: %v", err)
} }
case <-at.stopMonitorCh:
log.Printf("[%s] ⏹ 收到停止信号，退出自动交易主循环", at.name)
return nil
} }
} }