From a4effb8058254ea6b1507fe37eed64bb9e7e57ab Mon Sep 17 00:00:00 2001
From: milk <53408947@qq.com>
Date: Sat, 20 Sep 2025 14:50:58 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=81=9C=E6=AD=A2=E8=84=9A?=
 =?UTF-8?q?=E6=9C=AC=EF=BC=8C=E8=B0=83=E6=95=B4=E5=81=9C=E6=AD=A2=E8=84=9A?=
 =?UTF-8?q?=E6=9C=AC=E6=96=B9=E6=A1=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/workspace.xml                           |   3 +-
 Utils/ThreadManager.py                        |  38 +++++-
 .../__pycache__/ThreadManager.cpython-312.pyc | Bin 6267 -> 7499 bytes
 script/ScriptManager.py                       | 125 +++++++++---------
 .../__pycache__/ScriptManager.cpython-312.pyc | Bin 38772 -> 38469 bytes
 5 files changed, 94 insertions(+), 72 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 8fa4157..1e442b3 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -5,7 +5,8 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="eceeff5e-51c1-459c-a911-d21ec090a423" name="Changes" comment="20250904-初步功能已完成">
-      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/Utils/ThreadManager.py" beforeDir="false" afterPath="$PROJECT_DIR$/Utils/ThreadManager.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/script/ScriptManager.py" beforeDir="false" afterPath="$PROJECT_DIR$/script/ScriptManager.py" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
diff --git a/Utils/ThreadManager.py b/Utils/ThreadManager.py
index a950414..7917e7b 100644
--- a/Utils/ThreadManager.py
+++ b/Utils/ThreadManager.py
@@ -68,19 +68,41 @@ class ThreadManager:
     @classmethod
     def batch_stop(cls, udids: List[str]) -> Tuple[int, List[str], str]:
         """
-        批量停止任务，使用多线程并发执行。
-        :param udids: 待停止的设备唯一标识列表
-        :return: (code, fail_list, msg)
-                 code=200  全部成功，fail_list=[]
-                 code=1001 部分/全部失败，fail_list 为失败描述字符串列表
+        批量停止任务——瞬间下发停止信号，仍统计失败结果。
+        返回格式与原接口 100% 兼容：
+        (code, fail_list, msg)
+            code=200   全部成功
+            code=1001  部分/全部失败
         """
         if not udids:
             return 200, [], "无设备需要停止"
 
         fail_list: List[str] = []
 
+        # ---------- 1. 瞬间置位 event ----------
+        with cls._lock:
+            for udid in udids:
+                task = cls._tasks.get(udid)
+                if not task or not task.get("running"):
+                    fail_list.append(f"设备{udid}停止失败：当前设备没有执行相关任务")
+                    continue
+                task["event"].set()  # 下发停止信号
+
+        # ---------- 2. 并发等 0.2 s 收尾 ----------
+        def _wait_and_clean(udid: str) -> Tuple[int, str]:
+            """子线程里只做极短 join 并清理记录"""
+            with cls._lock:
+                task = cls._tasks.get(udid)
+                if not task:
+                    return 400, f"设备{udid}任务记录已丢失"
+                thread = task["thread"]
+                # 浅等 0.2 s，后台还没死也继续
+                thread.join(0.2)
+                del cls._tasks[udid]  # 立即清理
+            return 200, f"设备{udid}已下发停止指令"
+
         with ThreadPoolExecutor(max_workers=min(32, len(udids))) as executor:
-            future_map = {executor.submit(cls.stop, udid): udid for udid in udids}
+            future_map = {executor.submit(_wait_and_clean, udid): udid for udid in udids}
             for future in as_completed(future_map):
                 udid = future_map[future]
                 try:
@@ -89,8 +111,10 @@ class ThreadManager:
                         fail_list.append(f"设备{udid}停止失败：{reason}")
                 except Exception as exc:
                     fail_list.append(f"设备{udid}停止异常：{exc}")
+
+        # ---------- 3. 返回兼容格式 ----------
         if fail_list:
-            return 1001, fail_list, "停止失败"
+            return 1001, fail_list, "部分设备停止失败"
         return 200, [], "全部设备停止成功"
 
 
diff --git a/Utils/__pycache__/ThreadManager.cpython-312.pyc b/Utils/__pycache__/ThreadManager.cpython-312.pyc
index 73e2d2b8596c813eddbe41e387a84ff1a08a0a82..1165bb2ac84732a73b7cfa5ac26d18bceffd0946 100644
GIT binary patch
delta 2362
zcmZuyeN0=|6~FJpUl@O3gTW-k6hlJSfWc{&CWIs<G%ZrIKWMvoZNwZu1E!80JwJ~$
zdXAHADUh;Y^jaB`2AnR{+$KRui&j!-lQfOAsnYaNveonUN4D_{?4KIaiYVQrooi#N
zR=LkQ@A!QD?z!jVzHjYcY}bCF(G(z9<<I}QyTACV_DM}SO(E2WVu&Y#GKT0v4B1Jw
zqb?LC2Za4bO98PL9dIHPrUrx?RIv~?78|LH1O@>i&C{%br+Z|=P12;zi-RRR*`olF
zaRbd$XAvVix8_2i!F@c<$jiXJM<r+oO9VtO(@2FF1%57)S!hHcM#*J^#s3)<SD2F{
z#A(;KHGL<E0Xyk_)JZS}zbOpMIK!HiG0!n-t~k&0#A>*kQGUxyh4~XaiNbOoPCi7r
zNiTAf2f!^%@$w$Ca8+Y$k?~aCho=N`&`hJSB1~~OhV0@Mc_hf*kHJ^TD|jVVhba}}
zl|AM7<R!1bS;MMu0k2|+SHX-m=MxvnB~HT^oJHs8JQ!r^sYhjsCs`Sz<4H!3YnQE}
z0drNT0R@R(l0Z(#CwPB$gmR)@!VMBP8K!!{f?Ky5GqNGJGOWfCASB!(4I6VYXnFPb
zV{k&H!s=t{!IQbS@IP&Nq&<gRTNL^h@CvM}D?M;+v2RE^@pk(1J9E?1(y8<RI{qg7
z=Ep8A#wO>c-jIfdSGCvAOG6)hH8VIj{oDEJ@r8-=(uJ!Flkd(?3+b`9|9$*dYnThy
z-;~adrQ<Ww%+TD_Y3cNM`gHlb($Md$4R(9ARXRB%O<enG=1kr}n9$jtb_W>G&PKZ(
z;*w4#7Jr>c_eZ5u<9VBGxLF&(Xs}wrK<a<JK4+Q>M0iQR$;RTY`bG|9Vd7KiLSM)M
zZ0-O#E7(_9F0k2I+@$+i+_bC?h<kNpfJF%V<EFg-0LWWJ3=L4iPmHA`ylzq^JY&1i
z#r%vBFqsC1U`QUpC{gFAPSQ;>G=B0;NT7C@Uq+T~Ff!jm8hIXrz#H78iX&(z`k^Px
zTn<@@ksr}BhSkcdLYpC4>2h@b<LmQ@Hx~N_rJ?tw6KB$6C+5d5TYCatzg4>ShxF9R
z`RMBl6IY~9-eU2zu^WMeFgF*;c0f)iee}WH)H{&0{j3IbU1vt|`qM7foHx%}eAgi9
z!M?fa3$-+hPsyq=v0zdK1f<za7hwU0V{umpX&_M9<Lr81Qo4>vuglAIxcp3q+vjol
zk2bu}&3atS^De)u%fr?kbaC$PjvyB}T-W3axLv+rb6v;xU0%Vkr+_>-j_w&uv9jT^
zC8W?)C(V}F(cz=9W5dVd%pLQOqV(U)<;n7jcum5Tkc)LKqIIuW9@)F10OPDjMu{vH
zBi*AFQTaW6NlZPg9%;F&w<b;ISle*h2q&6sD>^XF=#j}hQWH1D<zmeav9w7vHi?Bz
zD+a8?TR#lyA)eFKd+gLFRX}dqWqY1dELuTWOQh6?Tt_;31MI6FHW(7d^czdOi*VzI
zN<p1#@?0YeqW<xS?gzO|$z6vJd;ARh7+9yMAjh(}byJkr&#{04+##<&Mfp7blsp(Z
zc*x7KIOi!j>j{Q@TuRk?#O*oEc?161!fZ*{YOGduy1c#)pBDhXD_boBKBe>=@wh`=
zfE5lHHp#K}7gk}wus!kt%mXBSsR-$dlg5$}Qe5W{jSjKUac@IqzbYd~TEmcYz`2Cv
zDqFI2{W6kiY*G4=g^6$Z{kHSl63^YO+L|=2|I%ceHQD07OfZR;L`SDs-F4U0oiwdW
z>P^v~4r{*DSI+7yBY)9XEvW%=g#!FcQGsgbg{lmK*QM%7YO?)`^1b?R@ZYaXk=A;t
z<qA33G9~-4?amXs?rL^tkV@4?+;}$G{<FW9Isdq2WYc*4Xnmr7YRetV?i;pQ%QIq`
zv%d|<KP)xzqjxNg%TU@jA}UXsE8{h@=2~HU(ViVLjIvaU3LyjLkuuTNEE=1|!seu|
zDEhQm+9>K8MP=j4J_3h`^YGv0Cy?dm#DlN3!uv&b#(@2Eu{;dE0J)9r*|2vT_1R8Y
z>sIO(X=$b9x7HP7zOlYlMSosN0{{6oSu3HqO=FweDpjjPal6ReTBo>Oo0Zhbu*5-O
z?N(Xqt`F_TZjyLS7%iTbvG~RioF&ihX6t}sD=@KP0-qSf?f{aa4+a80wi(#>(0!mN
zJFG1JvS$gl4E{&>XUW;d2AN}oi?@uvmO;QKUcBO%qNm!gsctw#$1}5=_bp@beG179
z84|cmHz8a$S8CewP_=5dMfkh<May$ok`?2N;i0nWP=E>fJk9KWp{?{W9ZwJy%W$C*
I6<MSI19?cT5&!@I

delta 1202
zcmY*YZERCj7(Vx_?d`|ftt;KyZEa!3)(_gXg030Ptb>thh_YZLX2H>W$GUaxa(bJM
z<X!_&WayGX4snBN7-ne6fDIv9P}$c{Vp0MzOMe)D^se16$MlEd4?VY~Q_syk_sR2q
zJn#GFz4wEE`6})k3|fFso#n^Ala)6sb{TxD1OO92BoYiq90MHLOLc)`Kq3XqmySS{
z5l0COnyRqxre~j8cL9kKiFPnfhsg*ClidygBwD2U)#aFfzakpfSlUE-mMn21jmR+<
z4J1aQ1zp)sWXieQLHElzn@VIvRV_A4Gz&ykzX5rTj!Lzp5!D<qfIXm9B>RnMi8S+!
zNKXMyC2FR?=UX)rV62%2EZ{WCQ&uN{NJ55VMUvAhJr}#zDJV=5_?75kumcFDa$Su8
zx+LsfQhK(eq!!u#D;>rv68k<ocD(dO9+O?)F+v>%!-PklY$ni~ruv3ozaPu}u#i8W
zl4maF?=Iw1pU8K<k;l)io%yP8c??Ok^_4`>Dc?IKpZsj?`WN|&9~N%hlV?uL=jU?i
z6Km6_3v(aIqZ5V8DXsJA2|`{-!dMXfY--$F<ic@|-{bfBoKE>vYW;)M+UQyN<4ah&
zw<i)k5{)E;J@0mJ#h3Fqi(ySZUla0GRzLq=cV{krSDv|9xP4`9e7vwQFJGU?U;8qb
z{<>5OYOi!V)}44>9wMt7>=`*S9ESruOe9s9D>Z;Vt#<1UMAq>}CH0s^kE)*wvrt*E
zEHxO3WvM71%c>H|qk|CvHewpmicJOiL^3L5RXsyPe2mModq=|jkPwN-JX%<%xILq|
zv0JTWHT(!4P6}}di#lg4Zd%!V^sOcMo&zuM3GlcIm@KR2ZIfiCE|4(?GWx(T4%aA~
zGdQk==E>WkG;^!-;R~&g46khfE!#;f?q7Z5t)FTSF1Am)FL^I`Q#<C|SKagN4{goq
zmmb(!GqndtJMoo6tJ~i3s+Ew(H9(Iwtdq6V2Qp@VM(<xWR-J9j)c7+-e@5f~bJGrN
zUBn;1o6vyO_qJJyDTzHv?8D_=WkOEsMq}Gf)l!uO!zH)3EkG|@NsO0wD#qmi8>&|?
zw^&0p>J_uXtkf`=S*fQK>|{coTYp>oNFt2-Y~L|iDj`7Rw(oaksYpzK4a)3_b5?#>
zxEo(t`e-~Jh0W-ky@6Oq^Y*DGI}?}`rb8EwZvYHahvoxmI^A`LT?}Lb`yRa5v8m9%
zQ9xC>L1MJgf}}c^p+m{24BexHt!TFHkWFa`7U_D7o@iPI<6JVzzY1SRw)*YHUV>=Y
J1j=1>`UhYeWT*fD

diff --git a/script/ScriptManager.py b/script/ScriptManager.py
index 737ba01..9d55601 100644
--- a/script/ScriptManager.py
+++ b/script/ScriptManager.py
@@ -41,9 +41,9 @@ class ScriptManager():
 
                 # 关闭并重新打开 TikTok
                 ControlUtils.closeTikTok(session, udid)
-                time.sleep(1)
+                event.wait(timeout=1)
                 ControlUtils.openTikTok(session, udid)
-                time.sleep(3)
+                event.wait(timeout=3)
                 LogManager.method_info("养号重启tiktok", "养号", udid)
                 AiUtils.makeUdidDir(udid)
 
@@ -81,7 +81,7 @@ class ScriptManager():
                         img.save(filePath)
                         LogManager.method_info(f"保存屏幕图像成功 -> {filePath}", "养号", udid)
                         print("保存了背景图:", filePath)
-                        time.sleep(1)
+                        event.wait(timeout=1)
                     except Exception as e:
                         LogManager.method_info(f"截图或保存失败,失败原因:{e}", "养号", udid)
                         raise Exception("截图或保存失败,重启养号功能")
@@ -94,7 +94,7 @@ class ScriptManager():
                             tx, ty = AiUtils.findImageInScreen("add", udid)
                             if addX == tx and addY == ty:
                                 isSame = True
-                                time.sleep(1)
+                                event.wait(timeout=1)
                             else:
                                 isSame = False
                                 break
@@ -105,7 +105,7 @@ class ScriptManager():
                             if homeButton:
                                 LogManager.method_info("有首页按钮，查看视频", "养号", udid)
                                 videoTime = random.randint(5, 15)
-                                time.sleep(videoTime)
+                                event.wait(timeout=videoTime)
 
                                 # 重置 session
                                 client = wda.USBClient(udid)
@@ -118,14 +118,15 @@ class ScriptManager():
 
                                 LogManager.method_info("继续观看视频", "养号", udid)
                                 videoTime = random.randint(10, 30)
-                                time.sleep(videoTime)
+                                event.wait(timeout=videoTime)
+
                                 LogManager.method_info("准备划到下一个视频", "养号", udid)
                                 client.swipe_up()
                             else:
                                 LogManager.method_error("找不到首页按钮。出错了", "养号", udid)
                         else:
                             nextTime = random.randint(1, 5)
-                            time.sleep(nextTime)
+                            event.wait(timeout=nextTime)
                             client.swipe_up()
 
                     except Exception as e:
@@ -134,7 +135,7 @@ class ScriptManager():
 
             except Exception as e:
                 LogManager.method_error(f"[{udid}] 养号出现异常，将重启流程: {e}", "养号", udid)
-                time.sleep(3)  # 等待后重生
+                event.wait(timeout=3)
 
     # 观看直播
     def watchLiveForGrowth(self, udid, event, max_retries=None):
@@ -152,9 +153,9 @@ class ScriptManager():
 
                 # 1) 先关再开
                 ControlUtils.closeTikTok(session, udid)
-                time.sleep(1)
+                event.wait(timeout=1)
                 ControlUtils.openTikTok(session, udid)
-                time.sleep(3)
+                event.wait(timeout=3)
 
                 # 2) 进入直播  （使用英文）
                 live_button = session(
@@ -166,7 +167,8 @@ class ScriptManager():
                     LogManager.method_error("无法找到直播间按钮 抛出异常 重新启动", "直播养号", udid)
                     # 抛出异常
                     raise Exception(f"找不到直播按钮，抛出异常 重新启动")
-                time.sleep(20)
+                waitTime = random.randint(15, 20)
+                event.wait(timeout=waitTime)
 
                 live_button = session(xpath='//XCUIElementTypeButton[@name="直播"]')
                 if live_button.exists:
@@ -182,7 +184,7 @@ class ScriptManager():
 
                 # 4) 主循环：刷直播
                 while not event.is_set():
-                    time.sleep(3)
+                    event.wait(timeout=3)
 
                     # 找到一个看直播的时候肯定有的元素，当这个元素没有的时候，就代表当前的页面出现了问题
                     # 需要抛出异常，重启这个流程
@@ -236,7 +238,7 @@ class ScriptManager():
                             session.double_tap(x, y)
 
                     print("--------------------------------------------")
-                    time.sleep(random.randint(300, 600))
+                    event.wait(timeout=random.randint(300, 600))
                     session.swipe_up()
 
                 # 正常退出（外部 event 触发）
@@ -251,7 +253,8 @@ class ScriptManager():
                     _ = client.session()
                 except Exception:
                     pass
-                time.sleep(backoff_sec)  # 冷却后整段流程重来
+                # 冷却后整段流程重来
+                event.wait(timeout=backoff_sec)
                 continue
 
     """
@@ -269,7 +272,7 @@ class ScriptManager():
             except Exception as e:
                 retries += 1
                 LogManager.method_error(f"greetNewFollowers 出现异常: {e}，准备第 {retries} 次重试", "关注打招呼", udid)
-                time.sleep(3)
+                event.wait(timeout=3)
         LogManager.method_error("greetNewFollowers 重试次数耗尽，任务终止", "关注打招呼", udid)
 
     # 关注打招呼以及回复主播消息
@@ -284,11 +287,11 @@ class ScriptManager():
 
         # 先关闭Tik Tok
         ControlUtils.closeTikTok(session, udid)
-        time.sleep(1)
+        event.wait(timeout=1)
 
         # 重新打开Tik Tok
         ControlUtils.openTikTok(session, udid)
-        time.sleep(3)
+        event.wait(timeout=3)
         LogManager.method_info(f"重启tiktok", "关注打招呼", udid)
         # 设置查找深度
         session.appium_settings({"snapshotMaxDepth": 15})
@@ -303,7 +306,7 @@ class ScriptManager():
 
                 session.appium_settings({"snapshotMaxDepth": 15})
                 ControlUtils.clickBack(session)
-                time.sleep(2)
+                event.wait(timeout=2)
 
         LogManager.method_info(f"循环条件1:{not event.is_set()}", "关注打招呼", udid)
         LogManager.method_info(f"循环条件2:{len(anchorList) > 0}", "关注打招呼", udid)
@@ -331,7 +334,7 @@ class ScriptManager():
 
             if not anchor:
                 LogManager.method_info(f"数据库中的数据不足", "关注打招呼", udid)
-                time.sleep(30)
+                event.wait(timeout=30)
                 continue
 
             aid = anchor.get("anchorId", "")
@@ -354,14 +357,14 @@ class ScriptManager():
             if input.exists:
                 input.click()
                 # 稍作停顿
-                time.sleep(0.5)
+                event.wait(timeout=0.5)
             else:
                 print(f"找不到输入框")
 
             input = session.xpath('//XCUIElementTypeSearchField')
             if input.exists:
                 input.clear_text()
-                time.sleep(1)
+                event.wait(timeout=1)
                 # 输入主播id
                 input.set_text(f"{aid or '暂无数据'}\n")
 
@@ -381,13 +384,12 @@ class ScriptManager():
                     session.appium_settings({"snapshotMaxDepth": 15})
                     continue
 
-            time.sleep(2)
-
+            event.wait(timeout=2)
             # 找到并点击第一个视频
             cellClickResult, workCount = ControlUtils.clickFirstVideoFromDetailPage(session)
 
             LogManager.method_info(f"点击第一个视频", "关注打招呼", udid)
-            time.sleep(2)
+            event.wait(timeout=2)
 
             # 观看主播视频
             def viewAnchorVideo(workCount):
@@ -400,9 +402,9 @@ class ScriptManager():
                     count = workCount
 
                 while count != 0:
-                    time.sleep(5)
+                    event.wait(timeout=5)
                     img = client.screenshot()
-                    time.sleep(1)
+                    event.wait(timeout=1)
 
                     # filePath = f"resources/{udid}/bgv.png"
 
@@ -415,7 +417,7 @@ class ScriptManager():
                     img.save(filePath)
 
                     LogManager.method_info("保存屏幕图像成功", "关注打招呼", udid)
-                    time.sleep(2)
+                    event.wait(timeout=2)
                     # 查找add图标
                     r = ControlUtils.clickLike(session, udid)
 
@@ -425,7 +427,7 @@ class ScriptManager():
                     count -= 1
 
                     # 随机看视频 15~30秒
-                    time.sleep(random.randint(15, 30))
+                    event.wait(timeout=random.randint(15, 30))
                     if count != 0:
                         client.swipe_up()
 
@@ -437,17 +439,17 @@ class ScriptManager():
                 # 观看主播视频
                 LogManager.method_info("去查看主播视频", "关注打招呼", udid)
                 viewAnchorVideo(workCount)
-                time.sleep(3)
+                event.wait(timeout=3)
                 LogManager.method_info("视频看完了，重置试图查询深度", "关注打招呼", udid)
                 session.appium_settings({"snapshotMaxDepth": 25})
-
-                time.sleep(0.5)
+                event.wait(timeout=0.5)
                 # 向上滑动
                 session.swipe_down()
 
-                time.sleep(2)
+                event.wait(timeout=2)
                 msgButton = AiUtils.getSendMesageButton(session)
-                time.sleep(2)
+                event.wait(timeout=2)
+
                 if msgButton.exists:
                     # 进入聊天页面
                     msgButton.click()
@@ -460,7 +462,7 @@ class ScriptManager():
                     session.appium_settings({"snapshotMaxDepth": 15})
                     continue
 
-                time.sleep(3)
+                event.wait(timeout=3)
                 # 查找聊天界面中的输入框节点
                 chatInput = session.xpath("//TextView")
                 if chatInput.exists:
@@ -497,12 +499,10 @@ class ScriptManager():
                     if chatInput.exists:
                         chatInput.click()
                         chatInput.set_text(f"{msg or '暂无数据'}\n")
-                        time.sleep(2)
+                        event.wait(timeout=2)
                         # 发送消息
                     # input.set_text(f"{aid or '暂无数据'}\n")
-
-                    time.sleep(1)
-
+                    event.wait(timeout=1)
                 else:
                     print("无法发送信息")
                     LogManager.method_info(f"给主播{aid} 发送消息失败", "关注打招呼", udid)
@@ -544,8 +544,7 @@ class ScriptManager():
 
             # 设置查找深度
             session.appium_settings({"snapshotMaxDepth": 15})
-            time.sleep(2)
-
+            event.wait(timeout=2)
             print("即将要回复消息")
             LogManager.method_info("即将要回复消息", "关注打招呼", udid)
 
@@ -562,10 +561,9 @@ class ScriptManager():
                     homeButton.click()
                 else:
                     ControlUtils.closeTikTok(session, udid)
-                    time.sleep(2)
-
+                    event.wait(timeout=2)
                     ControlUtils.openTikTok(session, udid)
-                    time.sleep(3)
+                    event.wait(timeout=3)
 
                 print("重新创建wda会话 防止wda会话失效")
                 client = wda.USBClient(udid)
@@ -582,25 +580,25 @@ class ScriptManager():
         client = wda.USBClient(udid)
         session = client.session()
         ControlUtils.closeTikTok(session, udid)
-        time.sleep(2)
+        event.wait(timeout=2)
         ControlUtils.openTikTok(session, udid)
-        time.sleep(3)
+        event.wait(timeout=3)
 
         while not event.is_set():
             try:
                 # 调用检测消息的方法
-                self.monitorMessages(session, udid)
+                self.monitorMessages(session, udid, event)
             except Exception as e:
                 LogManager.method_error(f"监控消息 出现异常: {e}，重新启动监控直播", "检测消息", udid)
                 # 出现异常时，稍等再重启 TikTok 并重试
                 ControlUtils.closeTikTok(session, udid)
-                time.sleep(2)
+                event.wait(timeout=2)
                 ControlUtils.openTikTok(session, udid)
-                time.sleep(3)
+                event.wait(timeout=3)
                 continue  # 重新进入 while 循环，调用 monitorMessages
 
     # 检查未读消息并回复
-    def monitorMessages(self, session, udid):
+    def monitorMessages(self, session, udid, event):
 
         # 调整节点的深度为 7
         session.appium_settings({"snapshotMaxDepth": 7})
@@ -620,7 +618,7 @@ class ScriptManager():
             if count:
                 el.click()
                 session.appium_settings({"snapshotMaxDepth": 25})
-                time.sleep(3)
+                event.wait(timeout=3)
                 while True:
                     info_count = 0
 
@@ -724,7 +722,7 @@ class ScriptManager():
 
                     if user_text:
                         user_text.tap()
-                        time.sleep(3)
+                        event.wait(timeout=3)
                         xml = session.source()
                         msgs = AiUtils.extract_messages_from_xml(xml)
                         # 检测出对方发的最后一条信息
@@ -786,7 +784,7 @@ class ScriptManager():
 
                             if sel.exists:
                                 sel.click()  # 聚焦
-                                time.sleep(1)
+                                event.wait(timeout=1)
                                 sel.clear_text()
                                 sel.set_text(f"{aiResult or '暂无数据'}\n")
                             else:
@@ -804,19 +802,18 @@ class ScriptManager():
                             # aiResult = response['result']
                             if sel.exists:
                                 sel.click()  # 聚焦
-                                time.sleep(1)
+                                event.wait(timeout=1)
                                 sel.clear_text()
                                 sel.set_text(f"{aiResult or '暂无数据'}\n")
 
                         LogManager.method_info(f"存储的sessionId:{anchorWithSession}", "检测消息", udid)
-                        time.sleep(1)
+                        event.wait(timeout=1)
                         # 返回
                         ControlUtils.clickBack(session)
 
                         # 重新回到收件箱页面后，强制刷新节点
                         session.appium_settings({"snapshotMaxDepth": 25})
-                        time.sleep(1)
-
+                        event.wait(timeout=1)
                     try:
                         # 如果 2 秒内找不到，会抛异常
                         badge_text = session.xpath(xp_new_fan_badge).get(timeout=2.0)
@@ -827,9 +824,9 @@ class ScriptManager():
                         LogManager.method_info(f"新粉丝未读数量:{val}", "检测消息", udid)
                         if badge_text:
                             badge_text.tap()
-                            time.sleep(1)
+                            event.wait(timeout=1)
                             ControlUtils.clickBack(session)
-                            time.sleep(1)
+                            event.wait(timeout=1)
                     except Exception:
                         LogManager.method_warning("当前屏幕没有找到 新粉丝 未读徽标数字", "检测消息", udid)
                         print("当前屏幕没有找到 新粉丝 未读徽标数字", udid)
@@ -846,9 +843,9 @@ class ScriptManager():
                         LogManager.method_info(f"活动未读数量:{val}", "检测消息", udid)
                         if badge_text:
                             badge_text.tap()
-                            time.sleep(1)
+                            event.wait(timeout=1)
                             ControlUtils.clickBack(session)
-                            time.sleep(1)
+                            event.wait(timeout=1)
                     except Exception:
                         LogManager.method_warning("当前屏幕没有找到 活动 未读徽标数字", "检测消息", udid)
                         print("当前屏幕没有找到 活动 未读徽标数字", udid)
@@ -864,9 +861,9 @@ class ScriptManager():
                         LogManager.method_info(f"系统通知未读数量:{val}", "检测消息", udid)
                         if badge_text:
                             badge_text.tap()
-                            time.sleep(1)
+                            event.wait(timeout=1)
                             ControlUtils.clickBack(session)
-                            time.sleep(1)
+                            event.wait(timeout=1)
                     except Exception:
                         LogManager.method_warning("当前屏幕没有找到 系统通知 未读徽标数字", "检测消息", udid)
                         print("当前屏幕没有找到 系统通知 未读徽标数字", udid)
@@ -882,9 +879,9 @@ class ScriptManager():
                         LogManager.method_info(f"消息请求未读数量:{val}", "检测消息", udid)
                         if badge_text:
                             badge_text.tap()
-                            time.sleep(1)
+                            event.wait(timeout=1)
                             ControlUtils.clickBack(session)
-                            time.sleep(1)
+                            event.wait(timeout=1)
                     except Exception:
                         LogManager.method_warning("当前屏幕没有找到 消息请求 未读徽标数字", "检测消息", udid)
                         print("当前屏幕没有找到 消息请求 未读徽标数字", udid)
diff --git a/script/__pycache__/ScriptManager.cpython-312.pyc b/script/__pycache__/ScriptManager.cpython-312.pyc
index b3eb96ea01b4e90b307ee4d34ed3f86df144110d..ead533c8fab7d40eaa6eda8524d50dae1d04be19 100644
GIT binary patch
delta 11751
zcmcIK3v?6Ll`|TRzLqqSMv^6sEXl?n+1SPy8?a;ZvH6(<NcaR&z!*k=KiGII2S`SQ
zq-lc_H!)lYNdpN<w<jc_DXF_H?WWx%r`^p-d$xR>1M6kmWDm(U-LxSj{bsk_`(`xy
z0m)`hJ3hX8^WMAn-FM%8_uYHneEg#B$0v2RpV({`3ZM5E|I7AsFWDrTUIqK;3PyiF
zHU15{O-D2EA;YsrvC|RQ$3__a(4$bNuVNUPflhsh*260eMPTo=>t$V!4d&Ijb@WL%
zQ0D~;>&~fXn3Fnqe|9A-VI7QzqF^i%fWPc4fP2{}dq&px_z5=r&s>KdUxF|w3Wg*r
zvpoWQz<OvWm~IZk6a(jr5{AhmnqQ#R(tWhdLRYT`HW^Gx&k%gs;PPa87G!z?H!BQ3
zHMkgU#1&SD-b~?qKHSPft<|DSl)>`d0=&A7*NSaM53N@I#fX*D;0MMM#+d5YX5<Cg
zC~`9W0;95%G$qQ_5=He)2ioLznndSG*9$temZmbOF4-iywT7fwHuN+g0*{i4)$y|V
z3F??mWHY1@b*4sI^vGrnlcqHJJL!`;ZMHOJrV<_)*)BASg-9ed{(AgPT9XB$KWR%e
zr^y90w03Gk3-++9sMD@NbtF02Dm!{BC`t;*1v00UJfbsc)3~V4;bOFz3`JA@w4Rc!
zqP@4BqQ+=xooqw6CeZ@FY7#inE(SFYlTIA_?e5UQL9;38l3m!1BMavg@`RzFy2OxZ
zOryFL9#H6v8#V47OTDJ7EKw{~%T`!9vr{bUML|f_gs?u0gyHFWFLd<q;OMl&|I`)1
zek(_(Mu>{VHy8m|3bqz-4AZj!qBcR_zal}DH3Z+m%312<Tp}%o()hf_p_9*ED_Ny5
zhdu*cwi4grJ=7kmgi1uT1)4%hl}QWX*5{Qi*U^k9oV9sMsHA1DWf#4R+Rdz^cF}nh
zijtNTdu4X6+;Sf+etQ4eTK{mFOg}-1<;uwV+-1;Ky$ScYrbINgj#6olzLY;ktYX=F
zWa~ahPZ|^5JK_VwiSZveJUTe<+^Q!A31+#zMwh@PSA%|6S9fAuaC5ZakpkExl^~d8
z<9EjU6O)E5eckvg)x$<!rakb=NFn@|pI-Q|o}%_qZ@GL&rXHAjxaNv3PTR^Z`vq7L
z^T7s>YwAVLbHsAMa=dQLGQpKz;)Dxa`B|>~gz*$V!8PW#jvw{_?YvkRddl*+<wV_M
zmWjgZD+N=b(YMlmF;e=h<!Q^Qy5p8NBMorKw<%pU`?zHy(sHnHuS4sk)?9{%3flq~
zh3Hcqk9VBd{aD9@FzcdF{M7Qtmrn@QS32R{!rSSM(CV*abha{({AKr~dA-1up5;nE
zxx!-0pN7^GNi8T|Wu|`I*zUM3M!jKJ)Uq;6onttxI~Oyr6qs|<OIP}s^F9{K=LH7q
z&xg&c49xio|0<f9pjj+W7)bqu*}U4yOt@-S8<;l@ES9&R6v^XIpcx@Ca34JiRe^=(
zsF~7HXs%4~k|cmo5{2&uR_bIOywb^YB74%1QG|p8-rgp_e+TTTcCTp6Zbv#6(R9)b
zO+pl&4bG2QL~D-83o8sD5VH(9VzDr2@Hq6MExol06b3w=f@|p875b%YP&W6J;6@G6
zmXyUeGd9@<w{GJDvaJVgTK<!CB<*lUn4g|p4)d~woD|R>vLQh%EfzU#=1Hf_^?38i
zQPfbA?7VJ$O`=-sEjr<N*aJTa@%2t34Lm(krwbkd8F{$1vF@X@aCw4D*N_9%&*x(+
z()OS<9*zihX+{>BH-+|gf;VYcuv;kOXlnGgi8_rnJkkd7gjzmms!Y1F(0#It7$uD(
zJd#`@OH94gkf?@7!(rs;z+f(EcsOjdW+v^|7~jboR1V-wxXK;uMOBx6n>Ci8b*yoR
z1&vpgL6lE}#;T?xj7|(ef5c~YXU#rrz0Q>Q49gl3u_!Z`xkwv~2nOaxjaIv8ybI3}
zZKzOK)M@H?7m`TwvLm-gRF_d$rH3bLViB2_J@EZ#G={$#9hCpy>#3|>(JUb=J5H|+
z?<f{aG&HgY6gIaOH(R~vqp)|`kRc<y5(-DB$VN2hrHR?vG-a<w6jxC%TH*cTTWL46
zmPAy=_uOpC-c*Wp_wMzM=|{hX_8m)^GbdKIOd`I9L{?Uc5I}q}NgyCZKp0*w`2yWE
zUN~g|O&5=EEWM9L?RdNF)E$$0aw14eNiVWK(li356Hre8;a6e_m_YzpYN?R`;>b+0
zcpz-)m5ij~CIZlrp`@D$SPt)$N32bxxR`*Mz*Pk44ydc}#(bHhMOuN4lhz$wyE~<L
zLh6nWNpaF$WeB!c6h&?&?}V92YhU-B@y^Y|iNrwvq=_6=tB`p(T2W=V9ovU|cp?Sh
z-HK+zSIFzFP#%lW{jfN;s4{KSKlA*7@5YvdgR#dNpK5))^+fTB&F6!4V<zp4nng~q
zsZdb4p}>En<3Pvp!Lg1BJ~p1HEYbPZn!U&Ge0J~CdrxgSU4OoO4r!hXr>2G-3mD2B
z{lmwL8Hx{GrL6GtsXOkuVxXK}<!EdsglqquEBxe&&ua7kX{ZgS@U?d1t$ON5Q*Y++
z=d9km(!`v#Rjp*0v$KnD6LjZ-G?vc^=G!XRbEP^`E~iPk!h_}W42%7>Qw6C}lnMWp
zL!}Y@fg_a2(n&qK;!eE)?^XBGW>{Slrsu$L&0-x^M@snVcyyRFMNRn_>|S=X4|NcK
zvvkms(m?^NwHvL(WGbpRTn}8W2kx&eUS&{pYtp$*ipLYn;=2|O^z{wwic3SP)?}23
zC|S&q(UD1We>^VU7T?*oM^zW2rYg6?C$+a0nQ<~h&mt1>LEQU|7ga~(5IQ0TJkoon
zwPHB&+_dHy+9IMGq8;r<h8*oaL_Xx6$5F3x=J|!ptNw=hZss*Ni)HwL@tTU<6!if8
z00YzNeoBu(MD!R$=A<6?`_p<i{IS6ezp1mU4GbQ}FgU%^Z4h-M=@^BkM!Y>9azYr5
zqN$rk%;jtu{ARk%#_ad*r?)bq`F>N9#CKuVGQwa))};?XdwqS_njl+Pc@jlhNm~-J
z0Js@mI9VTNZ5mct0kxZ!Txgg-6H%|>=*NshpbTy&Y{TGg9^!Tqpqb&=j0o+3AI|Wh
zi-;3oI2`o-8PztYY(SIdI>u-ix}GVdL(qMa*Z4zIdNe_#t324=r4PcF8X`dz*`p$7
z&RW?xR7u$2ym`_iGUr7fk-16>DgRzJqHlp`94GoUBb+oTmGgG;I?)en8)L?xY(h2#
z*xwk2Zd|GFH&(erdDK&D<4&!OHUh3$jLgVZq>Y-ipaarn<PB1ZZ0V^c5s13%m0~!X
zw|;Aa=(F;O5e-|>f*Vq7LW;E+igs1QR2nn|S7v%)#VoTYinA%sKKC`v3K_)`qFEXS
z2BUcXs1G_3PtKadP05?Ls>x+(O>SxTz{`y$Xq{com0zcCrKt4PM%eG!uWGMetU&Fx
z%LQVL1gB$+)B=&F8hCd$m$xgb@~EaH&*ky1>@ioaOmUvg8S!wrtR#GJZ?}MpYhjWO
z1v{^U>`>ROUUsPK25alX@UP9KaJo4<yE>Pxti`L&2ow)}jKnhUn&A07wHaeZKS)i0
z%~p!EI@M@2FtX<eTO3B*k7Ny63;PyS6p6Jr<Z4=?6`U3U3R+@JU8=mQ#Z9-t<5oeJ
zs(7X)W}7ZMQD5pan-mUX;)ZUm3C~bk8c5PZY&^#14YdTKeIe*=oobvZyRpYCc(S#@
zKbw>>MUrpXRGq$NS_Y{JU2?KZLJZeaM^ZBZ_ilPfM^oapYD|>Tk-Msj6ouT4&|j7%
zs3syPlh~~6@tZ(Dw*<pd+_9d#B~h0SR?H1zhGDF(vQj~4$)C!NR@j$EZp<*+qOCrv
zu42%&O`-6tC-Z>g^DrAUuK*re5aPwwT&c-A>5p(|-c)#go)!Kw->R3Xo?GBjUDTQ}
zm&@SFyeMoox($+3=2f-T^{;?4byKxdD6@BSP9fA&b$ojM!M5A4FOz<^Hic{Ko_7Ac
z(#DoUmblwA#ii9`Ny@rl-fafF-!_vjg@+scbR)F3#~fvuzS=mYd7@fJjhRL{gzV_|
zv;<159bRlN-F`Qc&URq&b+`b*dk=i&ow08wx_c7?y%|?`OUmde{1_18c};!vI)cN@
z5h{^xl_`xWOuDT^=bVNQEJZw~i*zIU%qfJYqLFA3{4BuX;uSd<4Gk@LD)D+xPRu>J
zT8|Qm8J7){=>3=fc<7xcp1gee!ON%jz59)?OUh&-*r595F;XIDbId4pkh0?X%p|3>
zyFF=ET<iH==w2)S5GxIn4qqUE_{=WVKQF=J5b@6=k$td!;oQPnob1p#toXw|>XIk$
zSOcuTO0nn$eS6_dca{V6CRh5Q73;@8Sy+t0z<AMOFHOgwVM)E=Wpoh_>!E*%A3egl
zI1fjc)UwA$Og$_Sii63HOGb<&G0p1ItvS(p!UV@>2;QFbIfQ(r9<>QJc6ex|lTzZ~
zVn<2p{gqCSn-NVT7EC;+G9yWS8jFXWOKqv1g-bo~&7}nlrc9JH_lrv{1|>u5Cl&`j
zSy})uge@evcVnt!#FDkp+MIF{7>O`!unSEiX6#DhDtwX#nZ~dZw`P(iQ&nrTVS=oL
z@~B==sZF$N*x3R@I&3elwZx4Wd&-Gvv}rZEF?#eET)8=-M^$pb{9Br)M3ACXMS$W_
zD^VWN9Cd4yl2SQ5aZB_bMa2}wijvA21Tl{qc_})j1a5Ok(_8}P5ip+sOc+qo0s`6y
zXeMAG0gDL8XeODmw2S~HG*e?de4Vro?dsmSI^HRDZ`+=TStrfA2BhA$fnm%ODjJL1
zjFMInu!eLuirvzRuEh39T9TB=jwo}ME?e<6qCWfJk!33l4-tiq!!MULS6<|^W3G#V
z$b~@F*+A9#K=oK#ZW}CGe%PK@^`FZ_L5#ON0TQ?Uof@NUK3#miyoJPQt>d8;w=nG$
zY80FafR*4iPYijXup(fhqS7n^ros5i1qLPZZH7Oue2!iUCsxgi-GXg7k#CZ8R%ZW2
zEKM4u_|R})Lb@MZtJ@8akj8_se)Y`8PEt$<!Ah(W*@S=j&)m6^hjf(@+!cl$3&S=a
zk=-eb`aao5U54;xKiJo_)?75%9<hvA9;@4LnJ|SuHc)2I1ylH}DSX^`f}b$uwL@af
zO!jvMgSl+{)S6ASU9%z6Nx)hL!L`rW-%6!->&Gl_a^>*)+NyLfHRB6^Uc1hH#YNd%
zk93T5JT|z$W1=8>Io1H(>na=<3!GWCzlUS%rskthtcxwu#>GJ<xbn9+-vzGtELS|i
zP0@x=WtWAL3&PB^!pzgg^TOOQvxcX(z6H&9^rabA>&Cxz$1XaWmvPn<g#`F-^0CXj
z9~Q1ZnaAuU`1AUEX65SHB|dV2uR6<Domg~g)db&^+j^Pvobk3zaP5~;>G6Ns5DP3Y
zQSL&LJAbt1<HaV*Y(HbKf73MM4<9cD^Tq*ZX|-5EU9OlH+FHQ8Yo)gqK+zT-y&j(4
zcsI!vVVJHL@d60l4IUOR<;gu@s@{dJQ+9?>*MnZLKEMu@;T0Ub+Tr14y-drxj77w|
z1*J>T5ItI&x)O1rLMabki3}&%1Zo+vvxTBwX3;fd(YZwPn4tmp)+m>hpTQi1%)y77
z_{gbik_pCTQu>g@<W;0=^&JKI8&fezc{_0$vMD`JKnnrNwk3I~>}-O%<<k2}x*aCE
z<`~-0v<`g){>`;hbGOGO6aQ(OqknUdJ+)whYl6|u3)bZ7+Na-hTq3C+hmoXu{K(>K
zM)&+`>a}WfdlmCq<GiZ&GUi8REWT{fLv#zzUd7Dz5r_-~VAYly2JhD3tjO!fEE0p_
z4l5O0J&yr_i6{5CQXmuj;jOMiac6$mX9lZiGaF>Xm|1!iX+*_#lIg)q1fE<8WZWDx
zB^oew*|jAa)RP5QAJHP~wL=Y0Si*x3f}4tBRuQiPG8&KwrZH?9O}zWECrwDvTOg-X
zN<ATx5eS(xId;5cMWaO?(b0>GA{9emQ@9k94mTJeo&Ud&{@ju<q9lfb7&~sThpLp6
z1V#io1MR^KN75p?lU9+(D_l>~CVKIHVsOB3wQG!G5(51qr!OPFqywYODNtv0W6tEj
zU<s3XBW~r~ZCrNEPK=IJ9>PJHQv$3U9%Kgw)Ndfg7;zWyBLU^kCug~28ZScxJ6_~g
ztHMK<yoPu`OPv~*N!K<?EP94cx-)kRV)%Y4QLkahF0F4n^+KvLlicrVRJ^HzZgYXA
z0!dzF+lOiNYuUzIh>`6fUpg0*^vE8Gk@=*zzgESIMz4$4pfQvl(!zL=+6UW1wsh89
zTB_3U7t3BWLM3Q~a)hSd1lu!d_M|t3FhxNqy#}E=bp@_Z`jnnwqfea_4D9w|Hq7HI
zzb?D#eY(tx75Q>$iCqst_Q^WzZ4fJu>bKF!!p!!P3$+En<ej3FzACx!I+7(}euyrF
z7kaDRe%Y5G4x94aNlT|y%#s=z*%xcCnI^G}%G0x$ENGQioF>*CO`j6V*9w7TP!49O
z%06O5Wk0;V!^14a->4W?)ex_oGFp!o!QZn~iT3>%%OY_)0Q3$&eVT0H@)>yxl(7*r
zv}xnDnlkN%28H>?YnV?@RQ3_0nG7cKrW5qaL7dRcqv?<>Jt39-j?c?}p-$x~JS!uR
zYnMbdqJdm-B$lg^#?80_?`?}9I#8A}w<JI}!v|6cEE}|_iPanfBFI9H0m-~+1|+K{
zV?aW)uWLXAX$jKHG9RD8XdaW*e?<nH{}v3ESkpJv*D=QbUs<;NO<09fTmPC1KIgB=
zWS&~!9p*gcW213A>gfT#A{okf6^YfFa?2rczGnI)K@Rn-A$y+*^{gf5;%diT7}JrP
z*M1xJG?0CZzYg*%rrR_NkSw~v2yHnd+>sh#JsF`sO+^`jO^sl>!3bfQ?&&1>jv_g%
zQPm8tr#;t7jhROu+CvfhHT(bM<KXu{0ZlIGF4rh@H#G<@QOG5XUtA@3`>P$9dtxOU
zwnEE;-I!3*HH1DyLgb^k)P*w=Vn*NoEJAC=oAL>1jEgs+uSIeV_+YA*O6C)v^V!5(
zZ%DlLQ;F+Fk9`(#mpC_{INWlVzap1Qdh`>GP;9|6DS~r(j|2q6FTtxN#c=AbuLcBs
zRd3EmNl8hugh=T&=)AiKkFC9T|A>x_x5+=%>!j9k;oifv;X9=L+wk4{zCiy1++X|$
z?hvUsOu(ZA9D$#IaX<ZS*mnPB8sLrlrv;{9bxb$O4i3kqJ(K$3p|~VHNV+}*{FiR?
z{WBIP9a{$a@5HOnu0;1he`mKSy*{4&(w(%miuBt>z;5{Smn*hTlV+0_HMu|#by9rN
zFcj~SwrrPPCKXIKeyGK6lLm%&N?S=^;!UZEpmaE-L`Rdht=;`%XS^@I1Hb7Sk{%=d
zlqBR=;lKm87cV96&mx$#b`N#-b@gu>?%EcYPLOKc(3JEXSoXJVI7W(35}*WR_hD($
zuo=@o;?SgVdl$|qA*nOiPCD%-pqqeR1hI&E%S&8P<x4X)IJ*sBC+Qv1@c7sF+i3d%
z@~Ydi8~^tVMevTl*c4Gy9nZsiBgMvbBzALH!S&$2yu`uyu?N3{8H=26$;LO1Zq=nf
z8^bTjCh$wLpFRA{wN()~`babn8(x28O8&=bIwuqz+zOk<VwKu=W`pEAv${({#RXyd
zSz-FAnG-^DZX0}K?9k`w9zSsK^K=g$gwNCc+`$)(+f0-%c%=^>fKuHs3)2o2!x<3h
z&EvlY7rmi+KG*G|E?V1yJx=Q1%G-jyR_Yf_Td<F%{v(V(bEx-x^*wgxS2mhJXML}U
z`7a|)ptZhF$GlI|1hVygH!<%w(*(|`-_gkYx`E!&2<s2u6xd9ZU=IQJ5FiuqJp!JG
zZyjDDUbSqe*|Lw;FvB$KztYbztm&%7%I>7E3f+3P;p$qmoAv*0YQLUcL`xVfQxeHK
z$NXx(@(nCcniJclc$e7SkDnlrcYVBnc!z}9?$oz0bD{Im<5Rv)-U+Vs3IPf!50?I9
ex@pININTR+m2^;YWUh1AMlYhTQp%6g?SBD?-gDvr

delta 12116
zcmcgS33OZ4mH+E&-(@Y9WXY1e#8$l9v7LC|LWm&&oCLy<U>tuXvEnUXa!k^%EI>=r
zy5Ml*28K|=RzeeK7@smMQz#UAW`<6|#61DmGr$Z9P`U(2IUJbI%za<_(wFQ|PUp1$
z9KHYa-hKDoci(+?d;gVFvWrj146hmtS_+?*)_>bBf6~Cw^tG^`E>>t+`EB&{NxD-8
zJ(YIt90DDsSUM($DnqV(QXV-8CGrx5f>(r9@Uh-4iz(sV>RcnQ<mr<#f{~(V3aZ+3
zX%=3ubkJt#tG5~!^g3DQBrSqRt??Q~g>BHMv_hT245w<eV63*ns7nh&ihSm6UI_;}
zZ1AYU!YIRD0q&OyEu-R9@UFookK{+KaA2z!%*w3nd=Vk55vRF@MnKC}8>~@k=s09l
znH5Mu>Qj&l2zpkTMaQQv(V3MR3YT9*mamVgqs8J}aG=o!zf;+?8BJ3vyCx0D5v~%)
zq~6hLIH}6lX%-B&W$_x;jO=CNz%gw!2rqPa+`N{xoXSdZec?zmf>=d>n2uM&>wY`r
zj%tiFmAS?;8?U>Ux=+R`Qd1$+3XwwA&g(=}@f~)vGLdC8rJ<tPB51gQ>`tpIB@&xZ
zG-8IBk#)yR(Pj~j%@N0UQJdQk!kmetBol`vmc<)*%MRox=jDxjmQZuDmY9hMU8$6$
zi54;)O%2m>iZ`&v9bFVPNprot3Cm5<Ryfe)akEC&BQ7gumCWBk1Q+husj<auybVV<
zGC5}PX7EbDXk>F)RT86}P$lE-@S?URb!y}>WkQ-ubQZgn_3c3ZaAlbj!1FpYt$_n!
zuPf~UrNITZ+sup8L9==3bU1mt$nb^x4^4VAqX@4;vG&M^*Ch_q1U5FtS!HBpY;F>v
zgDlL<J5mVoOpw8?^xLQ_^7DVV+qv7BPet>@-7cWGr7?XP?I<PL4qm^A*yY0m27A6U
zrr)a{r^l(And_->Is;oS!6qE}&kW`w{Vg>6)$r{ieBlzFzL#Q)gqh{(%;V*(Y>xqD
z5j9?W?mnrSx}J(pF!4<0M8V>*f5ByH{fXy;+kbfO+b7O_^SN_({^R-YJ#&6~>JR@k
zaqj6Ke0ckJ-#>Ey`D4$XJNQ%*xM8%9>l^Zqu>)*_|AQx<KlkwM{taELy9mHO0bv3n
zv@0|mZScSU><jOo_|Ew|9z`Vnm82~b)llEfy<8~D4TK^M{`1H7pL_UGocV(vO`SjW
z!1<}u{^GSG!y*3%51e@a;b+euJ^tZ6lkx6g648gmIDAM`D3;St8SOH9Exc;p3U!tT
z=>mAmQmcy&429+tk-<=CbUG``Ojl=fZXCjq-JVkjl+NiSbj+y|1kEY?2M3U5t_oVL
zJp8^W0B>1KJqP6!wV%3Rq^$OXs&}%okCq-TohrW|3(<yLaNA0k%$sdTwTHELR~<3T
zn>}aEMKk826ROj;S#zDFYnrnGZJc*{?$_R<JzjOpa6w-J4#zs(yuaX4?E~5qRgV~8
z+;Nj${J&z>Ukm3PdkxZtdEl};o%0_5{oVI;AHR9lQ~9PR@BXXqxoXx^c40HTmVF()
z35uLm41>ho;9RmV`|hg4`bkxikfVmfhA%Iuu=|V1CgjM}%Hs8Y>XnwRtaTLiua?U-
z>*}aC+-7V$LuuC4FlRJ{>&lrk<qA@-VMu$OX1$j=)9PC9WM-WTtj~H$`>bEHVJR~k
ztlv<`{Hjoa^?o^J!zmJv2H(U^d^!py*JUcB2DcDZ%?xWpL%LUvf8-EQ*r7C}0kgY2
z*<e+kOqyc^(z2>kY6!dg84at2*WKABo!Ea1Eh4cdEhZ5Z9Agm11T?ZqdP2=>!U0qV
zUig{UE05`UJu$wyygs}{q&4-98Dj>7*AbHnpXU@L$udaD;<fN@o!wv*35l5!Ev96P
znK!|4pPgyo&E#z;kCup&ux9wFC#W*BTAn^-feRjcc9uBq7Fq&lML0WM3OkqCoN-{$
z@FrGi!&Tns_32Wm?TI0%&g}NgF}zmbgU2}W$7qE}O}LU+mu9U<LChkdz`<LHMil#K
zinp)|V!XIo2~@U7=djIosX5KK5j~PI&J>|4SAr9Bxg}Qj4wO>vj}pk76l5SL6MeKs
zTnBEuBD{=P`+Ql-j*66{Ri8#pnk5KFoNXRs#F@zk_?0h9!cA{#YP&acYLS~+Xx7)E
zQCIFk6_ujGmx~SnwvcBJ{$f_%m<bb*vHCO^n`GTS-pbqHWq+Uq-y#%EP5f9+Nud1V
z3I&lMC(5Qw5P{|xey7tWr4)BBE&x6l3)IneI28y6@_7~7pMsQgl`_n@^Kv|Lp9QX=
zv*7YPzjzdE(8_9?XbO!G6|?WPPs%6mkJnQ6F<7{kBa7!er0|i#PYN$7a^cmy8|W3&
zMfodfIxsy{a0`u6exdO6dX8)-*G&o{pj<gADoH`yRBkyb6r`vo#WGUVlA-~NIR&co
z{vDi(G&GW;i4<$$izWV2;yZGyNKr=$RPofDxqoDAINICCvb|e&_uf1-$gL)QS3rA_
zBj89G5$-C|d^IT~<iY-;Tt^RSB&5yh1_yS9dbf;4qa(xcd{K#VBeq5y@P{H7Xo?$^
zN66n5&|U1O2VqC?s$%z~{8CorO|zsE=8ISBlMU5JjL;R_tjnG3I@*1>`|h1b)=WPh
z%$K>uhP`+1x_|FIdr$PAt~ukYpS3NA4@-QePKL4uKEHSwL)pBaP+G_?9oqL!5^3YC
zx#-``&Mz<6wFcK0kxnG_q0VJjS5Ys!uC(Fn^(swIE%SOqNlzs+vm~!aBYQ(lWBm<{
zrpK;$BTGi=Hk#D!c2ciYAUs-w)T73#U<^=h;$a*p%DzpjVY19ecfjeg%Vkj=9Pjm1
zqQ{z4|AK@m_9`YuP`>ajkuOa`zP!*@exouM(T~+YpvMM3DbL@a5(H<?vW*LcqH9Cr
zmyHY#j*N%6NL(aR5+dv;5u>0owcm4^;ZTU}35^c!j&J=n2*7QGWfj-tVzfd<9>V|o
zsduuh2UTyz{evUuA1KiRKUC2|=fZzhG*&EXfJs<##M*AAUNmbua+nug%R3y*OAbXx
z4qRQCt=wy+sM~26sr&_GD}33~uoT_E_=92Ti}g0BsL~^hA7(0pRs}0Nlnlve>X0Lx
zErg^e6efMtl^p2CfmZl!8;Q6MIu6oXWvu!(H9D8?R{Inhp20wt*u34<H9l>WoLJ$B
z`V$pO+!j^`uU6M8^vMyv8cqFI!V`lbIM!)&isR*zs>lmSgdc-A={h8&=LwX})C62c
zUa<%!MYxcxm@y%3fn{YbGp|IYX1R~a#0VqfUQ5;~tGE_ar^li$Z1uqL91T3X%&&@%
zwZXf~taKUSjmjR!0wzU~MG|C8e8H=5-krl3^f*QR98(L8NQ}WHY1I%!1~;!pvT}G0
z(X2pMxnNFZ1w(@t-l_~(J?X?sw^4QoV;mLE;}r>yX;GJ#!pxvmu>@-s$RH098n~%W
z1FzJX3_cN(2*jlaH{;+caj;1uaoApijzNyyk0b}AE`UgwRmtWJ(5Y!K>^6{O0F-s=
z;qCf>DnG@y?7|dWG$qRof-IXF)NsS{BGr-<e4zyXpk0twhAl#AHS&74m;~CB4A(=L
zN(bTN<+<WnfD6k_a*;rVKp+?tLBbWKa59?3wHhQdpai_8^WaA4;Q_VJB<bNz2`1NI
zEzaa^t+_I`1YT=&(IxPsh7vf^P-sJoD`(}YHHstvo<U4iO=t*WLmB|tlWMk191}D1
z=5VQa)>3bb_NSsmVF?dgPEI^sPNp|hMB5V0RJa3P+~NjPQ@~J}*4o@uNUwyqn>_lo
z=8yGO_<mDyeiiZW*y@D`C5iZQA@}g#P36HF0d^UYUbgnW45bsjB01tpVZ_$vQdJ#q
zMc8_{r@5A14zD$5L$%6k&Rnw~#Lc*R!e1|AM!9Qm$x+7T4)ltpbRpS8mqa*+mq=K$
zg0Mu@Ae^m6__QUTPO3lR3E{p#YikbO1g}*tT`E8|VQMK&)qK_VsV9{aH%a%C95V)G
z1m111(#?VfZcazX%eemqUt2c(29Gw^7LfB)_$pCt%TU^O?)1P%Z6<Vj$N{$SwzzD`
zhOfm)zm!aHi35|S{Lw8ZG{E=Ubnt%r8p*PUtrCLGOhUCQBeF@=#0xOf?to`HOyKUc
z!mm3D?^<pGQ<V-{mfNAC(=HW%2^N#%dTLTV(S)U9VqQ#x1Uun7orSvHxcQ=M_tQ?h
zGVbreuRC1@zr?O7*-<K*FzOV=CoKs&<=3KPOhcJG*T&MwL?#vB9Fk#L7xgG??kd+w
zA`p@bfs&ARAL{Ona%wl4?zLkkoaKWTj-0#q`|myd?f0JEfBx}DIDx2?=ZQLl3aaBS
zp5Oq~5u%eG<(x+F9y|KbgG_k^axOxkNZ=gzKuJ;|LL3`E?T40?ZO&!HA;48opYNyU
z?e4p4Vbdp+0$qXct*kdEoq#FB$2x4BerIJKy1LWMDhEv$gZuIt|15e%Q;d{9tVE|C
zQp4eXJKS=4x#6)WaeRd*tR#$)YU@L)um(?$+ZdB&f=T1nsFt``aPMk69j{rI+hmDG
zp_&CxuFg;NMY`=)hE*NXu<DZuS1u+`0mJHULmW~@{0($14tDEl9q0x<Xrx88hB1eX
z<jRe_MEOO%FrxS7U_5_FliKi1!n2ccK4u65$+hPZH>O^VBNM?DCNOCXtkAcL(NY}Z
zh}1h;NbG+=&l<$B5;AEFZ0m8G&4)0FUuT2;IXd`{EA-4`_#ag@{@2P;*o<JhvcV^a
z)l$UF5zjLo=?I}s0r|TGhOP|k6XcIb9p@(n(d|J;JO&Y@E-7VP3+ZnqMH?yFNkN=&
z4*e#I>mUUQaJZGExQrAj0T!a6HKa|5nur?a)?zWYUKbf37!CDu1KYMogW5UG_z1V7
zlSDjmnO;vIH<02w0<K~QxU2i3+vjMGOGY(94lP0waEWXpY+18Td6<a&-@$Wh8Vlxa
zPB9F5)9pX&E}3zcoN<>;c1k+Hzjmr!^8Y<&!C7bdjI;d2_|x(;&gRMX3t9?K&NYX-
zCs$rnQg#<Xc`P2rY&o5G##cLQtDF9E?HXovFdi1BBEnT<0U6v7V#5@7g#c0DIFVuw
z_ZZ_!nCMxlTtTW0aJJ_$x*HCxYY$$D4M9ozkoyLK5W>IxSesLFp~%=^lsf<)t?N=w
zkj^`yc746|CQ?nZErPO0!GZNwo!{Tq#@R{d9=LCPfx$yqcL0N-FZNUKfu+v{@2_tu
zo>%Md)E?4KR!tai{TlmOwQol4JFYrmn^l)fI$_<0dc_}=N=@$cof~eVb)tG9LE)dS
zeNgvaA~9JrWrD}AD@pcaq7u$ucYW5yEXrWHv-?o@<j#pTIMdQP=-F7TpVynk#?Ro;
z#?rKLKie2=N#Z?XddHl7)|@wE&YLwCh|MGq>d8Orsh{!GKdn0BX`9rDlwsGKP;>oY
zk~D0Xe*F4z+AB$nUQ{Rc{O+Aoge<!oR^D(*O4fUKZQ8d)Dnd5@SzF1Bt>nb2)9Yt#
z4U#T6x#>#xRcgxWBzfEKm0#>pQySyz#+qNLmwkS516VeXSgOlHPU@Vq-Mh7kIp0Wc
zZGyv_vuO?<+x(406l#<z;V53#Re9j`8|5(Ct4%^kY!d3YK)**3Da7kIxUkv*L%n9m
z>(6mV=!t^eXru7Dz=l#FJb3x=jhF)7?Z*g@L^G@$-LJHpE*LG#T`--*DlAG+rS!fj
z894uVLEx-h%Lz&eede1s^cpe`R4TiYae{<Y%%ix1j2K!PImeGm@*H5y{PUYym1|H@
zN6vw+ucAvL%=2p7rQ|%3bSFVICM4c5+s>K`X3Pc0uRFocnrq-&eJj^U1netv@be_8
zVN#K#h6^cw$&l4iO}$jD>8fL1YHY9Ss$yQQQgqdk?N?lehxRD6^t)mGmhv11qtk@Z
zi|<;zoYZn<xH~>Z&NFa8Zi7Fu8mpX_bM91B!^^`a!Eq@KIW%}XJ*nY7Lg+w$*Mb`-
z_@zRlCKr~h5-+d&wgj4))U_XrF}Y}`(2OohPb5zgCA-P2K`pD}WfH4O%#!e6su8sh
zdGLD55JTr`i$l*Rvn^pCaUhoBEpi|Zg`S#P9Dz5MxQX0?*>W)AzQk-M_z7D=e=ROq
zkV}yq$x8CbN=nR$SU+us-5A%$G;CH3uajds))v#V_Lu<<hg@(+M2n#Uj<h&VWs8(!
z#ApmJfxd1l=^M>wB>&L4d}7orZQ1HIm@?_`=I|yV=a5DRZ^Q`nE#4^l28-^k9QTa|
zOS{L2_sJxoDLnCv`xWLSiI!~?oBJRg%SvUlS>J6`lvpm|;VmL;7j-hx7A1yEc*4tx
z`{hgCA&5eQcgRHQ<1hkC1AY>bVf2%>6bWSw7<$=~DP?lo%rU$*W*@FdLlxL=_brAf
zgCs+eq?kR5(cKD<<l2|JA`K;On=6mEqdLq-b(l_{aG5O`ir6w1mR}$YEnF}(#q{JQ
zx-sTRAKq^B^NvN>k}*ei(W1<Y-`(?8w)oO~Ulm+zDDU89I8MnfJtp5q$FfsLpHGS}
zy1toYl<?V$5KDr5FNT2khs(T9-VwcA-1%KJ_gp%TMjHYkqbnA0s})u^drRzWC0lhY
zY2JhnCR{N$?@l4*9VEBTJK?oKJF^zwf&ScuCjf8uFzdoQ!)t`d-ibjl3M%b_z9FY^
zSW1<kx~i6C?0ZUeEfeJ*@5eIuQBo@`rf$Jvk{sY2WJt`7-wxpNa_qbt7g&ERnNLVA
zFut5Mf5CEGx(up<%Tvr+WVfv1?j*i4LQawIU`V1_c)~qGM0LkbJ;;X(7v(H4qdB_d
zCq?lDXqw{7;d9aypX6Uc@kv@1Q+zoq7FB#X+*N$erPbagm!iA$GLn~%f0bo4{%w{~
zxQOxj|L;Nb--h@cUD7-FtL#DR-(VTtsB4sLyYLy-H2O;<!p(SMo|K;!y-w`pJ#2@l
zyg3i=32zkilm|W@vt7#?_vqp`xWfhnRFZ>^ZzFl9`b7N{^Il?t&a??OkqH=2_(tNc
z)TGa#NX($V#0<GS9quFJU0y!<5!6CE5$H<Srjwe9f7mUxCW6jg@wMDV3|~AVvoL%q
zC$qtf$^&ga1ucUIYHTg67yZCQMusLA!}uL0s}Me4QVN;FaWQ9jDP&5vfly4a!6W0A
zvYa#o%*3aE9zjzQf$Qdl2(I|^2wFr0Eo@81deX^}O+57Hv9*cVD%iHK#70kiDPjw*
zT+8{Oa`(^eLOzLblsiNUA<?uB%zJX_A4A2Sm+9i^i+g?{Hw5W975M~eWGu=xPrtNp
zidIe&_$OiWfg9)#;h6)^nGchOyGQ|~I0Coba*%!!47YBfCt>u~N*cd$yVa_^opc_A
zXK(Gveg&&@rv8!PU3hES7abTG?j2ycpHJuCwu{yYiLWsNybB)wX7RqNcp7yDX%TMX
zWn5@Z842}q{oA=`2_|M>I69};#*K`Pa$5;lD!5E#aFTcSbB3)0!)$M8Ff@dpXGORv
zGD1k#9wo@+1H)TK=8Qw3==Kq|cf1cS`&MV3ko|g?bn6Bpy@P$j+s68~g}6t^P&~gB
z_X9Zjt<H^qPpbElLI`yCVQo&i1+!voWKOlc50@I{IALkq3D7Q543J_67C~S9l9*ih
z3#l<~9oFXPAucj~#q9>#cnA3_>%SR)yCXil`**|sgKAYg1N10N9?Vnq3&F4!o;kQ*
znrE3_b?7Nf=%l_Do7R12t1R`c*uw_c_uU86{#V@5E*$`S?<h$7+)QqP4=1;R>&{?-
z`2E<<V{7I;#b-U$GoI?x^|PKvNe2wxdF1N>E}gvV>j9phgs%tq(BUUk18OQe=fW^-
zysJ<)t^gYH;DNh5GM2%r72de(e>PWkn8P&nrnfT?Zlr$Q+8NkUOT8WF3=CFK|HX6$
zhJw^@=$i0y<~Q{;DI05cR5Kq{(WI=c87yUfTSAkvqGo6b^SeTtl);)|Kl6JZJ?w|F
zBTeppva#c&;7PHE6i<=jQMmQUYW7p@2(8Hdlw~5c!gV3cFbef2TAgB){=_pZSJZy8
zMPpUCJ}VuOD^}q*x?~)=>I}N#so8(V`kW@ZoeTA`1H;>dBQPfq4UY|Rcn6U9;H4ER
tr;ZmqD30ZxCp7_;9cy2xn}$Z%vB6LaN5RFZHcOk4UPXUG2`>Tc{{Y%vs*3;s