feat: add profile redeem code flow

2026-04-28 12:56:38 +08:00
parent bb4100fca4
commit 6611852a97
27 changed files with 1671 additions and 279 deletions
--- a/server-rs/crates/api-server/src/app.rs
+++ b/server-rs/crates/api-server/src/app.rs
@@ -83,8 +83,7 @@ use crate::{
        get_puzzle_agent_session, get_puzzle_gallery_detail, get_puzzle_run,
        get_puzzle_work_detail, get_puzzle_works, list_puzzle_gallery, put_puzzle_work,
        start_puzzle_run, stream_puzzle_agent_message, submit_puzzle_agent_message,
-        submit_puzzle_leaderboard,
-        swap_puzzle_pieces,
+        submit_puzzle_leaderboard, swap_puzzle_pieces,
    },
    refresh_session::refresh_session,
    request_context::{attach_request_context, resolve_request_id},
@@ -95,9 +94,10 @@ use crate::{
    runtime_chat::stream_runtime_npc_chat_turn,
    runtime_inventory::get_runtime_inventory_state,
    runtime_profile::{
+        admin_disable_profile_redeem_code, admin_upsert_profile_redeem_code,
        create_profile_recharge_order, get_profile_dashboard, get_profile_play_stats,
        get_profile_recharge_center, get_profile_referral_invite_center, get_profile_wallet_ledger,
-        redeem_profile_referral_invite_code,
+        redeem_profile_referral_invite_code, redeem_profile_reward_code,
    },
    runtime_save::{
        delete_runtime_snapshot, get_runtime_snapshot, list_profile_save_archives,
@@ -144,6 +144,20 @@ pub fn build_router(state: AppState) -> Router {
                require_admin_auth,
            )),
        )
+        .route(
+            "/admin/api/profile/redeem-codes",
+            post(admin_upsert_profile_redeem_code).route_layer(middleware::from_fn_with_state(
+                state.clone(),
+                require_admin_auth,
+            )),
+        )
+        .route(
+            "/admin/api/profile/redeem-codes/disable",
+            post(admin_disable_profile_redeem_code).route_layer(middleware::from_fn_with_state(
+                state.clone(),
+                require_admin_auth,
+            )),
+        )
        .route(
            "/healthz",
            get(|Extension(request_context): Extension<_>| async move {
@@ -848,6 +862,20 @@ pub fn build_router(state: AppState) -> Router {
                require_bearer_auth,
            )),
        )
+        .route(
+            "/api/runtime/profile/redeem-codes/redeem",
+            post(redeem_profile_reward_code).route_layer(middleware::from_fn_with_state(
+                state.clone(),
+                require_bearer_auth,
+            )),
+        )
+        .route(
+            "/api/profile/redeem-codes/redeem",
+            post(redeem_profile_reward_code).route_layer(middleware::from_fn_with_state(
+                state.clone(),
+                require_bearer_auth,
+            )),
+        )
        .route(
            "/api/runtime/profile/play-stats",
            get(get_profile_play_stats).route_layer(middleware::from_fn_with_state(
--- a/server-rs/crates/api-server/src/runtime_profile.rs
+++ b/server-rs/crates/api-server/src/runtime_profile.rs
@@ -7,30 +7,36 @@ use axum::{
 use module_runtime::{
    PROFILE_RECHARGE_PAYMENT_CHANNEL_MOCK, RuntimeProfileMembershipBenefitRecord,
    RuntimeProfileRechargeCenterRecord, RuntimeProfileRechargeOrderRecord,
-    RuntimeProfileRechargeProductRecord, RuntimeProfileWalletLedgerSourceType,
-    RuntimeReferralInviteCenterRecord, RuntimeReferralRedeemRecord,
+    RuntimeProfileRechargeProductRecord, RuntimeProfileRedeemCodeMode,
+    RuntimeProfileRedeemCodeRecord, RuntimeProfileRewardCodeRedeemRecord,
+    RuntimeProfileWalletLedgerSourceType, RuntimeReferralInviteCenterRecord,
+    RuntimeReferralRedeemRecord,
 };
 use serde_json::{Value, json};
 use shared_contracts::runtime::{
+    AdminDisableProfileRedeemCodeRequest, AdminUpsertProfileRedeemCodeRequest,
    CreateProfileRechargeOrderRequest, CreateProfileRechargeOrderResponse,
    PROFILE_WALLET_LEDGER_SOURCE_TYPE_ASSET_GENERATION_CONSUME,
    PROFILE_WALLET_LEDGER_SOURCE_TYPE_ASSET_GENERATION_REFUND,
    PROFILE_WALLET_LEDGER_SOURCE_TYPE_INVITE_INVITEE_REWARD,
    PROFILE_WALLET_LEDGER_SOURCE_TYPE_INVITE_INVITER_REWARD,
    PROFILE_WALLET_LEDGER_SOURCE_TYPE_POINTS_RECHARGE,
+    PROFILE_WALLET_LEDGER_SOURCE_TYPE_REDEEM_CODE_REWARD,
    PROFILE_WALLET_LEDGER_SOURCE_TYPE_SNAPSHOT_SYNC, ProfileDashboardSummaryResponse,
    ProfileMembershipBenefitResponse, ProfileMembershipResponse, ProfilePlayStatsResponse,
    ProfilePlayedWorkSummaryResponse, ProfileRechargeCenterResponse, ProfileRechargeOrderResponse,
-    ProfileRechargeProductResponse, ProfileReferralInviteCenterResponse,
-    ProfileWalletLedgerEntryResponse, ProfileWalletLedgerResponse,
-    RedeemProfileReferralInviteCodeRequest, RedeemProfileReferralInviteCodeResponse,
+    ProfileRechargeProductResponse, ProfileRedeemCodeAdminResponse,
+    ProfileReferralInviteCenterResponse, ProfileWalletLedgerEntryResponse,
+    ProfileWalletLedgerResponse, RedeemProfileReferralInviteCodeRequest,
+    RedeemProfileReferralInviteCodeResponse, RedeemProfileRewardCodeRequest,
+    RedeemProfileRewardCodeResponse,
 };
 use spacetime_client::SpacetimeClientError;
 use time::OffsetDateTime;

 use crate::{
-    api_response::json_success_body, auth::AuthenticatedAccessToken, http_error::AppError,
-    request_context::RequestContext, state::AppState,
+    admin::AuthenticatedAdmin, api_response::json_success_body, auth::AuthenticatedAccessToken,
+    http_error::AppError, request_context::RequestContext, state::AppState,
 };

 pub async fn get_profile_dashboard(
@@ -118,6 +124,9 @@ fn format_profile_wallet_ledger_source_type(
        RuntimeProfileWalletLedgerSourceType::AssetGenerationRefund => {
            PROFILE_WALLET_LEDGER_SOURCE_TYPE_ASSET_GENERATION_REFUND
        }
+        RuntimeProfileWalletLedgerSourceType::RedeemCodeReward => {
+            PROFILE_WALLET_LEDGER_SOURCE_TYPE_REDEEM_CODE_REWARD
+        }
    }
 }

@@ -228,6 +237,99 @@ pub async fn redeem_profile_referral_invite_code(
    ))
 }

+pub async fn redeem_profile_reward_code(
+    State(state): State<AppState>,
+    Extension(request_context): Extension<RequestContext>,
+    Extension(authenticated): Extension<AuthenticatedAccessToken>,
+    Json(payload): Json<RedeemProfileRewardCodeRequest>,
+) -> Result<Json<Value>, Response> {
+    let user_id = authenticated.claims().user_id().to_string();
+    let redeemed_at_micros = OffsetDateTime::now_utc().unix_timestamp_nanos() / 1_000;
+    let record = state
+        .spacetime_client()
+        .redeem_profile_reward_code(user_id, payload.code, redeemed_at_micros as i64)
+        .await
+        .map_err(|error| {
+            runtime_profile_error_response(
+                &request_context,
+                map_runtime_profile_client_error(error),
+            )
+        })?;
+
+    Ok(json_success_body(
+        Some(&request_context),
+        build_redeem_profile_reward_code_response(record),
+    ))
+}
+
+pub async fn admin_upsert_profile_redeem_code(
+    State(state): State<AppState>,
+    Extension(request_context): Extension<RequestContext>,
+    Extension(admin): Extension<AuthenticatedAdmin>,
+    Json(payload): Json<AdminUpsertProfileRedeemCodeRequest>,
+) -> Result<Json<Value>, Response> {
+    let updated_at_micros = OffsetDateTime::now_utc().unix_timestamp_nanos() / 1_000;
+    let mode = parse_profile_redeem_code_mode(&payload.mode).map_err(|error| {
+        runtime_profile_error_response(
+            &request_context,
+            AppError::from_status(StatusCode::BAD_REQUEST).with_message(error),
+        )
+    })?;
+    let record = state
+        .spacetime_client()
+        .admin_upsert_profile_redeem_code(
+            admin.session().subject.clone(),
+            payload.code,
+            mode,
+            payload.reward_points,
+            payload.max_uses,
+            payload.enabled,
+            payload.allowed_user_ids,
+            payload.allowed_public_user_codes,
+            updated_at_micros as i64,
+        )
+        .await
+        .map_err(|error| {
+            runtime_profile_error_response(
+                &request_context,
+                map_runtime_profile_client_error(error),
+            )
+        })?;
+
+    Ok(json_success_body(
+        Some(&request_context),
+        build_profile_redeem_code_admin_response(record),
+    ))
+}
+
+pub async fn admin_disable_profile_redeem_code(
+    State(state): State<AppState>,
+    Extension(request_context): Extension<RequestContext>,
+    Extension(admin): Extension<AuthenticatedAdmin>,
+    Json(payload): Json<AdminDisableProfileRedeemCodeRequest>,
+) -> Result<Json<Value>, Response> {
+    let updated_at_micros = OffsetDateTime::now_utc().unix_timestamp_nanos() / 1_000;
+    let record = state
+        .spacetime_client()
+        .admin_disable_profile_redeem_code(
+            admin.session().subject.clone(),
+            payload.code,
+            updated_at_micros as i64,
+        )
+        .await
+        .map_err(|error| {
+            runtime_profile_error_response(
+                &request_context,
+                map_runtime_profile_client_error(error),
+            )
+        })?;
+
+    Ok(json_success_body(
+        Some(&request_context),
+        build_profile_redeem_code_admin_response(record),
+    ))
+}
+
 pub async fn get_profile_play_stats(
    State(state): State<AppState>,
    Extension(request_context): Extension<RequestContext>,
@@ -396,6 +498,49 @@ fn build_redeem_profile_referral_invite_code_response(
    }
 }

+fn build_redeem_profile_reward_code_response(
+    record: RuntimeProfileRewardCodeRedeemRecord,
+) -> RedeemProfileRewardCodeResponse {
+    RedeemProfileRewardCodeResponse {
+        wallet_balance: record.wallet_balance,
+        amount_granted: record.amount_granted,
+        ledger_entry: ProfileWalletLedgerEntryResponse {
+            id: record.ledger_entry.wallet_ledger_id,
+            amount_delta: record.ledger_entry.amount_delta,
+            balance_after: record.ledger_entry.balance_after,
+            source_type: format_profile_wallet_ledger_source_type(record.ledger_entry.source_type)
+                .to_string(),
+            created_at: record.ledger_entry.created_at,
+        },
+    }
+}
+
+fn parse_profile_redeem_code_mode(raw: &str) -> Result<RuntimeProfileRedeemCodeMode, String> {
+    match raw.trim().to_ascii_lowercase().as_str() {
+        "public" => Ok(RuntimeProfileRedeemCodeMode::Public),
+        "unique" => Ok(RuntimeProfileRedeemCodeMode::Unique),
+        "private" => Ok(RuntimeProfileRedeemCodeMode::Private),
+        _ => Err("兑换码类型无效".to_string()),
+    }
+}
+
+fn build_profile_redeem_code_admin_response(
+    record: RuntimeProfileRedeemCodeRecord,
+) -> ProfileRedeemCodeAdminResponse {
+    ProfileRedeemCodeAdminResponse {
+        code: record.code,
+        mode: record.mode.as_str().to_string(),
+        reward_points: record.reward_points,
+        max_uses: record.max_uses,
+        global_used_count: record.global_used_count,
+        enabled: record.enabled,
+        allowed_user_ids: record.allowed_user_ids,
+        created_by: record.created_by,
+        created_at: record.created_at,
+        updated_at: record.updated_at,
+    }
+}
+
 #[cfg(test)]
 mod tests {
    use module_runtime::RuntimeProfileWalletLedgerSourceType;