#!/usr/bin/env python
# -*- coding: utf-8 -*-

import os
import sys
import argparse
from typing import Dict, Any
import schedule
import time
import logging

# 添加项目根目录到Python路径
current_dir = os.path.dirname(os.path.abspath(__file__))
parent_dir = os.path.dirname(current_dir)
sys.path.append(parent_dir)

from cryptoai.agents.crypto_agent import CryptoAgent
from cryptoai.agents.gold_agent import GoldAgent
from cryptoai.utils.config_loader import ConfigLoader
from cryptoai.tasks.user import task_run
from cryptoai.tasks.news import task_run as news_task_run
logger = logging.getLogger(__name__)   
logger.setLevel(logging.DEBUG)

def task_start():
    try:

        # GoldAgent().start_agent()
        # CryptoAgent().start_agent("WLDUSDT")
        # return

        # logger.info("🚀 加密货币Agent程序已启动")
        # schedule.every().day.at("00:00").do(CryptoAgent().start_agent)
        schedule.every().day.at("08:00").do(CryptoAgent().start_agent)
        # schedule.every().day.at("12:00").do(CryptoAgent().start_agent)
        # schedule.every().day.at("16:00").do(CryptoAgent().start_agent)
        schedule.every().day.at("20:00").do(CryptoAgent().start_agent)

        # 每天00:00执行 用户积分复位
        logger.info("积分复位启动")
        schedule.every().day.at("00:00").do(task_run)

        # 每天08:00执行 新闻获取
        logger.info("新闻获取启动")
        schedule.every().day.at("08:00").do(news_task_run)
        schedule.every().day.at("20:00").do(news_task_run)

        while True:
            schedule.run_pending()
            time.sleep(1)
    
    except Exception as e:
        logger.error(f"程序运行出错: {e}")
        import traceback
        traceback.print_exc()