瀏覽代碼

同花顺和wind指标刷新时记录最新的数据刷新时间

xyxie 6 天之前
父節點
當前提交
bb39ead12f
共有 3 個文件被更改,包括 26 次插入4 次删除
  1. 10 1
      controllers/base_from_ths_ds.go
  2. 8 2
      controllers/base_from_wind.go
  3. 8 1
      controllers/base_from_wind_wsd.go

+ 10 - 1
controllers/base_from_ths_ds.go

@@ -100,6 +100,7 @@ func (this *ThsDsController) Refresh() {
 	}
 	//期货数据,就默认到今天,特殊处理下
 	endDate := time.Now().Format(utils.FormatDate)
+	dataUpdateTime := time.Now().Format(utils.FormatDateTime)
 	// 获取指标详情
 	edbInfo, err := models.GetEdbInfoByEdbCode(source, req.EdbCode)
 	if err != nil {
@@ -153,7 +154,15 @@ func (this *ThsDsController) Refresh() {
 		return
 	}
 	// 更新指标最大最小值
-	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
+	// err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
+	// if err != nil {
+	// 	br.Msg = errMsg
+	// 	br.ErrMsg = err.Error()
+	// 	return
+	// }
+
+	// 更新指标最大最小值
+	_, err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfoDataUpdate(edbInfo, dataUpdateTime)
 	if err != nil {
 		br.Msg = errMsg
 		br.ErrMsg = err.Error()

+ 8 - 2
controllers/base_from_wind.go

@@ -184,7 +184,7 @@ func (this *WindController) Refresh() {
 		br.Msg = "系统处理中,请稍后重试"
 		return
 	}
-
+	dataUpdateTime := time.Now().Format(utils.FormatDateTime)
 	//获取指标信息
 	edbInfo, err := models.GetEdbInfoById(req.EdbInfoId)
 	if err != nil {
@@ -255,7 +255,13 @@ func (this *WindController) Refresh() {
 		return
 	}
 	// 更新指标最大最小值
-	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
+	// err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
+	// if err != nil {
+	// 	br.Msg = errMsg
+	// 	br.ErrMsg = err.Error()
+	// 	return
+	// }
+	_, err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfoDataUpdate(edbInfo, dataUpdateTime)
 	if err != nil {
 		br.Msg = errMsg
 		br.ErrMsg = err.Error()

+ 8 - 1
controllers/base_from_wind_wsd.go

@@ -167,6 +167,7 @@ func (this *WindWsdController) Refresh() {
 		br.Msg = "系统处理中,请稍后重试"
 		return
 	}
+	dataUpdateTime := time.Now().Format(utils.FormatDateTime)
 	//获取指标信息
 	edbInfo, err := models.GetEdbInfoById(req.EdbInfoId)
 	if err != nil {
@@ -236,7 +237,13 @@ func (this *WindWsdController) Refresh() {
 		return
 	}
 	// 更新指标最大最小值
-	err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
+	// err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
+	// if err != nil {
+	// 	br.Msg = errMsg
+	// 	br.ErrMsg = err.Error()
+	// 	return
+	// }
+	_, err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfoDataUpdate(edbInfo, dataUpdateTime)
 	if err != nil {
 		br.Msg = errMsg
 		br.ErrMsg = err.Error()