|
|
|
@@ -116,7 +116,7 @@ func isHandled(sourceType string, requestId string, operateType string) (bool, e |
|
|
|
} |
|
|
|
|
|
|
|
func initRewardOperateRecord(ctx *models.RewardOperateContext) (string, error) { |
|
|
|
sn, err := generateOperateSerialNo(ctx.OperateType, ctx.Reward.Type) |
|
|
|
sn, err := generateOperateSerialNo() |
|
|
|
if err != nil { |
|
|
|
log.Error("generateOperateSerialNo error. %v", err) |
|
|
|
return "", err |
|
|
|
@@ -145,7 +145,7 @@ func initRewardOperateRecord(ctx *models.RewardOperateContext) (string, error) { |
|
|
|
} |
|
|
|
|
|
|
|
func createPeriodicRewardOperateRecord(ctx *models.StartPeriodicTaskOpts) (string, error) { |
|
|
|
sn, err := generateOperateSerialNo(ctx.OperateType, ctx.RewardType) |
|
|
|
sn, err := generateOperateSerialNo() |
|
|
|
if err != nil { |
|
|
|
log.Error("createPeriodic generateOperateSerialNo error. %v", err) |
|
|
|
return "", err |
|
|
|
@@ -269,7 +269,7 @@ func StopPeriodicTask(sourceType models.SourceType, sourceId string, operateType |
|
|
|
return models.StopPeriodicTask(task.ID, task.OperateSerialNo, now) |
|
|
|
} |
|
|
|
|
|
|
|
func generateOperateSerialNo(operateType models.RewardOperateType, rewardType models.RewardType) (string, error) { |
|
|
|
func generateOperateSerialNo() (string, error) { |
|
|
|
s, err := GetSerialNoByRedis() |
|
|
|
if err != nil { |
|
|
|
log.Error("generateOperateSerialNo error. %v", err) |
|
|
|
|