mygo-kyx/codexautopool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add team process API endpoint.

Browse Source
This commit is contained in:
kyx236
2026-02-08 14:31:09 +08:00
parent ae37a7165d
commit 571322ffcb
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
backend/internal/api/team_process.go
View File

@@ -819,19 +819,29 @@ func processSingleTeam(idx int, req TeamProcessRequest) (result TeamProcessResul
logger.Status(fmt.Sprintf("%s 入库重试中... | 代理: %s", memberLogPrefix, proxyDisplay), memberEmail, "team") 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) { authLogger := auth.NewAuthLogger(memberEmail, logPrefix, memberIdx+1, func(entry auth.AuthLogEntry) {
if entry.IsError { if entry.IsError {
logger.Error(fmt.Sprintf("%s %s", memberLogPrefix, entry.Message), memberEmail, "team") logger.Error(fmt.Sprintf("%s %s", memberLogPrefix, entry.Message), memberEmail, "team")
} else { } else {
// 只显示关键步骤：提交邮箱、验证密码、选择工作区、授权成功 // 只显示关键步骤，且每个步骤只输出首次（避免重试时重复日志）
switch entry.Step { switch entry.Step {
case auth.StepInputEmail: 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: 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: 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: case auth.StepComplete:
logger.Info(fmt.Sprintf("%s 授权成功，获取到授权码", memberLogPrefix), memberEmail, "team") logger.Info(fmt.Sprintf("%s 授权成功，获取到授权码", memberLogPrefix), memberEmail, "team")
} }