from cryptoai.models.user import User
from cryptoai.utils.db_manager import get_db_context, SessionLocal
from sqlalchemy.orm import Session
import logging
import requests

logger = logging.getLogger(__name__)
logger.setLevel(logging.DEBUG)

def task_run():
    try:

        #dify api
        url = "http://ai.meida.fit/v1/workflows/run"
        token = "app-ov8ji3bC6WrRlOdNt0cxPyg6"

        headers = {
            "Authorization": f"Bearer {token}",
            "Content-Type": "application/json"
        }

        payload = {
            "inputs": {},
            "response_mode": "blocking",
            "user": "system",
        }

        response = requests.post(url, headers=headers, json=payload)
        print(response.json())

    except Exception as e:
        logger.error(f"新闻获取失败: {e}")