- more debug for SendFilesToStores.
This commit is contained in:
@@ -2,6 +2,7 @@ package financial
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"mime/multipart"
|
"mime/multipart"
|
||||||
"path"
|
"path"
|
||||||
@@ -25,7 +26,11 @@ type tUploadFileInfo struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func SendFilesToStores(files []*multipart.FileHeader, isAsync bool, userName string) (msg string, err error) {
|
func SendFilesToStores(files []*multipart.FileHeader, isAsync bool, userName string) (msg string, err error) {
|
||||||
globals.SugarLogger.Debugf("SendFilesToStores, isAsync:%t, userName:%s", isAsync, userName)
|
globals.SugarLogger.Debugf("SendFilesToStores, fileCount:%d isAsync:%t, userName:%s", len(files), isAsync, userName)
|
||||||
|
if len(files) == 0 {
|
||||||
|
return "", errors.New("没有文件上传!")
|
||||||
|
}
|
||||||
|
|
||||||
fileList := make([]*tUploadFileInfo, len(files))
|
fileList := make([]*tUploadFileInfo, len(files))
|
||||||
for k, fileHeader := range files {
|
for k, fileHeader := range files {
|
||||||
fileList[k] = &tUploadFileInfo{
|
fileList[k] = &tUploadFileInfo{
|
||||||
@@ -51,6 +56,7 @@ func SendFilesToStores(files []*multipart.FileHeader, isAsync bool, userName str
|
|||||||
fileHeader := fileInfo.FileHeader
|
fileHeader := fileInfo.FileHeader
|
||||||
storeID := fileInfo.StoreID
|
storeID := fileInfo.StoreID
|
||||||
file, err := fileHeader.Open()
|
file, err := fileHeader.Open()
|
||||||
|
globals.SugarLogger.Debugf("SendFilesToStores upload file:%s", fileHeader.Filename)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
ret := storage.PutRet{}
|
ret := storage.PutRet{}
|
||||||
key := "storeBill_" + utils.Int2Str(storeID) + "_" + strings.ToLower(utils.GetUUID()) + path.Ext(fileHeader.Filename)
|
key := "storeBill_" + utils.Int2Str(storeID) + "_" + strings.ToLower(utils.GetUUID()) + path.Ext(fileHeader.Filename)
|
||||||
@@ -78,7 +84,7 @@ func SendFilesToStores(files []*multipart.FileHeader, isAsync bool, userName str
|
|||||||
}, fileList)
|
}, fileList)
|
||||||
|
|
||||||
if isAsync {
|
if isAsync {
|
||||||
return "Running", nil
|
return task.ID, nil
|
||||||
}
|
}
|
||||||
if _, err = task.GetResult(0); err == nil {
|
if _, err = task.GetResult(0); err == nil {
|
||||||
return "Done", nil
|
return "Done", nil
|
||||||
|
|||||||
Reference in New Issue
Block a user