From 7417caa778350471e2b1f0926e4fb9853d19e41c Mon Sep 17 00:00:00 2001 From: ArvinLovegood Date: Wed, 5 Mar 2025 09:21:10 +0800 Subject: [PATCH] =?UTF-8?q?fix(stock=5Fdata):=E4=BF=AE=E5=A4=8D=E8=82=A1?= =?UTF-8?q?=E7=A5=A8=E4=BB=A3=E7=A0=81=E5=AE=9E=E6=97=B6=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E8=8E=B7=E5=8F=96=E6=97=B6=E7=9A=84=E5=BC=82=E5=B8=B8=E5=AD=97?= =?UTF-8?q?=E7=AC=A6=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在获取昨日收盘价时,使用 strutil.ReplaceWithMap函数去除引号 - 移除了测试代码中不必要的 JSON 序列化和数据库操作 - 在测试函数中添加了新的股票代码参数 --- backend/data/stock_data_api.go | 2 +- backend/data/stock_data_api_test.go | 22 +--------------------- 2 files changed, 2 insertions(+), 22 deletions(-) diff --git a/backend/data/stock_data_api.go b/backend/data/stock_data_api.go index 0c3b813..42e7840 100644 --- a/backend/data/stock_data_api.go +++ b/backend/data/stock_data_api.go @@ -555,7 +555,7 @@ func ParseUSStockData(datas []string) (map[string]string, error) { result["股票代码"] = code result["股票名称"] = parts[0] result["今日开盘价"] = parts[5] - result["昨日收盘价"] = parts[len(parts)-1] + result["昨日收盘价"] = strutil.ReplaceWithMap(parts[len(parts)-1], map[string]string{"\"": ""}) result["今日最高价"] = parts[6] result["今日最低价"] = parts[7] result["当前价格"] = parts[1] diff --git a/backend/data/stock_data_api_test.go b/backend/data/stock_data_api_test.go index 08d7329..2c9f599 100644 --- a/backend/data/stock_data_api_test.go +++ b/backend/data/stock_data_api_test.go @@ -105,32 +105,12 @@ func TestParseFullSingleStockData(t *testing.T) { logger.SugaredLogger.Error(er.Error()) } logger.SugaredLogger.Infof("%+#v", result) - marshal, err := json.Marshal(result) - if err != nil { - logger.SugaredLogger.Errorf("json.Marshal error:%s", err.Error()) - } - logger.SugaredLogger.Infof("json:%s", string(marshal)) - stockInfo := &StockInfo{} - err = json.Unmarshal(marshal, &stockInfo) - if err != nil { - logger.SugaredLogger.Errorf("json.Unmarshal error:%s", err.Error()) - } - logger.SugaredLogger.Infof("%+#v", stockInfo) - stockData := stockInfo - db.Init("../../data/stock.db") - var count int64 - db.Dao.Model(&StockInfo{}).Where("code = ?", stockData.Code).Count(&count) - if count == 0 { - db.Dao.Model(&StockInfo{}).Create(stockData) - } else { - db.Dao.Model(&StockInfo{}).Where("code = ?", stockData.Code).Updates(stockData) - } } func TestNewStockDataApi(t *testing.T) { db.Init("../../data/stock.db") stockDataApi := NewStockDataApi() - datas, _ := stockDataApi.GetStockCodeRealTimeData("sh600859", "sh600745") + datas, _ := stockDataApi.GetStockCodeRealTimeData("sh600859", "sh600745", "gb_tsla") for _, data := range *datas { t.Log(data) }