|
@@ -158,28 +158,28 @@ func (this *WindController) Refresh() {
|
|
|
|
|
|
// GetServerUrl 获取服务器地址
|
|
|
func GetServerUrl(edbCode string) (windUrl string, err error) {
|
|
|
- list, err := models.GetServerUrlCountGroupByServerUrl()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
- windUrlNum := 0
|
|
|
-
|
|
|
- //现有系统的wind数据服务地址分配
|
|
|
- windUrlMap := make(map[string]int)
|
|
|
- for _, v := range list {
|
|
|
- windUrlMap[v.ServerUrl] = v.Total
|
|
|
- }
|
|
|
-
|
|
|
- for _, tmpWind := range utils.Hz_Wind_Data_Url_LIST {
|
|
|
- tmpWindUrl := tmpWind.Url
|
|
|
- tmpNum := windUrlMap[tmpWindUrl]
|
|
|
- if windUrl == `` || (windUrl != `` && tmpNum < windUrlNum) {
|
|
|
- windUrl = tmpWindUrl
|
|
|
- windUrlNum = tmpNum
|
|
|
- }
|
|
|
- }
|
|
|
+ //list, err := models.GetServerUrlCountGroupByServerUrl()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //windUrlNum := 0
|
|
|
+ //
|
|
|
+ ////现有系统的wind数据服务地址分配
|
|
|
+ //windUrlMap := make(map[string]int)
|
|
|
+ //for _, v := range list {
|
|
|
+ // windUrlMap[v.ServerUrl] = v.Total
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //for _, tmpWind := range utils.Hz_Wind_Data_Url_LIST {
|
|
|
+ // tmpWindUrl := tmpWind.Url
|
|
|
+ // tmpNum := windUrlMap[tmpWindUrl]
|
|
|
+ // if windUrl == `` || (windUrl != `` && tmpNum < windUrlNum) {
|
|
|
+ // windUrl = tmpWindUrl
|
|
|
+ // windUrlNum = tmpNum
|
|
|
+ // }
|
|
|
+ //}
|
|
|
|
|
|
- //windUrl = `http://datawind.hzinsights.com:8040/`
|
|
|
+ windUrl = `http://datawind.hzinsights.com:8040/`
|
|
|
// 设置缓存
|
|
|
cacheKey := utils.CACHE_WIND_URL + ":" + edbCode
|
|
|
_ = utils.Rc.SetNX(cacheKey, windUrl, utils.GetTodayLastSecond())
|