使用 OpenClaw 部署 DailyHot 热榜服务并实现自动化内容生成

# 首先加载环境变量
env_file = Path(__file__).parent / '.env'
if env_file.exists():
    with open(env_file) as f:
        for line in f:
            if line.strip() and '=' in line:
                key, value = line.split('=', 1)
                os.environ[key] = value

# 然后再导入其他模块
from api_client import api_client

# 修改前
self.data_dir = os.getenv("DAILY_HOT_DATA_DIR", "/root/.openclaw/...")

# 修改后
default_data_dir = os.path.join(os.getcwd(), "data")
self.data_dir = os.getenv("DAILY_HOT_DATA_DIR", default_data_dir)

async def fetch_hot_news():
    """获取热点新闻（跨平台聚合）"""
    platforms = [
        ('weibo', '微博'),
        ('zhihu', '知乎'),
        ('bilibili', 'B站'),
        ('36kr', '36氪'),
        ('baidu', '百度'),
    ]
    
    all_hot = []
    for source_id, name in platforms:
        result = await api_client.fetch_hot_list(source_id)
        if result and result.get('data'):
            for item in result.get('data', [])[:3]:
                all_hot.append({
                    'title': item.get('title', ''),
                    'platform': name,
                    'hot': item.get('hot', ''),
                })
    
    # 按热度排序
    all_hot.sort(key=lambda x: parse_hot_num(x['hot']), reverse=True)
    return all_hot[:15]

async def fetch_ai_news():
    """获取AI相关资讯"""
    ai_platforms = [
        ('36kr', '36氪'),
        ('ithome', 'IT之家'),
        ('juejin', '稀土掘金'),
    ]
    
    ai_keywords = ['AI', '人工智能', 'ChatGPT', '大模型', 'LLM', 'OpenAI', 'Claude']
    
    ai_news = []
    for source_id, name in ai_platforms:
        result = await api_client.fetch_hot_list(source_id)
        for item in result.get('data', []):
            title = item.get('title', '')
            if any(kw in title for kw in ai_keywords):
                ai_news.append(item)
    
    return ai_news[:10]

jobs = {
    "version": 1,
    "jobs": [
        {
            "id": "daily_hot_news_morning",
            "name": "每日热点新闻推送",
            "schedule": "0 8 * * *",
            "command": "python3 cron_jobs.py morning_hot_news",
            "enabled": True
        },
        {
            "id": "daily_ai_blog",
            "name": "每日AI资讯博客生成",
            "schedule": "0 10 * * *",
            "command": "python3 cron_jobs.py generate_ai_blog",
            "enabled": True
        }
    ]
}

async def send_feishu_notification(title, content):
    """发送飞书通知"""
    if not FEISHU_WEBHOOK:
        return False
    
    message = {
        "msg_type": "post",
        "content": {
            "post": {
                "zh_cn": {
                    "title": title,
                    "content": [[{"tag": "text", "text": content}]]
                }
            }
        }
    }
    
    resp = requests.post(FEISHU_WEBHOOK, json=message, timeout=30)
    return resp.json().get('code') == 0