修改传参的形式

scheduler/extract.go

@@ -22,7 +22,7 @@ func ETLExtract() {
 	for _, task := range taskLi {
 		for _, trigger := range task.TriggerLi {
 			if trigger.TriggerType == model.TRIGGER_TYPE_TIME {
-				go ExtractTrigger(&trigger, &task)
+				go ExtractTrigger(trigger, task)
 			}
 		}
 	}

scheduler/trigger.go

@@ -7,7 +7,7 @@ import (
 	"time"
 )
 
-func ExtractTrigger(triggerConfig *model.Trigger, task *model.TaskHead) {
+func ExtractTrigger(triggerConfig model.Trigger, task model.TaskHead) {
 	global.TaskExtractStatusMap.Lock.Lock()
 	_, exist := global.TaskExtractStatusMap.Map[triggerConfig.TaskId]
 	if !exist {
@@ -36,7 +36,7 @@ func ExtractTrigger(triggerConfig *model.Trigger, task *model.TaskHead) {
 		}
 	}
 	extractService := svr.NewExtractService()
-	extractService.StandardExtract(task)
+	extractService.StandardExtract(&task)
 	global.ETLTaskRecord.TaskMap[triggerConfig.TaskId] = time.Now()
 }