From 70f07e8327364008b803268e1f2e727efbd7f5b2 Mon Sep 17 00:00:00 2001
From: tanjun <tanjun@tanjundeMac-mini.local>
Date: Fri, 6 Feb 2026 21:03:32 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=A4=9A=E5=9B=BE=E4=B8=8A=E4=BC=A0?=
 =?UTF-8?q?=E6=94=B9=E4=B8=BA=E9=80=90=E5=BC=A0=E4=B8=8A=E4=BC=A0=EF=BC=8C?=
 =?UTF-8?q?=E9=80=82=E9=85=8D=E9=A1=B5=E9=9D=A2=20DOM=20=E5=8F=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

原实现一次性上传所有图片，但小红书页面在第一张上传后会移除
.upload-input class，导致后续图片可能上传失败。
改为逐张上传，第一张用 .upload-input，后续用 input[type="file"]，
每张独立 30s 超时，同时将 Must* 替换为错误返回。

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 xiaohongshu/publish.go | 27 +++++++++++++++++++--------
 1 file changed, 19 insertions(+), 8 deletions(-)

diff --git a/xiaohongshu/publish.go b/xiaohongshu/publish.go
index 6d64df3..2005d31 100644
--- a/xiaohongshu/publish.go
+++ b/xiaohongshu/publish.go
@@ -199,8 +199,6 @@ func isElementBlocked(elem *rod.Element) (bool, error) {
 }
 
 func uploadImages(page *rod.Page, imagesPaths []string) error {
-	pp := page.Timeout(30 * time.Second)
-
 	// 验证文件路径有效性
 	validPaths := make([]string, 0, len(imagesPaths))
 	for _, path := range imagesPaths {
@@ -209,18 +207,31 @@ func uploadImages(page *rod.Page, imagesPaths []string) error {
 			continue
 		}
 		validPaths = append(validPaths, path)
-
 		logrus.Infof("获取有效图片：%s", path)
 	}
 
-	// 等待上传输入框出现
-	uploadInput := pp.MustElement(".upload-input")
+	// 逐张上传：第一张用 .upload-input，后续页面会移除该 class，改用 input[type="file"]
+	for i, path := range validPaths {
+		selector := `input[type="file"]`
+		if i == 0 {
+			selector = ".upload-input"
+		}
 
-	// 上传多个文件
-	uploadInput.MustSetFiles(validPaths...)
+		pp := page.Timeout(60 * time.Second)
+		uploadInput, err := pp.Element(selector)
+		if err != nil {
+			return errors.Wrapf(err, "查找上传输入框失败(第%d张)", i+1)
+		}
+		if err := uploadInput.SetFiles([]string{path}); err != nil {
+			return errors.Wrapf(err, "上传第%d张图片失败", i+1)
+		}
+
+		slog.Info("图片已提交上传", "index", i+1, "path", path)
+		time.Sleep(1 * time.Second)
+	}
 
 	// 等待并验证上传完成
-	return waitForUploadComplete(pp, len(validPaths))
+	return waitForUploadComplete(page, len(validPaths))
 }
 
 // waitForUploadComplete 等待并验证上传完成