add 百家號上傳實現

README.MD

@@ -10,7 +10,8 @@ social-auto-upload 该项目旨在自动化发布视频到各个社交媒体平
   - [x] bilibili
   - [x] 小红书
   - [x] 快手
-  - [ ] 百家号
+  - [x] 百家号
+  - [ ] qq視頻
 
 - 部分国外社交媒体：
   - [x] tiktok

examples/get_baijiahao_cookie.py

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

examples/get_douyin_cookie.py

@@ -6,4 +6,5 @@ from uploader.douyin_uploader.main import douyin_setup
 
 if __name__ == '__main__':
     account_file = Path(BASE_DIR / "cookies" / "douyin_uploader" / "account.json")
+    account_file.parent.mkdir(exist_ok=True)
     cookie_setup = asyncio.run(douyin_setup(str(account_file), handle=True))

examples/get_kuaishou_cookie.py

@@ -6,4 +6,5 @@ from uploader.ks_uploader.main import ks_setup
 
 if __name__ == '__main__':
     account_file = Path(BASE_DIR / "cookies" / "ks_uploader" / "account.json")
+    account_file.parent.mkdir(exist_ok=True)
     cookie_setup = asyncio.run(ks_setup(str(account_file), handle=True))

examples/get_tencent_cookie.py

@@ -6,4 +6,5 @@ from uploader.tencent_uploader.main import weixin_setup
 
 if __name__ == '__main__':
     account_file = Path(BASE_DIR / "cookies" / "tencent_uploader" / "account.json")
+    account_file.parent.mkdir(exist_ok=True)
     cookie_setup = asyncio.run(weixin_setup(str(account_file), handle=True))

examples/get_tk_cookie.py

@@ -6,4 +6,5 @@ from uploader.tk_uploader.main_chrome import tiktok_setup
 
 if __name__ == '__main__':
     account_file = Path(BASE_DIR / "cookies" / "tk_uploader" / "account.json")
+    account_file.parent.mkdir(exist_ok=True)
     cookie_setup = asyncio.run(tiktok_setup(str(account_file), handle=True))

examples/upload_video_to_baijiahao.py

@@ -0,0 +1,27 @@
+import asyncio
+from pathlib import Path
+
+from conf import BASE_DIR
+from uploader.baijiahao_uploader.main import baijiahao_setup, BaiJiaHaoVideo
+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" / "baijiahao_uploader" / "account.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(baijiahao_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}")
+        app = BaiJiaHaoVideo(title, file, tags, publish_datetimes[index], account_file)
+        asyncio.run(app.main(), debug=False)

uploader/baijiahao_uploader/main.py

@@ -0,0 +1,248 @@
+# -*- coding: utf-8 -*-
+import random
+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 baijiahao_logger
+from utils.network import async_retry
+
+
+async def baijiahao_cookie_gen(account_file):
+    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://baijiahao.baidu.com/builder/theme/bjh/login")
+        await page.pause()
+        # 点击调试器的继续，保存cookie
+        await context.storage_state(path=account_file)
+        baijiahao_logger.success("cookie saved")
+
+
+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://baijiahao.baidu.com/builder/rc/home")
+        await page.wait_for_timeout(timeout=5000)
+
+        if await page.get_by_text('注册/登录百家号').count():
+            baijiahao_logger.error("等待5秒 cookie 失效")
+            return False
+        else:
+            baijiahao_logger.success("[+] cookie 有效")
+            return True
+
+
+async def baijiahao_setup(account_file, handle=False):
+    if not os.path.exists(account_file) or not await cookie_auth(account_file):
+        if not handle:
+            return False
+        baijiahao_logger.error("cookie文件不存在或已失效，即将自动打开浏览器，请扫码登录，登陆后会自动生成cookie文件")
+        await baijiahao_cookie_gen(account_file)
+    return True
+
+class BaiJiaHaoVideo(object):
+    def __init__(self, title, file_path, tags, publish_date: datetime, account_file, proxy_setting=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.proxy_setting = proxy_setting
+
+    async def set_schedule_time(self, page, publish_date):
+        """
+        todo 时间选择，日后在处理 百家号的时间选择不准确，目前是随机
+        """
+        publish_date_day = f"{publish_date.month}月{publish_date.day}日" if publish_date.day >9  else f"{publish_date.month}月0{publish_date.day}日"
+        publish_date_hour = f"{publish_date.hour}点"
+        publish_date_min = f"{publish_date.minute}分"
+        await page.wait_for_selector('div.select-wrap', timeout=5000)
+        for _ in range(3):
+            try:
+                await page.locator('div.select-wrap').nth(0).click()
+                await page.wait_for_selector('div.rc-virtual-list  div.cheetah-select-item', timeout=5000)
+                break
+            except:
+                await page.locator('div.select-wrap').nth(0).click()
+        # page.locator(f'div.rc-virtual-list-holder-inner >> text={publish_date_day}').click()
+        await page.wait_for_timeout(2000)
+        await page.locator(f'div.rc-virtual-list  div.cheetah-select-item >> text={publish_date_day}').click()
+        await page.wait_for_timeout(2000)
+
+        # 改为随机点击一个 hour
+        for _ in range(3):
+            try:
+                await page.locator('div.select-wrap').nth(1).click()
+                await page.wait_for_selector('div.rc-virtual-list div.rc-virtual-list-holder-inner:visible', timeout=5000)
+                break
+            except:
+                await page.locator('div.select-wrap').nth(1).click()
+        await page.wait_for_timeout(2000)
+        current_choice_hour = await page.locator('div.rc-virtual-list:visible div.cheetah-select-item-option').count()
+        await page.wait_for_timeout(2000)
+        await page.locator('div.rc-virtual-list:visible div.cheetah-select-item-option').nth(
+            random.randint(1, current_choice_hour-3)).click()
+        # 2024.08.05 current_choice_hour的获取可能有问题，页面有7，这里获取了10，暂时硬编码至6
+
+        await page.wait_for_timeout(2000)
+        await page.locator("button >> text=定时发布").click()
+
+
+    async def handle_upload_error(self, page):
+        # 日后实现，目前没遇到
+        return
+        print("视频出错了，重新上传中")
+
+    async def upload(self, playwright: Playwright) -> None:
+        # 使用 Chromium 浏览器启动一个浏览器实例
+        browser = await playwright.chromium.launch(headless=False, executable_path=self.local_executable_path, proxy=self.proxy_setting)
+        # 创建一个浏览器上下文，使用指定的 cookie 文件
+        context = await browser.new_context(storage_state=f"{self.account_file}", user_agent='Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.4324.150 Safari/537.36')
+        # context = await set_init_script(context)
+        await context.grant_permissions(['geolocation'])
+
+        # 创建一个新的页面
+        page = await context.new_page()
+        # 访问指定的 URL
+        await page.goto("https://baijiahao.baidu.com/builder/rc/edit?type=videoV2", timeout=60000)
+        baijiahao_logger.info(f"正在上传-------{self.title}.mp4")
+        # 等待页面跳转到指定的 URL，没进入，则自动等待到超时
+        baijiahao_logger.info('正在打开主页...')
+        await page.wait_for_url("https://baijiahao.baidu.com/builder/rc/edit?type=videoV2", timeout=60000)
+
+        # 点击 "上传视频" 按钮
+        await page.locator("div[class^='video-main-container'] input").set_input_files(self.file_path)
+
+        # 等待页面跳转到指定的 URL
+        while True:
+            # 判断是是否进入视频发布页面，没进入，则自动等待到超时
+            try:
+                await page.wait_for_selector("div#formMain:visible")
+                break
+            except:
+                baijiahao_logger.info("正在等待进入视频发布页面...")
+                await asyncio.sleep(0.1)
+
+        # 填充标题和话题
+        # 这里为了避免页面变化，故使用相对位置定位：作品标题父级右侧第一个元素的input子元素
+        await asyncio.sleep(1)
+        baijiahao_logger.info("正在填充标题和话题...")
+        await self.add_title_tags(page)
+
+        upload_status = await self.uploading_video(page)
+        if not upload_status:
+            baijiahao_logger.error(f"发现上传出错了... 文件:{self.file_path}")
+            raise
+
+        # 判断视频封面图是否生成成功
+        while True:
+            baijiahao_logger.info("正在确认封面完成, 准备去点击定时/发布...")
+            if await page.locator("div.cheetah-spin-container img").count():
+                baijiahao_logger.info("封面已完成，点击定时/发布...")
+                break
+            else:
+                baijiahao_logger.info("等待封面生成...")
+                await asyncio.sleep(3)
+
+        await self.publish_video(page, self.publish_date)
+        await page.wait_for_timeout(2000)
+        if await page.locator('div.passMod_dialog-container >> text=百度安全验证:visible').count():
+            baijiahao_logger.error("出现验证，退出")
+            raise Exception("出现验证，退出")
+        await page.wait_for_url("https://baijiahao.baidu.com/builder/rc/clue**", timeout=5000)
+        baijiahao_logger.success("视频发布成功")
+
+        await context.storage_state(path=self.account_file)  # 保存cookie
+        baijiahao_logger.info('cookie更新完毕！')
+        await asyncio.sleep(2)  # 这里延迟是为了方便眼睛直观的观看
+        # 关闭浏览器上下文和浏览器实例
+        await context.close()
+        await browser.close()
+
+
+    @async_retry(timeout=300)  # 例如，最多重试3次，超时时间为180秒
+    async def uploading_video(self, page):
+        while True:
+            upload_failed = await page.locator('div .cover-overlay:has-text("上传失败")').count()
+            if upload_failed:
+                baijiahao_logger.error("发现上传出错了...")
+                # await self.handle_upload_error(page)  # 假设这是处理上传错误的函数
+                return False
+
+            uploading = await page.locator('div .cover-overlay:has-text("上传中")').count()
+            if uploading:
+                baijiahao_logger.info("正在上传视频中...")
+                await asyncio.sleep(2)  # 等待2秒再次检查
+                continue
+
+            # 检查上传是否成功
+            if not uploading and not upload_failed:
+                baijiahao_logger.success("视频上传完毕")
+                return True
+
+    async def set_schedule_publish(self, page, publish_date):
+        while True:
+            schedule_element = page.locator("div.op-btn-outter-content >> text=定时发布").locator("..").locator(
+                'button')
+            try:
+                await schedule_element.click()
+                await page.wait_for_selector('div.select-wrap:visible', timeout=3000)
+                await page.wait_for_timeout(timeout=2000)
+                baijiahao_logger.info("开始点击发布定时...")
+                await self.set_schedule_time(page, publish_date)
+                break
+            except Exception as e:
+                baijiahao_logger.error(f"定时发布失败: {e}")
+                raise  # 重新抛出异常，让重试装饰器捕获
+
+    @async_retry(timeout=300)  # 例如，最多重试3次，超时时间为180秒
+    async def publish_video(self, page: Page, publish_date):
+        if publish_date != 0:
+            # 定时发布
+            await self.set_schedule_publish(page, publish_date)
+        else:
+            # 立即发布
+            await self.direct_publish(page)
+
+    async def direct_publish(self, page):
+        try:
+            publish_button = page.locator("button >> text=发布")
+            if await publish_button.count():
+                await publish_button.click()
+        except Exception as e:
+            baijiahao_logger.error(f"直接发布视频失败: {e}")
+            raise  # 重新抛出异常，让重试装饰器捕获
+
+    async def add_title_tags(self, page):
+        title_container = page.get_by_placeholder('添加标题获得更多推荐')
+        if len(self.title) <= 8:
+            self.title += " 你不知道的"
+        await title_container.fill(self.title[:30])
+
+    async def main(self):
+        async with async_playwright() as playwright:
+            await self.upload(playwright)
+

utils/log.py

@@ -49,3 +49,4 @@ xhs_logger = create_logger('xhs', 'logs/xhs.log')
 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')

utils/network.py

@@ -0,0 +1,28 @@
+import asyncio
+import time
+from functools import wraps
+
+
+def async_retry(timeout=60, max_retries=None):
+    def decorator(func):
+        @wraps(func)
+        async def wrapper(*args, **kwargs):
+            start_time = time.time()
+            attempts = 0
+            while True:
+                try:
+                    return await func(*args, **kwargs)
+                except Exception as e:
+                    attempts += 1
+                    if max_retries is not None and attempts >= max_retries:
+                        print(f"Reached maximum retries of {max_retries}.")
+                        raise Exception(f"Failed after {max_retries} retries.") from e
+                    if time.time() - start_time > timeout:
+                        print(f"Function timeout after {timeout} seconds.")
+                        raise TimeoutError(f"Function execution exceeded {timeout} seconds timeout.") from e
+                    print(f"Attempt {attempts} failed: {e}. Retrying...")
+                    await asyncio.sleep(1)  # Sleep to avoid tight loop or provide backoff logic here
+
+        return wrapper
+
+    return decorator