| | |
|---|
| | | package upload |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "basic.com/fileserver/WeedFSClient.git" |
|---|
| | | uuid "github.com/satori/go.uuid" |
|---|
| | | "strconv" |
|---|
| | | "time" |
|---|
| | | "wms/conf" |
|---|
| | | "wms/pkg/logx" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | func UploadFileToSeaWeed(fileType, ext 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=" + strconv.FormatInt(time.Now().Unix(), 10) + "-" + 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, picFileName, fileBytes, 3*time.Second) |
|---|
| | | return picUrl, nil |
|---|
| | | } |
|---|
