指标期数位移-刷新指标

controllers/base_from_calculate.go

@@ -1537,10 +1537,10 @@ func (this *CalculateController) Refresh() {
 		if err != nil && err.Error() != utils.ErrNoRow() {
 			errMsg = "RefreshAllCalculateTimeShift Err:" + err.Error()
 		}
-	case utils.DATA_SOURCE_CALCULATE_PHASE_SHIFT:
+	case utils.DATA_SOURCE_CALCULATE_PHASE_SHIFT: // 期数位移
 		calculate, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
 		if err != nil {
-			errMsg = "GetEdbInfoCalculateTbzDetail Err:" + err.Error()
+			errMsg = "GetEdbInfoCalculateMappingDetail Err:" + err.Error()
 			break
 		}
 		fromEdbInfo, err := models.GetEdbInfoById(calculate.FromEdbInfoId)

models/edb_data_calculate_phase_shift.go

@@ -248,6 +248,13 @@ func RefreshAllCalculatePhaseShift(edbInfoId, source, subSource, formulaInt, mov
 		}
 	}()
 
+	//清空原有数据
+	sql := ` DELETE FROM edb_data_calculate_phase_shift WHERE edb_info_id = ? `
+	_, err = to.Raw(sql, edbInfoId).Exec()
+	if err != nil {
+		return
+	}
+
 	//计算数据
 	err = refreshAllCalculatePhaseShift(to, edbInfoId, source, subSource, formulaInt, moveType, fromEdbInfo, edbCode, startDate, endDate, moveFrequency)