添加参数

models/etl/etl.go

@@ -3,6 +3,8 @@ package etl
 import "LAPP_ETL/grmi"
 
 const (
+	// 数据库类型
+	ENGINE_TYPE_SQLSERVER = "MSSQL"
 	// 程序模式
 	MOD_DEBUG   = "debug"
 	MOD_RELEASE = "release"
@@ -51,6 +53,8 @@ const (
 	ADDITION_FUNC_DELETE = "DELETE"
 	ADDITION_FUNC_INSERT = "INSERT"
 	ADDITION_FUNC_STORE  = "STORE"
+	// TaskHead 是否需要执行抽取
+	LOAD_NOT_NEED = 1
 )
 
 // 数据表的字段定义

scheduler/load.go

@@ -2,6 +2,7 @@ package scheduler
 
 import (
 	"LAPP_ETL/infra/logger"
+	model "LAPP_ETL/models/etl"
 	svr "LAPP_ETL/services/etl"
 	"fmt"
 )
@@ -13,7 +14,7 @@ func ETLLoad() {
 	}
 	log, _ := logger.NewLogger(-1, "Scheduler")
 	taskService := svr.NewTaskHeadService()
-	taskLi, err := taskService.SelectWithDetail()
+	taskLi, err := taskService.SelectWithDetail(model.STAGE_LOAD_DATA)
 	if err != nil {
 		log.Error("ETLLoad get task failed, error:", err)
 		return