修改bug

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)

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读取文件，不存在时则创建，使用追加模式