|
|
@@ -42,6 +42,7 @@ func InitTimer() (err error) {
|
|
|
time.Sleep(dur)
|
|
|
|
|
|
// 执行函数
|
|
|
+ global.M2A_LOG.Info("WMS结算单导入：启动-ImportWMSReckon")
|
|
|
ImportWMSReckon()
|
|
|
}
|
|
|
}()
|
|
|
@@ -69,6 +70,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)
|
|
|
@@ -76,6 +79,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()))
|
