refactor: harden task authority and room mutations

fix: enforce decor placement surfaces
feat: add personal space visits and editor
2026-07-23 00:59:00 +08:00 · 2026-07-22 14:20:18 +08:00 · 2026-07-22 13:41:28 +08:00 · 2026-07-22 12:16:31 +08:00
48 changed files with 1887 additions and 195 deletions
--- a/.env.example
+++ b/.env.example
@@ -15,6 +15,11 @@ ADMIN_BOOTSTRAP_ENABLED=false
 ADMIN_USERNAME=
 ADMIN_PASSWORD=
 ADMIN_NICKNAME=
+TEST_ADMIN_AUTO_PROVISION=true
+TEST_ADMIN_USERNAME=admin
+TEST_ADMIN_PASSWORD=
+TEST_ADMIN_NICKNAME=测试管理员
+TEST_LAB_ENABLED=false

 # Local storage mode
 USE_MEMORY_STORAGE=true
--- a/.env.production.example
+++ b/.env.production.example
@@ -14,6 +14,7 @@ ADMIN_BOOTSTRAP_ENABLED=false
 ADMIN_USERNAME=
 ADMIN_PASSWORD=
 ADMIN_NICKNAME=
+TEST_LAB_ENABLED=false

 # Persistent storage
 USE_MEMORY_STORAGE=false
--- a/src/business/admin/admin.module.ts
+++ b/src/business/admin/admin.module.ts
@@ -38,6 +38,12 @@ import { AdminOperationLogMemoryService } from './admin_operation_log_memory.ser
 import { AdminOperationLog } from './admin_operation_log.entity';
 import { AdminDatabaseExceptionFilter } from './admin_database_exception.filter';
 import { AdminOperationLogInterceptor } from './admin_operation_log.interceptor';
+import { TestLabController } from './test_lab.controller';
+import { TestLabService } from './test_lab.service';
+import { TestLabGuard } from './test_lab.guard';
+import { ChatGatewayModule } from '../../gateway/chat/chat.gateway.module';
+import { AuthModule } from '../auth/auth.module';
+import { LoginCoreModule } from '../../core/login_core/login_core.module';

 /**
 * 检查数据库配置是否完整
@@ -55,6 +61,9 @@ function isDatabaseConfigured(): boolean {
    LoggerModule,
    UsersModule,
    SessionCoreModule,
+    AuthModule,
+    LoginCoreModule,
+    ChatGatewayModule,
    UserProfilesModule,
    // 注意：ZulipAccountsModule 是全局模块，已在 AppModule 中导入，无需重复导入
    // 注册AdminOperationLog实体
@@ -63,7 +72,8 @@ function isDatabaseConfigured(): boolean {
  controllers: [
    AdminController,
    AdminDatabaseController,
-    AdminOperationLogController
+    AdminOperationLogController,
+    TestLabController,
  ],
  providers: [
    AdminService,
@@ -75,12 +85,15 @@ function isDatabaseConfigured(): boolean {
        : AdminOperationLogMemoryService,
    },
    AdminDatabaseExceptionFilter,
-    AdminOperationLogInterceptor
+    AdminOperationLogInterceptor,
+    TestLabService,
+    TestLabGuard,
  ],
  exports: [
    AdminService,
    DatabaseManagementService,
-    AdminOperationLogService
+    AdminOperationLogService,
+    TestLabService,
  ], // 导出服务供其他模块使用
 })
 export class AdminModule {}
--- a/src/business/admin/test_lab.controller.ts
+++ b/src/business/admin/test_lab.controller.ts
@@ -0,0 +1,67 @@
+import { Body, Controller, Delete, Get, Param, Patch, Post, UseGuards, ValidationPipe } from '@nestjs/common';
+import { ApiBearerAuth, ApiOperation, ApiTags } from '@nestjs/swagger';
+import { TestLabService } from './test_lab.service';
+import { CreateTestLabActorDto, TestLabMessageDto, TestLabRoomPolicyDto, TestLabSocialActionDto, UpdateTestLabActorDto } from './test_lab.dto';
+import { Req } from '@nestjs/common';
+import { TestLabGuard, TestLabRequest } from './test_lab.guard';
+
+@ApiTags('admin-test-lab')
+@ApiBearerAuth('JWT-auth')
+@UseGuards(TestLabGuard)
+@Controller('admin/test-lab')
+export class TestLabController {
+  constructor(private readonly testLab: TestLabService) {}
+
+  @Get('status')
+  @ApiOperation({ summary: '获取测试实验室状态' })
+  async status() {
+    return { success: true, data: await this.testLab.status() };
+  }
+
+  @Post('actors')
+  @ApiOperation({ summary: '创建并上线测试假人' })
+  async create(@Body(new ValidationPipe({ transform: true })) dto: CreateTestLabActorDto, @Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.createActor(dto, this.admin(request)) };
+  }
+
+  @Patch('actors/:userId')
+  @ApiOperation({ summary: '更新测试假人的在线、位置或外观' })
+  async update(@Param('userId') userId: string, @Body(new ValidationPipe({ transform: true })) dto: UpdateTestLabActorDto, @Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.updateActor(userId, dto, this.admin(request)) };
+  }
+
+  @Patch('actors/:userId/room-policy')
+  @ApiOperation({ summary: '设置测试假人房间访问策略' })
+  async roomPolicy(@Param('userId') userId: string, @Body(new ValidationPipe({ transform: true })) dto: TestLabRoomPolicyDto, @Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.setRoomPolicy(userId, dto, this.admin(request)) };
+  }
+
+  @Post('actors/:userId/messages')
+  @ApiOperation({ summary: '以测试假人身份发送公共消息或私聊' })
+  async message(@Param('userId') userId: string, @Body(new ValidationPipe({ transform: true })) dto: TestLabMessageDto, @Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.sendMessage(userId, dto, this.admin(request)) };
+  }
+
+  @Post('actors/:userId/social')
+  @ApiOperation({ summary: '以测试假人身份执行好友或拉黑操作' })
+  async social(@Param('userId') userId: string, @Body(new ValidationPipe({ transform: true })) dto: TestLabSocialActionDto, @Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.socialAction(userId, dto, this.admin(request)) };
+  }
+
+  @Delete('actors/:userId')
+  @ApiOperation({ summary: '删除单个测试假人及其测试数据' })
+  async remove(@Param('userId') userId: string, @Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.removeActor(userId, this.admin(request)) };
+  }
+
+  @Delete('actors')
+  @ApiOperation({ summary: '清空全部测试假人及关联测试数据' })
+  async clear(@Req() request: TestLabRequest) {
+    return { success: true, data: await this.testLab.clear(this.admin(request)) };
+  }
+
+  private admin(request: TestLabRequest) {
+    if (!request.admin) throw new Error('管理员身份缺失');
+    return request.admin;
+  }
+}
--- a/src/business/admin/test_lab.dto.ts
+++ b/src/business/admin/test_lab.dto.ts
@@ -0,0 +1,92 @@
+import { Type } from 'class-transformer';
+import { IsBoolean, IsIn, IsNotEmpty, IsNumber, IsOptional, IsString, Length, Matches, Max, Min, ValidateIf } from 'class-validator';
+import { MALL_SKIN_ITEMS } from '../mall/mall_catalog';
+
+export const TEST_LAB_MAP_IDS = ['whale_port', 'work_zone', 'whale_cafe'] as const;
+export type TestLabMapId = (typeof TEST_LAB_MAP_IDS)[number];
+export const TEST_LAB_SKIN_IDS = MALL_SKIN_ITEMS.map((item) => item.skinId).filter((skinId): skinId is string => Boolean(skinId));
+const TEST_LAB_NICKNAME_PATTERN = /^[\u4E00-\u9FFF A-Za-z0-9_-]+$/;
+
+export class CreateTestLabActorDto {
+  @IsString()
+  @IsNotEmpty()
+  @Length(1, 32)
+  @Matches(TEST_LAB_NICKNAME_PATTERN, { message: '昵称仅支持中文、字母、数字、空格、下划线和连字符' })
+  nickname: string;
+
+  @IsIn(TEST_LAB_MAP_IDS)
+  mapId: TestLabMapId;
+
+  @Type(() => Number)
+  @IsNumber()
+  @Min(-8192)
+  @Max(8192)
+  x: number;
+
+  @Type(() => Number)
+  @IsNumber()
+  @Min(-8192)
+  @Max(8192)
+  y: number;
+
+  @IsOptional()
+  @IsIn(TEST_LAB_SKIN_IDS)
+  skinId?: string;
+}
+
+export class UpdateTestLabActorDto {
+  @IsOptional()
+  @IsBoolean()
+  online?: boolean;
+
+  @ValidateIf((value) => value.mapId !== undefined)
+  @IsIn(TEST_LAB_MAP_IDS)
+  mapId?: TestLabMapId;
+
+  @IsOptional()
+  @Type(() => Number)
+  @IsNumber()
+  @Min(-8192)
+  @Max(8192)
+  x?: number;
+
+  @IsOptional()
+  @Type(() => Number)
+  @IsNumber()
+  @Min(-8192)
+  @Max(8192)
+  y?: number;
+
+  @IsOptional()
+  @IsIn(TEST_LAB_SKIN_IDS)
+  skinId?: string;
+}
+
+export class TestLabMessageDto {
+  @IsIn(['local', 'global', 'private'])
+  scope: 'local' | 'global' | 'private';
+
+  @IsString()
+  @IsNotEmpty()
+  @Length(1, 1000)
+  content: string;
+
+  @ValidateIf((value) => value.scope === 'private')
+  @IsString()
+  @IsNotEmpty()
+  targetUserId?: string;
+}
+
+export class TestLabSocialActionDto {
+  @IsIn(['friend_request', 'friend_accept', 'friend_reject', 'block'])
+  action: 'friend_request' | 'friend_accept' | 'friend_reject' | 'block';
+
+  @IsString()
+  @IsNotEmpty()
+  targetUserId: string;
+}
+
+export class TestLabRoomPolicyDto {
+  @IsIn(['friends', 'public', 'closed'])
+  roomVisitPolicy: 'friends' | 'public' | 'closed';
+}
--- a/src/business/admin/test_lab.guard.ts
+++ b/src/business/admin/test_lab.guard.ts
@@ -0,0 +1,73 @@
+import { CanActivate, ExecutionContext, ForbiddenException, Inject, Injectable, UnauthorizedException } from '@nestjs/common';
+import { Request } from 'express';
+import { AdminAuthPayload, AdminCoreService } from '../../core/admin_core/admin_core.service';
+import { LoginCoreService, JwtPayload } from '../../core/login_core/login_core.service';
+import { Users } from '../../core/db/users/users.entity';
+
+export interface TestLabRequest extends Request {
+  admin?: AdminAuthPayload;
+  user?: JwtPayload;
+}
+
+type UsersLookup = {
+  findOne(id: bigint): Promise<Users>;
+};
+
+/**
+ * 测试实验室既可由旧管理端 token 调用，也可由游戏内管理员的登录 token 调用。
+ * 两条路径最终都会回查当前用户 role，避免客户端角色字段或旧 token 被单独信任。
+ */
+@Injectable()
+export class TestLabGuard implements CanActivate {
+  constructor(
+    private readonly adminCore: AdminCoreService,
+    private readonly loginCore: LoginCoreService,
+    @Inject('UsersService') private readonly users: UsersLookup,
+  ) {}
+
+  async canActivate(context: ExecutionContext): Promise<boolean> {
+    const request = context.switchToHttp().getRequest<TestLabRequest>();
+    const token = this.extractBearerToken(request);
+
+    try {
+      const admin = this.adminCore.verifyToken(token);
+      await this.assertCurrentAdministrator(admin.adminId);
+      request.admin = admin;
+      return true;
+    } catch (_adminTokenError) {
+      // 继续尝试游戏登录 token；两类 token 使用不同签名，不会相互放行。
+    }
+
+    try {
+      const user = await this.loginCore.verifyToken(token, 'access');
+      if (user.role !== 9) throw new ForbiddenException('仅管理员可使用测试实验室');
+      await this.assertCurrentAdministrator(user.sub);
+      request.user = user;
+      request.admin = {
+        adminId: user.sub,
+        username: user.username,
+        role: 9,
+        iat: user.iat || Math.floor(Date.now() / 1000),
+        exp: user.exp || Math.floor(Date.now() / 1000),
+      };
+      return true;
+    } catch (error) {
+      if (error instanceof ForbiddenException) throw error;
+      throw new UnauthorizedException('需要有效的管理员登录凭据');
+    }
+  }
+
+  private extractBearerToken(request: Request): string {
+    const authorization = request.headers.authorization;
+    if (!authorization || Array.isArray(authorization)) throw new UnauthorizedException('缺少Authorization头');
+    const [scheme, token] = authorization.split(' ');
+    if (scheme !== 'Bearer' || !token) throw new UnauthorizedException('Authorization格式错误');
+    return token;
+  }
+
+  private async assertCurrentAdministrator(userId: string): Promise<void> {
+    if (!/^\d+$/.test(userId)) throw new UnauthorizedException('管理员身份无效');
+    const user = await this.users.findOne(BigInt(userId));
+    if (user.role !== 9) throw new ForbiddenException('仅管理员可使用测试实验室');
+  }
+}
--- a/src/business/admin/test_lab.service.ts
+++ b/src/business/admin/test_lab.service.ts
@@ -0,0 +1,281 @@
+import { BadRequestException, ForbiddenException, Inject, Injectable, Logger, OnModuleInit, Optional } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
+import { DataSource } from 'typeorm';
+import { randomUUID } from 'crypto';
+import { AccountProfileService } from '../auth/account_profile.service';
+import { SocialService } from '../social/social.service';
+import { ChatWebSocketGateway } from '../../gateway/chat/chat.gateway';
+import { Users } from '../../core/db/users/users.entity';
+import { AdminOperationLogService } from './admin_operation_log.service';
+import {
+  clearTestLabPresences,
+  getAllTestLabPresences,
+  getTestLabPresence,
+  TestLabPresence,
+} from './test_lab_presence.registry';
+import { CreateTestLabActorDto, TestLabMessageDto, TestLabRoomPolicyDto, TestLabSocialActionDto, UpdateTestLabActorDto } from './test_lab.dto';
+
+type UserStore = {
+  create(input: Partial<Users> & { username: string; nickname: string }): Promise<Users>;
+  findOne(id: bigint): Promise<Users>;
+  findAll(limit: number, offset: number): Promise<Users[]>;
+  remove(id: bigint): Promise<unknown>;
+};
+
+type AdminActor = { adminId: string; username: string };
+
+const MAX_TEST_ACTORS = 20;
+
+@Injectable()
+export class TestLabService implements OnModuleInit {
+  private readonly logger = new Logger(TestLabService.name);
+
+  constructor(
+    private readonly config: ConfigService,
+    @Inject('UsersService') private readonly users: UserStore,
+    private readonly accountProfiles: AccountProfileService,
+    private readonly social: SocialService,
+    private readonly gateway: ChatWebSocketGateway,
+    private readonly audit: AdminOperationLogService,
+    @Optional() private readonly dataSource?: DataSource,
+  ) {}
+
+  async onModuleInit(): Promise<void> {
+    if (this.isTestEnvironment()) {
+      await this.clearTestAccounts('startup');
+    }
+  }
+
+  isEnabled(): boolean {
+    return this.isTestEnvironment() && this.config.get<string>('TEST_LAB_ENABLED', 'false') === 'true';
+  }
+
+  async status() {
+    this.assertEnabled();
+    const actors = await this.listActorsInternal();
+    return {
+      enabled: this.isEnabled(),
+      environment: this.config.get<string>('NODE_ENV', 'development'),
+      maxActors: MAX_TEST_ACTORS,
+      actors,
+      onlinePlayers: this.gateway.getOnlineWorldPlayers(),
+    };
+  }
+
+  async createActor(dto: CreateTestLabActorDto, admin: AdminActor) {
+    this.assertEnabled();
+    const actors = await this.listActorsInternal();
+    if (actors.length >= MAX_TEST_ACTORS) throw new BadRequestException(`最多创建 ${MAX_TEST_ACTORS} 个测试假人`);
+
+    const nickname = dto.nickname.trim();
+    const user = await this.users.create({
+      username: `test_actor_${randomUUID().replace(/-/g, '').slice(0, 18)}`,
+      nickname,
+      role: 1,
+      email_verified: true,
+      is_test_account: true,
+    });
+    await this.accountProfiles.ensureProfile(user.id, dto.skinId || 'classic_whale');
+    await this.accountProfiles.updateAccountProfile(user.id, { settings: { room_visit_policy: 'public' } });
+
+    const presence: TestLabPresence = {
+      userId: user.id.toString(),
+      username: user.username,
+      nickname: user.nickname,
+      mapId: dto.mapId,
+      x: dto.x,
+      y: dto.y,
+      skinId: dto.skinId || 'classic_whale',
+      avatarId: 'default',
+      online: true,
+    };
+    this.gateway.setTestLabPresence(presence);
+    await this.record(admin, 'CREATE', 'test_lab_actor', user.id.toString(), '创建测试假人');
+    return await this.serializeActor(user, presence);
+  }
+
+  async updateActor(userId: string, dto: UpdateTestLabActorDto, admin: AdminActor) {
+    this.assertEnabled();
+    const user = await this.requireActor(userId);
+    const current = getTestLabPresence(user.id) || this.offlinePresence(user);
+    const next: TestLabPresence = {
+      ...current,
+      online: dto.online ?? current.online,
+      mapId: dto.mapId ?? current.mapId,
+      x: dto.x ?? current.x,
+      y: dto.y ?? current.y,
+      skinId: dto.skinId ?? current.skinId,
+    };
+    this.gateway.setTestLabPresence(next);
+    await this.record(admin, 'UPDATE', 'test_lab_actor', userId, '更新测试假人状态');
+    return await this.serializeActor(user, next);
+  }
+
+  async setRoomPolicy(userId: string, dto: TestLabRoomPolicyDto, admin: AdminActor) {
+    this.assertEnabled();
+    const user = await this.requireActor(userId);
+    await this.accountProfiles.updateAccountProfile(user.id, { settings: { room_visit_policy: dto.roomVisitPolicy } });
+    await this.record(admin, 'UPDATE', 'test_lab_actor', userId, '更新测试假人房间访问策略');
+    return await this.serializeActor(user, getTestLabPresence(user.id) || this.offlinePresence(user));
+  }
+
+  async sendMessage(userId: string, dto: TestLabMessageDto, admin: AdminActor) {
+    this.assertEnabled();
+    const actor = await this.requireOnlineActor(userId);
+    const content = dto.content.trim();
+    if (dto.scope === 'private') {
+      const targetId = this.requireOnlineTarget(dto.targetUserId || '');
+      await this.social.sendTestDirectMessage(actor.id, BigInt(targetId), content);
+    } else {
+      this.gateway.broadcastTestLabChat(getTestLabPresence(actor.id) as TestLabPresence, content, dto.scope);
+    }
+    await this.record(admin, 'CREATE', 'test_lab_message', userId, `测试假人发送${dto.scope === 'private' ? '私聊' : '公共消息'}`);
+    return { success: true };
+  }
+
+  async socialAction(userId: string, dto: TestLabSocialActionDto, admin: AdminActor) {
+    this.assertEnabled();
+    const actor = await this.requireOnlineActor(userId);
+    const targetId = this.requireOnlineTarget(dto.targetUserId);
+    const target = BigInt(targetId);
+    let result: unknown;
+    if (dto.action === 'friend_request') result = await this.social.createTestFriendRequest(actor.id, target);
+    else if (dto.action === 'friend_accept') result = await this.social.respondToTestFriendRequest(actor.id, target, true);
+    else if (dto.action === 'friend_reject') result = await this.social.respondToTestFriendRequest(actor.id, target, false);
+    else result = await this.social.blockUser(actor.id, target);
+    await this.record(admin, 'UPDATE', 'test_lab_social', userId, `测试假人执行${dto.action}`);
+    return result;
+  }
+
+  async removeActor(userId: string, admin: AdminActor) {
+    this.assertEnabled();
+    const user = await this.requireActor(userId);
+    this.gateway.removeTestLabActor(user.id.toString());
+    await this.removeAccounts([user]);
+    await this.record(admin, 'DELETE', 'test_lab_actor', userId, '删除测试假人');
+    return { success: true };
+  }
+
+  async clear(admin: AdminActor) {
+    this.assertEnabled();
+    const count = await this.clearTestAccounts('manual');
+    await this.record(admin, 'DELETE', 'test_lab_actor', undefined, `清空 ${count} 个测试假人`);
+    return { success: true, count };
+  }
+
+  private isTestEnvironment(): boolean {
+    const environment = this.config.get<string>('NODE_ENV', 'development');
+    return environment === 'development' || environment === 'test';
+  }
+
+  private assertEnabled(): void {
+    if (!this.isEnabled()) throw new ForbiddenException('测试实验室仅在已启用的开发/测试环境可用');
+  }
+
+  private async listActorsInternal() {
+    const users = await this.users.findAll(MAX_TEST_ACTORS + 20, 0);
+    return Promise.all(users
+      .filter((user) => user.is_test_account === true)
+      .map((user) => this.serializeActor(user, getTestLabPresence(user.id) || this.offlinePresence(user))));
+  }
+
+  private async requireActor(userId: string): Promise<Users> {
+    if (!/^\d+$/.test(userId)) throw new BadRequestException('测试假人用户 ID 无效');
+    const user = await this.users.findOne(BigInt(userId));
+    if (user.is_test_account !== true) throw new ForbiddenException('目标不是测试实验室账号');
+    return user;
+  }
+
+  private async requireOnlineActor(userId: string): Promise<Users> {
+    const actor = await this.requireActor(userId);
+    if (!getTestLabPresence(actor.id)?.online) throw new BadRequestException('测试假人当前不在线');
+    return actor;
+  }
+
+  private requireOnlineTarget(userId: string): string {
+    if (!/^\d+$/.test(userId)) throw new BadRequestException('目标用户 ID 无效');
+    if (!this.gateway.getOnlineWorldPlayers().some((player) => player.userId === userId)) {
+      throw new BadRequestException('目标玩家当前不在线');
+    }
+    return userId;
+  }
+
+  private offlinePresence(user: Users): TestLabPresence {
+    return {
+      userId: user.id.toString(), username: user.username, nickname: user.nickname,
+      mapId: 'whale_port', x: 1280, y: 960, skinId: 'classic_whale', avatarId: 'default', online: false,
+    };
+  }
+
+  private async serializeActor(user: Users, presence: TestLabPresence) {
+    const account = await this.accountProfiles.getAccountProfile(user.id);
+    const configuredPolicy = account.profile.settings?.room_visit_policy;
+    const roomVisitPolicy = configuredPolicy === 'friends' || configuredPolicy === 'public' || configuredPolicy === 'closed'
+      ? configuredPolicy
+      : 'friends';
+    return {
+      userId: user.id.toString(), username: user.username, nickname: user.nickname,
+      mapId: presence.mapId, x: presence.x, y: presence.y,
+      skinId: presence.skinId, avatarId: presence.avatarId, online: presence.online, roomVisitPolicy,
+    };
+  }
+
+  private async clearTestAccounts(reason: 'startup' | 'manual'): Promise<number> {
+    const users = (await this.users.findAll(MAX_TEST_ACTORS + 20, 0)).filter((user) => user.is_test_account === true);
+    if (users.length === 0) {
+      if (reason === 'startup') clearTestLabPresences();
+      return 0;
+    }
+    for (const presence of getAllTestLabPresences()) this.gateway.removeTestLabActor(presence.userId);
+    await this.removeAccounts(users);
+    this.logger.log(`测试实验室已清理 ${users.length} 个假人账号`, { reason });
+    return users.length;
+  }
+
+  private async removeAccounts(users: Users[]): Promise<void> {
+    const ids = users.map((user) => user.id);
+    for (const user of users) this.gateway.removeTestLabActor(user.id.toString());
+    await this.social.purgeTestUsers(ids);
+    await this.purgeDomainRows(ids);
+    for (const user of users) await this.users.remove(user.id);
+  }
+
+  private async purgeDomainRows(ids: bigint[]): Promise<void> {
+    if (!this.dataSource || ids.length === 0) return;
+    const values = ids.map((id) => id.toString());
+    const placeholders = values.map(() => '?').join(', ');
+    const runner = this.dataSource.createQueryRunner();
+    await runner.connect();
+    try {
+      for (const table of ['room_decor_placements', 'user_assets', 'wallet_transactions', 'user_wallets', 'player_task_progress', 'user_profiles']) {
+        try {
+          await runner.query(`DELETE FROM \`${table}\` WHERE \`user_id\` IN (${placeholders})`, values);
+        } catch (error) {
+          this.logger.debug(`测试实验室清理跳过不可用表 ${table}`, { error: error instanceof Error ? error.message : String(error) });
+        }
+      }
+    } finally {
+      await runner.release();
+    }
+  }
+
+  private async record(admin: AdminActor, operation: 'CREATE' | 'UPDATE' | 'DELETE', targetType: string, targetId: string | undefined, description: string): Promise<void> {
+    try {
+      await this.audit.createLog({
+        adminUserId: admin.adminId,
+        adminUsername: admin.username,
+        operationType: operation,
+        targetType,
+        targetId,
+        operationDescription: description,
+        httpMethodPath: '/admin/test-lab',
+        operationResult: 'SUCCESS',
+        durationMs: 0,
+        requestId: randomUUID(),
+        context: { testLab: true },
+      });
+    } catch (error) {
+      this.logger.warn('测试实验室操作日志写入失败', { error: error instanceof Error ? error.message : String(error) });
+    }
+  }
+}
--- a/src/business/admin/test_lab_presence.registry.ts
+++ b/src/business/admin/test_lab_presence.registry.ts
@@ -0,0 +1,46 @@
+export type TestLabPresence = {
+  userId: string;
+  username: string;
+  nickname: string;
+  mapId: string;
+  x: number;
+  y: number;
+  skinId: string;
+  avatarId: string;
+  online: boolean;
+};
+
+const presences = new Map<string, TestLabPresence>();
+
+export function upsertTestLabPresence(presence: TestLabPresence): TestLabPresence {
+  const normalized = { ...presence, userId: String(presence.userId), online: Boolean(presence.online) };
+  presences.set(normalized.userId, normalized);
+  return { ...normalized };
+}
+
+export function getTestLabPresence(userId: string | bigint): TestLabPresence | null {
+  const presence = presences.get(String(userId));
+  return presence ? { ...presence } : null;
+}
+
+export function getTestLabPresences(mapId?: string): TestLabPresence[] {
+  return [...presences.values()]
+    .filter((presence) => presence.online && (!mapId || presence.mapId === mapId))
+    .map((presence) => ({ ...presence }));
+}
+
+export function getAllTestLabPresences(): TestLabPresence[] {
+  return [...presences.values()].map((presence) => ({ ...presence }));
+}
+
+export function removeTestLabPresence(userId: string | bigint): TestLabPresence | null {
+  const existing = presences.get(String(userId));
+  presences.delete(String(userId));
+  return existing ? { ...existing } : null;
+}
+
+export function clearTestLabPresences(): TestLabPresence[] {
+  const existing = getTestLabPresences();
+  presences.clear();
+  return existing;
+}
--- a/src/business/auth/account_profile.service.ts
+++ b/src/business/auth/account_profile.service.ts
@@ -56,7 +56,8 @@ export interface AccountProfilePayload {
  };
 }

-export type AccountSettings = Record<string, boolean | number>;
+export type RoomVisitPolicy = 'friends' | 'public' | 'closed';
+export type AccountSettings = Record<string, boolean | number | RoomVisitPolicy>;

 export interface UpdateAccountProfileRequest {
  skin_id?: string;
@@ -101,6 +102,7 @@ const DEFAULT_ACCOUNT_SETTINGS: AccountSettings = {
  allow_nearby_private: true,
  allow_nearby_friend_requests: true,
  allow_nearby_profile: true,
+  room_visit_policy: 'friends',
  mute_ui_sfx: false,
 };
 const ACCOUNT_SETTING_NUMBER_KEYS = new Set(['master_volume', 'music_volume', 'effects_volume', 'ui_scale']);
@@ -118,6 +120,7 @@ const ACCOUNT_SETTING_BOOLEAN_KEYS = new Set([
  'allow_nearby_profile',
  'mute_ui_sfx',
 ]);
+const ROOM_VISIT_POLICIES = new Set<RoomVisitPolicy>(['friends', 'public', 'closed']);

 export interface AccountSkinAsset {
  id: string;
@@ -669,6 +672,8 @@ export class AccountProfileService {
        }
      } else if (ACCOUNT_SETTING_BOOLEAN_KEYS.has(key)) {
        sanitized[key] = typeof value === 'boolean' ? value : value === 'true' || value === 1 || value === '1';
+      } else if (key === 'room_visit_policy' && typeof value === 'string' && ROOM_VISIT_POLICIES.has(value as RoomVisitPolicy)) {
+        sanitized[key] = value as RoomVisitPolicy;
      }
    }
    return sanitized;
--- a/src/business/mall/mall_catalog.ts
+++ b/src/business/mall/mall_catalog.ts
@@ -1,3 +1,5 @@
+import { ROOM_DECOR_DEFINITIONS } from '../room_decor/room_decor_catalog';
+
 export type MallItemType = 'skin' | 'room_decor';

 export interface MallCatalogItem {
@@ -23,6 +25,19 @@ export const MALL_CATEGORIES = [
  { id: 'limited', label: '限时', icon: 'limited' },
 ];

+const ROOM_DECOR_MALL_ITEMS: MallCatalogItem[] = ROOM_DECOR_DEFINITIONS.map((definition) => ({
+  itemId: definition.item_id,
+  itemType: 'room_decor',
+  decorId: definition.decor_id,
+  icon: definition.icon,
+  name: definition.name,
+  category: definition.shop.category,
+  description: definition.shop.description,
+  price: definition.shop.price,
+  tags: definition.shop.tags,
+  sortOrder: definition.shop.sort_order,
+}));
+
 export const MALL_ITEMS: MallCatalogItem[] = [
  {
    itemId: 'skin_classic_whale',
@@ -81,126 +96,7 @@ export const MALL_ITEMS: MallCatalogItem[] = [
    tags: ['可预览', '永久', '皮肤'],
    sortOrder: 50,
  },
-  {
-    itemId: 'decor_whale_floor_rug',
-    itemType: 'room_decor',
-    decorId: 'whale_floor_rug',
-    icon: 'res://assets/ui/mall/items/room_decor_whale_floor_rug.png',
-    name: '鲸浪地毯',
-    category: 'space',
-    description: '蓝白鲸鱼主题地毯，适合铺在个人房间地板区域。',
-    price: 260,
-    tags: ['房间家具', '可拖拽', '地面'],
-    sortOrder: 110,
-  },
-  {
-    itemId: 'decor_whale_memory_board',
-    itemType: 'room_decor',
-    decorId: 'whale_memory_board',
-    icon: 'res://assets/ui/mall/items/room_decor_whale_memory_board.png',
-    name: '鲸语记忆板',
-    category: 'space',
-    description: '挂在房间里的鲸鱼木质装饰板，适合点缀窗边墙面。',
-    price: 220,
-    tags: ['房间家具', '可拖拽', '挂件'],
-    sortOrder: 120,
-  },
-  {
-    itemId: 'decor_whale_tail_lamp',
-    itemType: 'room_decor',
-    decorId: 'whale_tail_lamp',
-    icon: 'res://assets/ui/mall/items/room_decor_whale_tail_lamp.png',
-    name: '鲸尾暖灯',
-    category: 'space',
-    description: '鲸尾造型的温暖装饰灯，可自由摆放在个人房间中。',
-    price: 360,
-    tags: ['房间家具', '可拖拽', '灯具'],
-    sortOrder: 130,
-  },
-  {
-    itemId: 'decor_boat_cabin_bed',
-    itemType: 'room_decor',
-    decorId: 'boat_cabin_bed',
-    icon: 'res://assets/ui/mall/items/room_decor_boat_cabin_bed.png',
-    name: '船舱小床',
-    category: 'space',
-    description: '白木船舱造型的小床，适合放在个人房间地面区域。',
-    price: 520,
-    tags: ['房间家具', '可拖拽', '床'],
-    sortOrder: 140,
-  },
-  {
-    itemId: 'decor_low_wave_bed',
-    itemType: 'room_decor',
-    decorId: 'low_wave_bed',
-    icon: 'res://assets/ui/mall/items/room_decor_low_wave_bed.png',
-    name: '海浪低床',
-    category: 'space',
-    description: '蓝白海浪被面的低矮小床，适合轻松的海风房间。',
-    price: 500,
-    tags: ['房间家具', '可拖拽', '床'],
-    sortOrder: 150,
-  },
-  {
-    itemId: 'decor_whale_tail_headboard_bed',
-    itemType: 'room_decor',
-    decorId: 'whale_tail_headboard_bed',
-    icon: 'res://assets/ui/mall/items/room_decor_whale_tail_headboard_bed.png',
-    name: '鲸尾床头床',
-    category: 'space',
-    description: '鲸尾床头和深蓝被面的主题小床，鲸镇特色更明显。',
-    price: 580,
-    tags: ['房间家具', '可拖拽', '床'],
-    sortOrder: 180,
-  },
-  {
-    itemId: 'decor_dev_whale_bookshelf',
-    itemType: 'room_decor',
-    decorId: 'dev_whale_bookshelf',
-    icon: 'res://assets/ui/mall/items/room_decor_dev_whale_bookshelf.png',
-    name: '程序员鲸书架',
-    category: 'space',
-    description: '带 GitHub、Datawhale 和代码小物件的蓝白书架，适合程序员风格的个人房间。',
-    price: 620,
-    tags: ['房间家具', '可拖拽', '书架'],
-    sortOrder: 190,
-  },
-  {
-    itemId: 'decor_datawhale_bug_feature_badge',
-    itemType: 'room_decor',
-    decorId: 'datawhale_bug_feature_badge',
-    icon: 'res://assets/ui/mall/items/room_decor_datawhale_bug_feature_badge.png',
-    name: 'BUG特性徽章',
-    category: 'space',
-    description: '写着“这不是BUG 这是feature”的佛系学习小徽章，适合贴在个人房间墙面。',
-    price: 120,
-    tags: ['房间家具', '可拖拽', '徽章'],
-    sortOrder: 200,
-  },
-  {
-    itemId: 'decor_datawhale_buddhist_learning_badge',
-    itemType: 'room_decor',
-    decorId: 'datawhale_buddhist_learning_badge',
-    icon: 'res://assets/ui/mall/items/room_decor_datawhale_buddhist_learning_badge.png',
-    name: '佛系学习徽章',
-    category: 'space',
-    description: 'Datawhale 佛系学习主题徽章，适合贴在个人房间墙面。',
-    price: 140,
-    tags: ['房间家具', '可拖拽', '徽章'],
-    sortOrder: 210,
-  },
-  {
-    itemId: 'decor_datawhale_ok_working_badge',
-    itemType: 'room_decor',
-    decorId: 'datawhale_ok_working_badge',
-    icon: 'res://assets/ui/mall/items/room_decor_datawhale_ok_working_badge.png',
-    name: '已经在做徽章',
-    category: 'space',
-    description: '写着“OKKKK 已经在做了”的工作状态徽章，适合贴在个人房间墙面。',
-    price: 120,
-    tags: ['房间家具', '可拖拽', '徽章'],
-    sortOrder: 220,
-  },
+	...ROOM_DECOR_MALL_ITEMS,
 ];

 export const MALL_SKIN_ITEMS = MALL_ITEMS.filter((item) => item.itemType === 'skin' && item.skinId);
--- a/src/business/player/player.types.ts
+++ b/src/business/player/player.types.ts
@@ -48,5 +48,5 @@ export interface PlayerSnapshotPayload {
    owned_skin_ids: string[];
    owned_skins: unknown[];
  };
-  settings: Record<string, boolean | number>;
+  settings: Record<string, boolean | number | string>;
 }
--- a/src/business/room_decor/dto/reset_room_decor_placements.dto.ts
+++ b/src/business/room_decor/dto/reset_room_decor_placements.dto.ts
@@ -0,0 +1,16 @@
+import { IsInt, IsString, Length, Matches, Min } from 'class-validator';
+
+export class ResetRoomDecorPlacementsDto {
+  @IsInt({ message: '布局版本必须是整数' })
+  @Min(0, { message: '布局版本不能小于0' })
+  layout_revision!: number;
+
+  @IsInt({ message: 'mutation版本必须是整数' })
+  @Min(1, { message: 'mutation版本必须大于0' })
+  mutation_revision!: number;
+
+  @IsString({ message: 'mutation ID必须是字符串' })
+  @Length(16, 64, { message: 'mutation ID长度需在16-64字符之间' })
+  @Matches(/^[A-Za-z0-9_-]+$/, { message: 'mutation ID格式不正确' })
+  mutation_id!: string;
+}
--- a/src/business/room_decor/dto/save_room_decor_placement.dto.ts
+++ b/src/business/room_decor/dto/save_room_decor_placement.dto.ts
@@ -1,10 +1,11 @@
-import { IsBoolean, IsNumber, IsOptional, IsString, Length, Matches, Max, Min } from 'class-validator';
+import { IsBoolean, IsInt, IsNumber, IsOptional, IsString, Length, Matches, Max, Min } from 'class-validator';

 export class SaveRoomDecorPlacementDto {
+  @IsOptional()
  @IsString({ message: '摆件ID必须是字符串' })
  @Length(1, 100, { message: '摆件ID长度需在1-100字符之间' })
  @Matches(/^[A-Za-z0-9_:-]+$/, { message: '摆件ID格式不正确' })
-  decor_id!: string;
+  decor_id?: string;

  @IsBoolean({ message: '摆放状态必须是布尔值' })
  placed!: boolean;
@@ -27,9 +28,29 @@ export class SaveRoomDecorPlacementDto {
  @Max(4, { message: '缩放不能太大' })
  scale?: number;

+  @IsOptional()
+  @IsNumber({}, { message: '旋转角度必须是数字' })
+  @IsInt({ message: '旋转角度必须是整数' })
+  @Min(0, { message: '旋转角度超出范围' })
+  @Max(270, { message: '旋转角度超出范围' })
+  rotation_degrees?: number;
+
  @IsOptional()
  @IsNumber({}, { message: '层级必须是数字' })
  @Min(-1000, { message: '层级超出范围' })
  @Max(1000, { message: '层级超出范围' })
  z_index?: number;
+
+  @IsInt({ message: '布局版本必须是整数' })
+  @Min(0, { message: '布局版本不能小于0' })
+  layout_revision!: number;
+
+  @IsInt({ message: 'mutation版本必须是整数' })
+  @Min(1, { message: 'mutation版本必须大于0' })
+  mutation_revision!: number;
+
+  @IsString({ message: 'mutation ID必须是字符串' })
+  @Length(16, 64, { message: 'mutation ID长度需在16-64字符之间' })
+  @Matches(/^[A-Za-z0-9_-]+$/, { message: 'mutation ID格式不正确' })
+  mutation_id!: string;
 }
--- a/src/business/room_decor/room_decor.controller.ts
+++ b/src/business/room_decor/room_decor.controller.ts
@@ -1,15 +1,16 @@
-import { Body, Controller, Get, HttpStatus, Param, Put, Res, UseGuards, UsePipes, ValidationPipe } from '@nestjs/common';
+import { BadRequestException, Body, Controller, Get, HttpStatus, Param, Post, Put, Res, UseGuards, UsePipes, ValidationPipe } from '@nestjs/common';
 import { ApiBearerAuth, ApiOperation, ApiResponse as SwaggerApiResponse, ApiTags } from '@nestjs/swagger';
 import { Response } from 'express';
 import { JwtPayload } from '../../core/login_core/login_core.service';
 import { CurrentUser } from '../../gateway/auth/current_user.decorator';
 import { JwtAuthGuard } from '../../gateway/auth/jwt_auth.guard';
 import { SaveRoomDecorPlacementDto } from './dto/save_room_decor_placement.dto';
+import { ResetRoomDecorPlacementsDto } from './dto/reset_room_decor_placements.dto';
 import { RoomDecorService } from './room_decor.service';

@ApiTags('room-decor')
@ApiBearerAuth()
-@Controller('rooms/me/decor-placements')
+@Controller('rooms')
@UseGuards(JwtAuthGuard)
 export class RoomDecorController {
  constructor(private readonly roomDecorService: RoomDecorService) {}
@@ -22,7 +23,7 @@ export class RoomDecorController {
    status: 200,
    description: '房间家具背包获取成功',
  })
-  @Get()
+  @Get('me/decor-placements')
  async getInventory(@CurrentUser() user: JwtPayload, @Res() res: Response): Promise<void> {
    const data = await this.roomDecorService.getInventory(BigInt(user.sub));
    res.status(HttpStatus.OK).json({
@@ -32,6 +33,45 @@ export class RoomDecorController {
    });
  }

+  @ApiOperation({
+    summary: '参观其他玩家的房间布局',
+    description: '按房主访问策略返回只读布局；拉黑关系始终拒绝访问。',
+  })
+  @SwaggerApiResponse({ status: 200, description: '只读房间布局获取成功' })
+  @Get(':ownerUserId/decor-placements')
+  async getRoomView(
+    @CurrentUser() user: JwtPayload,
+    @Param('ownerUserId') ownerUserId: string,
+    @Res() res: Response,
+  ): Promise<void> {
+    const data = await this.roomDecorService.getRoomView(BigInt(user.sub), this.parseUserId(ownerUserId));
+    res.status(HttpStatus.OK).json({
+      success: true,
+      data,
+      message: '房间布局获取成功',
+    });
+  }
+
+  @ApiOperation({
+    summary: '收回当前账号所有已摆放家具',
+    description: '仅清空布局，不删除已拥有家具资产。',
+  })
+  @SwaggerApiResponse({ status: 200, description: '房间布局已重置' })
+  @Post('me/decor-placements/reset')
+  @UsePipes(new ValidationPipe({ transform: true, whitelist: true }))
+  async resetPlacements(
+    @CurrentUser() user: JwtPayload,
+    @Body() dto: ResetRoomDecorPlacementsDto,
+    @Res() res: Response,
+  ): Promise<void> {
+    const data = await this.roomDecorService.resetPlacements(BigInt(user.sub), dto);
+    res.status(HttpStatus.OK).json({
+      success: true,
+      data,
+      message: '房间布局已重置，家具已收回背包',
+    });
+  }
+
  @ApiOperation({
    summary: '保存房间家具摆放',
    description: '保存当前账号某个家具的摆放状态、位置、缩放和层级。',
@@ -40,7 +80,7 @@ export class RoomDecorController {
    status: 200,
    description: '家具摆放保存成功',
  })
-  @Put(':decorId')
+  @Put('me/decor-placements/:decorId')
  @UsePipes(new ValidationPipe({ transform: true, whitelist: true }))
  async savePlacement(
    @CurrentUser() user: JwtPayload,
@@ -58,4 +98,11 @@ export class RoomDecorController {
      message: '家具摆放保存成功',
    });
  }
+
+  private parseUserId(value: string): bigint {
+    if (!/^\d+$/.test(value)) {
+      throw new BadRequestException('房主用户ID格式不正确');
+    }
+    return BigInt(value);
+  }
 }
--- a/src/business/room_decor/room_decor.service.ts
+++ b/src/business/room_decor/room_decor.service.ts
@@ -1,6 +1,8 @@
 import { BadRequestException, Inject, Injectable } from '@nestjs/common';
 import { InventoryService } from '../player/inventory.service';
+import { SocialService } from '../social/social.service';
 import { SaveRoomDecorPlacementDto } from './dto/save_room_decor_placement.dto';
+import { ResetRoomDecorPlacementsDto } from './dto/reset_room_decor_placements.dto';
 import {
  ROOM_DECOR_BED_DEFAULT_SCALE,
  ROOM_DECOR_DEFINITIONS,
@@ -8,6 +10,7 @@ import {
  ROOM_DECOR_LEGACY_BED_MAX_SCALE,
  ROOM_DECOR_LEGACY_WALL_DECOR_SCALES,
  ROOM_DECOR_ROOM_SCALE,
+  RoomDecorDefinition,
  findRoomDecorDefinition,
 } from './room_decor_catalog';

@@ -17,18 +20,22 @@ interface UserRoomDecorRow {
  position_x: number | null;
  position_y: number | null;
  scale: number;
+  rotation_degrees?: number;
  z_index: number;
+  mutation_revision?: number;
 }

 interface IRoomDecorPlacementsService {
-  listPlacements(userId: bigint): Promise<UserRoomDecorRow[]>;
-  savePlacement(userId: bigint, placement: SaveRoomDecorPlacementDto): Promise<UserRoomDecorRow>;
+  getSnapshot(userId: bigint): Promise<{ revision: number; placements: UserRoomDecorRow[] }>;
+  savePlacement(userId: bigint, placement: SaveRoomDecorPlacementDto): Promise<{ revision: number; placement: UserRoomDecorRow }>;
+  resetPlacements(userId: bigint, mutation: ResetRoomDecorPlacementsDto): Promise<{ revision: number; placements: UserRoomDecorRow[] }>;
 }

 interface RoomDecorPayloadPlacement {
  position_x: number | null;
  position_y: number | null;
  scale: number;
+  rotation_degrees: number;
 }

@Injectable()
@@ -36,13 +43,15 @@ export class RoomDecorService {
  constructor(
    @Inject('IRoomDecorPlacementsService') private readonly roomDecorPlacementsService: IRoomDecorPlacementsService,
    private readonly inventoryService: InventoryService,
+    private readonly socialService: SocialService,
  ) {}

  async getInventory(userId: bigint) {
-    const [inventory, placements] = await Promise.all([
+    const [inventory, snapshot] = await Promise.all([
      this.inventoryService.listInventory(userId, 'room_decor'),
-      this.roomDecorPlacementsService.listPlacements(userId),
+      this.roomDecorPlacementsService.getSnapshot(userId),
    ]);
+    const placements = snapshot.placements;
    const placementByDecorId = new Map(placements.map((row) => [row.decor_id, row]));
    const rows = inventory.room_decor_ids.map((decorId) => {
      const definition = findRoomDecorDefinition(decorId);
@@ -53,6 +62,7 @@ export class RoomDecorService {
        position_x: definition?.default_position.x ?? null,
        position_y: definition?.default_position.y ?? null,
        scale: definition?.default_scale ?? 1,
+        rotation_degrees: definition?.default_rotation_degrees ?? 0,
        z_index: definition?.default_z_index ?? 0,
      };
    });
@@ -61,23 +71,67 @@ export class RoomDecorService {
        .filter((row) => findRoomDecorDefinition(row.decor_id))
        .map((row) => this.toPayload(row)),
      definitions: ROOM_DECOR_DEFINITIONS,
+      revision: snapshot.revision,
    };
  }

  async savePlacement(userId: bigint, placement: SaveRoomDecorPlacementDto) {
-    const definition = findRoomDecorDefinition(placement.decor_id);
+    const decorId = placement.decor_id?.trim() || '';
+    const definition = findRoomDecorDefinition(decorId);
    if (!definition) {
      throw new BadRequestException('摆件不存在或暂未开放');
    }
-    if (!(await this.inventoryService.hasAsset(userId, 'room_decor', placement.decor_id))) {
+    if (!(await this.inventoryService.hasAsset(userId, 'room_decor', decorId))) {
      throw new BadRequestException('尚未拥有该房间摆件');
    }
-    const row = await this.roomDecorPlacementsService.savePlacement(userId, {
+    const rotationDegrees = placement.rotation_degrees ?? definition.default_rotation_degrees;
+    if (!definition.rotation_steps.includes(rotationDegrees)) {
+      throw new BadRequestException('该摆件不支持此旋转角度');
+    }
+    const positionX = this.snapToGrid(placement.position_x ?? definition.default_position.x, definition.grid_size);
+    const positionY = this.snapToGrid(placement.position_y ?? definition.default_position.y, definition.grid_size);
+    if (placement.placed && !this.isWithinPlacementBounds(positionX, positionY, definition)) {
+      throw new BadRequestException(definition.placement_surface === 'wall'
+        ? '墙面挂饰只能摆放在墙面网格内'
+        : '地面家具只能摆放在地面网格内');
+    }
+    const result = await this.roomDecorPlacementsService.savePlacement(userId, {
      ...placement,
+      decor_id: decorId,
+      position_x: positionX,
+      position_y: positionY,
      scale: placement.scale ?? definition.default_scale,
+      rotation_degrees: rotationDegrees,
      z_index: placement.z_index ?? definition.default_z_index,
    });
-    return this.toPayload(row);
+    return {
+      ...this.toPayload(result.placement),
+      layout_revision: result.revision,
+    };
+  }
+
+  async getRoomView(viewerId: bigint, ownerId: bigint) {
+    const owner = await this.socialService.getRoomOwnerProfile(viewerId, ownerId);
+    const [inventory, snapshot] = await Promise.all([
+      this.inventoryService.listInventory(ownerId, 'room_decor'),
+      this.roomDecorPlacementsService.getSnapshot(ownerId),
+    ]);
+    const placements = snapshot.placements;
+    const ownedDecorIds = new Set(inventory.room_decor_ids);
+    return {
+      owner,
+      read_only: true,
+      items: placements
+        .filter((row) => row.placed && ownedDecorIds.has(row.decor_id) && Boolean(findRoomDecorDefinition(row.decor_id)))
+        .map((row) => this.toPayload(row)),
+      definitions: ROOM_DECOR_DEFINITIONS,
+      revision: snapshot.revision,
+    };
+  }
+
+  async resetPlacements(userId: bigint, mutation: ResetRoomDecorPlacementsDto) {
+    await this.roomDecorPlacementsService.resetPlacements(userId, mutation);
+    return this.getInventory(userId);
  }

  private toPayload(row: UserRoomDecorRow) {
@@ -93,26 +147,36 @@ export class RoomDecorService {
      position_x: placement.position_x,
      position_y: placement.position_y,
      scale: placement.scale,
+      rotation_degrees: placement.rotation_degrees,
      z_index: row.z_index ?? definition?.default_z_index ?? 0,
+      mutation_revision: row.mutation_revision ?? 0,
+      category: definition?.category ?? 'floor',
+      placement_surface: definition?.placement_surface ?? 'floor',
+      placement_bounds: definition?.placement_bounds,
+      grid_size: definition?.grid_size ?? 16,
+      rotation_steps: definition?.rotation_steps ?? [0],
+      stackable: definition?.stackable ?? false,
      default_position: definition?.default_position ?? { x: 0, y: 0 },
      default_scale: definition?.default_scale ?? 1,
+      default_rotation_degrees: definition?.default_rotation_degrees ?? 0,
      default_z_index: definition?.default_z_index ?? 0,
    };
  }

  private normalizedPlacement(
    row: UserRoomDecorRow,
-    definition?: { default_scale: number; default_position: { x: number; y: number } },
+    definition?: RoomDecorDefinition,
  ): RoomDecorPayloadPlacement {
    const usesLegacyPlacement = this.usesLegacyPlacement(row);
    return {
      position_x: this.normalizedPositionValue(row.position_x, definition?.default_position.x ?? 0, usesLegacyPlacement),
      position_y: this.normalizedPositionValue(row.position_y, definition?.default_position.y ?? 0, usesLegacyPlacement),
      scale: this.normalizedScale(row, definition),
+      rotation_degrees: this.normalizedRotation(row, definition),
    };
  }

-  private normalizedScale(row: UserRoomDecorRow, definition?: { default_scale: number }) {
+  private normalizedScale(row: UserRoomDecorRow, definition?: Pick<RoomDecorDefinition, 'default_scale'>) {
    const scale = row.scale ?? definition?.default_scale ?? 1;
    if (!row.placed && definition) {
      return definition.default_scale;
@@ -146,6 +210,20 @@ export class RoomDecorService {
    return usesLegacyPlacement ? Math.round(value * ROOM_DECOR_ROOM_SCALE) : value;
  }

+  private normalizedRotation(row: UserRoomDecorRow, definition?: RoomDecorDefinition): number {
+    const rotation = row.rotation_degrees ?? definition?.default_rotation_degrees ?? 0;
+    return definition?.rotation_steps.includes(rotation) ? rotation : definition?.default_rotation_degrees ?? 0;
+  }
+
+  private snapToGrid(value: number, gridSize: number): number {
+    return Math.round(value / gridSize) * gridSize;
+  }
+
+  private isWithinPlacementBounds(x: number, y: number, definition: RoomDecorDefinition): boolean {
+    const bounds = definition.placement_bounds;
+    return x >= bounds.min_x && x <= bounds.max_x && y >= bounds.min_y && y <= bounds.max_y;
+  }
+
  private usesLegacyPlacement(row: UserRoomDecorRow) {
    const legacy = ROOM_DECOR_LEGACY_DEFAULTS[row.decor_id];
    if (!legacy) {
--- a/src/business/room_decor/room_decor_catalog.ts
+++ b/src/business/room_decor/room_decor_catalog.ts
@@ -2,14 +2,28 @@ export interface RoomDecorDefinition {
  decor_id: string;
  name: string;
  item_id: string;
+  category: 'floor' | 'rug' | 'wall';
+  placement_surface: 'floor' | 'wall';
+  placement_bounds: RoomDecorPlacementBounds;
+  grid_size: number;
+  rotation_steps: number[];
+  stackable: boolean;
  icon: string;
  texture?: string;
  default_scale: number;
+  default_rotation_degrees: number;
  default_position: {
    x: number;
    y: number;
  };
  default_z_index: number;
+  shop: {
+    category: 'space';
+    description: string;
+    price: number;
+    tags: string[];
+    sort_order: number;
+  };
  collision_size?: {
    x: number;
    y: number;
@@ -20,6 +34,13 @@ export interface RoomDecorDefinition {
  };
 }

+export interface RoomDecorPlacementBounds {
+  min_x: number;
+  max_x: number;
+  min_y: number;
+  max_y: number;
+}
+
 export interface RoomDecorLegacyDefault {
  scale: number;
  default_position: {
@@ -35,6 +56,18 @@ export const ROOM_DECOR_FLOOR_RUG_DEFAULT_SCALE = 1.0;
 export const ROOM_DECOR_WALL_DECOR_DEFAULT_SCALE = 0.04;
 export const ROOM_DECOR_LEGACY_BED_MAX_SCALE = 0.35;
 export const ROOM_DECOR_LEGACY_WALL_DECOR_SCALES = [0.7, 0.18];
+export const ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS: RoomDecorPlacementBounds = {
+  min_x: -426,
+  max_x: 426,
+  min_y: -176,
+  max_y: 212,
+};
+export const ROOM_DECOR_WALL_PLACEMENT_BOUNDS: RoomDecorPlacementBounds = {
+  min_x: -378,
+  max_x: 378,
+  min_y: -258,
+  max_y: -192,
+};

 export const ROOM_DECOR_LEGACY_DEFAULTS: Record<string, RoomDecorLegacyDefault> = {
  whale_floor_rug: {
@@ -84,30 +117,54 @@ export const ROOM_DECOR_DEFINITIONS: RoomDecorDefinition[] = [
    decor_id: 'whale_floor_rug',
    item_id: 'decor_whale_floor_rug',
    name: '鲸浪地毯',
+    category: 'rug',
+    placement_surface: 'floor',
+    placement_bounds: ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_whale_floor_rug.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_whale_floor_rug_roomfit.png',
    default_scale: ROOM_DECOR_FLOOR_RUG_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: 0, y: 161 },
    default_z_index: -8,
+    shop: { category: 'space', description: '蓝白鲸鱼主题地毯，适合铺在个人房间地板区域。', price: 260, tags: ['房间家具', '可拖拽', '地面'], sort_order: 110 },
  },
  {
    decor_id: 'whale_memory_board',
    item_id: 'decor_whale_memory_board',
    name: '鲸语记忆板',
+    category: 'wall',
+    placement_surface: 'wall',
+    placement_bounds: ROOM_DECOR_WALL_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_whale_memory_board.png',
    default_scale: 0.11,
+    default_rotation_degrees: 0,
    default_position: { x: 182, y: -207 },
    default_z_index: -14,
+    shop: { category: 'space', description: '挂在房间里的鲸鱼木质装饰板，适合点缀窗边墙面。', price: 220, tags: ['房间家具', '可拖拽', '挂件'], sort_order: 120 },
  },
  {
    decor_id: 'whale_tail_lamp',
    item_id: 'decor_whale_tail_lamp',
    name: '鲸尾暖灯',
+    category: 'floor',
+    placement_surface: 'floor',
+    placement_bounds: ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0, 90, 180, 270],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_whale_tail_lamp.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_whale_tail_lamp_roomfit.png',
    default_scale: 1,
+    default_rotation_degrees: 0,
    default_position: { x: 231, y: -175 },
    default_z_index: -10,
+    shop: { category: 'space', description: '鲸尾造型的温暖装饰灯，可自由摆放在个人房间中。', price: 360, tags: ['房间家具', '可拖拽', '灯具'], sort_order: 130 },
    collision_size: { x: 50, y: 32 },
    collision_offset: { x: 0, y: 56 },
  },
@@ -115,11 +172,19 @@ export const ROOM_DECOR_DEFINITIONS: RoomDecorDefinition[] = [
    decor_id: 'boat_cabin_bed',
    item_id: 'decor_boat_cabin_bed',
    name: '船舱小床',
+    category: 'floor',
+    placement_surface: 'floor',
+    placement_bounds: ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0, 90, 180, 270],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_boat_cabin_bed.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_boat_cabin_bed_roomfit.png',
    default_scale: ROOM_DECOR_BED_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: -161, y: 25 },
    default_z_index: -9,
+    shop: { category: 'space', description: '白木船舱造型的小床，适合放在个人房间地面区域。', price: 520, tags: ['房间家具', '可拖拽', '床'], sort_order: 140 },
    collision_size: { x: 220, y: 112 },
    collision_offset: { x: 0, y: 52 },
  },
@@ -127,11 +192,19 @@ export const ROOM_DECOR_DEFINITIONS: RoomDecorDefinition[] = [
    decor_id: 'low_wave_bed',
    item_id: 'decor_low_wave_bed',
    name: '海浪低床',
+    category: 'floor',
+    placement_surface: 'floor',
+    placement_bounds: ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0, 90, 180, 270],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_low_wave_bed.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_low_wave_bed_roomfit.png',
    default_scale: ROOM_DECOR_BED_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: -98, y: 39 },
    default_z_index: -9,
+    shop: { category: 'space', description: '蓝白海浪被面的低矮小床，适合轻松的海风房间。', price: 500, tags: ['房间家具', '可拖拽', '床'], sort_order: 150 },
    collision_size: { x: 220, y: 112 },
    collision_offset: { x: 0, y: 56 },
  },
@@ -139,11 +212,19 @@ export const ROOM_DECOR_DEFINITIONS: RoomDecorDefinition[] = [
    decor_id: 'whale_tail_headboard_bed',
    item_id: 'decor_whale_tail_headboard_bed',
    name: '鲸尾床头床',
+    category: 'floor',
+    placement_surface: 'floor',
+    placement_bounds: ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0, 90, 180, 270],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_whale_tail_headboard_bed.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_whale_tail_headboard_bed_roomfit.png',
    default_scale: ROOM_DECOR_BED_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: 0, y: 32 },
    default_z_index: -9,
+    shop: { category: 'space', description: '鲸尾床头和深蓝被面的主题小床，鲸镇特色更明显。', price: 580, tags: ['房间家具', '可拖拽', '床'], sort_order: 180 },
    collision_size: { x: 214, y: 112 },
    collision_offset: { x: 0, y: 62 },
  },
@@ -151,11 +232,19 @@ export const ROOM_DECOR_DEFINITIONS: RoomDecorDefinition[] = [
    decor_id: 'dev_whale_bookshelf',
    item_id: 'decor_dev_whale_bookshelf',
    name: '程序员鲸书架',
+    category: 'floor',
+    placement_surface: 'floor',
+    placement_bounds: ROOM_DECOR_FLOOR_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0, 90, 180, 270],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_dev_whale_bookshelf.png',
    texture: 'res://assets/ui/mall/items/room_decor_dev_whale_bookshelf.png',
    default_scale: ROOM_DECOR_BOOKSHELF_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: -210, y: -39 },
    default_z_index: -10,
+    shop: { category: 'space', description: '带 GitHub、Datawhale 和代码小物件的蓝白书架，适合程序员风格的个人房间。', price: 620, tags: ['房间家具', '可拖拽', '书架'], sort_order: 190 },
    collision_size: { x: 626.667, y: 226.667 },
    collision_offset: { x: 0, y: 580 },
  },
@@ -163,31 +252,55 @@ export const ROOM_DECOR_DEFINITIONS: RoomDecorDefinition[] = [
    decor_id: 'datawhale_bug_feature_badge',
    item_id: 'decor_datawhale_bug_feature_badge',
    name: 'BUG特性徽章',
+    category: 'wall',
+    placement_surface: 'wall',
+    placement_bounds: ROOM_DECOR_WALL_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_datawhale_bug_feature_badge.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_datawhale_bug_feature_badge_hires_clean.png',
    default_scale: ROOM_DECOR_WALL_DECOR_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: -210, y: -203 },
    default_z_index: -14,
+    shop: { category: 'space', description: '写着“这不是BUG 这是feature”的佛系学习小徽章，适合贴在个人房间墙面。', price: 120, tags: ['房间家具', '可拖拽', '徽章'], sort_order: 200 },
  },
  {
    decor_id: 'datawhale_buddhist_learning_badge',
    item_id: 'decor_datawhale_buddhist_learning_badge',
    name: '佛系学习徽章',
+    category: 'wall',
+    placement_surface: 'wall',
+    placement_bounds: ROOM_DECOR_WALL_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_datawhale_buddhist_learning_badge.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_datawhale_buddhist_learning_badge_hires_clean.png',
    default_scale: ROOM_DECOR_WALL_DECOR_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: 0, y: -203 },
    default_z_index: -14,
+    shop: { category: 'space', description: 'Datawhale 佛系学习主题徽章，适合贴在个人房间墙面。', price: 140, tags: ['房间家具', '可拖拽', '徽章'], sort_order: 210 },
  },
  {
    decor_id: 'datawhale_ok_working_badge',
    item_id: 'decor_datawhale_ok_working_badge',
    name: '已经在做徽章',
+    category: 'wall',
+    placement_surface: 'wall',
+    placement_bounds: ROOM_DECOR_WALL_PLACEMENT_BOUNDS,
+    grid_size: 16,
+    rotation_steps: [0],
+    stackable: false,
    icon: 'res://assets/ui/mall/items/room_decor_datawhale_ok_working_badge.png',
    texture: 'res://assets/maps/personal_space/v1/decor/room_decor_datawhale_ok_working_badge_hires_clean.png',
    default_scale: ROOM_DECOR_WALL_DECOR_DEFAULT_SCALE,
+    default_rotation_degrees: 0,
    default_position: { x: 210, y: -203 },
    default_z_index: -14,
+    shop: { category: 'space', description: '写着“OKKKK 已经在做了”的工作状态徽章，适合贴在个人房间墙面。', price: 120, tags: ['房间家具', '可拖拽', '徽章'], sort_order: 220 },
  },
 ];

--- a/src/business/social/social.database-store.ts
+++ b/src/business/social/social.database-store.ts
@@ -58,5 +58,18 @@ export class SocialDatabaseStore implements SocialStore {
  async markNotificationRead(userId: bigint, id: bigint): Promise<SocialNotification | null> { const notification = await this.notifications.findOne({ where: { id, user_id: userId } }); if (!notification) return null; notification.read_at = new Date(); return this.notifications.save(notification); }
  async markAllNotificationsRead(userId: bigint): Promise<number> { const result = await this.notifications.createQueryBuilder().update(SocialNotification).set({ read_at: new Date() }).where('user_id = :userId AND read_at IS NULL', { userId }).execute(); return result.affected || 0; }
  async countUnreadNotifications(userId: bigint): Promise<number> { return this.notifications.count({ where: { user_id: userId, read_at: null, expires_at: MoreThan(new Date()) } }); }
+  async purgeUsers(userIds: bigint[]): Promise<void> {
+    if (userIds.length === 0) return;
+    const ids = userIds;
+    await Promise.all([
+      this.friendships.createQueryBuilder().delete().where('user_low_id IN (:...ids) OR user_high_id IN (:...ids)', { ids }).execute(),
+      this.requests.createQueryBuilder().delete().where('requester_id IN (:...ids) OR recipient_id IN (:...ids)', { ids }).execute(),
+      this.blocks.createQueryBuilder().delete().where('user_id IN (:...ids) OR blocked_user_id IN (:...ids)', { ids }).execute(),
+      this.messages.createQueryBuilder().delete().where('sender_id IN (:...ids) OR recipient_id IN (:...ids)', { ids }).execute(),
+      this.reports.createQueryBuilder().delete().where('reporter_id IN (:...ids) OR reported_user_id IN (:...ids)', { ids }).execute(),
+      this.unlocks.createQueryBuilder().delete().where('user_id IN (:...ids)', { ids }).execute(),
+      this.notifications.createQueryBuilder().delete().where('user_id IN (:...ids)', { ids }).orWhere("JSON_CONTAINS(action_metadata, JSON_OBJECT('testLab', true))").execute(),
+    ]);
+  }
  async cleanupExpired(now: Date): Promise<void> { await Promise.all([this.requests.delete({ status: FriendRequestStatus.PENDING, expires_at: LessThan(now) }), this.messages.delete({ expires_at: LessThan(now) }), this.notifications.delete({ expires_at: LessThan(now) })]); }
 }
--- a/src/business/social/social.memory-store.ts
+++ b/src/business/social/social.memory-store.ts
@@ -74,5 +74,16 @@ export class SocialMemoryStore implements SocialStore {
  async markNotificationRead(userId: bigint, id: bigint): Promise<SocialNotification | null> { const item = this.notifications.find((entry) => entry.user_id === userId && entry.id === id); if (item) { item.read_at = new Date(); item.updated_at = new Date(); } return item || null; }
  async markAllNotificationsRead(userId: bigint): Promise<number> { let affected = 0; for (const item of this.notifications) if (item.user_id === userId && !item.read_at) { item.read_at = new Date(); item.updated_at = new Date(); affected++; } return affected; }
  async countUnreadNotifications(userId: bigint): Promise<number> { return this.notifications.filter((item) => item.user_id === userId && !item.read_at && item.expires_at > new Date()).length; }
+  async purgeUsers(userIds: bigint[]): Promise<void> {
+    const ids = new Set(userIds.map((id) => id.toString()));
+    const has = (id: bigint) => ids.has(id.toString());
+    this.friendships = this.friendships.filter((item) => !has(item.user_low_id) && !has(item.user_high_id));
+    this.requests = this.requests.filter((item) => !has(item.requester_id) && !has(item.recipient_id));
+    this.blocks = this.blocks.filter((item) => !has(item.user_id) && !has(item.blocked_user_id));
+    this.messages = this.messages.filter((item) => !has(item.sender_id) && !has(item.recipient_id));
+    this.reports = this.reports.filter((item) => !has(item.reporter_id) && !has(item.reported_user_id));
+    this.unlocks = this.unlocks.filter((item) => !has(item.user_id));
+    this.notifications = this.notifications.filter((item) => !has(item.user_id) && !(item.action_metadata as Record<string, unknown> | null)?.testLab);
+  }
  async cleanupExpired(now: Date): Promise<void> { this.requests = this.requests.filter((item) => item.status !== FriendRequestStatus.PENDING || item.expires_at > now); this.messages = this.messages.filter((item) => item.expires_at > now); this.notifications = this.notifications.filter((item) => item.expires_at > now); }
 }
--- a/src/business/social/social.service.ts
+++ b/src/business/social/social.service.ts
@@ -8,6 +8,7 @@ import {
 } from '@nestjs/common';
 import { Cron, CronExpression } from '@nestjs/schedule';
 import { AccountProfileService } from '../auth/account_profile.service';
+import { getTestLabPresence } from '../admin/test_lab_presence.registry';
 import { ChatSessionService } from '../chat/services/chat_session.service';
 import { FriendRequestStatus } from './social.entities';
 import { SOCIAL_STORE, SocialStore } from './social.store';
@@ -39,6 +40,7 @@ const DEFAULT_PRIVACY = {
  allow_nearby_private: true,
  allow_nearby_friend_requests: true,
 };
+const ROOM_VISIT_POLICIES = new Set(['friends', 'public', 'closed']);
 const TRAVEL_MAP_ORIGINS: Record<string, { x: number; y: number }> = {
  whale_port: { x: 1280, y: 960 },
  work_zone: { x: 1280, y: 960 },
@@ -162,6 +164,26 @@ export class SocialService {
    return this.buildProfile(viewerId, targetId, self);
  }

+  async canVisitRoom(viewerId: bigint, ownerId: bigint): Promise<boolean> {
+    if (viewerId === ownerId) return true;
+    const profile = await this.ensureProfile(ownerId);
+    return await this.canVisitRoomWithProfile(viewerId, ownerId, profile);
+  }
+
+  async getRoomOwnerProfile(viewerId: bigint, ownerId: bigint) {
+    if (!(await this.canVisitRoom(viewerId, ownerId))) {
+      throw new ForbiddenException('该玩家的个人空间暂不可访问');
+    }
+    const profile = await this.buildProfile(viewerId, ownerId, viewerId === ownerId);
+    return {
+      id: profile.id,
+      username: profile.username,
+      nickname: profile.nickname,
+      avatarUrl: profile.avatarUrl,
+      skinId: profile.skinId,
+    };
+  }
+
  async getFriends(userId: bigint) {
    const friendships = await this.store.listFriendships(userId);
    const result = [];
@@ -197,6 +219,29 @@ export class SocialService {
    return { id: request.id.toString(), createdAt: request.created_at, expiresAt: request.expires_at };
  }

+  /** 仅供测试实验室调用：使用真实社交记录，但合成玩家无需真实 WebSocket 会话。 */
+  async createTestFriendRequest(requesterId: bigint, targetId: bigint) {
+    this.assertDistinct(requesterId, targetId);
+    await this.assertNotBlockedEitherWay(requesterId, targetId);
+    if (await this.areFriends(requesterId, targetId)) throw new BadRequestException('已经是好友');
+    if (await this.store.findPendingFriendRequest(requesterId, targetId)) throw new BadRequestException('好友请求已发送');
+
+    await this.usersService.findOne(targetId);
+    const request = await this.store.createFriendRequest(requesterId, targetId, new Date(Date.now() + FRIEND_REQUEST_MS));
+    const requester = await this.buildProfile(targetId, requesterId, false);
+    await this.createNotification(targetId, 'friend_request', '新的好友申请', `${requester.nickname} 想与你成为好友`, { requestId: request.id.toString(), userId: requesterId.toString(), testLab: true });
+    await this.sendToUser(targetId, { t: 'friend_request_received', request: { id: request.id.toString(), requester } });
+    return { id: request.id.toString(), createdAt: request.created_at, expiresAt: request.expires_at };
+  }
+
+  async respondToTestFriendRequest(actorId: bigint, requesterId: bigint, accept: boolean) {
+    const request = await this.store.findPendingFriendRequest(requesterId, actorId);
+    if (!request) throw new NotFoundException('不存在待处理的好友申请');
+    return accept
+      ? this.acceptFriendRequest(actorId, request.id)
+      : this.rejectFriendRequest(actorId, request.id);
+  }
+
  async acceptFriendRequest(userId: bigint, requestId: bigint) {
    const request = await this.store.findFriendRequest(requestId);
    if (!request || request.recipient_id !== userId || request.status !== FriendRequestStatus.PENDING || request.expires_at <= new Date()) throw new NotFoundException('好友请求不存在或已过期');
@@ -274,7 +319,10 @@ export class SocialService {
    if (!normalizedContent || normalizedContent.length > 1000) throw new BadRequestException('私聊内容需为 1-1000 个字符');
    await this.assertNotBlockedEitherWay(senderId, targetId);
    const targetSocket = await this.sessions.getSocketIdByUserId(targetId.toString());
-    if (!targetSocket) throw new BadRequestException('对方当前不在线');
+    const targetTestPresence = getTestLabPresence(targetId.toString());
+    // 测试实验室假人没有真实 WebSocket 连接，但其合成在线状态应与普通在线玩家
+    // 一致地通过私聊在线校验。消息仍只写入现有的私聊存储，不触发外部副作用。
+    if (!targetSocket && !targetTestPresence?.online) throw new BadRequestException('对方当前不在线');
    if (!(await this.areFriends(senderId, targetId))) await this.assertNearbyAllowed(senderId, targetId, 'private');

    const message = await this.store.createDirectMessage({ sender_id: senderId, recipient_id: targetId, content: normalizedContent, expires_at: new Date(Date.now() + RETENTION_MS) });
@@ -285,6 +333,20 @@ export class SocialService {
    return payload.message;
  }

+  /** 测试假人私聊：仍写入正式私聊存储，但不要求假人拥有真实 socket。 */
+  async sendTestDirectMessage(senderId: bigint, targetId: bigint, content: string) {
+    this.assertDistinct(senderId, targetId);
+    const normalizedContent = content.trim();
+    if (!normalizedContent || normalizedContent.length > 1000) throw new BadRequestException('私聊内容需为 1-1000 个字符');
+    await this.assertNotBlockedEitherWay(senderId, targetId);
+    await this.usersService.findOne(targetId);
+    const message = await this.store.createDirectMessage({ sender_id: senderId, recipient_id: targetId, content: normalizedContent, expires_at: new Date(Date.now() + RETENTION_MS) });
+    const sender = await this.buildProfile(targetId, senderId, false);
+    const payload = { t: 'dm_message', message: { id: message.id.toString(), senderId: senderId.toString(), recipientId: targetId.toString(), content: message.content, createdAt: message.created_at, sender } };
+    await this.sendToUser(targetId, payload);
+    return payload.message;
+  }
+
  async listConversation(userId: bigint, otherUserId: bigint, limit: number, before?: Date) {
    await this.assertNotBlockedEitherWay(userId, otherUserId);
    const messages = await this.store.listDirectMessages(userId, otherUserId, limit, before);
@@ -362,6 +424,10 @@ export class SocialService {
    await this.store.cleanupExpired(new Date());
  }

+  async purgeTestUsers(userIds: bigint[]): Promise<void> {
+    await this.store.purgeUsers(userIds);
+  }
+
  private async buildProfile(viewerId: bigint, targetId: bigint, includePrivate: boolean) {
    const [user, profile, socketId] = await Promise.all([
      this.usersService.findOne(targetId),
@@ -370,19 +436,23 @@ export class SocialService {
    ]);
    const tags = this.profileTags(profile);
    const session = socketId ? await this.sessions.getSession(socketId) : null;
+    const testPresence = getTestLabPresence(targetId);
+    const isFriend = viewerId === targetId ? false : await this.areFriends(viewerId, targetId);
+    const blockedEitherWay = viewerId === targetId ? false : await this.isBlockedEitherWay(viewerId, targetId);
    return {
      id: targetId.toString(),
      username: user.username,
      nickname: user.nickname,
      avatarUrl: user.avatar_url || '',
      skinId: profile.skin_id || '',
-      online: Boolean(socketId),
-      currentArea: session?.currentMap || profile.current_map,
+      online: Boolean(socketId) || Boolean(testPresence?.online),
+      currentArea: testPresence?.mapId || session?.currentMap || profile.current_map,
      bio: String(profile.bio || '').slice(0, 160),
      interests: this.validInterests(tags.interests),
      privacy: includePrivate ? this.privacy(profile) : undefined,
-      isFriend: includePrivate || viewerId === targetId ? false : await this.areFriends(viewerId, targetId),
-      blocked: includePrivate ? false : await this.store.isBlocked(viewerId, targetId),
+      isFriend: includePrivate || viewerId === targetId ? false : isFriend,
+      blocked: includePrivate ? false : blockedEitherWay,
+      room_visitable: viewerId === targetId || (!blockedEitherWay && this.roomVisitPolicy(profile) === 'public') || (!blockedEitherWay && this.roomVisitPolicy(profile) === 'friends' && isFriend),
    };
  }

@@ -405,6 +475,23 @@ export class SocialService {
    return { ...DEFAULT_PRIVACY, ...(values && typeof values === 'object' ? values : {}) };
  }

+  private roomVisitPolicy(profile: ProfileRecord): 'friends' | 'public' | 'closed' {
+    const value = this.profileTags(profile)[SOCIAL_SETTINGS_KEY];
+    if (value && typeof value === 'object' && !Array.isArray(value)) {
+      const policy = String((value as Record<string, unknown>).room_visit_policy || 'friends');
+      if (ROOM_VISIT_POLICIES.has(policy)) return policy as 'friends' | 'public' | 'closed';
+    }
+    return 'friends';
+  }
+
+  private async canVisitRoomWithProfile(viewerId: bigint, ownerId: bigint, profile: ProfileRecord): Promise<boolean> {
+    if (viewerId === ownerId) return true;
+    if (await this.isBlockedEitherWay(viewerId, ownerId)) return false;
+    const policy = this.roomVisitPolicy(profile);
+    if (policy === 'public') return true;
+    return policy === 'friends' && await this.areFriends(viewerId, ownerId);
+  }
+
  private validInterests(value: unknown): string[] {
    return Array.isArray(value) ? value.map(String).filter((item) => INTEREST_IDS.has(item)).slice(0, 3) : [];
  }
@@ -412,10 +499,22 @@ export class SocialService {
  private async assertNearbyAllowed(sourceId: bigint, targetId: bigint, purpose: 'profile' | 'private' | 'friend') {
    const targetSocketId = await this.sessions.getSocketIdByUserId(targetId.toString());
    const sourceSocketId = await this.sessions.getSocketIdByUserId(sourceId.toString());
-    if (!targetSocketId || !sourceSocketId) throw new ForbiddenException('陌生玩家需要在线且在附近才能互动');
-    const [target, source, profile] = await Promise.all([this.sessions.getSession(targetSocketId), this.sessions.getSession(sourceSocketId), this.ensureProfile(targetId)]);
-    if (!target || !source || target.currentMap !== source.currentMap) throw new ForbiddenException('陌生玩家仅可在同一地图互动');
-    const distance = Math.hypot(Number(target.position?.x || 0) - Number(source.position?.x || 0), Number(target.position?.y || 0) - Number(source.position?.y || 0));
+    const targetTestPresence = getTestLabPresence(targetId);
+    const sourceTestPresence = getTestLabPresence(sourceId);
+    const [target, source, profile] = await Promise.all([
+      targetSocketId ? this.sessions.getSession(targetSocketId) : Promise.resolve(null),
+      sourceSocketId ? this.sessions.getSession(sourceSocketId) : Promise.resolve(null),
+      this.ensureProfile(targetId),
+    ]);
+    const targetPosition = targetTestPresence?.online
+      ? { mapId: targetTestPresence.mapId, x: targetTestPresence.x, y: targetTestPresence.y }
+      : target ? { mapId: target.currentMap, x: Number(target.position?.x || 0), y: Number(target.position?.y || 0) } : null;
+    const sourcePosition = sourceTestPresence?.online
+      ? { mapId: sourceTestPresence.mapId, x: sourceTestPresence.x, y: sourceTestPresence.y }
+      : source ? { mapId: source.currentMap, x: Number(source.position?.x || 0), y: Number(source.position?.y || 0) } : null;
+    if (!targetPosition || !sourcePosition) throw new ForbiddenException('陌生玩家需要在线且在附近才能互动');
+    if (targetPosition.mapId !== sourcePosition.mapId) throw new ForbiddenException('陌生玩家仅可在同一地图互动');
+    const distance = Math.hypot(targetPosition.x - sourcePosition.x, targetPosition.y - sourcePosition.y);
    if (distance > NEARBY_DISTANCE) throw new ForbiddenException('请靠近该玩家后再互动');
    const privacy = this.privacy(profile);
    const key = purpose === 'profile' ? 'allow_nearby_profile' : purpose === 'private' ? 'allow_nearby_private' : 'allow_nearby_friend_requests';
--- a/src/business/social/social.store.ts
+++ b/src/business/social/social.store.ts
@@ -38,5 +38,6 @@ export interface SocialStore {
  markNotificationRead(userId: bigint, id: bigint): Promise<SocialNotification | null>;
  markAllNotificationsRead(userId: bigint): Promise<number>;
  countUnreadNotifications(userId: bigint): Promise<number>;
+  purgeUsers(userIds: bigint[]): Promise<void>;
  cleanupExpired(now: Date): Promise<void>;
 }
--- a/src/business/tasks/dto/report_task_activity.dto.ts
+++ b/src/business/tasks/dto/report_task_activity.dto.ts
@@ -1,4 +1,4 @@
-import { IsIn, IsOptional, IsString, MaxLength } from 'class-validator';
+import { IsIn, IsISO8601, IsOptional, IsString, Matches, MaxLength } from 'class-validator';
 import { TASK_ACTIVITY_TYPES } from '../task_catalog';

 export class ReportTaskActivityDto {
@@ -9,4 +9,13 @@ export class ReportTaskActivityDto {
  @IsString()
  @MaxLength(64)
  target_id?: string;
+
+  @IsString()
+  @MaxLength(64)
+  @Matches(/^[A-Za-z0-9_-]{16,64}$/)
+  nonce: string;
+
+  @IsOptional()
+  @IsISO8601()
+  occurred_at?: string;
 }
--- a/src/business/tasks/migrations/create-task-activity-audit.sql
+++ b/src/business/tasks/migrations/create-task-activity-audit.sql
@@ -0,0 +1,21 @@
+CREATE TABLE IF NOT EXISTS `task_activity_audit` (
+  `id` bigint NOT NULL AUTO_INCREMENT,
+  `user_id` bigint NOT NULL,
+  `nonce` varchar(64) NOT NULL,
+  `activity` varchar(40) NOT NULL,
+  `requested_target_id` varchar(80) NULL,
+  `resolved_target_id` varchar(80) NULL,
+  `accepted` boolean NOT NULL DEFAULT FALSE,
+  `reason` varchar(120) NOT NULL,
+  `session_id` varchar(80) NULL,
+  `map_id` varchar(40) NULL,
+  `position_x` float NULL,
+  `position_y` float NULL,
+  `client_ip` varchar(64) NULL,
+  `user_agent` varchar(255) NULL,
+  `client_occurred_at` timestamp NULL DEFAULT NULL,
+  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+  PRIMARY KEY (`id`),
+  KEY `idx_task_activity_audit_user_created` (`user_id`, `created_at`),
+  KEY `idx_task_activity_audit_nonce` (`user_id`, `nonce`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='任务活动校验审计';
--- a/src/business/tasks/task.service.ts
+++ b/src/business/tasks/task.service.ts
@@ -1,4 +1,6 @@
 import { BadRequestException, Inject, Injectable } from '@nestjs/common';
+import { ReportTaskActivityDto } from './dto/report_task_activity.dto';
+import { TaskActivityAuthorityService } from './task_activity_authority.service';
 import { TaskActivityType } from './task_catalog';
 import { TaskBoardPayload, TaskClaimResult, TaskProgressStore } from './tasks.types';

@@ -12,17 +14,25 @@ const CLIENT_ACTIVITY_TYPES: TaskActivityType[] = [

@Injectable()
 export class TaskService {
-  constructor(@Inject('ITaskProgressStore') private readonly taskProgressStore: TaskProgressStore) {}
+  constructor(
+    @Inject('ITaskProgressStore') private readonly taskProgressStore: TaskProgressStore,
+    private readonly taskActivityAuthority: TaskActivityAuthorityService,
+  ) {}

  async getBoard(userId: bigint): Promise<TaskBoardPayload> {
    return await this.taskProgressStore.getBoard(userId);
  }

-  async recordClientActivity(userId: bigint, activity: TaskActivityType, targetId?: string): Promise<TaskBoardPayload> {
-    if (!CLIENT_ACTIVITY_TYPES.includes(activity)) {
+  async recordClientActivity(
+    userId: bigint,
+    dto: ReportTaskActivityDto,
+    context: { clientIp?: string; userAgent?: string } = {},
+  ): Promise<TaskBoardPayload> {
+    if (!CLIENT_ACTIVITY_TYPES.includes(dto.activity)) {
      throw new BadRequestException('该任务活动只能由服务器业务记录');
    }
-    return await this.taskProgressStore.recordActivity(userId, activity, targetId?.trim());
+    const resolved = await this.taskActivityAuthority.resolve(userId, dto, context);
+    return await this.taskProgressStore.recordActivity(userId, resolved.activity, resolved.targetId);
  }

  async recordActivity(userId: bigint, activity: TaskActivityType, targetId?: string): Promise<TaskBoardPayload> {
--- a/src/business/tasks/task_activity_audit.entity.ts
+++ b/src/business/tasks/task_activity_audit.entity.ts
@@ -0,0 +1,54 @@
+import { Column, Entity, Index, PrimaryGeneratedColumn } from 'typeorm';
+
+@Entity('task_activity_audit')
+@Index('idx_task_activity_audit_user_created', ['user_id', 'created_at'])
+@Index('idx_task_activity_audit_nonce', ['user_id', 'nonce'])
+export class TaskActivityAudit {
+  @PrimaryGeneratedColumn({ type: 'bigint' })
+  id: bigint;
+
+  @Column({ type: 'bigint', nullable: false })
+  user_id: bigint;
+
+  @Column({ type: 'varchar', length: 64, nullable: false })
+  nonce: string;
+
+  @Column({ type: 'varchar', length: 40, nullable: false })
+  activity: string;
+
+  @Column({ type: 'varchar', length: 80, nullable: true })
+  requested_target_id: string | null;
+
+  @Column({ type: 'varchar', length: 80, nullable: true })
+  resolved_target_id: string | null;
+
+  @Column({ type: 'boolean', nullable: false, default: false })
+  accepted: boolean;
+
+  @Column({ type: 'varchar', length: 120, nullable: false })
+  reason: string;
+
+  @Column({ type: 'varchar', length: 80, nullable: true })
+  session_id: string | null;
+
+  @Column({ type: 'varchar', length: 40, nullable: true })
+  map_id: string | null;
+
+  @Column({ type: 'float', nullable: true })
+  position_x: number | null;
+
+  @Column({ type: 'float', nullable: true })
+  position_y: number | null;
+
+  @Column({ type: 'varchar', length: 64, nullable: true })
+  client_ip: string | null;
+
+  @Column({ type: 'varchar', length: 255, nullable: true })
+  user_agent: string | null;
+
+  @Column({ type: 'timestamp', nullable: true })
+  client_occurred_at: Date | null;
+
+  @Column({ type: 'timestamp', default: () => 'CURRENT_TIMESTAMP' })
+  created_at: Date;
+}
--- a/src/business/tasks/task_activity_audit.store.ts
+++ b/src/business/tasks/task_activity_audit.store.ts
@@ -0,0 +1,22 @@
+export interface TaskActivityAuditRecord {
+  user_id: bigint;
+  nonce: string;
+  activity: string;
+  requested_target_id: string | null;
+  resolved_target_id: string | null;
+  accepted: boolean;
+  reason: string;
+  session_id: string | null;
+  map_id: string | null;
+  position_x: number | null;
+  position_y: number | null;
+  client_ip: string | null;
+  user_agent: string | null;
+  client_occurred_at: Date | null;
+}
+
+export interface TaskActivityAuditStore {
+  append(record: TaskActivityAuditRecord): Promise<void>;
+}
+
+export const TASK_ACTIVITY_AUDIT_STORE = 'TASK_ACTIVITY_AUDIT_STORE';
--- a/src/business/tasks/task_activity_audit_database.service.ts
+++ b/src/business/tasks/task_activity_audit_database.service.ts
@@ -0,0 +1,17 @@
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { TaskActivityAudit } from './task_activity_audit.entity';
+import { TaskActivityAuditRecord, TaskActivityAuditStore } from './task_activity_audit.store';
+
+@Injectable()
+export class TaskActivityAuditDatabaseService implements TaskActivityAuditStore {
+  constructor(
+    @InjectRepository(TaskActivityAudit)
+    private readonly repository: Repository<TaskActivityAudit>,
+  ) {}
+
+  async append(record: TaskActivityAuditRecord): Promise<void> {
+    await this.repository.insert(record);
+  }
+}
--- a/src/business/tasks/task_activity_audit_memory.service.ts
+++ b/src/business/tasks/task_activity_audit_memory.service.ts
@@ -0,0 +1,15 @@
+import { Injectable } from '@nestjs/common';
+import { TaskActivityAuditRecord, TaskActivityAuditStore } from './task_activity_audit.store';
+
+@Injectable()
+export class TaskActivityAuditMemoryService implements TaskActivityAuditStore {
+  private readonly records: Array<TaskActivityAuditRecord & { created_at: Date }> = [];
+  private static readonly MAX_RECORDS = 5000;
+
+  async append(record: TaskActivityAuditRecord): Promise<void> {
+    this.records.push({ ...record, created_at: new Date() });
+    if (this.records.length > TaskActivityAuditMemoryService.MAX_RECORDS) {
+      this.records.splice(0, this.records.length - TaskActivityAuditMemoryService.MAX_RECORDS);
+    }
+  }
+}
--- a/src/business/tasks/task_activity_authority.service.ts
+++ b/src/business/tasks/task_activity_authority.service.ts
@@ -0,0 +1,218 @@
+import { ConflictException, HttpException, HttpStatus, Inject, Injectable, Logger } from '@nestjs/common';
+import { IRedisService } from '../../core/redis/redis.interface';
+import { Position } from '../../core/location_broadcast_core/position.interface';
+import { LocationBroadcastCore } from '../../core/location_broadcast_core/location_broadcast_core.service';
+import { ReportTaskActivityDto } from './dto/report_task_activity.dto';
+import { TaskActivityType } from './task_catalog';
+import {
+  TASK_ACTIVITY_AUDIT_STORE,
+  TaskActivityAuditRecord,
+  TaskActivityAuditStore,
+} from './task_activity_audit.store';
+
+interface TaskActivityRequestContext {
+  clientIp?: string;
+  userAgent?: string;
+}
+
+interface ResolvedActivity {
+  activity: TaskActivityType;
+  targetId?: string;
+}
+
+interface FacilityPoint {
+  mapId: string;
+  x: number;
+  y: number;
+  radius: number;
+}
+
+const SESSION_REQUIRED_ACTIVITIES = new Set<TaskActivityType>([
+  'map_visited',
+  'notice_viewed',
+  'course_board_opened',
+  'facility_interacted',
+]);
+const MAP_TASK_TARGETS: Record<string, string> = {
+  whale_port: 'square',
+  work_zone: 'work_zone',
+  whale_cafe: 'whale_cafe',
+};
+const FACILITY_POINTS: Record<string, FacilityPoint[]> = {
+  welcome_board: [{ mapId: 'whale_port', x: 1470, y: 408, radius: 220 }],
+  notice_board: [{ mapId: 'whale_port', x: 701, y: 1529, radius: 240 }],
+  course_board: [{ mapId: 'work_zone', x: 1778, y: 1366, radius: 240 }],
+  npc: [
+    { mapId: 'whale_port', x: 1081, y: 445, radius: 220 },
+    { mapId: 'whale_port', x: 455, y: 1397, radius: 220 },
+    { mapId: 'whale_cafe', x: 296, y: 221, radius: 240 },
+  ],
+};
+const NONCE_TTL_SECONDS = 10 * 60;
+const SESSION_FRESHNESS_MS = 30 * 1000;
+const RATE_LIMIT_PER_MINUTE = 30;
+
+@Injectable()
+export class TaskActivityAuthorityService {
+  private readonly logger = new Logger(TaskActivityAuthorityService.name);
+
+  constructor(
+    @Inject('REDIS_SERVICE') private readonly redisService: IRedisService,
+    private readonly locationBroadcastCore: LocationBroadcastCore,
+    @Inject(TASK_ACTIVITY_AUDIT_STORE) private readonly auditStore: TaskActivityAuditStore,
+  ) {}
+
+  async resolve(
+    userId: bigint,
+    dto: ReportTaskActivityDto,
+    context: TaskActivityRequestContext = {},
+  ): Promise<ResolvedActivity> {
+    const requestedTargetId = dto.target_id?.trim() || undefined;
+    const auditBase: TaskActivityAuditRecord = {
+      user_id: userId,
+      nonce: dto.nonce,
+      activity: dto.activity,
+      requested_target_id: requestedTargetId ?? null,
+      resolved_target_id: null,
+      accepted: false,
+      reason: 'pending',
+      session_id: null,
+      map_id: null,
+      position_x: null,
+      position_y: null,
+      client_ip: context.clientIp?.slice(0, 64) || null,
+      user_agent: context.userAgent?.slice(0, 255) || null,
+      client_occurred_at: dto.occurred_at ? new Date(dto.occurred_at) : null,
+    };
+
+    try {
+      await this.enforceRateLimit(userId);
+      const nonceAccepted = await this.redisService.setIfAbsent(
+        `tasks:activity:nonce:${userId.toString()}:${dto.nonce}`,
+        '1',
+        NONCE_TTL_SECONDS,
+      );
+      if (!nonceAccepted) {
+        throw new ConflictException('任务活动 nonce 已使用');
+      }
+
+      let position: Position | null = null;
+      let sessionId: string | null = null;
+      if (SESSION_REQUIRED_ACTIVITIES.has(dto.activity)) {
+        [sessionId, position] = await Promise.all([
+          this.redisService.get(`user:${userId.toString()}:session`),
+          this.locationBroadcastCore.getUserPosition(userId.toString()),
+        ]);
+        auditBase.session_id = sessionId;
+        auditBase.map_id = position?.mapId ?? null;
+        auditBase.position_x = position?.x ?? null;
+        auditBase.position_y = position?.y ?? null;
+        this.assertActiveSession(sessionId, position);
+      }
+
+      const resolved = this.resolveActivity(dto.activity, requestedTargetId, position);
+      await this.appendAudit({
+        ...auditBase,
+        resolved_target_id: resolved.targetId ?? null,
+        accepted: true,
+        reason: 'accepted',
+      });
+      return resolved;
+    } catch (error) {
+      await this.appendAudit({
+        ...auditBase,
+        reason: error instanceof Error ? error.message.slice(0, 120) : 'unknown_error',
+      });
+      throw error;
+    }
+  }
+
+  private async enforceRateLimit(userId: bigint): Promise<void> {
+    const minuteBucket = Math.floor(Date.now() / 60000);
+    const key = `tasks:activity:rate:${userId.toString()}:${minuteBucket}`;
+    const count = await this.redisService.incr(key);
+    if (count === 1) {
+      await this.redisService.expire(key, 120);
+    }
+    if (count > RATE_LIMIT_PER_MINUTE) {
+      throw new HttpException('任务活动上报过于频繁', HttpStatus.TOO_MANY_REQUESTS);
+    }
+  }
+
+  private assertActiveSession(sessionId: string | null, position: Position | null): asserts position is Position {
+    if (!sessionId || !position) {
+      throw new ConflictException('游戏会话尚未就绪');
+    }
+    if (!Number.isFinite(position.timestamp) || Date.now() - position.timestamp > SESSION_FRESHNESS_MS) {
+      throw new ConflictException('游戏会话位置已过期');
+    }
+  }
+
+  private resolveActivity(
+    activity: TaskActivityType,
+    requestedTargetId: string | undefined,
+    position: Position | null,
+  ): ResolvedActivity {
+    if (activity === 'map_visited') {
+      const targetId = MAP_TASK_TARGETS[position?.mapId ?? ''];
+      if (!targetId) {
+        throw new ConflictException('当前地图不计入任务进度');
+      }
+      if (requestedTargetId && requestedTargetId !== targetId) {
+        throw new ConflictException('地图活动与当前会话不一致');
+      }
+      return { activity, targetId };
+    }
+
+    if (activity === 'notice_viewed') {
+      this.assertNearFacility(position, 'notice_board');
+      return { activity, targetId: 'notice_board' };
+    }
+
+    if (activity === 'course_board_opened') {
+      this.assertNearFacility(position, 'course_board');
+      return { activity, targetId: 'course_board' };
+    }
+
+    if (activity === 'facility_interacted') {
+      if (!requestedTargetId || !FACILITY_POINTS[requestedTargetId]) {
+        throw new ConflictException('设施活动目标无效');
+      }
+      this.assertNearFacility(position, requestedTargetId);
+      return { activity, targetId: requestedTargetId };
+    }
+
+    return { activity, targetId: requestedTargetId };
+  }
+
+  private assertNearFacility(position: Position | null, facilityId: string): void {
+    if (!position) {
+      throw new ConflictException('游戏会话尚未就绪');
+    }
+    const matched = FACILITY_POINTS[facilityId].some((point) => {
+      if (point.mapId !== position.mapId) return false;
+      const deltaX = position.x - point.x;
+      const deltaY = position.y - point.y;
+      return deltaX * deltaX + deltaY * deltaY <= point.radius * point.radius;
+    });
+    if (!matched) {
+      throw new ConflictException('玩家不在目标设施交互范围内');
+    }
+  }
+
+  private async appendAudit(record: TaskActivityAuditRecord): Promise<void> {
+    try {
+      await this.auditStore.append(record);
+      this.logger.log({
+        operation: 'task_activity',
+        userId: record.user_id.toString(),
+        activity: record.activity,
+        accepted: record.accepted,
+        reason: record.reason,
+        mapId: record.map_id,
+      });
+    } catch (error) {
+      this.logger.error('任务活动审计写入失败', error instanceof Error ? error.stack : String(error));
+    }
+  }
+}
--- a/src/business/tasks/tasks.controller.ts
+++ b/src/business/tasks/tasks.controller.ts
@@ -1,6 +1,6 @@
-import { Body, Controller, Get, HttpStatus, Param, Post, Res, UseGuards, UsePipes, ValidationPipe } from '@nestjs/common';
+import { Body, Controller, Get, HttpStatus, Param, Post, Req, Res, UseGuards, UsePipes, ValidationPipe } from '@nestjs/common';
 import { ApiBearerAuth, ApiBody, ApiOperation, ApiResponse as SwaggerApiResponse, ApiTags } from '@nestjs/swagger';
-import { Response } from 'express';
+import { Request, Response } from 'express';
 import { CurrentUser } from '../../gateway/auth/current_user.decorator';
 import { JwtAuthGuard } from '../../gateway/auth/jwt_auth.guard';
 import { JwtPayload } from '../../core/login_core/login_core.service';
@@ -29,9 +29,13 @@ export class TasksController {
  async reportActivity(
    @CurrentUser() user: JwtPayload,
    @Body() dto: ReportTaskActivityDto,
+    @Req() req: Request,
    @Res() res: Response,
  ): Promise<void> {
-    const data = await this.taskService.recordClientActivity(BigInt(user.sub), dto.activity, dto.target_id);
+    const data = await this.taskService.recordClientActivity(BigInt(user.sub), dto, {
+      clientIp: req.ip,
+      userAgent: req.get('user-agent'),
+    });
    res.status(HttpStatus.OK).json({ success: true, data, message: '任务进度已更新' });
  }

--- a/src/business/tasks/tasks.module.ts
+++ b/src/business/tasks/tasks.module.ts
@@ -1,7 +1,14 @@
 import { DynamicModule, Global, Module } from '@nestjs/common';
 import { TypeOrmModule } from '@nestjs/typeorm';
+import { LocationBroadcastCoreModule } from '../../core/location_broadcast_core/location_broadcast_core.module';
 import { LoginCoreModule } from '../../core/login_core/login_core.module';
+import { RedisModule } from '../../core/redis/redis.module';
 import { PlayerTaskProgress } from './player_task_progress.entity';
+import { TaskActivityAudit } from './task_activity_audit.entity';
+import { TASK_ACTIVITY_AUDIT_STORE } from './task_activity_audit.store';
+import { TaskActivityAuditDatabaseService } from './task_activity_audit_database.service';
+import { TaskActivityAuditMemoryService } from './task_activity_audit_memory.service';
+import { TaskActivityAuthorityService } from './task_activity_authority.service';
 import { TaskProgressDatabaseService } from './task_progress_database.service';
 import { TaskProgressMemoryService } from './task_progress_memory.service';
 import { TaskService } from './task.service';
@@ -14,11 +21,14 @@ export class TasksModule {
    return {
      module: TasksModule,
      global: true,
-      imports: [LoginCoreModule, TypeOrmModule.forFeature([PlayerTaskProgress])],
+      imports: [LoginCoreModule, RedisModule, LocationBroadcastCoreModule, TypeOrmModule.forFeature([PlayerTaskProgress, TaskActivityAudit])],
      controllers: [TasksController],
      providers: [
        TaskProgressDatabaseService,
        { provide: 'ITaskProgressStore', useExisting: TaskProgressDatabaseService },
+        TaskActivityAuditDatabaseService,
+        { provide: TASK_ACTIVITY_AUDIT_STORE, useExisting: TaskActivityAuditDatabaseService },
+        TaskActivityAuthorityService,
        TaskService,
      ],
      exports: [TaskService, 'ITaskProgressStore'],
@@ -29,11 +39,14 @@ export class TasksModule {
    return {
      module: TasksModule,
      global: true,
-      imports: [LoginCoreModule],
+      imports: [LoginCoreModule, RedisModule, LocationBroadcastCoreModule],
      controllers: [TasksController],
      providers: [
        TaskProgressMemoryService,
        { provide: 'ITaskProgressStore', useExisting: TaskProgressMemoryService },
+        TaskActivityAuditMemoryService,
+        { provide: TASK_ACTIVITY_AUDIT_STORE, useExisting: TaskActivityAuditMemoryService },
+        TaskActivityAuthorityService,
        TaskService,
      ],
      exports: [TaskService, 'ITaskProgressStore'],
--- a/src/core/admin_core/admin_core.service.ts
+++ b/src/core/admin_core/admin_core.service.ts
@@ -100,6 +100,7 @@ export class AdminCoreService implements OnModuleInit {
   * ```
   */
  async onModuleInit(): Promise<void> {
+    await this.ensureDevelopmentTestAdmin();
    await this.bootstrapAdminIfEnabled();
  }

@@ -317,6 +318,50 @@ export class AdminCoreService implements OnModuleInit {
    this.logger.log(`管理员账号已创建：${username} (role=9)`);
  }

+  /**
+   * 开发/测试专用管理员。密码必须由本地或 CI 环境注入，不能作为生产回退值。
+   */
+  private async ensureDevelopmentTestAdmin(): Promise<void> {
+    const environment = this.configService.get<string>('NODE_ENV', 'development');
+    if (environment !== 'development' && environment !== 'test') return;
+    if (this.configService.get<string>('TEST_ADMIN_AUTO_PROVISION', 'true') !== 'true') return;
+
+    const username = this.configService.get<string>('TEST_ADMIN_USERNAME', 'admin')?.trim();
+    const password = this.configService.get<string>('TEST_ADMIN_PASSWORD')
+      || this.configService.get<string>('ADMIN_PASSWORD');
+    const nickname = this.configService.get<string>('TEST_ADMIN_NICKNAME', '测试管理员');
+
+    if (!username || !password) {
+      this.logger.warn('测试管理员未创建：请在开发/测试环境配置 TEST_ADMIN_PASSWORD');
+      return;
+    }
+
+    const existing = await this.usersService.findByUsername(username);
+    if (existing) {
+      if (existing.role !== 9) {
+        this.logger.warn(`测试管理员用户名已被普通账号占用，拒绝提权：${username}`);
+      }
+      return;
+    }
+
+    try {
+      this.validatePasswordStrength(password);
+    } catch (error) {
+      const reason = error instanceof Error ? error.message : '密码不满足强度要求';
+      this.logger.warn(`测试管理员未创建：TEST_ADMIN_PASSWORD 配置无效（${reason}）`);
+      return;
+    }
+    await this.usersService.create({
+      username,
+      password_hash: await this.hashPassword(password),
+      nickname,
+      role: 9,
+      email_verified: true,
+      is_test_account: false,
+    });
+    this.logger.log(`开发/测试管理员账号已创建：${username}`);
+  }
+
  private getAdminTokenSecret(): string {
    const secret = this.configService.get<string>('ADMIN_TOKEN_SECRET');
    if (!secret || secret.length < 16) {
--- a/src/core/db/player_assets/create-player-assets-tables.sql
+++ b/src/core/db/player_assets/create-player-assets-tables.sql
@@ -19,10 +19,21 @@ CREATE TABLE IF NOT EXISTS `room_decor_placements` (
  `position_x` FLOAT NULL COMMENT '房间内X坐标',
  `position_y` FLOAT NULL COMMENT '房间内Y坐标',
  `scale` FLOAT NOT NULL DEFAULT 1 COMMENT '摆件缩放',
+  `rotation_degrees` FLOAT NOT NULL DEFAULT 0 COMMENT '摆件旋转角度',
  `z_index` INT NOT NULL DEFAULT 0 COMMENT '摆放层级',
+  `mutation_revision` INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '最后修改该摆件的布局版本',
  `created_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  `updated_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
  PRIMARY KEY (`id`),
  UNIQUE KEY `idx_room_decor_placements_user_decor_unique` (`user_id`, `decor_id`),
  KEY `idx_room_decor_placements_user_id` (`user_id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+CREATE TABLE IF NOT EXISTS `room_decor_layout_state` (
+  `user_id` BIGINT NOT NULL COMMENT '关联users.id',
+  `revision` INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '当前布局版本',
+  `last_mutation_id` VARCHAR(64) NULL COMMENT '最后一次幂等mutation ID',
+  `last_mutation_scope` VARCHAR(120) NULL COMMENT '最后一次mutation作用域',
+  `updated_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+  PRIMARY KEY (`user_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
--- a/src/core/db/player_assets/migrations/add-room-decor-layout-revision.sql
+++ b/src/core/db/player_assets/migrations/add-room-decor-layout-revision.sql
@@ -0,0 +1,14 @@
+ALTER TABLE `room_decor_placements`
+  ADD COLUMN IF NOT EXISTS `mutation_revision` INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '最后修改该摆件的布局版本' AFTER `z_index`;
+
+CREATE TABLE IF NOT EXISTS `room_decor_layout_state` (
+  `user_id` BIGINT NOT NULL COMMENT '关联users.id',
+  `revision` INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '当前布局版本',
+  `last_mutation_id` VARCHAR(64) NULL COMMENT '最后一次幂等mutation ID',
+  `last_mutation_scope` VARCHAR(120) NULL COMMENT '最后一次mutation作用域',
+  `updated_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+  PRIMARY KEY (`user_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+ALTER TABLE `room_decor_layout_state`
+  ADD COLUMN IF NOT EXISTS `last_mutation_scope` VARCHAR(120) NULL COMMENT '最后一次mutation作用域' AFTER `last_mutation_id`;
--- a/src/core/db/player_assets/migrations/add-room-decor-placement-rotation.sql
+++ b/src/core/db/player_assets/migrations/add-room-decor-placement-rotation.sql
@@ -0,0 +1,2 @@
+ALTER TABLE `room_decor_placements`
+  ADD COLUMN IF NOT EXISTS `rotation_degrees` FLOAT NOT NULL DEFAULT 0 COMMENT '摆件旋转角度' AFTER `scale`;
--- a/src/core/db/player_assets/player_assets.module.ts
+++ b/src/core/db/player_assets/player_assets.module.ts
@@ -4,6 +4,7 @@ import { PlayerAssets } from './player_assets.entity';
 import { PlayerAssetsMemoryService } from './player_assets_memory.service';
 import { PlayerAssetsService } from './player_assets.service';
 import { RoomDecorPlacements } from './room_decor_placements.entity';
+import { RoomDecorLayoutState } from './room_decor_layout_state.entity';
 import { RoomDecorPlacementsMemoryService } from './room_decor_placements_memory.service';
 import { RoomDecorPlacementsService } from './room_decor_placements.service';

@@ -13,12 +14,12 @@ export class PlayerAssetsModule {
  static forDatabase(): DynamicModule {
    return {
      module: PlayerAssetsModule,
-      imports: [TypeOrmModule.forFeature([PlayerAssets, RoomDecorPlacements])],
+      imports: [TypeOrmModule.forFeature([PlayerAssets, RoomDecorPlacements, RoomDecorLayoutState])],
      providers: [
        PlayerAssetsService,
        RoomDecorPlacementsService,
        { provide: 'IPlayerAssetsService', useClass: PlayerAssetsService },
-        { provide: 'IRoomDecorPlacementsService', useClass: RoomDecorPlacementsService },
+        { provide: 'IRoomDecorPlacementsService', useExisting: RoomDecorPlacementsService },
      ],
      exports: [PlayerAssetsService, RoomDecorPlacementsService, 'IPlayerAssetsService', 'IRoomDecorPlacementsService'],
    };
@@ -31,7 +32,7 @@ export class PlayerAssetsModule {
        PlayerAssetsMemoryService,
        RoomDecorPlacementsMemoryService,
        { provide: 'IPlayerAssetsService', useClass: PlayerAssetsMemoryService },
-        { provide: 'IRoomDecorPlacementsService', useClass: RoomDecorPlacementsMemoryService },
+        { provide: 'IRoomDecorPlacementsService', useExisting: RoomDecorPlacementsMemoryService },
      ],
      exports: [PlayerAssetsMemoryService, RoomDecorPlacementsMemoryService, 'IPlayerAssetsService', 'IRoomDecorPlacementsService'],
    };
--- a/src/core/db/player_assets/room_decor_layout_state.entity.ts
+++ b/src/core/db/player_assets/room_decor_layout_state.entity.ts
@@ -0,0 +1,19 @@
+import { Column, Entity, PrimaryColumn } from 'typeorm';
+
+@Entity('room_decor_layout_state')
+export class RoomDecorLayoutState {
+  @PrimaryColumn({ type: 'bigint', comment: '关联users.id' })
+  user_id: bigint;
+
+  @Column({ type: 'int', unsigned: true, nullable: false, default: 0, comment: '当前布局版本' })
+  revision: number;
+
+  @Column({ type: 'varchar', length: 64, nullable: true, comment: '最后一次幂等mutation ID' })
+  last_mutation_id: string | null;
+
+  @Column({ type: 'varchar', length: 120, nullable: true, comment: '最后一次mutation作用域' })
+  last_mutation_scope: string | null;
+
+  @Column({ type: 'timestamp', default: () => 'CURRENT_TIMESTAMP', onUpdate: 'CURRENT_TIMESTAMP' })
+  updated_at: Date;
+}
--- a/src/core/db/player_assets/room_decor_placements.entity.ts
+++ b/src/core/db/player_assets/room_decor_placements.entity.ts
@@ -25,9 +25,15 @@ export class RoomDecorPlacements {
  @Column({ type: 'float', nullable: false, default: 1, comment: '摆件缩放' })
  scale: number;

+  @Column({ type: 'float', nullable: false, default: 0, comment: '摆件旋转角度' })
+  rotation_degrees: number;
+
  @Column({ type: 'int', nullable: false, default: 0, comment: '摆放层级' })
  z_index: number;

+  @Column({ type: 'int', unsigned: true, nullable: false, default: 0, comment: '最后修改该摆件的布局版本' })
+  mutation_revision: number;
+
  @Column({ type: 'timestamp', default: () => 'CURRENT_TIMESTAMP', comment: '创建时间' })
  created_at: Date;

--- a/src/core/db/player_assets/room_decor_placements.service.ts
+++ b/src/core/db/player_assets/room_decor_placements.service.ts
@@ -1,41 +1,149 @@
-import { BadRequestException, Injectable } from '@nestjs/common';
-import { InjectRepository } from '@nestjs/typeorm';
-import { Repository } from 'typeorm';
+import { BadRequestException, ConflictException, Injectable } from '@nestjs/common';
+import { DataSource, EntityManager } from 'typeorm';
 import { SaveRoomDecorPlacementDto } from '../../../business/room_decor/dto/save_room_decor_placement.dto';
+import { ResetRoomDecorPlacementsDto } from '../../../business/room_decor/dto/reset_room_decor_placements.dto';
+import { RoomDecorLayoutState } from './room_decor_layout_state.entity';
 import { RoomDecorPlacements } from './room_decor_placements.entity';

@Injectable()
 export class RoomDecorPlacementsService {
-  constructor(
-    @InjectRepository(RoomDecorPlacements)
-    private readonly placementsRepository: Repository<RoomDecorPlacements>,
-  ) {}
+  constructor(private readonly dataSource: DataSource) {}

  async listPlacements(userId: bigint): Promise<RoomDecorPlacements[]> {
-    return await this.placementsRepository.find({
+    return await this.dataSource.getRepository(RoomDecorPlacements).find({
      where: { user_id: userId },
      order: { created_at: 'ASC', id: 'ASC' },
    });
  }

-  async savePlacement(userId: bigint, placement: SaveRoomDecorPlacementDto): Promise<RoomDecorPlacements> {
-    const decorId = this.normalizeDecorId(placement.decor_id);
-    let row = await this.placementsRepository.findOne({
-      where: { user_id: userId, decor_id: decorId },
+  async getSnapshot(userId: bigint): Promise<{ revision: number; placements: RoomDecorPlacements[] }> {
+    return await this.dataSource.transaction('REPEATABLE READ', async (manager) => {
+      await this.ensureLayoutState(manager, userId);
+      const state = await manager.getRepository(RoomDecorLayoutState).findOneByOrFail({ user_id: userId });
+      const placements = await manager.getRepository(RoomDecorPlacements).find({
+        where: { user_id: userId },
+        order: { created_at: 'ASC', id: 'ASC' },
+      });
+      return { revision: state.revision, placements };
    });
-    if (!row) {
-      row = new RoomDecorPlacements();
-      row.user_id = userId;
-      row.decor_id = decorId;
-      row.created_at = new Date();
+  }
+
+  async savePlacement(
+    userId: bigint,
+    placement: SaveRoomDecorPlacementDto,
+  ): Promise<{ revision: number; placement: RoomDecorPlacements }> {
+    return await this.dataSource.transaction(async (manager) => {
+      const state = await this.lockLayoutState(manager, userId);
+      const placementsRepository = manager.getRepository(RoomDecorPlacements);
+      const decorId = this.normalizeDecorId(placement.decor_id);
+      const mutationScope = `decor:${decorId}`;
+      let row = await placementsRepository.findOne({
+        where: { user_id: userId, decor_id: decorId },
+        lock: { mode: 'pessimistic_write' },
+      });
+      if (this.isIdempotentRetry(state, placement, mutationScope)) {
+        if (!row) throw new ConflictException('装修 mutation 状态不完整，请刷新布局');
+        return { revision: state.revision, placement: row };
+      }
+      this.assertNextRevision(state, placement);
+      if (!row) {
+        row = new RoomDecorPlacements();
+        row.user_id = userId;
+        row.decor_id = decorId;
+        row.created_at = new Date();
+      }
+      row.placed = placement.placed;
+      row.position_x = placement.placed ? Number(placement.position_x ?? row.position_x ?? 0) : null;
+      row.position_y = placement.placed ? Number(placement.position_y ?? row.position_y ?? 0) : null;
+      row.scale = Number(placement.scale ?? row.scale ?? 1);
+      row.rotation_degrees = Number(placement.rotation_degrees ?? row.rotation_degrees ?? 0);
+      row.z_index = Number(placement.z_index ?? row.z_index ?? 0);
+      row.mutation_revision = placement.mutation_revision;
+      row.updated_at = new Date();
+      const saved = await placementsRepository.save(row);
+      await this.advanceLayoutState(manager, state, placement.mutation_revision, placement.mutation_id, mutationScope);
+      return { revision: placement.mutation_revision, placement: saved };
+    });
+  }
+
+  async resetPlacements(
+    userId: bigint,
+    mutation: ResetRoomDecorPlacementsDto,
+  ): Promise<{ revision: number; placements: RoomDecorPlacements[] }> {
+    return await this.dataSource.transaction(async (manager) => {
+      const state = await this.lockLayoutState(manager, userId);
+      if (!this.isIdempotentRetry(state, mutation, 'reset')) {
+        this.assertNextRevision(state, mutation);
+        await manager.getRepository(RoomDecorPlacements).createQueryBuilder()
+          .update(RoomDecorPlacements)
+          .set({
+            placed: false,
+            position_x: null,
+            position_y: null,
+            mutation_revision: mutation.mutation_revision,
+          })
+          .where('user_id = :userId', { userId: userId.toString() })
+          .execute();
+        await this.advanceLayoutState(manager, state, mutation.mutation_revision, mutation.mutation_id, 'reset');
+      }
+      const placements = await manager.getRepository(RoomDecorPlacements).find({
+        where: { user_id: userId },
+        order: { created_at: 'ASC', id: 'ASC' },
+      });
+      return { revision: state.revision, placements };
+    });
+  }
+
+  private async ensureLayoutState(manager: EntityManager, userId: bigint): Promise<void> {
+    await manager.getRepository(RoomDecorLayoutState).createQueryBuilder()
+      .insert()
+      .values({ user_id: userId, revision: 0, last_mutation_id: null, last_mutation_scope: null })
+      .orIgnore()
+      .execute();
+  }
+
+  private async lockLayoutState(manager: EntityManager, userId: bigint): Promise<RoomDecorLayoutState> {
+    await this.ensureLayoutState(manager, userId);
+    return await manager.getRepository(RoomDecorLayoutState).findOneOrFail({
+      where: { user_id: userId },
+      lock: { mode: 'pessimistic_write' },
+    });
+  }
+
+  private isIdempotentRetry(
+    state: RoomDecorLayoutState,
+    mutation: Pick<SaveRoomDecorPlacementDto, 'mutation_revision' | 'mutation_id'>,
+    mutationScope: string,
+  ): boolean {
+    return mutation.mutation_revision === state.revision
+      && mutation.mutation_id === state.last_mutation_id
+      && mutationScope === state.last_mutation_scope;
+  }
+
+  private assertNextRevision(
+    state: RoomDecorLayoutState,
+    mutation: Pick<SaveRoomDecorPlacementDto, 'layout_revision' | 'mutation_revision'>,
+  ): void {
+    if (mutation.layout_revision !== state.revision || mutation.mutation_revision !== state.revision + 1) {
+      throw new ConflictException({
+        message: '装修布局版本已过期，请刷新后重试',
+        current_revision: state.revision,
+      });
    }
-    row.placed = placement.placed;
-    row.position_x = placement.placed ? Number(placement.position_x ?? row.position_x ?? 0) : null;
-    row.position_y = placement.placed ? Number(placement.position_y ?? row.position_y ?? 0) : null;
-    row.scale = Number(placement.scale ?? row.scale ?? 1);
-    row.z_index = Number(placement.z_index ?? row.z_index ?? 0);
-    row.updated_at = new Date();
-    return await this.placementsRepository.save(row);
+  }
+
+  private async advanceLayoutState(
+    manager: EntityManager,
+    state: RoomDecorLayoutState,
+    revision: number,
+    mutationId: string,
+    mutationScope: string,
+  ): Promise<void> {
+    state.revision = revision;
+    state.last_mutation_id = mutationId;
+    state.last_mutation_scope = mutationScope;
+    state.updated_at = new Date();
+    await manager.getRepository(RoomDecorLayoutState).save(state);
  }

  private normalizeDecorId(decorId: string): string {
--- a/src/core/db/player_assets/room_decor_placements_memory.service.ts
+++ b/src/core/db/player_assets/room_decor_placements_memory.service.ts
@@ -1,5 +1,6 @@
-import { BadRequestException, Injectable } from '@nestjs/common';
+import { BadRequestException, ConflictException, Injectable } from '@nestjs/common';
 import { SaveRoomDecorPlacementDto } from '../../../business/room_decor/dto/save_room_decor_placement.dto';
+import { ResetRoomDecorPlacementsDto } from '../../../business/room_decor/dto/reset_room_decor_placements.dto';
 import { RoomDecorPlacements } from './room_decor_placements.entity';

@Injectable()
@@ -7,6 +8,11 @@ export class RoomDecorPlacementsMemoryService {
  private placements: Map<bigint, RoomDecorPlacements> = new Map();
  private userDecorIndex: Map<string, bigint> = new Map();
  private currentId: bigint = BigInt(1);
+  private layoutStates: Map<bigint, {
+    revision: number;
+    last_mutation_id: string | null;
+    last_mutation_scope: string | null;
+  }> = new Map();

  async listPlacements(userId: bigint): Promise<RoomDecorPlacements[]> {
    return Array.from(this.placements.values())
@@ -17,11 +23,28 @@ export class RoomDecorPlacementsMemoryService {
      });
  }

-  async savePlacement(userId: bigint, placement: SaveRoomDecorPlacementDto): Promise<RoomDecorPlacements> {
+  async getSnapshot(userId: bigint): Promise<{ revision: number; placements: RoomDecorPlacements[] }> {
+    const state = this.getLayoutState(userId);
+    return { revision: state.revision, placements: await this.listPlacements(userId) };
+  }
+
+  async savePlacement(
+    userId: bigint,
+    placement: SaveRoomDecorPlacementDto,
+  ): Promise<{ revision: number; placement: RoomDecorPlacements }> {
+    const state = this.getLayoutState(userId);
    const decorId = this.normalizeDecorId(placement.decor_id);
+    const mutationScope = `decor:${decorId}`;
    const key = this.indexKey(userId, decorId);
    const existingId = this.userDecorIndex.get(key);
    const row = existingId ? this.placements.get(existingId) as RoomDecorPlacements : new RoomDecorPlacements();
+    if (placement.mutation_revision === state.revision
+      && placement.mutation_id === state.last_mutation_id
+      && mutationScope === state.last_mutation_scope) {
+      if (!existingId) throw new ConflictException('装修 mutation 状态不完整，请刷新布局');
+      return { revision: state.revision, placement: row };
+    }
+    this.assertNextRevision(state, placement.layout_revision, placement.mutation_revision);
    if (!existingId) {
      row.id = this.currentId++;
      row.user_id = userId;
@@ -34,9 +57,64 @@ export class RoomDecorPlacementsMemoryService {
    row.position_x = placement.placed ? Number(placement.position_x ?? row.position_x ?? 0) : null;
    row.position_y = placement.placed ? Number(placement.position_y ?? row.position_y ?? 0) : null;
    row.scale = Number(placement.scale ?? row.scale ?? 1);
+    row.rotation_degrees = Number(placement.rotation_degrees ?? row.rotation_degrees ?? 0);
    row.z_index = Number(placement.z_index ?? row.z_index ?? 0);
+    row.mutation_revision = placement.mutation_revision;
    row.updated_at = new Date();
-    return row;
+    state.revision = placement.mutation_revision;
+    state.last_mutation_id = placement.mutation_id;
+    state.last_mutation_scope = mutationScope;
+    return { revision: state.revision, placement: row };
+  }
+
+  async resetPlacements(
+    userId: bigint,
+    mutation: ResetRoomDecorPlacementsDto,
+  ): Promise<{ revision: number; placements: RoomDecorPlacements[] }> {
+    const state = this.getLayoutState(userId);
+    if (!(mutation.mutation_revision === state.revision
+      && mutation.mutation_id === state.last_mutation_id
+      && state.last_mutation_scope === 'reset')) {
+      this.assertNextRevision(state, mutation.layout_revision, mutation.mutation_revision);
+      for (const row of this.placements.values()) {
+        if (row.user_id !== userId) continue;
+        row.placed = false;
+        row.position_x = null;
+        row.position_y = null;
+        row.mutation_revision = mutation.mutation_revision;
+        row.updated_at = new Date();
+      }
+      state.revision = mutation.mutation_revision;
+      state.last_mutation_id = mutation.mutation_id;
+      state.last_mutation_scope = 'reset';
+    }
+    return { revision: state.revision, placements: await this.listPlacements(userId) };
+  }
+
+  private getLayoutState(userId: bigint): {
+    revision: number;
+    last_mutation_id: string | null;
+    last_mutation_scope: string | null;
+  } {
+    let state = this.layoutStates.get(userId);
+    if (!state) {
+      state = { revision: 0, last_mutation_id: null, last_mutation_scope: null };
+      this.layoutStates.set(userId, state);
+    }
+    return state;
+  }
+
+  private assertNextRevision(
+    state: { revision: number },
+    layoutRevision: number,
+    mutationRevision: number,
+  ): void {
+    if (layoutRevision !== state.revision || mutationRevision !== state.revision + 1) {
+      throw new ConflictException({
+        message: '装修布局版本已过期，请刷新后重试',
+        current_revision: state.revision,
+      });
+    }
  }

  private indexKey(userId: bigint, decorId: string): string {
--- a/src/core/db/users/migrations/add-is-test-account.sql
+++ b/src/core/db/users/migrations/add-is-test-account.sql
@@ -0,0 +1,18 @@
+ALTER TABLE `users`
+  ADD COLUMN IF NOT EXISTS `is_test_account` TINYINT(1) NOT NULL DEFAULT 0 COMMENT '是否为开发测试实验室账号' AFTER `role`;
+
+SET @test_account_index_exists := (
+  SELECT COUNT(*)
+  FROM information_schema.statistics
+  WHERE table_schema = DATABASE()
+    AND table_name = 'users'
+    AND index_name = 'idx_users_is_test_account'
+);
+SET @test_account_index_sql := IF(
+  @test_account_index_exists = 0,
+  'CREATE INDEX `idx_users_is_test_account` ON `users` (`is_test_account`)',
+  'SELECT 1'
+);
+PREPARE test_account_index_stmt FROM @test_account_index_sql;
+EXECUTE test_account_index_stmt;
+DEALLOCATE PREPARE test_account_index_stmt;
--- a/src/core/db/users/users.dto.ts
+++ b/src/core/db/users/users.dto.ts
@@ -36,7 +36,8 @@ import {
  IsOptional,
  Length,
  IsNotEmpty,
-  IsEnum
+  IsEnum,
+  IsBoolean
 } from 'class-validator';
 import { UserStatus } from './user_status.enum';
 import { USER_ROLES, FIELD_LIMITS } from './users.constants';
@@ -91,6 +92,10 @@ export class CreateUserDto {
  @Length(1, FIELD_LIMITS.USERNAME_MAX_LENGTH, { message: `用户名长度需在1-${FIELD_LIMITS.USERNAME_MAX_LENGTH}字符之间` })
  username: string;

+  @IsOptional()
+  @IsBoolean()
+  is_test_account?: boolean;
+
  /**
   * 邮箱地址
   *
@@ -272,4 +277,4 @@ export class CreateUserDto {
  @IsOptional()
  @IsEnum(UserStatus, { message: '用户状态必须是有效的枚举值' })
  status?: UserStatus = UserStatus.ACTIVE;
-}
+}
--- a/src/core/db/users/users.entity.ts
+++ b/src/core/db/users/users.entity.ts
@@ -358,6 +358,17 @@ export class Users {
  })
  role: number;

+  /**
+   * 仅供开发/测试实验室创建的合成玩家使用。生产业务不得据此授予权限。
+   */
+  @Column({
+    type: 'boolean',
+    nullable: false,
+    default: false,
+    comment: '是否为测试实验室账号'
+  })
+  is_test_account: boolean;
+
  /**
   * 用户状态
   *
--- a/src/core/db/users/users.service.ts
+++ b/src/core/db/users/users.service.ts
@@ -157,6 +157,7 @@ export class UsersService extends BaseUsersService {
    user.github_id = createUserDto.github_id || null;
    user.avatar_url = createUserDto.avatar_url || null;
    user.role = createUserDto.role || USER_ROLES.NORMAL_USER;
+    user.is_test_account = createUserDto.is_test_account === true;
    user.email_verified = createUserDto.email_verified || false;
    user.status = createUserDto.status || UserStatus.ACTIVE;

@@ -711,4 +712,4 @@ export class UsersService extends BaseUsersService {
      });
    }
  }
-}
+}
--- a/src/core/db/users/users_memory.service.ts
+++ b/src/core/db/users/users_memory.service.ts
@@ -257,6 +257,7 @@ export class UsersMemoryService extends BaseUsersService {
    user.github_id = createUserDto.github_id || null;
    user.avatar_url = createUserDto.avatar_url || null;
    user.role = createUserDto.role || USER_ROLES.NORMAL_USER;
+    user.is_test_account = createUserDto.is_test_account === true;
    user.email_verified = createUserDto.email_verified || false;
    user.status = createUserDto.status || UserStatus.ACTIVE;
    user.created_at = new Date();
--- a/src/core/redis/file_redis.service.ts
+++ b/src/core/redis/file_redis.service.ts
@@ -265,6 +265,22 @@ export class FileRedisService implements IRedisService, OnModuleDestroy {
    this.logger.debug(`设置Redis键: ${key}, TTL: ${ttl || '永不过期'}`);
  }

+  async setIfAbsent(key: string, value: string, ttl?: number): Promise<boolean> {
+    const existing = this.data.get(key);
+    if (existing && (!existing.expireAt || existing.expireAt > Date.now())) {
+      return false;
+    }
+    if (existing) {
+      this.data.delete(key);
+    }
+    this.data.set(key, {
+      value,
+      expireAt: ttl && ttl > 0 ? Date.now() + ttl * 1000 : undefined,
+    });
+    await this.saveData();
+    return true;
+  }
+
  /**
   * 获取键对应的值
   *
--- a/src/core/redis/real_redis.service.ts
+++ b/src/core/redis/real_redis.service.ts
@@ -134,6 +134,18 @@ export class RealRedisService implements IRedisService, OnModuleDestroy {
    }
  }

+  async setIfAbsent(key: string, value: string, ttl?: number): Promise<boolean> {
+    try {
+      const result = ttl && ttl > 0
+        ? await this.redis.set(key, value, 'EX', ttl, 'NX')
+        : await this.redis.set(key, value, 'NX');
+      return result === 'OK';
+    } catch (error) {
+      this.logger.error(`原子设置Redis键失败: ${key}`, error);
+      throw error;
+    }
+  }
+
  /**
   * 获取键对应的值
   *
--- a/src/core/redis/redis.interface.ts
+++ b/src/core/redis/redis.interface.ts
@@ -45,6 +45,13 @@ export interface IRedisService {
   */
  set(key: string, value: string, ttl?: number): Promise<void>;

+  /**
+   * 仅当键不存在时设置值，用于 nonce、幂等键等原子占位。
+   *
+   * @returns 成功占位返回 true，键已存在返回 false
+   */
+  setIfAbsent(key: string, value: string, ttl?: number): Promise<boolean>;
+
  /**
   * 设置键值对并指定过期时间
   *
--- a/src/gateway/chat/chat.gateway.ts
+++ b/src/gateway/chat/chat.gateway.ts
@@ -34,6 +34,13 @@ import { Injectable, Logger, OnModuleInit, OnModuleDestroy } from '@nestjs/commo
 import * as WebSocket from 'ws';
 import { ChatService } from '../../business/chat/chat.service';
 import { SocialService } from '../../business/social/social.service';
+import {
+  getTestLabPresence,
+  getTestLabPresences,
+  removeTestLabPresence,
+  TestLabPresence,
+  upsertTestLabPresence,
+} from '../../business/admin/test_lab_presence.registry';

 /** WebSocket 服务器默认端口 */
 const DEFAULT_WEBSOCKET_PORT = 3001;
@@ -911,6 +918,58 @@ export class ChatWebSocketGateway implements OnModuleInit, OnModuleDestroy, ICha
    return players;
  }

+  /** 管理端测试实验室使用：返回真实在线玩家，绝不包含合成假人。 */
+  public getOnlineWorldPlayers(): Array<{ userId: string; username: string; mapId: string }> {
+    return [...this.clients.values()]
+      .filter((client) => client.authenticated && client.worldReady && client.userId && client.currentMap)
+      .map((client) => ({ userId: String(client.userId), username: String(client.username || ''), mapId: String(client.currentMap) }));
+  }
+
+  public setTestLabPresence(presence: TestLabPresence): void {
+    const previous = getTestLabPresence(presence.userId);
+    const current = upsertTestLabPresence(presence);
+    if (previous?.online && (!current.online || previous.mapId !== current.mapId)) {
+      this.broadcastToMap(previous.mapId, { t: 'player_left', userId: previous.userId, username: previous.nickname, mapId: previous.mapId });
+    }
+    if (!current.online) return;
+    const payload = {
+      t: previous?.online && previous.mapId === current.mapId ? 'position_update' : 'player_joined',
+      userId: current.userId,
+      username: current.nickname,
+      mapId: current.mapId,
+      x: current.x,
+      y: current.y,
+      skinId: current.skinId,
+      avatarId: current.avatarId,
+      appearance: { skinId: current.skinId, avatarId: current.avatarId },
+    };
+    this.broadcastToMap(current.mapId, payload);
+  }
+
+  public removeTestLabActor(userId: string): void {
+    const previous = removeTestLabPresence(userId);
+    if (previous?.online) {
+      this.broadcastToMap(previous.mapId, { t: 'player_left', userId: previous.userId, username: previous.nickname, mapId: previous.mapId });
+    }
+  }
+
+  public broadcastTestLabChat(actor: TestLabPresence, content: string, scope: 'local' | 'global' = 'local'): void {
+    const payload = {
+      t: 'chat_render',
+      from: actor.nickname,
+      fromUserId: actor.userId,
+      txt: content,
+      bubble: true,
+      timestamp: new Date().toISOString(),
+      messageId: `test_${Date.now()}_${actor.userId}`,
+      mapId: actor.mapId,
+      scope,
+      testLab: true,
+    };
+    if (scope === 'global') this.broadcastToAll(payload);
+    else this.broadcastToMap(actor.mapId, payload);
+  }
+
  // ========== 私有辅助方法 ==========

  private sendMessage(ws: ExtendedWebSocket, data: any) {
@@ -976,10 +1035,22 @@ export class ChatWebSocketGateway implements OnModuleInit, OnModuleDestroy, ICha
    });
    const players = (await this.chatService.getMapPlayerSnapshot(normalizedMapId, ws.id))
      .filter((player) => activeUserIds.has(String(player.userId)));
+    const testPlayers = getTestLabPresences(normalizedMapId).map((player) => ({
+      userId: player.userId,
+      username: player.nickname,
+      mapId: player.mapId,
+      x: player.x,
+      y: player.y,
+      skinId: player.skinId,
+      avatarId: player.avatarId,
+      appearance: { skinId: player.skinId, avatarId: player.avatarId },
+      cafeCompanion: null,
+      movementLocked: false,
+    }));
    this.sendMessage(ws, {
      t: 'map_players_snapshot',
      mapId: normalizedMapId,
-      players,
+      players: [...players, ...testPlayers].filter((player) => String(player.userId) !== String(ws.userId)),
    });
  }

@@ -1037,6 +1108,11 @@ export class ChatWebSocketGateway implements OnModuleInit, OnModuleDestroy, ICha
  }

  private legacyFriend(profile: any) {
-    return { userId: String(profile.id), username: String(profile.nickname || profile.username || '玩家'), online: Boolean(profile.online) };
+    return {
+      userId: String(profile.id),
+      username: String(profile.nickname || profile.username || '玩家'),
+      online: Boolean(profile.online),
+      room_visitable: Boolean(profile.room_visitable),
+    };
  }
 }
Author	SHA1	Message	Date
ANG-Server	968a672fbd	refactor: harden task authority and room mutations	2026-07-23 00:59:00 +08:00
ANG-Server	3f14230e15	fix: enforce decor placement surfaces	2026-07-22 14:20:18 +08:00
ANG-Server	b6b32f6676	feat: add personal space visits and editor	2026-07-22 13:41:28 +08:00
ANG-Server	a3341b6a3b	feat: add in-game social test lab	2026-07-22 12:16:31 +08:00