From 64fda709f70cf7aa3f92ce721879c47eb4990b01 Mon Sep 17 00:00:00 2001 From: aaron <> Date: Tue, 6 May 2025 22:59:43 +0800 Subject: [PATCH] update --- cryptoai/config/config.yaml | 1 + cryptoai/monitor_endpoint.py | 10 ++- cryptoai/monitors/important_events.py | 118 ++++++++++++++++++++++++++ docker-compose.yml | 2 +- 4 files changed, 127 insertions(+), 4 deletions(-) create mode 100644 cryptoai/monitors/important_events.py diff --git a/cryptoai/config/config.yaml b/cryptoai/config/config.yaml index de67658..4fdf4c7 100644 --- a/cryptoai/config/config.yaml +++ b/cryptoai/config/config.yaml @@ -74,6 +74,7 @@ discord: gold_webhook_url: "https://discord.com/api/webhooks/1367341235987021914/XVcjs6ZAZad3ZezzuudyiK_KqNUowqz2o2NJPdvwWY_EvwZVJcnVHq5M0-RQhkKV-FEQ" volume_growup_webhook_url: "https://discord.com/api/webhooks/1368217200023961631/yl_zZK865YLNpq7F7ISwPa6ztXEjU8_V646XxL95RF7PIGEFoLCTa_dTiabkfUaUvme0" technical_indicators_webhook_url: "https://discord.com/api/webhooks/1368420664767287296/96aYVXPfQdv0KE6BKCZJ6w4M60jNMpwyXfDm05THa7oaknnOxhWTV5t6hO9wqw3TwyNs" + important_events_webhook_url: "https://discord.com/api/webhooks/1369323413750939729/s4seRx4_CMcHFGHvzGucmNBWhCUH8FoUAbiPi24q5-Me7j0PBdongXmLlrSCUaBsoZ4r" # 数据库配置 database: diff --git a/cryptoai/monitor_endpoint.py b/cryptoai/monitor_endpoint.py index 7515315..1054265 100644 --- a/cryptoai/monitor_endpoint.py +++ b/cryptoai/monitor_endpoint.py @@ -1,21 +1,25 @@ from cryptoai.monitors.volume_growup import VolumeGrowupMonitor from cryptoai.monitors.technical_indicators import TechnicalIndicatorsMonitor +from cryptoai.monitors.important_events import ImportantEventsMonitor import schedule def run_monitor(): - volume_growup_monitor = VolumeGrowupMonitor() + # volume_growup_monitor = VolumeGroclearwupMonitor() # volume_growup_monitor.run(time_interval="5m") - technical_indicators_monitor = TechnicalIndicatorsMonitor() + # technical_indicators_monitor = TechnicalIndicatorsMonitor() # technical_indicators_monitor.run(time_interval="15m") - # return + important_events_monitor = ImportantEventsMonitor() + # important_events_monitor.run() try: print("☕️ 加密货币监控程序已启动") + schedule.every().day.at("08:00").do(important_events_monitor.run) + # # 5分钟监控，交易量增长 # for time in [":00", ":05", ":10", ":15", ":20", ":25", ":30", ":35", ":40", ":45", ":50", ":55"]: # schedule.every().hour.at(time).do(volume_growup_monitor.run, time_interval="5m") diff --git a/cryptoai/monitors/important_events.py b/cryptoai/monitors/important_events.py new file mode 100644 index 0000000..0abbeb3 --- /dev/null +++ b/cryptoai/monitors/important_events.py @@ -0,0 +1,118 @@ +import logging +from datetime import datetime, timedelta +import time +import requests +import json +from cryptoai.utils.config_loader import ConfigLoader +from cryptoai.utils.discord_bot import DiscordBot + + +logger = logging.getLogger(__name__) +logger.setLevel(logging.DEBUG) + +class ImportantEventsMonitor: + def __init__(self): + self.config = ConfigLoader() + self.webhook_url = self.config.get_discord_config()['important_events_webhook_url'] + + self.discord_bot = DiscordBot(self.webhook_url) + + + def run(self): + logger.info("获取重要事件") + + items = [] + add_days = 0 + while add_days < 14: + date = datetime.now() + timedelta(days=add_days) + events = self._get_important_events(date) + if len(events) > 0: + items.extend(events) + add_days += 1 + + content = "" + print("items length", len(items)) + for item in items: + # 计算事件临近程度 + pub_time = datetime.strptime(item['pub_time'], '%Y-%m-%d %H:%M') + + time_diff = pub_time - datetime.now() + hours_diff = time_diff.total_seconds() / 3600 + + # 根据临近程度添加标记 + urgency_indicator = "" + if hours_diff < 24: + urgency_indicator = "🔴 今日" # 24小时内 + elif hours_diff < 48: + urgency_indicator = "🟠 明日" # 48小时内 + else: + urgency_indicator = "🟢 近期" # 其他 + + # 构建星级显示 + star_display = "⭐" * item['star'] + + # 五星级数据重点标注 + is_five_star = item['star'] == 5 + title_prefix = "🔥 重要 🔥 " if is_five_star else "" + title_suffix = " 🔥🔥🔥" if is_five_star else "" + + # 使用Markdown格式构建消息 + content += f"### {title_prefix}{urgency_indicator} {item['country']} 经济数据{title_suffix}\n" + + # 五星级数据使用粗体标题 + if is_five_star: + content += f"### **{item['indicator_name']}** ({item['time_period']})\n\n" + else: + content += f"### {item['indicator_name']} ({item['time_period']})\n\n" + + # 使用列表格式展示数据 + if item['previous'] is not None: + content += f"- **前值**: {item['previous']}\n" + + if item['consensus'] is not None: + content += f"- **预测值**: {item['consensus']}\n" + + # 五星级数据的重要程度使用特殊标记 + if is_five_star: + content += f"- **重要程度**: {star_display} (最高级别)\n" + else: + content += f"- **重要程度**: {star_display}\n" + + content += f"- **公布时间**: {item['pub_time']}\n\n" + + # 五星级数据添加额外强调 + if is_five_star: + content += "**⚠️ 此为市场高度关注的重要数据，可能引起较大波动 ⚠️**\n\n" + + # 添加分隔线 + content += "---\n\n" + + print(content) + self.discord_bot.send_message(content) + + # 获取重要事件 + def _get_important_events(self, date: datetime): + url = f"https://e0430d16720e4211b5e072c26205c890.z3c.jin10.com/get/data?date={date.strftime('%Y-%m-%d')}&category=cj" + print(url) + headers = { + "x-app-id": "sKKYe29sFuJaeOCJ", + "x-version": "2.0" + } + response = requests.get(url, headers=headers) + data = response.json() + + if data['status'] != 200: + logger.error(f"获取重要事件失败: {data['message']}") + return [] + + items = [] + for item in data['data']: + if item['star'] >= 4: + items.append(item) + + return items + + +if __name__ == "__main__": + monitor = ImportantEventsMonitor() + monitor.run() diff --git a/docker-compose.yml b/docker-compose.yml index 2b2148f..7ec73b1 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -18,7 +18,7 @@ services: cryptoai-monitor: build: . container_name: cryptoai-monitor - image: cryptoai-monitor:0.0.10 + image: cryptoai-monitor:0.0.11 restart: always command: python run_monitor.py environment: