feat(publish): B站-智能工厂四级补贴首发归档

- drafts/ 按日期+名称分类重整
- 2026-05-09_B站首发归档至published/
- 配图6张永久存档

ops/publish-wechat.py

@@ -0,0 +1,165 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+import sys
+import json
+import os
+from pathlib import Path
+from urllib.request import urlopen, Request
+from urllib.parse import urlencode, quote
+
+# WeChat API 配置
+APPID = "wx834051fbc89ae2b1"
+APPSECRET = os.environ.get("WECHAT_APPSECRET", "")
+
+class WeChatPublisher:
+    def __init__(self, appid, appsecret):
+        self.appid = appid
+        self.appsecret = appsecret
+        self.token = None
+
+    def get_token(self):
+        url = f"https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={self.appid}&secret={self.appsecret}"
+        try:
+            resp = urlopen(url, timeout=10)
+            result = json.loads(resp.read().decode('utf-8'))
+            if "access_token" in result:
+                self.token = result["access_token"]
+                return self.token
+            else:
+                print(f"获取token失败: {result}")
+                return None
+        except Exception as e:
+            print(f"Token请求失败: {e}")
+            return None
+
+    def upload_image(self, image_path):
+        if not self.token:
+            self.get_token()
+        if not self.token:
+            return None
+        
+        url = f"https://api.weixin.qq.com/cgi-bin/media/upload?access_token={self.token}&type=image"
+        try:
+            with open(image_path, 'rb') as f:
+                image_data = f.read()
+            
+            boundary = '----FormBoundary7MA4YWxkTrZu0gW'
+            body = f"--{boundary}\r\nContent-Disposition: form-data; name=\"media\"; filename=\"cover.png\"\r\nContent-Type: image/png\r\n\r\n".encode('utf-8') + image_data + f"\r\n--{boundary}--".encode('utf-8')
+            
+            req = Request(url, data=body, headers={'Content-Type': f'multipart/form-data; boundary={boundary}'})
+            resp = urlopen(req, timeout=30)
+            result = json.loads(resp.read().decode('utf-8'))
+            print(f"封面上传结果: {result}")
+            return result.get("media_id")
+        except Exception as e:
+            print(f"封面上传失败: {e}")
+            return None
+
+    def markdown_to_html(self, content):
+        """简化版 Markdown 转 HTML"""
+        import re
+        html = []
+        lines = content.split('\n')
+        in_code_block = False
+        
+        for line in lines:
+            line = line.strip()
+            if not line:
+                continue
+            
+            # 代码块
+            if line.startswith('```'):
+                if in_code_block:
+                    html.append('</code></pre>')
+                    in_code_block = False
+                else:
+                    html.append('<pre><code>')
+                    in_code_block = True
+                continue
+            
+            if in_code_block:
+                html.append(line)
+                continue
+            
+            # 标题
+            if line.startswith('# '):
+                html.append(f'<h2>{line[2:]}</h2>')
+            elif line.startswith('## '):
+                html.append(f'<h3>{line[3:]}</h3>')
+            elif line.startswith('### '):
+                html.append(f'<h4>{line[4:]}</h4>')
+            # 引用
+            elif line.startswith('>'):
+                html.append(f'<blockquote>{line[1:].strip()}</blockquote>')
+            # 列表
+            elif line.startswith('- ') or line.startswith('* '):
+                html.append(f'<li>{line[2:].strip()}</li>')
+            # 粗体/斜体
+            elif '**' in line:
+                line = re.sub(r'\*\*(.+?)\*\*', r'<strong>\1</strong>', line)
+                html.append(f'<p>{line}</p>')
+            else:
+                html.append(f'<p>{line}</p>')
+        
+        return ''.join(html)
+
+    def create_draft(self, title, content, thumb_media_id, digest=""):
+        if not self.token:
+            self.get_token()
+        if not self.token:
+            return None
+        
+        html_content = self.markdown_to_html(content)
+        draft_data = {
+            "articles": [{
+                "title": title,
+                "content": html_content,
+                "author": "上海橙轩智能",
+                "digest": digest,
+                "thumb_media_id": thumb_media_id,
+                "show_cover_pic": 1
+            }]
+        }
+        
+        url = f"https://api.weixin.qq.com/cgi-bin/draft/add?access_token={self.token}"
+        json_data = json.dumps(draft_data, ensure_ascii=False).encode('utf-8')
+        
+        try:
+            req = Request(url, data=json_data, headers={'Content-Type': 'application/json'})
+            resp = urlopen(req, timeout=30)
+            result = json.loads(resp.read().decode('utf-8'))
+            print(f"草稿创建结果: {result}")
+            return result
+        except Exception as e:
+            print(f"草稿创建失败: {e}")
+            return None
+
+    def publish(self, article_path, cover_path, title, digest=""):
+        print(f"开始发布文章：{title}")
+        
+        # 上传封面
+        media_id = self.upload_image(cover_path)
+        if not media_id:
+            print("封面上传失败，终止发布")
+            return None
+        
+        # 读取文章
+        content = Path(article_path).read_text(encoding='utf-8')
+        
+        # 创建草稿
+        result = self.create_draft(title, content, media_id, digest)
+        if result and result.get("media_id"):
+            print(f"✅ 发布成功！草稿 media_id: {result['media_id']}")
+            return result["media_id"]
+        else:
+            print(f"❌ 发布失败: {result}")
+            return None
+
+if __name__ == "__main__":
+    publisher = WeChatPublisher(APPID, APPSECRET)
+    result = publisher.publish(
+        article_path="/home/node/.openclaw/workspace/drafts/2026-04-21_公众号_协议打通-OEE提升42pct.md",
+        cover_path="/home/node/.openclaw/workspace/assets/xhs-cover-1.png",
+        title="给120台设备装一个大脑：一家工厂如何在2周内实现全协议互通"
+    )
+    print(f"最终结果: {result}")

ops/test-wechat-publish.sh

@@ -0,0 +1,10 @@
+#!/bin/bash
+export WECHAT_APPID="wx834051fbc89ae2b1"
+export WECHAT_APPSECRET="${WECHAT_APPSECRET}"
+cd /home/node/.openclaw/workspace/skills/wechat-publisher-pro
+python wechat_publish.py \
+  --article "/home/node/.openclaw/workspace/drafts/2026-04-21_公众号_协议打通-OEE提升42pct.md" \
+  --cover "/home/node/.openclaw/workspace/assets/xhs-cover-1.png" \
+  --title "给120台设备装一个大脑：一家工厂如何在2周内实现全协议互通" \
+  --appid "$WECHAT_APPID" \
+  --appsecret "$WECHAT_APPSECRET"