残差分析 刷新残差指标时间戳

models/residual_analysis_model/edb_data_residual_analysis.go

@@ -38,3 +38,20 @@ func AddResidualAnalysisData(dataList []edbDataResidualAnalysis) (num int64, err
 
 	return num, nil
 }
+
+// GetDataListByCondition 根据条件查询所有数据
+func GetDataListByCondition(condition string, pars []interface{}) (items []edbDataResidualAnalysis, err error) {
+	o := orm.NewOrmUsingDB("data")
+	sql := `select * from edb_data_residual_analysis where 1=1` + condition
+	_, err = o.Raw(sql, pars...).QueryRows(&items)
+	return items, err
+}
+
+// RefreshDataTimestamp 刷新残差指标时间戳
+func (m *edbDataResidualAnalysis) RefreshDataTimestamp(cols []string) {
+	o := orm.NewOrmUsingDB("data")
+	_, err := o.Update(m, cols...)
+	if err != nil {
+		return
+	}
+}

services/residual_analysis_service/residual_analysis_service.go

@@ -901,6 +901,42 @@ func SaveResidualAnalysis(req residual_analysis_model.ResidualAnalysisIndexSaveR
 	return nil
 }
 
+// 刷新残差指标时间戳
+/*func init() {
+	//func main() {
+	var condition string
+	var pars []interface{}
+
+	condition = " and edb_data_id > 0 order by edb_data_id asc limit 500"
+
+	for {
+		dataList, err := residual_analysis_model.GetDataListByCondition(condition, pars)
+		if err != nil {
+			utils.FileLog.Info("获取数据失败, 错误：" + err.Error())
+			return
+		}
+
+		// 如果没有数据，退出循环
+		if dataList == nil || len(dataList) == 0 {
+			utils.FileLog.Info("没有更多数据需要更新")
+			break
+		}
+
+		// 更新数据时间戳
+		for _, data := range dataList {
+			data.DataTimeStamp = utils.StringToTime(data.DataTime).UnixMilli()
+			data.ModifyTime = time.Now()
+			data.CreateTime = time.Now()
+			data.RefreshDataTimestamp([]string{"create_time", "modify_time", "data_timestamp"})
+		}
+
+		condition = " and edb_data_id > ? order by edb_data_id asc limit 500"
+		pars = []interface{}{dataList[len(dataList)-1].EdbDataId}
+
+		utils.FileLog.Info("刷新残差指标时间戳, 已处理数量：" + strconv.Itoa(len(dataList)))
+	}
+}*/
+
 func ResidualAnalysisDetail(edbInfoId int) (residual_analysis_model.ResidualAnalysisDetailResp, error) {
 	// 通过指标配置映射表 拿到配置id，再获取关联的所有指标信息
 	var condition string