新增郑商所重复校验

services/commodity_trade_zhengzhou.go

@@ -249,6 +249,7 @@ func SyncRankingFromZhengzhou() {
 							if err != nil {
 								fmt.Println("insert error:", err)
 							}
+							existIndexMap[item.DealName+item.BuyName+item.SoldName] = item
 							fmt.Println("insert new indexID:", newID)
 						} else if existIndex != nil && itemVerifyCode != (existIndex.DealValue+existIndex.BuyValue+existIndex.SoldValue) {
 							//更新
@@ -293,6 +294,7 @@ func SyncRankingFromZhengzhou() {
 								fmt.Println("insert error:", err)
 							}
 							fmt.Println("insert new indexID:", newID)
+							existIndexMap[item.DealName+item.BuyName+item.SoldName] = item
 						} else if existIndex != nil && itemVerifyCode != (existIndex.DealValue+existIndex.BuyValue+existIndex.SoldValue) {
 							//更新
 							err := models.ModifyBaseFromTradeZhengzhouIndex(item.DealValue, item.BuyValue, item.SoldValue, existIndex.BaseFromTradeZhengzhouIndexId)