dededdew

2025-11-12 17:37:39 +08:00
parent 0302233fce
commit c6dcf4b0f3
5 changed files with 184 additions and 142 deletions
--- a/telegram/bot-v3.0.py
+++ b/telegram/bot-v3.0.py
@@ -1,4 +1,5 @@
-from nbformat.v4 import new_raw_cell
+import datetime
+import requests
 from telethon import TelegramClient, events, Button
 import sqlite3
 from datetime import date
@@ -33,7 +34,6 @@ COMMANDS = {
 }

 # ------------命令列表-------------------
-
 data = {
    "签到": ['/sign', '签到', "haha"],
    "发言": ["/daily_rank"],
@@ -53,52 +53,31 @@ def init_db():
    conn = sqlite3.connect(DB_PATH)
    cursor = conn.cursor()
    cursor.execute('''
-                   CREATE TABLE IF NOT EXISTS users
-                   (
-                       user_id
-                       INTEGER
-                       PRIMARY
-                       KEY,
-                       username
-                       TEXT,
-                       points
-                       INTEGER
-                       DEFAULT
-                       0,
-                       last_sign_date
-                       TEXT
-                   )
-                   ''')
+        CREATE TABLE IF NOT EXISTS users
+        (
+            user_id INTEGER PRIMARY KEY,
+            username TEXT,
+            points INTEGER DEFAULT 0,
+            last_sign_date TEXT
+        )
+    ''')
    cursor.execute('''
-                   CREATE TABLE IF NOT EXISTS daily_messages
-                   (
-                       user_id
-                       INTEGER,
-                       date
-                       TEXT,
-                       count
-                       INTEGER
-                       DEFAULT
-                       0,
-                       PRIMARY
-                       KEY
-                   (
-                       user_id,
-                       date
-                   )
-                       )
-                   ''')
+        CREATE TABLE IF NOT EXISTS daily_messages
+        (
+            user_id INTEGER,
+            date TEXT,
+            count INTEGER DEFAULT 0,
+            PRIMARY KEY(user_id, date)
+        )
+    ''')
    cursor.execute('''
-                   CREATE TABLE IF NOT EXISTS invites
-                   (
-                       inviter_id
-                       INTEGER,
-                       invitee_id
-                       INTEGER
-                       PRIMARY
-                       KEY
-                   )
-                   ''')
+        CREATE TABLE IF NOT EXISTS invites
+        (
+            inviter_id INTEGER,
+            invitee_id INTEGER,
+            PRIMARY KEY(inviter_id, invitee_id)
+        )
+    ''')
    conn.commit()
    conn.close()

@@ -127,11 +106,11 @@ def add_points(user_id, points):
    conn = sqlite3.connect(DB_PATH)
    cursor = conn.cursor()
    cursor.execute("""
-                   UPDATE users
-                   SET points         = points + ?,
-                       last_sign_date = ?
-                   WHERE user_id = ?
-                   """, (points, today, user_id))
+        UPDATE users
+        SET points = points + ?,
+            last_sign_date = ?
+        WHERE user_id = ?
+    """, (points, today, user_id))
    conn.commit()
    conn.close()

@@ -151,11 +130,10 @@ def add_message(user_id):
    conn = sqlite3.connect(DB_PATH)
    cursor = conn.cursor()
    cursor.execute("""
-                   INSERT INTO daily_messages (user_id, date, count)
-                   VALUES (?, ?, 1) ON CONFLICT(user_id, date)
-        DO
-                   UPDATE SET count = count + 1
-                   """, (user_id, today))
+        INSERT INTO daily_messages (user_id, date, count)
+        VALUES (?, ?, 1) ON CONFLICT(user_id, date)
+        DO UPDATE SET count = count + 1
+    """, (user_id, today))
    conn.commit()
    conn.close()

@@ -165,12 +143,12 @@ def get_daily_message_ranking():
    conn = sqlite3.connect(DB_PATH)
    cursor = conn.cursor()
    cursor.execute("""
-                   SELECT u.username, d.count
-                   FROM daily_messages d
-                            JOIN users u ON d.user_id = u.user_id
-                   WHERE d.date = ?
-                   ORDER BY d.count DESC
-                   """, (today,))
+        SELECT u.username, d.count
+        FROM daily_messages d
+                 JOIN users u ON d.user_id = u.user_id
+        WHERE d.date = ?
+        ORDER BY d.count DESC
+    """, (today,))
    results = cursor.fetchall()
    conn.close()
    return results
@@ -194,6 +172,71 @@ def get_invite_count(inviter_id):
    return count


+# ---------- 获取币价 ----------
+def get_price():
+    headers = {
+        'accept': 'application/json, text/plain, */*',
+        'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
+        'cache-control': 'no-cache',
+        'dnt': '1',
+        'origin': 'https://www.websea.com',
+        'pragma': 'no-cache',
+        'priority': 'u=1, i',
+        'referer': 'https://www.websea.com/',
+        'sec-ch-ua': '"Chromium";v="142", "Microsoft Edge";v="142", "Not_A Brand";v="99"',
+        'sec-ch-ua-mobile': '?0',
+        'sec-ch-ua-platform': '"Windows"',
+        'sec-fetch-dest': 'empty',
+        'sec-fetch-mode': 'cors',
+        'sec-fetch-site': 'same-site',
+        'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/142.0.0.0 Safari/537.36 Edg/142.0.0.0',
+    }
+
+    tz = datetime.timezone(datetime.timedelta(hours=8))
+    today = datetime.datetime.now(tz).date()
+    start_of_day = datetime.datetime.combine(today, datetime.time.min, tzinfo=tz)
+    end_of_day = datetime.datetime.combine(today, datetime.time.max, tzinfo=tz)
+
+    params = {
+        'symbol': 'SOL-USDT',
+        'period': '30min',
+        'start': int(start_of_day.timestamp()),
+        'end': int(end_of_day.timestamp()),
+    }
+
+    response = requests.get('https://eapi.websea.com/webApi/market/getKline', params=params, headers=headers)
+    data = response.json()["result"]["data"]
+
+    if not data:
+        return 0, 0, 0, 0
+
+    current_price = float(data[0]['close'])
+    today_high = max(float(item['high']) for item in data)
+    today_low = min(float(item['low']) for item in data)
+    price_24h_ago = float(data[-1]['open'])
+    change_24h = (current_price - price_24h_ago) / price_24h_ago * 100
+
+    return current_price, change_24h, today_high, today_low
+
+
+# ---------- 发送币价消息 ----------
+async def send_price_periodically(bot, chat_id):
+    while True:
+        try:
+            current_price, change_24h, today_high, today_low = get_price()
+            msg = (
+                "SOL/USDT 现货数据\n\n"
+                f"💰价格：{current_price:.2f} USDT\n"
+                f"📈24小时涨跌幅：{change_24h:.2f}%\n"
+                f"⬆️最高价：{today_high:.2f} USDT\n"
+                f"⬇️最低价：{today_low:.2f} USDT"
+            )
+            await bot.send_message(chat_id, msg)
+        except Exception as e:
+            print(f"发送价格失败: {e}")
+        await asyncio.sleep(3600)  # 每小时发送一次
+
+
 # ---------- 统一命令处理 ----------
 async def handle_command(event, cmd):
    user = await event.get_sender()
@@ -227,7 +270,6 @@ async def handle_command(event, cmd):
    else:
        reply_text = f"⚠️ 未知命令：{cmd}"

-    # 每次命令回复附带命令列表
    reply_text += "\n\n" + get_command_list_text()
    await event.reply(reply_text)

@@ -238,6 +280,10 @@ async def main():
    bot = TelegramClient('bot_session', API_ID, API_HASH, proxy=PROXY)
    await bot.start(bot_token=BOT_TOKEN)

+    # 启动定时任务，每小时发送币价
+    for group_id in ALLOWED_GROUPS:
+        asyncio.create_task(send_price_periodically(bot, group_id))
+
    # 新用户加入欢迎
    @bot.on(events.ChatAction)
    async def welcome_new_user(event):
@@ -256,25 +302,14 @@ async def main():
        user = await event.get_sender()
        user_id = user.id

-        # 普通消息计入发言
-
        for i in data:
            if text in data[i]:
-                # 去掉 @botusername 后缀
                cmd = text.split('@')[0]
                await handle_command(event, cmd)
                break
-
        else:
            add_message(user_id)

-        # if not text.startswith('/'):
-        #     add_message(user_id)
-        # else:
-        #     # 去掉 @botusername 后缀
-        #     cmd = text.split('@')[0]
-        #     await handle_command(event, cmd)
-
    # 按钮命令发送
    @bot.on(events.NewMessage(pattern='/commands'))
    async def send_buttons(event):
@@ -287,10 +322,9 @@ async def main():
    # 按钮点击处理
    @bot.on(events.CallbackQuery)
    async def callback_handler(event):
-        cmd = event.data.decode()  # 获取按钮绑定的命令
-        print(cmd)
+        cmd = event.data.decode()
        await handle_command(event, cmd)
-        await event.answer()  # 防止按钮 loading 一直转
+        await event.answer()

    print("🤖 机器人已启动，等待群聊消息...")
    await bot.run_until_disconnected()
--- a/telegram/bot_session.session
+++ b/telegram/bot_session.session
--- a/telegram/sign.db
+++ b/telegram/sign.db
--- a/test.py
+++ b/test.py
@@ -1,49 +1,16 @@
-import requests
+import datetime

-headers = {'vs': '05g7pXj83SRrFp94citJ7BkbjNqFc6kQ', 'language': 'zh_CN', 'sec-ch-ua-platform': '"Windows"',
-           'sec-ch-ua': '"Not;A=Brand";v="99", "Google Chrome";v="139", "Chromium";v="139"', 'sec-ch-ua-mobile': '?0',
-           'appVersion': '2.0.1', 'Accept': 'application/json, text/plain, */*', 'Content-Type': 'application/json',
-           'locale': 'zh_CN', 'terminalCode': 'ea778f2af8f3a418595f4993fe0ed949', 'Referer': 'https://www.weeaxs.site/',
-           'X-SIG': '64fbc4638b9132d0639c0864ad7b2631',
-           'sidecar': '01752def6506a5c558793e0c6ea8793a0e6defd487fbe009718c20e36c7b5e16fc',
-           'X-TIMESTAMP': '1762425944928', 'bundleid': '',
-           'U-TOKEN': 'eyJhbGciOiJSUzI1NiJ9.eyJqdGkiOiI4MjE2MDlhOS1kMDI3LTRiOTAtOTU0OC1iZGU3YTlmNmRiOWMxMzczNjgzNjU1IiwidWlkIjoidEQzQ1FIaFJUblVYcm5MNFNwckw3UT09Iiwic3ViIjoieXgyMDI1KioqKkBnbWFpbC5jb20iLCJpcCI6IllXb3dNNkVVWnYzamdjOTkwUHVHUFE9PSIsImRpZCI6InVxSnQ1N1N2SVBZcE5oM1MzU3VxcktCVERiaHBoeTN6S2VyMmZVNnF3MktnMk12cVptaUhFNmJ0YSt0OUgrcUEiLCJzdHMiOjAsImlhdCI6MTc2MjQwOTc3NywiZXhwIjoxNzcwMTg1Nzc3LCJwdXNoaWQiOiJvTmpMNm1ab2h4T203V3ZyZlIvcWdBPT0iLCJhdGwiOiIwIiwiaXNzIjoidXBleCJ9.idUb4bjGwoDy2MRZWmaIuNZAwCRAos6t6nt4sAZBw_Urg2Jtuz5sEZQYnZxx0fczg7RG8zm0bzeAqoIRHXWLSEQs366HA55bAIcz_GM12Wik7-zWZ_CVz5VqTVCO1xUUfRX7a-qRB6HfgdUu_f-rlqG8U8l__65sWhEtDZ2mJNk',
-           'terminaltype': '1',
-           'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/139.0.0.0 Safari/537.36',
-           'traceId': '378eb6c9-eb23-4925-a306-d437c3865a87',  'accept-encoding': 'gzip, deflate, br, zstd',
-           'accept-language': 'fi', 'content-length': '68', 'origin': 'https://www.weeaxs.site', 'priority': 'u=1, i',
-           'sec-fetch-dest': 'empty', 'sec-fetch-mode': 'cors', 'sec-fetch-site': 'cross-site'}
+# 获取当前日期（UTC）
+today = datetime.datetime.now(datetime.UTC).date()

-json_data = {
-    'filterCoinIdList': [
-        2,
-    ],
-    'filterContractIdList': [],
-    'filterOrderStatusList': [
-        'CANCELED',
-        'FILLED',
-    ],
-    'filterOrderTypeList': [],
-    'languageType': 1,
-    'limit': 20,
-    'sign': 'SIGN',
-    'timeZone': 'string',
-}
+# 获取当天开始时间（00:00:00 UTC）
+start_of_day = datetime.datetime.combine(today, datetime.time.min, tzinfo=datetime.timezone.utc)
+# 获取当天结束时间（23:59:59.999999 UTC）
+end_of_day = datetime.datetime.combine(today, datetime.time.max, tzinfo=datetime.timezone.utc)

-response = requests.post(
-    'https://http-gateway2.ngsvsfx.cn/api/v1/private/order/v2/getHistoryOrderPage',
-    headers=headers,
-    json=json_data,
-)
+# 将时间转换为时间戳
+start_timestamp = start_of_day.timestamp()
+end_timestamp = end_of_day.timestamp()

-for i in response.json()["data"]["dataList"]:
-    print(i)
-
-# Note: json_data will not be serialized by requests
-# exactly as it was in the original request.
-# data = '{"filterCoinIdList":[2],"filterContractIdList":[],"filterOrderStatusList":["CANCELED","FILLED"],"filterOrderTypeList":[],"languageType":1,"limit":20,"sign":"SIGN","timeZone":"string"}'
-# response = requests.post(
-#    'https://http-gateway2.ngsvsfx.cn/api/v1/private/order/v2/getHistoryOrderPage',
-#    headers=headers,
-#    data=data,
-# )
+print(f"当天开始的 UTC 时间戳: {start_timestamp}")
+print(f"当天结束的 UTC 时间戳: {end_timestamp}")
--- a/test1.py
+++ b/test1.py
@@ -1,27 +1,68 @@
-import time
 import datetime
+import requests

-# 获取当前时间戳
-current_timestamp = time.time()
-# 将当前时间戳转换为 datetime 对象
-current_datetime = datetime.datetime.fromtimestamp(current_timestamp)
+headers = {
+    'accept': 'application/json, text/plain, */*',
+    'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
+    'cache-control': 'no-cache',
+    'dnt': '1',
+    'origin': 'https://www.websea.com',
+    'pragma': 'no-cache',
+    'priority': 'u=1, i',
+    'referer': 'https://www.websea.com/',
+    'sec-ch-ua': '"Chromium";v="142", "Microsoft Edge";v="142", "Not_A Brand";v="99"',
+    'sec-ch-ua-mobile': '?0',
+    'sec-ch-ua-platform': '"Windows"',
+    'sec-fetch-dest': 'empty',
+    'sec-fetch-mode': 'cors',
+    'sec-fetch-site': 'same-site',
+    'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/142.0.0.0 Safari/537.36 Edg/142.0.0.0',
+}

-# 计算距离当前时间最近的整点或 30 分时刻
-if current_datetime.minute < 30:
-    target_datetime = current_datetime.replace(minute=0, second=0, microsecond=0)
+# # 获取当前日期（UTC）
+# today = datetime.datetime.now(datetime.timezone.utc).date()
+#
+# # 当天开始和结束时间
+# start_of_day = datetime.datetime.combine(today, datetime.time.min, tzinfo=datetime.timezone.utc)
+# end_of_day = datetime.datetime.combine(today, datetime.time.max, tzinfo=datetime.timezone.utc)
+
+# 获取今天日期（本地时间，中国时区 UTC+8）
+tz = datetime.timezone(datetime.timedelta(hours=8))
+today = datetime.datetime.now(tz).date()
+
+# 当天开始时间（北京时间 00:00）
+start_of_day = datetime.datetime.combine(today, datetime.time.min, tzinfo=tz)
+# 当天结束时间（北京时间 23:59:59.999999）
+end_of_day = datetime.datetime.combine(today, datetime.time.max, tzinfo=tz)
+
+params = {
+    'symbol': 'BTC-USDT',
+    'period': '30min',
+    'start': int(start_of_day.timestamp()),
+    'end': int(end_of_day.timestamp()),
+}
+
+response = requests.get('https://eapi.websea.com/webApi/market/getKline', params=params, headers=headers)
+data = response.json()["result"]["data"]
+
+if not data:
+    print("没有获取到数据")
 else:
-    target_datetime = current_datetime.replace(minute=30, second=0, microsecond=0)
+    # 当前价格 = 最新一条 K 线的 close
+    current_price = float(data[0]['close'])

-# 将目标 datetime 对象转换为时间戳
-target_timestamp = target_datetime.timestamp()
+    # 当天最高价 = 当天所有 K 线的 high
+    today_high = max(float(item['high']) for item in data)
+    # 当天最低价 = 当天所有 K 线的 low
+    today_low = min(float(item['low']) for item in data)

-print(f"当前时间戳: {current_timestamp}")
-print(f"目标时间戳: {target_timestamp}")
+    # 24 小时涨幅计算（用最新一条 close 与 24 小时前的价格对比）
+    # 如果接口只能获取当天数据，可能不足 24 小时，可根据需求扩展
+    # 假设获取过去 24 小时数据，使用第一条 K 线的 open 作为 24 小时前价格
+    price_24h_ago = float(data[-1]['open'])
+    change_24h = (current_price - price_24h_ago) / price_24h_ago * 100

-# 进行时间戳比对
-if current_timestamp == target_timestamp:
-    print("当前时间就是目标时间。")
-elif current_timestamp < target_timestamp:
-    print(f"当前时间早于目标时间，还需等待 {target_timestamp - current_timestamp} 秒。")
-else:
-    print(f"当前时间晚于目标时间，已经过去了 {current_timestamp - target_timestamp} 秒。")
+    print(f"当前价格: {current_price}")
+    print(f"24小时涨幅: {change_24h:.2f}%")
+    print(f"当天最高价: {today_high}")
+    print(f"当天最低价: {today_low}")