广州交易所数据同步

models/data_manage/base_from_trade_guangzhou.go

@@ -83,7 +83,7 @@ type BaseFromTradeGuangzhouContract struct {
 // 新增合约
 func (obj *BaseFromTradeGuangzhouIndex) AddBaseFromTradeGuangzhouContract(item *BaseFromTradeGuangzhouContract) (err error) {
 	o := orm.NewOrmUsingDB("data")
-	_, err = o.Insert(item)
+	_, err = o.InsertOrUpdate(item)
 	return
 }
 

services/trade_guangzhou.go

@@ -122,13 +122,13 @@ func SyncFromGuangzhouContract() (err error) {
 	obj := new(data_manage.BaseFromTradeGuangzhouIndex)
 
 	for _, item := range respObj.Data {
-		if _, ok := existContractMap[item.BaseFromTradeGuangzhouContractId]; !ok {
-			err = obj.AddBaseFromTradeGuangzhouContract(item)
-			if err != nil {
-				fmt.Println("AddBaseFromTradeGuangzhouContract error:", err)
-			}
-			fmt.Println("AddBaseFromTradeGuangzhouContract new indexID:")
+		//if _, ok := existContractMap[item.BaseFromTradeGuangzhouContractId]; !ok {
+		err = obj.AddBaseFromTradeGuangzhouContract(item)
+		if err != nil {
+			fmt.Println("AddBaseFromTradeGuangzhouContract error:", err)
 		}
+		fmt.Println("AddBaseFromTradeGuangzhouContract new indexID:")
+		//}
 	}
 	return err
 }