Browse Source

fix:刷新数据时,同步更新最大最小值

Roc 2 years ago
parent
commit
1cf2aba6f1

+ 18 - 0
controllers/base_from_cffex.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *CffexController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoById(req.EdbInfoId)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,15 @@ func (this *CffexController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromCffex,Err:" + err.Error()
 			return
 		}
+
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
+
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 17 - 0
controllers/base_from_coal.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *CoalController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoById(req.EdbInfoId)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,14 @@ func (this *CoalController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromCoal,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
+
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_dl.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -38,6 +39,14 @@ func (this *DlController) Add() {
 		br.ErrMsg = "请输入指标编码,指标编码为空"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_ADD + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -47,6 +56,13 @@ func (this *DlController) Add() {
 			br.ErrMsg = "获取指标信息失败 AddEdbDataFromDl,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_gie.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -38,6 +39,14 @@ func (this *GieController) Add() {
 		br.ErrMsg = "请输入指标编码,指标编码为空"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_ADD + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -47,6 +56,13 @@ func (this *GieController) Add() {
 			br.ErrMsg = "获取指标信息失败 AddEdbDataFromGie,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_google_travel.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -88,6 +89,14 @@ func (this *GoogleTravelController) Refresh() {
 		return
 	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
 		err = models.RefreshEdbDataGoogleTravel(req.EdbInfoId, req.EdbCode, req.StartDate)
@@ -96,6 +105,13 @@ func (this *GoogleTravelController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataGoogleTravel,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 15 - 0
controllers/base_from_lt.go

@@ -94,6 +94,14 @@ func (this *LtController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -109,6 +117,13 @@ func (this *LtController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromLt,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_lz.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *LzController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *LzController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromLz,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_manual.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *ManualController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *ManualController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromManual,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_mysteel.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *MySteelController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *MySteelController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromMysteel,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 15 - 0
controllers/base_from_pb.go

@@ -94,6 +94,14 @@ func (this *PbController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -112,6 +120,13 @@ func (this *PbController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromPb,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 15 - 0
controllers/base_from_pb_finance.go

@@ -104,6 +104,14 @@ func (this *PbFinanceController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -133,6 +141,13 @@ func (this *PbFinanceController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromPb,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_sh.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *ShController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *ShController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromSh,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_shfe.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *ShfeController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *ShfeController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromShfe,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_smm.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *SmmController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *SmmController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromSmm,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 15 - 0
controllers/base_from_ths.go

@@ -94,6 +94,14 @@ func (this *ThsController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -109,6 +117,13 @@ func (this *ThsController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromThs,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 8 - 0
controllers/base_from_wind.go

@@ -113,6 +113,7 @@ func (this *WindController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -146,6 +147,13 @@ func (this *WindController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromWind,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 16 - 0
controllers/base_from_zz.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"encoding/json"
 	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/services"
 	"hongze/hongze_edb_lib/utils"
 	"strconv"
 	"time"
@@ -87,6 +88,14 @@ func (this *ZzController) Refresh() {
 		br.ErrMsg = "请输入指标ID"
 		return
 	}
+
+	// 获取指标详情
+	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
+	if err != nil {
+		br.Msg = "指标不存在!"
+		br.ErrMsg = "指标不存在"
+		return
+	}
 	cacheKey = utils.CACHE_EDB_DATA_REFRESH + strconv.Itoa(source) + "_" + req.EdbCode
 	if !utils.Rc.IsExist(cacheKey) {
 		utils.Rc.SetNX(cacheKey, 1, 1*time.Minute)
@@ -96,6 +105,13 @@ func (this *ZzController) Refresh() {
 			br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromZz,Err:" + err.Error()
 			return
 		}
+		// 更新指标最大最小值
+		err, errMsg := services.ModifyEdbInfoMaxAndMinInfo(edbInfo)
+		if err != nil {
+			br.Msg = errMsg
+			br.ErrMsg = err.Error()
+			return
+		}
 		br.Ret = 200
 		br.Success = true
 		br.Msg = "获取成功"

+ 33 - 0
services/edbinfo.go

@@ -0,0 +1,33 @@
+package services
+
+import (
+	"errors"
+	"hongze/hongze_edb_lib/models"
+	"hongze/hongze_edb_lib/utils"
+)
+
+// ModifyEdbInfoMaxAndMinInfo 修改指标的最大最小值
+func ModifyEdbInfoMaxAndMinInfo(edbInfo *models.EdbInfo) (err error, errMsg string) {
+	// 修改最大最小值
+	maxAndMinItem, err := models.GetEdbInfoMaxAndMinInfo(edbInfo.Source, edbInfo.EdbCode)
+	if err != nil {
+		if err.Error() == utils.ErrNoRow() {
+			err = nil
+			return
+		}
+
+		errMsg = "刷新指标失败!"
+		err = errors.New("获取指标最大最小值失败,err:" + err.Error())
+		return
+	}
+
+	if maxAndMinItem != nil {
+		err = models.ModifyEdbInfoMaxAndMinInfo(edbInfo.EdbInfoId, maxAndMinItem)
+		if err != nil {
+			errMsg = "刷新指标失败!"
+			err = errors.New("修改指标最大最小值失败,err:" + err.Error())
+			return
+		}
+	}
+	return
+}