|
@@ -1,2238 +0,0 @@
|
|
|
-package controllers
|
|
|
-
|
|
|
-import (
|
|
|
- "eta_gn/eta_api/models"
|
|
|
- "eta_gn/eta_api/models/data_manage"
|
|
|
- "eta_gn/eta_api/utils"
|
|
|
- "fmt"
|
|
|
- "github.com/rdlucklib/rdluck_tools/paging"
|
|
|
- "strconv"
|
|
|
- "strings"
|
|
|
-)
|
|
|
-
|
|
|
-type TradeCommonController struct {
|
|
|
- BaseAuthController
|
|
|
-}
|
|
|
-
|
|
|
-type Data []struct {
|
|
|
- Title string
|
|
|
- ItemList []ShanghaiList
|
|
|
-}
|
|
|
-type ShanghaiList struct {
|
|
|
- Code string
|
|
|
- Item []*data_manage.BaseFromTradeShanghaiIndex
|
|
|
-}
|
|
|
-type EicData struct {
|
|
|
- Country string
|
|
|
- Type string
|
|
|
- EicCode string
|
|
|
- ShortName string
|
|
|
- Name string
|
|
|
- Status string
|
|
|
- GasDayStartedOn string
|
|
|
- GasInStorage float64
|
|
|
- GasInStorageCode string
|
|
|
- Full float64
|
|
|
- FullCode string
|
|
|
- Trend float64
|
|
|
- TrendCode string
|
|
|
- Injection float64
|
|
|
- InjectionCode string
|
|
|
- Withdrawal float64
|
|
|
- WithdrawalCode string
|
|
|
- WorkingGasVolume float64
|
|
|
- WorkingGasVolumeCode string
|
|
|
- InjectionCapacity float64
|
|
|
- InjectionCapacityCode string
|
|
|
- WithdrawalCapacity float64
|
|
|
- WithdrawalCapacityCode string
|
|
|
- Info string
|
|
|
- Children []*data_manage.BaseFromTradeEicIndex
|
|
|
-}
|
|
|
-
|
|
|
-// ExchangeClassify
|
|
|
-// @title 获取交易所种类列表
|
|
|
-// @Description 获取交易所种类列表接口
|
|
|
-// @Param Exchange query string true "交易所名称"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/exchange/classify [get]
|
|
|
-func (this *TradeCommonController) ExchangeClassify() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- exchange := this.GetString("Exchange")
|
|
|
- date := this.GetString("DataTime")
|
|
|
-
|
|
|
- var respItem [][]string
|
|
|
-
|
|
|
- latestData, err := data_manage.GetLatestDate(exchange)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取失败"
|
|
|
- br.ErrMsg = "获取最新日期失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- if latestData == "" {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = respItem
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- if date == "" {
|
|
|
- date = latestData
|
|
|
- }
|
|
|
-
|
|
|
- classifyName, err := data_manage.GetExchangeClassify(exchange, date)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取种类失败"
|
|
|
- br.ErrMsg = "获取种类失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- respItem = append(respItem, classifyName)
|
|
|
- respItem = append(respItem, []string{latestData})
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = respItem
|
|
|
-}
|
|
|
-
|
|
|
-// ExchangeClassifyContract
|
|
|
-// @title 获取交易所种类合约列表
|
|
|
-// @Description 获取交易所种类合约列表接口
|
|
|
-// @Param Exchange query string true "交易所名称"
|
|
|
-// @Param Classify query string true "种类名称"
|
|
|
-// @Param DataTime query string true "时间"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/exchange/classifyContract [get]
|
|
|
-func (this *TradeCommonController) ExchangeClassifyContract() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- exchange := this.GetString("Exchange")
|
|
|
- classify := this.GetString("Classify")
|
|
|
- dataTime := this.GetString("DataTime")
|
|
|
- classifyName, err := data_manage.GetExchangeClassifyContract(exchange, classify, dataTime)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取种类失败"
|
|
|
- br.ErrMsg = "获取种类失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = classifyName
|
|
|
-}
|
|
|
-
|
|
|
-// ShfeDataList
|
|
|
-// @title 获取上期所列表
|
|
|
-// @Description 获取上期所列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param ClassifyName query string false "分类名称"
|
|
|
-// @Param ClassifyType query string false "分类合约"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/shfe [get]
|
|
|
-func (this *TradeCommonController) ShfeDataList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- classifyName := this.GetString("ClassifyName")
|
|
|
- classifyType := this.GetString("ClassifyType")
|
|
|
- frequencyList, err := data_manage.GetBaseFromTradeIndexByParam("shanghai", date, classifyName, classifyType)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var data Data
|
|
|
- var j, k int
|
|
|
- if len(frequencyList) == 0 {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- if classifyName == "" {
|
|
|
- data = make(Data, 50)
|
|
|
- for i, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- if data[j].Title == item.ClassifyName {
|
|
|
- if data[j].ItemList[k].Code == item.ClassifyType {
|
|
|
- data[j].ItemList[k].Item = append(data[j].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i > 0 {
|
|
|
- k++
|
|
|
- }
|
|
|
- data[j].ItemList[k].Code = item.ClassifyType
|
|
|
- data[j].ItemList[k].Item = append(data[j].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i != 0 {
|
|
|
- if k == 0 {
|
|
|
- data[j].ItemList = data[j].ItemList[:k+1]
|
|
|
- } else {
|
|
|
- data[j].ItemList = data[j].ItemList[:k]
|
|
|
- }
|
|
|
- j++
|
|
|
- k = 0
|
|
|
- }
|
|
|
- if data[j].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 930)
|
|
|
- data[j].ItemList = list
|
|
|
- }
|
|
|
- data[j].Title = item.ClassifyName
|
|
|
- data[j].ItemList[k].Code = item.ClassifyType
|
|
|
- data[j].ItemList[k].Item = append(data[j].ItemList[k].Item, item)
|
|
|
- }
|
|
|
- data = data[:j]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- data = make(Data, 1)
|
|
|
- for i, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = classifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 200)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[k].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i > 0 {
|
|
|
- k++
|
|
|
- }
|
|
|
- data[0].ItemList[k].Code = item.ClassifyType
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- }
|
|
|
- data[0].ItemList = data[0].ItemList[:k+1]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// IneDataList
|
|
|
-// @title 获取上海国际能源交易所列表
|
|
|
-// @Description 获取上海国际能源交易所列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param ClassifyName query string false "分类名称"
|
|
|
-// @Param ClassifyType query string false "分类合约"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/ine [get]
|
|
|
-func (this *TradeCommonController) IneDataList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- classifyName := this.GetString("ClassifyName")
|
|
|
- classifyType := this.GetString("ClassifyType")
|
|
|
- frequencyList, err := data_manage.GetBaseFromTradeIndexByParam("ine", date, classifyName, classifyType)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- var data Data
|
|
|
- var k int
|
|
|
- if len(frequencyList) == 0 {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- data = make(Data, 1)
|
|
|
- if len(frequencyList) > 20 {
|
|
|
- for i, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = classifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 200)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[k].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i > 0 {
|
|
|
- k++
|
|
|
- }
|
|
|
- data[0].ItemList[k].Code = item.ClassifyType
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- }
|
|
|
- data[0].ItemList = data[0].ItemList[:k+1]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- for _, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = item.ClassifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 1)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[0].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- //if i != 0 {
|
|
|
- // k++
|
|
|
- // fmt.Println(k)
|
|
|
- //}
|
|
|
- data[0].ItemList[0].Code = item.ClassifyType
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- }
|
|
|
- //data[0].ItemList = data[0].ItemList[:k]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// CffexDataList
|
|
|
-// @title 获取中金所所列表
|
|
|
-// @Description 获取中金所列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param ClassifyName query string false "分类名称"
|
|
|
-// @Param ClassifyType query string false "分类合约"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/cffex [get]
|
|
|
-func (this *TradeCommonController) CffexDataList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- date = strings.Replace(date, "-", "", -1)
|
|
|
- classifyName := this.GetString("ClassifyName")
|
|
|
- classifyType := this.GetString("ClassifyType")
|
|
|
- frequencyList, err := data_manage.GetBaseFromTradeIndexByParam("cffex", date, classifyName, classifyType)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var data Data
|
|
|
- var k int
|
|
|
- if len(frequencyList) == 0 {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- data = make(Data, 1)
|
|
|
- if len(frequencyList) > 20 {
|
|
|
- for i, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = classifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 200)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[k].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i > 0 {
|
|
|
- k++
|
|
|
- }
|
|
|
- data[0].ItemList[k].Code = item.ClassifyType
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- }
|
|
|
- data[0].ItemList = data[0].ItemList[:k+1]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- for _, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = item.ClassifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 1)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[0].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- //if i != 0 {
|
|
|
- // k++
|
|
|
- // fmt.Println(k)
|
|
|
- //}
|
|
|
- data[0].ItemList[0].Code = item.ClassifyType
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- }
|
|
|
- //data[0].ItemList = data[0].ItemList[:20]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// ZhengzhouDataList
|
|
|
-// @title 获取郑州交易所列表
|
|
|
-// @Description 获取郑州交易所列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param ClassifyName query string false "分类名称"
|
|
|
-// @Param ClassifyType query string false "分类合约"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/zhengzhou [get]
|
|
|
-func (this *TradeCommonController) ZhengzhouDataList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- fmt.Println(date)
|
|
|
- date = strings.Replace(date, "-", "", -1)
|
|
|
- fmt.Println(date)
|
|
|
- classifyName := this.GetString("ClassifyName")
|
|
|
- classifyType := this.GetString("ClassifyType")
|
|
|
- frequencyList, err := data_manage.GetBaseFromTradeIndexByParam("zhengzhou", date, classifyName, classifyType)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var data Data
|
|
|
- var k int
|
|
|
- if len(frequencyList) == 0 {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- data = make(Data, 1)
|
|
|
- fmt.Println(len(frequencyList))
|
|
|
- if len(frequencyList) > 21 {
|
|
|
- for i, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = classifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 200)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[k].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i > 0 {
|
|
|
- k++
|
|
|
- }
|
|
|
- data[0].ItemList[k].Code = item.ClassifyType
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- }
|
|
|
- data[0].ItemList = data[0].ItemList[:k]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- for _, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = item.ClassifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 1)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[0].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- //if i != 0 {
|
|
|
- // k++
|
|
|
- // fmt.Println(k)
|
|
|
- //}
|
|
|
- data[0].ItemList[0].Code = item.ClassifyType
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- }
|
|
|
- //data[0].ItemList = data[0].ItemList[:k]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// DalianDataList
|
|
|
-// @title 获取大连交易所列表
|
|
|
-// @Description 获取大连交易所列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param ClassifyName query string false "分类名称"
|
|
|
-// @Param ClassifyType query string false "分类合约"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/dalian [get]
|
|
|
-func (this *TradeCommonController) DalianDataList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- classifyName := this.GetString("ClassifyName")
|
|
|
- classifyType := this.GetString("ClassifyType")
|
|
|
- frequencyList, err := data_manage.GetBaseFromTradeIndexByParam("dalian", date, classifyName, classifyType)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var data Data
|
|
|
- var k int
|
|
|
- if len(frequencyList) == 0 {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- data = make(Data, 1)
|
|
|
- fmt.Println("len:", len(frequencyList))
|
|
|
- if len(frequencyList) > 21 {
|
|
|
- for i, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = classifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 200)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[k].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- if i > 0 {
|
|
|
- k++
|
|
|
- }
|
|
|
- data[0].ItemList[k].Code = item.ClassifyType
|
|
|
- data[0].ItemList[k].Item = append(data[0].ItemList[k].Item, item)
|
|
|
- }
|
|
|
- data[0].ItemList = data[0].ItemList[:k]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- } else {
|
|
|
- for _, item := range frequencyList {
|
|
|
- if item.DealCode == "" {
|
|
|
- item.DealValue = ""
|
|
|
- item.DealChange = ""
|
|
|
- }
|
|
|
- if item.BuyCode == "" {
|
|
|
- item.BuyValue = ""
|
|
|
- item.BuyChange = ""
|
|
|
- }
|
|
|
- if item.SoldCode == "" {
|
|
|
- item.SoldValue = ""
|
|
|
- item.SoldChange = ""
|
|
|
- }
|
|
|
- data[0].Title = item.ClassifyName
|
|
|
- if data[0].ItemList == nil {
|
|
|
- list := make([]ShanghaiList, 1)
|
|
|
- data[0].ItemList = list
|
|
|
- }
|
|
|
- if data[0].ItemList[0].Code == item.ClassifyType {
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- continue
|
|
|
- }
|
|
|
- //if i != 0 {
|
|
|
- // k++
|
|
|
- // fmt.Println(k)
|
|
|
- //}
|
|
|
- data[0].ItemList[0].Code = item.ClassifyType
|
|
|
- data[0].ItemList[0].Item = append(data[0].ItemList[0].Item, item)
|
|
|
- }
|
|
|
- //data[0].ItemList = data[0].ItemList[:k]
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// EicLatestDate
|
|
|
-// @title 获取欧洲天然气最新日期
|
|
|
-// @Description 获取欧洲天然气最新日期接口
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/eicLatestDate [get]
|
|
|
-func (this *TradeCommonController) EicLatestDate() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- latestData, err := data_manage.GetEicDate()
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取日期失败"
|
|
|
- br.ErrMsg = "获取日期失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = latestData[0].GasDayStartedOn
|
|
|
-}
|
|
|
-
|
|
|
-// EicContinentList 欧洲天然气洲际及国家级列表
|
|
|
-// @title 获取欧洲天然气列表
|
|
|
-// @Description 获取欧洲天然气列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/eicContinent [get]
|
|
|
-func (this *TradeCommonController) EicContinentList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- continentList, err := data_manage.GetContinentEicDate(date)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- countryList, err := data_manage.GetCountryEicDate(date)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if len(countryList) == 0 || len(continentList) < 1 {
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = []EicData{}
|
|
|
- } else {
|
|
|
- countryLen := len(countryList)
|
|
|
- var euData = EicData{
|
|
|
- Country: "eu",
|
|
|
- Type: "continent",
|
|
|
- EicCode: "eu",
|
|
|
- ShortName: "eu",
|
|
|
- Name: "eu",
|
|
|
- Status: "N",
|
|
|
- GasDayStartedOn: "",
|
|
|
- GasInStorage: 0,
|
|
|
- GasInStorageCode: "euGS",
|
|
|
- Full: 0,
|
|
|
- FullCode: "euF",
|
|
|
- Trend: 0,
|
|
|
- TrendCode: "euT",
|
|
|
- Injection: 0,
|
|
|
- InjectionCode: "euIn",
|
|
|
- Withdrawal: 0,
|
|
|
- WithdrawalCode: "euOut",
|
|
|
- WorkingGasVolume: 0,
|
|
|
- WorkingGasVolumeCode: "euWGV",
|
|
|
- InjectionCapacity: 0,
|
|
|
- InjectionCapacityCode: "euIC",
|
|
|
- WithdrawalCapacity: 0,
|
|
|
- WithdrawalCapacityCode: "euWC",
|
|
|
- Info: "",
|
|
|
- Children: countryList[:countryLen-2],
|
|
|
- }
|
|
|
- var neData = EicData{
|
|
|
- Country: "ne",
|
|
|
- Type: "continent",
|
|
|
- EicCode: "ne",
|
|
|
- ShortName: "ne",
|
|
|
- Name: "ne",
|
|
|
- Status: "N",
|
|
|
- GasDayStartedOn: "",
|
|
|
- GasInStorage: 0,
|
|
|
- GasInStorageCode: "neGS",
|
|
|
- Full: 0,
|
|
|
- FullCode: "neF",
|
|
|
- Trend: 0,
|
|
|
- TrendCode: "neT",
|
|
|
- Injection: 0,
|
|
|
- InjectionCode: "neIn",
|
|
|
- Withdrawal: 0,
|
|
|
- WithdrawalCode: "neOut",
|
|
|
- WorkingGasVolume: 0,
|
|
|
- WorkingGasVolumeCode: "neWGV",
|
|
|
- InjectionCapacity: 0,
|
|
|
- InjectionCapacityCode: "neIC",
|
|
|
- WithdrawalCapacity: 0,
|
|
|
- WithdrawalCapacityCode: "neWC",
|
|
|
- Info: "",
|
|
|
- Children: countryList[countryLen-2:],
|
|
|
- }
|
|
|
- //如果洲际数据正常
|
|
|
- if continentList[0].Country == "eu" {
|
|
|
- gasInStorage, _ := strconv.ParseFloat(continentList[0].GasInStorage, 64)
|
|
|
- full, _ := strconv.ParseFloat(continentList[0].Full, 64)
|
|
|
- trend, _ := strconv.ParseFloat(continentList[0].Trend, 64)
|
|
|
- injection, _ := strconv.ParseFloat(continentList[0].Injection, 64)
|
|
|
- withdrawal, _ := strconv.ParseFloat(continentList[0].Withdrawal, 64)
|
|
|
- workingGasVolume, _ := strconv.ParseFloat(continentList[0].WorkingGasVolume, 64)
|
|
|
- injectionCapacity, _ := strconv.ParseFloat(continentList[0].InjectionCapacity, 64)
|
|
|
- withdrawalCapacity, _ := strconv.ParseFloat(continentList[0].WithdrawalCapacity, 64)
|
|
|
- euData = EicData{
|
|
|
- continentList[0].Country,
|
|
|
- continentList[0].Type,
|
|
|
- continentList[0].EicCode,
|
|
|
- continentList[0].ShortName,
|
|
|
- continentList[0].Name,
|
|
|
- continentList[0].Status,
|
|
|
- continentList[0].GasDayStartedOn,
|
|
|
- gasInStorage,
|
|
|
- continentList[0].GasInStorageCode,
|
|
|
- full,
|
|
|
- continentList[0].FullCode,
|
|
|
- trend,
|
|
|
- continentList[0].TrendCode,
|
|
|
- injection,
|
|
|
- continentList[0].InjectionCode,
|
|
|
- withdrawal,
|
|
|
- continentList[0].WithdrawalCode,
|
|
|
- workingGasVolume,
|
|
|
- continentList[0].WorkingGasVolumeCode,
|
|
|
- injectionCapacity,
|
|
|
- continentList[0].InjectionCapacityCode,
|
|
|
- withdrawalCapacity,
|
|
|
- continentList[0].WithdrawalCapacityCode,
|
|
|
- continentList[0].Info,
|
|
|
- countryList[:countryLen-2],
|
|
|
- }
|
|
|
- if len(continentList) > 1 {
|
|
|
- gasInStorage1, _ := strconv.ParseFloat(continentList[1].GasInStorage, 64)
|
|
|
- full1, _ := strconv.ParseFloat(continentList[1].Full, 64)
|
|
|
- trend1, _ := strconv.ParseFloat(continentList[1].Trend, 64)
|
|
|
- injection1, _ := strconv.ParseFloat(continentList[1].Injection, 64)
|
|
|
- withdrawal1, _ := strconv.ParseFloat(continentList[1].Withdrawal, 64)
|
|
|
- workingGasVolume1, _ := strconv.ParseFloat(continentList[1].WorkingGasVolume, 64)
|
|
|
- injectionCapacity1, _ := strconv.ParseFloat(continentList[1].InjectionCapacity, 64)
|
|
|
- withdrawalCapacity1, _ := strconv.ParseFloat(continentList[1].WithdrawalCapacity, 64)
|
|
|
- neData = EicData{
|
|
|
- continentList[1].Country,
|
|
|
- continentList[1].Type,
|
|
|
- continentList[1].EicCode,
|
|
|
- continentList[1].ShortName,
|
|
|
- continentList[1].Name,
|
|
|
- continentList[1].Status,
|
|
|
- continentList[1].GasDayStartedOn,
|
|
|
- gasInStorage1,
|
|
|
- continentList[1].GasInStorageCode,
|
|
|
- full1,
|
|
|
- continentList[1].FullCode,
|
|
|
- trend1,
|
|
|
- continentList[1].TrendCode,
|
|
|
- injection1,
|
|
|
- continentList[1].InjectionCode,
|
|
|
- withdrawal1,
|
|
|
- continentList[1].WithdrawalCode,
|
|
|
- workingGasVolume1,
|
|
|
- continentList[1].WorkingGasVolumeCode,
|
|
|
- injectionCapacity1,
|
|
|
- continentList[1].InjectionCapacityCode,
|
|
|
- withdrawalCapacity1,
|
|
|
- continentList[1].WithdrawalCapacityCode,
|
|
|
- continentList[1].Info,
|
|
|
- countryList[countryLen-2:],
|
|
|
- }
|
|
|
- }
|
|
|
- } else {
|
|
|
- //数据不正常,只有一个洲际数据时
|
|
|
- if continentList[0].Country == "eu" {
|
|
|
- gasInStorage, _ := strconv.ParseFloat(continentList[0].GasInStorage, 64)
|
|
|
- full, _ := strconv.ParseFloat(continentList[0].Full, 64)
|
|
|
- trend, _ := strconv.ParseFloat(continentList[0].Trend, 64)
|
|
|
- injection, _ := strconv.ParseFloat(continentList[0].Injection, 64)
|
|
|
- withdrawal, _ := strconv.ParseFloat(continentList[0].Withdrawal, 64)
|
|
|
- workingGasVolume, _ := strconv.ParseFloat(continentList[0].WorkingGasVolume, 64)
|
|
|
- injectionCapacity, _ := strconv.ParseFloat(continentList[0].InjectionCapacity, 64)
|
|
|
- withdrawalCapacity, _ := strconv.ParseFloat(continentList[0].WithdrawalCapacity, 64)
|
|
|
- euData = EicData{
|
|
|
- continentList[0].Country,
|
|
|
- continentList[0].Type,
|
|
|
- continentList[0].EicCode,
|
|
|
- continentList[0].ShortName,
|
|
|
- continentList[0].Name,
|
|
|
- continentList[0].Status,
|
|
|
- continentList[0].GasDayStartedOn,
|
|
|
- gasInStorage,
|
|
|
- continentList[0].GasInStorageCode,
|
|
|
- full,
|
|
|
- continentList[0].FullCode,
|
|
|
- trend,
|
|
|
- continentList[0].TrendCode,
|
|
|
- injection,
|
|
|
- continentList[0].InjectionCode,
|
|
|
- withdrawal,
|
|
|
- continentList[0].WithdrawalCode,
|
|
|
- workingGasVolume,
|
|
|
- continentList[0].WorkingGasVolumeCode,
|
|
|
- injectionCapacity,
|
|
|
- continentList[0].InjectionCapacityCode,
|
|
|
- withdrawalCapacity,
|
|
|
- continentList[0].WithdrawalCapacityCode,
|
|
|
- continentList[0].Info,
|
|
|
- countryList[:countryLen-2],
|
|
|
- }
|
|
|
- } else {
|
|
|
- gasInStorage1, _ := strconv.ParseFloat(continentList[0].GasInStorage, 64)
|
|
|
- full1, _ := strconv.ParseFloat(continentList[0].Full, 64)
|
|
|
- trend1, _ := strconv.ParseFloat(continentList[0].Trend, 64)
|
|
|
- injection1, _ := strconv.ParseFloat(continentList[0].Injection, 64)
|
|
|
- withdrawal1, _ := strconv.ParseFloat(continentList[0].Withdrawal, 64)
|
|
|
- workingGasVolume1, _ := strconv.ParseFloat(continentList[0].WorkingGasVolume, 64)
|
|
|
- injectionCapacity1, _ := strconv.ParseFloat(continentList[0].InjectionCapacity, 64)
|
|
|
- withdrawalCapacity1, _ := strconv.ParseFloat(continentList[0].WithdrawalCapacity, 64)
|
|
|
- neData = EicData{
|
|
|
- continentList[0].Country,
|
|
|
- continentList[0].Type,
|
|
|
- continentList[0].EicCode,
|
|
|
- continentList[0].ShortName,
|
|
|
- continentList[0].Name,
|
|
|
- continentList[0].Status,
|
|
|
- continentList[0].GasDayStartedOn,
|
|
|
- gasInStorage1,
|
|
|
- continentList[0].GasInStorageCode,
|
|
|
- full1,
|
|
|
- continentList[0].FullCode,
|
|
|
- trend1,
|
|
|
- continentList[0].TrendCode,
|
|
|
- injection1,
|
|
|
- continentList[0].InjectionCode,
|
|
|
- withdrawal1,
|
|
|
- continentList[0].WithdrawalCode,
|
|
|
- workingGasVolume1,
|
|
|
- continentList[0].WorkingGasVolumeCode,
|
|
|
- injectionCapacity1,
|
|
|
- continentList[0].InjectionCapacityCode,
|
|
|
- withdrawalCapacity1,
|
|
|
- continentList[0].WithdrawalCapacityCode,
|
|
|
- continentList[0].Info,
|
|
|
- countryList[countryLen-2:],
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- var data []EicData
|
|
|
- data = append(data, euData)
|
|
|
- data = append(data, neData)
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// EicDataList 欧洲天然气细节列表
|
|
|
-// @title 获取欧洲天然气列表
|
|
|
-// @Description 获取欧洲天然气列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param Country query string true "国家"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/eicData [get]
|
|
|
-func (this *TradeCommonController) EicDataList() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- country := this.GetString("Country")
|
|
|
- ssoList, err := data_manage.GetSSOEicDate(date, country)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- storageList, err := data_manage.GetStorageEicDate(date, country)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var data []EicData
|
|
|
- for _, sso := range ssoList {
|
|
|
- gasInStorage, _ := strconv.ParseFloat(sso.GasInStorage, 64)
|
|
|
- full, _ := strconv.ParseFloat(sso.Full, 64)
|
|
|
- trend, _ := strconv.ParseFloat(sso.Trend, 64)
|
|
|
- injection, _ := strconv.ParseFloat(sso.Injection, 64)
|
|
|
- withdrawal, _ := strconv.ParseFloat(sso.Withdrawal, 64)
|
|
|
- workingGasVolume, _ := strconv.ParseFloat(sso.WorkingGasVolume, 64)
|
|
|
- injectionCapacity, _ := strconv.ParseFloat(sso.InjectionCapacity, 64)
|
|
|
- withdrawalCapacity, _ := strconv.ParseFloat(sso.WithdrawalCapacity, 64)
|
|
|
- item := EicData{
|
|
|
- sso.Country,
|
|
|
- sso.Type,
|
|
|
- sso.EicCode,
|
|
|
- sso.ShortName,
|
|
|
- sso.Name,
|
|
|
- sso.Status,
|
|
|
- sso.GasDayStartedOn,
|
|
|
- gasInStorage,
|
|
|
- sso.GasInStorageCode,
|
|
|
- full,
|
|
|
- sso.FullCode,
|
|
|
- trend,
|
|
|
- sso.TrendCode,
|
|
|
- injection,
|
|
|
- sso.InjectionCode,
|
|
|
- withdrawal,
|
|
|
- sso.WithdrawalCode,
|
|
|
- workingGasVolume,
|
|
|
- sso.WorkingGasVolumeCode,
|
|
|
- injectionCapacity,
|
|
|
- sso.InjectionCapacityCode,
|
|
|
- withdrawalCapacity,
|
|
|
- sso.WithdrawalCapacityCode,
|
|
|
- sso.Info,
|
|
|
- []*data_manage.BaseFromTradeEicIndex{},
|
|
|
- }
|
|
|
- for _, st := range storageList {
|
|
|
- if item.ShortName == st.ShortName {
|
|
|
- item.Children = append(item.Children, st)
|
|
|
- }
|
|
|
- }
|
|
|
- data = append(data, item)
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
-}
|
|
|
-
|
|
|
-// EicHistoryData
|
|
|
-// @title 获取欧洲天然气历史列表
|
|
|
-// @Description 获取欧洲天然气历史列表接口
|
|
|
-// @Param Code query string true "Code"
|
|
|
-// @Param StartDate query string false "开始时间"
|
|
|
-// @Param EndDate query string false "结束时间"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/eicHistoryData [get]
|
|
|
-func (this *TradeCommonController) EicHistoryData() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- code := this.GetString("Code")
|
|
|
- startDate := this.GetString("StartDate")
|
|
|
- endDate := this.GetString("EndDate")
|
|
|
- var eicList []*data_manage.BaseFromTradeEicIndex
|
|
|
- var err error
|
|
|
- if endDate != "" {
|
|
|
- eicList, err = data_manage.GetEicHistoryDateByDate(code, startDate, endDate)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- } else {
|
|
|
- eicList, err = data_manage.GetEicHistoryDate(code)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
- var data []EicData
|
|
|
- for _, eic := range eicList {
|
|
|
- gasInStorage, _ := strconv.ParseFloat(eic.GasInStorage, 64)
|
|
|
- full, _ := strconv.ParseFloat(eic.Full, 64)
|
|
|
- trend, _ := strconv.ParseFloat(eic.Trend, 64)
|
|
|
- injection, _ := strconv.ParseFloat(eic.Injection, 64)
|
|
|
- withdrawal, _ := strconv.ParseFloat(eic.Withdrawal, 64)
|
|
|
- workingGasVolume, _ := strconv.ParseFloat(eic.WorkingGasVolume, 64)
|
|
|
- injectionCapacity, _ := strconv.ParseFloat(eic.InjectionCapacity, 64)
|
|
|
- withdrawalCapacity, _ := strconv.ParseFloat(eic.WithdrawalCapacity, 64)
|
|
|
- item := EicData{
|
|
|
- eic.Country,
|
|
|
- eic.Type,
|
|
|
- eic.EicCode,
|
|
|
- eic.ShortName,
|
|
|
- eic.Name,
|
|
|
- eic.Status,
|
|
|
- eic.GasDayStartedOn,
|
|
|
- gasInStorage,
|
|
|
- eic.GasInStorageCode,
|
|
|
- full,
|
|
|
- eic.FullCode,
|
|
|
- trend,
|
|
|
- eic.TrendCode,
|
|
|
- injection,
|
|
|
- eic.InjectionCode,
|
|
|
- withdrawal,
|
|
|
- eic.WithdrawalCode,
|
|
|
- workingGasVolume,
|
|
|
- eic.WorkingGasVolumeCode,
|
|
|
- injectionCapacity,
|
|
|
- eic.InjectionCapacityCode,
|
|
|
- withdrawalCapacity,
|
|
|
- eic.WithdrawalCapacityCode,
|
|
|
- eic.Info,
|
|
|
- []*data_manage.BaseFromTradeEicIndex{},
|
|
|
- }
|
|
|
- data = append(data, item)
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
-}
|
|
|
-
|
|
|
-//// EicHistoryDataByDate
|
|
|
-//// @title 根据时间获取欧洲天然气历史列表
|
|
|
-//// @Description 根据时间获取欧洲天然气历史列表
|
|
|
-//// @Param Code query string true "Code"
|
|
|
-//// @Param Date1 query string true "时间1"
|
|
|
-//// @Param Date2 query string true "时间2"
|
|
|
-//// @Success 200 {object} models.
|
|
|
-//// @router /data/eicHistoryDataByDate [get]
|
|
|
-//func (this *TradeCommonController) EicHistoryDataByDate() {
|
|
|
-// br := new(models.BaseResponse).Init()
|
|
|
-// defer func() {
|
|
|
-// this.Data["json"] = br
|
|
|
-// this.ServeJSON()
|
|
|
-// }()
|
|
|
-// code := this.GetString("Code")
|
|
|
-// date1 := this.GetString("Date1")
|
|
|
-// date2 := this.GetString("Date2")
|
|
|
-// eicList, err := data_manage.GetEicHistoryDateByDate(code,date1,date2)
|
|
|
-// if err != nil {
|
|
|
-// br.Msg = "获取持仓排名失败"
|
|
|
-// br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
-// return
|
|
|
-// }
|
|
|
-// var data []EicData
|
|
|
-// for _, eic := range eicList {
|
|
|
-// gasInStorage, _ := strconv.ParseFloat(eic.GasInStorage, 64)
|
|
|
-// full, _ := strconv.ParseFloat(eic.Full, 64)
|
|
|
-// trend, _ := strconv.ParseFloat(eic.Trend, 64)
|
|
|
-// injection, _ := strconv.ParseFloat(eic.Injection, 64)
|
|
|
-// withdrawal, _ := strconv.ParseFloat(eic.Withdrawal, 64)
|
|
|
-// workingGasVolume, _ := strconv.ParseFloat(eic.WorkingGasVolume, 64)
|
|
|
-// injectionCapacity, _ := strconv.ParseFloat(eic.InjectionCapacity, 64)
|
|
|
-// withdrawalCapacity, _ := strconv.ParseFloat(eic.WithdrawalCapacity, 64)
|
|
|
-// item := EicData{
|
|
|
-// eic.Country,
|
|
|
-// eic.Type,
|
|
|
-// eic.EicCode,
|
|
|
-// eic.ShortName,
|
|
|
-// eic.Name,
|
|
|
-// eic.Status,
|
|
|
-// eic.GasDayStartedOn,
|
|
|
-// gasInStorage,
|
|
|
-// eic.GasInStorageCode,
|
|
|
-// full,
|
|
|
-// eic.FullCode,
|
|
|
-// trend,
|
|
|
-// eic.TrendCode,
|
|
|
-// injection,
|
|
|
-// eic.InjectionCode,
|
|
|
-// withdrawal,
|
|
|
-// eic.WithdrawalCode,
|
|
|
-// workingGasVolume,
|
|
|
-// eic.WorkingGasVolumeCode,
|
|
|
-// injectionCapacity,
|
|
|
-// eic.InjectionCapacityCode,
|
|
|
-// withdrawalCapacity,
|
|
|
-// eic.WithdrawalCapacityCode,
|
|
|
-// eic.Info,
|
|
|
-// []*data_manage.BaseFromTradeEicIndex{},
|
|
|
-// }
|
|
|
-// data = append(data, item)
|
|
|
-// }
|
|
|
-//
|
|
|
-// br.Ret = 200
|
|
|
-// br.Success = true
|
|
|
-// br.Msg = "获取成功"
|
|
|
-// br.Data = data
|
|
|
-//}
|
|
|
-
|
|
|
-// CoalMineClassify
|
|
|
-// @title 获取中国煤炭市场网分类列表
|
|
|
-// @Description 获取中国煤炭市场网分类列表
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/coalMineData/classify [get]
|
|
|
-func (this *TradeCommonController) CoalMineClassify() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- var coalList []data_manage.BaseFromCoalmineClassifyItem
|
|
|
- var suffix string
|
|
|
- var coal data_manage.BaseFromCoalmineClassifyItem
|
|
|
- groups := []*string{}
|
|
|
- var childs []data_manage.CoalChild
|
|
|
- var child data_manage.CoalChild
|
|
|
-
|
|
|
- list, err := data_manage.GetCoalmineClassifyList()
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- for _, v := range list {
|
|
|
- if v.Suffix == "jsm_index" {
|
|
|
- suffix = "jsm_index"
|
|
|
- groups, err = data_manage.GetProvinceFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- coal.ClassifyId = 1
|
|
|
- coal.ClassifyName = "晋陕蒙三省煤矿产量周度数据"
|
|
|
- jsmId := 100
|
|
|
- for _, group := range groups {
|
|
|
- jsmId++
|
|
|
- child.ClassifyId = jsmId
|
|
|
- child.ClassifyName = *group
|
|
|
- childs = append(childs, child)
|
|
|
- }
|
|
|
-
|
|
|
- coal.Child = childs
|
|
|
- coalList = append(coalList, coal)
|
|
|
- }
|
|
|
-
|
|
|
- if v.Suffix == "company_index" {
|
|
|
- suffix = "company_index"
|
|
|
- groups = []*string{}
|
|
|
- childs = []data_manage.CoalChild{}
|
|
|
- groups, err = data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- coal.ClassifyId = 2
|
|
|
- coal.ClassifyName = "442家晋陕蒙煤矿周度产量"
|
|
|
- companyId := 200
|
|
|
- for _, group := range groups {
|
|
|
- companyId++
|
|
|
- child.ClassifyId = companyId
|
|
|
- child.ClassifyName = *group
|
|
|
- childs = append(childs, child)
|
|
|
- }
|
|
|
- coal.Child = childs
|
|
|
- coalList = append(coalList, coal)
|
|
|
- }
|
|
|
-
|
|
|
- if v.Suffix == "firm_index" {
|
|
|
- suffix = "firm_index"
|
|
|
- groups = []*string{}
|
|
|
- childs = []data_manage.CoalChild{}
|
|
|
- groups, err = data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- coal.ClassifyId = 3
|
|
|
- coal.ClassifyName = "全国分企业煤炭产量旬度数据"
|
|
|
- firmId := 300
|
|
|
- for _, group := range groups {
|
|
|
- firmId++
|
|
|
- child.ClassifyId = firmId
|
|
|
- child.ClassifyName = *group
|
|
|
- childs = append(childs, child)
|
|
|
-
|
|
|
- }
|
|
|
- coal.Child = childs
|
|
|
- coalList = append(coalList, coal)
|
|
|
- }
|
|
|
-
|
|
|
- if v.Suffix == "coastal_index" {
|
|
|
- suffix = "coastal_index"
|
|
|
- groups = []*string{}
|
|
|
- childs = []data_manage.CoalChild{}
|
|
|
- groups, err = data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- coal.ClassifyId = 4
|
|
|
- coal.ClassifyName = "沿海八省动力煤终端用户供耗存"
|
|
|
- coastalId := 400
|
|
|
- for _, group := range groups {
|
|
|
- coastalId++
|
|
|
- child.ClassifyId = coastalId
|
|
|
- child.ClassifyName = *group
|
|
|
- childs = append(childs, child)
|
|
|
-
|
|
|
- }
|
|
|
- coal.Child = childs
|
|
|
- coalList = append(coalList, coal)
|
|
|
- }
|
|
|
-
|
|
|
- if v.Suffix == "inland_index" {
|
|
|
- suffix = "inland_index"
|
|
|
- groups = []*string{}
|
|
|
- childs = []data_manage.CoalChild{}
|
|
|
- groups, err = data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- coal.ClassifyId = 5
|
|
|
- coal.ClassifyName = "内陆17省动力煤终端用户供耗存"
|
|
|
- inlandId := 500
|
|
|
- for _, group := range groups {
|
|
|
- inlandId++
|
|
|
- child.ClassifyId = inlandId
|
|
|
- child.ClassifyName = *group
|
|
|
- childs = append(childs, child)
|
|
|
-
|
|
|
- }
|
|
|
- coal.Child = childs
|
|
|
- coalList = append(coalList, coal)
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = coalList
|
|
|
-}
|
|
|
-
|
|
|
-// CoalMineFrequency
|
|
|
-// @title 获取中国煤炭市场网频度
|
|
|
-// @Description 获取中国煤炭市场网频度
|
|
|
-// @Param ClassifyId query int true "数据id"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/coalMineData/frequency [get]
|
|
|
-func (this *TradeCommonController) CoalMineFrequency() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
-
|
|
|
- classifyId, _ := this.GetInt("ClassifyId")
|
|
|
- var suffix string
|
|
|
- if classifyId == 1 {
|
|
|
- suffix = "jsm_index"
|
|
|
- } else if classifyId == 2 {
|
|
|
- suffix = "company_index"
|
|
|
- } else if classifyId == 3 {
|
|
|
- suffix = "firm_index"
|
|
|
- } else if classifyId == 4 {
|
|
|
- suffix = "coastal_index"
|
|
|
- } else if classifyId == 5 {
|
|
|
- suffix = "inland_index"
|
|
|
- }
|
|
|
- frequency, err := data_manage.GetFrequencyFromCoal(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭频度数据失败"
|
|
|
- br.ErrMsg = "获取煤炭频度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var resp data_manage.FrequencyResp
|
|
|
- switch *frequency {
|
|
|
- case "日度":
|
|
|
- resp.Frequency = 1
|
|
|
- case "周度":
|
|
|
- resp.Frequency = 2
|
|
|
- case "旬度":
|
|
|
- resp.Frequency = 3
|
|
|
- case "月度":
|
|
|
- resp.Frequency = 4
|
|
|
- case "季度":
|
|
|
- resp.Frequency = 5
|
|
|
- case "年度":
|
|
|
- resp.Frequency = 6
|
|
|
- default:
|
|
|
- resp.Frequency = 99
|
|
|
- }
|
|
|
- var list []data_manage.FrequencyResp
|
|
|
- list = append(list, resp)
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = list
|
|
|
-}
|
|
|
-
|
|
|
-// CoalMineData
|
|
|
-// @title 获取中国煤炭市场网详细数据列表
|
|
|
-// @Description 获取中国煤炭市场网详细数据接口
|
|
|
-// @Param ClassifyId query int true "数据id"
|
|
|
-// @Param GroupName query string true "分组名"
|
|
|
-// @Param Frequency query string true "频度"
|
|
|
-// @Param PageSize query int true "每页数据条数"
|
|
|
-// @Param CurrentIndex query int true "当前页页码,从1开始"
|
|
|
-// @Success 200 {object} []data_manage.CoalmineDataResp
|
|
|
-// @router /data/coalMineData/data [get]
|
|
|
-func (this *TradeCommonController) CoalMineData() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- classifyId, _ := this.GetInt("ClassifyId")
|
|
|
- frequency := this.GetString("Frequency")
|
|
|
- groupName := this.GetString("GroupName")
|
|
|
- pageSize, _ := this.GetInt("PageSize")
|
|
|
- currentIndex, _ := this.GetInt("CurrentIndex")
|
|
|
- var startSize int
|
|
|
-
|
|
|
- if pageSize <= 0 {
|
|
|
- pageSize = utils.PageSize20
|
|
|
- }
|
|
|
- if currentIndex <= 0 {
|
|
|
- currentIndex = 1
|
|
|
- }
|
|
|
- startSize = utils.StartIndex(currentIndex, pageSize)
|
|
|
- //var groups []*string
|
|
|
- //var err error
|
|
|
- //var suffix string
|
|
|
- //if classifyId == 1 {
|
|
|
- // suffix = "jsm_index"
|
|
|
- //} else if classifyId == 2 {
|
|
|
- // suffix = "company_index"
|
|
|
- //} else if classifyId == 3 {
|
|
|
- // suffix = "firm_index"
|
|
|
- //} else if classifyId == 4 {
|
|
|
- // suffix = "coastal_index"
|
|
|
- //} else if classifyId == 5 {
|
|
|
- // suffix = "inland_index"
|
|
|
- //}
|
|
|
-
|
|
|
- switch classifyId {
|
|
|
- case 1:
|
|
|
- classifies, err := data_manage.GetClassifyCoalmineIndexByGroupName(groupName)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineDataPageResp
|
|
|
- for _, classify := range classifies {
|
|
|
- items, err := data_manage.GetPageFromCoalmineIndexByFrequency(frequency, *classify, startSize, pageSize)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- total, err := data_manage.GetCountFromJsm(*classify)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page := paging.GetPaging(currentIndex, pageSize, total)
|
|
|
- var resp data_manage.CoalmineDataPageResp
|
|
|
- for i, item := range items {
|
|
|
- if i == 0 {
|
|
|
- resp.ModifyTime = item.CreateTime
|
|
|
- }
|
|
|
- resp.Paging = page
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.Frequency = item.Frequency
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
- }
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 2:
|
|
|
- classifies, err := data_manage.GetClassifyCompanyByGroupName(groupName)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineDataPageResp
|
|
|
- for _, classify := range classifies {
|
|
|
- items, err := data_manage.GetPageFromCoalmineCompanyIndexByFrequency(frequency, *classify, startSize, pageSize)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- total, err := data_manage.GetCountFromCompany(*classify)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page := paging.GetPaging(currentIndex, pageSize, total)
|
|
|
- var resp data_manage.CoalmineDataPageResp
|
|
|
- for i, item := range items {
|
|
|
- if i == 0 {
|
|
|
- resp.ModifyTime = item.CreateTime
|
|
|
- }
|
|
|
- resp.Paging = page
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.Frequency = item.Frequency
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
- }
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 3:
|
|
|
- classifies, err := data_manage.GetClassifyFirmByGroupName(groupName)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineDataPageResp
|
|
|
- for _, classify := range classifies {
|
|
|
- items, err := data_manage.GetPageFromCoalmineFirmIndexByFrequency(frequency, *classify, startSize, pageSize)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- total, err := data_manage.GetCountFromFirm(*classify)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page := paging.GetPaging(currentIndex, pageSize, total)
|
|
|
- var resp data_manage.CoalmineDataPageResp
|
|
|
- for i, item := range items {
|
|
|
- if i == 0 {
|
|
|
- resp.ModifyTime = item.CreateTime
|
|
|
- }
|
|
|
- resp.Paging = page
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.Frequency = item.Frequency
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
- }
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 4:
|
|
|
- classifies, err := data_manage.GetClassifyCoastalByGroupName(groupName)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineDataPageResp
|
|
|
- for _, classify := range classifies {
|
|
|
- items, err := data_manage.GetPageFromCoalmineCoastalIndexByFrequency(frequency, *classify, startSize, pageSize)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- total, err := data_manage.GetCountFromCoastal(*classify)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page := paging.GetPaging(currentIndex, pageSize, total)
|
|
|
- var resp data_manage.CoalmineDataPageResp
|
|
|
- for i, item := range items {
|
|
|
- if i == 0 {
|
|
|
- resp.ModifyTime = item.CreateTime
|
|
|
- }
|
|
|
- resp.Paging = page
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.Frequency = item.Frequency
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
- }
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 5:
|
|
|
- classifies, err := data_manage.GetClassifyInlandByGroupName(groupName)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineDataPageResp
|
|
|
- for _, classify := range classifies {
|
|
|
- items, err := data_manage.GetPageFromCoalmineInlandIndexByFrequency(frequency, *classify, startSize, pageSize)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- total, err := data_manage.GetCountFromInland(*classify)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- page := paging.GetPaging(currentIndex, pageSize, total)
|
|
|
- var resp data_manage.CoalmineDataPageResp
|
|
|
- for i, item := range items {
|
|
|
- if i == 0 {
|
|
|
- resp.ModifyTime = item.CreateTime
|
|
|
- }
|
|
|
- resp.Paging = page
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.Frequency = item.Frequency
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
- }
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- default:
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err: classifyId 错误"
|
|
|
- return
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// CoalSingleData
|
|
|
-// @Title 获取煤炭单条数据
|
|
|
-// @Description 获取煤炭单条数据
|
|
|
-// @Param IndexCode query string true "指标唯一编码"
|
|
|
-// @Success 200 {object} []data_manage.CoalmineSingalDataResp
|
|
|
-// @router /data/coalMineData/single_data [get]
|
|
|
-func (this *TradeCommonController) CoalSingleData() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- indexCode := this.GetString("IndexCode")
|
|
|
- var classifyId int
|
|
|
- var suffix string
|
|
|
- if strings.Contains(indexCode, "jsm") {
|
|
|
- classifyId = 1
|
|
|
- suffix = "jsm_index"
|
|
|
- } else if strings.Contains(indexCode, "company") {
|
|
|
- classifyId = 2
|
|
|
- suffix = "company_index"
|
|
|
- } else if strings.Contains(indexCode, "firm") {
|
|
|
- classifyId = 3
|
|
|
- suffix = "firm_index"
|
|
|
- } else if strings.Contains(indexCode, "coastal") {
|
|
|
- classifyId = 4
|
|
|
- suffix = "coastal_index"
|
|
|
- } else if strings.Contains(indexCode, "inland") {
|
|
|
- classifyId = 5
|
|
|
- suffix = "inland_index"
|
|
|
- }
|
|
|
-
|
|
|
- switch classifyId {
|
|
|
- case 1:
|
|
|
- items, err := data_manage.GetBaseFromCoalmineIndexByCode(indexCode)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groups, err := data_manage.GetProvinceFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groupMap := make(map[string]int)
|
|
|
- jsmId := 100
|
|
|
- for _, group := range groups {
|
|
|
- jsmId++
|
|
|
- groupMap[*group] = jsmId
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineSingalDataResp
|
|
|
- var resp data_manage.CoalmineSingalDataResp
|
|
|
-
|
|
|
- classify := items[0].IndexName
|
|
|
- for i, item := range items {
|
|
|
- if item.IndexName != classify {
|
|
|
- lists = append(lists, resp)
|
|
|
- classify = item.IndexName
|
|
|
- }
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.GroupId = groupMap[item.Province]
|
|
|
- resp.GroupName = item.Province
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.Frequency = item.Frequency
|
|
|
- resp.ModifyTime = item.ModifyTime
|
|
|
- resp.ClassifyId = classifyId
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
-
|
|
|
- if i == len(items)-1 {
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 2:
|
|
|
- items, err := data_manage.GetBaseFromCoalmineCompanyIndexByCode(indexCode)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groups, err := data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groupMap := make(map[string]int)
|
|
|
- companyId := 200
|
|
|
- for _, group := range groups {
|
|
|
- companyId++
|
|
|
- groupMap[*group] = companyId
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineSingalDataResp
|
|
|
- var resp data_manage.CoalmineSingalDataResp
|
|
|
-
|
|
|
- classify := items[0].IndexName
|
|
|
- for i, item := range items {
|
|
|
- if item.IndexName != classify {
|
|
|
- lists = append(lists, resp)
|
|
|
- classify = item.IndexName
|
|
|
- }
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.GroupId = groupMap[item.GroupName]
|
|
|
- resp.GroupName = item.GroupName
|
|
|
- resp.Frequency = item.Frequency
|
|
|
- resp.ModifyTime = item.ModifyTime
|
|
|
- resp.ClassifyId = classifyId
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
-
|
|
|
- if i == len(items)-1 {
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 3:
|
|
|
- items, err := data_manage.GetBaseFromCoalmineFirmIndexByCode(indexCode)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groups, err := data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groupMap := make(map[string]int)
|
|
|
- firmId := 300
|
|
|
- for _, group := range groups {
|
|
|
- firmId++
|
|
|
- groupMap[*group] = firmId
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineSingalDataResp
|
|
|
- var resp data_manage.CoalmineSingalDataResp
|
|
|
-
|
|
|
- classify := items[0].IndexName
|
|
|
- for i, item := range items {
|
|
|
- if item.IndexName != classify {
|
|
|
- lists = append(lists, resp)
|
|
|
- classify = item.IndexName
|
|
|
- }
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.GroupId = groupMap[item.GroupName]
|
|
|
- resp.GroupName = item.GroupName
|
|
|
- resp.Frequency = item.Frequency
|
|
|
- resp.ModifyTime = item.ModifyTime
|
|
|
- resp.ClassifyId = classifyId
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
-
|
|
|
- if i == len(items)-1 {
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 4:
|
|
|
- items, err := data_manage.GetBaseFromCoalmineCoastalIndexByCode(indexCode)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groups, err := data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groupMap := make(map[string]int)
|
|
|
- coastalId := 400
|
|
|
- for _, group := range groups {
|
|
|
- coastalId++
|
|
|
- groupMap[*group] = coastalId
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineSingalDataResp
|
|
|
- var resp data_manage.CoalmineSingalDataResp
|
|
|
-
|
|
|
- classify := items[0].IndexName
|
|
|
- for i, item := range items {
|
|
|
- if item.IndexName != classify {
|
|
|
- lists = append(lists, resp)
|
|
|
- classify = item.IndexName
|
|
|
- }
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.GroupId = groupMap[item.GroupName]
|
|
|
- resp.GroupName = item.GroupName
|
|
|
- resp.Frequency = item.Frequency
|
|
|
- resp.ModifyTime = item.ModifyTime
|
|
|
- resp.ClassifyId = classifyId
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
-
|
|
|
- if i == len(items)-1 {
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- case 5:
|
|
|
- items, err := data_manage.GetBaseFromCoalmineInlandIndexByCode(indexCode)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groups, err := data_manage.GetGroupNameFromCoalmineIndex(suffix)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取煤炭分类数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度分类数据失败,Err: " + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- groupMap := make(map[string]int)
|
|
|
- inlandId := 500
|
|
|
- for _, group := range groups {
|
|
|
- inlandId++
|
|
|
- groupMap[*group] = inlandId
|
|
|
- }
|
|
|
- var lists []data_manage.CoalmineSingalDataResp
|
|
|
- var resp data_manage.CoalmineSingalDataResp
|
|
|
-
|
|
|
- classify := items[0].IndexName
|
|
|
- for i, item := range items {
|
|
|
- if item.IndexName != classify {
|
|
|
- lists = append(lists, resp)
|
|
|
- classify = item.IndexName
|
|
|
- }
|
|
|
- resp.IndexName = item.IndexName
|
|
|
- resp.IndexCode = item.IndexCode
|
|
|
- resp.Unit = item.Unit
|
|
|
- resp.GroupId = groupMap[item.GroupName]
|
|
|
- resp.GroupName = item.GroupName
|
|
|
- resp.Frequency = item.Frequency
|
|
|
- resp.ModifyTime = item.ModifyTime
|
|
|
- resp.ClassifyId = classifyId
|
|
|
-
|
|
|
- //组装dataList
|
|
|
- var dataItem data_manage.DataList
|
|
|
- dataItem.DataTime = item.DataTime
|
|
|
- dataItem.Value = item.DealValue
|
|
|
- resp.DataList = append(resp.DataList, dataItem)
|
|
|
-
|
|
|
- if i == len(items)-1 {
|
|
|
- lists = append(lists, resp)
|
|
|
- }
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = lists
|
|
|
- default:
|
|
|
- br.Msg = "获取煤炭数据失败"
|
|
|
- br.ErrMsg = "获取煤炭度数据失败,Err: indexCode 错误"
|
|
|
- return
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-// EicLatestDateV2
|
|
|
-// @title 获取欧洲天然气最新日期V2
|
|
|
-// @Description 获取欧洲天然气最新日期接口
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/eicLatestDateV2 [get]
|
|
|
-func (this *TradeCommonController) EicLatestDateV2() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- latestData, err := data_manage.GetEicDateV2()
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取日期失败"
|
|
|
- br.ErrMsg = "获取日期失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = latestData[0].GasDayStart
|
|
|
-}
|
|
|
-
|
|
|
-type EicDataV2 struct {
|
|
|
- Name string `json:"name" description:"指标名称"`
|
|
|
- Code string `json:"code" description:"指标编码"`
|
|
|
- GasDayStart string `json:"gasDayStart" description:"指标日期"`
|
|
|
- GasInStorage float64 `json:"gasInStorage" description:"储存容量"`
|
|
|
- Consumption string `json:"consumption" description:"消耗"`
|
|
|
- ConsumptionFull string `json:"consumptionFull" description:"消耗百分比"`
|
|
|
- Injection float64 `json:"injection" description:"注入量"`
|
|
|
- Withdrawal float64 `json:"withdrawal" description:"减少量"`
|
|
|
- WorkingGasVolume float64 `json:"workingGasVolume" description:"工作气体量"`
|
|
|
- InjectionCapacity float64 `json:"injectionCapacity" description:"注入速度"`
|
|
|
- WithdrawalCapacity float64 `json:"withdrawalCapacity" description:"减少速度"`
|
|
|
- Status string `json:"status" description:"状态"`
|
|
|
- Trend float64 `json:"trend" description:"较前日对比"`
|
|
|
- Full float64 `json:"full" description:"储存容量百分比"`
|
|
|
- Info string `json:"info" description:"信息"`
|
|
|
- Children []EicDataV2 `json:"children"`
|
|
|
-}
|
|
|
-
|
|
|
-// eicDataV2
|
|
|
-// @title 获取欧洲天然气列表
|
|
|
-// @Description 获取欧洲天然气列表接口
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Success 200 {object} models.
|
|
|
-// @router /data/eicDataV2 [get]
|
|
|
-func (this *TradeCommonController) EicDataV2() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- list, err := data_manage.GetEicDataV2(date)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取天然气数据失败"
|
|
|
- br.ErrMsg = "获取天然气数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- var continentItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- var countryItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- var ssoItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- var facItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- for _, item := range list {
|
|
|
- switch item.Type {
|
|
|
- case "continent":
|
|
|
- continentItems = append(continentItems, *item)
|
|
|
- case "country":
|
|
|
- countryItems = append(countryItems, *item)
|
|
|
- case "sso":
|
|
|
- ssoItems = append(ssoItems, *item)
|
|
|
- case "fac":
|
|
|
- facItems = append(facItems, *item)
|
|
|
- default:
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
- var data []data_manage.BaseFromTradeEicIndexV2
|
|
|
- data = continentItems
|
|
|
- for i, continentItem := range continentItems {
|
|
|
- for _, countryItem := range countryItems {
|
|
|
- if countryItem.Parent == continentItem.Name {
|
|
|
- data[i].Children = append(data[i].Children, countryItem)
|
|
|
- }
|
|
|
- }
|
|
|
- for j, country := range data[i].Children {
|
|
|
- for _, ssoItem := range ssoItems {
|
|
|
- if country.Name == ssoItem.Parent {
|
|
|
- data[i].Children[j].Children = append(data[i].Children[j].Children, ssoItem)
|
|
|
- }
|
|
|
- }
|
|
|
- for k, sso := range data[i].Children[j].Children {
|
|
|
- for _, facItem := range facItems {
|
|
|
- if sso.Name == facItem.Parent {
|
|
|
- data[i].Children[j].Children[k].Children = append(data[i].Children[j].Children[k].Children, facItem)
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
-}
|
|
|
-
|
|
|
-// EicHistoryDataV2
|
|
|
-// @title 获取欧洲天然气历史列表
|
|
|
-// @Description 获取欧洲天然气历史列表接口
|
|
|
-// @Param Code query string true "Code"
|
|
|
-// @Param StartDate query string false "开始时间"
|
|
|
-// @Param EndDate query string false "结束时间"
|
|
|
-// @Success 200 {object} []EicDataV2
|
|
|
-// @router /data/eicHistoryDataV2 [get]
|
|
|
-func (this *TradeCommonController) EicHistoryDataV2() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- code := this.GetString("Code")
|
|
|
- startDate := this.GetString("StartDate")
|
|
|
- endDate := this.GetString("EndDate")
|
|
|
- var eicList []*data_manage.BaseFromTradeEicIndexV2
|
|
|
- var err error
|
|
|
- if endDate != "" {
|
|
|
- eicList, err = data_manage.GetEicHistoryDateByDateV2(code, startDate, endDate)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- } else {
|
|
|
- eicList, err = data_manage.GetEicHistoryDateV2(code)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取持仓排名失败"
|
|
|
- br.ErrMsg = "获取持仓排名失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- var data []EicDataV2
|
|
|
- for _, eic := range eicList {
|
|
|
- item := EicDataV2{
|
|
|
- Name: eic.Name,
|
|
|
- Code: eic.EicCode,
|
|
|
- GasDayStart: eic.GasDayStart,
|
|
|
- GasInStorage: eic.GasInStorage,
|
|
|
- Consumption: eic.Consumption,
|
|
|
- ConsumptionFull: eic.ConsumptionFull,
|
|
|
- Injection: eic.Injection,
|
|
|
- Withdrawal: eic.Withdrawal,
|
|
|
- WorkingGasVolume: eic.WorkingGasVolume,
|
|
|
- InjectionCapacity: eic.InjectionCapacity,
|
|
|
- WithdrawalCapacity: eic.WithdrawalCapacity,
|
|
|
- Status: eic.Status,
|
|
|
- Trend: eic.Trend,
|
|
|
- Full: eic.Full,
|
|
|
- Info: eic.Info,
|
|
|
- }
|
|
|
- data = append(data, item)
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
-}
|
|
|
-
|
|
|
-// eicContinentV2 欧洲天然气洲际及国家级列表
|
|
|
-// @title 欧洲天然气洲际及国家级列表
|
|
|
-// @Description 欧洲天然气洲际及国家级列表
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Success 200 {object} []data_manage.BaseFromTradeEicIndexV2
|
|
|
-// @router /data/eicContinentV2 [get]
|
|
|
-func (this *TradeCommonController) EicContinentListV2() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- list, err := data_manage.GetContinentAndCountryEicDateV2(date)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取天然气数据失败"
|
|
|
- br.ErrMsg = "获取天然气数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- var continentItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- var countryItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- for _, item := range list {
|
|
|
- switch item.Type {
|
|
|
- case "continent":
|
|
|
- continentItems = append(continentItems, *item)
|
|
|
- case "country":
|
|
|
- countryItems = append(countryItems, *item)
|
|
|
- default:
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
- var data []data_manage.BaseFromTradeEicIndexV2
|
|
|
- data = continentItems
|
|
|
- for i, continentItem := range continentItems {
|
|
|
- for _, countryItem := range countryItems {
|
|
|
- if countryItem.Parent == continentItem.Name {
|
|
|
- data[i].Children = append(data[i].Children, countryItem)
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
-}
|
|
|
-
|
|
|
-// EicDataListV2 欧洲天然气细节列表
|
|
|
-// @title 欧洲天然气细节列表
|
|
|
-// @Description 欧洲天然气细节列表
|
|
|
-// @Param Date query string true "查询日期"
|
|
|
-// @Param Name query string true "国家"
|
|
|
-// @Success 200 {object} []data_manage.BaseFromTradeEicIndexV2
|
|
|
-// @router /data/eicSSODataV2 [get]
|
|
|
-func (this *TradeCommonController) EicDataListV2() {
|
|
|
- br := new(models.BaseResponse).Init()
|
|
|
- defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
- }()
|
|
|
- date := this.GetString("Date")
|
|
|
- name := this.GetString("Name")
|
|
|
- list, err := data_manage.GetSSOAndFacEicDateV2(date, name)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取天然气数据失败"
|
|
|
- br.ErrMsg = "获取天然气数据失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- var ssoItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- var facItems []data_manage.BaseFromTradeEicIndexV2
|
|
|
- for _, item := range list {
|
|
|
- switch item.Type {
|
|
|
- case "sso":
|
|
|
- ssoItems = append(ssoItems, *item)
|
|
|
- case "fac":
|
|
|
- facItems = append(facItems, *item)
|
|
|
- default:
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
- i := 0
|
|
|
- var data []data_manage.BaseFromTradeEicIndexV2
|
|
|
- for _, ssoItem := range ssoItems {
|
|
|
- if ssoItem.Parent == name {
|
|
|
- data = append(data, ssoItem)
|
|
|
- for _, facItem := range facItems {
|
|
|
- if facItem.Parent == ssoItem.Name {
|
|
|
- data[i].Children = append(data[i].Children, facItem)
|
|
|
- }
|
|
|
- }
|
|
|
- i++
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- br.Ret = 200
|
|
|
- br.Success = true
|
|
|
- br.Msg = "获取成功"
|
|
|
- br.Data = data
|
|
|
-}
|