diff --git a/weex交易/30分钟仿盘交易.py b/weex交易/30分钟仿盘交易.py index 22aad85..96182a1 100644 --- a/weex交易/30分钟仿盘交易.py +++ b/weex交易/30分钟仿盘交易.py @@ -259,59 +259,59 @@ class WeexTransaction: self.pbar.n = current_minute - 30 self.pbar.refresh() - if current_minute in [0,1,2, 30,31,32]: # 判断是否是 新的30分钟了 + if current_minute not in [0, 1, 2, 30, 31, 32]: # 判断是否是 新的30分钟了 + time.sleep(10) + continue - if self.get_text(target_text="仓位(1)"): - if self.get_text(target_text="ETH/SUSDT多"): - self.start = 1 - elif self.get_text(target_text="ETH/SUSDT空"): - self.start = -1 - else: + if self.get_text(target_text="仓位(1)"): + if self.get_text(target_text="ETH/SUSDT多"): + self.start = 1 + elif self.get_text(target_text="ETH/SUSDT空"): + self.start = -1 + else: + self.start = 0 + + new_price_datas = self.get_price() + if new_price_datas: + logger.success("获取最新交易价格成功!!!") + else: + logger.info("获取最新价格有问题!!!") + continue + + 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:] + + time.sleep(15) + 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"{datetime.datetime.now()},第一根信号:{self.kline_1},{self.kline_2},平多") + self.page.ele('x://*[contains(text(), "闪电平仓")]').scroll.to_see(center=True) + self.page.ele('x://*[contains(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"{datetime.datetime.now()},第一根信号:{self.kline_1},{self.kline_2},平空") + + self.page.ele('x://*[contains(text(), "闪电平仓")]').scroll.to_see(center=True) + self.page.ele('x://*[contains(text(), "闪电平仓")]').click() self.start = 0 - new_price_datas = self.get_price() - if new_price_datas: - logger.success("获取最新交易价格成功!!!") - else: - logger.info("获取最新价格有问题!!!") - continue + self.direction, signal_key = self.check_signal(prev=self.kline_1, curr=self.kline_2) - 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.direction: + try: + self.to_do_page() + except Exception as e: + self.send_dingtalk_message( + message_content=f"{datetime.datetime.now()},{e}") - time.sleep(15) - 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"{datetime.datetime.now()},第一根信号:{self.kline_1},{self.kline_2},平多") - self.page.ele('x://*[contains(text(), "闪电平仓")]').scroll.to_see(center=True) - self.page.ele('x://*[contains(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"{datetime.datetime.now()},第一根信号:{self.kline_1},{self.kline_2},平空") - - self.page.ele('x://*[contains(text(), "闪电平仓")]').scroll.to_see(center=True) - self.page.ele('x://*[contains(text(), "闪电平仓")]').click() - self.start = 0 - - 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"{datetime.datetime.now()},{e}") - - self.pbar.reset() # 重置进度条 - self.send_dingtalk_message( - message_content=f"{datetime.datetime.now()},目前有持仓:{ "无" if self.start == 0 else ("多" if self.start in [1, -1] else "空")}") - - time.sleep(10) + self.pbar.reset() # 重置进度条 + self.send_dingtalk_message( + message_content=f"{datetime.datetime.now()},目前有持仓:{"无" if self.start == 0 else ("多" if self.start in [1, -1] else "空")}") if __name__ == '__main__':