diff --git a/task/manager.go b/task/manager.go
index 68f23a0..a928eba 100644
--- a/task/manager.go
+++ b/task/manager.go
@@ -29,6 +29,7 @@ import (
 	"github.com/RichardKnop/machinery/v2/log"
 	"github.com/RichardKnop/machinery/v2/tasks"
 	"github.com/RichardKnop/machinery/v2/utils"
+	"github.com/google/uuid"
 	"github.com/robfig/cron/v3"
 
 	irevoker "git.ifooth.com/common/pkg/task/revokers/iface"
@@ -290,6 +291,8 @@ func (m *TaskManager) registerScheduleTask(spec string, task *types.Task) error
 			return
 		}
 
+		// 定时任务每次生成新的任务ID
+		task.TaskID = uuid.NewString()
 		err = m.Dispatch(task)
 		if err != nil {
 			log.ERROR.Printf("periodic task failed. task name is: %s. error is %s", task.TaskName, err.Error())