This commit is contained in:
wood chen 2024-09-18 01:39:12 +08:00
parent 68c2651908
commit bd1d4b2e2b
2 changed files with 11 additions and 6 deletions

View File

@ -1,6 +1,7 @@
package service package service
import ( import (
"context"
"fmt" "fmt"
"log" "log"
"os" "os"
@ -55,27 +56,28 @@ func getTickerInfo(symbol string) (tickerInfo, error) {
client := binance.NewClient("", "") client := binance.NewClient("", "")
// 获取当前价格 // 获取当前价格
ticker, err := client.NewListPricesService().Symbol(symbol).Do(binance.NewContext()) ticker, err := client.NewListPricesService().Symbol(symbol).Do(context.Background())
if err != nil { if err != nil {
return tickerInfo{}, err return tickerInfo{}, err
} }
if len(ticker) == 0 { if len(ticker) == 0 {
return tickerInfo{}, fmt.Errorf("no ticker found for symbol %s", symbol) return tickerInfo{}, fmt.Errorf("no ticker found for symbol %s", symbol)
} }
last, err := ticker[0].Price.Float64() // 在 getTickerInfo 函数中
last, err := strconv.ParseFloat(ticker[0].Price, 64)
if err != nil { if err != nil {
return tickerInfo{}, err return tickerInfo{}, err
} }
// 获取24小时价格变化 // 获取24小时价格变化
stats, err := client.NewListPriceChangeStatsService().Symbol(symbol).Do(binance.NewContext()) stats, err := client.NewListPriceChangeStatsService().Symbol(symbol).Do(context.Background())
if err != nil { if err != nil {
return tickerInfo{}, err return tickerInfo{}, err
} }
if len(stats) == 0 { if len(stats) == 0 {
return tickerInfo{}, fmt.Errorf("no price change stats found for symbol %s", symbol) return tickerInfo{}, fmt.Errorf("no price change stats found for symbol %s", symbol)
} }
changePercent, err := stats[0].PriceChangePercent.Float64() changePercent, err := strconv.ParseFloat(stats[0].PriceChangePercent, 64)
if err != nil { if err != nil {
return tickerInfo{}, err return tickerInfo{}, err
} }

View File

@ -14,7 +14,6 @@ import (
) )
var ( var (
botToken string
adminID int64 adminID int64
dbFile string dbFile string
debugMode bool debugMode bool
@ -151,7 +150,11 @@ func StartBot() error {
return fmt.Errorf("error registering commands: %w", err) return fmt.Errorf("error registering commands: %w", err)
} }
linkFilter := core.NewLinkFilter(dbFile) linkFilter, err := core.NewLinkFilter(dbFile)
if err != nil {
log.Fatalf("Failed to create LinkFilter: %v", err)
}
rateLimiter := NewRateLimiter(10, time.Second) rateLimiter := NewRateLimiter(10, time.Second)
u := tgbotapi.NewUpdate(0) u := tgbotapi.NewUpdate(0)