库存调整修改2

liujiandao

2024-04-22 ce055975bf3880012871835719b2c5f7a79a3b41

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package controllers
 
import (
    "bytes"
    "github.com/gin-gonic/gin"
    "io"
    "path"
    "strings"
    "wms/constvar"
    "wms/extend/code"
    "wms/extend/util"
    "wms/models"
    "wms/pkg/logx"
    "wms/utils/image"
    "wms/utils/upload"
)
 
type AttachmentController struct {
}
 
// UploadFiles
//
//    @Tags        附件管理
//    @Summary    上传附件
//    @Success    200        {object}    util.Response     "成功"
//    @Router    /api-wms/v1/attachment/uploadFiles [post]
func (slf AttachmentController) UploadFiles(c *gin.Context) {
    form, err := c.MultipartForm()
    if err != nil {
        logx.Errorf("file upload err: %v", err)
        util.ResponseFormat(c, code.RequestParamError, "参数解析失败")
        return
    }
    files := form.File["files"]
 
    var attachmentList []*models.Attachment
    for _, fileHeader := range files {
        ext := strings.ToLower(path.Ext(fileHeader.Filename))[1:]
        fileParams := strings.Split(fileHeader.Filename, ".")
        var fileType constvar.FileType
        if value, ok := constvar.FileExtMap[ext]; ok {
            fileType = value
        }
        if value, ok := constvar.PicExtMap[ext]; ok {
            fileType = value
        }
        if fileType == "" {
            logx.Errorf("file upload err: 不支持上传该格式的文件")
            util.ResponseFormat(c, code.RequestParamError, "不支持上传该格式的文件")
            return
        }
        file, err := fileHeader.Open()
        if err != nil {
            logx.Errorf("file upload err: %v", err)
            util.ResponseFormat(c, code.RequestParamError, "错误文件")
            return
        }
        buffer := new(bytes.Buffer)
        _, _ = io.Copy(buffer, file)
        fileBytes := buffer.Bytes()
        fileUrl, err := upload.UploadFileToSeaWeed(string(fileType), fileHeader.Filename, fileBytes)
        if err != nil {
            logx.Errorf("file upload err: %v", err)
            util.ResponseFormat(c, code.RequestParamError, err.Error())
            return
        }
 
        attachment := &models.Attachment{
            FileName: fileHeader.Filename,
            FileUrl:  fileUrl,
            Ext:      ext,
            FileType: fileType,
        }
        attachmentList = append(attachmentList, attachment)
 
        if fileType == constvar.FileType_Picture {
            thumbnailBytes, err := image.CreateThumbnail(fileBytes, 60, 0, 0)
            if err != nil {
                logx.Errorf("file upload err: %v", err)
                util.ResponseFormat(c, code.RequestParamError, "生成缩略图失败："+err.Error())
                return
            }
            thumbnailUrl, err := upload.UploadFileToSeaWeed(string(constvar.FileType_Thumbnail), fileParams[0]+"thumbnail."+ext, thumbnailBytes)
            if err != nil {
                logx.Errorf("file upload err: %v", err)
                util.ResponseFormat(c, code.RequestParamError, err.Error())
                return
            }
 
            thumbAttach := &models.Attachment{
                FileName: fileHeader.Filename,
                FileUrl:  thumbnailUrl,
                Ext:      ext,
                FileType: constvar.FileType_Thumbnail,
            }
            attachmentList = append(attachmentList, thumbAttach)
        }
    }
 
    if len(attachmentList) > 0 {
        if attachmentList, err = models.NewAttachmentSearch().CreateBatchWithResp(attachmentList); err != nil {
            logx.Errorf("attachment create err: %v", err)
            util.ResponseFormat(c, code.SaveFail, "文件保存失败")
            return
        }
    }
 
    util.ResponseFormat(c, code.Success, attachmentList)
}