Commit 7f5bb56c by Li Feifei

debug

parent 636114f1
Pipeline #17149 passed with stages
in 1 minute 4 seconds
...@@ -8,7 +8,6 @@ import ( ...@@ -8,7 +8,6 @@ import (
"image" "image"
"image/jpeg" "image/jpeg"
"image/png" "image/png"
"io/ioutil"
"os" "os"
"path" "path"
"regexp" "regexp"
...@@ -18,6 +17,7 @@ import ( ...@@ -18,6 +17,7 @@ import (
"ppt_server/library/http" "ppt_server/library/http"
"ppt_server/library/oss" "ppt_server/library/oss"
"github.com/chai2010/webp"
"github.com/gogf/gf/errors/gerror" "github.com/gogf/gf/errors/gerror"
"github.com/gogf/gf/frame/g" "github.com/gogf/gf/frame/g"
"github.com/gogf/gf/os/gtime" "github.com/gogf/gf/os/gtime"
...@@ -74,8 +74,6 @@ func (f *ObtainFile) fileInfo() error { ...@@ -74,8 +74,6 @@ func (f *ObtainFile) fileInfo() error {
if err != nil { if err != nil {
return err return err
} }
g.Log().Async().Infof("file info: %s", string(fileBytes))
var fileInfo model.UploadFileInfo var fileInfo model.UploadFileInfo
if err = json.Unmarshal(fileBytes, &fileInfo); err != nil { if err = json.Unmarshal(fileBytes, &fileInfo); err != nil {
return err return err
...@@ -102,23 +100,15 @@ func (f *ObtainFile) taskJob(file *zip.File) ([]interface{}, error) { ...@@ -102,23 +100,15 @@ func (f *ObtainFile) taskJob(file *zip.File) ([]interface{}, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
defer fd.Close() defer fd.Close()
pictureBytes, _ := ioutil.ReadAll(fd)
// 获取图片信息reader
imageReader := ioutil.NopCloser(bytes.NewBuffer(pictureBytes))
defer imageReader.Close()
// 上传图片reader
fileReader := ioutil.NopCloser(bytes.NewBuffer(pictureBytes))
defer fileReader.Close()
var img image.Image var img image.Image
fileSuffix := path.Ext(file.Name) //获取文件后缀 fileSuffix := path.Ext(file.Name) //获取文件后缀
switch fileSuffix { switch fileSuffix {
case ".png": case ".png":
img, err = png.Decode(imageReader) img, err = png.Decode(fd)
case ".jpeg": case ".jpeg":
img, err = jpeg.Decode(imageReader) img, err = jpeg.Decode(fd)
default: default:
return nil, gerror.New("image ext is not found") return nil, gerror.New("image ext is not found")
} }
...@@ -126,13 +116,16 @@ func (f *ObtainFile) taskJob(file *zip.File) ([]interface{}, error) { ...@@ -126,13 +116,16 @@ func (f *ObtainFile) taskJob(file *zip.File) ([]interface{}, error) {
return nil, err return nil, err
} }
replaceName := fmt.Sprintf("%05s", reFileNameCompile.ReplaceAllString(file.Name, "$1")) + fileSuffix replaceName := fmt.Sprintf("%05s", reFileNameCompile.ReplaceAllString(file.Name, "$1")) + ".webp"
var buf bytes.Buffer
if err := webp.Encode(&buf, img, &webp.Options{Lossless: true}); err != nil {
return nil, err
}
info := img.Bounds() info := img.Bounds()
imageInfo := []interface{}{replaceName, info.Max.X, info.Max.Y} imageInfo := []interface{}{replaceName, info.Max.X, info.Max.Y}
return imageInfo, oss.Upload(f.parser.splitUploadPath()+"images/"+replaceName, bytes.NewBuffer(buf.Bytes()))
return imageInfo, oss.Upload(f.parser.splitUploadPath()+"images/"+replaceName, fileReader)
} }
func (f *ObtainFile) task(file *zip.File) (err error) { func (f *ObtainFile) task(file *zip.File) (err error) {
...@@ -153,7 +146,6 @@ func (f *ObtainFile) uploadPicture() error { ...@@ -153,7 +146,6 @@ func (f *ObtainFile) uploadPicture() error {
return err return err
} }
defer reader.Close() defer reader.Close()
pool := workpool.New(10) pool := workpool.New(10)
for _, file := range reader.File { for _, file := range reader.File {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment