。。

controllers/base_from_wind.go

@@ -197,9 +197,9 @@ func (this *WindController) Refresh() {
 		endDate = time.Now().Format(utils.FormatDate)
 	}
 	// 判断是否调用桥接服务
-	windUrl, _ := services.GetWindBridgeUrl()
+	windBridgeUrl, _ := services.GetWindBridgeJYUrl()
 	var dataList []*models.EdbDataFromWindSimple
-	if windUrl != "" && windUrl == edbInfo.ServerUrl {
+	if windBridgeUrl != "" && windBridgeUrl == edbInfo.ServerUrl {
 		var errMsg string
 		dataList, err, errMsg = services.RefreshEdbDataFromWindBridge(edbInfo.ServerUrl, req, edbInfo, endDate)
 		if err != nil {

services/base_from_manual.go

@@ -15,6 +15,9 @@ func AddEdbDataFromManual(edbCode string) (err error) {
 		if err != nil {
 			return
 		}
+		// 设置指标与终端关系的缓存
+		windUrlCacheKey := utils.CACHE_WIND_URL + ":" + edbCode
+		_ = utils.Rc.SetNX(windUrlCacheKey, url, utils.GetTodayLastSecond())
 	} else {
 		var condition string
 		var pars []interface{}
@@ -35,7 +38,7 @@ func AddEdbDataFromManual(edbCode string) (err error) {
 
 func RefreshEdbDataFromManual(req models.RefreshEdbInfoReq, edbinfo *models.EdbInfo) (err error) {
 	var manualDataList []*models.ManualEdbdata
-	url, _ := GetWindBridgeUrl()
+	url, _ := GetManualBridgeJYUrl()
 	if url != "" && edbinfo.ServerUrl == url {
 		manualDataList, err = GetManualEdbDataFromBridgeJy(url, req.EdbCode, "", "")
 		if err != nil {

services/base_from_wind_bridge.go

@@ -56,6 +56,46 @@ func GetWindBridgeUrl() (windUrl string, err error) {
 	return
 }
 
+// GetWindBridgeJYUrl 获取嘉悦桥接服务地址
+func GetWindBridgeJYUrl() (windUrl string, err error) {
+	defer func() {
+		if err == nil && windUrl == "" {
+			err = errors.New("wind桥接服务器地址为空")
+		}
+	}()
+	// 先配置中获取，如果有指定配置的话，那么取配置中的数据
+	tmpConfig, err := models.GetConfigDetailByCode("wind_from_bridge_jy")
+	if err != nil && err.Error() != utils.ErrNoRow() {
+		err = errors.New("获取配置的wind地址失败，err:" + err.Error())
+		return
+	}
+	err = nil
+	if tmpConfig != nil {
+		windUrl = tmpConfig.ConfigValue
+	}
+	return
+}
+
+// GetManualBridgeJYUrl 获取嘉悦桥接服务地址
+func GetManualBridgeJYUrl() (windUrl string, err error) {
+	defer func() {
+		if err == nil && windUrl == "" {
+			err = errors.New("wind桥接服务器地址为空")
+		}
+	}()
+	// 先配置中获取，如果有指定配置的话，那么取配置中的数据
+	tmpConfig, err := models.GetConfigDetailByCode("manual_from_bridge_jy")
+	if err != nil && err.Error() != utils.ErrNoRow() {
+		err = errors.New("获取配置的wind地址失败，err:" + err.Error())
+		return
+	}
+	err = nil
+	if tmpConfig != nil {
+		windUrl = tmpConfig.ConfigValue
+	}
+	return
+}
+
 // GetManualBridgeUrl 获取桥接服务地址
 func GetManualBridgeUrl() (manualUrl string, err error) {
 	defer func() {