Merge branch 'fix/coal_source_name'

controllers/base_from_coal.go

@@ -9,7 +9,7 @@ import (
 	"time"
 )
 
-// 中国煤炭网
+// 中国煤炭市场网
 type CoalController struct {
 	BaseAuthController
 }
@@ -58,8 +58,8 @@ func (this *CoalController) Add() {
 	}
 }
 
-// @Title 刷新中国煤炭网指标接口
-// @Description 刷新中国煤炭网指标接口
+// @Title 刷新中国煤炭市场网指标接口
+// @Description 刷新中国煤炭市场网指标接口
 // @Success 200 {object} models.RefreshEdbInfoReq
 // @router /refresh [post]
 func (this *CoalController) Refresh() {

controllers/base_from_mtjh.go

@@ -15,7 +15,6 @@ type MtjhDataController struct {
 	BaseAuthController
 }
 
-
 // @Title 煤炭江湖数据
 // @Description 刷新煤炭江湖数据接口
 // @Param	request	body models.CoalMineDataReq true "type json string"
@@ -165,7 +164,7 @@ func (this *MtjhDataController) Mtjh() {
 									if len(py) > 0 {
 										pys = append(pys, py)
 									} else {
-										if r != '-' && r != '（'  && r != '）'{
+										if r != '-' && r != '（' && r != '）' {
 											pys = append(pys, []string{string(r)})
 										}
 									}
@@ -224,7 +223,7 @@ func (this *MtjhDataController) Mtjh() {
 	if len(mappingAddList) > 0 {
 		newId, err := models.AddBaseFromMtjhMappingMuti(mappingAddList)
 		if err != nil {
-			fmt.Println("添加指标名称错误",err.Error())
+			fmt.Println("添加指标名称错误", err.Error())
 		} else {
 			fmt.Println("添加指标名称成功", newId)
 		}
@@ -250,7 +249,7 @@ func (this *MtjhDataController) Mtjh() {
 	if len(indexAddList) > 0 {
 		newId, err := models.AddBaseFromMtjhIndexMuti(indexAddList)
 		if err != nil {
-			fmt.Println("添加指标名称错误",err.Error())
+			fmt.Println("添加指标名称错误", err.Error())
 		} else {
 			fmt.Println("添加指标名称成功", newId)
 		}
@@ -263,7 +262,6 @@ func (this *MtjhDataController) Mtjh() {
 	return
 }
 
-
 // @Title 新增煤炭网指标接口
 // @Description 新增煤炭网指标接口
 // @Success 200 {object} models.AddEdbInfoReq
@@ -308,8 +306,8 @@ func (this *MtjhDataController) Add() {
 	}
 }
 
-// @Title 刷新中国煤炭网指标接口
-// @Description 刷新中国煤炭网指标接口
+// @Title 刷新中国煤炭市场网指标接口
+// @Description 刷新中国煤炭市场网指标接口
 // @Success 200 {object} models.RefreshEdbInfoReq
 // @router /refresh [post]
 func (this *MtjhDataController) Refresh() {

models/edb_info.go

@@ -1135,7 +1135,7 @@ func EdbInfoAdd(req *AddEdbInfoParams, serverUrl string, sysUserId int, sysUserR
 		utils.DATA_SOURCE_SHFE:                "上期能源",
 		utils.DATA_SOURCE_GIE:                 "欧洲天然气",
 		utils.DATA_SOURCE_LT:                  "路透",
-		utils.DATA_SOURCE_COAL:                "中国煤炭网",
+		utils.DATA_SOURCE_COAL:                "中国煤炭市场网",
 		utils.DATA_SOURCE_GOOGLE_TRAVEL:       "our world in data",
 		utils.DATA_SOURCE_MYSTEEL_CHEMICAL:    "钢联化工",
 		utils.DATA_SOURCE_EIA_STEO:            "EIA STEO报告",

utils/constants.go

@@ -137,7 +137,7 @@ const (
 	DATA_SOURCE_NAME_CALCULATE_ZJPJ                       = `直接拼接`              //直接拼接->23
 	DATA_SOURCE_NAME_CALCULATE_LJZTBPJ                    = `累计值同比拼接`           //累计值同比拼接->24
 	DATA_SOURCE_NAME_LT                                   = `路透`                //路透->25
-	DATA_SOURCE_NAME_COAL                                 = `中国煤炭网`             //煤炭网->26
+	DATA_SOURCE_NAME_COAL                                 = `中国煤炭市场网`           //中国煤炭市场网->26
 	DATA_SOURCE_NAME_PYTHON                               = `代码运算`              //python代码->27
 	DATA_SOURCE_NAME_PB_FINANCE                           = `彭博财务`              //彭博财务数据->28
 	DATA_SOURCE_NAME_GOOGLE_TRAVEL                        = `our world in data` //谷歌出行数据->29