diff --git a/services/reward/operator.go b/services/reward/operator.go
index b66810c70..b9d8c8d59 100644
--- a/services/reward/operator.go
+++ b/services/reward/operator.go
@@ -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)