From 71e392fec096bbf923e47f959f2dfb9ed6e64517 Mon Sep 17 00:00:00 2001 From: Hobr Date: Tue, 9 Jul 2024 15:40:31 +0800 Subject: [PATCH] =?UTF-8?q?chore:=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- util/Task/__init__.py | 90 ++++++++++++++++++++++--------------------- 1 file changed, 46 insertions(+), 44 deletions(-) diff --git a/util/Task/__init__.py b/util/Task/__init__.py index 9ed3983..2a456ed 100644 --- a/util/Task/__init__.py +++ b/util/Task/__init__.py @@ -39,6 +39,49 @@ def __init__( self.cap = cap self.api = api + self.notice = notice + self.sleep = sleep + + self.data = Data() + self.queryCache = False + self.orderId = 0 + + # 重试创建订单间隔 + self.refreshInterval = 2.1 + # 上次重试创建订单时间 + self.refreshTime = 0 + + # 上次有票时间 + self.availableTime = 0 + # 有票期内间隔 + self.availableSchedule = [ + # 0-0 + [0, 0.0], + # 0-1 + [1.0, self.sleep / 1.5], + # 1-5 + [5.0, self.sleep], + # 5-9.9 + [9.9, self.sleep * 1.5], + # 9.9-10.5 + [10.5, self.sleep / 1.5], + ] + + # ERR3间隔 + self.err3Sleep = 4.96 + # 上次ERR3时间 + self.err3Time = 0 + # ERR3结束间隔 + self.err3Interval = 1.5 + + # Code + self.skipToken = False + self.queryTokenCode = 114514 + self.riskProcessCode = 114514 + self.queryTicketCode = False + self.createOrderCode = 114514 + self.createStatusCode = 114514 + self.states = [ State(name="开始"), State(name="等待开票", on_enter="WaitAvailableAction"), @@ -191,50 +234,6 @@ def __init__( conditions=lambda: self.createStatusCode != 0, ) - # 重试创建订单间隔 - self.refreshInterval = 2.1 - # 上次重试创建订单时间 - self.refreshTime = 0 - - # 普通间隔 - self.sleep = sleep - - # 上次有票时间 - self.availableTime = 0 - # 有票期内间隔 - self.availableSchedule = [ - # 0-0 - [0, 0.0], - # 0-1 - [1.0, self.sleep / 1.5], - # 1-5 - [5.0, self.sleep], - # 5-9.9 - [9.9, self.sleep * 1.5], - # 9.9-10.5 - [10.5, self.sleep / 1.5], - ] - - # ERR3间隔 - self.err3Sleep = 4.96 - # 上次ERR3时间 - self.err3Time = 0 - # ERR3结束间隔 - self.err3Interval = 1.5 - - # Code - self.skipToken = False - self.queryTokenCode = 114514 - self.riskProcessCode = 114514 - self.queryTicketCode = False - self.createOrderCode = 114514 - self.createStatusCode = 114514 - - # 是否已缓存getV2 - self.queryCache = False - - self.data = Data() - # 取消以绘制FSM图 # self.DrawFSM() @@ -563,6 +562,9 @@ def FinishAction(self) -> None: @logger.catch def AutoSleep(self) -> None: + """ + 自动Sleep策略 + """ # ERR3 if self.data.TimestampCheck(timestamp=self.err3Time, duration=self.err3Interval): logger.info(f"【ERR3】因{((int(time())-self.err3Time)/60):.2f}分钟内触发过ERR3, {self.err3Interval}分钟内请求间隔将延长至{self.err3Sleep}秒")