From 2633f64fa9f8576c45345025492b70aca6e8a85c Mon Sep 17 00:00:00 2001
From: "yineng.huang" <huangyineng_zxl@163.com>
Date: Thu, 22 Aug 2024 11:40:52 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E9=97=ADios=E6=8E=A8=E5=9B=BE?=
 =?UTF-8?q?=E7=9A=84=E5=90=8C=E6=97=B6=E5=85=B3=E9=97=ADwda=E7=9A=84?=
 =?UTF-8?q?=E6=8E=A8=E5=9B=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../screen/IosScreenResponseThread.java       |  8 ++++++++
 .../upperComputer/driver/ios/NKAgent.java     | 19 +++++++++++++++++++
 2 files changed, 27 insertions(+)

diff --git a/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/deviceManager/screen/IosScreenResponseThread.java b/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/deviceManager/screen/IosScreenResponseThread.java
index 64aea18..2ccc511 100644
--- a/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/deviceManager/screen/IosScreenResponseThread.java
+++ b/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/deviceManager/screen/IosScreenResponseThread.java
@@ -3,6 +3,7 @@ package net.northking.cctp.upperComputer.deviceManager.screen;
 import net.northking.cctp.upperComputer.constants.ResponseCmd;
 import net.northking.cctp.upperComputer.deviceManager.IOSDeviceManager;
 import net.northking.cctp.upperComputer.deviceManager.thread.IosDeviceInitThread;
+import net.northking.cctp.upperComputer.driver.ios.NKAgent;
 import net.northking.cctp.upperComputer.driver.usbmuxd.AppleDevice;
 import net.northking.cctp.upperComputer.driver.usbmuxd.UsbMuxd;
 import net.northking.cctp.upperComputer.driver.usbmuxd.UsbMuxdConnectFailedException;
@@ -279,6 +280,13 @@ public class IosScreenResponseThread extends ImageScreenResponse {
                 logger.warn("设备【{}】关闭图像抓取失败。。。。。", phone.getUdid(), e);
             }
         }
+        //发送消息通知wda停止获取图片
+        IosDeviceInitThread iosInitThread = IOSDeviceManager.getInstance().getIosInitThread(phone.getUdid());
+        if (null != iosInitThread && !iosInitThread.isInterrupted() && iosInitThread.isAlive()) {
+            NKAgent nkAgent = iosInitThread.getNkAgent();
+            boolean success = nkAgent.disconnectAllMJpegSever();
+            logger.info("通知wda取消推图的结果：{}",success);
+        }
         IOSDeviceManager.getInstance().removeScreenThread(phone.getUdid());
         interrupt();
     }
diff --git a/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/driver/ios/NKAgent.java b/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/driver/ios/NKAgent.java
index c63cb56..1bb5771 100644
--- a/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/driver/ios/NKAgent.java
+++ b/cctp-atu/atu-upper-computer/src/main/java/net/northking/cctp/upperComputer/driver/ios/NKAgent.java
@@ -222,6 +222,25 @@ public final class NKAgent {
         return bool.isSuccess();
     }
 
+    public String activeAppBundleId() {
+        ICommandPacket packet = packetTransfer.syncSend(30);
+        TextData data = new TextData();
+        packet.fillICommandData(data);
+        return data.text;
+    }
+
+    /*
+    停止所有推图流
+     */
+    public  boolean disconnectAllMJpegSever() {
+        ICommandPacket packet = packetTransfer.syncSend(31);
+        if (packet == null) return false;
+        BooleanCommandData bool = new BooleanCommandData();
+        packet.fillICommandData(bool);
+        return bool.isSuccess();
+    }
+
+
     public boolean getStatus() {
         return this.packetTransfer.isConnected();
     }