upload audio

controllers/event_controller.go

@@ -47,6 +47,10 @@ type Message struct {
 	Data interface{} `json:"data"`
 }
 
+const (
+	audioPath = "/jxdata/cthrgw/dist/audio/"
+)
+
 // @Title 测试websocket
 // @Description 测试websocket
 // @Success 200 {object} controllers.CallResult
@@ -378,28 +382,37 @@ func (c *EventController) UploadImg() {
 // @router /UploadAudio [post]
 func (c *EventController) UploadAudio() {
 	c.callUploadAudio(func(params *tEventUploadAudioParams) (retVal interface{}, errCode string, err error) {
+		var (
+			timeStr  = time.Now().Format("20060102")
+			filePath = audioPath + timeStr
+		)
 		files := c.Ctx.Request.MultipartForm.File["rsmAudio"]
 		head := files[0]
-		fmt.Println("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaa", *head)
 		file, err := head.Open()
-		// file, head, err := c.GetFile("rsmAudio")
 		defer file.Close()
 		if path.Ext(head.Filename) != ".mp3" {
 			err = fmt.Errorf("不支持的音频格式，请重新选择！")
 		}
 		if err != nil {
-			fmt.Println("bbbbbbbbbbbbbbbbbbbbbb", err)
 			return retVal, "", err
 		}
-		fmt.Println("cccccccccccccccccccccccccccccccc", head.Filename)
-		fileName := utils.GetUUID() + "_" + time.Now().Format("20060102") + path.Ext(head.Filename)
-		f, err := os.OpenFile("/jxdata/cthrgw/dist/audio/"+time.Now().Format("20060102")+"/"+fileName, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0666)
+		fileName := utils.GetUUID() + "_" + timeStr + path.Ext(head.Filename)
+		fmt.Println("aaaaaaaaaaaaaaaaaaaaaaa", fileName)
+		if err = os.Mkdir(filePath, os.ModeDir); err != nil {
+			if os.IsExist(err) {
+				err = nil
+			} else {
+				fmt.Println("bbbbbbbbbbbbbbbbbbbbbbbb", err)
+				return retVal, "", err
+			}
+		}
+		f, err := os.Create(filePath + "/" + fileName)
 		if err != nil {
+			fmt.Println("ccccccccccccccccccccccc", err)
 			return retVal, "", err
 		}
 		defer f.Close()
 		io.Copy(f, file)
-		// c.SaveToFile("rsmAudio", "/jxdata/cthrgw/dist/audio/"+time.Now().Format("20060102")+"/"+fileName)
 		return "https://www.jxcs.net/audio/" + fileName, "", err
 	})
 }