diff --git a/internal/impl/impl.go b/internal/impl/impl.go index 45a3337..6b67faf 100644 --- a/internal/impl/impl.go +++ b/internal/impl/impl.go @@ -9,7 +9,7 @@ import ( var ( CacheUrl = "redis://null:Weidong2023~!@139.224.247.176:19379/0" - DBSources = []string{"host=139.224.247.176 user=postgres password=Stock0310~! dbname=stock_prod port=19432 sslmode=disable TimeZone=Asia/Shanghai"} + DBSources = []string{"host=139.224.247.176 user=postgres password=Stock0310~! dbname=stock_prod port=19432 sslmode=disable"} RedisService *redis.RedisClient DBService *gorm.DB ) diff --git a/internal/logic/boot.go b/internal/logic/boot.go index 3f991dd..19e9407 100644 --- a/internal/logic/boot.go +++ b/internal/logic/boot.go @@ -35,7 +35,7 @@ func Boot(cfg *conf.Config) { coll := NewCollector(COLLECTOR_URL) // 启动时检查并补全订单簿数据 - CheckAndRepairOrderBooks(cfg.AccountID) + // CheckAndRepairOrderBooks(cfg.AccountID) // 创建cron调度器 c := cron.New(cron.WithSeconds()) diff --git a/internal/logic/storage.go b/internal/logic/storage.go index 669128d..f4d3068 100644 --- a/internal/logic/storage.go +++ b/internal/logic/storage.go @@ -108,10 +108,10 @@ func SaveData(status *types.StatusData) error { } // 处理订单簿逻辑 - if err := processOrderBook(status.Data.Assets.AccountID, order, ymd, now, open_price); err != nil { - fmt.Printf("处理订单簿失败: %v\n", err) - // 不返回错误,避免影响主流程 - } + // if err := processOrderBook(status.Data.Assets.AccountID, order, ymd, now, open_price); err != nil { + // fmt.Printf("处理订单簿失败: %v\n", err) + // // 不返回错误,避免影响主流程 + // } } }