第5天：自动化工作流

#!/usr/bin/env python3
"""
每日工作简报生成器
每天早上自动汇总今日任务、本周进度、昨日完成情况
"""
import sys
import os
sys.path.append(os.path.join(os.path.dirname(__file__), '..', 'tools'))

from notion import query_database
from feishu import send
from datetime import datetime, timedelta
import json

def get_today_tasks():
    """获取今日待办任务"""
    result = query_database(
        "任务看板",
        filter_type="date",
        filter_value="今天"
    )
    return result.get("results", [])

def get_week_topics():
    """获取本周选题进度"""
    result = query_database(
        "选题库",
        filter_type="date",
        filter_value="本周"
    )
    topics = result.get("results", [])
    
    # 统计各状态数量
    completed = len([t for t in topics if "已完成" in t.get("tags", [])])
    in_progress = len([t for t in topics if "进行中" in t.get("tags", [])])
    todo = len([t for t in topics if "待开始" in t.get("tags", [])])
    
    return {
        "completed": completed,
        "in_progress": in_progress,
        "todo": todo,
        "total": len(topics)
    }

def get_yesterday_done():
    """获取昨日完成的任务"""
    result = query_database(
        "任务看板",
        filter_type="date",
        filter_value="昨天"
    )
    return [t for t in result.get("results", []) if "已完成" in t.get("tags", [])]

def format_report(tasks, topics, done):
    """格式化简报内容"""
    today = datetime.now().strftime("%Y-%m-%d")
    
    report = f"""📋 今日工作简报（{today}）

【今日待办】共 {len(tasks)} 项
"""
    
    for i, task in enumerate(tasks[:5], 1):  # 最多显示5项
        report += f"{i}. {task['title']}
"
    
    if len(tasks) > 5:
        report += f"...还有 {len(tasks) - 5} 项
"
    
    report += f"""
【本周选题进度】
• 已完成：{topics['completed']} 篇
• 进行中：{topics['in_progress']} 篇
• 待开始：{topics['todo']} 篇
"""
    
    if done:
        report += "
【昨日完成】
"
        for task in done[:3]:  # 最多显示3项
            report += f"• {task['title']} ✅
"
    
    return report

def main():
    """主函数"""
    print("开始生成每日简报...")
    
    # 获取数据
    tasks = get_today_tasks()
    topics = get_week_topics()
    done = get_yesterday_done()
    
    # 格式化简报
    report = format_report(tasks, topics, done)
    
    # 发送到飞书
    target_id = os.getenv("MY_FEISHU_ID")  # 你的飞书open_id
    result = send(target_id, report)
    
    if result.get("code") == 0:
        print("简报发送成功！")
    else:
        print(f"发送失败：{result}")

if __name__ == "__main__":
    main()

def format_progress_bar(completed, total):
    """生成进度条"""
    if total == 0:
        return "━━━━━━━━━━ 0%"
    
    percentage = int((completed / total) * 100)
    filled = int(percentage / 10)
    bar = "█" * filled + "░" * (10 - filled)
    
    return f"{bar} {percentage}%"

# 使用示例
progress = format_progress_bar(3, 10)
# 输出：███░░░░░░░ 30%