hsun 1 年之前
父节点
当前提交
ae3d834a1c
共有 1 个文件被更改,包括 25 次插入1 次删除
  1. 25 1
      models/data_manage/future_good/future_good_edb_info.go

+ 25 - 1
models/data_manage/future_good/future_good_edb_info.go

@@ -70,7 +70,15 @@ func GetAllFutureGoodEdbInfoList() (list []*FutureGoodEdbInfo, err error) {
 // GetFutureGoodEdbInfoListByParentId 根据父级ID获取指标数据列表
 func GetFutureGoodEdbInfoListByParentId(parentId int) (list []*FutureGoodEdbInfo, err error) {
 	o := orm.NewOrmUsingDB("data")
-	sql := `SELECT * FROM future_good_edb_info WHERE parent_id = ?  ORDER BY future_good_edb_info_id ASC `
+	sql := `SELECT * FROM future_good_edb_info WHERE parent_id = ? or  future_good_edb_info_id = ? ORDER BY future_good_edb_info_id ASC `
+	_, err = o.Raw(sql, parentId, parentId).QueryRows(&list)
+	return
+}
+
+// GetChildFutureGoodEdbInfoListByParentId 根据父级ID获取下面所有的指标数据列表
+func GetChildFutureGoodEdbInfoListByParentId(parentId int) (list []*FutureGoodEdbInfo, err error) {
+	o := orm.NewOrmUsingDB("data")
+	sql := `SELECT * FROM future_good_edb_info WHERE parent_id = ? ORDER BY future_good_edb_info_id ASC `
 	_, err = o.Raw(sql, parentId).QueryRows(&list)
 	return
 }
@@ -112,6 +120,22 @@ func GetFutureGoodEdbInfoGroupList(condition string, pars []interface{}) (list [
 	return
 }
 
+type FutureGoodExchange struct {
+	Exchange string `description:"所属交易所"`
+}
+
+// GetFutureGoodEdbExchangeList 获取分組指标数据列表
+func GetFutureGoodEdbExchangeList(condition string, pars []interface{}) (list []FutureGoodExchange, err error) {
+	o := orm.NewOrmUsingDB("data")
+	sql := `SELECT exchange FROM future_good_edb_info WHERE 1=1 `
+	if condition != "" {
+		sql += condition
+	}
+	sql += ` GROUP BY exchange `
+	_, err = o.Raw(sql, pars).QueryRows(&list)
+	return
+}
+
 // BarChartInfoReq 柱方图预览请求数据
 type BarChartInfoReq struct {
 	EdbInfoIdList []BarChartInfoEdbItemReq `description:"指标信息"`