update

internal/service/ingest_service.go

@@ -286,7 +286,6 @@ func (s *IngestService) processRunway(ctx context.Context, job model.IngestJob,
 				Image:       fi.url,
 				Name:        fmt.Sprintf("Look %d", i+1),
 				SortOrder:   uint32(i + 1),
-				LookIndex:   uint32(i + 1),
 				IsDetail:    0,
 				Phash:       sqlNull(fi.phash),
 				IsDuplicate: fi.isDup,
@@ -333,13 +332,21 @@ func (s *IngestService) processRunway(ctx context.Context, job model.IngestJob,
 		s.failOrRetry(ctx, job.ID, "save runway: "+saveErr.Error())
 		return
 	}
+	// 入库后按 sort_order 回填细节图的 parent_image_id，使新走秀自动成组（与街拍一致）。
+	runwayID := rw.ID
+	if runwayID == 0 {
+		runwayID = reuseID
+	}
+	if rerr := s.repo.RepairRunwayDetailParents(ctx, runwayID); rerr != nil {
+		log.Printf("[ingest] job=%d runway 回填 parent 失败: %v", job.ID, rerr)
+	}
 	log.Printf("[ingest] job=%d runway 写正式表 耗时=%v 图片行=%d 复用驳回=%v",
 		job.ID, time.Since(writeStart).Round(time.Millisecond), len(images), action == ingestReuseRejected)
 	_ = s.repo.MarkDone(ctx, job.ID)
 }
 
 // fetchLookImages 按 Looks 结构下载主图+细节图并上传到存储，返回可直接落正式图片表的
-// BrandRunwayImage 行（带 look_index / is_detail 分组）。任意一张下载/上传失败即把
+// BrandRunwayImage 行（带 parent_image_id / is_detail 分组）。任意一张下载/上传失败即把
 // failed 置 true，调用方据此把整条任务判失败并回滚本批已上传的 key，符合「单图失败=整任务失败」策略。
 // cover 取首个成功下载的主图；image_count 由调用方按返回行中 is_detail == 0 的数量计
 //（countMainImages），而不是 len(Looks)：跳过空主图 / sha1 重复后实际行数可能更少。
@@ -408,7 +415,6 @@ func (s *IngestService) fetchLookImages(ctx context.Context, looks []dto.RunwayL
 			Image:       r.url,
 			Name:        name,
 			SortOrder:   uint32(order),
-			LookIndex:   uint32(task.lookIdx),
 			IsDetail:    isDetail,
 			Phash:       sqlNull(r.phashBits),
 			IsDuplicate: isDup,
@@ -435,9 +441,11 @@ func countMainImages(images []model.BrandRunwayImage) uint16 {
 // processStreet 街拍入库：实体键分三支（新建 / 放弃 / 复用驳回）→ 下载图 → 直写 street_snaps（无品牌）。
 func (s *IngestService) processStreet(ctx context.Context, job model.IngestJob, p dto.RunwayIngest) {
 	// 1) 实体键查重并决定分支（单表模型，同 runway）。
-	// 实体键含 title：与下方 snap.Title 用的是同一个 p.TitleEn，保证查重口径与落库内容一致，
+	// 实体键含 title：与下方 snap.Title 用的是同一个归一化后的 title，保证查重口径与落库内容一致，
 	// 同城同年的不同专题（Day 2 / Day 3）因此不会被误判为重复。
-	reuseID, existStatus, exist, err := s.repo.StreetSnapEntityState(ctx, p.City, p.Year, p.TitleEn)
+	// 标题先经 NormalizeStreetTitle 归一化（空白折叠），消除「纯空白微调」造成的重复实体（设计规格 §12.4）。
+	title := repository.NormalizeStreetTitle(p.TitleEn)
+	reuseID, existStatus, exist, err := s.repo.StreetSnapEntityState(ctx, p.City, p.Year, title)
 	if err != nil {
 		// 同 runway：读失败不得当「未命中」，否则会给同一实体留两行。fail-closed + 退避重试。
 		s.failOrRetry(ctx, job.ID, "entity lookup: "+err.Error())
@@ -465,7 +473,7 @@ func (s *IngestService) processStreet(ctx context.Context, job model.IngestJob,
 	writeStart := time.Now()
 	snap := &model.StreetSnap{
 		JobID:      job.ID,
-		Title:      p.TitleEn, // 街拍单标题，爬虫优先填 title_en
+		Title:      title, // 街拍单标题，爬虫优先填 title_en（已归一化，与查重口径一致）
 		Year:       p.Year,
 		City:       p.City,
 		Cover:      cover,
@@ -695,7 +703,7 @@ func concurrentFetch(ctx context.Context, n int, fn func(context.Context, int) d
 }
 
 // lookImageTask 是 fetchLookImages 摊平后的一张待下载任务：记录它属于哪个 look、
-// 是主图还是第几张细节图，供并发下载完成后重建 Name / LookIndex / IsDetail。
+// 是主图还是第几张细节图，供并发下载完成后重建 Name / 主副图归属 / IsDetail。
 type lookImageTask struct {
 	url      string
 	lookIdx  int  // 1-based look 序号