Procházet zdrojové kódy

fix:修改配置文件, 参数接口提示

zqbao před 8 měsíci
rodič
revize
35e63731b3

+ 5 - 1
controllers/base_from_mysteel_chemical.go

@@ -218,7 +218,11 @@ func (this *MySteelChemicalController) HandleApiMysteelIndex() {
 	errMsg, err := services.HandleApiMysteelIndex(&req)
 	errMsg, err := services.HandleApiMysteelIndex(&req)
 	if err != nil {
 	if err != nil {
 		fmt.Println("HandleMysteelIndex Err:" + err.Error())
 		fmt.Println("HandleMysteelIndex Err:" + err.Error())
-		br.Msg = errMsg
+		if errMsg == "" {
+			br.Msg = "数据获取失败"
+		} else {
+			br.Msg = errMsg
+		}
 		br.ErrMsg = "处理失败,Err:" + err.Error()
 		br.ErrMsg = "处理失败,Err:" + err.Error()
 		return
 		return
 	}
 	}

+ 5 - 5
services/base_from_mysteel_chemical.go

@@ -490,8 +490,8 @@ type MySteelChemicalApiInfoBody struct {
 
 
 func GetEdbDataFromMySteelChemical(indexCodes []string, startTime, endTime, order string) (item *models.MySteelChemicalApiResp, err error) {
 func GetEdbDataFromMySteelChemical(indexCodes []string, startTime, endTime, order string) (item *models.MySteelChemicalApiResp, err error) {
 	// 如果没有配置,获取配置的方式是api,那么就走官方接口
 	// 如果没有配置,获取配置的方式是api,那么就走官方接口
-	if utils.MsClRefreshToken == "" {
-		err = errors.New("钢联接口token配置")
+	if utils.MysteelChemicalApiToken == "" {
+		err = errors.New("钢联接口token配置")
 		return
 		return
 	}
 	}
 	m := new(MySteelChemicalApiDataBody)
 	m := new(MySteelChemicalApiDataBody)
@@ -518,8 +518,8 @@ func GetEdbDataFromMySteelChemical(indexCodes []string, startTime, endTime, orde
 
 
 func GetMySteelChemicalIndexNameMap(indexCodes []string) (indexNameMap map[string]*models.MySteelChemicalApiInfoItem, err error) {
 func GetMySteelChemicalIndexNameMap(indexCodes []string) (indexNameMap map[string]*models.MySteelChemicalApiInfoItem, err error) {
 	// 如果没有配置,获取配置的方式是api,那么就走官方接口
 	// 如果没有配置,获取配置的方式是api,那么就走官方接口
-	if utils.MsClRefreshToken == "" {
-		err = errors.New("钢联接口token配置")
+	if utils.MysteelChemicalApiToken == "" {
+		err = errors.New("钢联接口token配置")
 		return
 		return
 	}
 	}
 	m := new(MySteelChemicalApiInfoBody)
 	m := new(MySteelChemicalApiInfoBody)
@@ -560,7 +560,7 @@ func MySteelChemicalPost(postUrl, hType string, postData []byte) (body []byte, e
 		return
 		return
 	}
 	}
 	req.Header.Set(`Content-Type`, `application/json`)
 	req.Header.Set(`Content-Type`, `application/json`)
-	req.Header.Set(`accessTokenSign`, utils.MsClRefreshToken)
+	req.Header.Set(`accessTokenSign`, utils.MysteelChemicalApiToken)
 	req.Header.Set(`infoOrData`, hType)
 	req.Header.Set(`infoOrData`, hType)
 
 
 	client := &http.Client{}
 	client := &http.Client{}

+ 4 - 4
utils/config.go

@@ -71,9 +71,9 @@ var (
 	EDB_DATA_LIMIT        = 10
 	EDB_DATA_LIMIT        = 10
 	Hz_Wind_Data_Url_LIST []WindUrlMap // wind接口服务地址配置(客户本地机器,是个list列表)
 	Hz_Wind_Data_Url_LIST []WindUrlMap // wind接口服务地址配置(客户本地机器,是个list列表)
 
 
-	ThsDataMethod    string //同花顺数据获取的方式,app是通过终端;api是通过接口
-	ThsRefreshToken  string // 同花顺的刷新token
-	MsClRefreshToken string // 钢联的刷新token
+	ThsDataMethod           string //同花顺数据获取的方式,app是通过终端;api是通过接口
+	ThsRefreshToken         string // 同花顺的刷新token
+	MysteelChemicalApiToken string // 钢联化工的api数据token
 )
 )
 
 
 type WindUrlMap struct {
 type WindUrlMap struct {
@@ -221,7 +221,7 @@ func init() {
 		if ThsDataMethod == `` {
 		if ThsDataMethod == `` {
 			ThsDataMethod = "api"
 			ThsDataMethod = "api"
 		}
 		}
-		MsClRefreshToken = config["mscl_refresh_token"]
+		MysteelChemicalApiToken = config["mysteel_chemical_api_token"]
 	}
 	}
 
 
 	// ES配置
 	// ES配置