fix: 建行前按同标题兜底，防止季节码漂移造出重复图集

男装季节码由 FWyy 改为 SSyy 后，仍按旧规则算码的实例（如本机残留的旧后端）
会把同一场秀当成新场次再建一行，今天已产生 7 组重复（Acne/Celine/AMBUSH 等）。

- 新增 IngestRepository.RunwayTitleExists（品牌 + 英文标题）
- processRunway 在「实体键未命中、准备新建」时再查一次同标题：
  命中则跳过并记 outcome=skipped_existing，note 写明「季节码漂移保护」
- 宁可跳过也不产生重复；标题含年份，正常不会误伤不同场次

internal/repository/ingest_repository.go

@@ -33,6 +33,12 @@ type IngestRepository interface {
 	// outcome 取 model.IngestOutcome* 常量，note 例如「新建 42 张图」「已存在(status=published)」。
 	// 二者是后台「品牌更新记录」的全部信息源：只有 status=done 看不出这次到底新建还是跳过。
 	MarkDone(ctx context.Context, id uint32, outcome, note string) error
+	// RunwayTitleExists 按（品牌 + 英文标题）查已有图集，返回其 id 与是否存在。
+	//
+	// 用途：季节码推导规则变更后，同一场秀可能被算出不同的 season_code（如 Spring 男装
+	// 曾是 FWyy、现在是 SSyy）。老实例按旧规则写入会建出「同标题不同季节码」的重复图集。
+	// 建行前用它兜底，把「标题相同」视为同一场秀。
+	RunwayTitleExists(ctx context.Context, brandID uint32, titleEn string) (uint32, bool, error)
 	// ListByBrand 取某品牌的入库记录（按 id 倒序），供品牌详情页展示更新历史。
 	ListByBrand(ctx context.Context, brandID uint32, limit int) ([]BrandIngestRecord, error)
 	// MarkFailed 标记任务失败并记录错误（attempts 自增）。
@@ -183,6 +189,20 @@ func (r *ingestRepository) MarkDone(ctx context.Context, id uint32, outcome, not
 		}).Error
 }
 
+// RunwayTitleExists 按（品牌 + 英文标题）查已有图集。
+func (r *ingestRepository) RunwayTitleExists(ctx context.Context, brandID uint32, titleEn string) (uint32, bool, error) {
+	if brandID == 0 || titleEn == "" {
+		return 0, false, nil
+	}
+	var id uint32
+	if err := r.db.WithContext(ctx).Raw(
+		"SELECT id FROM brand_runways WHERE brand_id = ? AND title_en = ? AND is_deleted = 0 LIMIT 1",
+		brandID, titleEn).Scan(&id).Error; err != nil {
+		return 0, false, err
+	}
+	return id, id > 0, nil
+}
+
 // BrandIngestRecord 是品牌详情页需要的「一条更新记录」。
 //
 // 只取必要列：payload 可能几十 KB（含全部 look 的 key），一次拉 20 条会传上兆，

internal/service/ingest_image_count_test.go

@@ -44,6 +44,12 @@ func (c *captureIngestRepo) MarkDone(ctx context.Context, id uint32, outcome, no
 	return nil
 }
 
+// RunwayTitleExists 捕获型仓储没有真实数据，一律视为「不存在」，
+// 免得测试路径走进「同标题已存在 → 跳过」分支。
+func (c *captureIngestRepo) RunwayTitleExists(ctx context.Context, brandID uint32, titleEn string) (uint32, bool, error) {
+	return 0, false, nil
+}
+
 // ListByBrand 捕获型仓储不需要品牌维度查询。
 func (c *captureIngestRepo) ListByBrand(ctx context.Context, brandID uint32, limit int) ([]repository.BrandIngestRecord, error) {
 	return nil, nil

internal/service/ingest_service.go

@@ -349,6 +349,17 @@ func (s *IngestService) processRunway(ctx context.Context, job model.IngestJob,
 		}
 	}
 	action := decideIngestAction(exist, existStatus)
+	// 季节码漂移保护：实体键按 season_code 去重，但规则改过（Spring 男装由 FWyy 改为 SSyy）。
+	// 若还有实例按旧规则算码，就会把同一场秀当成新场次再建一行。
+	// 这里在建行前用「同品牌同标题」再兜一次底，宁可跳过也不产生重复。
+	if !exist && action != ingestSkip {
+		if dupID, found, terr := s.repo.RunwayTitleExists(ctx, brandID, p.TitleEn); terr == nil && found {
+			log.Printf("[ingest] job=%d runway 已存在同标题图集 id=%d（季节码可能漂移），跳过", job.ID, dupID)
+			_ = s.repo.MarkDone(ctx, job.ID, model.IngestOutcomeSkippedExisting,
+				fmt.Sprintf("已存在同标题图集(id=%d)，跳过（季节码漂移保护）", dupID))
+			return
+		}
+	}
 	if action == ingestSkip {
 		log.Printf("[ingest] job=%d runway 实体已存在(status=%s)，跳过（回填 published_at）", job.ID, existStatus)
 		// 临时回填：仅更新发布时间与缺失年份，不重下图片（图片已在库）。