指标期数位移-预测指标

models/predict_edb_data_calculate_phase_shift.go

@@ -10,7 +10,7 @@ import (
 	"time"
 )
 
-// SavePredictCalculatePhaseShift 时间移位
+// SavePredictCalculatePhaseShift 期数移位
 func SavePredictCalculatePhaseShift(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, edbCode, uniqueCode string, sysUserId int, sysUserRealName, lang string) (edbInfo *EdbInfo, latestDateStr string, latestValue float64, err error) {
 	o := orm.NewOrm()
 	to, err := o.Begin()
@@ -301,5 +301,18 @@ func refreshAllPredictCalculatePhaseShift(to orm.TxOrmer, edbInfoId, source, sub
 		}
 	}
 
+	// 查询该指标最新日期
+	var latestDate time.Time
+
+	queryLastDataSql := "SELECT data_time FROM edb_data_predict_calculate_phase_shift WHERE edb_info_id = ? ORDER BY data_time DESC LIMIT 1"
+	err = to.Raw(queryLastDataSql, edbInfoIdStr).QueryRow(&latestDate)
+	if err != nil {
+		// 处理错误
+		fmt.Println("查询错误:", err)
+	} else {
+		// 将时间格式化为字符串
+		latestDateStr = latestDate.Format("2006-01-02 15:04:05") // 根据需要格式化
+		fmt.Println("最新的 data_time:", latestDateStr)
+	}
 	return
 }