openClaw_agent_dm/scripts/daily-fortune.js

#!/usr/bin/env node

/**
 * 每日运势推送 - 简化版
 * 
 * 功能：
 * 1. 使用 Tavily 搜索星座运势
 * 2. 查询黄历信息
 * 3. 生成运势报告
 * 4. 通过 Telegram 发送
 * 
 * 用户信息：
 * - 王院长
 * - 生日：1984 年 5 月 16 日 23:00-24:00 (子时)
 * - 星座：金牛座
 * - 生肖：鼠
 */

const https = require('https');
const http = require('http');

// 配置
const CONFIG = {
    tavilyApiKey: process.env.TAVILY_API_KEY || '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',
    telegramBotToken: process.env.TELEGRAM_BOT_TOKEN || '7047245486:AAF504oCHZpfEIx3-3VXJYSSS9XelkV6o3g',
    telegramChatId: '5237946060', // 王院长的 Telegram ID
    timezone: 'Asia/Shanghai'
};

// 用户信息
const USER = {
    name: '王院长',
    birthday: '1984-05-16',
    birthTime: '23:00-24:00 (子时)',
    zodiac: '金牛座',
    chineseZodiac: '鼠'
};

/**
 * Tavily 搜索
 */
async function tavilySearch(query, searchDepth = 'basic') {
    return new Promise((resolve, reject) => {
        const postData = JSON.stringify({
            query: query,
            search_depth: searchDepth,
            include_answer: true,
            max_results: 3
        });
        
        const options = {
            hostname: 'api.tavily.com',
            port: 443,
            path: '/search',
            method: 'POST',
            headers: {
                'Content-Type': 'application/json',
                'Content-Length': Buffer.byteLength(postData),
                'Authorization': `Bearer ${CONFIG.tavilyApiKey}`
            }
        };
        
        const req = https.request(options, (res) => {
            let data = '';
            res.on('data', (chunk) => data += chunk);
            res.on('end', () => {
                try {
                    const result = JSON.parse(data);
                    resolve(result);
                } catch (e) {
                    reject(e);
                }
            });
        });
        
        req.on('error', reject);
        req.write(postData);
        req.end();
    });
}

/**
 * 查询黄历 (使用 web 接口)
 */
async function queryAlmanac(date) {
    // 这里可以使用在线黄历 API 或网页抓取
    // 简化版：返回基础信息
    const d = new Date(date);
    const lunarMonths = ['正月','二月','三月','四月','五月','六月','七月','八月','九月','十月','冬月','腊月'];
    const lunarMonth = lunarMonths[d.getMonth()];
    const lunarDay = d.getDate();
    
    return {
        success: true,
        date: date,
        lunarDate: `农历${lunarMonth}${getLunarDay(lunarDay)}`,
        yi: ['开市', '交易', '纳财', '安床'], // 简化版，实际应该查询真实黄历
        ji: ['嫁娶', '栽种', '安葬'],
        chong: '冲鸡 煞西'
    };
}

function getLunarDay(day) {
    const days = ['初一','初二','初三','初四','初五','初六','初七','初八','初九','初十',
                  '十一','十二','十三','十四','十五','十六','十七','十八','十九','二十',
                  '廿一','廿二','廿三','廿四','廿五','廿六','廿七','廿八','廿九','三十'];
    return days[day - 1] || '未知';
}

/**
 * 八字分析 (简化版)
 */
function analyzeBazi(date, userBirthday) {
    const d = new Date(date);
    const dayOfWeek = d.getDay();
    const elements = ['金', '木', '水', '火', '土'];
    const tomorrowElement = elements[dayOfWeek % 5]; // 修正：确保索引在 0-4 范围内
    
    // 简化的五行分析
    const analysis = {
        '金': '金旺之日，适合决断和执行',
        '木': '木旺之日，适合学习和规划',
        '水': '水旺之日，适合沟通和交流',
        '火': '火旺之日，适合展示和表达',
        '土': '土旺之日，适合稳定和积累'
    };
    
    const suggestions = {
        '金': {
            lucky: ['签署合同', '做决策', '执行计划'],
            avoid: ['犹豫不决', '拖延']
        },
        '木': {
            lucky: ['学习新知', '制定计划', '拜访贵人'],
            avoid: ['冲动行事', '独自决策']
        },
        '水': {
            lucky: ['商务谈判', '团队合作', '社交活动'],
            avoid: ['与人争执', '情绪化']
        },
        '火': {
            lucky: ['演讲展示', '创意工作', '运动健身'],
            avoid: ['与人冲突', '过度消费']
        },
        '土': {
            lucky: ['整理归纳', '储蓄理财', '陪伴家人'],
            avoid: ['冒险投资', '大额支出']
        }
    };
    
    return {
        element: tomorrowElement,
        analysis: analysis[tomorrowElement],
        suggestions: suggestions[tomorrowElement]
    };
}

/**
 * 生成运势报告
 */
async function generateFortuneReport() {
    const tomorrow = new Date();
    tomorrow.setDate(tomorrow.getDate() + 1);
    const dateStr = tomorrow.toISOString().split('T')[0];
    
    console.log(`[INFO] 开始生成 ${dateStr} 的运势报告...`);
    
    // 1. 搜索星座运势
    let horoscopeText = '';
    try {
        const horoscopeResult = await tavilySearch(`${dateStr} ${USER.zodiac} 运势 星座运程`, 'basic');
        if (horoscopeResult.answer) {
            horoscopeText = horoscopeResult.answer;
        } else if (horoscopeResult.results && horoscopeResult.results.length > 0) {
            horoscopeText = horoscopeResult.results[0].content;
        } else {
            horoscopeText = `${USER.zodiac}明日运势平稳，保持积极心态。`;
        }
    } catch (e) {
        console.error('[ERROR] 星座运势搜索失败:', e.message);
        horoscopeText = `${USER.zodiac}明日运势平稳。`;
    }
    
    // 2. 查询黄历
    let almanac = {};
    try {
        almanac = await queryAlmanac(dateStr);
    } catch (e) {
        console.error('[ERROR] 黄历查询失败:', e.message);
        almanac = {
            lunarDate: '查询中',
            yi: ['待查询'],
            ji: ['待查询'],
            chong: ''
        };
    }
    
    // 3. 八字分析
    const bazi = analyzeBazi(dateStr, USER.birthday);
    
    // 4. 生成报告
    const report = {
        date: dateStr,
        user: USER.name,
        zodiac: USER.zodiac,
        chineseZodiac: USER.chineseZodiac,
        almanac: almanac,
        horoscope: horoscopeText,
        bazi: bazi
    };
    
    return report;
}

/**
 * 格式化消息
 */
function formatMessage(report) {
    const { date, user, zodiac, chineseZodiac, almanac, horoscope, bazi } = report;
    
    let message = `🌙 桐哥的每日运势提醒\n\n`;
    message += `📅 明日：${date}\n`;
    message += `♉ 星座：${zodiac}\n`;
    message += `🐭 生肖：${chineseZodiac}\n\n`;
    
    message += `✨ **星座运势**\n`;
    message += `${horoscope}\n\n`;
    
    message += `🏮 **黄历信息**\n`;
    message += `${almanac.lunarDate}\n`;
    message += `宜：${almanac.yi?.join('、') || '待查询'}\n`;
    message += `忌：${almanac.ji?.join('、') || '待查询'}\n`;
    if (almanac.chong) {
        message += `冲煞：${almanac.chong}\n`;
    }
    message += `\n`;
    
    message += `🔮 **五行分析**\n`;
    message += `明日五行：${bazi.element}\n`;
    message += `${bazi.analysis}\n\n`;
    
    message += `🎯 **趋吉避凶**\n`;
    message += `✅ 宜：${bazi.suggestions?.lucky?.join('、') || '顺其自然'}\n`;
    message += `❌ 忌：${bazi.suggestions?.avoid?.join('、') || '谨慎行事'}\n\n`;
    
    message += `_桐哥祝您明日顺心如意！_ ❤️`;
    
    return message;
}

/**
 * 发送 Telegram 消息
 */
async function sendTelegramMessage(message) {
    return new Promise((resolve, reject) => {
        const postData = JSON.stringify({
            chat_id: CONFIG.telegramChatId,
            text: message,
            parse_mode: 'Markdown'
        });
        
        const options = {
            hostname: 'api.telegram.org',
            port: 443,
            path: `/bot${CONFIG.telegramBotToken}/sendMessage`,
            method: 'POST',
            headers: {
                'Content-Type': 'application/json',
                'Content-Length': Buffer.byteLength(postData)
            }
        };
        
        const req = https.request(options, (res) => {
            let data = '';
            res.on('data', (chunk) => data += chunk);
            res.on('end', () => {
                try {
                    const result = JSON.parse(data);
                    if (result.ok) {
                        console.log('[INFO] Telegram 消息发送成功');
                        resolve(result);
                    } else {
                        console.error('[ERROR] Telegram API 错误:', result);
                        reject(new Error(result.description));
                    }
                } catch (e) {
                    reject(e);
                }
            });
        });
        
        req.on('error', reject);
        req.write(postData);
        req.end();
    });
}

/**
 * 主函数
 */
async function main() {
    try {
        console.log('[INFO] 开始执行每日运势推送...');
        
        // 生成报告
        const report = await generateFortuneReport();
        console.log('[INFO] 运势报告生成完成');
        
        // 格式化消息
        const message = formatMessage(report);
        console.log('[INFO] 消息格式化完成');
        
        // 发送消息
        await sendTelegramMessage(message);
        console.log('[INFO] 消息发送完成');
        
        console.log('\n=== 运势报告预览 ===\n');
        console.log(message);
        
    } catch (error) {
        console.error('[FATAL] 执行失败:', error);
        process.exit(1);
    }
}

// 执行
if (require.main === module) {
    main();
}

module.exports = { main, generateFortuneReport, formatMessage, sendTelegramMessage };