新增郑州交易所

models/base_from_trade_zhengzhou.go

@@ -0,0 +1,25 @@
+package models
+
+import (
+	"rdluck_tools/orm"
+	"time"
+)
+
+type BaseFromTradeZhengzhouIndex struct {
+	BaseFromTradeZhengzhouIndexId int `orm:"column(base_from_trade_zhengzhou_index_id);pk"`
+	IndexName                     string
+	IndexCode                     string
+	Frequency                     string
+	StartDate                     time.Time
+	EndDate                       time.Time
+	CreateTime                    time.Time
+	ModifyTime                    time.Time
+	ClassifyName                  string
+}
+
+func AddBaseFromTradeZhengzhouIndex(item *BaseFromTradeZhengzhouIndex) (lastId int64, err error) {
+	o := orm.NewOrm()
+	o.Using("data")
+	lastId, err = o.Insert(item)
+	return
+}

models/db.go

@@ -26,5 +26,7 @@ func init() {
 	data_db.SetConnMaxLifetime(10 * time.Minute)
 
 	//注册对象
-	orm.RegisterModel()
+	orm.RegisterModel(
+		new(BaseFromTradeZhengzhouIndex),
+		)
 }

services/commodity_exchange_zhengzhou.go → services/commodity_trade_zhengzhou.go

@@ -28286,6 +28286,8 @@ func SyncRankingFromZhenzhou() {
 		log.Fatal(err)
 	}
 	table := doc.Find("table")
+	var classifyName, tradeDate string
+	var dealSuffix, dealZjSuffix, buySuffix, buyZjSuffix, sellSuffix, sellZjSuffix string
 	table.Find("tr").Each(func(i int, tr *goquery.Selection) {
 		tds := tr.Find("td")
 		if tds.Length() == 1 {
@@ -28294,11 +28296,40 @@ func SyncRankingFromZhenzhou() {
 			if tdText != "" {
 				tdTextArr := strings.Split(tdText, "    ")
 				for k, v := range tdTextArr {
-					fmt.Println(k, v)
-					utils.FileLog.Info(v)
+					//fmt.Println(k, v)
+					if k == 0 {
+						classifyName = v
+					} else {
+						tradeDate = v
+					}
 				}
 			}
 		} else {
+			tds.Each(func(tk int, td *goquery.Selection) {
+				tdText := td.Text()
+				if tk == 2 && strings.Contains(tdText, "成交量") {
+					dealSuffix = tdText
+				}
+				if tk == 3 && strings.Contains(tdText, "增减量") {
+					dealZjSuffix = tdText
+				}
+				if tk == 5 && strings.Contains(tdText, "持买仓量") {
+					buySuffix = tdText
+				}
+				if tk == 6 && strings.Contains(tdText, "增减量") {
+					buyZjSuffix = tdText
+				}
+				if tk == 8 && strings.Contains(tdText, "持卖仓量") {
+					sellSuffix = tdText
+				}
+				if tk == 9 && strings.Contains(tdText, "增减量") {
+					sellZjSuffix = tdText
+				}
+				if tk == 0 && !strings.Contains(tdText, "名次") {
+
+				}
+			})
+			fmt.Println(i, tds.Text())
 			//fmt.Println("len 10:" + tds.Text())
 		}
 	})