WebSocket带截图/点击/滑屏/按键/跑脚本/状态查询

QQ896757558

WebSocket带截图/点击/滑屏/按键/跑脚本/状态查询










https://www.yuque.com/aiwork/nba2pr/bqfv1ssogplvivae

1. // =====================================================================
   
2. //  AIWROK WebSocket 客户端（实用版 — 带截图/点击/滑屏/按键/跑脚本/状态查询）
   
3. //
   
4. //  服务端可下发的指令（type）：
   
5. //    CMD_SCREENSHOT           截图（base64 返回，可调 quality 0.3~0.95）
   
6. //    CMD_CLICK                点击 {x, y}
   
7. //    CMD_SWIPE                滑屏 {x1,y1,x2,y2,duration}
   
8. //    CMD_KEY                  按键 {key: "BACK"|"HOME"|"RECENT"|"POWER"|"NOTIFICATION"|数字keyCode}
   
9. //    CMD_RUN_SCRIPT           远程启动脚本 {path: "/sdcard/AIWROK/xxx.js", timeoutSec, args:{...}}
   
10. //    CMD_STATUS               查设备状态（包名/内存/运行时长/分辨率）
    
11. //    CMD_TOAST                弹提示 {msg}
    
12. //    CMD_CLEAR_CACHE          清除本地缓存
    
13. //    MANAGE_TASK_NEW          下发任务（兼容原格式，自动转成 CMD_RUN_SCRIPT 或回执）
    
14. //    MANAGE_CMD_STOP_ALL      停止一切（写标志 + 设 stopAll + 回 CLIENT_STOPPING + 关 WS）
    
15. //    SERVER_PING              心跳回包
    
16. //
    
17. //  客户端上报：
    
18. //    CLIENT_REGISTER / CLIENT_HEARTBEAT / CLIENT_TASK_ACK
    
19. //    CMD_RESP  （每条 CMD_* 指令执行完都回，格式统一，含 ok/msg/data/ts/cmdId）
    
20. //    CLIENT_STOPPING  （停止前最后一条广播给服务端）
    
21. //
    
22. //  用法：CFG.serverUrl 改成 ws://ip:port/ws，直接跑
    
23. // =====================================================================
    
24. 
    
25. // ---------- 全局变量（必须放在文件顶部，避免 Rhino ES5 ReferenceError）----------
    
26. var G = {
    
27.     ws: null,
    
28.     clientId: null,
    
29.     isAllowReConnect: true,
    
30.     isInfiniteReConnect: true,
    
31.     reConnectMaxTimes: 10,
    
32.     reConnectTimes: 0,
    
33.     connectDelayMs: 3000,
    
34.     multiplier: 2,
    
35.     maxConnectDelayMs: 30000,
    
36.     heartbeatIntervalMs: 50000,
    
37.     heartbeatTimer: null,
    
38.     lastTs: 0,
    
39.     dispatcher: {},
    
40.     running: true,
    
41.     stopAll: false,            // STOP_ALL 全局标志（业务脚本都可以读这个退出）
    
42.     startTime: nowSec(),       // 启动时间戳
    
43.     activeThreads: {},         // CMD_RUN_SCRIPT 启动的线程 id -> thread 对象
    
44.     STOP_FLAG: "/sdcard/AIWROK/STOP_ALL"
    
45. };
    
46. 
    
47. var CFG = {
    
48.     serverUrl: "ws://192.168.10.103:32101/ws", // 主群控服务端
    
49.     platform:  "AIWROK",
    
50.     appName:   "AIWROK_WebSocket客户端",
    
51.     debug:     true,
    
52.     // 截图默认参数（可以被 CMD_SCREENSHOT.data 覆盖）
    
53.     defaultQuality: 0.55,
    
54.     maxWidth:   1080,          // 超过就等比缩放，减少带宽
    
55.     stopReceiverIntervalMs: 1500
    
56. };
    
57. 
    
58. // ---------- 工具函数 ----------
    
59. function nowSec() {
    
60.     return Math.floor((new Date()).getTime() / 1000);
    
61. }
    
62. function nowMs() {
    
63.     return (new Date()).getTime();
    
64. }
    
65. function jitter(ms) {
    
66.     return Math.floor(ms * (0.85 + Math.random() * 0.3));
    
67. }
    
68. function readTextFile(path) {
    
69.     try {
    
70.         var br = new java.io.BufferedReader(
    
71.             new java.io.InputStreamReader(new java.io.FileInputStream(path), "utf-8"));
    
72.         var sb = new java.lang.StringBuilder();
    
73.         var line;
    
74.         while ((line = br.readLine()) != null) sb.append(line).append("\n");
    
75.         br.close();
    
76.         return "" + sb.toString();
    
77.     } catch (e) { return null; }
    
78. }
    
79. function deleteFileOrDir(p) {
    
80.     try {
    
81.         var f = new java.io.File(p);
    
82.         if (!f.exists()) return true;
    
83.         if (f.isDirectory()) {
    
84.             var list = f.listFiles();
    
85.             for (var i = 0; i < list.length; i++) deleteFileOrDir(list[i].getAbsolutePath());
    
86.         }
    
87.         return f["delete"]();
    
88.     } catch (e) { return false; }
    
89. }
    
90. function humanSize(bytes) {
    
91.     if (bytes < 1024) return bytes + "B";
    
92.     if (bytes < 1024 * 1024) return (bytes / 1024).toFixed(1) + "KB";
    
93.     return (bytes / 1024 / 1024).toFixed(2) + "MB";
    
94. }
    
95. 
    
96. // ---------- 本地缓存封装 ----------
    
97. var Cache = {
    
98.     BASE: "/sdcard/AIWROK/wscache",
    
99.     ensure: function () {
    
100.         try {
     
101.             var f = new java.io.File(this.BASE);
     
102.             if (!f.exists()) f.mkdirs();
     
103.         } catch (e) {}
     
104.     },
     
105.     read: function (key) {
     
106.         this.ensure();
     
107.         try {
     
108.             var p = this.BASE + "/" + encodeURIComponent(key) + ".json";
     
109.             return JSON.parse(readTextFile(p));
     
110.         } catch (e) { return null; }
     
111.     },
     
112.     write: function (key, val) {
     
113.         this.ensure();
     
114.         try {
     
115.             var p = this.BASE + "/" + encodeURIComponent(key) + ".json";
     
116.             var fw = new java.io.FileWriter(p);
     
117.             fw.write(JSON.stringify(val));
     
118.             fw.close();
     
119.             return true;
     
120.         } catch (e) { return false; }
     
121.     },
     
122.     clear: function (key) {
     
123.         try {
     
124.             var p = this.BASE + "/" + encodeURIComponent(key) + ".json";
     
125.             var f = new java.io.File(p);
     
126.             if (f.exists()) f["delete"]();
     
127.         } catch (e) {}
     
128.     },
     
129.     clearAll: function () {
     
130.         return deleteFileOrDir(this.BASE);
     
131.     }
     
132. };
     
133. 
     
134. // 尝试恢复 client_id
     
135. G.clientId = (Cache.read("wsc_client_id") || {}).id || null;
     
136. 
     
137. // ---------- 统一 CMD_RESP ----------
     
138. function cmdResp(cmdName, cmdId, ok, msg, data) {
     
139.     var obj = {
     
140.         type: "CMD_RESP",
     
141.         cmd: cmdName,
     
142.         cmdId: cmdId || ("cid_" + nowMs() + "_" + Math.floor(Math.random() * 1000)),
     
143.         ok: !!ok,
     
144.         msg: msg || (ok ? "ok" : "failed"),
     
145.         ts: nowSec()
     
146.     };
     
147.     if (typeof data !== "undefined") obj.data = data;
     
148.     if (G.clientId) obj.client_id = G.clientId;
     
149.     WSC.send(obj);
     
150.     return obj;
     
151. }
     
152. 
     
153. // ---------- 消息派发器 ----------
     
154. var WSC = {
     
155.     on: function (type, fn) {
     
156.         if (!G.dispatcher[type]) G.dispatcher[type] = [];
     
157.         G.dispatcher[type].push(fn);
     
158.     },
     
159.     off: function (type, fn) {
     
160.         var arr = G.dispatcher[type] || [];
     
161.         for (var i = arr.length - 1; i >= 0; i--) if (arr[i] === fn) arr.splice(i, 1);
     
162.     },
     
163.     fire: function (type, msgObj) {
     
164.         var arr = G.dispatcher[type] || [];
     
165.         for (var i = 0; i < arr.length; i++) {
     
166.             try {
     
167.                 arr[i](msgObj);
     
168.             } catch (e) {
     
169.                 printl("派发[" + type + "]异常: " + (e.message || e));
     
170.             }
     
171.         }
     
172.     },
     
173.     send: function (obj) {
     
174.         if (!G.ws) return false;
     
175.         if (G.clientId && obj.clientId == null) obj.client_id = G.clientId;
     
176.         if (obj.timestamp == null) obj.timestamp = nowSec();
     
177.         if (obj.platform == null) obj.platform = CFG.platform;
     
178.         var txt = JSON.stringify(obj);
     
179.         try {
     
180.             G.ws.send(txt);
     
181.             if (CFG.debug) {
     
182.                 var head = (obj.type || "?") + " ";
     
183.                 // 截图回包 base64 太长，只打摘要
     
184.                 if (obj.type === "CMD_RESP" && obj.data && obj.data.base64) {
     
185.                     printl("SEND -> " + head + "[" + obj.cmd + "] base64_len=" + obj.data.base64.length + " (" + obj.data.w + "x" + obj.data.h + " q=" + obj.data.quality + ")");
     
186.                 } else {
     
187.                     printl("SEND -> " + head + txt.slice(0, 160));
     
188.                 }
     
189.             }
     
190.             return true;
     
191.         } catch (e) {
     
192.             printl("发送失败: " + (e.message || e));
     
193.             return false;
     
194.         }
     
195.     },
     
196.     stop: function () {
     
197.         G.running = false;
     
198.         G.isAllowReConnect = false;
     
199.         if (G.heartbeatTimer) {
     
200.             try { clearTimeout(G.heartbeatTimer); } catch (e) {}
     
201.             G.heartbeatTimer = null;
     
202.         }
     
203.         try { if (G.ws) G.ws.close(); } catch (e) {}
     
204.     }
     
205. };
     
206. 
     
207. // ---------- 心跳（安全版：链式 setTimeout 全包 try-catch，避免 AIWROK 未捕获异常杀脚本）----------
     
208. function startHeartbeat() {
     
209.     if (G.heartbeatTimer) {
     
210.         try { clearTimeout(G.heartbeatTimer); } catch (e) {}
     
211.     }
     
212.     (function tick() {
     
213.         try {
     
214.             if (!G.running) return;
     
215.             var imei = "";
     
216.             try { if (typeof device !== "undefined") imei = device.getIMEI() || ""; } catch (e) {}
     
217.             WSC.send({
     
218.                 type: "CLIENT_HEARTBEAT",
     
219.                 imei: imei,
     
220.                 platform: CFG.platform,
     
221.                 app: CFG.appName,
     
222.                 runtimeSec: nowSec() - G.startTime,
     
223.                 stopAll: !!G.stopAll
     
224.             });
     
225.         } catch (eOuter) {
     
226.             try { printl("心跳异常(已兜住): " + (eOuter.message || eOuter)); } catch (eL) {}
     
227.         }
     
228.         try {
     
229.             G.heartbeatTimer = setTimeout(tick, G.heartbeatIntervalMs);
     
230.         } catch (eTimer) {
     
231.             try { printl("心跳下一次调度失败: " + (eTimer.message || eTimer)); } catch (eL) {}
     
232.         }
     
233.     })();
     
234. }
     
235. 
     
236. // ---------- 设备信息采集（连接时用，也被 CMD_STATUS 复用）----------
     
237. function collectDeviceInfo() {
     
238.     var info = {
     
239.         platform: CFG.platform,
     
240.         app: CFG.appName,
     
241.         imei: "",
     
242.         android: "",
     
243.         model: "",
     
244.         brand: "",
     
245.         w: 1080,
     
246.         h: 2400,
     
247.         dpi: 0,
     
248.         frontPkg: "",
     
249.         internalMB: 0,
     
250.         sdMB: 0,
     
251.         clientId: G.clientId,
     
252.         runtimeSec: nowSec() - G.startTime,
     
253.         stopAll: !!G.stopAll,
     
254.         activeScriptCount: 0
     
255.     };
     
256.     try { if (typeof device !== "undefined") info.imei = device.getIMEI() || ""; } catch (e) {}
     
257.     try { info.android = java.lang.System.getProperty("os.version") + ""; } catch (e) {}
     
258.     try { info.model = android.os.Build.MODEL + ""; } catch (e) {}
     
259.     try { info.brand = android.os.Build.BRAND + ""; } catch (e) {}
     
260.     try {
     
261.         if (typeof screen !== "undefined") {
     
262.             info.w = screen.getScreenWidth();
     
263.             info.h = screen.getScreenHeight();
     
264.             try { info.dpi = screen.getDensityDpi(); } catch (e2) {}
     
265.         }
     
266.     } catch (e) {}
     
267.     try {
     
268.         var am = context.getSystemService(android.content.Context.ACTIVITY_SERVICE);
     
269.         info.frontPkg = am.getRunningTasks(1).get(0).topActivity.getPackageName() + "";
     
270.     } catch (e) {}
     
271.     try {
     
272.         var stat = new android.os.StatFs(android.os.Environment.getDataDirectory().getAbsolutePath());
     
273.         info.internalMB = Math.floor((stat.getAvailableBytes() * 1.0) / 1024 / 1024);
     
274.     } catch (e) {}
     
275.     try {
     
276.         var sd = android.os.Environment.getExternalStorageDirectory();
     
277.         var s2 = new android.os.StatFs(sd.getAbsolutePath());
     
278.         info.sdMB = Math.floor((s2.getAvailableBytes() * 1.0) / 1024 / 1024);
     
279.     } catch (e) {}
     
280.     var cnt = 0;
     
281.     try { for (var k in G.activeThreads) if (G.activeThreads.hasOwnProperty(k)) cnt++; } catch (e) {}
     
282.     info.activeScriptCount = cnt;
     
283.     return info;
     
284. }
     
285. 
     
286. // ---------- 事件回调：onConnected ----------
     
287. function wsOnConnected() {
     
288.     G.reConnectTimes = 0;
     
289.     G.connectDelayMs = 3000;
     
290.     printl("✓ 连接成功 — 握手完成");
     
291. 
     
292.     var info = collectDeviceInfo();
     
293.     WSC.send({
     
294.         type: "CLIENT_REGISTER",
     
295.         platform: info.platform,
     
296.         imei: info.imei,
     
297.         app: info.app,
     
298.         lastClientId: G.clientId,
     
299.         screen: info.w + "x" + info.h,
     
300.         dpi: info.dpi,
     
301.         android: info.android,
     
302.         model: info.model,
     
303.         brand: info.brand,
     
304.         internalMB: info.internalMB,
     
305.         sdMB: info.sdMB
     
306.     });
     
307.     startHeartbeat();
     
308.     WSC.fire("_connected", info);
     
309. }
     
310. 
     
311. // ---------- 事件回调：onTextMessage ----------
     
312. function wsOnTextMessage(msg) {
     
313.     var s = "" + msg;
     
314.     if (CFG.debug) printl("RECV <- " + s.slice(0, 200));
     
315.     var obj = null;
     
316.     try { obj = JSON.parse(s); } catch (e) {
     
317.         printl("非JSON消息，忽略: " + s.slice(0, 120));
     
318.         WSC.fire("_text", { raw: s });
     
319.         return;
     
320.     }
     
321.     if (obj && obj.type === "SERVER_INIT") {
     
322.         if (obj.client_id) {
     
323.             G.clientId = obj.client_id;
     
324.             Cache.write("wsc_client_id", { id: G.clientId });
     
325.             printl("服务端分配 client_id: " + G.clientId + "（已本地保存）");
     
326.         }
     
327.         if (obj.msg) printl("服务端消息: " + obj.msg);
     
328.     }
     
329.     if (obj && obj.type) {
     
330.         WSC.fire(obj.type, obj);
     
331.         WSC.fire("_any", obj);
     
332.     }
     
333. }
     
334. 
     
335. // ---------- 事件回调：onConnectError ----------
     
336. function wsOnConnectError() {
     
337.     printl("✗ 连接失败（通常服务端未开启或端口不通）");
     
338.     scheduleReconnect();
     
339. }
     
340. 
     
341. // ---------- 事件回调：onDisconnected ----------
     
342. function wsOnDisconnected() {
     
343.     printl("✗ 连接已断开");
     
344.     if (G.heartbeatTimer) {
     
345.         try { clearTimeout(G.heartbeatTimer); } catch (e) {}
     
346.         G.heartbeatTimer = null;
     
347.     }
     
348.     scheduleReconnect();
     
349. }
     
350. 
     
351. // ---------- 连接 + 事件重挂 ----------
     
352. function connectWebSocket() {
     
353.     if (G.ws) {
     
354.         try { G.ws.close(); } catch (e) {}
     
355.         G.ws = null;
     
356.     }
     
357.     printl("开始连接: " + CFG.serverUrl + "  (重试计数 " + G.reConnectTimes + "/" + G.reConnectMaxTimes + ")");
     
358. 
     
359.     var ws = null;
     
360.     try { ws = new websocket(); }
     
361.     catch (e) {
     
362.         printl("new websocket() 失败: " + (e.message || e));
     
363.         scheduleReconnect();
     
364.         return;
     
365.     }
     
366. 
     
367.     G.ws = ws;
     
368. 
     
369.     // 挂事件：AIWROK 新版 ws.event() 优先，失败兜底属性赋值
     
370.     var eventOk = false;
     
371.     try {
     
372.         ws.event(wsOnConnected, wsOnTextMessage, wsOnConnectError, wsOnDisconnected);
     
373.         eventOk = true;
     
374.         if (CFG.debug) printl("ws.event() 挂事件成功");
     
375.     } catch (e1) {
     
376.         if (CFG.debug) printl("ws.event() 失败: " + (e1.message || e1) + " — 尝试属性赋值");
     
377.     }
     
378.     if (!eventOk) {
     
379.         try {
     
380.             ws.onConnected = wsOnConnected;
     
381.             ws.onTextMessage = wsOnTextMessage;
     
382.             ws.onConnectError = wsOnConnectError;
     
383.             ws.onDisconnected = wsOnDisconnected;
     
384.             if (CFG.debug) printl("属性赋值挂事件成功");
     
385.         } catch (e2) {
     
386.             printl("两种事件挂法都失败: " + (e2.message || e2));
     
387.         }
     
388.     }
     
389. 
     
390.     // 发起连接：AIWROK connet(双n) 优先，失败回退 connect
     
391.     try {
     
392.         var ret = null;
     
393.         try { ret = ws.connet(CFG.serverUrl); }
     
394.         catch (eA) {
     
395.             printl("connet() 异常: " + (eA.message || eA) + " — 回退 connect()");
     
396.             ret = ws.connect(CFG.serverUrl);
     
397.         }
     
398.         if (CFG.debug) printl("连接发起返回: " + (ret == null ? "null(表示已发起)" : ret));
     
399.     } catch (eB) {
     
400.         printl("两种连接方式都失败: " + (eB.message || eB));
     
401.         scheduleReconnect();
     
402.     }
     
403. }
     
404. 
     
405. // ---------- 指数退避 + 抖动重连（安全版：setTimeout 最外层包 try-catch）----------
     
406. function scheduleReconnect() {
     
407.     try {
     
408.         if (!G.running) return;
     
409.         if (!G.isAllowReConnect) return;
     
410.         G.reConnectTimes += 1;
     
411.         if (!G.isInfiniteReConnect && G.reConnectTimes > G.reConnectMaxTimes) {
     
412.             printl("⚠️  超过最大重试次数(" + G.reConnectMaxTimes + ")，停止重连");
     
413.             return;
     
414.         }
     
415.         G.connectDelayMs = Math.min(G.connectDelayMs * G.multiplier, G.maxConnectDelayMs);
     
416.         var waitMs = jitter(G.connectDelayMs);
     
417.         printl("下次重连等待 " + (waitMs / 1000).toFixed(2) + "s  (封顶" + (G.maxConnectDelayMs / 1000) + "s)");
     
418.         setTimeout(function () {
     
419.             try { connectWebSocket(); } catch (e) {
     
420.                 printl("重连回调异常(已兜住): " + (e.message || e));
     
421.                 scheduleReconnect();
     
422.             }
     
423.         }, waitMs);
     
424.     } catch (eOuter) {
     
425.         printl("scheduleReconnect 外层异常: " + (eOuter.message || eOuter));
     
426.     }
     
427. }
     
428. 
     
429. // =====================================================================
     
430. //  业务指令实现（真正能用的功能，不是空壳）
     
431. // =====================================================================
     
432. 
     
433. // -------- CMD_SCREENSHOT：截图，base64 返回 -------
     
434. // 支持: o.data = { quality:0.3~0.95, maxWidth:1080, full:true/false }
     
435. WSC.on("CMD_SCREENSHOT", function (o) {
     
436.     var t0 = nowMs();
     
437.     var cmdId = o.cmdId;
     
438.     try {
     
439.         var quality = CFG.defaultQuality;
     
440.         if (o && o.data && o.data.quality && o.data.quality > 0 && o.data.quality <= 1) {
     
441.             quality = o.data.quality;
     
442.         }
     
443.         var maxW = CFG.maxWidth;
     
444.         if (o && o.data && o.data.maxWidth && o.data.maxWidth > 0) maxW = o.data.maxWidth;
     
445. 
     
446.         // 1) fastCapture 截图
     
447.         var bmp = null;
     
448.         try {
     
449.             if (typeof image !== "undefined") {
     
450.                 bmp = image.fastCapture();
     
451.             } else {
     
452.                 cmdResp("CMD_SCREENSHOT", cmdId, false, "image 对象不可用");
     
453.                 return;
     
454.             }
     
455.         } catch (e) {
     
456.             cmdResp("CMD_SCREENSHOT", cmdId, false, "fastCapture 异常: " + (e.message || e));
     
457.             return;
     
458.         }
     
459.         if (!bmp) { cmdResp("CMD_SCREENSHOT", cmdId, false, "截图返回空"); return; }
     
460. 
     
461.         var w = bmp.getWidth();
     
462.         var h = bmp.getHeight();
     
463. 
     
464.         // 2) 超宽就等比缩放
     
465.         if (w > maxW) {
     
466.             var ratio = maxW * 1.0 / w;
     
467.             var newH = Math.floor(h * ratio);
     
468.             try {
     
469.                 var scaled = android.graphics.Bitmap.createScaledBitmap(bmp, maxW, newH, true);
     
470.                 try { bmp.recycle(); } catch (e) {}
     
471.                 bmp = scaled;
     
472.                 w = maxW;
     
473.                 h = newH;
     
474.             } catch (e2) {}
     
475.         }
     
476. 
     
477.         // 3) JPEG 压缩转 base64
     
478.         var baos = new java.io.ByteArrayOutputStream();
     
479.         bmp.compress(android.graphics.Bitmap.CompressFormat.JPEG, Math.floor(quality * 100), baos);
     
480.         try { bmp.recycle(); } catch (e) {}
     
481.         var bytes = baos.toByteArray();
     
482.         var b64 = android.util.Base64.encodeToString(bytes, android.util.Base64.NO_WRAP);
     
483.         try { baos.close(); } catch (e) {}
     
484. 
     
485.         cmdResp("CMD_SCREENSHOT", cmdId, true, "ok", {
     
486.             base64: "" + b64,
     
487.             w: w,
     
488.             h: h,
     
489.             quality: quality,
     
490.             sizeKb: Math.floor(bytes.length / 1024),
     
491.             costMs: nowMs() - t0
     
492.         });
     
493.     } catch (eBig) {
     
494.         cmdResp("CMD_SCREENSHOT", cmdId, false, "截图总异常: " + (eBig.message || eBig));
     
495.     }
     
496. });
     
497. 
     
498. // -------- CMD_CLICK：点击 {x, y} -------
     
499. WSC.on("CMD_CLICK", function (o) {
     
500.     var cmdId = o.cmdId;
     
501.     var x = (o && o.data && o.data.x != null) ? parseInt(o.data.x, 10) : NaN;
     
502.     var y = (o && o.data && o.data.y != null) ? parseInt(o.data.y, 10) : NaN;
     
503.     if (isNaN(x) || isNaN(y) || x < 0 || y < 0) {
     
504.         cmdResp("CMD_CLICK", cmdId, false, "缺少有效 x/y 坐标");
     
505.         return;
     
506.     }
     
507.     try {
     
508.         if (typeof action !== "undefined") {
     
509.             action.click(x, y);
     
510.             cmdResp("CMD_CLICK", cmdId, true, "ok", { x: x, y: y });
     
511.         } else {
     
512.             cmdResp("CMD_CLICK", cmdId, false, "action 对象不可用");
     
513.         }
     
514.     } catch (e) {
     
515.         cmdResp("CMD_CLICK", cmdId, false, "点击异常: " + (e.message || e));
     
516.     }
     
517. });
     
518. 
     
519. // -------- CMD_SWIPE：滑屏 {x1,y1,x2,y2,duration} -------
     
520. WSC.on("CMD_SWIPE", function (o) {
     
521.     var cmdId = o.cmdId;
     
522.     var d = o && o.data ? o.data : {};
     
523.     var x1 = parseInt(d.x1, 10), y1 = parseInt(d.y1, 10);
     
524.     var x2 = parseInt(d.x2, 10), y2 = parseInt(d.y2, 10);
     
525.     var dur = d.duration ? parseInt(d.duration, 10) : 300;
     
526.     if ([x1, y1, x2, y2].some(function (n) { return isNaN(n) || n < 0; })) {
     
527.         cmdResp("CMD_SWIPE", cmdId, false, "坐标缺失");
     
528.         return;
     
529.     }
     
530.     try {
     
531.         if (typeof action !== "undefined") {
     
532.             action.swipe(x1, y1, x2, y2, dur);
     
533.             cmdResp("CMD_SWIPE", cmdId, true, "ok", { x1: x1, y1: y1, x2: x2, y2: y2, duration: dur });
     
534.         } else {
     
535.             cmdResp("CMD_SWIPE", cmdId, false, "action 对象不可用");
     
536.         }
     
537.     } catch (e) {
     
538.         cmdResp("CMD_SWIPE", cmdId, false, "滑屏异常: " + (e.message || e));
     
539.     }
     
540. });
     
541. 
     
542. // -------- CMD_KEY：按键 -------
     
543. // data.key 支持: "BACK" / "HOME" / "RECENT" / "POWER" / "NOTIFICATION" / 数字 keyCode
     
544. WSC.on("CMD_KEY", function (o) {
     
545.     var cmdId = o.cmdId;
     
546.     var key = (o && o.data && o.data.key != null) ? ("" + o.data.key) : "";
     
547.     if (!key) { cmdResp("CMD_KEY", cmdId, false, "缺少 key"); return; }
     
548.     try {
     
549.         // 方式1：action 快捷方法
     
550.         if (typeof action !== "undefined") {
     
551.             var k = key.toUpperCase();
     
552.             if (k === "BACK") { action.back(); cmdResp("CMD_KEY", cmdId, true, "BACK"); return; }
     
553.             if (k === "HOME") { action.home(); cmdResp("CMD_KEY", cmdId, true, "HOME"); return; }
     
554.             if (k === "RECENT" || k === "RECENTS" || k === "APP_SWITCH") {
     
555.                 action.recents(); cmdResp("CMD_KEY", cmdId, true, "RECENT"); return;
     
556.             }
     
557.         }
     
558.         // 方式2：systempress 数字 keyCode
     
559.         var code = parseInt(key, 10);
     
560.         if (!isNaN(code) && code > 0) {
     
561.             if (typeof systempress !== "undefined") {
     
562.                 systempress(code);
     
563.                 cmdResp("CMD_KEY", cmdId, true, "keyCode " + code);
     
564.                 return;
     
565.             }
     
566.         }
     
567.         // 方式3：shell input keyevent（兜底）
     
568.         var shellKey = null;
     
569.         var k2 = key.toUpperCase();
     
570.         if (k2 === "BACK") shellKey = "4";
     
571.         else if (k2 === "HOME") shellKey = "3";
     
572.         else if (k2 === "RECENT" || k2 === "RECENTS") shellKey = "187";
     
573.         else if (k2 === "POWER") shellKey = "26";
     
574.         else if (k2 === "NOTIFICATION") shellKey = "83";
     
575.         else if (!isNaN(code) && code > 0) shellKey = "" + code;
     
576.         if (shellKey) {
     
577.             try {
     
578.                 java.lang.Runtime.getRuntime().exec(["su", "-c", "input keyevent " + shellKey]).waitFor();
     
579.                 cmdResp("CMD_KEY", cmdId, true, "shell key " + key);
     
580.                 return;
     
581.             } catch (eS) {}
     
582.             try {
     
583.                 java.lang.Runtime.getRuntime().exec(["input", "keyevent", shellKey]).waitFor();
     
584.                 cmdResp("CMD_KEY", cmdId, true, "shell key(no su) " + key);
     
585.                 return;
     
586.             } catch (eS2) {}
     
587.         }
     
588.         cmdResp("CMD_KEY", cmdId, false, "不支持的 key: " + key);
     
589.     } catch (e) {
     
590.         cmdResp("CMD_KEY", cmdId, false, "按键异常: " + (e.message || e));
     
591.     }
     
592. });
     
593. 
     
594. // -------- CMD_RUN_SCRIPT：远程跑脚本 -------
     
595. // data = { path, timeoutSec, args }
     
596. // 返回 { threadId, pid, ok }，后续可查线程状态
     
597. WSC.on("CMD_RUN_SCRIPT", function (o) {
     
598.     var cmdId = o.cmdId;
     
599.     var d = o && o.data ? o.data : {};
     
600.     var path = (d.path || "").trim();
     
601.     var timeoutSec = d.timeoutSec ? parseInt(d.timeoutSec, 10) : 600;
     
602.     if (!path) { cmdResp("CMD_RUN_SCRIPT", cmdId, false, "缺少脚本 path"); return; }
     
603. 
     
604.     // 路径支持两种：绝对路径，或相对于 /sdcard/AIWROK/
     
605.     var fullPath = path;
     
606.     if (!new java.io.File(path).isAbsolute()) {
     
607.         fullPath = "/sdcard/AIWROK/" + path;
     
608.     }
     
609.     if (!new java.io.File(fullPath).exists()) {
     
610.         cmdResp("CMD_RUN_SCRIPT", cmdId, false, "脚本不存在: " + fullPath);
     
611.         return;
     
612.     }
     
613. 
     
614.     try {
     
615.         // AIWROK 约束：用 thread.runJsFile() 加载外部脚本
     
616.         if (typeof thread === "undefined") {
     
617.             cmdResp("CMD_RUN_SCRIPT", cmdId, false, "thread 对象不可用");
     
618.             return;
     
619.         }
     
620.         var tid = "T" + nowMs() + "_" + Math.floor(Math.random() * 10000);
     
621.         // 构造成员：把 client_id、CMD_RUN_SCRIPT 的 args、STOP_ALL 标志路径放进脚本共享变量
     
622.         try { scriptShared = { CMD_ARGS: d.args || {}, STOP_FLAG: G.STOP_FLAG, CLIENT_ID: G.clientId, CMD_ID: cmdId }; } catch (eSh) {}
     
623. 
     
624.         var th = thread.runJsFile(fullPath);
     
625.         G.activeThreads[tid] = { thread: th, path: fullPath, startAt: nowSec(), timeoutSec: timeoutSec, cmdId: cmdId };
     
626. 
     
627.         // 守护协程：非阻塞链式 setTimeout 轮询（不占用派发线程，避免 AIWROK 杀脚本）
     
628.         (function watcherStep() {
     
629.             try {
     
630.                 var rec = G.activeThreads[tid];
     
631.                 if (!rec) return; // 已经被 STOP_ALL 清理掉了
     
632.                 var stillAlive = true;
     
633.                 try {
     
634.                     // isAlive 在部分 AIWROK 版本里是字段不是方法，两种都兜住
     
635.                     if (th && typeof th.isAlive === "function") stillAlive = th.isAlive();
     
636.                     else if (th && typeof th.isAlive === "boolean") stillAlive = th.isAlive;
     
637.                     else stillAlive = true;
     
638.                 } catch (eChk) { stillAlive = false; }
     
639. 
     
640.                 var runSec = nowSec() - rec.startAt;
     
641.                 var timeIsUp = runSec >= (rec.timeoutSec + 1);
     
642.                 var shouldStop = !stillAlive || timeIsUp || G.stopAll;
     
643. 
     
644.                 if (!shouldStop) {
     
645.                     setTimeout(watcherStep, 1000);
     
646.                     return;
     
647.                 }
     
648. 
     
649.                 // 超时或 STOP_ALL -> 停线程
     
650.                 if (stillAlive && timeIsUp) {
     
651.                     try { if (th && th.stop) th.stop(); } catch (eStop) {}
     
652.                 }
     
653.                 var cost = nowSec() - rec.startAt;
     
654.                 try { delete G.activeThreads[tid]; } catch (eDel) {}
     
655.                 WSC.send({
     
656.                     type: "CLIENT_SCRIPT_RESULT",
     
657.                     cmdId: cmdId,
     
658.                     threadId: tid,
     
659.                     path: fullPath,
     
660.                     timeout: timeIsUp && stillAlive,
     
661.                     runtimeSec: cost,
     
662.                     stopAll: !!G.stopAll,
     
663.                     ts: nowSec()
     
664.                 });
     
665.             } catch (eOuter) {
     
666.                 printl("CMD_RUN_SCRIPT 守护协程异常(已兜住): " + (eOuter.message || eOuter));
     
667.             }
     
668.         })();
     
669. 
     
670.         cmdResp("CMD_RUN_SCRIPT", cmdId, true, "已启动", { threadId: tid, path: fullPath, timeoutSec: timeoutSec });
     
671.     } catch (e) {
     
672.         cmdResp("CMD_RUN_SCRIPT", cmdId, false, "启动异常: " + (e.message || e));
     
673.     }
     
674. });
     
675. 
     
676. // -------- CMD_STATUS：查状态 -------
     
677. WSC.on("CMD_STATUS", function (o) {
     
678.     try {
     
679.         var info = collectDeviceInfo();
     
680.         // 列活跃线程
     
681.         var threads = [];
     
682.         try {
     
683.             for (var k in G.activeThreads) if (G.activeThreads.hasOwnProperty(k)) {
     
684.                 var t = G.activeThreads[k];
     
685.                 threads.push({
     
686.                     id: k,
     
687.                     path: t.path,
     
688.                     runSec: nowSec() - t.startAt,
     
689.                     timeoutSec: t.timeoutSec
     
690.                 });
     
691.             }
     
692.         } catch (e) {}
     
693.         info.threads = threads;
     
694.         cmdResp("CMD_STATUS", o && o.cmdId, true, "ok", info);
     
695.     } catch (e) {
     
696.         cmdResp("CMD_STATUS", o && o.cmdId, false, "状态异常: " + (e.message || e));
     
697.     }
     
698. });
     
699. 
     
700. // -------- CMD_TOAST：弹个消息 -------
     
701. WSC.on("CMD_TOAST", function (o) {
     
702.     var cmdId = o && o.cmdId;
     
703.     var msg = (o && o.data && o.data.msg != null) ? ("" + o.data.msg) : "";
     
704.     if (!msg) { cmdResp("CMD_TOAST", cmdId, false, "缺少 msg"); return; }
     
705.     try {
     
706.         if (typeof toast !== "undefined") { toast(msg); }
     
707.         cmdResp("CMD_TOAST", cmdId, true, "ok", { msg: msg });
     
708.     } catch (e) {
     
709.         cmdResp("CMD_TOAST", cmdId, false, "toast 异常: " + (e.message || e));
     
710.     }
     
711. });
     
712. 
     
713. // -------- CMD_CLEAR_CACHE：清除本地缓存 -------
     
714. WSC.on("CMD_CLEAR_CACHE", function (o) {
     
715.     var cmdId = o && o.cmdId;
     
716.     try {
     
717.         Cache.clearAll();
     
718.         // 顺便删 STOP_ALL 标志
     
719.         try {
     
720.             var f2 = new java.io.File(G.STOP_FLAG);
     
721.             if (f2.exists()) f2["delete"]();
     
722.         } catch (e2) {}
     
723.         G.stopAll = false;
     
724.         cmdResp("CMD_CLEAR_CACHE", cmdId, true, "ok");
     
725.     } catch (e) {
     
726.         cmdResp("CMD_CLEAR_CACHE", cmdId, false, "清除异常: " + (e.message || e));
     
727.     }
     
728. });
     
729. 
     
730. // -------- MANAGE_TASK_NEW：兼容原任务下发格式 -------
     
731. // 如果 data.action === "run_script" 就自动走 CMD_RUN_SCRIPT 逻辑；否则打印并回 ACK
     
732. WSC.on("MANAGE_TASK_NEW", function (o) {
     
733.     printl("[任务] 收到: " + JSON.stringify(o.data || o).slice(0, 160));
     
734.     try {
     
735.         var d = o.data || o;
     
736.         if (d && d.action === "run_script" && d.path) {
     
737.             WSC.fire("CMD_RUN_SCRIPT", { type: "CMD_RUN_SCRIPT", cmdId: (o.taskId || ("task_" + nowMs())), data: d });
     
738.             WSC.send({ type: "CLIENT_TASK_ACK", taskId: o.taskId || (d.taskId || ""), accepted: true, mode: "auto_run_script", data: d });
     
739.         } else {
     
740.             WSC.send({ type: "CLIENT_TASK_ACK", taskId: o.taskId || (d && d.taskId || ""), accepted: true });
     
741.         }
     
742.     } catch (e) {
     
743.         WSC.send({ type: "CLIENT_TASK_ACK", taskId: o.taskId || "", accepted: false, error: (e.message || e) });
     
744.     }
     
745. });
     
746. 
     
747. // -------- MANAGE_CMD_STOP_ALL：真停止逻辑（不是只写个文件就完事）-------
     
748. // 动作：1) 设标志 + 写文件 2) 停止所有活跃线程 3) 心跳停 4) 上报 CLIENT_STOPPING 5) 2 秒后 WSC.stop()
     
749. WSC.on("MANAGE_CMD_STOP_ALL", function (o) {
     
750.     printl("[指令] STOP_ALL 广播，开始完整清理");
     
751.     try { G.stopAll = true; } catch (e) {}
     
752.     try { G.isAllowReConnect = false; } catch (e) {}
     
753. 
     
754.     // 1) 写标志文件（供其他脚本读）
     
755.     try {
     
756.         var f = new java.io.File(G.STOP_FLAG);
     
757.         if (!f.exists()) f.createNewFile();
     
758.     } catch (e) {}
     
759. 
     
760.     // 2) 停止所有 CMD_RUN_SCRIPT 启动的活跃线程
     
761.     var stoppedCnt = 0;
     
762.     try {
     
763.         for (var k in G.activeThreads) if (G.activeThreads.hasOwnProperty(k)) {
     
764.             try {
     
765.                 var tObj = G.activeThreads[k];
     
766.                 if (tObj && tObj.thread && tObj.thread.stop) tObj.thread.stop();
     
767.                 stoppedCnt++;
     
768.             } catch (eSt) {}
     
769.         }
     
770.     } catch (e) {}
     
771.     try { G.activeThreads = {}; } catch (e) {}
     
772. 
     
773.     // 3) 立即发 CLIENT_STOPPING
     
774.     try {
     
775.         WSC.send({
     
776.             type: "CLIENT_STOPPING",
     
777.             reason: "MANAGE_CMD_STOP_ALL",
     
778.             stoppedThreads: stoppedCnt,
     
779.             runtimeSec: nowSec() - G.startTime,
     
780.             ts: nowSec()
     
781.         });
     
782.     } catch (eS) {}
     
783. 
     
784.     // 4) 2 秒后彻底关 WS 与保活（链式 setTimeout 全部兜 try-catch，避免 AIWROK 判"异常未捕获"直接杀）
     
785.     try {
     
786.         setTimeout(function () {
     
787.             try {
     
788.                 if (G.heartbeatTimer) { clearTimeout(G.heartbeatTimer); G.heartbeatTimer = null; }
     
789.             } catch (e1) {}
     
790.             try { WSC.stop(); } catch (e2) {}
     
791.             try { printl("[指令] STOP_ALL 清理完成，已断开 WS"); } catch (e3) {}
     
792.         }, 2000);
     
793.     } catch (eOuter) {}
     
794. });
     
795. 
     
796. // -------- SERVER_PING：心跳回包 -------
     
797. WSC.on("SERVER_PING", function (o) {
     
798.     WSC.send({
     
799.         type: "CLIENT_PONG",
     
800.         echo: o,
     
801.         runtimeSec: nowSec() - G.startTime,
     
802.         ts: nowSec()
     
803.     });
     
804. });
     
805. 
     
806. // =====================================================================
     
807. //  远程停止接收专用线程（硬约束要求）
     
808. //  单独轮询 STOP_ALL 标志文件；一旦存在就触发完整停止逻辑
     
809. // =====================================================================
     
810. function startStopReceiver() {
     
811.     (function loop() {
     
812.         try {
     
813.             if (!G.running) return;
     
814.             var f = new java.io.File(G.STOP_FLAG);
     
815.             if (f.exists() && !G.stopAll) {
     
816.                 printl("[接收器] 检测到 STOP_ALL 标志文件，触发停止");
     
817.                 try { f["delete"](); } catch (eDel) {}
     
818.                 // 模拟收到一条 MANAGE_CMD_STOP_ALL 消息，走同一套清理逻辑
     
819.                 WSC.fire("MANAGE_CMD_STOP_ALL", { type: "MANAGE_CMD_STOP_ALL", from: "local_flag" });
     
820.             }
     
821.         } catch (eOuter) {
     
822.             try { printl("[接收器] 轮询异常(已兜住): " + (eOuter.message || eOuter)); } catch (eL) {}
     
823.         }
     
824.         try { setTimeout(loop, CFG.stopReceiverIntervalMs); }
     
825.         catch (eTimer) {
     
826.             // runTime.setTimeout 兜底（仅当 setTimeout 不存在时用）
     
827.             try { runTime.setTimeout(loop, CFG.stopReceiverIntervalMs); } catch (eRT) {}
     
828.         }
     
829.     })();
     
830. }
     
831. 
     
832. // ---------- 启动入口（全局 try-catch + setTimeout 不阻塞，杜绝 AIWROK 随便『正在停止』）----------
     
833. function main() {
     
834.     try {
     
835.         // 启动先清一次 STOP_ALL 标志，避免上一次的残余
     
836.         try {
     
837.             var _f = new java.io.File(G.STOP_FLAG);
     
838.             if (_f.exists()) _f["delete"]();
     
839.         } catch (e) {}
     
840.         G.stopAll = false;
     
841. 
     
842.         printl("==========================================");
     
843.         printl("  AIWROK WebSocket 客户端 启动");
     
844.         printl("  平台: " + CFG.platform + "   App: " + CFG.appName);
     
845.         printl("  服务端: " + CFG.serverUrl);
     
846.         printl("  恢复 client_id: " + (G.clientId || "新注册"));
     
847.         printl("  可用指令: CMD_SCREENSHOT / CMD_CLICK / CMD_SWIPE / CMD_KEY");
     
848.         printl("           CMD_RUN_SCRIPT / CMD_STATUS / CMD_TOAST / CMD_CLEAR_CACHE");
     
849.         printl("==========================================");
     
850.         connectWebSocket();
     
851.         startStopReceiver();
     
852. 
     
853.         // 主线程保活（链式 setTimeout，非阻塞，全包 try-catch）
     
854.         var keepAliveTick = 0;
     
855.         (function keepAlive() {
     
856.             try {
     
857.                 if (!G.running) { printl("保活线程退出"); return; }
     
858.                 keepAliveTick++;
     
859.                 if (keepAliveTick % 20 === 0) {
     
860.                     printl("[保活] client_id=" + (G.clientId || "N/A") + " 重试=" + G.reConnectTimes + " 运行=" + (nowSec() - G.startTime) + "s stopAll=" + G.stopAll);
     
861.                 }
     
862.             } catch (eInner) {
     
863.                 try { printl("[保活] 一次循环异常(已兜住): " + (eInner.message || eInner)); } catch (eL) {}
     
864.             }
     
865.             try { setTimeout(keepAlive, 1000); }
     
866.             catch (eTimer) {
     
867.                 try { runTime.setTimeout(keepAlive, 1000); } catch (eRT) {}
     
868.             }
     
869.         })();
     
870.     } catch (eTop) {
     
871.         // 任何 main 里未捕获异常都兜住，不让 AIWROK 直接给『正在停止』
     
872.         try { printl("⚠️  main() 顶层异常(已兜住): " + (eTop.message || eTop)); } catch (eL) {}
     
873.         // 尝试继续重连
     
874.         try { setTimeout(function () { try { connectWebSocket(); } catch (e) {} }, 5000); } catch (e) {}
     
875.     }
     
876. }
     
877. 
     
878. main();
     

复制代码