feat: 增加 xiaohongshu 的登录和发布相关脚本

examples/get_xiaohongshu_cookie.py

@@ -0,0 +1,10 @@
+import asyncio
+from pathlib import Path
+
+from conf import BASE_DIR
+from uploader.xiaohongshu_uploader.main import xiaohongshu_setup
+
+if __name__ == '__main__':
+    account_file = Path(BASE_DIR / "cookies" / "xiaohongshu_uploader" / "account.json")
+    account_file.parent.mkdir(exist_ok=True)
+    cookie_setup = asyncio.run(xiaohongshu_setup(str(account_file), handle=True))

examples/upload_video_to_xiaohongshu.py

@@ -0,0 +1,31 @@
+import asyncio
+from pathlib import Path
+
+from conf import BASE_DIR
+from uploader.xiaohongshu_uploader.main import xiaohongshu_setup, XiaoHongShuVideo
+from utils.files_times import generate_schedule_time_next_day, get_title_and_hashtags
+
+
+if __name__ == '__main__':
+    filepath = Path(BASE_DIR) / "videos"
+    account_file = Path(BASE_DIR / "cookies" / "xiaohongshu_uploader" / "58a391ba-4082-11f0-a321-44e51723d63c.json")
+    # 获取视频目录
+    folder_path = Path(filepath)
+    # 获取文件夹中的所有文件
+    files = list(folder_path.glob("*.mp4"))
+    file_num = len(files)
+    publish_datetimes = generate_schedule_time_next_day(file_num, 1, daily_times=[16])
+    cookie_setup = asyncio.run(xiaohongshu_setup(account_file, handle=False))
+    for index, file in enumerate(files):
+        title, tags = get_title_and_hashtags(str(file))
+        thumbnail_path = file.with_suffix('.png')
+        # 打印视频文件名、标题和 hashtag
+        print(f"视频文件名：{file}")
+        print(f"标题：{title}")
+        print(f"Hashtag：{tags}")
+        # 暂时没有时间修复封面上传，故先隐藏掉该功能
+        # if thumbnail_path.exists():
+            # app = XiaoHongShuVideo(title, file, tags, publish_datetimes[index], account_file, thumbnail_path=thumbnail_path)
+        # else:
+        app = XiaoHongShuVideo(title, file, tags, 0, account_file)
+        asyncio.run(app.main(), debug=False)

myUtils/auth.py

@@ -71,22 +71,36 @@ async def cookie_auth_ks(account_file):
             return True
 
 
+async def cookie_auth_xhs(account_file):
+    async with async_playwright() as playwright:
+        browser = await playwright.chromium.launch(headless=True)
+        context = await browser.new_context(storage_state=account_file)
+        context = await set_init_script(context)
+        # 创建一个新的页面
+        page = await context.new_page()
+        # 访问指定的 URL
+        await page.goto("https://creator.xiaohongshu.com/creator-micro/content/upload")
+        try:
+            await page.wait_for_url("https://creator.xiaohongshu.com/creator-micro/content/upload", timeout=5000)
+        except:
+            print("[+] 等待5秒 cookie 失效")
+            await context.close()
+            await browser.close()
+            return False
+        # 2024.06.17 抖音创作者中心改版
+        if await page.get_by_text('手机号登录').count() or await page.get_by_text('扫码登录').count():
+            print("[+] 等待5秒 cookie 失效")
+            return False
+        else:
+            print("[+] cookie 有效")
+            return True
+
 
 async def check_cookie(type,file_path):
     match type:
         # 小红书
         case 1:
-            config = configparser.RawConfigParser()
-            config.read(Path(BASE_DIR / "cookiesFile" / file_path))
-            cookies = config['account1']['cookies']
-            xhs_client = XhsClient(cookies, sign=sign_local, timeout=60)
-            # auth cookie
-            # 注意：该校验cookie方式可能并没那么准确
-            try:
-                xhs_client.get_video_first_frame_image_id("3214")
-            except:
-                print("cookie 失效")
-            return True
+            return await cookie_auth_xhs(Path(BASE_DIR / "cookiesFile" / file_path))
         # 视频号
         case 2:
             return await cookie_auth_tencent(Path(BASE_DIR / "cookiesFile" / file_path))
@@ -99,5 +113,5 @@ async def check_cookie(type,file_path):
         case _:
             return False
 
-# a = asyncio.run(check_cookie(4,"3a6cfdc0-3d51-11f0-8507-44e51723d63c.json"))
+# a = asyncio.run(check_cookie(1,"3a6cfdc0-3d51-11f0-8507-44e51723d63c.json"))
 # print(a)

myUtils/login.py

@@ -217,6 +217,77 @@ async def get_ks_cookie(id,status_queue):
             conn.commit()
             print("✅ 用户状态已记录")
         status_queue.put("200")
-#
-# a = asyncio.run(douyin_cookie_gen(2,None))
-# print(a)
+
+# 小红书登录
+async def xiaohongshu_cookie_gen(id,status_queue):
+    url_changed_event = asyncio.Event()
+
+    async def on_url_change():
+        # 检查是否是主框架的变化
+        if page.url != original_url:
+            url_changed_event.set()
+
+    async with async_playwright() as playwright:
+        options = {
+            'args': [
+                '--lang en-GB'
+            ],
+            'headless': False,  # Set headless option here
+        }
+        # Make sure to run headed.
+        browser = await playwright.chromium.launch(**options)
+        # Setup context however you like.
+        context = await browser.new_context()  # Pass any options
+        context = await set_init_script(context)
+        # Pause the page, and start recording manually.
+        page = await context.new_page()
+        await page.goto("https://creator.xiaohongshu.com/")
+        await page.locator('img.css-wemwzq').click()
+
+        img_locator = page.get_by_role("img").nth(2)
+        # 获取 src 属性值
+        src = await img_locator.get_attribute("src")
+        original_url = page.url
+        print("✅ 图片地址:", src)
+        status_queue.put(src)
+        # 监听页面的 'framenavigated' 事件，只关注主框架的变化
+        page.on('framenavigated',
+                lambda frame: asyncio.create_task(on_url_change()) if frame == page.main_frame else None)
+
+        try:
+            # 等待 URL 变化或超时
+            await asyncio.wait_for(url_changed_event.wait(), timeout=200)  # 最多等待 200 秒
+            print("监听页面跳转成功")
+        except asyncio.TimeoutError:
+            status_queue.put("500")
+            print("监听页面跳转超时")
+            await page.close()
+            await context.close()
+            await browser.close()
+            return None
+        uuid_v1 = uuid.uuid1()
+        print(f"UUID v1: {uuid_v1}")
+        await context.storage_state(path=Path(BASE_DIR / "cookiesFile" / f"{uuid_v1}.json"))
+        result = await check_cookie(1, f"{uuid_v1}.json")
+        if not result:
+            status_queue.put("500")
+            await page.close()
+            await context.close()
+            await browser.close()
+            return None
+        await page.close()
+        await context.close()
+        await browser.close()
+
+        with sqlite3.connect(Path(BASE_DIR / "db" / "database.db")) as conn:
+            cursor = conn.cursor()
+            cursor.execute('''
+                           INSERT INTO user_info (type, filePath, userName, status)
+                           VALUES (?, ?, ?, ?)
+                           ''', (1, f"{uuid_v1}.json", id, 1))
+            conn.commit()
+            print("✅ 用户状态已记录")
+        status_queue.put("200")
+
+# a = asyncio.run(xiaohongshu_cookie_gen(4,None))
+# print(a)

myUtils/postVideo.py

@@ -5,6 +5,7 @@ from conf import BASE_DIR
 from uploader.douyin_uploader.main import DouYinVideo
 from uploader.ks_uploader.main import KSVideo
 from uploader.tencent_uploader.main import TencentVideo
+from uploader.xiaohongshu_uploader.main import XiaoHongShuVideo
 from utils.constant import TencentZoneTypes
 from utils.files_times import generate_schedule_time_next_day
 
@@ -65,8 +66,23 @@ def post_video_ks(title,files,tags,account_file,category=TencentZoneTypes.LIFEST
             app = KSVideo(title, str(file), tags, publish_datetimes[index], cookie)
             asyncio.run(app.main(), debug=False)
 
-# def post_every_type(list):
-#     for task_dist in list:
+def post_video_xhs(title,files,tags,account_file,category=TencentZoneTypes.LIFESTYLE.value,enableTimer=False,videos_per_day = 1, daily_times=None,start_days = 0):
+    # 生成文件的完整路径
+    account_file = [Path(BASE_DIR / "cookiesFile" / file) for file in account_file]
+    files = [Path(BASE_DIR / "videoFile" / file) for file in files]
+    file_num = len(files)
+    if enableTimer:
+        publish_datetimes = generate_schedule_time_next_day(file_num, videos_per_day, daily_times,start_days)
+    else:
+        publish_datetimes = 0
+    for index, file in enumerate(files):
+        for cookie in account_file:
+            # 打印视频文件名、标题和 hashtag
+            print(f"视频文件名：{file}")
+            print(f"标题：{title}")
+            print(f"Hashtag：{tags}")
+            app = XiaoHongShuVideo(title, file, tags, publish_datetimes, cookie)
+            asyncio.run(app.main(), debug=False)
 
 
 

uploader/ks_uploader/main.py

@@ -89,8 +89,6 @@ class KSVideo(object):
             )  # 创建一个浏览器上下文，使用指定的 cookie 文件
         context = await browser.new_context(storage_state=f"{self.account_file}")
         context = await set_init_script(context)
-        context.on("close", lambda: context.storage_state(path=self.account_file))
-
         # 创建一个新的页面
         page = await context.new_page()
         # 访问指定的 URL

uploader/tencent_uploader/main.py

@@ -188,7 +188,7 @@ class TencentVideo(object):
                 publish_buttion = page.locator('div.form-btns button:has-text("发表")')
                 if await publish_buttion.count():
                     await publish_buttion.click()
-                await page.wait_for_url("https://channels.weixin.qq.com/platform/post/list", timeout=1500)
+                await page.wait_for_url("https://channels.weixin.qq.com/platform/post/list", timeout=5000)
                 tencent_logger.success("  [-]视频发布成功")
                 break
             except Exception as e:

uploader/xiaohongshu_uploader/__init__.py

@@ -0,0 +1,5 @@
+from pathlib import Path
+
+from conf import BASE_DIR
+
+Path(BASE_DIR / "cookies" / "xiaohongshu_uploader").mkdir(exist_ok=True)

uploader/xiaohongshu_uploader/main.py

@@ -0,0 +1,367 @@
+# -*- coding: utf-8 -*-
+from datetime import datetime
+
+from playwright.async_api import Playwright, async_playwright, Page
+import os
+import asyncio
+
+from conf import LOCAL_CHROME_PATH
+from utils.base_social_media import set_init_script
+from utils.log import xiaohongshu_logger
+
+
+async def cookie_auth(account_file):
+    async with async_playwright() as playwright:
+        browser = await playwright.chromium.launch(headless=True)
+        context = await browser.new_context(storage_state=account_file)
+        context = await set_init_script(context)
+        # 创建一个新的页面
+        page = await context.new_page()
+        # 访问指定的 URL
+        await page.goto("https://creator.xiaohongshu.com/creator-micro/content/upload")
+        try:
+            await page.wait_for_url("https://creator.xiaohongshu.com/creator-micro/content/upload", timeout=5000)
+        except:
+            print("[+] 等待5秒 cookie 失效")
+            await context.close()
+            await browser.close()
+            return False
+        # 2024.06.17 抖音创作者中心改版
+        if await page.get_by_text('手机号登录').count() or await page.get_by_text('扫码登录').count():
+            print("[+] 等待5秒 cookie 失效")
+            return False
+        else:
+            print("[+] cookie 有效")
+            return True
+
+
+async def xiaohongshu_setup(account_file, handle=False):
+    if not os.path.exists(account_file) or not await cookie_auth(account_file):
+        if not handle:
+            # Todo alert message
+            return False
+        xiaohongshu_logger.info('[+] cookie文件不存在或已失效，即将自动打开浏览器，请扫码登录，登陆后会自动生成cookie文件')
+        await xiaohongshu_cookie_gen(account_file)
+    return True
+
+
+async def xiaohongshu_cookie_gen(account_file):
+    async with async_playwright() as playwright:
+        options = {
+            'headless': False
+        }
+        # Make sure to run headed.
+        browser = await playwright.chromium.launch(**options)
+        # Setup context however you like.
+        context = await browser.new_context()  # Pass any options
+        context = await set_init_script(context)
+        # Pause the page, and start recording manually.
+        page = await context.new_page()
+        await page.goto("https://creator.xiaohongshu.com/")
+        await page.pause()
+        # 点击调试器的继续，保存cookie
+        await context.storage_state(path=account_file)
+
+
+class XiaoHongShuVideo(object):
+    def __init__(self, title, file_path, tags, publish_date: datetime, account_file, thumbnail_path=None):
+        self.title = title  # 视频标题
+        self.file_path = file_path
+        self.tags = tags
+        self.publish_date = publish_date
+        self.account_file = account_file
+        self.date_format = '%Y年%m月%d日 %H:%M'
+        self.local_executable_path = LOCAL_CHROME_PATH
+        self.thumbnail_path = thumbnail_path
+
+    async def set_schedule_time_xiaohongshu(self, page, publish_date):
+        print("  [-] 正在设置定时发布时间...")
+        print(f"publish_date: {publish_date}")
+
+        # 使用文本内容定位元素
+        # element = await page.wait_for_selector(
+        #     'label:has-text("定时发布")',
+        #     timeout=5000  # 5秒超时时间
+        # )
+        # await element.click()
+
+        # # 选择包含特定文本内容的 label 元素
+        label_element = page.locator("label:has-text('定时发布')")
+        # # 在选中的 label 元素下点击 checkbox
+        await label_element.click()
+        await asyncio.sleep(1)
+        publish_date_hour = publish_date.strftime("%Y-%m-%d %H:%M")
+        print(f"publish_date_hour: {publish_date_hour}")
+
+        await asyncio.sleep(1)
+        await page.locator('.el-input__inner[placeholder="选择日期和时间"]').click()
+        await page.keyboard.press("Control+KeyA")
+        await page.keyboard.type(str(publish_date_hour))
+        await page.keyboard.press("Enter")
+
+        await asyncio.sleep(1)
+
+    async def handle_upload_error(self, page):
+        xiaohongshu_logger.info('视频出错了，重新上传中')
+        await page.locator('div.progress-div [class^="upload-btn-input"]').set_input_files(self.file_path)
+
+    async def upload(self, playwright: Playwright) -> None:
+        # 使用 Chromium 浏览器启动一个浏览器实例
+        if self.local_executable_path:
+            browser = await playwright.chromium.launch(headless=False, executable_path=self.local_executable_path)
+        else:
+            browser = await playwright.chromium.launch(headless=False)
+        # 创建一个浏览器上下文，使用指定的 cookie 文件
+        context = await browser.new_context(
+            viewport={"width": 1600, "height": 900},
+            storage_state=f"{self.account_file}"
+        )
+        context = await set_init_script(context)
+
+        # 创建一个新的页面
+        page = await context.new_page()
+        # 访问指定的 URL
+        await page.goto("https://creator.xiaohongshu.com/publish/publish?from=homepage&target=video")
+        xiaohongshu_logger.info(f'[+]正在上传-------{self.title}.mp4')
+        # 等待页面跳转到指定的 URL，没进入，则自动等待到超时
+        xiaohongshu_logger.info(f'[-] 正在打开主页...')
+        await page.wait_for_url("https://creator.xiaohongshu.com/publish/publish?from=homepage&target=video")
+        # 点击 "上传视频" 按钮
+        await page.locator("div[class^='upload-content'] input[class='upload-input']").set_input_files(self.file_path)
+
+        # 等待页面跳转到指定的 URL 2025.01.08修改在原有基础上兼容两种页面
+        while True:
+            try:
+                # 等待upload-input元素出现
+                upload_input = await page.wait_for_selector('input.upload-input', timeout=3000)
+                # 获取下一个兄弟元素
+                preview_new = await upload_input.query_selector(
+                    'xpath=following-sibling::div[contains(@class, "preview-new")]')
+                if preview_new:
+                    # 在preview-new元素中查找包含"上传成功"的stage元素
+                    stage_elements = await preview_new.query_selector_all('div.stage')
+                    upload_success = False
+                    for stage in stage_elements:
+                        text_content = await page.evaluate('(element) => element.textContent', stage)
+                        if '上传成功' in text_content:
+                            upload_success = True
+                            break
+                    if upload_success:
+                        xiaohongshu_logger.info("[+] 检测到上传成功标识!")
+                        break  # 成功检测到上传成功后跳出循环
+                    else:
+                        print("  [-] 未找到上传成功标识，继续等待...")
+                else:
+                    print("  [-] 未找到预览元素，继续等待...")
+                    await asyncio.sleep(1)
+            except Exception as e:
+                print(f"  [-] 检测过程出错: {str(e)}，重新尝试...")
+                await asyncio.sleep(0.5)  # 等待0.5秒后重新尝试
+
+        # 填充标题和话题
+        # 检查是否存在包含输入框的元素
+        # 这里为了避免页面变化，故使用相对位置定位：作品标题父级右侧第一个元素的input子元素
+        await asyncio.sleep(1)
+        xiaohongshu_logger.info(f'  [-] 正在填充标题和话题...')
+        title_container = page.locator('div.input.titleInput').locator('input.d-text')
+        if await title_container.count():
+            await title_container.fill(self.title[:30])
+        else:
+            titlecontainer = page.locator(".notranslate")
+            await titlecontainer.click()
+            await page.keyboard.press("Backspace")
+            await page.keyboard.press("Control+KeyA")
+            await page.keyboard.press("Delete")
+            await page.keyboard.type(self.title)
+            await page.keyboard.press("Enter")
+        css_selector = ".ql-editor" # 不能加上 .ql-blank 属性，这样只能获取第一次非空状态
+        for index, tag in enumerate(self.tags, start=1):
+            await page.type(css_selector, "#" + tag)
+            await page.press(css_selector, "Space")
+        xiaohongshu_logger.info(f'总共添加{len(self.tags)}个话题')
+
+        # while True:
+        #     # 判断重新上传按钮是否存在，如果不存在，代表视频正在上传，则等待
+        #     try:
+        #         #  新版：定位重新上传
+        #         number = await page.locator('[class^="long-card"] div:has-text("重新上传")').count()
+        #         if number > 0:
+        #             xiaohongshu_logger.success("  [-]视频上传完毕")
+        #             break
+        #         else:
+        #             xiaohongshu_logger.info("  [-] 正在上传视频中...")
+        #             await asyncio.sleep(2)
+
+        #             if await page.locator('div.progress-div > div:has-text("上传失败")').count():
+        #                 xiaohongshu_logger.error("  [-] 发现上传出错了... 准备重试")
+        #                 await self.handle_upload_error(page)
+        #     except:
+        #         xiaohongshu_logger.info("  [-] 正在上传视频中...")
+        #         await asyncio.sleep(2)
+        
+        # 上传视频封面
+        # await self.set_thumbnail(page, self.thumbnail_path)
+
+        # 更换可见元素
+        # await self.set_location(page, "青岛市")
+
+        # # 頭條/西瓜
+        # third_part_element = '[class^="info"] > [class^="first-part"] div div.semi-switch'
+        # # 定位是否有第三方平台
+        # if await page.locator(third_part_element).count():
+        #     # 检测是否是已选中状态
+        #     if 'semi-switch-checked' not in await page.eval_on_selector(third_part_element, 'div => div.className'):
+        #         await page.locator(third_part_element).locator('input.semi-switch-native-control').click()
+
+        if self.publish_date != 0:
+            await self.set_schedule_time_xiaohongshu(page, self.publish_date)
+
+        # 判断视频是否发布成功
+        while True:
+            try:
+                # 等待包含"定时发布"文本的button元素出现并点击
+                if self.publish_date != 0:
+                    await page.locator('button:has-text("定时发布")').click()
+                else:
+                    await page.locator('button:has-text("发布")').click()
+                await page.wait_for_url(
+                    "https://creator.xiaohongshu.com/publish/success?**",
+                    timeout=3000
+                )  # 如果自动跳转到作品页面，则代表发布成功
+                xiaohongshu_logger.success("  [-]视频发布成功")
+                break
+            except:
+                xiaohongshu_logger.info("  [-] 视频正在发布中...")
+                await page.screenshot(full_page=True)
+                await asyncio.sleep(0.5)
+
+        await context.storage_state(path=self.account_file)  # 保存cookie
+        xiaohongshu_logger.success('  [-]cookie更新完毕！')
+        await asyncio.sleep(2)  # 这里延迟是为了方便眼睛直观的观看
+        # 关闭浏览器上下文和浏览器实例
+        await context.close()
+        await browser.close()
+    
+    async def set_thumbnail(self, page: Page, thumbnail_path: str):
+        if thumbnail_path:
+            await page.click('text="选择封面"')
+            await page.wait_for_selector("div.semi-modal-content:visible")
+            await page.click('text="设置竖封面"')
+            await page.wait_for_timeout(2000)  # 等待2秒
+            # 定位到上传区域并点击
+            await page.locator("div[class^='semi-upload upload'] >> input.semi-upload-hidden-input").set_input_files(thumbnail_path)
+            await page.wait_for_timeout(2000)  # 等待2秒
+            await page.locator("div[class^='extractFooter'] button:visible:has-text('完成')").click()
+            # finish_confirm_element = page.locator("div[class^='confirmBtn'] >> div:has-text('完成')")
+            # if await finish_confirm_element.count():
+            #     await finish_confirm_element.click()
+            # await page.locator("div[class^='footer'] button:has-text('完成')").click()
+
+    async def set_location(self, page: Page, location: str = "青岛市"):
+        print(f"开始设置位置: {location}")
+        
+        # 点击地点输入框
+        print("等待地点输入框加载...")
+        loc_ele = await page.wait_for_selector('div.d-text.d-select-placeholder.d-text-ellipsis.d-text-nowrap')
+        print(f"已定位到地点输入框: {loc_ele}")
+        await loc_ele.click()
+        print("点击地点输入框完成")
+        
+        # 输入位置名称
+        print(f"等待1秒后输入位置名称: {location}")
+        await page.wait_for_timeout(1000)
+        await page.keyboard.type(location)
+        print(f"位置名称输入完成: {location}")
+        
+        # 等待下拉列表加载
+        print("等待下拉列表加载...")
+        dropdown_selector = 'div.d-popover.d-popover-default.d-dropdown.--size-min-width-large'
+        await page.wait_for_timeout(3000)
+        try:
+            await page.wait_for_selector(dropdown_selector, timeout=3000)
+            print("下拉列表已加载")
+        except:
+            print("下拉列表未按预期显示，可能结构已变化")
+        
+        # 增加等待时间以确保内容加载完成
+        print("额外等待1秒确保内容渲染完成...")
+        await page.wait_for_timeout(1000)
+        
+        # 尝试更灵活的XPath选择器
+        print("尝试使用更灵活的XPath选择器...")
+        flexible_xpath = (
+            f'//div[contains(@class, "d-popover") and contains(@class, "d-dropdown")]'
+            f'//div[contains(@class, "d-options-wrapper")]'
+            f'//div[contains(@class, "d-grid") and contains(@class, "d-options")]'
+            f'//div[contains(@class, "name") and text()="{location}"]'
+        )
+        await page.wait_for_timeout(3000)
+        
+        # 尝试定位元素
+        print(f"尝试定位包含'{location}'的选项...")
+        try:
+            # 先尝试使用更灵活的选择器
+            location_option = await page.wait_for_selector(
+                flexible_xpath,
+                timeout=3000
+            )
+            
+            if location_option:
+                print(f"使用灵活选择器定位成功: {location_option}")
+            else:
+                # 如果灵活选择器失败，再尝试原选择器
+                print("灵活选择器未找到元素，尝试原始选择器...")
+                location_option = await page.wait_for_selector(
+                    f'//div[contains(@class, "d-popover") and contains(@class, "d-dropdown")]'
+                    f'//div[contains(@class, "d-options-wrapper")]'
+                    f'//div[contains(@class, "d-grid") and contains(@class, "d-options")]'
+                    f'/div[1]//div[contains(@class, "name") and text()="{location}"]',
+                    timeout=2000
+                )
+            
+            # 滚动到元素并点击
+            print("滚动到目标选项...")
+            await location_option.scroll_into_view_if_needed()
+            print("元素已滚动到视图内")
+            
+            # 增加元素可见性检查
+            is_visible = await location_option.is_visible()
+            print(f"目标选项是否可见: {is_visible}")
+            
+            # 点击元素
+            print("准备点击目标选项...")
+            await location_option.click()
+            print(f"成功选择位置: {location}")
+            return True
+            
+        except Exception as e:
+            print(f"定位位置失败: {e}")
+            
+            # 打印更多调试信息
+            print("尝试获取下拉列表中的所有选项...")
+            try:
+                all_options = await page.query_selector_all(
+                    '//div[contains(@class, "d-popover") and contains(@class, "d-dropdown")]'
+                    '//div[contains(@class, "d-options-wrapper")]'
+                    '//div[contains(@class, "d-grid") and contains(@class, "d-options")]'
+                    '/div'
+                )
+                print(f"找到 {len(all_options)} 个选项")
+                
+                # 打印前3个选项的文本内容
+                for i, option in enumerate(all_options[:3]):
+                    option_text = await option.inner_text()
+                    print(f"选项 {i+1}: {option_text.strip()[:50]}...")
+                    
+            except Exception as e:
+                print(f"获取选项列表失败: {e}")
+                
+            # 截图保存（取消注释使用）
+            # await page.screenshot(path=f"location_error_{location}.png")
+            return False
+
+    async def main(self):
+        async with async_playwright() as playwright:
+            await self.upload(playwright)
+
+

utils/files_times.py

@@ -38,7 +38,7 @@ def get_title_and_hashtags(filename):
     return title, hashtags
 
 
-def generate_schedule_time_next_day(total_videos, videos_per_day, daily_times=None, timestamps=False, start_days=0):
+def generate_schedule_time_next_day(total_videos, videos_per_day = 1, daily_times=None, timestamps=False, start_days=0):
     """
     Generate a schedule for video uploads, starting from the next day.
 

utils/log.py

@@ -50,3 +50,4 @@ tiktok_logger = create_logger('tiktok', 'logs/tiktok.log')
 bilibili_logger = create_logger('bilibili', 'logs/bilibili.log')
 kuaishou_logger = create_logger('kuaishou', 'logs/kuaishou.log')
 baijiahao_logger = create_logger('baijiahao', 'logs/baijiahao.log')
+xiaohongshu_logger = create_logger('xiaohongshu', 'logs/xiaohongshu.log')

videos/demo.txt

@@ -1,2 +1,2 @@
-这位勇敢的男子为了心爱之人每天坚守 🥺❤️‍🩹
+男子为了心爱之人每天坚守❤️‍🩹
 #坚持不懈 #爱情执着 #奋斗使者 #短视频