self-tools
/
l-export-async
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

优化异步导出，修复上传空指针判断

This commit is contained in:
renzhiyuan 2025-12-27 13:41:38 +08:00
parent b262190ca1
commit 9cf8777a16
1 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
export_async.go
View File

@ -11,11 +11,6 @@ import (
"strconv" "strconv"
"strings" "strings"
"gitea.cdlsxd.cn/self-tools/l-export-async/attachment"
"gitea.cdlsxd.cn/self-tools/l-export-async/coroutine"
"github.com/google/uuid"
"github.com/redis/go-redis/v9"
"golang.org/x/sync/errgroup"
"io" "io"
"os" "os"
"path/filepath" "path/filepath"
@ -23,6 +18,12 @@ import (
"sync" "sync"
"sync/atomic" "sync/atomic"
"time" "time"
"gitea.cdlsxd.cn/self-tools/l-export-async/attachment"
"gitea.cdlsxd.cn/self-tools/l-export-async/coroutine"
"github.com/google/uuid"
"github.com/redis/go-redis/v9"
"golang.org/x/sync/errgroup"
) )
var exportAsyncPool = &sync.Pool{ var exportAsyncPool = &sync.Pool{
@ -189,14 +190,16 @@ func (e *ExportAsync) export(ctx context.Context, tempDir string) (source string
if err = e.folderToZip(excelsDir, source); err != nil { if err = e.folderToZip(excelsDir, source); err != nil {
return return
} }
if e.uploader != nil {
if len(e.uploader.Host) > 0 { if len(e.uploader.Host) > 0 {
e.logTool.Infof("异步导出任务：%s,开始上传", e.task.Id) e.logTool.Infof("异步导出任务：%s,开始上传", e.task.Id)
source, err = e.upload(source) source, err = e.upload(source)
if err != nil { if err != nil {
return return
}
} }
} }
e.task.Source = source e.task.Source = source
e.processAdd(ctx, ATT.int()) e.processAdd(ctx, ATT.int())
return return