..

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.InsertOrUpdate(item)
+	_, err = o.Insert(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)
+		if _, ok := existContractMap[item.BaseFromTradeGuangzhouContractId]; !ok {
+			err = obj.AddBaseFromTradeGuangzhouContract(item)
+			if err != nil {
+				fmt.Println("AddBaseFromTradeGuangzhouContract error:", err)
+			}
+			fmt.Println("AddBaseFromTradeGuangzhouContract new indexID:")
 		}
-		fmt.Println("AddBaseFromTradeGuangzhouContract new indexID:")
-		//}
 	}
 	return err
 }