@@ -158,6 +158,11 @@ services:
       METRICS_ENABLED: ${METRICS_ENABLED:-true}
       # 请求级结构化日志（logfmt，只记 /api、/v1、/authorize；不写 query/正文/用户名）
       REQUEST_LOG_ENABLED: ${REQUEST_LOG_ENABLED:-true}
+      # 签到定时：本地 HH:MM 逗号分隔，留空 = 全天每 10 分钟（旧行为）；抖动分钟
+      CHECKIN_TIMES: ${CHECKIN_TIMES:-}
+      CHECKIN_JITTER_MINUTES: ${CHECKIN_JITTER_MINUTES:-0}
+      # 管理台日志页环形缓冲行数（0 关闭该页）
+      LOG_BUFFER_LINES: ${LOG_BUFFER_LINES:-500}
       # 出站剥离思考内容（只过滤响应、不改请求体）；true 开启
       FORCE_DISABLE_THINKING: ${FORCE_DISABLE_THINKING:-false}
       # 出站 reasoning_effort 档位映射：渠道=from:to,from:to;*=from:to；留空原样透传
 
@@ -136,6 +136,17 @@ class Settings(BaseSettings):
     # 篡改活动数据（处罚为取消资格并追回礼品），开启前请评估账号风险；上游改版即失效。
     activity_report_enabled: bool = False
     activity_report_hour: int = 10          # 本地（北京）时间整点窗口内执行一次
+    # 每日签到的执行时点（本地时间，HH:MM，逗号分隔；留空 = 全天每 10 分钟
+    # 检查一次的旧行为）。命中时点才跑一轮：上游签到本身幂等（回 ALREADY），
+    # 但每次都要打 status+claim+回查三次，全天轮询纯属白打。抖动见下一项。
+    checkin_times: str = ""
+    # 签到抖动（分钟，0 = 不抖）：在时点**之前**提前一个随机偏移执行，避免
+    # 一堆部署在同一分钟齐刷刷打上游。按「日期 + 时点」记去重键，抖动只改
+    # 执行时刻、不改归属，不会让同一时点跑两次。
+    checkin_jitter_minutes: int = 0
+    # 服务端日志页（「任务与配置」→ 日志）：进程内环形缓冲的保留行数，
+    # 0 = 关闭该页（端点返回 404）。只收本进程 logging 记录，不读文件。
+    log_buffer_lines: int = 500
     # 运维告警：周期评估四类风险，命中即落 alert_events 并可选推送
     # webhook。webhook 留空 = 只留站内记录、不外推。
     alert_enabled: bool = True
 
@@ -77,3 +77,58 @@ def set_api_key_id(value: str | None) -> None:
 def get_api_key_id() -> str | None:
     """读当前上下文的 API Key id；无请求上下文（后台任务/脚本）返回 None。"""
     return _api_key_id.get()
+
+
+# 入站请求头带来的会话标识（E1）：客户端（Codex / Claude Code / opencode 等）
+# 用 `x-session-id` 这类头声明「这是同一段对话」，比消息前缀兜底可靠得多。
+# 与 request_id 同一套纪律：**入站头是客户端可写输入**，按白名单字符集与长度
+# 校验后才采信，不合法一律丢弃；且只作会话粘性的**兜底键**（优先级低于请求体
+# 里的显式键），不会影响模型、路由或鉴权。
+SESSION_ID_PATTERN = re.compile(r"^[A-Za-z0-9._:-]{1,128}$")
+
+# 接受的头名，按优先级排列。前三个是 opencode / Codex 生态实际在用的写法，
+# 后两个是 conversation_id 的头形式（部分客户端把它放头里）。
+SESSION_ID_HEADERS: tuple[bytes, ...] = (
+    b"x-session-id",
+    b"x-opencode-session",
+    b"x-session-affinity",
+    b"conversation-id",
+    b"conversation_id",
+)
+
+_session_id: ContextVar[str | None] = ContextVar("session_id", default=None)
+
+
+def sanitize_session_id(raw: str | None) -> str | None:
+    """校验会话标识；不合法（含换行/超长/空）返回 None，由调用方丢弃。"""
+    if not raw or not raw.strip():
+        return None
+    text = raw.strip()
+    return text if SESSION_ID_PATTERN.match(text) else None
+
+
+def session_id_from_headers(headers) -> str | None:
+    """从入站头取会话标识（`headers` 为 ASGI 的 [(bytes, bytes), ...]）。
+
+    按 `SESSION_ID_HEADERS` 的顺序取第一个**合法**的非空值；全部不合法返回
+    None。头名大小写不敏感（ASGI 里规范为小写，但仍统一 lower 一次防调用方
+    传大小写混合的列表）。
+    """
+    for name in SESSION_ID_HEADERS:
+        for key, value in headers:
+            if key.lower() == name:
+                candidate = sanitize_session_id(value.decode("latin-1"))
+                if candidate is not None:
+                    return candidate
+    return None
+
+
+def set_session_id(value: str | None) -> None:
+    """在当前上下文设置会话标识（请求入口调用；None = 复原）。"""
+    _session_id.set(value)
+
+
+def get_session_id() -> str | None:
+    """读当前上下文的会话标识；无请求上下文返回 None。"""
+    return _session_id.get()
+
@@ -208,6 +208,19 @@ def env_name(self) -> str:
     HotSetting("activity_report_hour", int, "活跃上报时点（0-23）",
                "本地（北京）时间整点窗口；该小时内每 10 分钟检查一次，每号每天"
                "最多补发一条。", minimum=0, maximum=23, task="activity"),
+    HotSetting("checkin_times", str, "签到时点",
+               "本地时间 HH:MM，逗号分隔（如 `09:37,21:10`）。命中时点才跑一轮"
+               "签到；留空 = 全天每 10 分钟检查一次（旧行为）。上游签到幂等，"
+               "多设几个时点只是多几次重试机会。", task="checkin"),
+    HotSetting("checkin_jitter_minutes", int, "签到抖动（分钟）",
+               "在时点**之前**提前一个 0..N 分钟的随机偏移执行，避免多部署"
+               "同一分钟齐打上游。按「日期 + 时点」去重，抖动不会让同一时点"
+               "跑两次。0 = 不抖。", minimum=0, maximum=1440, task="checkin"),
+    HotSetting("log_buffer_lines", int, "日志页保留行数",
+               "「任务与配置」→ 日志页的进程内环形缓冲行数（只收本进程日志，"
+               "不读文件）。0 = 关闭该页（端点返回 404）。日志行发出前经脱敏"
+               "白名单过滤，含 token / secret / authorization / cookie 的行整行丢弃。",
+               minimum=0, group="observability"),
     # 运维告警：全部归到「运维告警」任务卡片下——改阈值时人就在看
     # 这个任务最近报了什么。webhook 留空 = 只留站内记录、不外推。
     HotSetting("alert_enabled", bool, "运维告警开关",
@@ -743,6 +756,18 @@ def activity_report_enabled(self) -> bool:
     def activity_report_hour(self) -> int:
         return int(self.get("activity_report_hour"))
 
+    @property
+    def checkin_times(self) -> str:
+        return str(self.get("checkin_times"))
+
+    @property
+    def checkin_jitter_minutes(self) -> int:
+        return int(self.get("checkin_jitter_minutes"))
+
+    @property
+    def log_buffer_lines(self) -> int:
+        return int(self.get("log_buffer_lines"))
+
     # ---------------------------------------------------------- 运维告警
 
     @property
 
@@ -15,8 +15,10 @@
 from ..request_context import (
     REQUEST_ID_HEADER,
     resolve_request_id,
+    session_id_from_headers,
     set_api_key_id,
     set_request_id,
+    set_session_id,
 )
 
 
@@ -39,6 +41,9 @@ async def __call__(self, scope, receive, send) -> None:
             return
         request_id = resolve_request_id(_header(scope, b"x-request-id"))
         set_request_id(request_id)
+        # 会话标识（E1）：与请求 ID 同一中间件设置即可——它只被会话粘性读，
+        # 且必须在校验之前落进上下文（executor 早于任何业务层）。
+        set_session_id(session_id_from_headers(scope.get("headers", ())))
         header = (REQUEST_ID_HEADER.lower().encode("latin-1"),
                   request_id.encode("latin-1"))
 
@@ -51,7 +56,9 @@ async def send_with_header(message):
         try:
             await self.app(scope, receive, send_with_header)
         finally:
-            # 复原 Key 归属：contextvar 由鉴权依赖设置，而流式响应体在依赖
-            # 的 finally **之后**才发送，只靠依赖复原会让「响应体期间」的
-            # 后台写入串到下一个请求。中间件包住整个 ASGI 调用，最可靠。
+            # 复原 Key 归属与会话标识：contextvar 由鉴权依赖/本中间件设置，而
+            # 流式响应体在依赖的 finally **之后**才发送，只靠依赖复原会让
+            # 「响应体期间」的后台写入串到下一个请求。中间件包住整个 ASGI
+            # 调用，最可靠。
             set_api_key_id(None)
+            set_session_id(None)
@@ -211,3 +211,69 @@ def test_record_without_key_context_stores_null(db):
     collector.record(username="u", provider="trae", model="m", ok=True)
     assert db.connect().execute(
         "SELECT api_key_id FROM usage_events").fetchone()["api_key_id"] is None
+
+
+# ------------------------------------------------------- 会话标识（E1 的地基）
+
+def test_session_id_defaults_none_and_round_trips():
+    from src.request_context import get_session_id, set_session_id
+
+    assert get_session_id() is None
+    set_session_id("sess-1")
+    assert get_session_id() == "sess-1"
+    set_session_id(None)
+    assert get_session_id() is None
+
+
+def test_sanitize_session_id_accepts_and_rejects():
+    from src.request_context import SESSION_ID_PATTERN, sanitize_session_id
+
+    for raw in ("abc", "a-b.c_d:e", "x" * 128):
+        assert sanitize_session_id(raw) == raw
+    for raw in (None, "", "   ", "has space", "line\nbreak", "x" * 129):
+        assert sanitize_session_id(raw) is None
+    assert SESSION_ID_PATTERN.match("ok")
+
+
+def test_session_id_from_headers_prefers_earlier_header_names():
+    """按 SESSION_ID_HEADERS 顺序取第一个合法值（头名大小写不敏感）。"""
+    from src.request_context import session_id_from_headers
+
+    headers = [(b"conversation-id", b"third"), (b"x-session-id", b"first"),
+               (b"x-opencode-session", b"second")]
+    assert session_id_from_headers(headers) == "first"
+    only_later = [(b"conversation-id", b"conversation")]
+    assert session_id_from_headers(only_later) == "conversation"
+    # 大小写混合的头名同样识别
+    assert session_id_from_headers([(b"X-Session-Id", b"mixed")]) == "mixed"
+
+
+def test_session_id_from_headers_skips_invalid_and_returns_none():
+    from src.request_context import session_id_from_headers
+
+    assert session_id_from_headers([]) is None
+    assert session_id_from_headers([(b"x-session-id", b"bad id")]) is None
+    # 第一个头非法时继续看下一个头，而不是整体放弃
+    assert session_id_from_headers([(b"x-session-id", b"bad id"),
+                                    (b"x-opencode-session", b"good")]) == "good"
+
+
+def test_middleware_sets_and_clears_session_id():
+    """中间件从入站头设置会话标识，请求结束后复原。"""
+    from fastapi import FastAPI as _FastAPI
+    from fastapi.testclient import TestClient as _TestClient
+
+    from src.request_context import get_session_id
+
+    app = _FastAPI()
+    app.add_middleware(RequestIdMiddleware)
+
+    @app.get("/sess")
+    async def sess():
+        return {"session": get_session_id()}
+
+    with _TestClient(app) as client:
+        response = client.get("/sess", headers={"x-session-id": "abc-123"})
+        assert response.json()["session"] == "abc-123"
+        # 复原：下一个请求不带头时读不到上一次的值
+        assert client.get("/sess").json()["session"] is None