rename to mv

service/process.go

@@ -13,6 +13,7 @@ import (
 	"mime/multipart"
 	"net/http"
 	"os"
+	"os/exec"
 	"path/filepath"
 	"speechAnalysis/conf"
 	"speechAnalysis/constvar"
@@ -221,9 +222,12 @@ func PreLoad(cxt context.Context) {
 		} else {
 			src = conf.LocalConf.StorePath + "/" + fileName
 		}
-		err = os.Rename(eventName, src)
+		//err = os.Rename(eventName, src)
+		//利用exec命令移动文件
+		cmd := exec.Command("mv", eventName, src)
+		err = cmd.Run()
 		if err != nil {
-			logx.Errorf(fmt.Sprintf("%s:%s", fileName, "移动文件失败"))
+			logx.Errorf(fmt.Sprintf("%s:%s-%s", fileName, "移动文件失败", err.Error()))
 			return false
 		}
 		// 读取文件大小
@@ -258,7 +262,7 @@ func PreLoad(cxt context.Context) {
 		}
 		//解析 交路号:123_公里标:321
 		fileds := string(bts)
-		arr := strings.Split(fileds, "_")
+		arr := strings.Split(fileds, "\n")
 		if len(arr) != 2 {
 			logx.Errorf(fmt.Sprintf("%s:%s", filePath, "读取txt文件内容格式不对"))
 			return false
@@ -279,7 +283,10 @@ func PreLoad(cxt context.Context) {
 		} else {
 			src = conf.LocalConf.StorePath + "/" + fileName
 		}
-		err = os.Rename(filePath, src)
+		//err = os.Rename(filePath, src)
+		//利用exec命令移动文件
+		cmd := exec.Command("mv", filePath, src)
+		err = cmd.Run()
 		if err != nil {
 			logx.Errorf(fmt.Sprintf("%s:%s", fileName, "移动文件失败"))
 			return false