feat(data-management): add data management module for photo asset maintenance

- Introduced the DataManagementModule, including a controller and service for managing photo asset records.
- Implemented functionality to truncate photo asset records from the database, enhancing data management capabilities.
- Updated existing photo asset deletion logic to support optional deletion from storage.
- Added a new DataManagementPanel in the dashboard for user interaction with data management features.

Signed-off-by: Innei <tukon479@gmail.com>

Author: Innei

be/apps/core/src/modules/content/photo/assets/photo-asset.service.ts

@@ -149,7 +149,7 @@ export class PhotoAssetService {
     return summary
   }
 
-  async deleteAssets(ids: readonly string[]): Promise<void> {
+  async deleteAssets(ids: readonly string[], options?: { deleteFromStorage?: boolean }): Promise<void> {
     if (ids.length === 0) {
       return
     }
@@ -166,14 +166,20 @@ export class PhotoAssetService {
       return
     }
 
-    const { builderConfig, storageConfig } = await this.photoStorageService.resolveConfigForTenant(tenant.tenant.id)
-    const storageManager = this.createStorageManager(builderConfig, storageConfig)
-    const thumbnailRemotePrefix = this.resolveThumbnailRemotePrefix(storageConfig)
-    const deletedThumbnailKeys = new Set<string>()
-    const deletedVideoKeys = new Set<string>()
+    const shouldDeleteFromStorage = options?.deleteFromStorage === true
+
+    if (shouldDeleteFromStorage) {
+      const { builderConfig, storageConfig } = await this.photoStorageService.resolveConfigForTenant(tenant.tenant.id)
+      const storageManager = this.createStorageManager(builderConfig, storageConfig)
+      const thumbnailRemotePrefix = this.resolveThumbnailRemotePrefix(storageConfig)
+      const deletedThumbnailKeys = new Set<string>()
+      const deletedVideoKeys = new Set<string>()
+
+      for (const record of records) {
+        if (record.storageProvider === DATABASE_ONLY_PROVIDER) {
+          continue
+        }
 
-    for (const record of records) {
-      if (record.storageProvider !== DATABASE_ONLY_PROVIDER) {
         try {
           await storageManager.deleteFile(record.storageKey)
         } catch (error) {

be/apps/core/src/modules/content/photo/assets/photo.controller.ts

@@ -8,7 +8,8 @@ import type { PhotoAssetListItem, PhotoAssetSummary } from './photo-asset.servic
 import { PhotoAssetService } from './photo-asset.service'
 
 type DeleteAssetsDto = {
-  ids: string[]
+  ids?: string[]
+  deleteFromStorage?: boolean
 }
 
 @Controller('photos')
@@ -29,8 +30,9 @@ export class PhotoController {
   @Delete('assets')
   async deleteAssets(@Body() body: DeleteAssetsDto) {
     const ids = Array.isArray(body?.ids) ? body.ids : []
-    await this.photoAssetService.deleteAssets(ids)
-    return { ids, deleted: true }
+    const deleteFromStorage = body?.deleteFromStorage === true
+    await this.photoAssetService.deleteAssets(ids, { deleteFromStorage })
+    return { ids, deleted: true, deleteFromStorage }
   }
 
   @Post('assets/upload')

be/apps/core/src/modules/index.module.ts

@@ -26,6 +26,7 @@ import { DataSyncModule } from './infrastructure/data-sync/data-sync.module'
 import { StaticWebModule } from './infrastructure/static-web/static-web.module'
 import { AuthModule } from './platform/auth/auth.module'
 import { DashboardModule } from './platform/dashboard/dashboard.module'
+import { DataManagementModule } from './platform/data-management/data-management.module'
 import { SuperAdminModule } from './platform/super-admin/super-admin.module'
 import { TenantModule } from './platform/tenant/tenant.module'
 
@@ -55,6 +56,7 @@ function createEventModuleOptions(redis: RedisAccessor) {
     PhotoModule,
     ReactionModule,
     DashboardModule,
+    DataManagementModule,
     TenantModule,
     DataSyncModule,
     FeedModule,

be/apps/core/src/modules/platform/auth/auth.controller.ts

@@ -365,12 +365,33 @@ export class AuthController {
   }
 
   @AllowPlaceholderTenant()
+  @SkipTenantGuard()
+  @Get('/callback/*')
+  async callback(@ContextParam() context: Context) {
+    const query = context.req.query()
+    const { tenantSlug } = query
+
+    const reqUrl = new URL(context.req.url)
+
+    if (tenantSlug) {
+      reqUrl.hostname = `${tenantSlug}.${reqUrl.hostname}`
+      reqUrl.searchParams.delete('tenantSlug')
+
+      return context.redirect(reqUrl.toString(), 302)
+    }
+
+    return await this.auth.handler(context)
+  }
+
+  @AllowPlaceholderTenant()
+  @SkipTenantGuard()
   @Get('/*')
   async passthroughGet(@ContextParam() context: Context) {
     return await this.auth.handler(context)
   }
 
   @AllowPlaceholderTenant()
+  @SkipTenantGuard()
   @Post('/*')
   async passthroughPost(@ContextParam() context: Context) {
     return await this.auth.handler(context)

be/apps/core/src/modules/platform/data-management/data-management.controller.ts

@@ -0,0 +1,15 @@
+import { Controller, Post } from '@afilmory/framework'
+import { Roles } from 'core/guards/roles.decorator'
+
+import { DataManagementService } from './data-management.service'
+
+@Controller('data-management')
+@Roles('admin')
+export class DataManagementController {
+  constructor(private readonly dataManagementService: DataManagementService) {}
+
+  @Post('photo-assets/truncate')
+  async truncatePhotoAssetRecords() {
+    return await this.dataManagementService.clearPhotoAssetRecords()
+  }
+}

be/apps/core/src/modules/platform/data-management/data-management.module.ts

@@ -0,0 +1,10 @@
+import { Module } from '@afilmory/framework'
+
+import { DataManagementController } from './data-management.controller'
+import { DataManagementService } from './data-management.service'
+
+@Module({
+  controllers: [DataManagementController],
+  providers: [DataManagementService],
+})
+export class DataManagementModule {}

be/apps/core/src/modules/platform/data-management/data-management.service.ts

@@ -0,0 +1,32 @@
+import { photoAssets } from '@afilmory/db'
+import { EventEmitterService } from '@afilmory/framework'
+import { DbAccessor } from 'core/database/database.provider'
+import { requireTenantContext } from 'core/modules/platform/tenant/tenant.context'
+import { eq } from 'drizzle-orm'
+import { injectable } from 'tsyringe'
+
+@injectable()
+export class DataManagementService {
+  constructor(
+    private readonly dbAccessor: DbAccessor,
+    private readonly eventEmitter: EventEmitterService,
+  ) {}
+
+  async clearPhotoAssetRecords(): Promise<{ deleted: number }> {
+    const tenant = requireTenantContext()
+    const db = this.dbAccessor.get()
+
+    const deletedRecords = await db
+      .delete(photoAssets)
+      .where(eq(photoAssets.tenantId, tenant.tenant.id))
+      .returning({ id: photoAssets.id })
+
+    if (deletedRecords.length > 0) {
+      await this.eventEmitter.emit('photo.manifest.changed', { tenantId: tenant.tenant.id })
+    }
+
+    return {
+      deleted: deletedRecords.length,
+    }
+  }
+}

be/apps/dashboard/src/components/common/UserMenu.tsx

@@ -61,8 +61,8 @@ export function UserMenu({ user }: UserMenuProps) {
 
           {/* User Info - Hidden on small screens */}
           <div className="hidden text-left md:block">
-            <div className="text-text text-[13px] leading-tight font-medium">{user.name || user.email}</div>
-            <div className="text-text-tertiary text-[11px] leading-tight capitalize">{user.role}</div>
+            <div className="text-text text-sm leading-tight font-medium">{user.name || user.email}</div>
+            <div className="text-text-tertiary text-[10px] leading-tight capitalize">{user.role}</div>
           </div>
 
           {/* Chevron Icon */}

be/apps/dashboard/src/modules/data-management/api.ts

@@ -0,0 +1,11 @@
+import { coreApi } from '~/lib/api-client'
+
+type TruncatePhotoAssetsResponse = {
+  deleted: number
+}
+
+export async function truncatePhotoAssetRecords() {
+  return await coreApi<TruncatePhotoAssetsResponse>('/data-management/photo-assets/truncate', {
+    method: 'POST',
+  })
+}

be/apps/dashboard/src/modules/data-management/components/DataManagementPanel.tsx

@@ -0,0 +1,114 @@
+import { Button, Prompt } from '@afilmory/ui'
+import { clsxm } from '@afilmory/utils'
+import { DynamicIcon } from 'lucide-react/dynamic'
+
+import { LinearBorderPanel } from '~/components/common/GlassPanel'
+import { usePhotoAssetSummaryQuery } from '~/modules/photos/hooks'
+
+import { useTruncatePhotoAssetsMutation } from '../hooks'
+
+const SUMMARY_PLACEHOLDER = {
+  total: 0,
+  synced: 0,
+  pending: 0,
+  conflicts: 0,
+}
+
+const SUMMARY_STATS = [
+  { id: 'total', label: '总记录', accent: 'text-text', chip: '全部' },
+  { id: 'synced', label: '已同步', accent: 'text-emerald-300', chip: '正常' },
+  { id: 'pending', label: '待同步', accent: 'text-amber-300', chip: '排队中' },
+  { id: 'conflicts', label: '冲突', accent: 'text-rose-300', chip: '需处理' },
+] as const
+
+const numberFormatter = new Intl.NumberFormat('zh-CN')
+
+export function DataManagementPanel() {
+  const summaryQuery = usePhotoAssetSummaryQuery()
+  const summary = summaryQuery.data ?? SUMMARY_PLACEHOLDER
+  const truncateMutation = useTruncatePhotoAssetsMutation()
+
+  const handleTruncate = () => {
+    if (truncateMutation.isPending) {
+      return
+    }
+
+    Prompt.prompt({
+      title: '确认清空照片数据表？',
+      description: '该操作会删除数据库中的所有照片记录，但会保留对象存储中的原始文件。清空后需要重新执行一次照片同步。',
+      variant: 'danger',
+      onConfirmText: '立即清空',
+      onCancelText: '取消',
+      onConfirm: () => truncateMutation.mutateAsync().then(() => {}),
+    })
+  }
+
+  return (
+    <div className="space-y-6">
+      <LinearBorderPanel className="rounded-3xl bg-background-secondary/40 p-6">
+        <div className="flex flex-col gap-6 lg:flex-row lg:items-center lg:justify-between">
+          <div className="space-y-4">
+            <span className="shape-squircle inline-flex items-center gap-2 bg-accent/10 px-3 py-1 text-xs font-medium text-accent">
+              <DynamicIcon name="database" className="h-4 w-4" />
+              当前数据概况
+            </span>
+            <div className="space-y-2">
+              <h3 className="text-text text-xl font-semibold">照片数据表状态</h3>
+              <p className="text-text-secondary text-sm">以下统计来自数据库记录，不含对象存储中的原始文件。</p>
+            </div>
+            {summaryQuery.isError ? <p className="text-red text-sm">无法加载数据统计，请稍后再试。</p> : null}
+          </div>
+          <div className="grid w-full gap-4 sm:grid-cols-2 lg:grid-cols-4">
+            {SUMMARY_STATS.map((stat) => (
+              <div
+                key={stat.id}
+                className={clsxm(
+                  'rounded-2xl border border-white/5 bg-background-tertiary/60 px-4 py-3 shadow-sm backdrop-blur',
+                  summaryQuery.isLoading && 'animate-pulse',
+                )}
+              >
+                <div className="flex items-center justify-between text-[11px] text-text-tertiary">
+                  <span>{stat.label}</span>
+                  <span className="shape-squircle bg-white/5 px-2 py-0.5 font-medium text-white/80">{stat.chip}</span>
+                </div>
+                <div className={clsxm('mt-2 text-2xl font-semibold', stat.accent)}>
+                  {summaryQuery.isLoading ? '—' : numberFormatter.format(summary[stat.id])}
+                </div>
+              </div>
+            ))}
+          </div>
+        </div>
+      </LinearBorderPanel>
+
+      <LinearBorderPanel className="rounded-3xl bg-background-secondary/40 p-6">
+        <div className="flex flex-col gap-4 md:flex-row md:items-center md:justify-between">
+          <div className="space-y-2">
+            <div className="flex items-center gap-2 text-red">
+              <DynamicIcon name="triangle-alert" className="h-4 w-4" />
+              <span className="text-sm font-semibold">危险操作</span>
+            </div>
+            <div>
+              <h4 className="text-text text-lg font-semibold">清空照片数据表</h4>
+              <p className="text-text-secondary text-sm">
+                删除数据库中的所有照片记录，仅保留对象存储文件。通常用于处理数据不一致、重新同步或迁移场景。
+              </p>
+            </div>
+          </div>
+          <Button
+            type="button"
+            variant="destructive"
+            size="sm"
+            isLoading={truncateMutation.isPending}
+            loadingText="清理中…"
+            onClick={handleTruncate}
+          >
+            清空数据库记录
+          </Button>
+        </div>
+        <p className="text-text-tertiary mt-4 text-xs">
+          操作完成后请立即重新执行「照片同步」，以便使用存储中的原始文件重建数据库与 manifest。
+        </p>
+      </LinearBorderPanel>
+    </div>
+  )
+}