watch preloads file to autoload

controllers/audio.go

@@ -209,6 +209,7 @@ func (slf AudioCtl) List(c *gin.Context) {
 		SetEndTime(params.EndTime).
 		SetIsFollowed(params.IsFollowed).
 		SetAudioStatusList(params.StatusList).
+		SetOrder("created_at desc").
 		Find()
 
 	if err != nil {

service/process.go

@@ -175,10 +175,12 @@ func PreLoad(cxt context.Context) {
 	if err != nil {
 		log.Fatal(err)
 	}
+FOR:
 	for {
 		select {
 		case <-cxt.Done():
 			fmt.Println("preload stop")
+			break FOR // 退出循环
 		case event, ok := <-watcher.Events:
 			if !ok {
 				continue
@@ -186,11 +188,14 @@ func PreLoad(cxt context.Context) {
 			if event.Op&fsnotify.Create == fsnotify.Create {
 				// 判断文件类型是否为.mp3或.wav
 				if filepath.Ext(event.Name) == ".mp3" || filepath.Ext(event.Name) == ".wav" {
+					time.Sleep(time.Second * 1)
+					//设置文件访问权限
+					err = os.Chmod(event.Name, 0777)
+					if err != nil {
+						logx.Errorf(fmt.Sprintf("%s:%s", event.Name, "设置文件权限失败"))
+					}
 					// 文件名
 					fileName := filepath.Base(event.Name)
-					// 文件大小
-					bs, _ := os.ReadFile(event.Name)
-					size := len(bs)
 					//校验文件命名
 					arr := strings.Split(fileName, "_")
 					if len(arr) != 6 {
@@ -211,16 +216,30 @@ func PreLoad(cxt context.Context) {
 					}
 
 					//将文件移动到uploads文件夹下
-					src := conf.LocalConf.StorePath + "/" + fileName
+					//判断storePath中末尾是否带
+					var src string
+					if strings.HasSuffix(conf.LocalConf.StorePath, "/") {
+						src = conf.LocalConf.StorePath + fileName
+					} else {
+						src = conf.LocalConf.StorePath + "/" + fileName
+					}
 					err = os.Rename(event.Name, src)
 					if err != nil {
 						logx.Errorf(fmt.Sprintf("%s:%s", fileName, "移动文件失败"))
 						continue
 					}
+					// 读取文件大小
+					fileInfo, err := os.Stat(src)
+					if err != nil {
+						logx.Errorf(fmt.Sprintf("%s:%s", fileName, "获取文件大小失败"))
+						continue
+					}
+					size := fileInfo.Size()
+					fmt.Println("fileName:", fileName, "size:", size, "src1", src)
 
 					audio := &models.Audio{
 						Name:             fileName,
-						Size:             int64(size),
+						Size:             size,
 						FilePath:         src,
 						AudioStatus:      constvar.AudioStatusUploadOk,
 						LocomotiveNumber: arr[0],