From 571322ffcb7781db94b224c43a9b7bfc77962683 Mon Sep 17 00:00:00 2001 From: kyx236 Date: Sun, 8 Feb 2026 14:31:09 +0800 Subject: [PATCH] feat: add team process API endpoint. --- backend/internal/api/team_process.go | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) diff --git a/backend/internal/api/team_process.go b/backend/internal/api/team_process.go index 0b22192..46668e2 100644 --- a/backend/internal/api/team_process.go +++ b/backend/internal/api/team_process.go @@ -819,19 +819,29 @@ func processSingleTeam(idx int, req TeamProcessRequest) (result TeamProcessResul logger.Status(fmt.Sprintf("%s 入库重试中... | 代理: %s", memberLogPrefix, proxyDisplay), memberEmail, "team") } - // 创建日志回调 - 只显示关键步骤 + // 创建日志回调 - 只显示关键步骤（去重：每个步骤只输出一次） + loggedSteps := make(map[auth.AuthStep]bool) authLogger := auth.NewAuthLogger(memberEmail, logPrefix, memberIdx+1, func(entry auth.AuthLogEntry) { if entry.IsError { logger.Error(fmt.Sprintf("%s %s", memberLogPrefix, entry.Message), memberEmail, "team") } else { - // 只显示关键步骤：提交邮箱、验证密码、选择工作区、授权成功 + // 只显示关键步骤，且每个步骤只输出首次（避免重试时重复日志） switch entry.Step { case auth.StepInputEmail: - logger.Info(fmt.Sprintf("%s 提交邮箱: %s", memberLogPrefix, memberEmail), memberEmail, "team") + if !loggedSteps[entry.Step] { + loggedSteps[entry.Step] = true + logger.Info(fmt.Sprintf("%s 提交邮箱: %s", memberLogPrefix, memberEmail), memberEmail, "team") + } case auth.StepInputPassword: - logger.Info(fmt.Sprintf("%s 验证密码...", memberLogPrefix), memberEmail, "team") + if !loggedSteps[entry.Step] { + loggedSteps[entry.Step] = true + logger.Info(fmt.Sprintf("%s 验证密码...", memberLogPrefix), memberEmail, "team") + } case auth.StepSelectWorkspace: - logger.Info(fmt.Sprintf("%s 选择工作区: %s", memberLogPrefix, teamID), memberEmail, "team") + if !loggedSteps[entry.Step] { + loggedSteps[entry.Step] = true + logger.Info(fmt.Sprintf("%s 选择工作区: %s", memberLogPrefix, teamID), memberEmail, "team") + } case auth.StepComplete: logger.Info(fmt.Sprintf("%s 授权成功，获取到授权码", memberLogPrefix), memberEmail, "team") }