|
|
@@ -45,6 +45,7 @@ func InitTimer() (err error) {
|
|
|
|
|
|
if time.Now().Before(targetTime) {
|
|
|
// 执行函数
|
|
|
+ global.M2A_LOG.Info("WMS结算单导入：启动-ImportWMSReckon")
|
|
|
ImportWMSReckon()
|
|
|
}
|
|
|
}
|
|
|
@@ -74,6 +75,8 @@ func ImportWMSReckon() {
|
|
|
global.M2A_LOG.Error("FTP获取文件列表失败, err:", zap.Error(err))
|
|
|
return
|
|
|
}
|
|
|
+ global.M2A_LOG.Info("WMS结算单导入：FTP获取文件列表成功")
|
|
|
+
|
|
|
for _, entry := range entries {
|
|
|
// 下载FTP服务器上的文件
|
|
|
srcFile, err := global.M2A_FTP.Retr(global.M2A_CONFIG.FTP.Folder + "/" + entry.Name)
|
|
|
@@ -81,6 +84,7 @@ func ImportWMSReckon() {
|
|
|
global.M2A_LOG.Error("获取FTP源文件失败,", zap.String("file", entry.Name), zap.String("err", err.Error()))
|
|
|
continue
|
|
|
}
|
|
|
+
|
|
|
dstFile, err := os.Create("./.ftp_tmp/" + entry.Name)
|
|
|
if err != nil {
|
|
|
global.M2A_LOG.Error("创建FTP临时文件失败,", zap.String("file", entry.Name), zap.String("err", err.Error()))
|
