Browse Source

去掉刷新埋点

xyxie 1 year ago
parent
commit
aada56b022
2 changed files with 2 additions and 14 deletions
  1. 1 7
      controllers/base_from_pb.go
  2. 1 7
      controllers/base_from_wind.go

+ 1 - 7
controllers/base_from_pb.go

@@ -121,24 +121,18 @@ func (this *PbController) Refresh() {
 		br.ErrMsg = "获取指标信息失败 GetEdbDataFromPb,Err:" + err.Error()
 		return
 	}
-	dataUpdateTime := time.Now().Format(utils.FormatDateTime)
 	err = models.RefreshEdbDataFromPb(req.EdbInfoId, req.EdbCode, req.StartDate, dataItem)
 	if err != nil && err.Error() != utils.ErrNoRow() {
-		// 添加指标刷新失败日志
-		_ = services.AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 2, err.Error())
 		br.Msg = "刷新指标信息失败!"
 		br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromPb,Err:" + err.Error()
 		return
 	}
-	// 更新指标最大最小值
-	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfoTmp(edbInfo, dataUpdateTime)
+	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
 	if err != nil {
 		br.Msg = errMsg
 		br.ErrMsg = err.Error()
 		return
 	}
-	// 添加指标刷新成功日志
-	_ = services.AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 1, "")
 
 	// 更新ES
 	go logic.UpdateEs(edbInfo.EdbInfoId)

+ 1 - 7
controllers/base_from_wind.go

@@ -209,25 +209,19 @@ func (this *WindController) Refresh() {
 		br.ErrMsg = "获取指标信息失败 GetEdbDataFromWind,Err:" + err.Error()
 		return
 	}
-	dataUpdateTime := time.Now().Format(utils.FormatDateTime)
 	err = models.RefreshEdbDataFromWind(req.EdbInfoId, req.EdbCode, req.StartDate, dataItem)
 	if err != nil && err.Error() != utils.ErrNoRow() {
-		// 添加指标刷新失败日志
-		_ = services.AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 2, err.Error())
 		br.Msg = "刷新指标信息失败!"
 		br.ErrMsg = "刷新指标信息失败 RefreshEdbDataFromWind,Err:" + err.Error()
 		return
 	}
 	// 更新指标最大最小值
-	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfoTmp(edbInfo, dataUpdateTime)
+	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
 	if err != nil {
 		br.Msg = errMsg
 		br.ErrMsg = err.Error()
 		return
 	}
-
-	// 添加指标刷新成功日志
-	_ = services.AddEdbInfoUpdateLog(edbInfo.EdbInfoId, 1, "")
 	// 更新ES
 	go logic.UpdateEs(edbInfo.EdbInfoId)