修改FTP连接BUG

main.go

@@ -42,10 +42,11 @@ func main() {
 
 	// 连接FTP
 	if global.M2A_CONFIG.FTP.Enable {
-		var err error
-		if global.M2A_FTP, err = core.FTP(); err == nil {
-			defer global.M2A_FTP.Quit()
-		}
+		// 在这里连接FTP可能会在使用时已经断开
+		// var err error
+		// if global.M2A_FTP, err = core.FTP(); err == nil {
+		// 	defer global.M2A_FTP.Quit()
+		// }
 		// 开始FTP Timer任务
 		service.InitTimer()
 	}

service/ftp.go

@@ -3,6 +3,7 @@ package service
 import (
 	"fmt"
 	"io"
+	"mtp20_assisted/core"
 	"mtp20_assisted/global"
 	"mtp20_assisted/model"
 	"mtp20_assisted/utils"
@@ -49,6 +50,14 @@ func InitTimer() (err error) {
 
 // ImportWMSReckon 导入WMS结算单
 func ImportWMSReckon() {
+	// 连接FTP
+	var err error
+	if global.M2A_FTP, err = core.FTP(); err != nil {
+		global.M2A_LOG.Error("连接FTP失败, err:", zap.Error(err))
+		return
+	}
+	defer global.M2A_FTP.Quit()
+
 	// 暂存ftp文件的临时目录
 	os.RemoveAll("./.ftp_tmp")
 	os.Mkdir("./.ftp_tmp", os.ModePerm)