fiee/micro-bundle
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updata

Browse Source
This commit is contained in:
jiaji.H 2026-01-04 16:22:50 +08:00
parent 44c4a8627c
commit 65ffc2c43a
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/dao/taskBalanceSync.go
View File

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