|
@@ -268,7 +268,7 @@ func (this *ExchangeCrawler) RefreshSH() {
|
|
|
fmt.Println("insert new indexID:", newID)
|
|
|
} else if existIndex != nil && itemVerifyCode != (existIndex.DealValue+existIndex.BuyValue+existIndex.SoldValue) {
|
|
|
//更新
|
|
|
- err = models.ModifyBaseFromTradeShangHaiIndex(item.DealValue, item.BuyValue, item.SoldValue, existIndex.BaseFromTradeShangHaiIndexId)
|
|
|
+ err = models.ModifyBaseFromTradeShangHaiIndex(item.DealValue, item.BuyValue, item.SoldValue, existIndex.BaseFromTradeShanghaiIndexId)
|
|
|
if err != nil {
|
|
|
fmt.Println("data update err:", err)
|
|
|
}
|
|
@@ -324,7 +324,7 @@ func (this *ExchangeCrawler) RefreshSH() {
|
|
|
fmt.Println("insert new indexID:", newID)
|
|
|
} else if existIndex != nil && itemVerifyCode != (existIndex.DealValue+existIndex.BuyValue+existIndex.SoldValue) {
|
|
|
//更新
|
|
|
- err = models.ModifyBaseFromTradeShangHaiIndex(item.DealValue, item.BuyValue, item.SoldValue, existIndex.BaseFromTradeShangHaiIndexId)
|
|
|
+ err = models.ModifyBaseFromTradeShangHaiIndex(item.DealValue, item.BuyValue, item.SoldValue, existIndex.BaseFromTradeShanghaiIndexId)
|
|
|
if err != nil {
|
|
|
fmt.Println("data update err:", err)
|
|
|
}
|