微信公众号-脚本简单实现，自动新建草稿并发布草稿文章，代码开源 ...

铁佛  金牌会员 | 2025-1-21 16:44:10 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 877|帖子 877|积分 2631

介绍

本来想写一个自动化发布微信公众号的小绿书的脚本。但是微信公众号官网没有小绿书的接口。
想着算了吧，写都写了，那就写一个微信普通文章的脚本吧。
写完了 就想着把脚本分享出来，给大家一起交流下。
水平有限，大佬轻喷。
 
思绪

1，获取百度热搜列表
2，给热搜图片加上文字标题
3，上传图片到微信公众号素材库
4，新建微信公众号草稿
5，发布草稿
 
前期准备

1，注册微信公众号，获取AppID和AppSecret

 
2，微信公众号接口文档（ 文档链接），参照文档进行接口调用
3，微信公众号设置IP白名单
在服务器上面获取出口外网ip
  1. curl -s https://ipinfo.io/ip
复制代码
 
环境要求

1，我使用的是python12
2，依靠就需要安装PIL库，其他库都是默认安装的
  1. (py12-ai-django5) [root@gtp-test01-cyt wxmp]# python -V
复制代码
Python 3.12.4
  1. <br>#
复制代码
import requestsimport osimport timeimport yamlimport jsonimport string
from PIL import Image, ImageDraw, ImageFont # 安装PILpip install pillow==10.4.0 # 运行脚本wxmp.py 就行python wxmp.py # 输出图片已生存到 hotimg/orgimg/2.png
图片已生存到 hotimg/orgimg/3.png
图片已生存到 hotimg/orgimg/4.png
图片已生存到 hotimg/orgimg/5.png
图片已生存到 hotimg/orgimg/6.jpg
图片已生存到 hotimg/orgimg/7.jpg
图片已生存到 hotimg/orgimg/8.png
图片已生存到 hotimg/orgimg/9.png
图片已生存到 hotimg/orgimg/10.jpg
图片已生存到 hotimg/orgimg/11.png
图片已加文字 hotimg/nowimg/2.png
图片已加文字 hotimg/nowimg/3.png
图片已加文字 hotimg/nowimg/4.png
图片已加文字 hotimg/nowimg/5.png
图片已加文字 hotimg/nowimg/6.jpg
图片已加文字 hotimg/nowimg/7.jpg
图片已加文字 hotimg/nowimg/8.png
图片已加文字 hotimg/nowimg/9.png
图片已加文字 hotimg/nowimg/10.jpg
图片已加文字 hotimg/nowimg/11.png
新建草稿成功--{'media_id': 'V4QdIouS1e-m5FaD0_0keQQMcEMKo0-3YjLoF_JqJohqywWC3Byyr81SXUi1TheO', 'item': []}
{'errcode': 0, 'errmsg': 'ok', 'publish_id': 2247483801, 'msg_data_id': 2247483801}
  
 
 获取接口token

1，由于access_token的有效期只有2小时，故需要定时刷新。
2，这里使用app_token.yaml来生存获取到的token以实时间；token在时效内返回生存的token，凌驾时效会获取新的token
  1. def get_token(
  2.         app_id='',  # 微信公众号AppID
  3.         app_secret=''  # 微信公众号AppSecret
  4. ):
  5.     """
  6.     获取token
  7.     :return:
  8.     """
  9.     url = f'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={app_id}&secret={app_secret}'
  10.     res = requests.get(url=url)
  11.     result = res.json()
  12.     if result.get('access_token'):
  13.         token = result['access_token']
  14.         print(f"获取token成功：{token[:14]}****")
  15.         return token
  16.     else:
  17.         print(f"获取token失败--{result}")
  20. def refresh_token():
  21.     """
  22.     token刷新机制
  23.     :return:
  24.     """
  25.     app_token_path = os.path.dirname(os.path.abspath(__file__)) + os.sep + 'app_token.yaml'
  26.     try:
  27.         # 读取时间和token
  28.         if not os.path.exists(app_token_path):
  29.             with open(app_token_path, 'w+') as f:
  30.                 f.write('')
  31.         cfg_token = yaml_read(app_token_path)
  32.         t = cfg_token['time']
  33.         record_token = cfg_token['token']
  34.         cur_time = time.time()
  35.         # token时间在7200s之内，返回token
  36.         if 0 < cur_time - t < 7200:
  37.             # print(f"token时效内")
  38.             return record_token
  39.         # token过期，刷新时间和token
  40.         else:
  41.             # print('token已过期')
  42.             token = get_token()
  43.             if token:
  44.                 data = {'time': time.time(), 'token': token}
  45.                 yaml_clear(app_token_path)
  46.                 yaml_write(data, app_token_path)
  47.                 return token
  48.     except TypeError:
  49.         # 获取初始时间和token
  50.         print('获取初始token')
  51.         token = get_token()
  52.         data = {'time': time.time(), 'token': token}
  53.         yaml_write(data, app_token_path)
  54.         return token
  57. def yaml_read(file):
  58.     """
  59.     yaml文件读取
  60.     :param file:
  61.     :return:
  62.     """
  63.     with open(file=file, mode="r", encoding="utf-8") as f:
  64.         data = yaml.safe_load(f.read())
  65.     return data
  68. def yaml_write(data, file):
  69.     """
  70.     yaml文件写入
  71.     :param data:
  72.     :param file:
  73.     :return:
  74.     """
  75.     with open(file, 'a', encoding='utf-8') as f:
  76.         yaml.dump(
  77.             data,
  78.             stream=f,
  79.             allow_unicode=True,  # 避免unicode编码问题
  80.             sort_keys=False  # 不自动排序
  81.         )
  84. def yaml_clear(file):
  85.     """
  86.     yaml文件清空
  87.     :param file:
  88.     :return:
  89.     """
  90.     with open(file, 'w', encoding='utf-8') as f:
  91.         f.truncate()
复制代码
 
获取热搜

这里我是找的网上别人写好的接口。简单快速方便
  1. https://dabenshi.cn/other/api/hot.php?type=douyinhot // 抖音热点
  2. https://dabenshi.cn/other/api/hot.php?type=toutiaoHot // 头条热榜
  3. https://dabenshi.cn/other/api/hot.php?type=baidu // 百度热搜
复制代码
我这里使用的是百度热搜。
 
获取热搜数据
  1. # 获取热搜数据def get_hotdata():    '''    获取百度热搜的数据    url网上找的: https://dabenshi.cn/other/api/hot.php?type=baidu    '''    url = f"https://dabenshi.cn/other/api/hot.php?type=baidu"    hotdata = [] # 存储所有的热搜数据    res = requests.get(url=url)    result = res.json()    hotdata = result['data'][1:11]    # 这里我只拿了10条数据
  3. <br># 数据就是一个打列表，里面有字典
  4. hotdata =[
复制代码
  1. <em id="__mceDel">        {
  2.             "index": 2,
  3.             "title": "外交部回应是否邀请特朗普访华",
  4.             "desc": "1月21日，外交部就“中方是否邀请特朗普访华”一事做出回应：愿同美国新政府保持沟通，加强合作。",
  5.             "pic": "https:\/\/fyb-2.cdn.bcebos.com\/hotboard_image\/4d0700b48e6c791e29f1e231e24af061",
  6.             "url": "https:\/\/www.baidu.com\/s?wd=%E5%A4%96%E4%BA%A4%E9%83%A8%E5%9B%9E%E5%BA%94%E6%98%AF%E5%90%A6%E9%82%80%E8%AF%B7%E7%89%B9%E6%9C%97%E6%99%AE%E8%AE%BF%E5%8D%8E&sa=fyb_news&rsv_dl=fyb_news",
  7.             "hot": "797.6万",
  8.             "mobilUrl": "https:\/\/www.baidu.com\/s?wd=%E5%A4%96%E4%BA%A4%E9%83%A8%E5%9B%9E%E5%BA%94%E6%98%AF%E5%90%A6%E9%82%80%E8%AF%B7%E7%89%B9%E6%9C%97%E6%99%AE%E8%AE%BF%E5%8D%8E&sa=fyb_news&rsv_dl=fyb_news"
  9.         }<br>]</em>
复制代码
 
下载热搜图片

实在就是把热搜数据里面的pic图片生存到了本地
如许一会就好给图片加上标题文字了
  1. def get_hotimg(hotdataall):
  2.     """
  3.     下载热搜图片
  4.     hotdata: 所有数据
  5.     """
  7.     if hotdataall:
  8.         for hotdata in hotdataall:
  9.             try:
  10.                 # 发送HTTP GET请求获取图片数据
  11.                 response = requests.get(hotdata['pic'], timeout=10)
  12.                 # 检查请求是否成功
  13.                 if response.status_code == 200:
  14.                     # 获取Content-Type头信息
  15.                     content_type = response.headers.get('Content-Type')
  17.                     # 根据Content-Type判断图片类型
  18.                     image_extension = None
  19.                     if content_type == 'image/jpeg':
  20.                         image_extension = '.jpg'
  21.                     elif content_type == 'image/png':
  22.                         image_extension = '.png'
  23.                     elif content_type == 'image/gif':
  24.                         image_extension = '.gif'
  25.                     else:
  26.                         raise Exception(f"Unsupported image type: {content_type}")
  28.                     # 以二进制写模式打开文件，并将图片数据写入文件
  29.                     img_name = "hotimg/orgimg/" + str(hotdata['index']) + image_extension
  30.                     img_name_new = "hotimg/nowimg/" + str(hotdata['index']) + image_extension
  31.                     with open(img_name, 'wb') as file:
  32.                         file.write(response.content)
  33.                     print(f'图片已保存到 {img_name}')
  35.                     hotdata['image_path'] = img_name
  36.                     hotdata['image_path_new'] = img_name_new
  37.                 else:
  38.                     print(f'下载图片失败，状态码: {response.status_code}')
  39.             except requests.RequestException as e:
  40.                 print(f'请求出现异常: {e}')
复制代码
 
给图片加上标题文字
  1. # 给图片加上文字
  2.     if hotdata:
  3.         for hotdata_in in hotdata:
  4.             image_path = hotdata_in['image_path']
  5.             image_path_new = hotdata_in['image_path_new']
  6.             text = hotdata_in['title']
  7.             max_width = 500
  9.             add_text_to_image(image_path, image_path_new, text=text, max_width=max_width)
复制代码
  1. def add_text_to_image(image_path, image_path_new, text='', max_width=500):
  2.     '''
  3.     给图片添加文字
  4.     '''
  5.     image = Image.open(image_path)
  6.     draw = ImageDraw.Draw(image)
  7.     width, height = image.size
  9.     font_size = max(30, int(width * 0.03))
  11.     font = ImageFont.truetype("ttf/feihuasongti.ttf", font_size)
  12.     text_color = (255, 255, 255)  # 黑色字体
  13.     shadow_color = (0, 0, 0)  # 黑色阴影
  14.     # text_width, text_height = draw.textsize(text, font=font)
  15.     # 获取文本尺寸
  16.     bbox = draw.textbbox((0, 0), text, font=font)
  17.     text_width = bbox[2] - bbox[0]
  18.     text_height = bbox[3] - bbox[1]
  20.     while text_width > width - 30:
  21.         font_size -= 1
  22.         font = ImageFont.truetype("ttf/feihuasongti.ttf", font_size)
  23.         # text_width, text_height = draw.textsize(text, font=font)
  24.         # 获取文本尺寸
  25.         bbox = draw.textbbox((0, 0), text, font=font)
  26.         text_width = bbox[2] - bbox[0]
  27.         text_height = bbox[3] - bbox[1]
  29.     # 计算文本位置
  30.     x = width - text_width
  31.     y = height - text_height - 30
  32.     # 绘制文本阴影
  33.     draw.text(((x/2) + 2, y + 2), text, font=font, fill=shadow_color)
  34.     draw.text((x / 2, y), text, font=font, fill=text_color)
  36.     image.save(image_path_new)
  37.     print(f'图片已加文字 {image_path_new}')
复制代码
雷同如许，在图片底部加上文字

 
上传图片素材

这块会返回上传到素材url。这个url地点，可以在文章里面使用
  1. def add_media(hotdataall):
  2.     """
  3.     新增临时素材: https://api.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE
  4.     上传图文消息内的图片获取URL, 新增永久素材: https://api.weixin.qq.com/cgi-bin/media/uploadimg?access_token=ACCESS_TOKEN
  5.     新增其他类型永久素材, 新增永久素材: https://api.weixin.qq.com/cgi-bin/material/add_material?access_token=ACCESS_TOKEN&type=TYPE
  6.     """
  7.     # url = f"https://api.weixin.qq.com/cgi-bin/media/upload?access_token={refresh_token()}&type=image"
  8.     url = f"https://api.weixin.qq.com/cgi-bin/media/uploadimg?access_token={refresh_token()}"
  10.     if hotdataall:
  11.         for hotdata in hotdataall:
  12.             with open(hotdata['image_path_new'], 'rb') as fp:
  13.                 files = {'media': fp}
  14.                 res = requests.post(url, files=files)
  15.                 res = json.loads(str(res.content, 'utf8'))
  16.                 hotdata["wx_img_url"] = res['url']
复制代码
 
新建草稿

这里会返回草稿的ID
  1. def add_draft(hotdataall):
  2.     '''
  3.     新建草稿
  4.     '''
  5.     url = f'https://api.weixin.qq.com/cgi-bin/draft/add?access_token={refresh_token()}'
  7.     # content = "<img src='https://mmbiz.qpic.cn/sz_mmbiz_jpg/hY63os7Ee2Ro6WVkfj9nvfDdpONqLwr48J2eQEYXygs3cWibLvQTHAveYWNnXOOWHO3jZldO3fr7quVj6V0X5uA/0?wx_fmt=jpeg'/>"
  8.     # 读取文件html
  9.     # 打开HTML文件并读取内容
  10.     with open('content.html', 'r', encoding='utf-8') as file:
  11.         html_content_template = file.read()
  13.     # 动态生成草稿content内容全部，先定义一个变量
  14.     html_content = ""
  16.     # 动态生成草稿content内容片段
  17.     for hotdata in hotdataall:
  18.         # 判断热搜第一
  19.         if hotdata['index'] == 2:
  20.             title_color = "red"
  21.         else:
  22.             title_color = "black"
  24.         # 定义变量
  25.         hot_context = {
  26.             'num': hotdata['index'] - 1,
  27.             'url_img': hotdata['wx_img_url'],
  28.             'title_color': title_color,
  29.             'title_title': hotdata['title'],
  30.             'describe': hotdata['desc'],
  31.         }
  33.         # 替换变量
  34.         substitute_data = string.Template(html_content_template)
  35.         result = substitute_data.safe_substitute(hot_context)
  36.         html_content += result
  38.     data = {
  39.         "articles": [
  40.             {
  41.                 "title":"标题",
  42.                 "author":"作者",
  43.                 "digest":"描述",
  44.                 "content":html_content,
  45.                 "thumb_media_id":"封面素材ID",
  46.                 "need_open_comment":1,
  47.                 "only_fans_can_comment":1
  48.             }
  49.         ]
  50.     }
  52.     res = requests.post(url=url, data=json.dumps(data, ensure_ascii=False).encode('utf-8'))
  54.     if res.status_code == 200:
  55.         result = json.loads(res.content)
  56.         if result.get('media_id'):
  57.             print(f'新建草稿成功--{result}')
  58.             return result['media_id']
  59.         else:
  60.             print(f'新建草稿失败--{result}')
  61.     else:
  62.         print(f'新建草稿失败--{res.text}')
复制代码
 
发布草稿
  1. def free_publish(media_id):
  2.     '''
  3.     发布草稿
  4.     '''
  5.     url = f'https://api.weixin.qq.com/cgi-bin/freepublish/submit?access_token={refresh_token()}'
  7.     data = {
  8.         "media_id": media_id
  9.     }
  11.     res = requests.post(url=url, json=data)
  12.     res = json.loads(str(res.content, 'utf8'))
  13.     print(res)
复制代码
 
源码

gitee：https://gitee.com/ccsang/wxmp
 
关注我的公众号

这个公众号的文章就是这个脚本定时发送的。

盼望这个脚本对你有用。欢迎交流
最近想弄些PRA，自动化弄下那些没有接口的应用的。有大佬指教吗。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

铁佛

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表