From def8c3f817c4b3b0452c5c68c2ecfecd291551d4 Mon Sep 17 00:00:00 2001 From: "DESKTOP-4672LME\\Xu Tengfei" Date: Thu, 30 Dec 2021 16:15:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- etl_task/BackFlushPackOrder.go | 17 +++++++++++------ etl_task/BackFlushShipOrder.go | 14 ++++++++------ 2 files changed, 19 insertions(+), 12 deletions(-) diff --git a/etl_task/BackFlushPackOrder.go b/etl_task/BackFlushPackOrder.go index f727166..69562b0 100644 --- a/etl_task/BackFlushPackOrder.go +++ b/etl_task/BackFlushPackOrder.go @@ -9,11 +9,14 @@ import ( "LAPP_ACURA_MOM_BACKEND/utils" "encoding/csv" "fmt" + _ "github.com/denisenkom/go-mssqldb" + _ "github.com/go-sql-driver/mysql" "github.com/go-xorm/xorm" "os" "strconv" "time" ) +//BackFlushPackOrder.exe "server=101.201.121.115;database=LAPP_ACURA_MES;user id=sa;password=Leit2020;port=1433;encrypt=disable" "LAPP_ACURA_MES" "server=101.201.121.115;database=LAPP_ETL;user id=sa;password=Leit2020;port=1433;encrypt=disable" "LAPP_ETL" "10" const ( plantNr = 100 @@ -43,17 +46,18 @@ func main() { //fmt.Println("global.DatabaseDsn:", global.DatabaseDsn) //fmt.Println("global.MongoDsn:", global.MongoDsn) //fmt.Println("strconv.Itoa(task.TaskId):", strconv.Itoa(task.TaskId)) - var acuraDsn = os.Args[2] + var acuraDsn = os.Args[1] var etlDsn = os.Args[3] - taskId, err := strconv.Atoi(os.Args[4]) + taskId, err := strconv.Atoi(os.Args[5]) if err != nil { - fmt.Println("接收到的taskId错误, taskId:" + os.Args[4]) + fmt.Println("接收到的taskId错误, taskId:" + os.Args[5]) return } // 初始化数据库连接 + fmt.Println(etlDsn) etlDB, err := xorm.NewEngine("mssql", etlDsn) if err != nil { - fmt.Println("初始化讴歌数据库引擎错误:" + err.Error()) + fmt.Println("初始化etl数据库引擎错误:" + err.Error()) return } err = etlDB.Ping() @@ -61,6 +65,7 @@ func main() { fmt.Println("连接ETL数据库失败, error:" + err.Error()) return } + fmt.Println(acuraDsn) acraDB, err := xorm.NewEngine("mssql", acuraDsn) if err != nil { fmt.Println("初始化讴歌数据库引擎错误:" + err.Error()) @@ -83,7 +88,7 @@ func main() { etlSession := etlDB.NewSession() defer etlSession.Close() shellParamLi := make([]model.ShellParam, 0) - err = etlSession.Table("Shell").Where("TaskId = ?", taskId).Find(&shellParamLi) + err = etlSession.Table("ShellParam").Where("TaskId = ?", taskId).Find(&shellParamLi) if err != nil { fmt.Println("查询任务需要参数失败, error:" + err.Error()) return @@ -122,7 +127,7 @@ func main() { return } if len(backFlushLi) == 0 { - fmt.Println("OK") + fmt.Println("no ok") return } ArtMap := make(map[string]int) diff --git a/etl_task/BackFlushShipOrder.go b/etl_task/BackFlushShipOrder.go index a43c7f7..6388e4f 100644 --- a/etl_task/BackFlushShipOrder.go +++ b/etl_task/BackFlushShipOrder.go @@ -10,6 +10,8 @@ import ( "LAPP_ACURA_MOM_BACKEND/utils" "encoding/csv" "fmt" + _ "github.com/denisenkom/go-mssqldb" + _ "github.com/go-sql-driver/mysql" "github.com/go-xorm/xorm" "os" "strconv" @@ -35,17 +37,17 @@ func main() { fmt.Println("参数长度错误!") return } - var acuraDsn = os.Args[2] + var acuraDsn = os.Args[1] var etlDsn = os.Args[3] - taskId, err := strconv.Atoi(os.Args[4]) + taskId, err := strconv.Atoi(os.Args[5]) if err != nil { - fmt.Println("接收到的taskId错误, taskId:" + os.Args[4]) + fmt.Println("接收到的taskId错误, taskId:" + os.Args[5]) return } // 初始化数据库连接 etlDB, err := xorm.NewEngine("mssql", etlDsn) if err != nil { - fmt.Println("初始化讴歌数据库引擎错误:" + err.Error()) + fmt.Println("初始化etl数据库引擎错误:" + err.Error()) return } err = etlDB.Ping() @@ -69,7 +71,7 @@ func main() { var path string etlSession := etlDB.NewSession() shellParamLi := make([]model.ShellParam, 0) - err = etlSession.Table("Shell").Where("TaskId = ?", taskId).Find(&shellParamLi) + err = etlSession.Table("ShellParam").Where("TaskId = ?", taskId).Find(&shellParamLi) if err != nil { fmt.Println("查询任务需要参数失败, error:" + err.Error()) return @@ -104,7 +106,7 @@ func main() { } // 如果没有数据 则完成本次任务 if len(shipOrderDataLi) == 0 { - fmt.Println("OK") + fmt.Println("no OK") return } //OpenFile读取文件，不存在时则创建，使用追加模式