Merge branch 'data_crawler' into debug

controllers/exchange_crawler.go

@@ -42,10 +42,15 @@ func (this *ExchangeCrawler) GetOrAdd() {
 		fmt.Println("err:", err)
 		return
 	}
-
+	var resp models.JSONData
+	err = json.Unmarshal(body, &resp)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
 
 	br.Ret = 200
 	br.Msg = "获取成功"
 	br.Success = true
-	br.Data = body
+	br.Data = resp
 }

models/base_from_sh.go

@@ -266,3 +266,30 @@ func RefreshEdbDataFromSh(edbInfoId int, edbCode, startDate string) (err error)
 type RefreshExchangeoReq struct {
 	Url string `description:"交易所链接"`
 }
+
+
+type JSONData struct {
+	OCursor    []OCursor   `json:"o_cursor"`
+	OCode      interface{} `json:"o_code"`
+	OMsg       string      `json:"o_msg"`
+	ReportDate string      `json:"report_date"`
+	UpdateDate string      `json:"update_date"`
+}
+type OCursor struct {
+	Instrumentid     string      `json:"INSTRUMENTID"`
+	Participantid3   string      `json:"PARTICIPANTID3"`
+	Participantid2   string      `json:"PARTICIPANTID2"`
+	Participantid1   string      `json:"PARTICIPANTID1"`
+	Participantabbr3 string      `json:"PARTICIPANTABBR3"`
+	Participantabbr2 string      `json:"PARTICIPANTABBR2"`
+	Rank             int         `json:"RANK"`
+	Participantabbr1 string      `json:"PARTICIPANTABBR1"`
+	BuyIn            interface{} `json:"CJ2"`
+	Deal             interface{} `json:"CJ1"`
+	Change1          interface{} `json:"CJ1_CHG"`
+	Change3          interface{} `json:"CJ3_CHG"`
+	Productname      string      `json:"Productname"`
+	Productsortno    interface{} `json:"PRODUCTSORTNO"`
+	SoldOut          interface{} `json:"CJ3"`
+	Change2          interface{} `json:"CJ2_CHG"`
+}