实时数据只保留最新一条数据

spark · spark · commit a99393b4c70e · 2024-12-19T09:50:27.000+08:00
diff --git a/backend/data/stock_data_api.go b/backend/data/stock_data_api.go
@@ -220,7 +220,13 @@ func (receiver StockDataApi) GetStockCodeRealTimeData(StockCode string) (*StockI
 		return &StockInfo{}, nil
 	}
 	stockData, err := ParseFullSingleStockData(GB18030ToUTF8(resp.Body()))
-	//go db.Dao.Model(&StockInfo{}).Create(stockData)
+	var count int64
+	db.Dao.Model(&StockInfo{}).Where("code = ?", StockCode).Count(&count)
+	if count == 0 {
+		go db.Dao.Model(&StockInfo{}).Create(stockData)
+	} else {
+		go db.Dao.Model(&StockInfo{}).Where("code = ?", StockCode).Updates(stockData)
+	}
 	return stockData, err
 }
 

Original file line number	Diff line number	Diff line change
`@@ -220,7 +220,13 @@ func (receiver StockDataApi) GetStockCodeRealTimeData(StockCode string) (*StockI`
`220`	`220`	`return &StockInfo{}, nil`
`221`	`221`	`}`
`222`	`222`	`stockData, err := ParseFullSingleStockData(GB18030ToUTF8(resp.Body()))`
`223`		`- //go db.Dao.Model(&StockInfo{}).Create(stockData)`
	`223`	`+ var count int64`
	`224`	`+ db.Dao.Model(&StockInfo{}).Where("code = ?", StockCode).Count(&count)`
	`225`	`+ if count == 0 {`
	`226`	`+ go db.Dao.Model(&StockInfo{}).Create(stockData)`
	`227`	`+ } else {`
	`228`	`+ go db.Dao.Model(&StockInfo{}).Where("code = ?", StockCode).Updates(stockData)`
	`229`	`+ }`
`224`	`230`	`return stockData, err`
`225`	`231`	`}`
`226`	`232`