新增广州期货指标推送

models/base_from_trade_guangzhou.go

@@ -67,3 +67,10 @@ type BaseFromTradeGuangzhouDataResp struct {
 	List   []*BaseFromTradeGuangzhouData
 	Paging *paging.PagingItem `description:"分页数据"`
 }
+
+func GetBaseFromTradeGuangzhouIndex(startDate, endDate string) (list []*BaseFromTradeGuangzhouIndex, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM base_from_trade_guangzhou_index WHERE create_time>=? AND create_time<=? `
+	_, err = o.Raw(sql, startDate, endDate).QueryRows(&list)
+	return
+}

services/index.go

@@ -42,7 +42,7 @@ func GetIndexList(source int, startDate, endDate string) (list interface{}, err
 	case utils.DATA_SOURCE_MEETING_PROBABILITIES:
 		list, err = models.GetMeetingProbabilities(startDate, endDate)
 	case utils.DATA_SOURCE_GFEX:
-		list, err = models.GetTradeZhengzhouIndex(startDate, endDate)
+		list, err = models.GetBaseFromTradeGuangzhouIndex(startDate, endDate)
 	case utils.DATA_SOURCE_ICPI:
 		list, err = models.GetIcpiIndex(startDate, endDate)
 	default: