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