fix(acquisition): 集数待确认的资源在订阅侧写候选记录

评估跳过 episode_unresolved 时，给仍在追踪的收录版本各写一条 skipped 候选评估
（原因 episode_unresolved），作品「为什么选 / 不选」与订阅记录能看到"集数待确认"。
确认后重发评估按 (收录版本, 资源) 覆盖；换算到别的季不再进入原收录版本时，
先清掉旧的待确认记录，不留陈旧原因。

Co-Authored-By: Claude Opus 5.5 <[email protected]>
Claude-Session: https://claude.ai/code/session_01Cxwgnn2pbzQ7rXv3rq7fei

apps/server/src/modules/acquisition-organize/services/acquisition.ts

@@ -34,6 +34,7 @@ import { hashJson, jsonb, startOfDay, toApi } from "../util.ts";
 import {
   type AoDeps,
   automationBlock,
+  CANDIDATE_ARTIFACT_TITLE,
   downloaderPathOf,
   type Exec,
   enqueueTracked,
@@ -364,7 +365,13 @@ async function evaluateRelease(c: Ctx, rel: SourceReleaseRow, eventUnits: readon
   if (rel.availability !== "active") return skip(`release_${rel.availability}`);
   const entity = await resolveEntity(db, rel.media_entity_id);
   if (!entity || entity.status === "archived") return skip("entity_unavailable");
-  if (entity.kind !== "movie" && episodeUnresolved(rel)) return skip("episode_unresolved");
+  if (entity.kind !== "movie" && episodeUnresolved(rel)) {
+    // 订阅侧可见:相关收录版本各记一条候选评估;确认后重发 release.resolved 正常评估时按 (收录版本, 资源) 覆盖
+    await noteEpisodeUnresolved(c, rel, entity.id, onlySlotId);
+    return skip("episode_unresolved");
+  }
+  // 已确认的资源:先清掉之前的"集数待确认"记录(换算到别的季时下面可能不再进入该收录版本,不会被覆盖)
+  if (entity.kind !== "movie" && episodeResolutionOf(rel)) await clearEpisodeUnresolvedNotes(c, rel.id, entity.id);
   const parsed = parsedOf(rel);
   const units = await releaseUnits(
     db,
@@ -523,6 +530,37 @@ async function evaluateRelease(c: Ctx, rel: SourceReleaseRow, eventUnits: readon
   }
 }
 
+/** 集数待确认:给仍在追踪的收录版本各写一条 skipped 候选评估(原因 episode_unresolved) */
+async function noteEpisodeUnresolved(c: Ctx, rel: SourceReleaseRow, entityId: string, onlySlotId?: string) {
+  let q = c.d.ctx.db
+    .selectFrom("acquisition_slot as s")
+    .leftJoin("subscription as sub", "sub.id", "s.subscription_id")
+    .select("s.id")
+    .where("s.media_entity_id", "=", entityId)
+    .where((eb) => eb.or([eb("s.subscription_id", "is", null), eb("sub.status", "in", [...TRACKING_SUB_STATUSES])]));
+  if (onlySlotId) q = q.where("s.id", "=", onlySlotId);
+  for (const s of await q.execute())
+    await note(c, {
+      slotId: s.id,
+      sourceReleaseId: rel.id,
+      title: rel.title,
+      planId: null,
+      decision: "skipped",
+      mode: null,
+      rejected: [{ code: "episode_unresolved", message: "集数待确认，确认后自动重新评估" }],
+      reasons: ["episode_unresolved"],
+    });
+}
+
+async function clearEpisodeUnresolvedNotes(c: Ctx, sourceReleaseId: string, entityId: string) {
+  await sql`
+    delete from artifact
+     where title = ${CANDIDATE_ARTIFACT_TITLE} and subject_type = 'acquisition_slot'
+       and subject_id in (select id from acquisition_slot where media_entity_id = ${entityId})
+       and content->>'sourceReleaseId' = ${sourceReleaseId}
+       and content->'reasons' ? 'episode_unresolved'`.execute(c.d.ctx.db);
+}
+
 /** 站点字段 → 评估上下文(做种数、促销下载系数、副标题/标签、站点 id、发布后分钟数) */
 export function contextOf(rel: SourceReleaseRow, now: Date = new Date()): EvaluationContext {
   const promo = (rel.promotion ?? {}) as { kind?: string; raw?: { downloadFactor?: number | null } };