diff --git a/apps/android/app/src/main/res/drawable-v21/launch_background.xml b/apps/android/app/src/main/res/drawable-v21/launch_background.xml
index f74085f..9023017 100644
--- a/apps/android/app/src/main/res/drawable-v21/launch_background.xml
+++ b/apps/android/app/src/main/res/drawable-v21/launch_background.xml
@@ -1,7 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
-<!-- Modify this file to customize your launch splash screen -->
 <layer-list xmlns:android="http://schemas.android.com/apk/res/android">
-    <item android:drawable="?android:colorBackground" />
+    <item android:drawable="@color/launchBackground" />
 
     <!-- You can insert your own image assets here -->
     <!-- <item>
diff --git a/apps/android/app/src/main/res/drawable/launch_background.xml b/apps/android/app/src/main/res/drawable/launch_background.xml
index 304732f..9023017 100644
--- a/apps/android/app/src/main/res/drawable/launch_background.xml
+++ b/apps/android/app/src/main/res/drawable/launch_background.xml
@@ -1,7 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
-<!-- Modify this file to customize your launch splash screen -->
 <layer-list xmlns:android="http://schemas.android.com/apk/res/android">
-    <item android:drawable="@android:color/white" />
+    <item android:drawable="@color/launchBackground" />
 
     <!-- You can insert your own image assets here -->
     <!-- <item>
diff --git a/apps/android/app/src/main/res/values/colors.xml b/apps/android/app/src/main/res/values/colors.xml
index c5d5899..d4a5d7f 100644
--- a/apps/android/app/src/main/res/values/colors.xml
+++ b/apps/android/app/src/main/res/values/colors.xml
@@ -1,4 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
 <resources>
     <color name="ic_launcher_background">#FFFFFF</color>
+    <color name="launchBackground">#EFF8FF</color>
 </resources>
\ No newline at end of file
diff --git a/apps/assets/branding/assistant_octopus_foreground.png b/apps/assets/branding/assistant_octopus_foreground.png
new file mode 100644
index 0000000..460db78
Binary files /dev/null and b/apps/assets/branding/assistant_octopus_foreground.png differ
diff --git a/apps/lib/features/auth/ui/screens/auth_boot_screen.dart b/apps/lib/features/auth/ui/screens/auth_boot_screen.dart
index 81c62af..ccf685e 100644
--- a/apps/lib/features/auth/ui/screens/auth_boot_screen.dart
+++ b/apps/lib/features/auth/ui/screens/auth_boot_screen.dart
@@ -1,23 +1,17 @@
 import 'package:flutter/material.dart';
 
-import '../../../../core/theme/design_tokens.dart';
-import '../../../../shared/widgets/app_loading_indicator.dart';
-
 class AuthBootScreen extends StatelessWidget {
   const AuthBootScreen({super.key});
 
   @override
   Widget build(BuildContext context) {
-    return const Scaffold(
-      backgroundColor: AppColors.authBackgroundTop,
+    return Scaffold(
+      backgroundColor: const Color(0xFFEFF8FF),
       body: SafeArea(
         child: Center(
-          child: AppLoadingIndicator(
-            variant: AppLoadingVariant.surface,
-            size: 28,
-            strokeWidth: 2.5,
-            color: AppColors.authPrimaryButton,
-            trackColor: AppColors.authPrimaryButtonDisabled,
+          child: Image.asset(
+            'assets/branding/assistant_octopus_foreground.png',
+            width: 260,
           ),
         ),
       ),
diff --git a/apps/lib/features/calendar/data/models/schedule_item_model.dart b/apps/lib/features/calendar/data/models/schedule_item_model.dart
index 00f78e0..95f15d8 100644
--- a/apps/lib/features/calendar/data/models/schedule_item_model.dart
+++ b/apps/lib/features/calendar/data/models/schedule_item_model.dart
@@ -2,7 +2,7 @@ import 'package:flutter/material.dart';
 
 enum ScheduleSourceType { manual, imported, agentGenerated }
 
-enum ScheduleStatus { active, completed, canceled, archived }
+enum ScheduleStatus { active, archived }
 
 class ScheduleItemModel {
   final String id;
@@ -279,9 +279,7 @@ ScheduleSourceType _sourceTypeFromApi(String? raw) {
 ScheduleStatus _statusFromApi(String? raw) {
   switch (raw) {
     case 'completed':
-      return ScheduleStatus.completed;
     case 'canceled':
-      return ScheduleStatus.canceled;
     case 'archived':
       return ScheduleStatus.archived;
     case 'active':
@@ -294,10 +292,6 @@ String _statusToApi(ScheduleStatus status) {
   switch (status) {
     case ScheduleStatus.active:
       return 'active';
-    case ScheduleStatus.completed:
-      return 'completed';
-    case ScheduleStatus.canceled:
-      return 'canceled';
     case ScheduleStatus.archived:
       return 'archived';
   }
diff --git a/apps/pubspec.yaml b/apps/pubspec.yaml
index 1dd8b99..b965924 100644
--- a/apps/pubspec.yaml
+++ b/apps/pubspec.yaml
@@ -41,6 +41,7 @@ flutter:
   uses-material-design: true
   assets:
     - assets/images/
+    - assets/branding/
 
 flutter_launcher_icons:
   android: true
diff --git a/backend/AGENTS.md b/backend/AGENTS.md
index f5ea22f..dc27fa8 100644
--- a/backend/AGENTS.md
+++ b/backend/AGENTS.md
@@ -45,6 +45,10 @@ This file governs `backend/**` only. Keep it minimal, enforceable, and non-dupli
 - Use service-role DB access only in backend.
 - Soft delete uses `deleted_at`; reads must exclude deleted records by default.
 - Alembic is the only schema migration source of truth.
+- Database migrations use `./infra/scripts/dev-migrate.sh`:
+  - `migrate` - run migrations only
+  - `init-data` - seed data only
+  - `bootstrap` - migrate + init-data
 
 ## Agent Runtime & Tools
 
diff --git a/backend/alembic/versions/20260325_0001_schedule_item_status_converge.py b/backend/alembic/versions/20260325_0001_schedule_item_status_converge.py
new file mode 100644
index 0000000..d33a431
--- /dev/null
+++ b/backend/alembic/versions/20260325_0001_schedule_item_status_converge.py
@@ -0,0 +1,54 @@
+"""converge schedule item status to active or archived
+
+Revision ID: 202603250001
+Revises: 202603240001
+Create Date: 2026-03-25 10:00:00
+"""
+
+from typing import Sequence, Union
+
+from alembic import op
+
+revision: str = "202603250001"
+down_revision: Union[str, Sequence[str], None] = "202603240001"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    op.execute(
+        """
+        UPDATE public.schedule_items
+        SET status = 'archived'
+        WHERE status IN ('completed', 'canceled')
+        """
+    )
+    op.execute(
+        """
+        ALTER TABLE public.schedule_items
+        DROP CONSTRAINT IF EXISTS chk_schedule_item_status
+        """
+    )
+    op.execute(
+        """
+        ALTER TABLE public.schedule_items
+        ADD CONSTRAINT chk_schedule_item_status
+        CHECK (status IN ('active', 'archived'))
+        """
+    )
+
+
+def downgrade() -> None:
+    op.execute(
+        """
+        ALTER TABLE public.schedule_items
+        DROP CONSTRAINT IF EXISTS chk_schedule_item_status
+        """
+    )
+    op.execute(
+        """
+        ALTER TABLE public.schedule_items
+        ADD CONSTRAINT chk_schedule_item_status
+        CHECK (status IN ('active', 'completed', 'canceled', 'archived'))
+        """
+    )
diff --git a/backend/src/core/agentscope/events/persistence.py b/backend/src/core/agentscope/events/persistence.py
index a948b6b..35c0eaa 100644
--- a/backend/src/core/agentscope/events/persistence.py
+++ b/backend/src/core/agentscope/events/persistence.py
@@ -7,8 +7,9 @@ from uuid import UUID
 from sqlalchemy import func, select
 from sqlalchemy.ext.asyncio import AsyncSession
 
-from models.agent_chat_message import AgentChatMessage, AgentChatMessageRole
-from models.agent_chat_session import AgentChatSession, AgentChatSessionStatus
+from models.agent_chat_message import AgentChatMessage
+from models.agent_chat_session import AgentChatSession
+from schemas.enums import AgentChatMessageRole, AgentChatSessionStatus
 
 
 class MessageRepository:
diff --git a/backend/src/core/agentscope/events/store.py b/backend/src/core/agentscope/events/store.py
index 23eed2b..3113785 100644
--- a/backend/src/core/agentscope/events/store.py
+++ b/backend/src/core/agentscope/events/store.py
@@ -6,12 +6,11 @@ from uuid import UUID
 
 from core.agentscope.events.persistence import MessageRepository, SessionRepository
 from core.logging import get_logger
-from models.agent_chat_message import AgentChatMessageRole
-from models.agent_chat_session import AgentChatSessionStatus
+from schemas.enums import AgentChatMessageRole, AgentChatSessionStatus
 from schemas.agent.system_agent import AgentType
 from schemas.agent.runtime_models import AgentOutput, RouterAgentOutput, ToolAgentOutput
 from schemas.agent.visibility import SystemVisibilityBit, bit_mask
-from schemas.messages.chat_message import AgentChatMessageMetadata
+from schemas.domain.chat_message import AgentChatMessageMetadata
 
 
 class EventStore(Protocol):
diff --git a/backend/src/core/agentscope/persistence/user_context_cache.py b/backend/src/core/agentscope/persistence/user_context_cache.py
index d8d8b67..a040ed8 100644
--- a/backend/src/core/agentscope/persistence/user_context_cache.py
+++ b/backend/src/core/agentscope/persistence/user_context_cache.py
@@ -9,7 +9,7 @@ from uuid import UUID
 import redis.asyncio as redis
 from core.config.settings import config
 from core.logging import get_logger
-from schemas.user import (
+from schemas.shared.user import (
     UserContext,
     parse_profile_settings,
 )
diff --git a/backend/src/core/agentscope/prompts/memory_prompt.py b/backend/src/core/agentscope/prompts/memory_prompt.py
index 20cd2d7..ccc02cc 100644
--- a/backend/src/core/agentscope/prompts/memory_prompt.py
+++ b/backend/src/core/agentscope/prompts/memory_prompt.py
@@ -2,7 +2,7 @@ from __future__ import annotations
 
 import json
 
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
 
 
 def _wrap_section(section: str, content: str) -> str:
diff --git a/backend/src/core/agentscope/prompts/system_prompt.py b/backend/src/core/agentscope/prompts/system_prompt.py
index 6eac2d1..a9228d3 100644
--- a/backend/src/core/agentscope/prompts/system_prompt.py
+++ b/backend/src/core/agentscope/prompts/system_prompt.py
@@ -17,8 +17,8 @@ from core.agentscope.prompts.route_prompt import build_frontend_route_prompt
 from core.agentscope.prompts.tool_prompt import build_tools_prompt
 from schemas.agent.system_agent import AgentType, SystemAgentLLMConfig
 from schemas.agent.forwarded_props import ClientTimeContext
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
-from schemas.user.context import UserContext
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.shared.user import UserContext
 
 
 def _wrap_section(section: str, content: str) -> str:
diff --git a/backend/src/core/agentscope/runtime/orchestrator.py b/backend/src/core/agentscope/runtime/orchestrator.py
index edf00fd..55617ac 100644
--- a/backend/src/core/agentscope/runtime/orchestrator.py
+++ b/backend/src/core/agentscope/runtime/orchestrator.py
@@ -6,9 +6,9 @@ from ag_ui.core.types import RunAgentInput
 from agentscope.message import Msg
 from core.agentscope.runtime.runner import AgentScopeRunner
 from core.logging import get_logger
-from schemas.automation import RuntimeConfig
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
-from schemas.user import UserContext
+from schemas.domain.automation import RuntimeConfig
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.shared.user import UserContext
 
 logger = get_logger("core.agentscope.runtime.orchestrator")
 
diff --git a/backend/src/core/agentscope/runtime/runner.py b/backend/src/core/agentscope/runtime/runner.py
index aab1a4d..7cc9ef8 100644
--- a/backend/src/core/agentscope/runtime/runner.py
+++ b/backend/src/core/agentscope/runtime/runner.py
@@ -40,9 +40,9 @@ from schemas.agent.system_agent import (
     AgentType,
     SystemAgentLLMConfig,
 )
-from schemas.automation import RuntimeConfig
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
-from schemas.user import UserContext
+from schemas.domain.automation import RuntimeConfig
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.shared.user import UserContext
 from services.litellm.service import LiteLLMService
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
diff --git a/backend/src/core/agentscope/runtime/tasks.py b/backend/src/core/agentscope/runtime/tasks.py
index 7c52889..9798ecc 100644
--- a/backend/src/core/agentscope/runtime/tasks.py
+++ b/backend/src/core/agentscope/runtime/tasks.py
@@ -20,13 +20,13 @@ from core.config.settings import config
 from core.db.session import AsyncSessionLocal
 from core.logging import get_logger
 from core.taskiq.app import worker_agent_broker, worker_automation_broker
-from schemas.automation import MessageContextConfig, RuntimeConfig
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
-from schemas.messages.chat_message import (
+from schemas.domain.automation import MessageContextConfig, RuntimeConfig
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.domain.chat_message import (
     AgentChatMessageMetadata,
     extract_user_message_attachments,
 )
-from schemas.user import UserContext
+from schemas.shared.user import UserContext
 from services.base.redis import get_or_init_redis_client
 from services.base.supabase import supabase_service
 from v1.agent.repository import AgentRepository
diff --git a/backend/src/core/agentscope/services/context_service.py b/backend/src/core/agentscope/services/context_service.py
index 4260462..383b590 100644
--- a/backend/src/core/agentscope/services/context_service.py
+++ b/backend/src/core/agentscope/services/context_service.py
@@ -6,7 +6,7 @@ from typing import Any, Protocol
 
 from schemas.agent.visibility import SystemVisibilityBit, bit_mask
 
-from schemas.automation import ContextWindowMode, MessageContextConfig
+from schemas.domain.automation import ContextWindowMode, MessageContextConfig
 
 
 _DEFAULT_CONTEXT_WINDOW_USER_MESSAGES = 20
diff --git a/backend/src/core/agentscope/tools/custom/calendar.py b/backend/src/core/agentscope/tools/custom/calendar.py
index 43cbec6..eaf6fae 100644
--- a/backend/src/core/agentscope/tools/custom/calendar.py
+++ b/backend/src/core/agentscope/tools/custom/calendar.py
@@ -84,7 +84,7 @@ class CalendarWriteOperation(BaseModel):
         le=10080,
         description="Reminder minutes before event start.",
     )
-    status: Literal["active", "completed", "canceled", "archived"] | None = Field(
+    status: Literal["active", "archived"] | None = Field(
         default=None,
         description="Optional status for update action.",
     )
@@ -163,6 +163,10 @@ async def calendar_read(
 ) -> ToolResponse:
     """Read calendar events with optional keyword filtering and pagination.
 
+    Status semantics for returned events:
+    - active: Event is actionable.
+    - archived: Event is historical/expired and should not trigger reminders.
+
     Args:
         query: Optional keyword used to filter events by text fields.
         page: Page number starting from 1.
diff --git a/backend/src/core/agentscope/tools/custom/memory.py b/backend/src/core/agentscope/tools/custom/memory.py
index 87c0631..87ba62f 100644
--- a/backend/src/core/agentscope/tools/custom/memory.py
+++ b/backend/src/core/agentscope/tools/custom/memory.py
@@ -15,9 +15,9 @@ from core.agentscope.tools.utils.tool_response_builder import (
     build_error_output,
     build_tool_response,
 )
-from models.memories import MemoryType
+from schemas.enums import MemoryType
 from schemas.agent.runtime_models import ErrorInfo, ToolAgentOutput, ToolStatus
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
 
 
 class MemoryWriteArgs(BaseModel):
diff --git a/backend/src/core/agentscope/tools/utils/calendar_domain.py b/backend/src/core/agentscope/tools/utils/calendar_domain.py
index a2504e2..be3261e 100644
--- a/backend/src/core/agentscope/tools/utils/calendar_domain.py
+++ b/backend/src/core/agentscope/tools/utils/calendar_domain.py
@@ -46,6 +46,9 @@ def create_schedule_service(
 def schedule_event_to_dict(event: object) -> dict[str, Any]:
     event_id = str(getattr(event, "id"))
     metadata = getattr(event, "metadata", None)
+    status_value = getattr(event, "status", None)
+    if hasattr(status_value, "value"):
+        status_value = getattr(status_value, "value")
     location_value = getattr(metadata, "location", None)
     color_value = getattr(metadata, "color", None) or "#4F46E5"
     reminder_minutes_value = getattr(metadata, "reminder_minutes", None)
@@ -58,6 +61,7 @@ def schedule_event_to_dict(event: object) -> dict[str, Any]:
         if getattr(event, "end_at") is not None
         else None,
         "timezone": getattr(event, "timezone"),
+        "status": status_value,
         "location": location_value,
         "color": color_value,
         "reminderMinutes": reminder_minutes_value,
diff --git a/backend/src/core/automation/scheduler.py b/backend/src/core/automation/scheduler.py
index 69b70cd..dd38574 100644
--- a/backend/src/core/automation/scheduler.py
+++ b/backend/src/core/automation/scheduler.py
@@ -5,7 +5,7 @@ from uuid import UUID
 
 from core.config.settings import config
 from core.logging import get_logger
-from schemas.automation import RuntimeConfig
+from schemas.domain.automation import RuntimeConfig
 
 logger = get_logger("core.automation.scheduler")
 
diff --git a/backend/src/models/__init__.py b/backend/src/models/__init__.py
index a0f5f4b..6a443d1 100644
--- a/backend/src/models/__init__.py
+++ b/backend/src/models/__init__.py
@@ -6,7 +6,7 @@ from models.automation_jobs import AutomationJob
 from models.group_members import GroupMember
 from models.groups import Group
 from models.inbox_messages import InboxMessage
-from models.invite_code import InviteCode, InviteCodeStatus
+from models.invite_code import InviteCode
 from models.llm import Llm
 from models.llm_factory import LlmFactory
 from models.memories import Memory
@@ -16,6 +16,7 @@ from models.schedule_subscriptions import ScheduleSubscription
 from models.system_agents import SystemAgents
 from models.todos import Todo
 from models.todo_sources import TodoSource
+from schemas.enums import InviteCodeStatus
 
 __all__ = [
     "AgentChatMessage",
diff --git a/backend/src/models/agent_chat_message.py b/backend/src/models/agent_chat_message.py
index fbf72ba..d55513f 100644
--- a/backend/src/models/agent_chat_message.py
+++ b/backend/src/models/agent_chat_message.py
@@ -2,7 +2,6 @@ from __future__ import annotations
 
 from decimal import Decimal
 import uuid
-from enum import Enum
 
 from sqlalchemy import (
     BigInteger,
@@ -19,13 +18,9 @@ from sqlalchemy.dialects.postgresql import JSONB, UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import AgentChatMessageRole
 
-
-class AgentChatMessageRole(str, Enum):
-    USER = "user"
-    ASSISTANT = "assistant"
-    SYSTEM = "system"
-    TOOL = "tool"
+__all__ = ["AgentChatMessage", "AgentChatMessageRole"]
 
 
 class AgentChatMessage(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/agent_chat_session.py b/backend/src/models/agent_chat_session.py
index 6e096c4..32ada06 100644
--- a/backend/src/models/agent_chat_session.py
+++ b/backend/src/models/agent_chat_session.py
@@ -3,7 +3,6 @@ from __future__ import annotations
 from datetime import datetime
 from decimal import Decimal
 import uuid
-from enum import Enum
 
 from sqlalchemy import (
     DateTime,
@@ -19,18 +18,9 @@ from sqlalchemy.dialects.postgresql import JSONB, UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import AgentChatSessionStatus, SessionType
 
-
-class AgentChatSessionStatus(str, Enum):
-    PENDING = "pending"
-    RUNNING = "running"
-    COMPLETED = "completed"
-    FAILED = "failed"
-
-
-class SessionType(str, Enum):
-    CHAT = "chat"
-    AUTOMATION = "automation"
+__all__ = ["AgentChatSession", "AgentChatSessionStatus", "SessionType"]
 
 
 class AgentChatSession(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/automation_jobs.py b/backend/src/models/automation_jobs.py
index baef990..2e0322a 100644
--- a/backend/src/models/automation_jobs.py
+++ b/backend/src/models/automation_jobs.py
@@ -2,23 +2,15 @@ from __future__ import annotations
 
 import uuid
 from datetime import datetime
-from enum import Enum
 
 from sqlalchemy import DateTime, JSON, String
 from sqlalchemy.dialects.postgresql import JSONB, UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import AutomationJobStatus, ScheduleType
 
-
-class AutomationJobStatus(str, Enum):
-    ACTIVE = "active"
-    DISABLED = "disabled"
-
-
-class ScheduleType(str, Enum):
-    DAILY = "daily"
-    WEEKLY = "weekly"
+__all__ = ["AutomationJob", "AutomationJobStatus", "ScheduleType"]
 
 
 class AutomationJob(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/friendships.py b/backend/src/models/friendships.py
index d7f3f45..b03a753 100644
--- a/backend/src/models/friendships.py
+++ b/backend/src/models/friendships.py
@@ -2,21 +2,15 @@ from __future__ import annotations
 
 import uuid
 from datetime import datetime
-from enum import Enum
 
 from sqlalchemy import DateTime, String
 from sqlalchemy.dialects.postgresql import UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import FriendshipStatus
 
-
-class FriendshipStatus(str, Enum):
-    PENDING = "pending"
-    ACCEPTED = "accepted"
-    BLOCKED = "blocked"
-    DECLINED = "declined"
-    CANCELED = "canceled"
+__all__ = ["Friendship", "FriendshipStatus"]
 
 
 class Friendship(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/group_members.py b/backend/src/models/group_members.py
index 07d7e8f..fd9e944 100644
--- a/backend/src/models/group_members.py
+++ b/backend/src/models/group_members.py
@@ -1,30 +1,20 @@
 from __future__ import annotations
 
 import uuid
-from enum import Enum
 
 from sqlalchemy import String
 from sqlalchemy.dialects.postgresql import UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import GroupMemberRole, GroupMemberSource, GroupMemberStatus
 
-
-class GroupMemberRole(str, Enum):
-    OWNER = "owner"
-    ADMIN = "admin"
-    MEMBER = "member"
-
-
-class GroupMemberSource(str, Enum):
-    INVITED = "invited"
-    JOINED = "joined"
-
-
-class GroupMemberStatus(str, Enum):
-    ACTIVE = "active"
-    MUTED = "muted"
-    REMOVED = "removed"
+__all__ = [
+    "GroupMember",
+    "GroupMemberRole",
+    "GroupMemberSource",
+    "GroupMemberStatus",
+]
 
 
 class GroupMember(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/groups.py b/backend/src/models/groups.py
index d54b607..0694aed 100644
--- a/backend/src/models/groups.py
+++ b/backend/src/models/groups.py
@@ -1,18 +1,15 @@
 from __future__ import annotations
 
 import uuid
-from enum import Enum
 
 from sqlalchemy import String, Text
 from sqlalchemy.dialects.postgresql import UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import GroupStatus
 
-
-class GroupStatus(str, Enum):
-    ACTIVE = "active"
-    ARCHIVED = "archived"
+__all__ = ["Group", "GroupStatus"]
 
 
 class Group(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/inbox_messages.py b/backend/src/models/inbox_messages.py
index e77269f..5293671 100644
--- a/backend/src/models/inbox_messages.py
+++ b/backend/src/models/inbox_messages.py
@@ -1,27 +1,15 @@
 from __future__ import annotations
 
 import uuid
-from enum import Enum
 
 from sqlalchemy import Boolean, String
 from sqlalchemy.dialects.postgresql import JSONB, UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, TimestampMixin
+from schemas.enums import InboxMessageStatus, InboxMessageType
 
-
-class InboxMessageType(str, Enum):
-    FRIEND_REQUEST = "friend_request"
-    CALENDAR = "calendar"
-    SYSTEM = "system"
-    GROUP = "group"
-
-
-class InboxMessageStatus(str, Enum):
-    PENDING = "pending"
-    ACCEPTED = "accepted"
-    REJECTED = "rejected"
-    DISMISSED = "dismissed"
+__all__ = ["InboxMessage", "InboxMessageType", "InboxMessageStatus"]
 
 
 class InboxMessage(TimestampMixin, Base):
diff --git a/backend/src/models/invite_code.py b/backend/src/models/invite_code.py
index c9ace1d..bab7f63 100644
--- a/backend/src/models/invite_code.py
+++ b/backend/src/models/invite_code.py
@@ -2,7 +2,6 @@ from __future__ import annotations
 
 import uuid
 from datetime import datetime
-from enum import Enum
 
 from sqlalchemy import CheckConstraint, DateTime, ForeignKey, Integer, String
 from sqlalchemy.dialects.postgresql import UUID
@@ -10,12 +9,9 @@ from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, TimestampMixin
 from core.db.types import json_jsonb
+from schemas.enums import InviteCodeStatus
 
-
-class InviteCodeStatus(str, Enum):
-    ACTIVE = "active"
-    DISABLED = "disabled"
-    EXPIRED = "expired"
+__all__ = ["InviteCode", "InviteCodeStatus"]
 
 
 class InviteCode(TimestampMixin, Base):
diff --git a/backend/src/models/memories.py b/backend/src/models/memories.py
index afb8f8d..3a3cd0a 100644
--- a/backend/src/models/memories.py
+++ b/backend/src/models/memories.py
@@ -1,7 +1,6 @@
 from __future__ import annotations
 
 import uuid
-from enum import Enum
 
 from sqlalchemy import String
 from sqlalchemy.dialects.postgresql import UUID
@@ -9,16 +8,9 @@ from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, TimestampMixin
 from core.db.types import json_jsonb
+from schemas.enums import MemoryStatus, MemoryType
 
-
-class MemoryType(str, Enum):
-    USER = "user"
-    WORK = "work"
-
-
-class MemoryStatus(str, Enum):
-    ACTIVE = "active"
-    DISABLED = "disabled"
+__all__ = ["Memory", "MemoryType", "MemoryStatus"]
 
 
 class Memory(TimestampMixin, Base):
diff --git a/backend/src/models/schedule_items.py b/backend/src/models/schedule_items.py
index bcc6a25..28fcb26 100644
--- a/backend/src/models/schedule_items.py
+++ b/backend/src/models/schedule_items.py
@@ -2,7 +2,6 @@ from __future__ import annotations
 
 import uuid
 from datetime import datetime
-from enum import Enum
 
 from sqlalchemy import DateTime, String, Text
 from sqlalchemy.dialects.postgresql import UUID
@@ -10,19 +9,9 @@ from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
 from core.db.types import json_jsonb
+from schemas.enums import ScheduleItemSourceType, ScheduleItemStatus
 
-
-class ScheduleItemStatus(str, Enum):
-    ACTIVE = "active"
-    COMPLETED = "completed"
-    CANCELED = "canceled"
-    ARCHIVED = "archived"
-
-
-class ScheduleItemSourceType(str, Enum):
-    MANUAL = "manual"
-    IMPORTED = "imported"
-    AGENT_GENERATED = "agent_generated"
+__all__ = ["ScheduleItem", "ScheduleItemStatus", "ScheduleItemSourceType"]
 
 
 class ScheduleItem(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/models/schedule_subscriptions.py b/backend/src/models/schedule_subscriptions.py
index 06c86dc..856edce 100644
--- a/backend/src/models/schedule_subscriptions.py
+++ b/backend/src/models/schedule_subscriptions.py
@@ -1,33 +1,20 @@
 from __future__ import annotations
 
 import uuid
-from enum import Enum
 
 from sqlalchemy import Integer, String
 from sqlalchemy.dialects.postgresql import UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, TimestampMixin
+from schemas.enums import NotifyLevel, SubscriptionPermission, SubscriptionStatus
 
-
-class SubscriptionStatus(str, Enum):
-    ACTIVE = "active"
-    PENDING = "pending"
-    PAUSED = "paused"
-    UNSUBSCRIBED = "unsubscribed"
-
-
-class NotifyLevel(str, Enum):
-    ALL = "all"
-    MENTIONS = "mentions"
-    NONE = "none"
-
-
-class SubscriptionPermission(int, Enum):
-    VIEW = 1  # 001 - 可查看
-    INVITE = 2  # 010 - 可邀请
-    EDIT = 4  # 100 - 可编辑
-    OWNER = 7  # 111 - 所有者（VIEW + INVITE + EDIT）
+__all__ = [
+    "ScheduleSubscription",
+    "SubscriptionStatus",
+    "NotifyLevel",
+    "SubscriptionPermission",
+]
 
 
 class ScheduleSubscription(TimestampMixin, Base):
diff --git a/backend/src/models/todos.py b/backend/src/models/todos.py
index c636164..cceb7be 100644
--- a/backend/src/models/todos.py
+++ b/backend/src/models/todos.py
@@ -2,26 +2,15 @@ from __future__ import annotations
 
 import uuid
 from datetime import datetime
-from enum import Enum
 
 from sqlalchemy import DateTime, Integer, String
 from sqlalchemy.dialects.postgresql import UUID
 from sqlalchemy.orm import Mapped, mapped_column
 
 from core.db.base import Base, SoftDeleteMixin, TimestampMixin
+from schemas.enums import TodoPriority, TodoStatus
 
-
-class TodoStatus(str, Enum):
-    PENDING = "pending"
-    DONE = "done"
-    CANCELED = "canceled"
-
-
-class TodoPriority(int, Enum):
-    IMPORTANT_URGENT = 1
-    IMPORTANT_NOT_URGENT = 2
-    NOT_IMPORTANT_URGENT = 3
-    NOT_IMPORTANT_NOT_URGENT = 4
+__all__ = ["Todo", "TodoStatus", "TodoPriority"]
 
 
 class Todo(TimestampMixin, SoftDeleteMixin, Base):
diff --git a/backend/src/schemas/__init__.py b/backend/src/schemas/__init__.py
index cc79b61..82184cb 100644
--- a/backend/src/schemas/__init__.py
+++ b/backend/src/schemas/__init__.py
@@ -1,45 +1 @@
-"""Centralized shared schemas for cross-module contracts."""
-
-from schemas.inbox.messages import (
-    CalendarContent,
-    CalendarDeleteContent,
-    CalendarInviteContent,
-    CalendarUpdateContent,
-    FriendshipContent,
-    InboxMessageContent,
-    InboxMessageStatus,
-    InboxMessageType,
-    parse_calendar_content,
-)
-from schemas.invite_codes import InviteCodeRewardConfig
-from schemas.messages import AgentChatMessageMetadata
-from schemas.schedule.items import (
-    AttachmentType,
-    ScheduleItemMetadata,
-    ScheduleItemMetadataAttachment,
-    ScheduleItemSourceType,
-    ScheduleItemStatus,
-)
-from schemas.sessions import SessionStateSnapshot
-from schemas.user.context import UserContext
-
-__all__ = [
-    "AgentChatMessageMetadata",
-    "AttachmentType",
-    "CalendarContent",
-    "CalendarDeleteContent",
-    "CalendarInviteContent",
-    "CalendarUpdateContent",
-    "FriendshipContent",
-    "InboxMessageContent",
-    "InboxMessageStatus",
-    "InboxMessageType",
-    "InviteCodeRewardConfig",
-    "ScheduleItemMetadata",
-    "ScheduleItemMetadataAttachment",
-    "ScheduleItemSourceType",
-    "ScheduleItemStatus",
-    "SessionStateSnapshot",
-    "UserContext",
-    "parse_calendar_content",
-]
+"""Backend reusable schemas package."""
diff --git a/backend/src/schemas/agent/ui_schema.py b/backend/src/schemas/agent/ui_schema.py
index 11104cb..a0b682c 100644
--- a/backend/src/schemas/agent/ui_schema.py
+++ b/backend/src/schemas/agent/ui_schema.py
@@ -12,7 +12,7 @@ Version: 2.0
 from __future__ import annotations
 
 from enum import Enum
-from typing import Any, Literal, NotRequired, TypedDict, Union
+from typing import Any, Literal, TypedDict, Union
 
 # ============================================================
 # Enums
diff --git a/backend/src/schemas/domain/__init__.py b/backend/src/schemas/domain/__init__.py
new file mode 100644
index 0000000..9ecb748
--- /dev/null
+++ b/backend/src/schemas/domain/__init__.py
@@ -0,0 +1 @@
+"""Reusable domain schemas shared across backend modules."""
diff --git a/backend/src/schemas/automation/__init__.py b/backend/src/schemas/domain/automation.py
similarity index 70%
rename from backend/src/schemas/automation/__init__.py
rename to backend/src/schemas/domain/automation.py
index c642e6d..cfd757f 100644
--- a/backend/src/schemas/automation/__init__.py
+++ b/backend/src/schemas/domain/automation.py
@@ -2,13 +2,27 @@ from __future__ import annotations
 
 from datetime import datetime
 from enum import Enum
+from typing import Protocol
 from uuid import UUID
 
 from core.agentscope.tools.tool_config import AgentTool
 from pydantic import BaseModel, ConfigDict, Field, model_validator
+from schemas.enums import AutomationJobStatus, ScheduleType
 
-from models.automation_jobs import AutomationJob as OrmAutomationJob
-from models.automation_jobs import AutomationJobStatus, ScheduleType
+
+class AutomationJobLike(Protocol):
+    id: UUID
+    owner_id: UUID
+    bootstrap_key: str | None
+    title: str
+    config: dict[str, object]
+    next_run_at: datetime
+    timezone: str
+    last_run_at: datetime | None
+    status: AutomationJobStatus
+    created_by: UUID | None
+    created_at: datetime
+    updated_at: datetime
 
 
 class ContextSource(str, Enum):
@@ -50,8 +64,7 @@ class ScheduleConfig(BaseModel):
             invalid = [day for day in self.weekdays if day < 1 or day > 7]
             if invalid:
                 raise ValueError("weekdays must be within 1-7")
-            deduped = sorted(set(self.weekdays))
-            self.weekdays = deduped
+            self.weekdays = sorted(set(self.weekdays))
         else:
             self.weekdays = None
         return self
@@ -90,20 +103,20 @@ class AutomationJob(BaseModel):
     updated_at: datetime
 
     @classmethod
-    def from_orm(cls, obj: OrmAutomationJob) -> "AutomationJob":
+    def from_orm(cls, obj: object) -> "AutomationJob":
         return cls(
-            id=obj.id,
-            owner_id=obj.owner_id,
-            bootstrap_key=obj.bootstrap_key,
-            title=obj.title,
-            config=AutomationJobConfig.model_validate(obj.config or {}),
-            next_run_at=obj.next_run_at,
-            timezone=obj.timezone,
-            last_run_at=obj.last_run_at,
-            status=obj.status,
-            created_by=obj.created_by,
-            created_at=obj.created_at,
-            updated_at=obj.updated_at,
+            id=getattr(obj, "id"),
+            owner_id=getattr(obj, "owner_id"),
+            bootstrap_key=getattr(obj, "bootstrap_key"),
+            title=getattr(obj, "title"),
+            config=AutomationJobConfig.model_validate(getattr(obj, "config", {}) or {}),
+            next_run_at=getattr(obj, "next_run_at"),
+            timezone=getattr(obj, "timezone"),
+            last_run_at=getattr(obj, "last_run_at"),
+            status=getattr(obj, "status"),
+            created_by=getattr(obj, "created_by"),
+            created_at=getattr(obj, "created_at"),
+            updated_at=getattr(obj, "updated_at"),
         )
 
     @property
diff --git a/backend/src/schemas/messages/chat_message.py b/backend/src/schemas/domain/chat_message.py
similarity index 100%
rename from backend/src/schemas/messages/chat_message.py
rename to backend/src/schemas/domain/chat_message.py
diff --git a/backend/src/schemas/sessions/chat_session.py b/backend/src/schemas/domain/chat_session.py
similarity index 100%
rename from backend/src/schemas/sessions/chat_session.py
rename to backend/src/schemas/domain/chat_session.py
diff --git a/backend/src/schemas/inbox/messages.py b/backend/src/schemas/domain/inbox.py
similarity index 85%
rename from backend/src/schemas/inbox/messages.py
rename to backend/src/schemas/domain/inbox.py
index 6110332..d33129a 100644
--- a/backend/src/schemas/inbox/messages.py
+++ b/backend/src/schemas/domain/inbox.py
@@ -1,24 +1,22 @@
 from __future__ import annotations
 
 import json
-from enum import Enum
 from typing import ClassVar, Literal, Union
 
 from pydantic import BaseModel, ConfigDict, Field
+from schemas.enums import InboxMessageStatus, InboxMessageType
 
-
-class InboxMessageType(str, Enum):
-    FRIEND_REQUEST = "friend_request"
-    CALENDAR = "calendar"
-    SYSTEM = "system"
-    GROUP = "group"
-
-
-class InboxMessageStatus(str, Enum):
-    PENDING = "pending"
-    ACCEPTED = "accepted"
-    REJECTED = "rejected"
-    DISMISSED = "dismissed"
+__all__ = [
+    "InboxMessageType",
+    "InboxMessageStatus",
+    "CalendarInviteContent",
+    "CalendarUpdateContent",
+    "CalendarDeleteContent",
+    "FriendshipContent",
+    "CalendarContent",
+    "InboxMessageContent",
+    "parse_calendar_content",
+]
 
 
 class CalendarInviteContent(BaseModel):
diff --git a/backend/src/schemas/invite_codes/__init__.py b/backend/src/schemas/domain/invite_code.py
similarity index 100%
rename from backend/src/schemas/invite_codes/__init__.py
rename to backend/src/schemas/domain/invite_code.py
diff --git a/backend/src/schemas/memories/__init__.py b/backend/src/schemas/domain/memory.py
similarity index 79%
rename from backend/src/schemas/memories/__init__.py
rename to backend/src/schemas/domain/memory.py
index d4ccdf8..361ba10 100644
--- a/backend/src/schemas/memories/__init__.py
+++ b/backend/src/schemas/domain/memory.py
@@ -1,13 +1,11 @@
 from __future__ import annotations
 
 from datetime import datetime
-from enum import Enum
 from typing import ClassVar, Literal
 from uuid import UUID
 
 from pydantic import BaseModel, ConfigDict
-
-from schemas.memories.memory_content import (
+from schemas.domain.memory_content import (
     TeamMember,
     UserMemoryContent,
     UserPreferences,
@@ -15,16 +13,7 @@ from schemas.memories.memory_content import (
     WorkProfileContent,
     WorkProject,
 )
-
-
-class MemoryType(str, Enum):
-    USER = "user"
-    WORK = "work"
-
-
-class MemoryStatus(str, Enum):
-    ACTIVE = "active"
-    DISABLED = "disabled"
+from schemas.enums import MemoryStatus, MemoryType
 
 
 class MemoryModel(BaseModel):
diff --git a/backend/src/schemas/memories/memory_content.py b/backend/src/schemas/domain/memory_content.py
similarity index 100%
rename from backend/src/schemas/memories/memory_content.py
rename to backend/src/schemas/domain/memory_content.py
diff --git a/backend/src/schemas/schedule/items.py b/backend/src/schemas/domain/schedule.py
similarity index 78%
rename from backend/src/schemas/schedule/items.py
rename to backend/src/schemas/domain/schedule.py
index 1988176..10c276f 100644
--- a/backend/src/schemas/schedule/items.py
+++ b/backend/src/schemas/domain/schedule.py
@@ -5,6 +5,15 @@ from typing import ClassVar, Literal
 from uuid import UUID
 
 from pydantic import BaseModel, ConfigDict, Field
+from schemas.enums import ScheduleItemSourceType, ScheduleItemStatus
+
+__all__ = [
+    "AttachmentType",
+    "ScheduleItemMetadataAttachment",
+    "ScheduleItemMetadata",
+    "ScheduleItemSourceType",
+    "ScheduleItemStatus",
+]
 
 
 class AttachmentType(str, Enum):
@@ -32,16 +41,3 @@ class ScheduleItemMetadata(BaseModel):
     attachments: list[ScheduleItemMetadataAttachment] = Field(default_factory=list)
     reminder_minutes: int | None = Field(default=None, ge=0, le=10080)
     version: Literal[1] = 1
-
-
-class ScheduleItemStatus(str, Enum):
-    ACTIVE = "active"
-    COMPLETED = "completed"
-    CANCELED = "canceled"
-    ARCHIVED = "archived"
-
-
-class ScheduleItemSourceType(str, Enum):
-    MANUAL = "manual"
-    IMPORTED = "imported"
-    AGENT_GENERATED = "agent_generated"
diff --git a/backend/src/schemas/todo/contracts.py b/backend/src/schemas/domain/todo.py
similarity index 100%
rename from backend/src/schemas/todo/contracts.py
rename to backend/src/schemas/domain/todo.py
diff --git a/backend/src/schemas/enums.py b/backend/src/schemas/enums.py
new file mode 100644
index 0000000..ba4bf8a
--- /dev/null
+++ b/backend/src/schemas/enums.py
@@ -0,0 +1,136 @@
+from __future__ import annotations
+
+from enum import Enum
+
+
+class ScheduleItemStatus(str, Enum):
+    ACTIVE = "active"
+    ARCHIVED = "archived"
+
+
+class ScheduleItemSourceType(str, Enum):
+    MANUAL = "manual"
+    IMPORTED = "imported"
+    AGENT_GENERATED = "agent_generated"
+
+
+class AutomationJobStatus(str, Enum):
+    ACTIVE = "active"
+    DISABLED = "disabled"
+
+
+class ScheduleType(str, Enum):
+    DAILY = "daily"
+    WEEKLY = "weekly"
+
+
+class MemoryType(str, Enum):
+    USER = "user"
+    WORK = "work"
+
+
+class MemoryStatus(str, Enum):
+    ACTIVE = "active"
+    DISABLED = "disabled"
+
+
+class TodoStatus(str, Enum):
+    PENDING = "pending"
+    DONE = "done"
+    CANCELED = "canceled"
+
+
+class TodoPriority(int, Enum):
+    IMPORTANT_URGENT = 1
+    IMPORTANT_NOT_URGENT = 2
+    NOT_IMPORTANT_URGENT = 3
+    NOT_IMPORTANT_NOT_URGENT = 4
+
+
+class AgentChatMessageRole(str, Enum):
+    USER = "user"
+    ASSISTANT = "assistant"
+    SYSTEM = "system"
+    TOOL = "tool"
+
+
+class AgentChatSessionStatus(str, Enum):
+    PENDING = "pending"
+    RUNNING = "running"
+    COMPLETED = "completed"
+    FAILED = "failed"
+
+
+class SessionType(str, Enum):
+    CHAT = "chat"
+    AUTOMATION = "automation"
+
+
+class InboxMessageType(str, Enum):
+    FRIEND_REQUEST = "friend_request"
+    CALENDAR = "calendar"
+    SYSTEM = "system"
+    GROUP = "group"
+
+
+class InboxMessageStatus(str, Enum):
+    PENDING = "pending"
+    ACCEPTED = "accepted"
+    REJECTED = "rejected"
+    DISMISSED = "dismissed"
+
+
+class SubscriptionStatus(str, Enum):
+    ACTIVE = "active"
+    PENDING = "pending"
+    PAUSED = "paused"
+    UNSUBSCRIBED = "unsubscribed"
+
+
+class NotifyLevel(str, Enum):
+    ALL = "all"
+    MENTIONS = "mentions"
+    NONE = "none"
+
+
+class SubscriptionPermission(int, Enum):
+    VIEW = 1
+    INVITE = 2
+    EDIT = 4
+    OWNER = 7
+
+
+class FriendshipStatus(str, Enum):
+    PENDING = "pending"
+    ACCEPTED = "accepted"
+    BLOCKED = "blocked"
+    DECLINED = "declined"
+    CANCELED = "canceled"
+
+
+class InviteCodeStatus(str, Enum):
+    ACTIVE = "active"
+    DISABLED = "disabled"
+    EXPIRED = "expired"
+
+
+class GroupStatus(str, Enum):
+    ACTIVE = "active"
+    ARCHIVED = "archived"
+
+
+class GroupMemberRole(str, Enum):
+    OWNER = "owner"
+    ADMIN = "admin"
+    MEMBER = "member"
+
+
+class GroupMemberSource(str, Enum):
+    INVITED = "invited"
+    JOINED = "joined"
+
+
+class GroupMemberStatus(str, Enum):
+    ACTIVE = "active"
+    MUTED = "muted"
+    REMOVED = "removed"
diff --git a/backend/src/schemas/inbox/__init__.py b/backend/src/schemas/inbox/__init__.py
deleted file mode 100644
index 80d5f22..0000000
--- a/backend/src/schemas/inbox/__init__.py
+++ /dev/null
@@ -1,3 +0,0 @@
-from schemas.inbox.messages import InboxMessageStatus, InboxMessageType
-
-__all__ = ["InboxMessageStatus", "InboxMessageType"]
diff --git a/backend/src/schemas/messages/__init__.py b/backend/src/schemas/messages/__init__.py
deleted file mode 100644
index 2cf9e80..0000000
--- a/backend/src/schemas/messages/__init__.py
+++ /dev/null
@@ -1,3 +0,0 @@
-from schemas.messages.chat_message import AgentChatMessage, AgentChatMessageMetadata
-
-__all__ = ["AgentChatMessage", "AgentChatMessageMetadata"]
diff --git a/backend/src/schemas/schedule/__init__.py b/backend/src/schemas/schedule/__init__.py
deleted file mode 100644
index 48b28d8..0000000
--- a/backend/src/schemas/schedule/__init__.py
+++ /dev/null
@@ -1,27 +0,0 @@
-from schemas.inbox.messages import (
-    CalendarContent,
-    CalendarDeleteContent,
-    CalendarInviteContent,
-    CalendarUpdateContent,
-    parse_calendar_content,
-)
-from schemas.schedule.items import (
-    AttachmentType,
-    ScheduleItemMetadata,
-    ScheduleItemMetadataAttachment,
-    ScheduleItemSourceType,
-    ScheduleItemStatus,
-)
-
-__all__ = [
-    "AttachmentType",
-    "CalendarContent",
-    "CalendarDeleteContent",
-    "CalendarInviteContent",
-    "CalendarUpdateContent",
-    "ScheduleItemMetadata",
-    "ScheduleItemMetadataAttachment",
-    "ScheduleItemSourceType",
-    "ScheduleItemStatus",
-    "parse_calendar_content",
-]
diff --git a/backend/src/schemas/sessions/__init__.py b/backend/src/schemas/sessions/__init__.py
deleted file mode 100644
index 0f3c651..0000000
--- a/backend/src/schemas/sessions/__init__.py
+++ /dev/null
@@ -1,3 +0,0 @@
-from schemas.sessions.chat_session import SessionStateSnapshot
-
-__all__ = ["SessionStateSnapshot"]
diff --git a/backend/src/schemas/shared/__init__.py b/backend/src/schemas/shared/__init__.py
new file mode 100644
index 0000000..5d46bec
--- /dev/null
+++ b/backend/src/schemas/shared/__init__.py
@@ -0,0 +1 @@
+"""Shared schemas used across multiple domain modules."""
diff --git a/backend/src/schemas/user/context.py b/backend/src/schemas/shared/user.py
similarity index 100%
rename from backend/src/schemas/user/context.py
rename to backend/src/schemas/shared/user.py
diff --git a/backend/src/schemas/todo/__init__.py b/backend/src/schemas/todo/__init__.py
deleted file mode 100644
index 896123c..0000000
--- a/backend/src/schemas/todo/__init__.py
+++ /dev/null
@@ -1,3 +0,0 @@
-from .contracts import TodoOrder
-
-__all__ = ["TodoOrder"]
diff --git a/backend/src/schemas/user/__init__.py b/backend/src/schemas/user/__init__.py
deleted file mode 100644
index 205a8b5..0000000
--- a/backend/src/schemas/user/__init__.py
+++ /dev/null
@@ -1,17 +0,0 @@
-from schemas.user.context import (
-    PreferenceSettings,
-    ProfileSettingsUnion,
-    ProfileSettingsV1,
-    UserContext,
-    parse_profile_settings,
-    upgrade_to_latest,
-)
-
-__all__ = [
-    "PreferenceSettings",
-    "ProfileSettingsUnion",
-    "ProfileSettingsV1",
-    "UserContext",
-    "parse_profile_settings",
-    "upgrade_to_latest",
-]
diff --git a/backend/src/v1/agent/repository.py b/backend/src/v1/agent/repository.py
index 06a50da..2687319 100644
--- a/backend/src/v1/agent/repository.py
+++ b/backend/src/v1/agent/repository.py
@@ -9,10 +9,11 @@ from fastapi import HTTPException
 from sqlalchemy import Select, select
 from sqlalchemy.ext.asyncio import AsyncSession
 
-from models.agent_chat_message import AgentChatMessage, AgentChatMessageRole
+from models.agent_chat_message import AgentChatMessage
 from models.agent_chat_session import AgentChatSession
 from models.system_agents import SystemAgents
-from schemas.messages.chat_message import (
+from schemas.enums import AgentChatMessageRole
+from schemas.domain.chat_message import (
     AgentChatMessage as AgentChatMessageSchema,
     AgentChatMessageMetadata,
 )
diff --git a/backend/src/v1/agent/service.py b/backend/src/v1/agent/service.py
index aff480f..f234838 100644
--- a/backend/src/v1/agent/service.py
+++ b/backend/src/v1/agent/service.py
@@ -18,8 +18,8 @@ from schemas.agent.forwarded_props import (
     RuntimeMode,
 )
 from schemas.agent.visibility import SystemVisibilityBit, bit_mask
-from schemas.automation import RuntimeConfig
-from schemas.messages.chat_message import (
+from schemas.domain.automation import RuntimeConfig
+from schemas.domain.chat_message import (
     AgentChatMessageMetadata,
     UserMessageAttachment,
     extract_user_message_attachments,
@@ -362,7 +362,7 @@ class AgentService:
         before: date | None,
         current_user: CurrentUser,
     ) -> HistorySnapshotResponse:
-        from schemas.messages.chat_message import AgentChatMessage
+        from schemas.domain.chat_message import AgentChatMessage
         from v1.agent.utils import convert_message_to_history
         from v1.agent.schemas import HistoryMessage
 
diff --git a/backend/src/v1/agent/system_agents_config.py b/backend/src/v1/agent/system_agents_config.py
index 550de07..a9e3af5 100644
--- a/backend/src/v1/agent/system_agents_config.py
+++ b/backend/src/v1/agent/system_agents_config.py
@@ -11,7 +11,7 @@ from pydantic import ValidationError
 
 from core.agentscope.tools.tool_config import AgentTool
 from schemas.agent.system_agent import SystemAgentLLMConfig
-from schemas.automation import (
+from schemas.domain.automation import (
     ContextSource,
     ContextWindowMode,
     MessageContextConfig,
diff --git a/backend/src/v1/agent/utils.py b/backend/src/v1/agent/utils.py
index d67522d..c2344e9 100644
--- a/backend/src/v1/agent/utils.py
+++ b/backend/src/v1/agent/utils.py
@@ -8,7 +8,7 @@ from collections.abc import Callable
 from typing import Any
 
 from core.agentscope.runtime.ui_compiler import compile as compile_ui_hints
-from schemas.messages.chat_message import (
+from schemas.domain.chat_message import (
     AgentChatMessage,
     AgentChatMessageMetadata,
     extract_user_message_attachments,
diff --git a/backend/src/v1/auth/automation_static_config.py b/backend/src/v1/auth/automation_static_config.py
index a857973..ce0ab2d 100644
--- a/backend/src/v1/auth/automation_static_config.py
+++ b/backend/src/v1/auth/automation_static_config.py
@@ -7,7 +7,7 @@ from typing import Any
 
 import yaml
 
-from schemas.automation import AutomationJobConfig
+from schemas.domain.automation import AutomationJobConfig
 
 _CONFIG_NAME_PATTERN = re.compile(r"^[a-z0-9][a-z0-9_-]{0,63}$")
 
diff --git a/backend/src/v1/auth/registration_bootstrap.py b/backend/src/v1/auth/registration_bootstrap.py
index a6c2d22..d5de7f4 100644
--- a/backend/src/v1/auth/registration_bootstrap.py
+++ b/backend/src/v1/auth/registration_bootstrap.py
@@ -10,12 +10,12 @@ from sqlalchemy.dialects.postgresql import insert
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from core.logging import get_logger
-from models.automation_jobs import AutomationJob, AutomationJobStatus, ScheduleType
-from models.memories import MemoryType
+from models.automation_jobs import AutomationJob
+from schemas.enums import AutomationJobStatus, MemoryType, ScheduleType
 from models.profile import Profile
-from schemas.automation import AutomationJobConfig, ScheduleConfig
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
-from schemas.user.context import parse_profile_settings
+from schemas.domain.automation import AutomationJobConfig, ScheduleConfig
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.shared.user import parse_profile_settings
 from v1.auth.automation_static_config import load_static_automation_job_config
 from v1.auth.schemas import RegistrationBootstrapRequest
 from v1.memories.repository import SQLAlchemyMemoriesRepository
diff --git a/backend/src/v1/automation_jobs/repository.py b/backend/src/v1/automation_jobs/repository.py
index 194251b..02fa081 100644
--- a/backend/src/v1/automation_jobs/repository.py
+++ b/backend/src/v1/automation_jobs/repository.py
@@ -9,9 +9,10 @@ from sqlalchemy.ext.asyncio import AsyncSession
 from zoneinfo import ZoneInfo, ZoneInfoNotFoundError
 
 from core.db.base_repository import BaseRepository
-from models.agent_chat_session import AgentChatSession, SessionType
-from models.automation_jobs import AutomationJob, AutomationJobStatus, ScheduleType
-from schemas.automation import AutomationJobConfig, ScheduleConfig
+from models.agent_chat_session import AgentChatSession
+from models.automation_jobs import AutomationJob
+from schemas.enums import AutomationJobStatus, ScheduleType, SessionType
+from schemas.domain.automation import AutomationJobConfig, ScheduleConfig
 
 if TYPE_CHECKING:
     from v1.automation_jobs.schemas import (
diff --git a/backend/src/v1/automation_jobs/schemas.py b/backend/src/v1/automation_jobs/schemas.py
index 27aaa3e..bb6c82e 100644
--- a/backend/src/v1/automation_jobs/schemas.py
+++ b/backend/src/v1/automation_jobs/schemas.py
@@ -7,9 +7,8 @@ from zoneinfo import ZoneInfo, ZoneInfoNotFoundError
 
 from pydantic import BaseModel, ConfigDict, Field, field_validator, model_validator
 
-from models.automation_jobs import AutomationJob as OrmAutomationJob
-from models.automation_jobs import AutomationJobStatus
-from schemas.automation import AutomationJobConfig
+from schemas.domain.automation import AutomationJobConfig
+from schemas.enums import AutomationJobStatus
 
 
 class AutomationJobResponse(BaseModel):
@@ -29,20 +28,20 @@ class AutomationJobResponse(BaseModel):
     updated_at: datetime
 
     @classmethod
-    def from_orm(cls, obj: OrmAutomationJob) -> Self:
+    def from_orm(cls, obj: object) -> Self:
         return cls(
-            id=obj.id,
-            owner_id=obj.owner_id,
-            bootstrap_key=obj.bootstrap_key,
-            title=obj.title,
-            timezone=obj.timezone,
-            status=obj.status,
-            is_system=obj.bootstrap_key is not None,
-            config=AutomationJobConfig.model_validate(obj.config or {}),
-            next_run_at=obj.next_run_at,
-            last_run_at=obj.last_run_at,
-            created_at=obj.created_at,
-            updated_at=obj.updated_at,
+            id=getattr(obj, "id"),
+            owner_id=getattr(obj, "owner_id"),
+            bootstrap_key=getattr(obj, "bootstrap_key"),
+            title=getattr(obj, "title"),
+            timezone=getattr(obj, "timezone"),
+            status=getattr(obj, "status"),
+            is_system=getattr(obj, "bootstrap_key") is not None,
+            config=AutomationJobConfig.model_validate(getattr(obj, "config", {}) or {}),
+            next_run_at=getattr(obj, "next_run_at"),
+            last_run_at=getattr(obj, "last_run_at"),
+            created_at=getattr(obj, "created_at"),
+            updated_at=getattr(obj, "updated_at"),
         )
 
 
diff --git a/backend/src/v1/automation_jobs/service.py b/backend/src/v1/automation_jobs/service.py
index a8acdc1..0500b34 100644
--- a/backend/src/v1/automation_jobs/service.py
+++ b/backend/src/v1/automation_jobs/service.py
@@ -7,8 +7,8 @@ from uuid import UUID
 from zoneinfo import ZoneInfo, ZoneInfoNotFoundError
 
 from fastapi import HTTPException, status
-from models.automation_jobs import ScheduleType
-from schemas.automation import (
+from schemas.enums import ScheduleType
+from schemas.domain.automation import (
     AutomationJob as AutomationJobSchema,
     MessageContextConfig,
     RuntimeConfig,
diff --git a/backend/src/v1/friendships/repository.py b/backend/src/v1/friendships/repository.py
index 68ad13b..998414a 100644
--- a/backend/src/v1/friendships/repository.py
+++ b/backend/src/v1/friendships/repository.py
@@ -9,9 +9,10 @@ from sqlalchemy.exc import SQLAlchemyError
 
 from core.db.base_repository import BaseRepository
 from core.logging import get_logger
-from models.friendships import Friendship, FriendshipStatus
-from models.inbox_messages import InboxMessage, InboxMessageStatus, InboxMessageType
-from schemas.inbox.messages import FriendshipContent
+from models.friendships import Friendship
+from models.inbox_messages import InboxMessage
+from schemas.enums import FriendshipStatus, InboxMessageStatus, InboxMessageType
+from schemas.domain.inbox import FriendshipContent
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
diff --git a/backend/src/v1/friendships/schemas.py b/backend/src/v1/friendships/schemas.py
index 2b73293..d847442 100644
--- a/backend/src/v1/friendships/schemas.py
+++ b/backend/src/v1/friendships/schemas.py
@@ -6,7 +6,7 @@ from uuid import UUID
 
 from pydantic import BaseModel, ConfigDict, Field
 
-from schemas.user.context import UserContext
+from schemas.shared.user import UserContext
 
 
 class FriendRequestCreate(BaseModel):
diff --git a/backend/src/v1/friendships/service.py b/backend/src/v1/friendships/service.py
index 63d334e..e038e70 100644
--- a/backend/src/v1/friendships/service.py
+++ b/backend/src/v1/friendships/service.py
@@ -10,8 +10,9 @@ from sqlalchemy.exc import SQLAlchemyError
 from core.auth.models import CurrentUser
 from core.db.base_service import BaseService
 from core.logging import get_logger
-from models.friendships import Friendship, FriendshipStatus
-from models.inbox_messages import InboxMessage, InboxMessageStatus, InboxMessageType
+from models.friendships import Friendship
+from models.inbox_messages import InboxMessage
+from schemas.enums import FriendshipStatus, InboxMessageStatus, InboxMessageType
 from v1.friendships.repository import FriendshipRepository
 from v1.friendships.schemas import (
     FriendRequestCreate,
@@ -22,7 +23,7 @@ from v1.users.repository import UserRepository
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
-    from schemas.user.context import UserContext
+    from schemas.shared.user import UserContext
 
 
 logger = get_logger("v1.friendships.service")
@@ -593,7 +594,7 @@ class FriendshipService(BaseService):
         )
 
     def _build_user_basic_info(self, profile: Any) -> "UserContext":
-        from schemas.user.context import UserContext
+        from schemas.shared.user import UserContext
 
         if profile is None:
             return UserContext(id="", username="")
diff --git a/backend/src/v1/inbox_messages/repository.py b/backend/src/v1/inbox_messages/repository.py
index 3caf85d..c2aa212 100644
--- a/backend/src/v1/inbox_messages/repository.py
+++ b/backend/src/v1/inbox_messages/repository.py
@@ -7,7 +7,8 @@ from sqlalchemy import select, update
 from sqlalchemy.exc import SQLAlchemyError
 
 from core.logging import get_logger
-from models.inbox_messages import InboxMessage, InboxMessageType, InboxMessageStatus
+from models.inbox_messages import InboxMessage
+from schemas.enums import InboxMessageStatus, InboxMessageType
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
diff --git a/backend/src/v1/inbox_messages/schemas.py b/backend/src/v1/inbox_messages/schemas.py
index b4be2e4..6d28609 100644
--- a/backend/src/v1/inbox_messages/schemas.py
+++ b/backend/src/v1/inbox_messages/schemas.py
@@ -6,7 +6,7 @@ from uuid import UUID
 
 from pydantic import BaseModel, ConfigDict
 
-from schemas.inbox.messages import InboxMessageStatus, InboxMessageType
+from schemas.domain.inbox import InboxMessageStatus, InboxMessageType
 
 
 class InboxMessageResponse(BaseModel):
diff --git a/backend/src/v1/memories/repository.py b/backend/src/v1/memories/repository.py
index c07362f..b072c3b 100644
--- a/backend/src/v1/memories/repository.py
+++ b/backend/src/v1/memories/repository.py
@@ -9,7 +9,8 @@ from sqlalchemy.exc import SQLAlchemyError
 
 from core.db.base_repository import BaseRepository
 from core.logging import get_logger
-from models.memories import Memory, MemoryStatus, MemoryType
+from models.memories import Memory
+from schemas.enums import MemoryStatus, MemoryType
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
diff --git a/backend/src/v1/memories/router.py b/backend/src/v1/memories/router.py
index b8fd8d2..74dcf76 100644
--- a/backend/src/v1/memories/router.py
+++ b/backend/src/v1/memories/router.py
@@ -4,7 +4,7 @@ from typing import Annotated
 
 from fastapi import APIRouter, Depends, status
 
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
 from v1.memories.dependencies import get_memories_service
 from v1.memories.schemas import (
     MemoryListResponse,
diff --git a/backend/src/v1/memories/schemas.py b/backend/src/v1/memories/schemas.py
index b621bda..b4f4ca7 100644
--- a/backend/src/v1/memories/schemas.py
+++ b/backend/src/v1/memories/schemas.py
@@ -4,7 +4,7 @@ from typing import ClassVar
 
 from pydantic import BaseModel, ConfigDict
 
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
 
 
 class UserMemoryUpdate(BaseModel):
diff --git a/backend/src/v1/memories/service.py b/backend/src/v1/memories/service.py
index cb8e32c..c597f4e 100644
--- a/backend/src/v1/memories/service.py
+++ b/backend/src/v1/memories/service.py
@@ -8,8 +8,9 @@ from sqlalchemy.exc import SQLAlchemyError
 from core.auth.models import CurrentUser
 from core.db.base_service import BaseService
 from core.logging import get_logger
-from models.memories import Memory, MemoryType
-from schemas.memories.memory_content import UserMemoryContent, WorkProfileContent
+from models.memories import Memory
+from schemas.enums import MemoryType
+from schemas.domain.memory_content import UserMemoryContent, WorkProfileContent
 from v1.memories.repository import MemoriesRepositoryLike
 
 if TYPE_CHECKING:
diff --git a/backend/src/v1/schedule_items/repository.py b/backend/src/v1/schedule_items/repository.py
index 3e3bc4b..6b60680 100644
--- a/backend/src/v1/schedule_items/repository.py
+++ b/backend/src/v1/schedule_items/repository.py
@@ -9,8 +9,9 @@ from sqlalchemy.exc import SQLAlchemyError
 
 from core.db.base_repository import BaseRepository
 from core.logging import get_logger
-from models.schedule_items import ScheduleItem, ScheduleItemStatus
-from models.schedule_subscriptions import ScheduleSubscription, SubscriptionStatus
+from models.schedule_items import ScheduleItem
+from models.schedule_subscriptions import ScheduleSubscription
+from schemas.enums import ScheduleItemStatus, SubscriptionStatus
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
diff --git a/backend/src/v1/schedule_items/schemas.py b/backend/src/v1/schedule_items/schemas.py
index 769bf44..044c4fb 100644
--- a/backend/src/v1/schedule_items/schemas.py
+++ b/backend/src/v1/schedule_items/schemas.py
@@ -7,14 +7,14 @@ from zoneinfo import ZoneInfo, ZoneInfoNotFoundError
 
 from pydantic import BaseModel, ConfigDict, Field, field_validator
 
-from schemas.inbox.messages import (
+from schemas.domain.inbox import (
     CalendarContent,
     CalendarDeleteContent,
     CalendarInviteContent,
     CalendarUpdateContent,
     parse_calendar_content,
 )
-from schemas.schedule.items import (
+from schemas.domain.schedule import (
     AttachmentType,
     ScheduleItemMetadata,
     ScheduleItemMetadataAttachment,
diff --git a/backend/src/v1/schedule_items/service.py b/backend/src/v1/schedule_items/service.py
index 8336659..8e43c14 100644
--- a/backend/src/v1/schedule_items/service.py
+++ b/backend/src/v1/schedule_items/service.py
@@ -10,9 +10,14 @@ from sqlalchemy.exc import SQLAlchemyError
 from core.auth.models import CurrentUser
 from core.db.base_service import BaseService
 from core.logging import get_logger
-from models.inbox_messages import InboxMessage, InboxMessageType, InboxMessageStatus
+from models.inbox_messages import InboxMessage
 from models.schedule_items import ScheduleItem
-from models.schedule_subscriptions import SubscriptionPermission, SubscriptionStatus
+from schemas.enums import (
+    InboxMessageStatus,
+    InboxMessageType,
+    SubscriptionPermission,
+    SubscriptionStatus,
+)
 from v1.auth.gateway import SupabaseAuthGateway
 from v1.inbox_messages.repository import InboxMessageRepository
 from v1.schedule_items.repository import ScheduleItemRepository
@@ -35,6 +40,8 @@ if TYPE_CHECKING:
 
 logger = get_logger("v1.schedule_items.service")
 
+_LEGACY_ARCHIVED_STATUSES = {"completed", "canceled"}
+
 
 class AuthByPhoneGateway(Protocol):
     async def get_user_by_phone(self, phone: str) -> "UserByPhoneResponse": ...
@@ -417,8 +424,10 @@ class ScheduleItemService(BaseService):
         permission: int = 1,
     ) -> ScheduleItemResponse:
         status_value = (
-            item.status.value if hasattr(item.status, "value") else item.status
+            item.status.value if hasattr(item.status, "value") else str(item.status)
         )
+        if status_value in _LEGACY_ARCHIVED_STATUSES:
+            status_value = ScheduleItemStatus.ARCHIVED.value
         source_type_value = (
             item.source_type.value
             if hasattr(item.source_type, "value")
diff --git a/backend/src/v1/todo/repository.py b/backend/src/v1/todo/repository.py
index 1919f7b..01a764c 100644
--- a/backend/src/v1/todo/repository.py
+++ b/backend/src/v1/todo/repository.py
@@ -10,7 +10,8 @@ from sqlalchemy.exc import SQLAlchemyError
 from core.db.base_repository import BaseRepository
 from core.logging import get_logger
 from models.todo_sources import TodoSource
-from models.todos import Todo, TodoPriority, TodoStatus
+from models.todos import Todo
+from schemas.enums import TodoPriority, TodoStatus
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
diff --git a/backend/src/v1/todo/schemas.py b/backend/src/v1/todo/schemas.py
index b8d0c98..64ecc15 100644
--- a/backend/src/v1/todo/schemas.py
+++ b/backend/src/v1/todo/schemas.py
@@ -5,7 +5,7 @@ from uuid import UUID
 
 from pydantic import BaseModel, ConfigDict, Field
 
-from schemas.todo import TodoOrder
+from schemas.domain.todo import TodoOrder
 
 
 class TodoCreate(BaseModel):
diff --git a/backend/src/v1/todo/service.py b/backend/src/v1/todo/service.py
index c0e5bb2..4b6ed5d 100644
--- a/backend/src/v1/todo/service.py
+++ b/backend/src/v1/todo/service.py
@@ -10,7 +10,8 @@ from sqlalchemy.exc import SQLAlchemyError
 from core.auth.models import CurrentUser
 from core.db.base_service import BaseService
 from core.logging import get_logger
-from models.todos import Todo, TodoStatus
+from models.todos import Todo
+from schemas.enums import TodoStatus
 from v1.schedule_items.repository import SQLAlchemyScheduleItemRepository
 from v1.todo.repository import TodoRepository
 from v1.todo.schemas import (
diff --git a/backend/src/v1/users/router.py b/backend/src/v1/users/router.py
index 3b4cb62..53941f2 100644
--- a/backend/src/v1/users/router.py
+++ b/backend/src/v1/users/router.py
@@ -5,7 +5,7 @@ from uuid import UUID
 
 from fastapi import APIRouter, Depends
 
-from schemas.user.context import UserContext
+from schemas.shared.user import UserContext
 from v1.users.dependencies import get_user_service
 from v1.users.schemas import UserSearchRequest, UserUpdateRequest
 from v1.users.service import UserService
diff --git a/backend/src/v1/users/service.py b/backend/src/v1/users/service.py
index 70d5840..11acee1 100644
--- a/backend/src/v1/users/service.py
+++ b/backend/src/v1/users/service.py
@@ -13,14 +13,14 @@ from core.agentscope.persistence.user_context_cache import (
 )
 from core.db.base_service import BaseService
 from core.logging import get_logger
-from schemas.user.context import UserContext, parse_profile_settings
+from schemas.shared.user import UserContext, parse_profile_settings
 from v1.users.repository import UserRepository
 from v1.users.schemas import UserSearchRequest, UserUpdateRequest
 
 if TYPE_CHECKING:
     from sqlalchemy.ext.asyncio import AsyncSession
 
-    from schemas.user.context import UserContext
+    from schemas.shared.user import UserContext
 
 logger = get_logger("v1.users.service")
 
@@ -105,7 +105,7 @@ class UserService(BaseService):
         )
 
     async def get_user_by_id(self, user_id: UUID) -> "UserContext":
-        from schemas.user.context import UserContext
+        from schemas.shared.user import UserContext
 
         try:
             profile = await self._repository.get_by_user_id(user_id)
diff --git a/backend/tests/e2e/test_profile_flow.py b/backend/tests/e2e/test_profile_flow.py
index 0dec6fe..92d1f98 100644
--- a/backend/tests/e2e/test_profile_flow.py
+++ b/backend/tests/e2e/test_profile_flow.py
@@ -11,7 +11,7 @@ import uvicorn
 
 from app import app
 from core.auth.models import CurrentUser
-from schemas.user.context import UserContext
+from schemas.shared.user import UserContext
 from v1.users.dependencies import get_current_user, get_user_service
 from v1.users.schemas import UserUpdateRequest
 
diff --git a/backend/tests/integration/test_friendship_routes.py b/backend/tests/integration/test_friendship_routes.py
index 8da9241..5d7857c 100644
--- a/backend/tests/integration/test_friendship_routes.py
+++ b/backend/tests/integration/test_friendship_routes.py
@@ -9,7 +9,7 @@ from fastapi.testclient import TestClient
 
 from app import app
 from core.auth.models import CurrentUser
-from schemas.user.context import UserContext
+from schemas.shared.user import UserContext
 from v1.friendships.dependencies import get_friendship_service
 from v1.friendships.schemas import (
     FriendRequestCreate,
diff --git a/backend/tests/integration/test_users_routes.py b/backend/tests/integration/test_users_routes.py
index 20aa42b..d067beb 100644
--- a/backend/tests/integration/test_users_routes.py
+++ b/backend/tests/integration/test_users_routes.py
@@ -8,7 +8,7 @@ from fastapi.testclient import TestClient
 
 from app import app
 from core.auth.models import CurrentUser
-from schemas.user.context import UserContext
+from schemas.shared.user import UserContext
 from v1.users.dependencies import get_current_user, get_user_service
 from v1.users.schemas import UserSearchRequest, UserUpdateRequest
 from v1.users.service import UserService
diff --git a/backend/tests/unit/core/agentscope/persistence/test_user_context_cache.py b/backend/tests/unit/core/agentscope/persistence/test_user_context_cache.py
index 446ef0f..4ec64de 100644
--- a/backend/tests/unit/core/agentscope/persistence/test_user_context_cache.py
+++ b/backend/tests/unit/core/agentscope/persistence/test_user_context_cache.py
@@ -6,7 +6,7 @@ from uuid import uuid4
 import pytest
 
 from core.agentscope.persistence.user_context_cache import UserContextCache
-from schemas.user.context import (
+from schemas.shared.user import (
     UserContext,
     parse_profile_settings,
 )
diff --git a/backend/tests/unit/core/agentscope/runtime/test_consumer_registry.py b/backend/tests/unit/core/agentscope/runtime/test_consumer_registry.py
deleted file mode 100644
index 17905fd..0000000
--- a/backend/tests/unit/core/agentscope/runtime/test_consumer_registry.py
+++ /dev/null
@@ -1,28 +0,0 @@
-from __future__ import annotations
-
-import pytest
-
-from core.agentscope.runtime.registry_builder import build_consumer_registry
-
-
-def test_build_consumer_registry_from_system_agent_configs() -> None:
-    registry = build_consumer_registry(
-        system_agent_configs={
-            "router": {"config": {"visibility_consumer_bit": 16}},
-            "worker": {"config": {"visibility_consumer_bit": 17}},
-            "memory": {"config": {"visibility_consumer_bit": 18}},
-        }
-    )
-
-    assert registry.resolve_agent_bit(agent_type="router") == 16
-    assert registry.resolve_agent_bit(agent_type="worker") == 17
-
-
-def test_build_consumer_registry_rejects_duplicate_bit() -> None:
-    with pytest.raises(ValueError, match="duplicate visibility bit"):
-        build_consumer_registry(
-            system_agent_configs={
-                "router": {"config": {"visibility_consumer_bit": 16}},
-                "worker": {"config": {"visibility_consumer_bit": 16}},
-            }
-        )
diff --git a/backend/tests/unit/core/agentscope/runtime/test_orchestrator.py b/backend/tests/unit/core/agentscope/runtime/test_orchestrator.py
index 1f1d48d..b2eb6e7 100644
--- a/backend/tests/unit/core/agentscope/runtime/test_orchestrator.py
+++ b/backend/tests/unit/core/agentscope/runtime/test_orchestrator.py
@@ -6,8 +6,8 @@ import pytest
 from ag_ui.core import RunAgentInput
 
 from core.agentscope.runtime.orchestrator import AgentScopeRuntimeOrchestrator
-from schemas.automation import MessageContextConfig, RuntimeConfig
-from schemas.user import UserContext, parse_profile_settings
+from schemas.domain.automation import MessageContextConfig, RuntimeConfig
+from schemas.shared.user import UserContext, parse_profile_settings
 
 
 class _FakePipeline:
diff --git a/backend/tests/unit/core/agentscope/runtime/test_pipeline_registry.py b/backend/tests/unit/core/agentscope/runtime/test_pipeline_registry.py
deleted file mode 100644
index 6967799..0000000
--- a/backend/tests/unit/core/agentscope/runtime/test_pipeline_registry.py
+++ /dev/null
@@ -1,24 +0,0 @@
-from __future__ import annotations
-
-import pytest
-
-from core.agentscope.runtime.pipeline_registry import build_default_pipeline_spec
-
-
-def test_build_default_pipeline_spec_worker_has_two_stages() -> None:
-    spec = build_default_pipeline_spec(mode="worker")
-
-    assert spec.mode == "worker"
-    assert [item.stage_name for item in spec.stages] == ["router", "worker"]
-
-
-def test_build_default_pipeline_spec_memory_has_single_stage() -> None:
-    spec = build_default_pipeline_spec(mode="memory")
-
-    assert spec.mode == "memory"
-    assert [item.stage_name for item in spec.stages] == ["memory"]
-
-
-def test_build_default_pipeline_spec_rejects_unknown_mode() -> None:
-    with pytest.raises(ValueError, match="unsupported pipeline mode"):
-        build_default_pipeline_spec(mode="planner")
diff --git a/backend/tests/unit/core/agentscope/runtime/test_runner.py b/backend/tests/unit/core/agentscope/runtime/test_runner.py
index 3144850..e985c9d 100644
--- a/backend/tests/unit/core/agentscope/runtime/test_runner.py
+++ b/backend/tests/unit/core/agentscope/runtime/test_runner.py
@@ -18,8 +18,8 @@ from schemas.agent.runtime_models import (
     WorkerAgentOutputLite,
 )
 from schemas.agent.system_agent import AgentType
-from schemas.automation import MessageContextConfig, RuntimeConfig
-from schemas.user import UserContext, parse_profile_settings
+from schemas.domain.automation import MessageContextConfig, RuntimeConfig
+from schemas.shared.user import UserContext, parse_profile_settings
 
 
 def _run_input() -> RunAgentInput:
diff --git a/backend/tests/unit/core/agentscope/runtime/test_tasks.py b/backend/tests/unit/core/agentscope/runtime/test_tasks.py
index 446fe0f..0f73baa 100644
--- a/backend/tests/unit/core/agentscope/runtime/test_tasks.py
+++ b/backend/tests/unit/core/agentscope/runtime/test_tasks.py
@@ -7,8 +7,8 @@ import pytest
 
 import core.agentscope.runtime.tasks as tasks_module
 from schemas.agent import ToolStatus
-from schemas.automation import ContextWindowMode, MessageContextConfig
-from schemas.user import UserContext, parse_profile_settings
+from schemas.domain.automation import ContextWindowMode, MessageContextConfig
+from schemas.shared.user import UserContext, parse_profile_settings
 
 
 def _run_input_payload() -> dict[str, Any]:
diff --git a/backend/tests/unit/core/agentscope/schemas/test_agui_input.py b/backend/tests/unit/core/agentscope/schemas/test_agui_input.py
deleted file mode 100644
index b6f7113..0000000
--- a/backend/tests/unit/core/agentscope/schemas/test_agui_input.py
+++ /dev/null
@@ -1,250 +0,0 @@
-from __future__ import annotations
-
-import pytest
-
-from core.agentscope.schemas.agui_input import (
-    MAX_MESSAGES,
-    MAX_RUN_ID_LENGTH,
-    MAX_RUN_INPUT_BYTES,
-    MAX_TEXT_CHARS,
-    parse_run_input,
-    validate_run_request_messages_contract,
-)
-
-
-def _base_payload() -> dict[str, object]:
-    return {
-        "threadId": "00000000-0000-0000-0000-000000000001",
-        "runId": "run-1",
-        "state": {},
-        "messages": [{"id": "u1", "role": "user", "content": "hello"}],
-        "tools": [],
-        "context": [],
-        "forwardedProps": {"agent_type": "worker"},
-    }
-
-
-def test_parse_run_input_rejects_invalid_uuid() -> None:
-    payload = _base_payload()
-    payload["threadId"] = "bad-uuid"
-
-    with pytest.raises(ValueError, match="threadId must be a valid UUID"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_message_count_over_limit() -> None:
-    payload = _base_payload()
-    payload["messages"] = [
-        {"id": f"u{i}", "role": "user", "content": "x"} for i in range(MAX_MESSAGES + 1)
-    ]
-
-    with pytest.raises(ValueError, match="RunAgentInput.messages exceeds limit"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_user_text_over_limit() -> None:
-    payload = _base_payload()
-    payload["messages"] = [
-        {"id": "u1", "role": "user", "content": "x" * (MAX_TEXT_CHARS + 1)}
-    ]
-
-    with pytest.raises(
-        ValueError, match="RunAgentInput user message text exceeds limit"
-    ):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_payload_over_limit() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {"blob": "x" * MAX_RUN_INPUT_BYTES}
-
-    with pytest.raises(ValueError, match="RunAgentInput payload exceeds size limit"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_run_id_over_limit() -> None:
-    payload = _base_payload()
-    payload["runId"] = "r" * (MAX_RUN_ID_LENGTH + 1)
-
-    with pytest.raises(ValueError, match="runId exceeds length limit"):
-        parse_run_input(payload)
-
-
-def test_validate_run_request_messages_contract_requires_single_user_message() -> None:
-    payload = _base_payload()
-    payload["messages"] = [
-        {"id": "u1", "role": "user", "content": "hello"},
-        {"id": "u2", "role": "user", "content": "again"},
-    ]
-    run_input = parse_run_input(payload)
-
-    with pytest.raises(
-        ValueError,
-        match="RunAgentInput.messages must contain exactly one user message",
-    ):
-        validate_run_request_messages_contract(run_input)
-
-
-def test_validate_run_request_messages_contract_accepts_binary_url_blocks() -> None:
-    payload = _base_payload()
-    payload["messages"] = [
-        {
-            "id": "u1",
-            "role": "user",
-            "content": [
-                {"type": "text", "text": "请分析"},
-                {
-                    "type": "binary",
-                    "mimeType": "image/png",
-                    "url": "https://signed.example/a.png",
-                },
-            ],
-        }
-    ]
-    run_input = parse_run_input(payload)
-
-    validate_run_request_messages_contract(run_input)
-
-
-def test_validate_run_request_messages_contract_rejects_binary_data_block() -> None:
-    payload = _base_payload()
-    payload["messages"] = [
-        {
-            "id": "u1",
-            "role": "user",
-            "content": [
-                {"type": "text", "text": "请分析"},
-                {
-                    "type": "binary",
-                    "mimeType": "image/png",
-                    "data": "aGVsbG8=",
-                },
-            ],
-        }
-    ]
-    run_input = parse_run_input(payload)
-
-    with pytest.raises(ValueError, match="binary content requires url"):
-        validate_run_request_messages_contract(run_input)
-
-
-def test_parse_run_input_accepts_snake_case_aliases() -> None:
-    payload = {
-        "thread_id": "00000000-0000-0000-0000-000000000001",
-        "run_id": "run-1",
-        "state": {},
-        "messages": [
-            {
-                "id": "u1",
-                "role": "user",
-                "content": [
-                    {"type": "text", "text": "hello"},
-                    {
-                        "type": "binary",
-                        "mime_type": "image/png",
-                        "url": "https://signed.example/a.png",
-                    },
-                ],
-            }
-        ],
-        "tools": [],
-        "context": [],
-        "forwarded_props": {"agent_type": "worker"},
-    }
-
-    run_input = parse_run_input(payload)
-
-    assert run_input.thread_id == "00000000-0000-0000-0000-000000000001"
-    assert run_input.run_id == "run-1"
-    validate_run_request_messages_contract(run_input)
-
-
-def test_parse_run_input_accepts_client_time_forwarded_props() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {
-        "agent_type": "worker",
-        "client_time": {
-            "device_timezone": "America/Los_Angeles",
-            "client_now_iso": "2026-03-16T09:12:33-07:00",
-            "client_epoch_ms": 1773658353000,
-        },
-    }
-
-    run_input = parse_run_input(payload)
-
-    assert run_input.forwarded_props is not None
-
-
-def test_parse_run_input_rejects_invalid_client_time_timezone() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {
-        "agent_type": "worker",
-        "client_time": {
-            "device_timezone": "Mars/OlympusMons",
-            "client_now_iso": "2026-03-16T09:12:33-07:00",
-            "client_epoch_ms": 1773658353000,
-        },
-    }
-
-    with pytest.raises(ValueError, match="invalid RunAgentInput.forwardedProps"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_invalid_client_time_now_iso() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {
-        "agent_type": "worker",
-        "client_time": {
-            "device_timezone": "America/Los_Angeles",
-            "client_now_iso": "2026-03-16 09:12:33",
-            "client_epoch_ms": 1773658353000,
-        },
-    }
-
-    with pytest.raises(ValueError, match="invalid RunAgentInput.forwardedProps"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_invalid_client_time_epoch_type() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {
-        "agent_type": "worker",
-        "client_time": {
-            "device_timezone": "America/Los_Angeles",
-            "client_now_iso": "2026-03-16T09:12:33-07:00",
-            "client_epoch_ms": "1773658353000",
-        },
-    }
-
-    with pytest.raises(ValueError, match="invalid RunAgentInput.forwardedProps"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_unknown_forwarded_props_key() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {
-        "agent_type": "worker",
-        "client_time": {
-            "device_timezone": "America/Los_Angeles",
-            "client_now_iso": "2026-03-16T09:12:33-07:00",
-            "client_epoch_ms": 1773658353000,
-        },
-        "unexpected": {"foo": "bar"},
-    }
-
-    with pytest.raises(ValueError, match="invalid RunAgentInput.forwardedProps"):
-        parse_run_input(payload)
-
-
-def test_parse_run_input_rejects_missing_forwarded_props_agent_type() -> None:
-    payload = _base_payload()
-    payload["forwardedProps"] = {
-        "client_time": {
-            "device_timezone": "America/Los_Angeles",
-            "client_now_iso": "2026-03-16T09:12:33-07:00",
-            "client_epoch_ms": 1773658353000,
-        }
-    }
-
-    with pytest.raises(ValueError, match="invalid RunAgentInput.forwardedProps"):
-        parse_run_input(payload)
diff --git a/backend/tests/unit/core/agentscope/test_calendar_tools.py b/backend/tests/unit/core/agentscope/test_calendar_tools.py
index b0d87a1..64d9023 100644
--- a/backend/tests/unit/core/agentscope/test_calendar_tools.py
+++ b/backend/tests/unit/core/agentscope/test_calendar_tools.py
@@ -40,6 +40,7 @@ class _FakeService:
             start_at=datetime(2026, 3, 17, 9, 0, tzinfo=timezone.utc),
             end_at=datetime(2026, 3, 17, 9, 30, tzinfo=timezone.utc),
             timezone="Asia/Shanghai",
+            status="active",
             metadata=SimpleNamespace(
                 location=None, color="#4F46E5", reminder_minutes=15
             ),
@@ -247,7 +248,7 @@ async def test_calendar_read_returns_structured_result_with_ids(
     assert "total=1" in payload["result"]
     assert "timezone=Asia/Shanghai" in payload["result"]
     assert "description=今天下午五点的会议" in payload["result"]
-    assert "status=" in payload["result"]
+    assert "status=active" in payload["result"]
     assert fake_service.created_id in payload["result"]
     assert fake_service.list_calls == [{"page": 1, "page_size": 20, "query": "会议"}]
 
diff --git a/backend/tests/unit/core/agentscope/test_hitl_middleware.py b/backend/tests/unit/core/agentscope/test_hitl_middleware.py
deleted file mode 100644
index b2ffca6..0000000
--- a/backend/tests/unit/core/agentscope/test_hitl_middleware.py
+++ /dev/null
@@ -1,132 +0,0 @@
-from __future__ import annotations
-
-import json
-from typing import Any, AsyncGenerator
-
-import pytest
-
-from core.agentscope.tools.tool_config import ToolApprovalConfig, ToolConfig, ToolGroup
-from core.agentscope.tools.tool_middleware import create_approval_middleware
-
-
-async def _next_handler(**kwargs: Any) -> AsyncGenerator[dict[str, object], None]:
-    async def _generator() -> AsyncGenerator[dict[str, object], None]:
-        yield {"ok": True, "tool_call": kwargs.get("tool_call")}
-
-    return _generator()
-
-
-def _extract_error_payload(chunk: object) -> dict[str, Any]:
-    content = getattr(chunk, "content", None)
-    if not isinstance(content, list) or not content:
-        return {}
-    first_block = content[0]
-    text = getattr(first_block, "text", None)
-    if not isinstance(text, str) and isinstance(first_block, dict):
-        raw_text = first_block.get("text")
-        text = raw_text if isinstance(raw_text, str) else None
-    if not isinstance(text, str):
-        return {}
-    return json.loads(text)
-
-
-@pytest.mark.asyncio
-async def test_hitl_middleware_default_write_does_not_require_approval() -> None:
-    middleware = create_approval_middleware(
-        config_by_name={
-            "calendar_write": ToolConfig(
-                name="calendar_write",
-                group=ToolGroup.EXECUTE,
-                approval=ToolApprovalConfig(required=False),
-            )
-        }
-    )
-
-    responses = []
-    async for chunk in middleware(
-        {"tool_call": {"name": "calendar.write", "input": {"operation": "create"}}},
-        _next_handler,
-    ):
-        responses.append(chunk)
-
-    assert responses[0]["ok"] is True
-
-
-@pytest.mark.asyncio
-async def test_hitl_middleware_pending_when_tool_requires_approval() -> None:
-    middleware = create_approval_middleware(
-        config_by_name={
-            "calendar_write": ToolConfig(
-                name="calendar_write",
-                group=ToolGroup.EXECUTE,
-                approval=ToolApprovalConfig(required=True),
-            )
-        }
-    )
-
-    responses = []
-    async for chunk in middleware(
-        {"tool_call": {"name": "calendar_write", "input": {"operation": "create"}}},
-        _next_handler,
-    ):
-        responses.append(chunk)
-
-    payload = _extract_error_payload(responses[0])
-    assert payload["error"]["code"] == "TOOL_PENDING_APPROVAL"
-
-
-@pytest.mark.asyncio
-async def test_hitl_middleware_passes_when_write_approved() -> None:
-    middleware = create_approval_middleware(
-        config_by_name={
-            "calendar_write": ToolConfig(
-                name="calendar_write",
-                group=ToolGroup.EXECUTE,
-                approval=ToolApprovalConfig(required=True),
-            )
-        },
-        approval_resolver=lambda _name, _args, _config: "approved",
-    )
-
-    responses = []
-    async for chunk in middleware(
-        {
-            "tool_call": {
-                "name": "calendar.write",
-                "input": {
-                    "operation": "create",
-                    "_hitl": {"approval": "required"},
-                },
-            }
-        },
-        _next_handler,
-    ):
-        responses.append(chunk)
-
-    assert responses[0]["ok"] is True
-    sanitized_input = responses[0]["tool_call"]["input"]
-    assert "_hitl" not in sanitized_input
-
-
-@pytest.mark.asyncio
-async def test_hitl_middleware_rejected_short_circuits() -> None:
-    middleware = create_approval_middleware(
-        config_by_name={
-            "calendar_write": ToolConfig(
-                name="calendar_write",
-                group=ToolGroup.EXECUTE,
-                approval=ToolApprovalConfig(required=True),
-            )
-        },
-        approval_resolver=lambda _name, _args, _config: "rejected",
-    )
-
-    responses = []
-    async for chunk in middleware(
-        {"tool_call": {"name": "calendar_write", "input": {"operation": "create"}}},
-        _next_handler,
-    ):
-        responses.append(chunk)
-
-    payload = _extract_error_payload(responses[0])
-    assert payload["error"]["code"] == "TOOL_REJECTED"
diff --git a/backend/tests/unit/core/agentscope/test_memory_tools.py b/backend/tests/unit/core/agentscope/test_memory_tools.py
index ce8bbd7..4d39e50 100644
--- a/backend/tests/unit/core/agentscope/test_memory_tools.py
+++ b/backend/tests/unit/core/agentscope/test_memory_tools.py
@@ -9,7 +9,7 @@ from agentscope.tool import ToolResponse
 
 from core.agentscope.tools.custom import memory as memory_module
 from models.memories import MemoryType
-from schemas.memories.memory_content import UserMemoryContent
+from schemas.domain.memory_content import UserMemoryContent
 
 
 def _decode_tool_response(response: ToolResponse) -> dict[str, object]:
diff --git a/backend/tests/unit/core/agentscope/test_system_prompt.py b/backend/tests/unit/core/agentscope/test_system_prompt.py
index 6328c58..690a6a6 100644
--- a/backend/tests/unit/core/agentscope/test_system_prompt.py
+++ b/backend/tests/unit/core/agentscope/test_system_prompt.py
@@ -9,7 +9,7 @@ from core.agentscope.prompts.system_prompt import (
 )
 from schemas.agent.forwarded_props import ClientTimeContext
 from schemas.agent.system_agent import AgentType
-from schemas.user.context import UserContext, parse_profile_settings
+from schemas.shared.user import UserContext, parse_profile_settings
 
 
 def _build_user_context(*, timezone_name: str = "Asia/Shanghai") -> UserContext:
@@ -159,7 +159,7 @@ def test_build_system_prompt_keeps_sections_focused_without_language_duplication
 
 
 def test_build_system_prompt_includes_user_memory_section_for_router() -> None:
-    from schemas.memories.memory_content import UserMemoryContent
+    from schemas.domain.memory_content import UserMemoryContent
 
     user_memory = UserMemoryContent()
 
@@ -175,7 +175,7 @@ def test_build_system_prompt_includes_user_memory_section_for_router() -> None:
 
 
 def test_build_system_prompt_includes_work_memory_section_for_worker() -> None:
-    from schemas.memories.memory_content import WorkProfileContent
+    from schemas.domain.memory_content import WorkProfileContent
 
     work_memory = WorkProfileContent()
 
diff --git a/backend/tests/unit/core/automation/test_scheduler.py b/backend/tests/unit/core/automation/test_scheduler.py
index 1f83c04..365a7a7 100644
--- a/backend/tests/unit/core/automation/test_scheduler.py
+++ b/backend/tests/unit/core/automation/test_scheduler.py
@@ -6,7 +6,7 @@ from uuid import UUID, uuid4
 import pytest
 
 from models.automation_jobs import AutomationJob as OrmAutomationJob, ScheduleType
-from schemas.automation import (
+from schemas.domain.automation import (
     RuntimeConfig,
     ScheduleConfig,
     ScheduleRunAt,
diff --git a/backend/tests/unit/database/test_base_repository.py b/backend/tests/unit/database/test_base_repository.py
deleted file mode 100644
index 9989139..0000000
--- a/backend/tests/unit/database/test_base_repository.py
+++ /dev/null
@@ -1,87 +0,0 @@
-from __future__ import annotations
-
-from datetime import datetime, timezone
-from uuid import UUID, uuid4
-
-import pytest
-from sqlalchemy import Column, String, Table
-from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
-from sqlalchemy.orm import Mapped, mapped_column
-
-from core.db.base import Base, SoftDeleteMixin
-from core.db.base_repository import BaseRepository
-
-
-class Widget(SoftDeleteMixin, Base):
-    __tablename__ = "widgets"
-
-    id: Mapped[UUID] = mapped_column(primary_key=True)
-    name: Mapped[str] = mapped_column(String(50), nullable=False)
-
-
-@pytest.fixture
-async def db_engine():
-    auth_users = Table(
-        "users",
-        Base.metadata,
-        Column("id", String, primary_key=True),
-        schema="auth",
-        extend_existing=True,
-    )
-    engine = create_async_engine("sqlite+aiosqlite:///:memory:", echo=False)
-    async with engine.begin() as conn:
-        await conn.exec_driver_sql("ATTACH DATABASE ':memory:' AS auth")
-        await conn.run_sync(Base.metadata.create_all)
-    yield engine
-    Base.metadata.remove(auth_users)
-    await engine.dispose()
-
-
-@pytest.fixture
-async def db_session(db_engine):
-    async_session = async_sessionmaker(
-        bind=db_engine,
-        class_=AsyncSession,
-        expire_on_commit=False,
-    )
-    async with async_session() as session:
-        yield session
-        await session.rollback()
-
-
-@pytest.mark.asyncio
-async def test_get_by_id_filters_soft_deleted(db_session: AsyncSession) -> None:
-    repository = BaseRepository(db_session, Widget)
-    widget_id = uuid4()
-
-    widget = Widget(id=widget_id, name="widget")
-    db_session.add(widget)
-    await db_session.commit()
-
-    found = await repository.get_by_id(widget_id)
-    assert found is not None
-
-    deleted = await repository.soft_delete_by_id(widget_id)
-    assert deleted is not None
-    assert deleted.deleted_at is not None
-
-    missing = await repository.get_by_id(widget_id)
-    assert missing is None
-
-
-@pytest.mark.asyncio
-async def test_soft_delete_sets_timestamp(db_session: AsyncSession) -> None:
-    repository = BaseRepository(db_session, Widget)
-    widget_id = uuid4()
-
-    widget = Widget(id=widget_id, name="widget")
-    db_session.add(widget)
-    await db_session.commit()
-
-    deleted = await repository.soft_delete_by_id(widget_id)
-    assert deleted is not None
-    assert isinstance(deleted.deleted_at, datetime)
-    deleted_at = deleted.deleted_at
-    if deleted_at.tzinfo is None:
-        deleted_at = deleted_at.replace(tzinfo=timezone.utc)
-    assert deleted_at <= datetime.now(timezone.utc)
diff --git a/backend/tests/unit/database/test_profile_models.py b/backend/tests/unit/database/test_profile_models.py
deleted file mode 100644
index 1e9c0b5..0000000
--- a/backend/tests/unit/database/test_profile_models.py
+++ /dev/null
@@ -1,134 +0,0 @@
-from __future__ import annotations
-
-from uuid import uuid4
-
-import pytest
-from sqlalchemy import Column, String, Table, select
-from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine
-
-from core.db.base import Base
-from models.profile import Profile
-
-
-@pytest.fixture
-async def db_engine():
-    """Create in-memory SQLite engine for testing."""
-    users_table = Table(
-        "users",
-        Base.metadata,
-        Column("id", String, primary_key=True),
-        schema="auth",
-        extend_existing=True,
-    )
-    engine = create_async_engine(
-        "sqlite+aiosqlite:///:memory:",
-        echo=False,
-    )
-    async with engine.begin() as conn:
-        await conn.exec_driver_sql("ATTACH DATABASE ':memory:' AS auth")
-        await conn.run_sync(Base.metadata.create_all)
-    yield engine
-    Base.metadata.remove(users_table)
-    await engine.dispose()
-
-
-@pytest.fixture
-async def db_session(db_engine):
-    """Create a database session for testing."""
-    async_session = async_sessionmaker(
-        bind=db_engine,
-        class_=AsyncSession,
-        expire_on_commit=False,
-    )
-    async with async_session() as session:
-        yield session
-        await session.rollback()
-
-
-@pytest.mark.asyncio
-async def test_profile_model_create(db_session: AsyncSession) -> None:
-    """Test creating a Profile model."""
-    profile_id = uuid4()
-    profile = Profile(
-        id=profile_id,
-        username="testuser",
-    )
-    db_session.add(profile)
-    await db_session.commit()
-    await db_session.refresh(profile)
-
-    assert profile.id == profile_id
-    assert profile.username == "testuser"
-    assert profile.created_at is not None
-    assert profile.updated_at is not None
-    assert profile.deleted_at is None
-
-
-@pytest.mark.asyncio
-async def test_profile_model_get_by_id(db_session: AsyncSession) -> None:
-    """Test retrieving a Profile by ID."""
-    profile_id = uuid4()
-    profile = Profile(
-        id=profile_id,
-        username="testuser",
-    )
-    db_session.add(profile)
-    await db_session.commit()
-
-    result = await db_session.get(Profile, profile_id)
-    assert result is not None
-    assert result.username == "testuser"
-
-
-@pytest.mark.asyncio
-async def test_profile_model_get_by_username(db_session: AsyncSession) -> None:
-    """Test retrieving a Profile by username."""
-    profile = Profile(
-        id=uuid4(),
-        username="testuser",
-    )
-    db_session.add(profile)
-    await db_session.commit()
-
-    result = await db_session.execute(
-        select(Profile).where(Profile.username == "testuser")
-    )
-    found = result.scalar_one()
-    assert found is not None
-    assert found.username == "testuser"
-
-
-@pytest.mark.asyncio
-async def test_profile_model_update(db_session: AsyncSession) -> None:
-    """Test updating a Profile."""
-    profile = Profile(
-        id=uuid4(),
-        username="testuser",
-        bio="Old bio",
-    )
-    db_session.add(profile)
-    await db_session.commit()
-
-    profile.bio = "New bio"
-    await db_session.commit()
-    await db_session.refresh(profile)
-
-    assert profile.bio == "New bio"
-
-
-@pytest.mark.asyncio
-async def test_profile_model_allows_duplicate_usernames(
-    db_session: AsyncSession,
-) -> None:
-    first = Profile(id=uuid4(), username="same_name")
-    second = Profile(id=uuid4(), username="same_name")
-
-    db_session.add(first)
-    db_session.add(second)
-    await db_session.commit()
-
-    result = await db_session.execute(
-        select(Profile).where(Profile.username == "same_name")
-    )
-    found = result.scalars().all()
-    assert len(found) == 2
diff --git a/backend/tests/unit/infra/test_worker_runtime_script.py b/backend/tests/unit/infra/test_worker_runtime_script.py
deleted file mode 100644
index 1c9ac8c..0000000
--- a/backend/tests/unit/infra/test_worker_runtime_script.py
+++ /dev/null
@@ -1,32 +0,0 @@
-from __future__ import annotations
-
-from pathlib import Path
-
-
-ROOT_DIR = Path(__file__).resolve().parents[4]
-APP_SCRIPT = ROOT_DIR / "infra" / "scripts" / "app.sh"
-
-
-def test_worker_commands_use_taskiq() -> None:
-    content = APP_SCRIPT.read_text(encoding="utf-8")
-    removed_runner = "uv run celery"
-
-    assert "uv run taskiq worker" in content
-    assert "core.taskiq.app:critical_broker" in content
-    assert "core.taskiq.app:default_broker" in content
-    assert "core.taskiq.app:bulk_broker" in content
-    assert 'pgrep -f "uv run taskiq worker core.taskiq.app:"' in content
-    assert 'kill_pids_gracefully "taskiq workers"' in content
-    assert "gunicorn" not in content
-    assert removed_runner not in content
-
-
-def test_web_command_uses_uvicorn_only() -> None:
-    content = APP_SCRIPT.read_text(encoding="utf-8")
-
-    assert "uv run uvicorn app:app" in content
-    assert 'WEB_PORT="${SOCIAL_WEB__PORT:-5775}"' in content
-    assert "SOCIAL_WEB__WORKERS" in content
-    assert 'UVICORN_LOG_LEVEL="${UVICORN_LOG_LEVEL,,}"' in content
-    assert "SOCIAL_WEB__GUNICORN__" not in content
-    assert "uv run gunicorn" not in content
diff --git a/backend/tests/unit/schemas/agent/test_pipeline_spec.py b/backend/tests/unit/schemas/agent/test_pipeline_spec.py
deleted file mode 100644
index a682149..0000000
--- a/backend/tests/unit/schemas/agent/test_pipeline_spec.py
+++ /dev/null
@@ -1,36 +0,0 @@
-from __future__ import annotations
-
-import pytest
-
-from core.agentscope.schemas.consumer_registry import (
-    AgentConsumerBinding,
-    ConsumerRegistry,
-)
-from core.agentscope.schemas.pipeline_spec import ExecutorKind, PipelineSpec, StageSpec
-from schemas.agent.system_agent import AgentType
-
-
-def test_consumer_registry_rejects_duplicate_bits() -> None:
-    with pytest.raises(ValueError, match="duplicate visibility bit"):
-        ConsumerRegistry(
-            bindings=[
-                AgentConsumerBinding(agent_type="router", bit=16),
-                AgentConsumerBinding(agent_type="worker", bit=16),
-            ]
-        )
-
-
-def test_pipeline_spec_requires_non_empty_stages() -> None:
-    with pytest.raises(ValueError, match="at least 1 item"):
-        PipelineSpec(mode="worker", stages=[])
-
-
-def test_stage_spec_normalizes_stage_name() -> None:
-    spec = StageSpec(
-        stage_name=" Worker ",
-        agent_type=AgentType.WORKER,
-        executor_kind=ExecutorKind.REACT,
-    )
-
-    assert spec.stage_name == "worker"
-    assert spec.agent_type == AgentType.WORKER
diff --git a/backend/tests/unit/schemas/automation/test_config.py b/backend/tests/unit/schemas/automation/test_config.py
index 3f5558a..bc8b85f 100644
--- a/backend/tests/unit/schemas/automation/test_config.py
+++ b/backend/tests/unit/schemas/automation/test_config.py
@@ -2,23 +2,25 @@ from __future__ import annotations
 
 import pytest
 
-from schemas.automation.config import AutomationJobConfig, default_memory_job_config
+from schemas.domain.automation import AutomationJobConfig
+from v1.auth.automation_static_config import load_static_automation_job_config
 
 
-def test_default_memory_job_config_has_expected_defaults() -> None:
-    config = default_memory_job_config()
+def test_memory_extraction_static_config_has_expected_defaults() -> None:
+    config = load_static_automation_job_config(config_name="memory_extraction")
 
-    assert config.agent_type.value == "memory"
-    assert config.model_code == "qwen3.5-flash"
+    assert "memory.write" in (config.enabled_tools or [])
+    assert "memory.forget" in (config.enabled_tools or [])
+    assert config.context is not None
     assert config.context.source.value == "latest_chat"
+    assert config.schedule is not None
+    assert config.schedule.type.value == "daily"
 
 
-def test_automation_job_config_rejects_non_flash_model() -> None:
-    with pytest.raises(ValueError, match="model_code must be qwen3.5-flash"):
+def test_automation_job_config_rejects_missing_weekdays_for_weekly() -> None:
+    with pytest.raises(ValueError, match="weekdays is required"):
         AutomationJobConfig.model_validate(
             {
-                "agent_type": "memory",
-                "model_code": "qwen-plus",
                 "enabled_tools": ["calendar.read"],
                 "input_template": "x",
                 "context": {
@@ -26,5 +28,9 @@ def test_automation_job_config_rejects_non_flash_model() -> None:
                     "window_mode": "day",
                     "window_count": 2,
                 },
+                "schedule": {
+                    "type": "weekly",
+                    "run_at": {"hour": 9, "minute": 0},
+                },
             }
         )
diff --git a/backend/tests/unit/schemas/messages/test_chat_message_schema.py b/backend/tests/unit/schemas/messages/test_chat_message_schema.py
index 2049fb4..baa2197 100644
--- a/backend/tests/unit/schemas/messages/test_chat_message_schema.py
+++ b/backend/tests/unit/schemas/messages/test_chat_message_schema.py
@@ -3,7 +3,7 @@ from __future__ import annotations
 from datetime import UTC, datetime
 from uuid import uuid4
 
-from schemas.messages.chat_message import AgentChatMessage
+from schemas.domain.chat_message import AgentChatMessage
 
 
 def test_agent_chat_message_schema_matches_messages_columns() -> None:
diff --git a/backend/tests/unit/v1/agent/test_dependencies_queue.py b/backend/tests/unit/v1/agent/test_dependencies_queue.py
deleted file mode 100644
index ca1a93b..0000000
--- a/backend/tests/unit/v1/agent/test_dependencies_queue.py
+++ /dev/null
@@ -1,283 +0,0 @@
-from __future__ import annotations
-
-import pytest
-
-from v1.agent.dependencies import RedisEventStream, TaskiqQueueClient
-
-
-class _FakeRedis:
-    def __init__(self) -> None:
-        self.store: dict[str, str] = {}
-        self.delete_calls: list[str] = []
-
-    async def set(
-        self,
-        key: str,
-        value: str,
-        *,
-        nx: bool = False,
-        ex: int | None = None,
-    ) -> bool:
-        del ex
-        if nx and key in self.store:
-            return False
-        self.store[key] = value
-        return True
-
-    async def get(self, key: str) -> str | None:
-        return self.store.get(key)
-
-    async def delete(self, key: str) -> int:
-        self.delete_calls.append(key)
-        existed = 1 if key in self.store else 0
-        self.store.pop(key, None)
-        return existed
-
-
-class _FakeAsyncResult:
-    def __init__(self, task_id: str) -> None:
-        self.task_id = task_id
-
-
-class _FakeRedisStreamClient:
-    pass
-
-
-@pytest.mark.asyncio
-async def test_enqueue_returns_task_id(monkeypatch: pytest.MonkeyPatch) -> None:
-    from v1.agent import dependencies as deps
-
-    fake_redis = _FakeRedis()
-    resolved_client = {"value": False}
-
-    async def _fake_kiq(payload: dict[str, object]) -> _FakeAsyncResult:
-        assert payload["command"] == "run"
-        return _FakeAsyncResult("task-123")
-
-    async def _fake_get_or_init_client() -> _FakeRedis:
-        resolved_client["value"] = True
-        return fake_redis
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.run_command_task, "kiq", _fake_kiq)
-
-    client = TaskiqQueueClient()
-    task_id = await client.enqueue(command={"command": "run"}, dedup_key=None)
-
-    assert resolved_client["value"] is True
-    assert task_id == "task-123"
-
-
-@pytest.mark.asyncio
-async def test_enqueue_resume_dedup_returns_existing_task_id(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    fake_redis = _FakeRedis()
-    resolved_client = {"value": False}
-
-    async def _fake_kiq(payload: dict[str, object]) -> _FakeAsyncResult:
-        del payload
-        return _FakeAsyncResult("new-task-id")
-
-    async def _fake_get_or_init_client() -> _FakeRedis:
-        resolved_client["value"] = True
-        return fake_redis
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.run_command_task, "kiq", _fake_kiq)
-
-    dedup_key = "resume:session-1:call-1"
-    fake_redis.store[f"agent:dedup:{dedup_key}"] = "existing-task-id"
-
-    client = TaskiqQueueClient()
-    task_id = await client.enqueue(
-        command={
-            "command": "resume",
-            "session_id": "session-1",
-            "tool_call_id": "call-1",
-        },
-        dedup_key=dedup_key,
-    )
-
-    assert resolved_client["value"] is True
-    assert task_id == "existing-task-id"
-
-
-@pytest.mark.asyncio
-async def test_enqueue_inflight_dedup_waits_and_reuses_existing_task_id(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    fake_redis = _FakeRedis()
-    dedup_key = "resume:session-1:call-1"
-    redis_key = f"agent:dedup:{dedup_key}"
-    fake_redis.store[redis_key] = deps.DEDUP_INFLIGHT_MARKER
-    attempts = {"count": 0}
-
-    async def _fake_get_or_init_client() -> _FakeRedis:
-        return fake_redis
-
-    async def _fake_get(key: str) -> str | None:
-        attempts["count"] += 1
-        if attempts["count"] > 1:
-            fake_redis.store[key] = "existing-task-id"
-        return fake_redis.store.get(key)
-
-    async def _fake_sleep(_: float) -> None:
-        return None
-
-    async def _fake_kiq(payload: dict[str, object]) -> _FakeAsyncResult:
-        del payload
-        raise AssertionError("should not enqueue when dedup task id appears")
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(fake_redis, "get", _fake_get)
-    monkeypatch.setattr(deps.asyncio, "sleep", _fake_sleep)
-    monkeypatch.setattr(deps.run_command_task, "kiq", _fake_kiq)
-
-    client = TaskiqQueueClient()
-    task_id = await client.enqueue(
-        command={
-            "command": "resume",
-            "session_id": "session-1",
-            "tool_call_id": "call-1",
-        },
-        dedup_key=dedup_key,
-    )
-
-    assert task_id == "existing-task-id"
-
-
-@pytest.mark.asyncio
-async def test_enqueue_failure_cleans_dedup_lock(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    fake_redis = _FakeRedis()
-    dedup_key = "resume:session-1:call-1"
-    redis_key = f"agent:dedup:{dedup_key}"
-
-    async def _fake_get_or_init_client() -> _FakeRedis:
-        return fake_redis
-
-    async def _fake_kiq(payload: dict[str, object]) -> _FakeAsyncResult:
-        del payload
-        raise RuntimeError("enqueue failed")
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.run_command_task, "kiq", _fake_kiq)
-
-    client = TaskiqQueueClient()
-    with pytest.raises(RuntimeError, match="enqueue failed"):
-        await client.enqueue(
-            command={
-                "command": "resume",
-                "session_id": "session-1",
-                "tool_call_id": "call-1",
-            },
-            dedup_key=dedup_key,
-        )
-
-    assert redis_key in fake_redis.delete_calls
-
-
-@pytest.mark.asyncio
-async def test_enqueue_uses_critical_queue_when_requested(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    fake_redis = _FakeRedis()
-
-    async def _fake_get_or_init_client() -> _FakeRedis:
-        return fake_redis
-
-    async def _fake_default_kiq(_: dict[str, object]) -> _FakeAsyncResult:
-        raise AssertionError("default queue should not be selected")
-
-    async def _fake_critical_kiq(_: dict[str, object]) -> _FakeAsyncResult:
-        return _FakeAsyncResult("critical-task-id")
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.run_command_task, "kiq", _fake_default_kiq)
-    monkeypatch.setattr(deps.run_command_task_critical, "kiq", _fake_critical_kiq)
-
-    client = TaskiqQueueClient()
-    task_id = await client.enqueue(
-        command={"command": "run", "queue": "critical"},
-        dedup_key=None,
-    )
-
-    assert task_id == "critical-task-id"
-
-
-@pytest.mark.asyncio
-async def test_enqueue_uses_bulk_queue_when_requested(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    fake_redis = _FakeRedis()
-
-    async def _fake_get_or_init_client() -> _FakeRedis:
-        return fake_redis
-
-    async def _fake_default_kiq(_: dict[str, object]) -> _FakeAsyncResult:
-        raise AssertionError("default queue should not be selected")
-
-    async def _fake_bulk_kiq(_: dict[str, object]) -> _FakeAsyncResult:
-        return _FakeAsyncResult("bulk-task-id")
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.run_command_task, "kiq", _fake_default_kiq)
-    monkeypatch.setattr(deps.run_command_task_bulk, "kiq", _fake_bulk_kiq)
-
-    client = TaskiqQueueClient()
-    task_id = await client.enqueue(
-        command={"command": "run", "queue": "bulk"},
-        dedup_key=None,
-    )
-
-    assert task_id == "bulk-task-id"
-
-
-@pytest.mark.asyncio
-async def test_event_stream_caps_block_ms_below_socket_timeout(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    async def _fake_get_or_init_client() -> _FakeRedisStreamClient:
-        return _FakeRedisStreamClient()
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.config.agent_runtime, "redis_stream_block_ms", 5000)
-    monkeypatch.setattr(deps.config.redis, "socket_timeout", 1.0)
-
-    stream = RedisEventStream()
-    bus = await stream._get_bus()
-
-    assert bus._block_ms == 900
-
-
-@pytest.mark.asyncio
-async def test_event_stream_uses_configured_block_ms_when_safe(
-    monkeypatch: pytest.MonkeyPatch,
-) -> None:
-    from v1.agent import dependencies as deps
-
-    async def _fake_get_or_init_client() -> _FakeRedisStreamClient:
-        return _FakeRedisStreamClient()
-
-    monkeypatch.setattr(deps, "get_or_init_redis_client", _fake_get_or_init_client)
-    monkeypatch.setattr(deps.config.agent_runtime, "redis_stream_block_ms", 200)
-    monkeypatch.setattr(deps.config.redis, "socket_timeout", 2.0)
-
-    stream = RedisEventStream()
-    bus = await stream._get_bus()
-
-    assert bus._block_ms == 200
diff --git a/backend/tests/unit/v1/agent/test_service.py b/backend/tests/unit/v1/agent/test_service.py
index 0c5a536..f6132d3 100644
--- a/backend/tests/unit/v1/agent/test_service.py
+++ b/backend/tests/unit/v1/agent/test_service.py
@@ -12,7 +12,7 @@ import pytest
 import v1.agent.service as agent_service_module
 from core.auth.models import CurrentUser
 from core.config.settings import config
-from schemas.messages.chat_message import AgentChatMessageMetadata
+from schemas.domain.chat_message import AgentChatMessageMetadata
 from v1.agent.service import AgentService
 
 
diff --git a/backend/tests/unit/v1/auth/test_registration_bootstrap_service.py b/backend/tests/unit/v1/auth/test_registration_bootstrap_service.py
index 819f859..265b77a 100644
--- a/backend/tests/unit/v1/auth/test_registration_bootstrap_service.py
+++ b/backend/tests/unit/v1/auth/test_registration_bootstrap_service.py
@@ -10,7 +10,7 @@ from models.automation_jobs import ScheduleType
 from v1.auth.registration_bootstrap import (
     compute_first_run_at_utc,
 )
-from schemas.automation import ScheduleConfig, ScheduleRunAt
+from schemas.domain.automation import ScheduleConfig, ScheduleRunAt
 
 
 def test_compute_first_run_at_utc_from_asia_shanghai() -> None:
diff --git a/backend/tests/unit/v1/automation_jobs/test_repository.py b/backend/tests/unit/v1/automation_jobs/test_repository.py
index d1277b5..e281a54 100644
--- a/backend/tests/unit/v1/automation_jobs/test_repository.py
+++ b/backend/tests/unit/v1/automation_jobs/test_repository.py
@@ -4,7 +4,7 @@ from uuid import uuid4
 import pytest
 
 from models.automation_jobs import AutomationJobStatus, ScheduleType
-from schemas.automation import (
+from schemas.domain.automation import (
     AgentTool,
     AutomationJobConfig,
     ContextSource,
diff --git a/backend/tests/unit/v1/automation_jobs/test_schemas.py b/backend/tests/unit/v1/automation_jobs/test_schemas.py
index ddb34e1..8366854 100644
--- a/backend/tests/unit/v1/automation_jobs/test_schemas.py
+++ b/backend/tests/unit/v1/automation_jobs/test_schemas.py
@@ -5,7 +5,8 @@ from uuid import uuid4
 import pytest
 from pydantic import ValidationError
 
-from schemas.automation import AgentTool, AutomationJobConfig
+from core.agentscope.tools.tool_config import AgentTool
+from schemas.domain.automation import AutomationJobConfig
 from v1.automation_jobs.schemas import (
     AutomationJobCreateRequest,
     AutomationJobResponse,
diff --git a/backend/tests/unit/v1/automation_jobs/test_service.py b/backend/tests/unit/v1/automation_jobs/test_service.py
index 1fb9881..08bde36 100644
--- a/backend/tests/unit/v1/automation_jobs/test_service.py
+++ b/backend/tests/unit/v1/automation_jobs/test_service.py
@@ -17,7 +17,7 @@ from v1.automation_jobs.schemas import (
     AutomationJobCreateRequest,
     AutomationJobUpdateRequest,
 )
-from schemas.automation import (
+from schemas.domain.automation import (
     AgentTool,
     AutomationJobConfig,
     ContextSource,
diff --git a/backend/tests/unit/v1/friendships/test_schemas.py b/backend/tests/unit/v1/friendships/test_schemas.py
index df1b0a2..e7a70c6 100644
--- a/backend/tests/unit/v1/friendships/test_schemas.py
+++ b/backend/tests/unit/v1/friendships/test_schemas.py
@@ -5,7 +5,7 @@ from uuid import uuid4
 
 import pytest
 from pydantic import ValidationError
-from schemas.user.context import UserContext
+from schemas.shared.user import UserContext
 
 from v1.friendships.schemas import (
     FriendRequestCreate,
diff --git a/backend/tests/unit/v1/inbox_messages/test_schemas.py b/backend/tests/unit/v1/inbox_messages/test_schemas.py
index 9e7474d..cbdc278 100644
--- a/backend/tests/unit/v1/inbox_messages/test_schemas.py
+++ b/backend/tests/unit/v1/inbox_messages/test_schemas.py
@@ -16,7 +16,7 @@ def test_inbox_message_response_schema() -> None:
         sender_id=uuid4(),
         message_type=InboxMessageType.CALENDAR,
         schedule_item_id=uuid4(),
-        content="Join my calendar",
+        content={"type": "invite", "permission": 1, "action": "pending"},
         is_read=False,
         status=InboxMessageStatus.PENDING,
         created_at=datetime.now(timezone.utc),
diff --git a/backend/tests/unit/v1/inbox_messages/test_service.py b/backend/tests/unit/v1/inbox_messages/test_service.py
index 17fc0dc..ad2f3cb 100644
--- a/backend/tests/unit/v1/inbox_messages/test_service.py
+++ b/backend/tests/unit/v1/inbox_messages/test_service.py
@@ -22,7 +22,7 @@ def _build_message(
     status: InboxMessageModelStatus = InboxMessageModelStatus.PENDING,
     message_type: InboxMessageModelType = InboxMessageModelType.CALENDAR,
     schedule_item_id: UUID | None = None,
-    content: str = '{"permission": 7}',
+    content: dict[str, object] = {"permission": 7},
 ) -> InboxMessage:
     message = MagicMock(spec=InboxMessage)
     message.id = message_id
diff --git a/backend/tests/unit/v1/schedule_items/test_service.py b/backend/tests/unit/v1/schedule_items/test_service.py
index 713f9b3..8f6d632 100644
--- a/backend/tests/unit/v1/schedule_items/test_service.py
+++ b/backend/tests/unit/v1/schedule_items/test_service.py
@@ -500,3 +500,43 @@ async def test_list_by_date_range_rolls_back_when_query_fails_after_archive(
     assert exc_info.value.status_code == 503
     mock_session.rollback.assert_awaited_once()
     mock_session.commit.assert_not_awaited()
+
+
+@pytest.mark.asyncio
+async def test_get_by_id_maps_legacy_completed_to_archived(
+    mock_session: AsyncMock,
+    mock_inbox_repository: MagicMock,
+) -> None:
+    user_id = UUID("00000000-0000-0000-0000-000000000001")
+    item = _create_mock_schedule_item()
+    setattr(item, "status", "completed")
+    service = ScheduleItemService(
+        repository=FakeRepo(item),
+        session=mock_session,
+        current_user=CurrentUser(id=user_id),
+        inbox_repository=mock_inbox_repository,
+    )
+
+    result = await service.get_by_id(item.id)
+
+    assert result.status == ScheduleItemStatus.ARCHIVED
+
+
+@pytest.mark.asyncio
+async def test_get_by_id_maps_legacy_canceled_to_archived(
+    mock_session: AsyncMock,
+    mock_inbox_repository: MagicMock,
+) -> None:
+    user_id = UUID("00000000-0000-0000-0000-000000000001")
+    item = _create_mock_schedule_item()
+    setattr(item, "status", "canceled")
+    service = ScheduleItemService(
+        repository=FakeRepo(item),
+        session=mock_session,
+        current_user=CurrentUser(id=user_id),
+        inbox_repository=mock_inbox_repository,
+    )
+
+    result = await service.get_by_id(item.id)
+
+    assert result.status == ScheduleItemStatus.ARCHIVED
diff --git a/backend/tests/unit/v1/schedule_items/test_subscription.py b/backend/tests/unit/v1/schedule_items/test_subscription.py
index a855b70..14381b4 100644
--- a/backend/tests/unit/v1/schedule_items/test_subscription.py
+++ b/backend/tests/unit/v1/schedule_items/test_subscription.py
@@ -1,4 +1,3 @@
-import json
 from datetime import datetime, timezone
 from unittest.mock import AsyncMock, MagicMock
 from uuid import UUID, uuid4
@@ -50,6 +49,11 @@ class FakeInboxRepo:
             return self._inbox
         return None
 
+    async def get_calendar_invite(
+        self, schedule_item_id: UUID, recipient_id: UUID
+    ) -> InboxMessage | None:
+        return await self.get_pending_calendar_invite(schedule_item_id, recipient_id)
+
     async def create(self, data: dict) -> InboxMessage:
         return MagicMock()
 
@@ -80,6 +84,9 @@ def mock_session() -> AsyncMock:
 @pytest.fixture
 def mock_repo() -> MagicMock:
     repo = MagicMock()
+    repo.get_subscription = AsyncMock(return_value=None)
+    repo.update_subscription_status = AsyncMock(return_value=None)
+    repo.archive_expired_subscribed_items = AsyncMock(return_value=0)
     repo.create_subscription = AsyncMock(return_value=MagicMock())
     return repo
 
@@ -196,6 +203,9 @@ async def test_list_by_date_range_with_subscriptions(
 
     mock_repo.list_by_date_range = AsyncMock(return_value=[owned_item])
     mock_repo.get_user_subscriptions = AsyncMock(return_value=[subscription])
+    mock_repo.list_subscribed_items_by_date_range = AsyncMock(
+        return_value=[(subscribed_item, subscription)]
+    )
     mock_repo.get_by_id = AsyncMock(return_value=subscribed_item)
 
     service = ScheduleItemService(
@@ -214,7 +224,6 @@ async def test_list_by_date_range_with_subscriptions(
 
     result = await service.list_by_date_range(request)
 
-    assert len(result) == 2
-    assert result[0].is_owner is True
-    assert result[1].is_owner is False
-    assert result[1].permission == 1
+    assert len(result) == 1
+    assert result[0].is_owner is False
+    assert result[0].permission == 1
diff --git a/docs/plans/2026-03-25-protocols-doc-fix.md b/docs/plans/2026-03-25-protocols-doc-fix.md
new file mode 100644
index 0000000..0aa0352
--- /dev/null
+++ b/docs/plans/2026-03-25-protocols-doc-fix.md
@@ -0,0 +1,99 @@
+# Protocols 文档修复计划
+
+> **For Claude:** REQUIRED SUB-SKILL: Use superpowers:executing-plans to implement this plan task-by-task.
+
+**Goal:** 修复 protocols 文档中与后端实现不一致的错误
+
+**Architecture:** 直接修改 docs/protocols/ 下的 markdown 文件，确保文档与 backend/src/models/ 中的实际模型定义保持一致
+
+**Tech Stack:** Markdown 编辑
+
+---
+
+## 修复任务清单
+
+### Task 1: 修复 Memories Protocol - 移除不存在的 `agent_id` 字段
+
+**文件:**
+- 修改: `docs/protocols/models/memory.md`
+
+**修改内容:**
+- 从 "数据库存储" 章节的表格中移除 `agent_id` 字段
+- 该字段在实现中不存在
+
+---
+
+### Task 2: 修复 InboxMessages Protocol - 添加缺失的 `group_id` 字段
+
+**文件:**
+- 修改: `docs/protocols/models/inbox-messages.md`
+
+**修改内容:**
+- 在 `InboxMessageResponse` 数据结构中添加 `group_id: uuid | null` 字段
+
+---
+
+### Task 3: 修复 ScheduleItems Protocol - 补充 `permission` 位掩码说明
+
+**文件:**
+- 修改: `docs/protocols/calendar/schedule-items.md`
+
+**修改内容:**
+- 在 `ScheduleItemResponse` 的说明中，添加 `permission` 字段的位掩码语义：
+  - `1` = view
+  - `2` = invite
+  - `4` = edit
+- 在 `ScheduleItemShareRequest` 中补充说明
+
+---
+
+### Task 4: 修复 Friendships Protocol - 补充内部状态说明
+
+**文件:**
+- 修改: `docs/protocols/models/friendships.md`
+
+**修改内容:**
+- 在 `FriendRequestResponse` 的 `status` 字段说明中，添加注释：
+  - `blocked` 和 `declined` 为内部实现状态
+  - 对外返回时映射为 `rejected`
+- 说明这是实现细节，客户端应处理所有枚举值
+
+---
+
+### Task 5: 修复 Memories Protocol - 改进 `source` 列移除说明
+
+**文件:**
+- 修改: `docs/protocols/models/memory.md`
+
+**修改内容:**
+- 在 "数据库存储" 章节的表格中，明确标注 `source` 列已移除
+- 或者在表格下方添加更醒目的 "已移除字段" 说明
+
+---
+
+### Task 6: 修复 Automation Jobs Protocol - 添加 `bootstrap_key` 字段
+
+**文件:**
+- 修改: `docs/protocols/models/automation-jobs.md`
+
+**修改内容:**
+- 在 "Canonical Fields" 表格中添加 `bootstrap_key: string | null` 字段说明
+- 简短说明其用途（引导配置键）
+
+---
+
+## 执行顺序
+
+1. Task 1 - Memories: 移除 agent_id
+2. Task 2 - InboxMessages: 添加 group_id
+3. Task 3 - ScheduleItems: 补充 permission 说明
+4. Task 4 - Friendships: 补充状态说明
+5. Task 5 - Memories: 改进 source 说明
+6. Task 6 - AutomationJobs: 添加 bootstrap_key
+
+---
+
+## 验证方式
+
+- 人工检查：对比修改后的文档与 backend/src/models/ 中的实际模型定义
+- 确保文档中描述的每个字段都能在对应 model 文件中找到
diff --git a/docs/plans/2026-03-25-schemas-restructure-design.md b/docs/plans/2026-03-25-schemas-restructure-design.md
new file mode 100644
index 0000000..b302159
--- /dev/null
+++ b/docs/plans/2026-03-25-schemas-restructure-design.md
@@ -0,0 +1,29 @@
+# Backend Schemas Restructure Design
+
+**Goal:** Restructure `backend/src/schemas` into clear domain/shared/enums modules while keeping API contracts in `backend/src/v1/*/schemas.py`.
+
+**Architecture:** Move reusable validation models and enums into `schemas/domain`, `schemas/shared`, and `schemas/enums.py`. Keep versioned request/response contracts in `v1/*/schemas.py` and update imports to explicit module paths. Remove legacy aggregate exports and duplicate/empty schema directories.
+
+**Tech Stack:** Python 3.13, Pydantic v2, Ruff, Pytest.
+
+---
+
+## Approved decisions
+
+- Use one-shot hard cut.
+- Keep API contracts in `backend/src/v1/*/schemas.py`.
+- Keep `schemas` as reusable constraints only.
+- Remove implicit root re-export usage.
+
+## Target structure
+
+- `backend/src/schemas/enums.py`
+- `backend/src/schemas/domain/*.py`
+- `backend/src/schemas/shared/*.py`
+- `backend/src/v1/*/schemas.py` (unchanged naming and ownership)
+
+## Validation gates
+
+- `uv run ruff check ...`
+- `uv run pytest ...` for impacted suites
+- `./infra/scripts/dev-migrate.sh migrate`
diff --git a/docs/plans/2026-03-25-schemas-restructure.md b/docs/plans/2026-03-25-schemas-restructure.md
new file mode 100644
index 0000000..b880d02
--- /dev/null
+++ b/docs/plans/2026-03-25-schemas-restructure.md
@@ -0,0 +1,123 @@
+# Backend Schemas Restructure Implementation Plan
+
+> **For Claude:** REQUIRED SUB-SKILL: Use superpowers:executing-plans to implement this plan task-by-task.
+
+**Goal:** Hard-cut refactor backend schema modules into clear domain/shared/enums boundaries while keeping API contracts in `v1/*/schemas.py`.
+
+**Architecture:** Introduce `schemas/enums.py` and move reusable schema models into `schemas/domain` and `schemas/shared`. Update all backend imports to explicit new module paths and remove old schema package wrappers and duplicate directories.
+
+**Tech Stack:** Python 3.13, Pydantic v2, Ruff, Pytest, Alembic migration runner.
+
+---
+
+### Task 1: Create new schema module layout
+
+**Files:**
+- Create: `backend/src/schemas/enums.py`
+- Create: `backend/src/schemas/domain/automation.py`
+- Create: `backend/src/schemas/domain/inbox.py`
+- Create: `backend/src/schemas/domain/schedule.py`
+- Create: `backend/src/schemas/domain/memory.py`
+- Create: `backend/src/schemas/domain/memory_content.py`
+- Create: `backend/src/schemas/domain/chat_message.py`
+- Create: `backend/src/schemas/domain/chat_session.py`
+- Create: `backend/src/schemas/domain/todo.py`
+- Create: `backend/src/schemas/domain/invite_code.py`
+- Create: `backend/src/schemas/shared/user.py`
+
+**Step 1: Write failing import checks**
+
+```python
+def test_new_schema_paths_importable() -> None:
+    import schemas.domain.automation  # noqa: F401
+```
+
+**Step 2: Run test to verify it fails**
+
+Run: `uv run pytest backend/tests/unit -k new_schema_paths_importable -v`
+Expected: FAIL with import error
+
+**Step 3: Implement new modules**
+
+Copy and normalize existing reusable models into new modules.
+
+**Step 4: Run test to verify it passes**
+
+Run: `uv run pytest backend/tests/unit -k new_schema_paths_importable -v`
+Expected: PASS
+
+### Task 2: Update all backend imports to new schema paths
+
+**Files:**
+- Modify: `backend/src/**/*.py` (affected import lines)
+
+**Step 1: Write failing grep assertions**
+
+Run: `uv run python -c "..."` with assertions for old import patterns.
+
+**Step 2: Verify failures with old paths present**
+
+Run: `uv run ruff check backend/src`
+
+**Step 3: Implement import rewrites**
+
+Replace old paths (`schemas.model_enums`, `schemas.automation`, `schemas.memories.memory_content`, etc.) with new explicit modules.
+
+**Step 4: Verify static checks pass**
+
+Run: `uv run ruff check backend/src`
+Expected: PASS
+
+### Task 3: Remove legacy schema wrappers and duplicates
+
+**Files:**
+- Delete: `backend/src/schemas/model_enums.py`
+- Delete: `backend/src/schemas/automation/__init__.py`
+- Delete: `backend/src/schemas/inbox/messages.py`
+- Delete: `backend/src/schemas/schedule/items.py`
+- Delete: `backend/src/schemas/memories/__init__.py`
+- Delete: `backend/src/schemas/memories/memory_content.py`
+- Delete: `backend/src/schemas/messages/chat_message.py`
+- Delete: `backend/src/schemas/messages/__init__.py`
+- Delete: `backend/src/schemas/sessions/chat_session.py`
+- Delete: `backend/src/schemas/sessions/__init__.py`
+- Delete: `backend/src/schemas/todo/contracts.py`
+- Delete: `backend/src/schemas/todo/__init__.py`
+- Delete: `backend/src/schemas/user/context.py`
+- Delete: `backend/src/schemas/user/__init__.py`
+- Delete: `backend/src/schemas/inbox/__init__.py`
+- Delete: `backend/src/schemas/invite_codes/__init__.py`
+- Modify: `backend/src/schemas/__init__.py`
+
+**Step 1: Remove old modules**
+
+Delete legacy wrappers after all imports are rewritten.
+
+**Step 2: Verify no old imports remain**
+
+Run: `uv run python -c "..."` or grep-based assertion commands.
+Expected: zero matches
+
+### Task 4: Verification and migration
+
+**Files:**
+- Verify only
+
+**Step 1: Run quality gates**
+
+Run: `uv run ruff check backend/src`
+
+**Step 2: Run impacted tests**
+
+Run: `uv run pytest backend/tests/unit/v1/automation_jobs backend/tests/unit/v1/schedule_items backend/tests/unit/v1/todo backend/tests/unit/v1/friendships backend/tests/unit/v1/inbox_messages backend/tests/unit/v1/users backend/tests/unit/v1/agent backend/tests/unit/core/agentscope`
+
+**Step 3: Run migration script**
+
+Run: `./infra/scripts/dev-migrate.sh migrate`
+
+**Step 4: Commit**
+
+```bash
+git add backend/src/schemas backend/src/v1 backend/src/models backend/src/core docs/plans
+git commit -m "refactor: restructure backend schema modules by domain boundaries"
+```
diff --git a/docs/protocols/calendar/schedule-items.md b/docs/protocols/calendar/schedule-items.md
index a6547b0..4d8adb9 100644
--- a/docs/protocols/calendar/schedule-items.md
+++ b/docs/protocols/calendar/schedule-items.md
@@ -28,10 +28,10 @@ Base URL: `/api/v1/schedule-items`
 | 值 | 说明 |
 |---|---|
 | `active` | 进行中 |
-| `completed` | 已完成 |
-| `canceled` | 已取消 |
 | `archived` | 已归档 |
 
+兼容策略：历史数据中若存在 `completed` 或 `canceled`，服务端统一按 `archived` 语义处理；新写入仅允许 `active` 或 `archived`。
+
 ### ScheduleItemSourceType
 
 | 值 | 说明 |
@@ -96,7 +96,7 @@ Base URL: `/api/v1/schedule-items`
   "end_at": "datetime | null (必须包含时区)",
   "timezone": "string | null (IANA 时区)",
   "metadata": "ScheduleItemMetadata | null",
-  "status": "ScheduleItemStatus | null"
+  "status": "ScheduleItemStatus | null (active | archived)"
 }
 ```
 
@@ -116,7 +116,7 @@ Base URL: `/api/v1/schedule-items`
   "source_type": "ScheduleItemSourceType",
   "created_at": "datetime",
   "updated_at": "datetime",
-  "permission": "int",
+  "permission": "int (位掩码: 1=view, 2=invite, 4=edit)",
   "is_owner": "boolean"
 }
 ```
@@ -132,6 +132,11 @@ Base URL: `/api/v1/schedule-items`
 }
 ```
 
+说明：`permission_view`、`permission_edit`、`permission_invite` 为布尔值，内部会转换为位掩码整数：
+- `permission_view = 1`
+- `permission_invite = 2`
+- `permission_edit = 4`
+
 ### ScheduleItemShareResponse
 
 ```json
diff --git a/docs/protocols/models/automation-jobs.md b/docs/protocols/models/automation-jobs.md
index 14f8a92..1a76325 100644
--- a/docs/protocols/models/automation-jobs.md
+++ b/docs/protocols/models/automation-jobs.md
@@ -10,6 +10,7 @@ scheduler computation, and Flutter settings pages.
 - `id`: UUID
 - `owner_id`: UUID
 - `title`: string
+- `bootstrap_key`: string | null (引导配置键，用于标识预设任务模板)
 - `config`: object
   - `input_template`: string
   - `enabled_tools`: string[]
diff --git a/docs/protocols/models/friendships.md b/docs/protocols/models/friendships.md
index af4bfb0..f8529a2 100644
--- a/docs/protocols/models/friendships.md
+++ b/docs/protocols/models/friendships.md
@@ -49,6 +49,8 @@ Base URL: `/api/v1/friends`
 }
 ```
 
+说明：`status` 对外返回的值包括 `pending`、`accepted`、`rejected`、`canceled`。内部实现中还有 `blocked` 和 `declined` 状态，在返回给客户端时会映射为 `rejected` 或 `canceled`。
+
 ### FriendResponse
 
 ```json
diff --git a/docs/protocols/models/inbox-messages.md b/docs/protocols/models/inbox-messages.md
index af09c3a..cfa9ca6 100644
--- a/docs/protocols/models/inbox-messages.md
+++ b/docs/protocols/models/inbox-messages.md
@@ -92,6 +92,7 @@ Base URL: `/api/v1/inbox/messages`
   "message_type": "InboxMessageType",
   "schedule_item_id": "uuid | null",
   "friendship_id": "uuid | null",
+  "group_id": "uuid | null",
   "content": "CalendarInviteContent | CalendarUpdateContent | CalendarDeleteContent | FriendshipContent | null",
   "is_read": "boolean",
   "status": "InboxMessageStatus",
diff --git a/docs/protocols/models/memory.md b/docs/protocols/models/memory.md
index bc8573e..0ea587c 100644
--- a/docs/protocols/models/memory.md
+++ b/docs/protocols/models/memory.md
@@ -172,7 +172,6 @@
 |------|------|------|
 | `id` | UUID | 主键 |
 | `owner_id` | UUID | 所有者用户 ID |
-| `agent_id` | UUID | 关联 Agent ID（可选） |
 | `memory_type` | VARCHAR(20) | 记忆类型枚举（当前含 `user`、`work`，可扩展） |
 | `content` | JSONB | UserMemoryContent 或 WorkProfileContent |
 | `status` | VARCHAR(20) | ACTIVE / DISABLED |
@@ -181,6 +180,7 @@
 
 说明：
 - `source` 列已移除，不再作为行级来源标记。
+- `agent_id` 列不存在。
 - 来源信息如果需要保留，使用 `content` 内各条目的 `meta.source`（字段级来源）。
 - 唯一性约束：同一 `owner_id` 下 `memory_type` 不能重复（`UNIQUE(owner_id, memory_type)`）。
 
@@ -306,8 +306,9 @@ build_system_prompt(
 
 | 文件 | 职责 |
 |------|------|
-| `src/schemas/memories/memory_content.py` | UserMemoryContent、WorkProfileContent 模型 |
-| `src/schemas/memories/__init__.py` | MemoryType、MemoryStatus 枚举 |
+| `src/schemas/domain/memory_content.py` | UserMemoryContent、WorkProfileContent 模型 |
+| `src/schemas/domain/memory.py` | MemoryModel 聚合模型 |
+| `src/schemas/enums.py` | MemoryType、MemoryStatus 枚举 |
 | `src/models/memories.py` | SQLAlchemy ORM 模型 |
 | `src/v1/memories/router.py` | API 端点 |
 | `src/v1/memories/service.py` | 业务逻辑层 |