diff --git a/internal/dao/taskBalanceSync.go b/internal/dao/taskBalanceSync.go index e9bdc6f..4a557c4 100644 --- a/internal/dao/taskBalanceSync.go +++ b/internal/dao/taskBalanceSync.go @@ -125,7 +125,7 @@ func RunIncrementalTaskBalanceSync() error { if err != nil { return err } - + if len(validArtists) == 0 { fmt.Println("增量同步:无有效艺人数据") return nil @@ -134,7 +134,7 @@ func RunIncrementalTaskBalanceSync() error { // 构造待插入的 TaskBalance 列表(仅包含不存在的记录) tasks := make([]model.TaskBalance, 0) skippedCount := 0 - + for _, a := range validArtists { // 根据 user_id + order_uuid 获取 BundleBalance 明细 var bb model.BundleBalance @@ -159,7 +159,7 @@ func RunIncrementalTaskBalanceSync() error { Count(&existingCount).Error; err != nil { return err } - + if existingCount > 0 { // 记录已存在,跳过 skippedCount++ @@ -334,8 +334,8 @@ inner join ( v.MonthlyIncreaseLimitImageNumber = v.MonthlyIncreaseLimitImageNumber - v.MonthlyIncreaseLimitImageConsumptionNumber + cal(v.IncreaseLimitImageNumber, v.MonthlyLimitImageQuotaNumber) v.MonthlyBundleLimitExpiredDataAnalysisNumber = cal(v.BundleLimitDataAnalysisExpiredNumber, v.MonthlyLimitDataAnalysisQuotaNumber) v.MonthlyIncreaseLimitExpiredDataAnalysisNumber = cal(v.IncreaseLimitDataAnalysisExpiredNumber, v.MonthlyLimitDataAnalysisQuotaNumber) - v.MonthlyBundleLimitDataAnalysisNumber = v.MonthlyBundleLimitDataAnalysisNumber - v.MonthlyBundleLimitDataAnalysisConsumptionNumber + cal(v.BundleLimitImageNumber, v.MonthlyLimitImageQuotaNumber) - v.MonthlyIncreaseLimitDataAnalysisNumber = v.MonthlyIncreaseLimitDataAnalysisNumber - v.MonthlyIncreaseLimitDataAnalysisConsumptionNumber + cal(v.IncreaseLimitImageNumber, v.MonthlyLimitImageQuotaNumber) + v.MonthlyBundleLimitDataAnalysisNumber = v.MonthlyBundleLimitDataAnalysisNumber - v.MonthlyBundleLimitDataAnalysisConsumptionNumber + cal(v.BundleLimitDataAnalysisNumber, v.MonthlyLimitDataAnalysisQuotaNumber) + v.MonthlyIncreaseLimitDataAnalysisNumber = v.MonthlyIncreaseLimitDataAnalysisNumber - v.MonthlyIncreaseLimitDataAnalysisConsumptionNumber + cal(v.IncreaseLimitDataAnalysisNumber, v.MonthlyLimitDataAnalysisQuotaNumber) // 重置单月消耗数量 v.MonthlyBundleVideoConsumptionNumber = 0 v.MonthlyIncreaseVideoConsumptionNumber = 0