From 993814cdfa2605a93f18f501474b1e413658219e Mon Sep 17 00:00:00 2001 From: YGXB_net Date: Fri, 1 May 2026 22:37:45 +0800 Subject: [PATCH] =?UTF-8?q?refactor(uploader):=20=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E4=BF=A1=E6=81=AF=E7=BB=9F=E8=AE=A1=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 将变量名 fInfo 重命名为 filesInfo 以提高可读性 - 调整代码顺序,将 AddLog 调用移到变量声明后 - 统一使用新变量名在所有相关位置进行引用 - 移动 g.SetLimit 注释位置以提高代码可读性 --- internal/uploader/uploader.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/internal/uploader/uploader.go b/internal/uploader/uploader.go index 97c87d3..052eecb 100644 --- a/internal/uploader/uploader.go +++ b/internal/uploader/uploader.go @@ -163,11 +163,11 @@ func uploadData(ctx context.Context, logChan *chan string) { //检测到文件 //统计文件行数 - var fInfo = make(map[string]fileInfo) - - AddLog(logChan, fmt.Sprintf("正在统计 %v 个文件行数", len(files))) + var filesInfo = make(map[string]fileInfo) isAllEmpty := true + + AddLog(logChan, fmt.Sprintf("正在统计 %v 个文件行数", len(files))) for _, filePath := range files { select { case <-ctx.Done(): @@ -189,7 +189,7 @@ func uploadData(ctx context.Context, logChan *chan string) { if lineCount == 0 { continue } - fInfo[filepath.Base(filePath)] = fileInfo{ + filesInfo[filepath.Base(filePath)] = fileInfo{ FilePath: filePath, FileLines: lineCount, } @@ -207,7 +207,7 @@ func uploadData(ctx context.Context, logChan *chan string) { //刷新文件上传进度 progress.Clear() - for fileName, info := range fInfo { + for fileName, info := range filesInfo { progress.Store(fileName, Progress{ FileName: fileName, @@ -220,9 +220,10 @@ func uploadData(ctx context.Context, logChan *chan string) { // 使用 errgroup 控制同时处理的文件数,并开始上传文件任务 g, egctx := errgroup.WithContext(ctx) - g.SetLimit(config.APPConfig.HandleFileCount) // 设置同时处理文件数 + // 设置同时处理文件数 + g.SetLimit(config.APPConfig.HandleFileCount) // 执行文件上传任务参数(文件路径,文件行数) - for fileName, info := range fInfo { + for fileName, info := range filesInfo { select { case <-egctx.Done(): return