From 68b329f4f9842c7a2ab8bc14cb17ee39bb674ef7 Mon Sep 17 00:00:00 2001
From: milk <53408947@qq.com>
Date: Sat, 20 Sep 2025 20:07:16 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=A7=E7=BB=AD=E4=BC=98=E5=8C=96=E6=89=B9?=
 =?UTF-8?q?=E9=87=8F=E5=81=9C=E6=AD=A2=E8=84=9A=E6=9C=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/workspace.xml                           |  28 +++++-
 Module/DeviceInfo.py                          |  93 ++++++++++++------
 Module/__pycache__/DeviceInfo.cpython-312.pyc | Bin 28632 -> 32113 bytes
 Utils/ThreadManager.py                        |  19 ++--
 .../__pycache__/ThreadManager.cpython-312.pyc | Bin 7499 -> 7901 bytes
 script/ScriptManager.py                       |  21 +++-
 .../__pycache__/ScriptManager.cpython-312.pyc | Bin 38469 -> 39160 bytes
 7 files changed, 122 insertions(+), 39 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 1e442b3..434a9ca 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -5,7 +5,9 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="eceeff5e-51c1-459c-a911-d21ec090a423" name="Changes" comment="20250904-初步功能已完成">
-      <change beforePath="$PROJECT_DIR$/Utils/ThreadManager.py" beforeDir="false" afterPath="$PROJECT_DIR$/Utils/ThreadManager.py" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/resources/bb5886c82b356593c2b3d917d578862cf0abf9c0/bgv.png" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/Module/DeviceInfo.py" beforeDir="false" afterPath="$PROJECT_DIR$/Module/DeviceInfo.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" />
@@ -57,6 +59,7 @@
     &quot;Python.123.executor&quot;: &quot;Run&quot;,
     &quot;Python.Main.executor&quot;: &quot;Run&quot;,
     &quot;Python.Test.executor&quot;: &quot;Run&quot;,
+    &quot;Python.test (1).executor&quot;: &quot;Run&quot;,
     &quot;Python.test.executor&quot;: &quot;Run&quot;,
     &quot;Python.tidevice_entry.executor&quot;: &quot;Run&quot;,
     &quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;,
@@ -179,6 +182,28 @@
       <option name="INPUT_FILE" value="" />
       <method v="2" />
     </configuration>
+    <configuration name="test (1)" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
+      <module name="iOSAI" />
+      <option name="ENV_FILES" value="" />
+      <option name="INTERPRETER_OPTIONS" value="" />
+      <option name="PARENT_ENVS" value="true" />
+      <envs>
+        <env name="PYTHONUNBUFFERED" value="1" />
+      </envs>
+      <option name="SDK_HOME" value="" />
+      <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
+      <option name="IS_MODULE_SDK" value="true" />
+      <option name="ADD_CONTENT_ROOTS" value="true" />
+      <option name="ADD_SOURCE_ROOTS" value="true" />
+      <option name="SCRIPT_NAME" value="$PROJECT_DIR$/test.py" />
+      <option name="PARAMETERS" value="" />
+      <option name="SHOW_COMMAND_LINE" value="false" />
+      <option name="EMULATE_TERMINAL" value="false" />
+      <option name="MODULE_MODE" value="false" />
+      <option name="REDIRECT_INPUT" value="false" />
+      <option name="INPUT_FILE" value="" />
+      <method v="2" />
+    </configuration>
     <configuration name="test" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
       <module name="iOSAI" />
       <option name="ENV_FILES" value="" />
@@ -204,6 +229,7 @@
     </configuration>
     <recent_temporary>
       <list>
+        <item itemvalue="Python.test (1)" />
         <item itemvalue="Python.test" />
         <item itemvalue="Python.123" />
         <item itemvalue="Python.Test" />
diff --git a/Module/DeviceInfo.py b/Module/DeviceInfo.py
index ae15790..8a05eb4 100644
--- a/Module/DeviceInfo.py
+++ b/Module/DeviceInfo.py
@@ -317,59 +317,86 @@ class Deviceinfo(object):
 
     # 检测usb是否超时
     def _usb_client_with_timeout(self,udid: str, timeout: 8):
+        LogManager.info(f"[CONNECT FLOW] 即将创建 USBClient（超时 {timeout}s）", udid)
         with ThreadPoolExecutor(max_workers=1) as exe:
             fut = exe.submit(wda.USBClient, udid, 8100)
-            return fut.result(timeout=timeout)
-
+            try:
+                client = fut.result(timeout=timeout)
+                LogManager.info("[CONNECT FLOW] USBClient 创建成功", udid)
+                return client
+            except Exception as e:
+                LogManager.error(f"[CONNECT FLOW] USBClient 创建失败（超时或异常）: {e}", udid)
+                return None
     # ------------------------------------------------------------------
     # 线程池里真正干活的地方（原 connectDevice 逻辑搬过来）
     # ------------------------------------------------------------------
     def _connect_device_task(self, udid: str):
-        if not self.is_device_trusted(udid):
-            LogManager.warning("设备未信任，跳过 WDA 启动", udid)
-            return
+        LogManager.info(f"[CONNECT FLOW] >>>>>>>>> 开始处理设备 {udid} >>>>>>>>>", udid)
 
-        d = self._usb_client_with_timeout(udid, 8)  # 8 秒必返
-        if d is None:
-            LogManager.info(f"设备链接超时，{udid}")
+        # 1. 信任检测
+        trusted = self.is_device_trusted(udid)
+        LogManager.info(f"[CONNECT FLOW] 信任检测结果 trusted={trusted}", udid)
+        if not trusted:
+            LogManager.warning("[CONNECT FLOW] 设备未信任，直接返回", udid)
             return
+        LogManager.info("[CONNECT FLOW] 信任检测通过，准备创建 USBClient", udid)
 
+        # 2. 创建 WDA 客户端（带超时）
         try:
-            d = wda.USBClient(udid, 8100)
+            d = self._usb_client_with_timeout(udid, 8)
+            if d is None:
+                LogManager.error("[CONNECT FLOW] USBClient 返回 None（超时或异常），直接返回", udid)
+                return
+            LogManager.info("[CONNECT FLOW] USBClient 创建成功", udid)
         except Exception as e:
-            LogManager.error(f"启动 WDA 失败: {e}", udid)
+            LogManager.error(f"[CONNECT FLOW] USBClient 抛异常: {e}", udid)
             return
 
+        # 3. 读取屏幕信息
         width, height, scale = 0, 0, 1.0
         try:
             size = d.window_size()
             width, height = size.width, size.height
             scale = d.scale
+            LogManager.info(f"[CONNECT FLOW] 屏幕信息 width={width} height={height} scale={scale}", udid)
         except Exception as e:
-            LogManager.warning(f"读取屏幕信息失败：{e}", udid)
+            LogManager.warning(f"[CONNECT FLOW] 读取屏幕信息失败: {e}，继续使用默认值", udid)
 
+        # 4. 分配端口
         port = self._alloc_port()
-        model = DeviceModel(udid, port, width, height, scale, type=1)
+        LogManager.info(f"[CONNECT FLOW] 分配投屏端口 {port}", udid)
 
-        # 先做完所有 IO，再抢锁写内存
+        # 5. 启动 WDA
         try:
+            LogManager.info("[CONNECT FLOW] 正在启动 WDA 应用", udid)
             d.app_start(WdaAppBundleId)
-            d.home()
+            LogManager.info("[CONNECT FLOW] WDA 应用启动完成，等待 2s", udid)
         except Exception as e:
-            LogManager.warning(f"启动/切回桌面失败：{e}", udid)
-
-        time.sleep(2)          # 原逻辑保留
+            LogManager.warning(f"[CONNECT FLOW] 启动 WDA 失败: {e}，仍继续", udid)
+        time.sleep(2)
 
+        # 6. 启动 iproxy
+        LogManager.info(f"[CONNECT FLOW] 准备启动 iproxy 本地 {port} -> 设备 9100", udid)
         target = self.relayDeviceScreenPort(udid, port)
+        if target is None:
+            LogManager.error("[CONNECT FLOW] iproxy 启动失败，释放端口并返回", udid)
+            self._free_port(port)
+            return
+        LogManager.info("[CONNECT FLOW] iproxy 启动成功，进程已注册", udid)
 
-        # 毫秒级临界区
+        # 7. 抢锁写内存
         with self._lock:
-            if udid in self._model_index:          # 并发防重
+            if udid in self._model_index:
+                LogManager.warning(f"[CONNECT FLOW] 并发重复，已存在内存中，放弃本次任务", udid)
+                self._terminate_proc(target)  # 避免孤儿
+                self._free_port(port)
                 return
+            model = DeviceModel(udid, port, width, height, scale, type=1)
             self._add_model(model)
-            if target:
-                self.pidList.append({"target": target, "id": udid})
+            self.pidList.append({"target": target, "id": udid})
+            LogManager.info(f"[CONNECT FLOW] 设备模型已加入内存，当前在线数: {len(self.deviceModelList)}", udid)
 
+        LogManager.info(f"[CONNECT FLOW] <<<<<<<<< 设备 {udid} 处理完成 <<<<<<<<", udid)
     # ------------------------------------------------------------------
     # 原函数保留（改名即可）
     # ------------------------------------------------------------------
@@ -380,31 +407,41 @@ class Deviceinfo(object):
     # -------------------- 工具方法（未改动） --------------------
     def is_device_trusted(self, udid: str) -> bool:
         try:
+            LogManager.info(f"[CONNECT FLOW] 开始信任检测", udid)
             d = BaseDevice(udid)
-            d.get_value("DeviceName")
+            name = d.get_value("DeviceName")
+            LogManager.info(f"[CONNECT FLOW] 信任检测成功，DeviceName={name}", udid)
             return True
-        except Exception:
+        except Exception as e:
+            LogManager.warning(f"[CONNECT FLOW] 信任检测失败: {e}", udid)
             return False
 
     def relayDeviceScreenPort(self, udid: str, port: int) -> Optional[subprocess.Popen]:
+        LogManager.info(f"[CONNECT FLOW] 进入 relayDeviceScreenPort，目标端口 {port}", udid)
         if not self._spawn_iproxy:
-            LogManager.error("iproxy 启动器未就绪", udid)
+            LogManager.error("[CONNECT FLOW] _spawn_iproxy 未初始化，返回 None", udid)
             return None
+
         for attempt in range(5):
             if not self._is_port_open(port):
+                LogManager.info(f"[CONNECT FLOW] 端口 {port} 检测为空闲", udid)
                 break
-            LogManager.warning(f"端口 {port} 仍被占用，第 {attempt+1} 次重试释放", udid)
+            LogManager.warning(f"[CONNECT FLOW] 端口 {port} 仍被占用，第 {attempt + 1}/5 次尝试释放", udid)
             pid = self._get_pid_by_port(port)
             if pid and pid != os.getpid():
+                LogManager.info(f"[CONNECT FLOW] 准备 kill 占用端口 {port} 的 PID {pid}", udid)
                 self._kill_pid_gracefully(pid)
             time.sleep(0.2)
+        else:
+            LogManager.error("[CONNECT FLOW] 连续 5 次无法释放端口，放弃", udid)
+            return None
+
         try:
             p = self._spawn_iproxy(udid, port, 9100)
-            self._port_in_use.add(port)
-            LogManager.info(f"启动 iproxy 成功，本地 {port} -> 设备 9100", udid)
+            LogManager.info(f"[CONNECT FLOW] iproxy 启动完成，PID={p.pid}", udid)
             return p
         except Exception as e:
-            LogManager.error(f"启动 iproxy 失败：{e}", udid)
+            LogManager.error(f"[CONNECT FLOW] iproxy 启动异常: {e}", udid)
             return None
 
     def _is_port_open(self, port: int) -> bool:
diff --git a/Module/__pycache__/DeviceInfo.cpython-312.pyc b/Module/__pycache__/DeviceInfo.cpython-312.pyc
index 9e2a38bd03dd46e047c38bf4ad8a145678530844..f1ac501fdb723c89c9891580afbf77214fd9a0e1 100644
GIT binary patch
delta 5889
zcma)A3s4kSy6*0oo)-->FayktBhv^HLDZ1oBSbVj)KvkWV0cStyh42T%=p?NLvmLg
z4X(OJSF%1rDyA~KzHrHAiD($Jri!g3dz(17K;y04s%sBeTlZ$NYP7WK?)^{q3=HVr
zdmHNSGv}QD`~UNw*Z23(_vDXH$hfa!V|4^P7mxpC<Bh7zalczmw~+*K0_8N?GdR*s
zog_Hww8BlEqi{EZAPFZemk5GWoL8PB(NDE3N@+?-aFZN;P9Zn8Dz$`Li7vmG7)za3
zodZbxw9?4`M#?-+9gXLv8!3*!e`7Y*5NU)nPF5m_bb_DWs&bNOVWo}YH0bRrt9hcv
zZqRR4y`@6CSEYHhWv*GETwS!HtZY%yT6S^CigmTDc&J<K+9!HXioI9Z@->A;o0^-p
zIDfe69r<)`@WiLAO9?uTAFdwYCqaQv!r~$pTR}XW3St7_C<ZHo2E9kbgYUcMFaN*0
zif1p6eDcw#?V$J9;?;M=o*uBC$7X7IJ+?a&1bVx~!ti)Bd^3nlH9A#dG2K=*O3w2w
zQ0GvCU|Dpfq|Eb2D7F!IGzo|G2lRq<Y5xoT7GZUTU|uIw)&?|ncVg|nf<Wxd5TVi9
zy3&Rc5>I3u%{sN_{o40xeZ^hrHxuT1i$att);46Zy>ETb>RZxby=lokqPk<Sp3ooF
z3+$49Q@~I*lsx%S3}F0-fgV3#2-D=h5tJv^2K@#N?0|t4(&~lv4MP1JLTaPX)EqFh
ze3v}wQ9N{)j6V%ARIKgEqu5Br69*pU$5RS(71wo{1^LwVd~IP4{e{X>m`#6SS3><4
z*)*=nQQ&eeU6`+K3@=O2BnU0R5CmR;_jM2wX$_;4T$N$s3P%3sB=n!lbW|&a*Q1qF
z;B|hQ8n-GbN3xUrm1c6BGP-&<-Wc&59bE@29mQ`<G{O2;MV4@@!mVfn0K_&;jvKe!
zB?Ok!L?dvz8gRRnZdJ9a0Zq}ON84kp%2tgV7W+z*(yeJpK=D~dTGdLs73gw|iE342
z*VDNeHw{~qajQVay45fYRW!1jXi3IcRI3*EH*yBIcEV86`phXA@#B;fEfy)D<Al>n
zpufL53C(Xb#d5IOBSR&Tg|<^%BJ$5Q;YKT$gl%xi<BtvSBo)0~YD#cxBbu!`x2|nk
zI7sFwL<nd>QWB$$oEsz|MNP?B+$8FFg+<p^Xe}Azypw+HAoxOQ(r7D2LqA_(XLMsA
z5~>1F(V5w{4CnL+fSYt{-LzZfR&$fi+s>)v`qmh5c?P&_)W<|&5G^y&(Pc(52e+to
zFzJ&|!7`G^Zs1a!FOR|!Ex8bTBU(5|t%(F3UCJ_}ml{*DIlG&LD6!+Cv>P9Mu!`je
z4!*Qjr5qqqi*C)BG!-9n%D0p|$(_V5MJ2J5oX~$N?hng$QJh-|@cQxam0|TGRQrqn
zPauy`0y6yrAhP|ZXMu7E2f33XiAuOGNTU4@vZtA;Wv*-(*o0GbLF8e@t8L=P?}}%C
zF??j-$i>gav-{aSIu9FZU*O7mR{L(>2X}jWgCDj9|M2c`FAAPH#X5PH!`Z~;yJkGw
zU4{*w`kk!z!`1fTlb-~C`O!$<G4bRXSKhN4o@fjA+I}<Aw;!~`{rkYZiFXOV9rRs4
zdlqEurjQM>Wm~s2J@@pV;1T~l9<wX`e}fDjJSkruzglfBo$_o?@$zBuv*R#~;M<qj
zoz0wcWBwiuyRoVHpEf%4_o!J%W5cGVd{^ePn#i`=?8#$YW@y5W^?p3ud*SZ2zTsoO
zd%Yba7te}qS6$Du=-qd3@1fwq<6wID+$HhwhpY>4*9kKpyzrrT$|oMVBp&p!>xv6l
z@yaoPcI8BO^~jg^ShL(;yx0!cEq3a{0rB&_>`RX4IueB~-MBCqyt_c}Zto#^Jp5*;
zc;3>I=Qu9xU-LG8>#p4_npbV}JZG7No5Rk9Z};|l`ws?>eJ+PU{Or^4D$9)?pFF&A
z>N1Z2A4mF54*T8}|M>f0w@=*H?ph=(dd9Ju&ps6oAHBE#ka+eGs6c1&LI)1(zP(Vm
z+j9Xb!3Xi`KL<~p51z-nMLhU{L~$}nz8?@XDSi&T_&<SgEs#w_TL|wN-v{Cu?2CBN
z(<$!#NXEw&uOackA+R`nr7w8A3nI)ui!nd)u;GpE!t{!j_qsfnY@|!(q%rz)JHFXb
z&o%96ZfvR#?`z&Ek)!_reTfqBv(Tm0(+#(^4coTWJDd%?laGZq^l<eQ&%fbLuVYb(
zMF$pm{`u=ztj5BPMH?37ATk-g7?<&eyRD8`+>fg;)#8V-7{THmh}%j>^PVRD7XB@T
z@EnvJ*Z?a%$gw8JQwrqQu@vt2C|<VM@APlzUp7k1LMp<TJeV+TAYq!%bTeV5S3OGM
ziv8>SO9gY8uySocQ+`XIbcabAWKss06u~Z4GUY=|LZrKStx!=F&{T(18m)22U>Y<m
zoiSjT;p4grZW`uz3x@Ot@9r^*minf!d3(UX4;e7*;S~o~2(}{s+5odG#1L%efX3#f
zy*rM$fDvl9pcmF=cp}|WUh^mV)&5<=%8LG7!n!)4o)hYt1ltB-<E8+!Iiw@NxZXaX
zx8KyKdX*9Xtn+);_AD06*obCXNJVR_$q1ya*v|!+<wH#D;pGRGpNb1GFN`*=5LT53
zn2HA;6`_qitUI7PlG7gh0Dc%{qFd}=>tEbIOE6anHR}VKhN1Yx!T9L|@zW(z8$Z{p
z8j6YcE&#ki#x}s%gvpgcb$x(YKg1aDusezaOlou-!|{fRiAy+Kb)f1;LaTj^8uI9k
zN1TJn(+1#QKTQhclmWvOVQNbxkP!0p0YiFcMZk~^6M#8$r!rue3L$<JgE2x95-{dO
zwo}>3`4)A}>6z`{9xyHSE{b@wD8Nj?<&py>gN%KEvHRxqm<HGd0S~h<5|fmgK<#>=
zp=q$eHPGO?S-V51*(um|347iOFrG(7Z0bSMXn^v1a(gm_*TR{=ziR3pKWHEcg9S*t
z);Jaxdy&7u|FSR{lYFM^4wLXSL_>$CfQ0*!9_<!9U*QFqx~xB^KTRlY66|>12bs;^
zGMk@<6eRR|`oJu!$TJ+#knsJR1p6AHymFAK`j)AZ6spN5k8ES%dE($;7hRv7wR{@!
z1)GFreu1$hc@=RZuYfGo5dE40P3bF&KU)g2;q}!tZHY<oRgR@ZulQO|L;34uZ7Hqz
znzfb^if;%S%HL?TrE?VD#9K>q6yM~~xcmxTMxno#e@7zpUBx_<GDAx}Ay92*2I?zi
ztYe8TkjY2}OS!2QH6qK5G1O?C0#oZO$RZRGmIuDW1GH5M^h_iFlJeLwI!9wV=TS{0
zPnqg6S1Kq>xGH686ir2L>x!jgv8-Wp)AO?3=)R*D%9u+2T2~rD<V>^^ttIEEdF<j$
z)!2cI4zEj`#5=*mOnU67<fRi5GYI6FnMjK0#=2Bb2R`^5P}fF;D2>)Kx^Nfz(*w*B
z*gPG%Hw`QtN=DO(SC78h;l63i_7;zJEA8j{D+HT#qA}G&#^lF$^k%$XF;Zkb75i8D
ziv;`6`T=sq9iv%Vua+kcGXW{gI|VTXam4jFZ9$&mda|Wpw&MD1x*!j|_<Ay}gA-Xw
z5q0us4xIj>?OCicocGNdmk#bGoLU%(^l*yE%oh{2y^yylAW?|H=>W>E)KU%`UJf=+
zDSbSl$Ma^A*zytZ`8aDzy40+4D>(HYfCa9uIXy0|1W<h#G>$HIE1mJkV78&IM2+gr
zxp3jkz-A1bR>IL?l71ReRdg*YTkA{?yNdb}6BD?o^riipl92L)cqTgE+6}og&Wa6?
z3Q=6_=vN%+dyR^VbJHzWv@Oq+F(FB&r4Kc>ur>UlCJle6f&7C6->YU!Hk7$uh1LnH
z8F&pa2o{lR5<S2mhEHA$cJ7Z5MHt(}{`HP+4Li5ghe;B!chP$qXA14V2JI+DeGh+{
zl9<H=gAr^4w6k)uaJT2m@Nci&qfY!DeP3nwBtXlo*(?wwvFr56rQ<Slb4`2J8JQNc
zZ#Hk*1fP^Tfv`r<@d{ywfAb4=<<er7{}O(=Fe{kg%ShiDV9~5(D|n(a*o|#@Mrq<G
zUE`Nv0KBIr0F2{`qdXXF=07h_7~fm^$OK=Q^kX}k$E*_lym~$PH40W2k$**5HB&tw
z;?27QL=<Z&2W}yhR}1DEq3(@<rg2Db9Mq?Nt522oqkOGa2(Q-!m|EDacav=$tI)2$
z5scRCT>=$@#;F6wshwQFI34!B^f775ydG1JN?1@Pu+j~0sJLZF#Aq+b3@3GNkFslr
zkiSY;T`APm4y>*fR@Di0+XVY|!Lc*I>_S&-SauX`S$}SShOn|ysHznz>jbtQuE&63
z1G-aVU10<_;1-Kbju3!yVO@2AsR74AN|n|uktKYWcjo#`KIctCuD4+HC|c4_{tNwQ
z+7B0On2Dg*YAw0rFH2*xboiL@;X@ENQsyp7BEC%0E~XS;+AWLn6<_AlP)2QB5;|M^
z-<GG)iGK-%LkR-&MIL`T;2)yiy2)f;_pQ25DDo%t%LbOb(S505Aw@n$KQyM31KlRh
zO~q(nZg?FQYIJhLeDYTJ(1yhnd9T~v>?27l>Tj7&{yTcmQcC_;cj23fWT8Zu-@z7q
zScq8QtBIeFMLrgP#o{3rKVk703yCx1eZ^bRdz;e8_2}BBV;&uC^A&{%c=e>-$FGpB
zkfiHLpYc8+6+$HxMHi8sY4-{I4(YVCrLz&Z4{h;r_wg%~WTnl%v=9NWt~JuD=XHO}
z;Npq__|IQ=A2)>NDd@aT=malc`hENg>0)T~m(6deqzEK-&)JeqS~GAU7Gp1Q44-J`
fZ{EteHZ?8aUq<e&OO5qvvW7g8^pKDWQpf)RM>UH&

delta 3233
zcma)8e^66b7QXkryueFd%!8MNgoY$QPy;Ub1I1F@E*b&rh^;bPwNkZ&R%k8yNGRBs
zV%zN!U0t!)9ca}RyX{Oy*fuVX%Zv`<*4FNHXErIB3A)U*P77jZXPOqac6I;Qa}xsH
z{<W9Pcg}tHJNKS<-aY5=?R`A<IbQIoPNzXI@busIPHw)i;QU5*03q@zYsp-R{H($@
zvvfH*$P~M<Siv5)fA*nYrKp<u)bhMkm;qHkrgL)j`H~e}t^5$^vWdd`6j}gWoJ_Zo
zU!`z?!k;L-4&dU*l3EMb%7IR{*VcBf2jvhN*V%)WQC)EyF?>lVe=O73Q+T5A^wzWW
zZ`B9gA?IjjSzz6mWa=qDQQr4lcloGPe2)X_J<9)%!u?h)>~w5JrG~wx;VPxH1_tJ-
zkq!!VY1*Mes0S&iIq?qQ!|lgROl#JgrFpCRXALmwpoFxP?Yx8lF)5axQJ6y(FH005
z$G|H16gtBs0|Oz49eAS6w%fo$HE-cj?*u3ODnI8}^GIPxi`J_0rzvUVg4Uo?(wa>q
zqfp{F2tGqbj0Uw|4URlS4rsHt_|v^PDNhuvq$?_gQ`DaH0lr_IeD3Gzp3U|YYhHRC
zDSh5UIN|Yf0}&T#wFRlw=7pqkkF-MjBNl3QrB>%9J%8@4G~i+(31?+tOoksZS=*4T
z;gKitmm<xEw1h0Jv!yE<*#<UC$%)4#yn+nZWwF9(hWxQG+th*bk#|ArASaUZ{Vard
zV_^=<DJ;Ry7#FdxupO|sALL8;CDhJtM=#-@SULUdo27O(EotHcYBxUW{QrzJNh4j-
zNS8Ds*_-k^b+x{HaBb@S;fZ&<CQqOL>gu_#E?@rU%F(Gm4^Ca}ay;p-bWC)AFmWU(
z9{`@uI7hxqh9`gf-qfWxCVMUcKanUt36_)eq~*I8rY^o$?r^a(y@v^S4ip&iM}3fF
z7!m(AbLTf#-cF>P3(KFtn$HT5+@@qA&^2-D_mk(2-aYfqL}EKi-UkF1Bd-D>e@ON0
zTNzEQyF86;O%08^yt1#=+vt(?blFScHicpe^O;*hr%eF2$fl<jF|t4oJSC}bsrI()
zYb3vVD(}f{l(3z`H40lOC;%?4?54VtLKlT*3KJA2Dck|LrD|<D*eKtm^L`4{*F-uK
z$Iexq)sU*KGXRIsm|lwM3nKc0K2KC%G%lE8f-NH0!glwFCn{_l6EeRL#F*fU2(F+r
zghz$t0X(J^0uKZA_~yf#!?qP6cW71ES{@Z10d`!a;-zs>>d~Fh^?Lf;qoONN8P_0(
zE0S&vaDldNUtGm-d=0VHFYJt`Bhe7k+ar4Ws6IEK8W$hxb@w@gT(B+V8(9_=*9W+`
zTE%a`V}kDZ#={#=FNg|@s9trr>S)bOI^uQ5HHS6b%Z}>4$S}q-iXs_BiRzY77Es64
zXhG)j9fx;(i#Xnm;Z?i6v8=@r_~{pqiKcs<9DN>7tO8k=LEor%eN@Q1sW*;^h92RB
z5EJtwVt%k~s4n7M8x_~x)6U!cFjIy^3oVvXB68M<U=7=shn9u%!#S&lR8e8gxRCiE
z4s}&}Fq4_!V!j5a!rW;K=T;0oF|;mh|HX(iCRBeWR6mHbl=5K4FiYPsM+f$rp*=%e
z!}iLN(wI>5nNX8pZ@~BOiSu6FZ`}c3`&yQ1{YrGLw6w~JKGYOc8_@MUu|~ySe`Fcp
zM=SZNTz2J0Ketp_*^jLpOg?t<)fw!^KeJQ|><xhf{e}S?VQ=JEsw>zV6&&cFsJI#(
z5qJLsx08SFUQKMf`MjNQSP$Zn7w%JXC^%K_Xi0Bop#&Pp)%}{i9SoEeXcx%=#fZgd
zJL+IlMaQM8y`^y{(x`UNzQ(#LNL|{4Zt>4GdUv($dBN8x)5L+t|C<A?v=ccT4tWJg
z`AZ@;<nHy;OTHZDhfo|YoMl|h?kyb^9f8W(yVNU0g@Q3D>xXf@`8$Mp%T38lgKxRt
zDuCH*Ry#V&7qRDY5!*obPmQ_G_Y9Pk9z-55neBH=eq5ZrbKMR)+-zvvsQwM;RxH$N
zp1k78Nn<d2QHFASdrwXtt1zdKN2RbH?jRfmy7~+Up`7cX3JEPWk)p;0>|#YlHWb=O
z$e6Bqz6{<t19p_ir-e4gYb4(+wXXK0rOw3YXqO5;4>0CFQ0h$(g1*Ce(&zp~;mEMj
z#6W+1#bYIf6*}^InY6^iCp^=ffu8&$Z@8_rwb)X7C0dJ`HVLhwrhSFneAd({)cP#I
zXxcBgw0F$b@`<;CQ0pf`7w%j>f0u(*9}U%={tqUO|H0uifbRI}^0BFR`X`R{-8mVA
z@_uJvz>z4?K9R0Y4xGE&b!_T`-`(vxGI?@X{s<n*)c`)~&1?rq9I5SaOa{6qj+})}
z$hqxSXVy;$;8UusyF__C-AGTa>}}B2Q#D4Rm^hl&;jf9OsbJq5^iG)pW(#NTXZqav
z%+Fap<ctcB!j&4&vi3ef+P_0-yfsh_4`Nb5M4~lTD!M5eQ~7V}%L*ET>TvPek+M&g
zU3++>D7>jYY=1hu8)|PODQR|)mgekEJ?s(}(|9wKq?ni&5%c;=!OlA>meR`%<vAxJ
z<iv#Bh>+U{9xQ_WleM{GsBWlgq$F(J60X}86}FE_hCog7zB9ae-gEn^(1B1xIH!Eb
z9Th6arL08FGT(2dAJ6=k)s?)PLDw1HUCdtBTHG%7x{Grc4?3SW;<A6!AkjQ)rI`&$
zIGcsjFgs{YW^>bv&$blrf*!fQMfUD$+28o$+k^XGxX9ocQqbbSX9ufV9%b<N<kttB
zcwn&qfWm0i5M?=?0!Nm6EAYj^7H<`UuMb{o3u0_0yV{HJ=j1o-oA6%;Z?+rp+S}BR
z*C+%jd`W?(s$4-~4TY~MP`~6E3g1)cr9f|?Y$i(&=HsVH-NBQcELRd-7e^q5a;K??
zi%U2+4ocIA%J?&w;nv~4{AomGT%+bJeGPF0BIuc>A}&gtIhY?uAVOOcVrbh)bFAu@
z5%{fna+)s03t6tb4@e+_PI^vxT%+a8eWdB--ReXHq`|+xyaZz>`Hy18%ZSmxK{}|$
QJ8`$^Unrr-Rp9%70oYG)>;M1&

diff --git a/Utils/ThreadManager.py b/Utils/ThreadManager.py
index 7917e7b..c5a3631 100644
--- a/Utils/ThreadManager.py
+++ b/Utils/ThreadManager.py
@@ -90,16 +90,23 @@ class ThreadManager:
 
         # ---------- 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}任务记录已丢失"
+                    return 400, "任务记录已丢失"
                 thread = task["thread"]
-                # 浅等 0.2 s，后台还没死也继续
-                thread.join(0.2)
-                del cls._tasks[udid]  # 立即清理
-            return 200, f"设备{udid}已下发停止指令"
+            # 第一次等 3 秒，让“分片睡眠”有机会退出
+            thread.join(timeout=3)
+            # 如果还活，再补 2 秒
+            if thread.is_alive():
+                thread.join(timeout=2)
+            # 最终仍活，记录日志但不硬杀，避免僵尸
+            with cls._lock:
+                cls._tasks.pop(udid, None)
+            if thread.is_alive():
+                LogManager.warning(f"[batch_stop] 线程 5s 未退出，已清理记录但线程仍跑 {udid}")
+                return 201, "已下发停止，线程超长任务未立即结束"
+            return 200, "已停止"
 
         with ThreadPoolExecutor(max_workers=min(32, len(udids))) as executor:
             future_map = {executor.submit(_wait_and_clean, udid): udid for udid in udids}
diff --git a/Utils/__pycache__/ThreadManager.cpython-312.pyc b/Utils/__pycache__/ThreadManager.cpython-312.pyc
index 1165bb2ac84732a73b7cfa5ac26d18bceffd0946..567153584a998a4531b2f595c6886d2cb96485b5 100644
GIT binary patch
delta 1046
zcmZ9LZAep57{|}KcdyP}@0_~abgfOT6(Y8x7kZ%<l^B(%A0$GonOjUJXEQTa(+~D$
zzFZD9EhURSR909<nlISPrwU@ypd|$b&grL?6$|M@=Qu>^UijVTJkS6CJm=iYeYf??
zcJ7^0nE=S8?R;;Kq&?=gDB!(;{R*=L)?uWwGeL+ytI8}1a$sAy`xvSQ0D=bSg*GOg
z#AliRYd+?r6u)FrxCf#>xS%HnFN0NFh6E*h<5hK{cv%^LQ?0is;@ai(lCeue{~r|Z
z$)R+Qa?x~>Ba_vuC0=j?^e{`~8>9^~6UYZ{SkFLEMm7Y&l}?<?Yq*`K*)mWM&GLh0
z2Bl(^I@5<}zgd<5t)dY<cHM4*BgZN{$L-~AkE`~mAu>E3x!Ypc=r&Au-=A%43||=j
zK6)iQ_+)yhInr@{=23rm?CR9m`M7Rsq;+OcFqoOyH?*6DfJmo?TEgu@xT$;k;ca4$
zOMNrXnrE+$PmPR(FW(})BYiF5)`7?fp6<Cx_NbwLdE6g&nq`Q73Pj%^(o$p*Ov)VY
z@(QQpROKXF>#9XEnv>R7pc+R_m05%msW6#>9v5X0xJ3j8+@>z_y(Q6~Mi5e^_|t{-
zA3&sB6Vhn?XM{8UbHce^+Xv0M4$&u#E~MKOlagYTDxxx=)py#v^c|9zoURjrQr%v7
zsjwGbEDR<Zzb2)&`!4x{Nrn)g=2r-c-d!DvAfNMfaSBwf3-M}yg5XN<a{|}t=`9KJ
zYhx_QFL^)n+K;?(f;R@Ts{(dspsG4xstNM0kftc4HpNyg?q)ugMto5~Fz=?vYg=he
zW}k@(Ua^^0J^MOYY}H9$>&4d9xGCitG~pGg1-cxfoRpuaa5&4I4!397d&(Q|rm|3{
zl4sp9MFDv{$bQN`E$)}y%ll22zjE;Pv@vBVl*qH9fZ*@k)&ZM_Wnm+>Ye%64XX_3a
zHjw^EPmxU_rPxI<DLUqIInf?0=!Ww*i!J2v)~<#qAmQE8e#?+(sQ9`3g(YCwJCVC@
zj;4RIK%$B=B#NHG-VCGiFzrQuX|n<q;J%Df?ID_3NN190Ubd~;Wvg>m?m#72n`un4
MGEhGUC>KQk0KHK)(f|Me

delta 746
zcmZ9KO-vI(7=~wd%eJMow05DTE1QN=Od}voPe_X)B_c$*G#oe?b;Ux8O%@13D#$@m
zA<|}|E%?_M4wWB+LZqNX@n%TO8a*J<gag~^t)d7a9-L|P;%xHFJKy)c@9rk^#j|!)
zx2DzR0=&3W@BG&bp6aSK&@q2P<6z(p5)FQ851`M6R;NLL0u=&xfk5A<+o*GtpdimQ
zMZ5q&-~%Bj<P>3jnF>)IO0-HDwahfkwsHRkjaKP`LEr)ZI|b$6WEDyF0UL0FF4#*!
z(29K!j2bS{t)Le=)IAkAO`Z*>mtUn5Bj1Kc<*_MwXd?AsDE)BO+7WEOXqA_qr;=CG
z;cH)?%*iXa#RBXQ4`K8WwT0do+4^Qti}i(xakAbX6HWix^5V0t<cK^Lk%#W3W*?<S
zhqqo#Ius)LD^WvWA+TYfB-=T76N|koVAH@xiy}qefl_N<H(8?nk^bmFWFRhlFdYsn
zKAE_6j*pim*aRb0dL?VU#MSRA@od(RQ2`4d^N;gkW>a4n)kHKg??=6Loi#<9B2BSw
zi7nmD$HN&tU`?^II2&iAvKq<kmW(#Hl;_?xkS2NcewQA9&n<gh6}@7^Sgp#bt47Ac
zJFo;z6*h8q+}%*OooNr84zzc5i+T7g9w2bc>r6D{a@C$mTL$25#=bx=_~ulPkL-}+
zPctevuV@<}qb|(=jNjYk^S{hA4g1hO_Yzj1#e*lUl_ZKMC?!x5)L?8V&IW@4u@>2i
zmz~ZWSFAhk9q-EkEE6qruB0OATT;JvNv`AXD;l;*`3DUcLx#dC<3~EaMB7BN$Tf9n
qL@)C2EtW=7$(D<;+E=+dgF;W>e684wX84l)5QO|TzLAj64*dbXwcUmQ

diff --git a/script/ScriptManager.py b/script/ScriptManager.py
index 9d55601..a9b96ac 100644
--- a/script/ScriptManager.py
+++ b/script/ScriptManager.py
@@ -238,7 +238,9 @@ class ScriptManager():
                             session.double_tap(x, y)
 
                     print("--------------------------------------------")
-                    event.wait(timeout=random.randint(300, 600))
+                    # 换成
+                    if not self.interruptible_sleep(event, random.randint(300, 600)):
+                        break
                     session.swipe_up()
 
                 # 正常退出（外部 event 触发）
@@ -334,8 +336,8 @@ class ScriptManager():
 
             if not anchor:
                 LogManager.method_info(f"数据库中的数据不足", "关注打招呼", udid)
-                event.wait(timeout=30)
-                continue
+                if not self.interruptible_sleep(event, 30):
+                    continue
 
             aid = anchor.get("anchorId", "")
             anchorCountry = anchor.get("country", "")
@@ -554,7 +556,7 @@ class ScriptManager():
                 print("----------------------------------------------------------")
                 print("监控回复消息")
                 # 执行回复消息逻辑
-                self.monitorMessages(session, udid)
+                self.monitorMessages(session, udid, event)
 
                 homeButton = AiUtils.findHomeButton(udid)
                 if homeButton.exists:
@@ -901,3 +903,14 @@ class ScriptManager():
         else:
             LogManager.method_error(f"检测不到收件箱", "检测消息", udid)
             raise Exception("当前页面找不到收件箱，重启")
+
+
+    # 放在 ScriptManager 类外面或 utils 里
+    def interruptible_sleep(self, event: threading.Event, seconds: float, slice_: float = 1.0):
+        """把一次长 sleep 拆成 1 秒一片，随时响应 event"""
+        left = seconds
+        while left > 0 and not event.is_set():
+            timeout = min(slice_, left)
+            event.wait(timeout=timeout)
+            left -= timeout
+        return not event.is_set()  # 返回 True 表示正常睡完，False 被中断
\ No newline at end of file
diff --git a/script/__pycache__/ScriptManager.cpython-312.pyc b/script/__pycache__/ScriptManager.cpython-312.pyc
index ead533c8fab7d40eaa6eda8524d50dae1d04be19..a3b653f6d2b01de60e460f304b9324b999564332 100644
GIT binary patch
delta 1983
zcmZWpdr(wm6u)Qh-d)%??!vnA+65H1&_#CuSsp5|5s0bajFlO#>;;y#h3+ntbX5!=
zi{VHf6f~b>QyR{w-F#MKPBz&%HKNRjTT?ls*yE3onk;)v-?yk)otgc8=R4<jzjMCx
zojo5Pmi>B6rn{)ssu&{Q_I=(s^T;t>BdC;gPvoc7*a6c)heyB~<JEgryryXqdK5;B
zn%8+Xyslp1)vn{7)`yvw;Auk*V>d|GAjb?lQEz!nnI6l?7*T<PUX#>f8IZAOMH$|%
zFrm6aC(TLvOwKY*`RK_rax%i>a1kGm1va&IKsFveD2ruQ;v!oaoW<?7awx#BY^UK}
zsXt9AhZNj5<(Sdv3xs$<Xl)7kR`~hapr7Y)LFQdphLuyT&>}rIwT^w_o5a+siO#`9
z=TY~m;#0Y2i%%C{NWT!gQcyFLxOjMC@@NbbmoTbi;*+kLG6qc<L#8RCt-vH&_h#+L
z+B1E$9jL#8WsJ68f38A9)|RRYlHq|e<st=hK5JeMSuUkn2@Wb^YgFu@{?Qta9V|$z
zPLW+s2BKe1iLHKwyPPSbx*e$gNIcQ6a9oW_x|y|425Q{kxDHmSG26sKFJ7OSD(!M^
z1i8pGW#YL!V;t)>KPU`z-w~B~JrIw}bJ{SXG@{m}!fV+!H0931nPgv^tA{Kc^c%T!
zQPt$Y+nOZ2m~X~C`C9xWH}O9l7vao!z*(4Q04I5uTD(wV#A&4({5r1|TqFw<>RmC?
z(pfbCMfd0q99Glt&U@jUqW)gEhS@2IuFs;Oek-EsbQUzI=ZwEC!!(uPxfPR8Uzq+c
zTT$U;aO2m7Nt)2Z)Y}>(?kTK<$7#RdAB9!wc@GY%irVUnIvxr|Z|)Ke(NvOILz7dQ
zTRd3?cd=oP8y3*3$h)A6#r@8BY=6OsKg_vbuQ<^(egVlbHwfe@4wOvBNu@^oqGUD}
z&x%J!={#lJQ%n!neFoQ-IzW_;m1Y8nc&*G0ZJ6q=g&EQsw_Zt1TdI(l(&ul5&C-ea
zTjgNKit2Vw@RQ`FkE#tYaW&C|g%s8ih$sX;*y;}n>+y%0GDQ!yBjzk_fK|AAafa3c
z3=@1ehGBm1U~XWX$0FTY94nh(PP}S%44NHBxue36*)?oRdS^*F#~pPK8C+83Gx?yi
zGdJvWlk2tYhz9Dl(re2&76!0yc>vs!!gF^bY({9G2B#%Q`&6akB#nC<m#tk2*YWh)
z_YB*pVLOFB3jMh5l`tGfZRZM7pq9=u#jDiZjb}Qm%@>Fo(bqKx+IS)83Hh1>wLY)#
zsg%C%Wl+3Cc`Naa^=|k8zh7UZ-a!p{6kf-f8=gr%NWWJ5g0+56prO^%zzc_{Q%&J*
z9N18ry@#rMDR2}z2}Betnp*?jU_{yIAt6J85RKDF{VOqLV-~bY^EPS$w&GLaTypWA
za2hO?q_C)-OKTrd26>V&IY1Hg`|9}GIytf47pk-5_tSX-eT*nuB^Tvhc&?0`ULgX$
zz$GOG^Fx#p6_FL?_y4M^I6~N;ZORb2!?FSLdQ^ZB<s#Q^W|)UgiW@&k5rppiadnM`
zAtRM-b&*d-Hf_3bs$=Bv{_nP(wbC)yVjX#P!$`QtI>UPFt*yj&t83$r?{|N<bIVBI
ziJQ3j=9ykA-^K?*0-dHpG66d)WRoSrKJN<%In<yKCQ)a!{eGd^9qO0+`TCHM!mJ^^
zrXU7uRD^g+ppDyZtEm%wEus0I0DYh7|DVAvn@KT(O9{7w`9_}*mJjPD^eo!c*x$NW
z+#&8-{bhosf6Bg$D+!t5@?lNfmddWm{ujfQLz>KCjiIN!YeBe-%;Q|W@t==&uO?&K
zWa%q>tq_YZ>1~%{Y(fIfNKe2H4Frjd&bG&4PH(=moos{-3acobp)f!o5*un1c#qc?
zXozrbTAv74?{D^m1V486I^kJ7*_-n0i@;e%1(xMv##Cyq1;&zmaxQ1=$yg(28OsXD
zxpKJeja71K2Q5cZ52cPWMEx))x?HMWa))lmlhcxrc8fq~m2i>5Uj)#y?c}sK>5jUE
pa}=Uip%uOxQ}}$dx7E)V3o6nsv}1zB_~*7feTfdz#u$oG_TQ+2P+I^1

delta 1366
zcmZXTe@s(X6vy9rudhE|DJ^LWbo{UdgtGBdCIwU!ORb<d5cb1O$7;bACPiC{4m-w#
zR5o4saU3v{In1`mfNaWhn`Dw~iEhRvWFXl(_Qzae{Ac^4t7f9hlHH5UXm<bj+;h%7
z_k8cU_r0a_?3GD2`g@g1V95Am>#Tcz@_e)#1eW?_+^)ke$N>RA1EbK(9EKO8YMD%>
z$gykVU<iv1TfiiC8LqJWOn`0HVoi=-tWOL{(C~yFgR2bcl!nxam12|93BVmjGme^4
zVFoXo>`;tRDbp||ew!kbKoZWTpU0CKOHhOFn2q2OKQ%kK%^{s(xN@L!v~#rmZ0DKI
zbIywe*E2TuS1#x_g>(r&>C)zOX$!ja@Ihb_j2~pZmvuTP+zw1kY}m#zTGP^<tyrJc
zx5Y}j`LJA8BVjIQZP$@$PNJxlb91VvYB_GMIAv!dJD&i=o=;TlH1qSTS!!nhwat2B
zU+4H*xmc1t%7Oxa$^8wI#hE-E2Z(1R$zr&m7jUUCE+%eLG6BnX#{hHUZa{`*t$O@?
zZ99ezX|c4>37Kf(wYbd^4Nqczi<VCf2+i4Oa%wTpr9fjz9I7qm|7DestlY=4{wY<V
z#}bQIEmdep)}p!SRXnAj8iIJPs1{(|Bk8%Y9;-`iE0P5P^&^tkN`7CFd#02gDzwf8
zrC1>(;+{r128&Hxe%k~8qxD+6(VWDtxRLeS@Ea1U-cY5ic+fM$G*{x-27Ig_?Xo1G
zc_=A>1`k+t;#jGcg?o5ulMSlyK)w-wZc)Mx%qugkoHHh%d$>s<2FrXvuKWJx)u=Dh
z;u`Blyyc>OM`6FUOs3hz^z$dCF=Wk!Bci-K1K<ee*=*p)c3VB<ia*-aG7`GA9Z9I8
zY7mZ#svUz8AYbIp4slhj2I5~QU3jZ0x(ODg-bSB)f19@l?RDkSJ{ljyfjSoi@LpY-
zDvms~@0^@r{_bLK;z5T&v_7j~H5&b}Fd&Ss=@%9>=^;(L`1131o?Flqh~vA9A==E`
zG?yjqi{fr6VPBN^=N_JealHGA2dv^g$NhLXfsT%BxG45@m}Sy0sOSZpdGjUs6%9wf
z(wwA$cPWM_hVkanUbuiQ-FwO1{Lo#le4B=k6ZjMGhFy<O_Y}o_N8ClVv(?ky==C|;
znp!>eO%2|wVt3CGkRGBN4x=P!gG*Q$+@Ktx0Sm<`91QMGI!kven|$^A9Uhn8;cE1b
z(M2W2C#XDT&3m7krzv=fqXdi6y{&#vgKtshb`Z%nuXkC;P1g@&=dmpCixbCG00TJP
zTS#so+?xWsMD1GvrBqFlGF3P=RIGoE=D$G^pqQo@$K>GxXDKn4dYBs;U01~&3C}0p
ziDr3YL~sM2e)~Dj54<7l;W%C%5tRG^h$J>i__dK26k6W!SC&V@+rb-4tEmVw4c=|k
zzDBU9XmfiT9Suz$7tRiUsr>lAB=6VQKN2sn<kjgP?%RY@BbFGy3hWSJmZ#-{{{q@!
Bnlu0a