广期所数据更新

models/data_manage/base_from_trade_guangzhou.go

@@ -23,7 +23,7 @@ type BaseFromTradeGuangzhouIndex struct {
 
 func AddBaseFromTradeGuangzhouIndex(item *BaseFromTradeGuangzhouIndex) (lastId int64, err error) {
 	o := orm.NewOrm()
-	lastId, err = o.Insert(item)
+	lastId, err = o.InsertOrUpdate(item)
 	return
 }
 

services/trade_guangzhou.go

@@ -79,14 +79,14 @@ func SyncFromGuangzhouIndex() (err error) {
 	}
 
 	for _, item := range respObj.Data {
-		if _, ok := existIndexMap[item.BaseFromTradeGuangzhouIndexId]; !ok {
-			
-			newID, err := data_manage.AddBaseFromTradeGuangzhouIndex(item)
-			if err != nil {
-				fmt.Println("insert error:", err)
-			}
-			fmt.Println("insert new indexID:", newID)
+		//if _, ok := existIndexMap[item.BaseFromTradeGuangzhouIndexId]; !ok {
+
+		newID, err := data_manage.AddBaseFromTradeGuangzhouIndex(item)
+		if err != nil {
+			fmt.Println("insert error:", err)
 		}
+		fmt.Println("insert new indexID:", newID)
+		//}
 	}
 	return err
 }