feat: add API for team processes
This commit is contained in:
@@ -743,10 +743,12 @@ func processSingleTeam(idx int, req TeamProcessRequest) (result TeamProcessResul
|
|||||||
memberMu.Unlock()
|
memberMu.Unlock()
|
||||||
logger.Success(fmt.Sprintf("%s ✓ 注册成功 (耗时: %.1fs)", memberLogPrefix, regDuration.Seconds()), currentEmail, "team")
|
logger.Success(fmt.Sprintf("%s ✓ 注册成功 (耗时: %.1fs)", memberLogPrefix, regDuration.Seconds()), currentEmail, "team")
|
||||||
|
|
||||||
// 流水线:注册成功后立即启动入库(异步)
|
// 流水线:注册成功后等待 3 秒再开始入库(避免触发邮箱验证)
|
||||||
s2aWg.Add(1)
|
s2aWg.Add(1)
|
||||||
go func(idx int, e, p string) {
|
go func(idx int, e, p string) {
|
||||||
defer s2aWg.Done()
|
defer s2aWg.Done()
|
||||||
|
// 等待 3 秒,让账号状态稳定
|
||||||
|
time.Sleep(3 * time.Second)
|
||||||
success := doS2A(idx, e, p)
|
success := doS2A(idx, e, p)
|
||||||
memberMu.Lock()
|
memberMu.Lock()
|
||||||
children[idx].S2ADone = true
|
children[idx].S2ADone = true
|
||||||
|
|||||||
Reference in New Issue
Block a user