|
|
@@ -77,7 +77,7 @@ func RunRewardTask(t models.RewardPeriodicTask, now time.Time) error { |
|
|
|
log.Error("RunRewardTask. operator of reward type is not exist") |
|
|
|
return errors.New("operator of reward type is not exist") |
|
|
|
} |
|
|
|
nextTime := t.NextExecuteTime |
|
|
|
nextTime := timeutil.TimeStamp(int64(t.NextExecuteTime) + t.IntervalSeconds) |
|
|
|
for i := 1; int64(i) <= n; i++ { |
|
|
|
err = operator.Operate(&models.RewardOperateContext{ |
|
|
|
SourceType: models.SourceTypeRunCloudbrainTask, |
|
|
|