From 86fb7f65635fb76a90dec27210e3aeb3c24ccd02 Mon Sep 17 00:00:00 2001 From: Edan's Win11 <961150665@qq.com> Date: Tue, 3 Jun 2025 23:02:47 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0=20xiaohongshu=20?= =?UTF-8?q?=E7=9A=84=E7=99=BB=E5=BD=95=E5=92=8C=E5=8F=91=E5=B8=83=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- examples/get_xiaohongshu_cookie.py | 10 + examples/upload_video_to_xiaohongshu.py | 31 ++ myUtils/auth.py | 38 ++- myUtils/login.py | 77 ++++- myUtils/postVideo.py | 20 +- uploader/ks_uploader/main.py | 2 - uploader/tencent_uploader/main.py | 2 +- uploader/xiaohongshu_uploader/__init__.py | 5 + uploader/xiaohongshu_uploader/main.py | 367 ++++++++++++++++++++++ utils/files_times.py | 2 +- utils/log.py | 1 + videos/demo.txt | 2 +- 12 files changed, 535 insertions(+), 22 deletions(-) create mode 100644 examples/get_xiaohongshu_cookie.py create mode 100644 examples/upload_video_to_xiaohongshu.py create mode 100644 uploader/xiaohongshu_uploader/__init__.py create mode 100644 uploader/xiaohongshu_uploader/main.py diff --git a/examples/get_xiaohongshu_cookie.py b/examples/get_xiaohongshu_cookie.py new file mode 100644 index 0000000..03eaa23 --- /dev/null +++ b/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)) diff --git a/examples/upload_video_to_xiaohongshu.py b/examples/upload_video_to_xiaohongshu.py new file mode 100644 index 0000000..c6bc6d6 --- /dev/null +++ b/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) diff --git a/myUtils/auth.py b/myUtils/auth.py index 01d5577..013f0ef 100644 --- a/myUtils/auth.py +++ b/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) \ No newline at end of file diff --git a/myUtils/login.py b/myUtils/login.py index 9ba1f30..3136a95 100644 --- a/myUtils/login.py +++ b/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) \ No newline at end of file + +# 小红书登录 +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) diff --git a/myUtils/postVideo.py b/myUtils/postVideo.py index cb13fc0..a4a152e 100644 --- a/myUtils/postVideo.py +++ b/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) diff --git a/uploader/ks_uploader/main.py b/uploader/ks_uploader/main.py index 8785028..2ca2e6d 100644 --- a/uploader/ks_uploader/main.py +++ b/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 diff --git a/uploader/tencent_uploader/main.py b/uploader/tencent_uploader/main.py index 6baeee3..0f9d76a 100644 --- a/uploader/tencent_uploader/main.py +++ b/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: diff --git a/uploader/xiaohongshu_uploader/__init__.py b/uploader/xiaohongshu_uploader/__init__.py new file mode 100644 index 0000000..ccd5db1 --- /dev/null +++ b/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) \ No newline at end of file diff --git a/uploader/xiaohongshu_uploader/main.py b/uploader/xiaohongshu_uploader/main.py new file mode 100644 index 0000000..8c0a7d6 --- /dev/null +++ b/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) + + diff --git a/utils/files_times.py b/utils/files_times.py index a1a6ccc..14988e3 100644 --- a/utils/files_times.py +++ b/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. diff --git a/utils/log.py b/utils/log.py index e8b8354..6a4b98f 100644 --- a/utils/log.py +++ b/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') diff --git a/videos/demo.txt b/videos/demo.txt index 94b58ea..246e91f 100644 --- a/videos/demo.txt +++ b/videos/demo.txt @@ -1,2 +1,2 @@ -这位勇敢的男子为了心爱之人每天坚守 🥺❤️‍🩹 +男子为了心爱之人每天坚守❤️‍🩹 #坚持不懈 #爱情执着 #奋斗使者 #短视频 \ No newline at end of file