lishihai
2024-07-03 91d7ca06128f996844aa7d2d691d083c944bdf1d
utils/upload/seaweed.go
@@ -1 +1,23 @@
package upload
import (
   "time"
   "wms/conf"
   "wms/pkg/logx"
   "wms/pkg/weedfs"
)
func UploadFileToSeaWeed(fileType, fileName string, fileBytes []byte) (string, error) {
   //assignUrl := conf.WebConf.FileServer + "/dir/assign?collection=" + time.Now().Format("2006-01-02 15:04:05")[:10] + "-" + conf.WebConf.ServerId + "-" + fileType
   assignUrl := conf.WebConf.FileServer + "/dir/assign?collection=12345-" + conf.WebConf.ServerId + "-" + fileType
   picUrl, err := WeedFSClient.GetFid(assignUrl)
   if err != nil {
      logx.Error(err.Error())
      return picUrl, err
   }
   //picFileName := uuid.NewV4().String() + "." + ext
   go WeedFSClient.UploadFile(picUrl, fileName, fileBytes, 3*time.Second)
   return picUrl, nil
}