From 5db69b6628c27ae2a637c67dbe7267f420b16da2 Mon Sep 17 00:00:00 2001
From: Administrator <fdefewf@vrfdgesgf>
Date: Mon, 15 Dec 2025 16:26:28 +0800
Subject: [PATCH] =?UTF-8?q?websea=E4=BC=98=E5=8C=96=E5=AE=8C=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 telegram/8619211027341.session | Bin 45056 -> 45056 bytes
 交易/websea_交易.py            | 177 ++++++++++++++++-----------------
 2 files changed, 85 insertions(+), 92 deletions(-)

diff --git a/telegram/8619211027341.session b/telegram/8619211027341.session
index 75ca1de0a4b6eea106b3a76ea59d0fd38c2463bd..c008fb34997296d6dce686023033b17ff3f25699 100644
GIT binary patch
delta 64
zcmV-G0Kfl$-~xc)0+1U44v`!~0S>WXrELiiLE2C8ckm)llMZep0>$04Gj7NP0>$35
W{c@540>$66k#r(E0>$2wwXaJ(XB*!D

delta 64
zcmZp8z|`=7X@WE(!$cWpMuv?EOLI9n9dG%6=#gH$b~0a{GSeZw&Bl2rSeOp!Z~j{}
UiIM4$!RCo2O4dOB<gM$y0Sapw5&!@I

diff --git a/交易/websea_交易.py b/交易/websea_交易.py
index a0ba1a8..6df47d0 100644
--- a/交易/websea_交易.py
+++ b/交易/websea_交易.py
@@ -323,106 +323,99 @@ class WeexTransaction:
 
         self.time_start = None  # 时间状态 避免同一个时段，发生太多消息
 
-        # 获取当前时间
-        current_time = time.localtime()
-        current_minute = current_time.tm_min
+        while True:
 
-        if current_minute < 30:
-            self.pbar.n = current_minute
-            self.pbar.refresh()
-        else:
-            self.pbar.n = current_minute - 30
-            self.pbar.refresh()
+            # 获取当前时间
+            current_time = time.localtime()
+            current_minute = current_time.tm_min
 
-        if current_minute not in [0, 1, 2, 3, 4, 5, 30, 31, 32, 33, 34, ]:  # 判断是否是 新的30分钟了
+            if current_minute < 30:
+                self.pbar.n = current_minute
+                self.pbar.refresh()
+            else:
+                self.pbar.n = current_minute - 30
+                self.pbar.refresh()
+
+            if current_minute not in [0, 1, 2, 3, 4, 5, 30, 31, 32, 33, 34, ]:  # 判断是否是 新的30分钟了
             # if current_minute not in range(60):  # 判断是否是 新的30分钟了
-            time.sleep(10)
-            return
+                time.sleep(10)
+                continue
 
-        if self.kline_3 and self.get_now_time() == self.kline_3["id"]:
-            return
+            if self.kline_3 and self.get_now_time() == self.kline_3["id"]:
+                continue
 
-        new_price_datas = self.get_price()
-        if not new_price_datas:
-            logger.info("获取最新价格有问题！！！")
+            new_price_datas = self.get_price()
+            if not new_price_datas:
+                logger.info("获取最新价格有问题！！！")
 
-            self.send_dingtalk_message(message_content=f"获取价格有问题！！！", type=0)
-            return
-
-        new_price_datas1 = sorted(new_price_datas, key=lambda x: x["id"])
-        self.kline_1, self.kline_2, self.kline_3 = new_price_datas1[-3:]
-
-        if self.time_start == self.get_now_time():
-            return
-
-        self.time_start = self.get_now_time()
-
-        self.page.get(url="https://www.websea.com/zh-CN/futures/ETH-USDT")  # 打开网页
-
-        if self.get_token():  # 获取token
-            logger.info("获取token成功!!!")
-        else:
-            logger.info("获取token失败！！！")
-            self.send_dingtalk_message(message_content=f"获取token失败！！！", type=0)
-            return
-
-        if self.get_position_status():
-            logger.info("获取仓位信息成功!!!")
-        else:
-            logger.info("获取仓位信息失败！！！")
-
-            self.send_dingtalk_message(message_content=f"获取仓位信息失败！！！", type=0)
-            return
-
-        try:
-            if self.start == 1:
-                if is_bearish(self.kline_1) and is_bearish(self.kline_2):
-                    logger.success(f"{datetime.datetime.now()}，第一根信号：{self.kline_1}，{self.kline_2}，平多")
-                    self.send_dingtalk_message(
-                        message_content=f"第一根信号：{self.kline_1}，{self.kline_2}，平多")
-
-                    self.page.ele('x://*[normalize-space(text())= "市价全平"]').scroll.to_see(center=True)
-                    time.sleep(1)
-                    self.page.ele('x://*[normalize-space(text())= "市价全平"]').click()
-                    self.start = 0
-            elif self.start == -1:
-                if is_bullish(self.kline_1) and is_bullish(self.kline_2):
-                    logger.success(f"{datetime.datetime.now()}，第一根信号：{self.kline_1}，{self.kline_2}，平空")
-                    self.send_dingtalk_message(
-                        message_content=f"第一根信号：{self.kline_1}，{self.kline_2}，平空")
-
-                    self.page.ele('x://*[normalize-space(text())= "市价全平"]').scroll.to_see(center=True)
-                    time.sleep(1)
-                    self.page.ele('x://*[normalize-space(text())= "市价全平"]').click()
-                    self.start = 0
-        except:
-            self.send_dingtalk_message(message_content=f"止损平仓出错！！！", type=0)
-            return
-
-        self.direction, signal_key = self.check_signal(prev=self.kline_1, curr=self.kline_2)  # 判断信号
-
-        if self.direction:
-            try:
-                self.to_do_page()
-            except Exception as e:
-                self.send_dingtalk_message(message_content=f"购买操作失败，{e}", type=0)
+                self.send_dingtalk_message(message_content=f"获取价格有问题！！！", type=0)
                 return
 
-        self.pbar.reset()  # 重置进度条
-        self.send_dingtalk_message(
-            message_content=
-            f"目前有持仓：{"无" if self.start == 0 else ("多" if self.start == 1 else "空")}，"
-            f"当前信号：{"无" if not self.direction else ("多" if self.direction == "long" else "空")}"
-        )
+            new_price_datas1 = sorted(new_price_datas, key=lambda x: x["id"])
+            self.kline_1, self.kline_2, self.kline_3 = new_price_datas1[-3:]
+
+            self.time_start = self.get_now_time()
+
+            self.page.get(url="https://www.websea.com/zh-CN/futures/ETH-USDT")  # 打开网页
+
+            if self.get_token():  # 获取token
+                logger.info("获取token成功!!!")
+            else:
+                logger.info("获取token失败！！！")
+                self.send_dingtalk_message(message_content=f"获取token失败！！！", type=0)
+                return
+
+            if self.get_position_status():
+                logger.info("获取仓位信息成功!!!")
+            else:
+                logger.info("获取仓位信息失败！！！")
+
+                self.send_dingtalk_message(message_content=f"获取仓位信息失败！！！", type=0)
+                return
+
+            try:
+                if self.start == 1:
+                    if is_bearish(self.kline_1) and is_bearish(self.kline_2):
+                        logger.success(f"{datetime.datetime.now()}，第一根信号：{self.kline_1}，{self.kline_2}，平多")
+                        self.send_dingtalk_message(
+                            message_content=f"第一根信号：{self.kline_1}，{self.kline_2}，平多")
+
+                        self.page.ele('x://*[normalize-space(text())= "市价全平"]').scroll.to_see(center=True)
+                        time.sleep(1)
+                        self.page.ele('x://*[normalize-space(text())= "市价全平"]').click()
+                        self.start = 0
+                elif self.start == -1:
+                    if is_bullish(self.kline_1) and is_bullish(self.kline_2):
+                        logger.success(f"{datetime.datetime.now()}，第一根信号：{self.kline_1}，{self.kline_2}，平空")
+                        self.send_dingtalk_message(
+                            message_content=f"第一根信号：{self.kline_1}，{self.kline_2}，平空")
+
+                        self.page.ele('x://*[normalize-space(text())= "市价全平"]').scroll.to_see(center=True)
+                        time.sleep(1)
+                        self.page.ele('x://*[normalize-space(text())= "市价全平"]').click()
+                        self.start = 0
+            except:
+                self.send_dingtalk_message(message_content=f"止损平仓出错！！！", type=0)
+                return
+
+            self.direction, signal_key = self.check_signal(prev=self.kline_1, curr=self.kline_2)  # 判断信号
+
+            if self.direction:
+                try:
+                    self.to_do_page()
+                except Exception as e:
+                    self.send_dingtalk_message(message_content=f"购买操作失败，{e}", type=0)
+                    return
+
+            self.pbar.reset()  # 重置进度条
+            self.send_dingtalk_message(
+                message_content=
+                f"目前有持仓：{"无" if self.start == 0 else ("多" if self.start == 1 else "空")}，"
+                f"当前信号：{"无" if not self.direction else ("多" if self.direction == "long" else "空")}"
+            )
 
 
 if __name__ == '__main__':
-    while True:
-        try:
-            WeexTransaction(
-                tge_id=191303,
-            ).action()
-        except:
-            pass
-
-        time.sleep(30)
+    WeexTransaction(
+        tge_id=191303,
+    ).action()