fix(admin): async plan-type probe on reset, avoid blocking batch resets

Reset endpoints no longer wait for the upstream Codex probe — it runs in a
background goroutine with its own 15s timeout and detached context, so
BatchResetStatus returns immediately and N accounts probe in parallel
instead of serially. Also fix mojibake in the persist-plan_type log.

Author: james-6-23

admin/handler.go

@@ -2714,18 +2714,17 @@ func (h *Handler) BatchResetStatus(c *gin.Context) {
 	})
 }
 
-func (h *Handler) syncAccountPlanAfterReset(parent context.Context, acc *auth.Account) {
+func (h *Handler) syncAccountPlanAfterReset(_ context.Context, acc *auth.Account) {
 	if h == nil || h.syncAccountPlanOnReset == nil || acc == nil {
 		return
 	}
-	if parent == nil {
-		parent = context.Background()
-	}
-	ctx, cancel := context.WithTimeout(parent, 15*time.Second)
-	defer cancel()
-	if err := h.syncAccountPlanOnReset(ctx, acc); err != nil {
-		log.Printf("[account %d] sync Codex plan type after reset failed: %v", acc.DBID, err)
-	}
+	go func() {
+		ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
+		defer cancel()
+		if err := h.syncAccountPlanOnReset(ctx, acc); err != nil {
+			log.Printf("[账号 %d] 重置后同步 Codex plan type 失败: %v", acc.DBID, err)
+		}
+	}()
 }
 
 func (h *Handler) syncSingleAccountPlanOnReset(ctx context.Context, acc *auth.Account) error {

admin/handler_test.go

@@ -155,14 +155,16 @@ func TestResetAccountStatusSyncsPlanMetadata(t *testing.T) {
 	account.SetUsageSnapshot(88, time.Now().Add(time.Hour))
 	store.AddAccount(account)
 
-	var called bool
+	called := make(chan int64, 1)
 	handler := &Handler{
 		store: store,
 		syncAccountPlanOnReset: func(_ context.Context, acc *auth.Account) error {
-			called = true
-			if acc == nil || acc.DBID != 42 {
-				t.Fatalf("sync account = %#v, want DBID 42", acc)
+			if acc == nil {
+				t.Errorf("sync account is nil")
+				called <- -1
+				return nil
 			}
+			called <- acc.DBID
 			return nil
 		},
 	}
@@ -177,7 +179,12 @@ func TestResetAccountStatusSyncsPlanMetadata(t *testing.T) {
 	if recorder.Code != http.StatusOK {
 		t.Fatalf("status = %d, want %d, body=%s", recorder.Code, http.StatusOK, recorder.Body.String())
 	}
-	if !called {
+	select {
+	case id := <-called:
+		if id != 42 {
+			t.Fatalf("sync DBID = %d, want 42", id)
+		}
+	case <-time.After(2 * time.Second):
 		t.Fatal("expected reset to sync plan metadata")
 	}
 	if _, ok := account.GetUsagePercent7d(); ok {
@@ -192,11 +199,11 @@ func TestBatchResetStatusSyncsEachResolvedAccount(t *testing.T) {
 	store.AddAccount(&auth.Account{DBID: 11, AccessToken: "at-11", PlanType: "free"})
 	store.AddAccount(&auth.Account{DBID: 22, AccessToken: "at-22", PlanType: "plus"})
 
-	var gotIDs []int64
+	gotIDs := make(chan int64, 2)
 	handler := &Handler{
 		store: store,
 		syncAccountPlanOnReset: func(_ context.Context, acc *auth.Account) error {
-			gotIDs = append(gotIDs, acc.DBID)
+			gotIDs <- acc.DBID
 			if acc.DBID == 22 {
 				return errors.New("temporary upstream failure")
 			}
@@ -214,16 +221,27 @@ func TestBatchResetStatusSyncsEachResolvedAccount(t *testing.T) {
 	if recorder.Code != http.StatusOK {
 		t.Fatalf("status = %d, want %d, body=%s", recorder.Code, http.StatusOK, recorder.Body.String())
 	}
-	if fmt.Sprint(gotIDs) != "[11 22]" {
-		t.Fatalf("synced ids = %v, want [11 22]", gotIDs)
-	}
 	var payload map[string]interface{}
 	if err := json.Unmarshal(recorder.Body.Bytes(), &payload); err != nil {
 		t.Fatalf("decode response: %v", err)
 	}
 	if payload["success"] != float64(2) || payload["failed"] != float64(1) {
 		t.Fatalf("payload = %#v, want success=2 failed=1", payload)
 	}
+
+	collected := make(map[int64]bool)
+	deadline := time.After(2 * time.Second)
+	for len(collected) < 2 {
+		select {
+		case id := <-gotIDs:
+			collected[id] = true
+		case <-deadline:
+			t.Fatalf("synced ids = %v, want {11,22}", collected)
+		}
+	}
+	if !collected[11] || !collected[22] {
+		t.Fatalf("synced ids = %v, want both 11 and 22", collected)
+	}
 }
 
 func TestCreateAPIKeyPersistsQuotaAndExpiration(t *testing.T) {

auth/store.go

@@ -4009,7 +4009,7 @@ func (s *Store) UpdateAccountPlanType(acc *Account, planType string) bool {
 	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
 	defer cancel()
 	if err := s.db.UpdateCredentials(ctx, acc.DBID, map[string]interface{}{"plan_type": plan}); err != nil {
-		log.Printf("[璐﹀彿 %d] 鎸佷箙鍖?plan_type 澶辫触: %v", acc.DBID, err)
+		log.Printf("[账号 %d] 持久化 plan_type 失败: %v", acc.DBID, err)
 	}
 	return changed
 }