From 347eca205646b86c59f5f5dd6dcfe16c64377604 Mon Sep 17 00:00:00 2001
From: kdletters <kdletters@qq.com>
Date: Thu, 27 Aug 2026 20:57:45 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=90=8E=E5=8F=B0=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E7=9B=AE=E6=A0=87=E8=B7=A8=E8=8A=82=E7=82=B9=E8=AF=BB?=
 =?UTF-8?q?=E5=8F=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

后台充值与钱包操作先刷新用户认证正式投影

避免目标用户仅存在于其他 API 节点时被误判不存在
---
 .../crates/api-server/src/admin_recharge.rs   | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/server-rs/crates/api-server/src/admin_recharge.rs b/server-rs/crates/api-server/src/admin_recharge.rs
index 28ad682ec..28492509e 100644
--- a/server-rs/crates/api-server/src/admin_recharge.rs
+++ b/server-rs/crates/api-server/src/admin_recharge.rs
@@ -64,6 +64,7 @@ pub async fn admin_list_recharge_orders(
     Extension(_admin): Extension<AuthenticatedAdmin>,
     Query(query): Query<AdminRechargeOrderListQuery>,
 ) -> Result<Json<Value>, Response> {
+    refresh_auth_projection(&state, &request_context).await?;
     let user_id = resolve_optional_user_id(&state, query.user_id, query.public_user_code)
         .map_err(|error| error_response(&request_context, error))?;
     let input = build_runtime_profile_recharge_order_admin_list_input(
@@ -112,6 +113,7 @@ pub async fn admin_get_user_detail(
     Extension(admin): Extension<AuthenticatedAdmin>,
     Query(query): Query<AdminUserDetailQuery>,
 ) -> Result<Json<Value>, Response> {
+    refresh_auth_projection(&state, &request_context).await?;
     let user = resolve_user(&state, query.user_id, query.public_user_code)
         .map_err(|error| error_response(&request_context, error))?;
     let wallet_detail = state
@@ -181,6 +183,7 @@ pub async fn admin_reconcile_user_consumption(
     Extension(admin): Extension<AuthenticatedAdmin>,
     Json(payload): Json<AdminUserConsumptionReconcileRequest>,
 ) -> Result<Json<Value>, Response> {
+    refresh_auth_projection(&state, &request_context).await?;
     let user = resolve_user(&state, Some(payload.user_id), None)
         .map_err(|error| error_response(&request_context, error))?;
     let input = build_runtime_profile_wallet_consumption_reconcile_input(
@@ -589,6 +592,7 @@ pub async fn admin_update_wallet_restriction(
     Extension(admin): Extension<AuthenticatedAdmin>,
     Json(payload): Json<AdminWalletRestrictionRequest>,
 ) -> Result<Json<Value>, Response> {
+    refresh_auth_projection(&state, &request_context).await?;
     let user = resolve_user(&state, Some(payload.user_id), None)
         .map_err(|error| error_response(&request_context, error))?;
     let input = build_runtime_profile_wallet_manual_restriction_upsert_input(
@@ -1040,6 +1044,22 @@ fn map_hold(hold: RuntimeProfileRechargeRefundHoldSnapshot) -> AdminRechargeRefu
     }
 }
 
+async fn refresh_auth_projection(
+    state: &AppState,
+    request_context: &RequestContext,
+) -> Result<(), Response> {
+    state
+        .refresh_auth_store_from_spacetime()
+        .await
+        .map_err(|error| {
+            error_response(
+                request_context,
+                AppError::from_status(StatusCode::BAD_GATEWAY)
+                    .with_message(format!("刷新用户认证信息失败：{error}")),
+            )
+        })
+}
+
 fn resolve_optional_user_id(
     state: &AppState,
     user_id: Option<String>,