注册 登录
发贴工具
自动发帖软件»群发软件 › 群发软件公告教程 › AIWORK源码分享 › 实战使用桌面控制WebSocket
返回列表 发帖
查看: 6|回复: 0
打印 上一主题 下一主题

[24小时收录超级好的网站] 实战使用桌面控制WebSocket

[复制链接]

2605

主题

2653

帖子

1万

积分

积分
15806
跳转到指定楼层
楼主
发帖软件 发表于 3 小时前 | 只看该作者 |只看大图 回帖奖励 |正序浏览 |阅读模式
实战使用桌面控制WebSocket
实战使用桌面控制WebSocket 群发软件发帖工具

  1. /**
  2. * WebSocket 高级技巧合集 - AIWROK 版
  3. *
  4. *       ws-multi-pool 连接池 / JetSocket / Binary Transfer Protocol /
  5. *       Android WebSocket 实战 / 大文件分片上传）
  6. *
  7. * 包含 8 大特殊模式：
  8. *   1. ACK 确认 + 超时重传 —— 消息不丢（仿 TCP 可靠投递）
  9. *   2. 请求-响应配对 —— 发指令等回应（仿 HTTP 请求模式，带超时）
  10. *   3. 消息序列号 + 断线补偿 —— 重连后补发缺失消息
  11. *   4. 离线消息队列 —— 断线缓存，重连后自动 flush
  12. *   5. 分片传输大截图 —— 64KB 分块，避免大帧阻塞
  13. *   6. 自适应心跳 —— 弱网拉长心跳间隔，省电防断
  14. *   7. 背压控制 —— 发送速率限制，防止淹没对端
  15. *   8. 频道订阅模式 —— 动态订阅/取消订阅事件流
  16. *
  17. * AIWROK 原生 WebSocket API：
  18. *   setSocketID(String) / event(onopen,onmsg,onerr,onclose) / connet(String) / send(Object) / close()
  19. *   定时器：runTime.setTimeout(fn, ms) / runTime.stopTimeout(id)
  20. */

  22. // ============================================================
  23. //  配置
  24. // ============================================================
  25. var CONFIG = {
  26.     // WebSocket 服务器的局域网 IP 地址，需改为你 PC 的实际 IP
  27.     // 查看方式：Windows 下运行 ipconfig → 找 IPv4 地址（通常是 192.168.x.x）
  28.     // ⚠️ 手机和 PC 必须连接到同一个 WiFi 网段
  29.     SERVER_IP: "192.168.10.104",
  30.     // WebSocket 服务器监听的端口号，需与服务器端保持一致
  31.     // 本项目配套的 WebSocket测试服务器.py 默认使用 8886
  32.     SERVER_PORT: "8886",
  33.     // WebSocket 连接的 URL 路径（根路径为 "/"）
  34.     // 如果服务器在特定路径上提供服务（如 "/ws"、"/api/v1/socket"），修改此处
  35.     // 最终连接地址格式: ws://{SERVER_IP}:{SERVER_PORT}{WS_PATH}
  36.     WS_PATH: "/",

  38.     // 1. ACK 确认
  39.     ACK_TIMEOUT_MS: 5000,        // 等待 ACK 超时
  40.     ACK_MAX_RETRY: 3,            // 最多重传 3 次

  42.     // 2. 请求-响应配对
  43.     REQ_TIMEOUT_MS: 10000,       // 请求超时 10 秒

  45.     // 3. 序列号
  46.     RESEND_ON_RECONNECT: true,  // 重连后是否请求补发缺失消息

  48.     // 4. 离线队列
  49.     OFFLINE_QUEUE_MAX: 1000,     // 离线队列最大缓存条数（分片传输时需要较大缓冲）

  51.     // 5. 分片传输
  52.     CHUNK_SIZE: 65536,           // 64KB 每片（RFC 标准分片大小）
  53.     LARGE_IMG_THRESHOLD_KB: 100, // 超过 100KB 的截图走分片
  54.     CHUNK_RETAIN_LAST_MS: 60000, // 保留最近一次分片原始数据用于重传，默认 60 秒

  56.     // 6. 自适应心跳
  57.     HEARTBEAT_MIN_MS: 15000,     // 网络好时 15 秒
  58.     HEARTBEAT_MAX_MS: 60000,     // 网络差时 60 秒
  59.     HEARTBEAT_TIMEOUT_MS: 15000,
  60.     NETWORK_CHECK_INTERVAL_MS: 30000, // 每 30 秒评估一次网络质量

  62.     // 7. 背压
  63.     SEND_RATE_LIMIT_MS: 5,       // 两次发送之间最少间隔 5ms（≈200条/秒上限，分片不阻塞）
  64.     SEND_BURST_MAX: 50,          // 允许突发 50 条（一次 23 片不被背压限流）

  66.     // 8. 截图参数（降低大尺寸手机的带宽消耗）
  67.     SCREENSHOT_JPEG_QUALITY: 80, // 0-100，越高质量越好体积越大
  68.     SCREENSHOT_MAX_WIDTH: 0,     // 最大宽度（像素），0=不缩放；建议低端机或省流量设 1080

  70.     // 9. 频道订阅
  71.     AUTO_SUBSCRIBE_CHANNELS: ["system", "cmd", "screenshot"],

  73.     // 通用
  74.     MAX_RETRY: 999,
  75.     RETRY_BASE_MS: 2000,
  76.     RETRY_MAX_MS: 30000,
  77.     DEBUG_LOG: true,             // 本脚本为演示，默认开日志
  78.     SHOW_LOG_WINDOW: false,

  80.     // ============================================================
  81.     //  降级模式（默认开启，避免 AIWROK 环境 ACK 强制 + 心跳过严导致的混乱）
  82.     //    RELAXED_MODE = true  → 所有消息默认 no_ack、ACK 重传不报错、心跳超时只警告不主动断
  83.     //    RELAXED_MODE = false → 完全启用 TCP 式可靠投递（需要服务器完全严格匹配协议）
  84.     // ============================================================
  85.     RELAXED_MODE: true,
  86.     RELAXED_ACK_REQUIRED: false,   // false = 不强制要求 ACK，超时直接丢弃，不打印 ERROR
  87.     RELAXED_HEARTBEAT_SOFT_FAIL: true  // true = 心跳超时仅降级网络质量，不主动 close
  88. };

  90. // ============================================================
  91. //  日志
  92. // ============================================================
  93. function LOG(tag, msg) {
  94.     if (!CONFIG.DEBUG_LOG && (tag === "DEBUG" || tag === "RECV" || tag === "SEND")) return;
  95.     try { printl("[" + tag + "] " + msg); } catch (e) {}
  96. }

  98. if (CONFIG.SHOW_LOG_WINDOW) {
  99.     try { logWindow.show(); } catch (e) {}
  100.     try { logWindow.setNoClickModel(); } catch (e) {}
  101. }

  103. // ============================================================
  104. //  全局状态
  105. // ============================================================
  106. var G = {
  107.     ws: null,
  108.     socketID: "phone_" + new Date().getTime(),
  109.     connected: false,
  110.     retryCount: 0,
  111.     running: true,
  112.     seq: 0,               // 发送序列号
  113.     lastReceivedSeq: 0,   // 收到服务端消息的最后序列号

  115.     // 1. ACK 确认
  116.     pendingAcks: {},       // seq -> { msg, retryCount, timerId, sentAt }

  118.     // 2. 请求-响应配对
  119.     pendingRequests: {},  // reqId -> { resolve, reject, timerId }

  121.     // 4. 离线队列
  122.     offlineQueue: [],

  124.     // 5. 分片传输
  125.     chunkTransfers: {},    // transferId -> { chunks:[], totalChunks, received, ts }
  126.     lastSentChunks: {},    // transferId -> { b64, chunkSize, width, height, ts } （发送端保留，用于 CHUNK_RESEND 重传）

  128.     // 6. 自适应心跳
  129.     heartbeatTimer: null,
  130.     currentHeartbeatMs: 25000,
  131.     networkQuality: "good", // good / fair / poor
  132.     lastPongAt: 0,
  133.     pingRtt: 0,

  135.     // 7. 背压
  136.     lastSendAt: 0,
  137.     sendBurstCount: 0,

  139.     // 8. 频道订阅
  140.     subscribedChannels: {}
  141. };

  143. // ============================================================
  144. //  消息构建 & 发送（含背压控制）
  145. // ============================================================
  146. function buildMsg(type, data, opts) {
  147.     G.seq++;
  148.     var msg = {
  149.         type: type,
  150.         seq: G.seq,
  151.         ts: new Date().getTime(),
  152.         device: { brand: "", model: "" },
  153.         data: data || {}
  154.     };
  155.     try { msg.device.brand = device.getBrand(); } catch (e) {}
  156.     try { msg.device.model = device.getModel(); } catch (e) {}
  157.     if (opts) {
  158.         if (opts.req_id) msg.req_id = opts.req_id;
  159.         if (opts.ack_for) msg.ack_for = opts.ack_for;
  160.         if (opts.channel) msg.channel = opts.channel;
  161.         if (opts.no_ack) msg.no_ack = true;  // 标记不需要 ACK
  162.     }
  163.     return msg;
  164. }

  166. /**
  167. * 发送消息（模式 7：背压控制）
  168. * 两次发送之间至少间隔 SEND_RATE_LIMIT_MS，但允许突发 SEND_BURST_MAX 条
  169. */
  170. function sendMsg(type, data, opts) {
  171.     // 降级模式：默认所有消息都无需 ACK，除非显式要求
  172.     if (CONFIG.RELAXED_MODE && !opts) opts = {};
  173.     if (CONFIG.RELAXED_MODE && opts && !opts.__force_ack) {
  174.         if (type !== "REGISTER" && type !== "SUBSCRIBE" && type !== "UNSUBSCRIBE") {
  175.             opts.no_ack = true;
  176.         }
  177.         // 对于 SUBSCRIBE / REGISTER：降级模式下也走 no_ack，减少混乱
  178.         if (!CONFIG.RELAXED_ACK_REQUIRED) {
  179.             opts.no_ack = true;
  180.         }
  181.     }

  183.     if (!G.ws || !G.connected) {
  184.         // 模式 4：离线队列 —— 断线时缓存
  185.         enqueueOffline(type, data, opts);
  186.         return -1;
  187.     }

  189.     // 分片消息（CHUNK_START/CHUNK_DATA/CHUNK_END）与 RESPONSE/STATUS：绕过背压
  190.     //   避免截图分片被限流后入队导致丢片
  191.     var bypassBackpressure = (
  192.         type === "CHUNK_START" || type === "CHUNK_DATA" || type === "CHUNK_END" ||
  193.         type === "RESPONSE" || type === "STATUS" || type === "SCREENSHOT_DATA" ||
  194.         type === "SCREENSHOT_FAIL" || type === "ACK" || type === "PONG"
  195.     );
  196.     if (!bypassBackpressure) {
  197.         // 背压控制（仅对控制类消息生效）
  198.         var now = new Date().getTime();
  199.         var elapsed = now - G.lastSendAt;
  200.         if (G.sendBurstCount >= CONFIG.SEND_BURST_MAX && elapsed < CONFIG.SEND_RATE_LIMIT_MS) {
  201.             // 超过突发上限且间隔不够 → 入队等待
  202.             LOG("WARN", "背压限制，消息入队等待 type=" + type);
  203.             enqueueOffline(type, data, opts);
  204.             return -1;
  205.         }
  206.         if (elapsed >= CONFIG.SEND_RATE_LIMIT_MS) {
  207.             G.sendBurstCount = 0; // 间隔够了，重置突发计数
  208.         }
  209.         G.sendBurstCount++;
  210.         G.lastSendAt = now;
  211.     }

  213.     var msg = buildMsg(type, data, opts);
  214.     var raw = JSON.stringify(msg);

  216.     try {
  217.         G.ws.send(raw);
  218.         LOG("SEND", type + " seq=" + msg.seq);

  220.         // 模式 1：需要 ACK 的消息 → 启动超时重传
  221.         if (!opts || !opts.no_ack) {
  222.             startAckTimer(msg);
  223.         }
  224.         return msg.seq;
  225.     } catch (e) {
  226.         LOG("ERROR", "send异常: " + e.message);
  227.         enqueueOffline(type, data, opts);
  228.         return -1;
  229.     }
  230. }

  232. // ============================================================
  233. //  模式 1：ACK 确认 + 超时重传
  234. //
  235. //  发送消息后，等对端回 ACK(seq)。
  236. //  超时未收到 → 重传（最多 ACK_MAX_RETRY 次）。
  237. //  超过最大重传次数 → 通知上层失败。
  238. // ============================================================
  239. function startAckTimer(msg) {
  240.     var entry = {
  241.         raw: JSON.stringify(msg),
  242.         retryCount: 0,
  243.         sentAt: new Date().getTime(),
  244.         timerId: null
  245.     };
  246.     G.pendingAcks[msg.seq] = entry;

  248.     entry.timerId = runTime.setTimeout(function () {
  249.         onAckTimeout(msg.seq);
  250.     }, CONFIG.ACK_TIMEOUT_MS);
  251. }

  253. function onAckTimeout(seq) {
  254.     var entry = G.pendingAcks[seq];
  255.     if (!entry) return; // 已经收到 ACK 了

  257.     entry.retryCount++;
  258.     if (entry.retryCount > CONFIG.ACK_MAX_RETRY) {
  259.         if (CONFIG.RELAXED_MODE) {
  260.             LOG("DEBUG", "ACK 未确认 seq=" + seq + "（降级模式自动忽略）");
  261.         } else {
  262.             LOG("ERROR", "ACK 重传超限 seq=" + seq + " 放弃");
  263.         }
  264.         delete G.pendingAcks[seq];
  265.         // 通知上层（可选：触发回调）
  266.         return;
  267.     }

  269.     if (CONFIG.RELAXED_MODE) {
  270.         LOG("DEBUG", "ACK 等待 seq=" + seq + " 第 " + entry.retryCount + " 次（降级模式不重传，仅等待）");
  271.         // 降级模式：不重传，继续等一次，下一次超时就 discard
  272.         entry.timerId = runTime.setTimeout(function () {
  273.             LOG("DEBUG", "ACK 最终未返回 seq=" + seq + "（降级模式丢弃）");
  274.             delete G.pendingAcks[seq];
  275.         }, CONFIG.ACK_TIMEOUT_MS);
  276.         return;
  277.     }

  279.     LOG("WARN", "ACK 超时 seq=" + seq + " 第 " + entry.retryCount + " 次重传");
  280.     if (G.ws && G.connected) {
  281.         try { G.ws.send(entry.raw); } catch (e) {}
  282.         // 重新启动超时计时
  283.         entry.timerId = runTime.setTimeout(function () {
  284.             onAckTimeout(seq);
  285.         }, CONFIG.ACK_TIMEOUT_MS);
  286.     } else {
  287.         // 连接断了，放回离线队列
  288.         delete G.pendingAcks[seq];
  289.         // 离线队列会在重连后 flush
  290.     }
  291. }

  293. function handleAck(seq) {
  294.     var entry = G.pendingAcks[seq];
  295.     if (!entry) {
  296.         LOG("DEBUG", "收到重复 ACK seq=" + seq);
  297.         return;
  298.     }
  299.     if (entry.timerId) {
  300.         try { runTime.stopTimeout(entry.timerId); } catch (e) {}
  301.     }
  302.     var rtt = new Date().getTime() - entry.sentAt;
  303.     LOG("DEBUG", "ACK 确认 seq=" + seq + " RTT=" + rtt + "ms");
  304.     delete G.pendingAcks[seq];
  305. }

  307. // ============================================================
  308. //  模式 2：请求-响应配对（仿 HTTP 请求模式）
  309. //
  310. //  sendRequest("GET_STATUS", { detailed: true })
  311. //    → 等服务端回 { type: "RESPONSE", req_id: "xxx", data: {...} }
  312. //    → 超时则 reject
  313. //
  314. //  AIWROK 不支持 Promise，这里用回调方式：
  315. //    sendRequest(type, data, onOk, onTimeout)
  316. // ============================================================
  317. var _reqCounter = 0;

  319. function sendRequest(type, data, onOk, onTimeout) {
  320.     _reqCounter++;
  321.     var reqId = "req_" + new Date().getTime() + "_" + _reqCounter;
  322.     var entry = {
  323.         reqId: reqId,
  324.         onOk: onOk,
  325.         onTimeout: onTimeout,
  326.         timerId: null
  327.     };
  328.     G.pendingRequests[reqId] = entry;

  330.     // 超时计时
  331.     entry.timerId = runTime.setTimeout(function () {
  332.         if (G.pendingRequests[reqId]) {
  333.             delete G.pendingRequests[reqId];
  334.             LOG("WARN", "请求超时 type=" + type + " reqId=" + reqId);
  335.             if (onTimeout) onTimeout("timeout");
  336.         }
  337.     }, CONFIG.REQ_TIMEOUT_MS);

  339.     sendMsg(type, data, { req_id: reqId });
  340.     LOG("DEBUG", "请求发出 type=" + type + " reqId=" + reqId);
  341.     return reqId;
  342. }

  344. function handleResponse(resp) {
  345.     var reqId = resp.req_id;
  346.     var entry = G.pendingRequests[reqId];
  347.     if (!entry) {
  348.         LOG("DEBUG", "收到过期响应 reqId=" + reqId);
  349.         return;
  350.     }
  351.     if (entry.timerId) {
  352.         try { runTime.stopTimeout(entry.timerId); } catch (e) {}
  353.     }
  354.     delete G.pendingRequests[reqId];
  355.     if (entry.onOk) entry.onOk(resp.data || resp);
  356.     LOG("DEBUG", "响应收到 reqId=" + reqId);
  357. }

  359. // ============================================================
  360. //  模式 3：消息序列号 + 断线补偿
  361. //
  362. //  每条收到的消息都带 seq。
  363. //  重连后发送 RESYNC(lastSeq)，请求服务端补发 lastSeq 之后的消息。
  364. // ============================================================
  365. function handleIncomingSeq(seq) {
  366.     if (seq > 0) {
  367.         if (seq <= G.lastReceivedSeq) {
  368.             LOG("WARN", "重复消息 seq=" + seq + " (last=" + G.lastReceivedSeq + ")，丢弃");
  369.             return false; // 重复消息
  370.         }
  371.         if (G.lastReceivedSeq > 0 && seq > G.lastReceivedSeq + 1) {
  372.             var gap = seq - G.lastReceivedSeq - 1;
  373.             LOG("WARN", "消息间隙 seq=" + seq + " 缺少 " + gap + " 条");
  374.             // 可选：请求补发
  375.             // sendMsg("RESYNC", { from: G.lastReceivedSeq + 1, to: seq - 1 });
  376.         }
  377.         G.lastReceivedSeq = seq;
  378.     }
  379.     return true;
  380. }

  382. function requestResyncOnReconnect() {
  383.     if (!CONFIG.RESEND_ON_RECONNECT) return;
  384.     if (G.lastReceivedSeq > 0) {
  385.         LOG("INFO", "重连后请求补发 seq>" + G.lastReceivedSeq);
  386.         sendMsg("RESYNC", { last_seq: G.lastReceivedSeq });
  387.     }
  388. }

  390. // ============================================================
  391. //  模式 4：离线消息队列
  392. //
  393. //  断线时所有发送的消息缓存到队列。
  394. //  重连后自动 flush（先进先出）。
  395. // ============================================================
  396. function enqueueOffline(type, data, opts) {
  397.     if (G.offlineQueue.length >= CONFIG.OFFLINE_QUEUE_MAX) {
  398.         G.offlineQueue.shift(); // 丢最老的
  399.         LOG("WARN", "离线队列已满，丢弃最旧消息");
  400.     }
  401.     G.offlineQueue.push({ type: type, data: data, opts: opts });
  402.     LOG("DEBUG", "入离线队列 type=" + type + " 队列长度=" + G.offlineQueue.length);
  403. }

  405. function flushOfflineQueue() {
  406.     if (G.offlineQueue.length === 0) return;
  407.     LOG("INFO", "开始 flush 离线队列 " + G.offlineQueue.length + " 条");
  408.     var count = 0;
  409.     while (G.offlineQueue.length > 0 && G.connected) {
  410.         var item = G.offlineQueue.shift();
  411.         // 直接发送，不走 sendMsg 的离线判断
  412.         var msg = buildMsg(item.type, item.data, item.opts);
  413.         try {
  414.             G.ws.send(JSON.stringify(msg));
  415.             if (!item.opts || !item.opts.no_ack) startAckTimer(msg);
  416.             count++;
  417.         } catch (e) {
  418.             // 发送失败，放回队列头部
  419.             G.offlineQueue.unshift(item);
  420.             break;
  421.         }
  422.         // 背压：每条之间稍微停顿
  423.         // AIWROK 中 sleep.millisecond 会阻塞，这里用极短间隔
  424.     }
  425.     LOG("INFO", "flush 完成 " + count + " 条");
  426. }

  428. // ============================================================
  429. // ============================================================
  430. //  模式 5：分片传输大截图
  431. //
  432. //  超过 LARGE_IMG_THRESHOLD_KB 的截图，分 CHUNK_SIZE 大小的块发送。
  433. //  协议：
  434. //    1. send { type: "CHUNK_START", transfer_id, total_chunks, mime, width, height }
  435. //    2. send { type: "CHUNK_DATA", transfer_id, chunk_index, data_base64 }
  436. //    3. send { type: "CHUNK_END", transfer_id }
  437. //
  438. //  本函数对截图 API 做 4 级 fallback，失败时尽量给出原因而不是 #0
  439. // ============================================================
  440. function takeScreenshotRobust() {
  441.     /**
  442.      * AIWROK 正确截图 API：优先 screen.screenShot(w,h,quality) 可缩放+控质量
  443.      * 失败时回退 screen.screenShotFull() → .toBase64()
  444.      * 返回 { base64, size_kb, width, height }
  445.      * 失败时返回 null
  446.      */
  447.     try {
  448.         var errs = [];
  449.         // 读取配置
  450.         var maxW = parseInt(CONFIG.SCREENSHOT_MAX_WIDTH) || 0;
  451.         var quality = parseInt(CONFIG.SCREENSHOT_JPEG_QUALITY);
  452.         if (!quality || quality < 10 || quality > 100) quality = 80;

  454.         // 0) 检查截图权限
  455.         try {
  456.             if (typeof permissionManger !== "undefined" && permissionManger) {
  457.                 var hasPerm = permissionManger.checkScreenShotPremission();
  458.                 if (hasPerm === false) {
  459.                     LOG("ERROR", "截图权限未开启！请在 AIWROK 权限管理中开启「截图/投屏」权限");
  460.                     return null;
  461.                 }
  462.             }
  463.         } catch (ePerm) { errs.push("perm_check:" + ePerm.message); }

  465.         // 计算目标尺寸（等比缩放）
  466.         var realW = 0, realH = 0;
  467.         try { realW = screen.getScreenWidth(); } catch (ew) {}
  468.         try { realH = screen.getScreenHeight(); } catch (eh) {}
  469.         var targetW = realW, targetH = realH;
  470.         if (maxW > 0 && realW > 0 && realH > 0 && realW > maxW) {
  471.             targetW = maxW;
  472.             targetH = Math.floor(realH * (maxW / realW));
  473.         }

  475.         // 1) 优先 screen.screenShot(w, h, quality)：可同时控制分辨率和 JPEG 质量（减少带宽）
  476.         if (typeof screen !== "undefined" && screen && typeof screen.screenShot === "function") {
  477.             try {
  478.                 if (!targetW || !targetH) { targetW = realW || 1080; targetH = realH || 1920; }
  479.                 var imgA = screen.screenShot(targetW, targetH, quality);
  480.                 if (!imgA) throw new Error("screenShot 返回 null");
  481.                 var b64A = "";
  482.                 if (typeof imgA.toBase64 === "function") {
  483.                     b64A = "" + imgA.toBase64();
  484.                 } else if (typeof imgA.toBase64Jpg === "function") {
  485.                     b64A = "" + imgA.toBase64Jpg();
  486.                 } else {
  487.                     throw new Error("screenShot 返回对象无 toBase64 方法");
  488.                 }
  489.                 try { imgA.recycle(); } catch (er) {}
  490.                 if (!b64A || b64A.length < 10) throw new Error("Base64 为空 len=" + b64A.length);
  491.                 var sizeKBA = Math.floor((b64A.length * 0.75) / 1024);
  492.                 LOG("INFO", "截图 OK (screenShot scaled) size=" + sizeKBA + "KB " + targetW + "x" + targetH + " q=" + quality);
  493.                 return { base64: b64A, size_kb: sizeKBA, width: targetW, height: targetH };
  494.             } catch (eA) {
  495.                 errs.push("screenShot(" + targetW + "," + targetH + "," + quality + "):" + (eA.message || eA));
  496.             }
  497.         }

  499.         // 2) 回退 screen.screenShotFull()（AIWROK 主要截图 API）
  500.         if (typeof screen !== "undefined" && screen && typeof screen.screenShotFull === "function") {
  501.             try {
  502.                 var img = screen.screenShotFull();
  503.                 if (!img) throw new Error("screenShotFull 返回 null");

  505.                 var w = realW, h = realH;
  506.                 if (!w || !h) {
  507.                     try { w = img.getWidth(); } catch (ew2) {}
  508.                     try { h = img.getHeight(); } catch (eh2) {}
  509.                 }

  511.                 var b64 = "";
  512.                 if (typeof img.toBase64 === "function") {
  513.                     b64 = "" + img.toBase64();
  514.                 } else if (typeof img.toBase64Jpg === "function") {
  515.                     b64 = "" + img.toBase64Jpg();
  516.                 } else {
  517.                     throw new Error("截图对象没有 toBase64 方法");
  518.                 }

  520.                 try { img.recycle(); } catch (er) {}
  521.                 if (!b64 || b64.length < 10) throw new Error("Base64 为空或过短 len=" + (b64 ? b64.length : 0));

  523.                 var sizeKB = Math.floor((b64.length * 0.75) / 1024);
  524.                 LOG("INFO", "截图 OK size=" + sizeKB + "KB width=" + w + " height=" + h);
  525.                 return { base64: b64, size_kb: sizeKB, width: w, height: h };
  526.             } catch (e1) {
  527.                 errs.push("screenShotFull:" + (e1.message || e1));
  528.             }
  529.         } else {
  530.             errs.push("screenShotFull_not_found");
  531.         }

  533.         // 3) 最后兜底：尝试 image.* 系列
  534.         if (typeof image !== "undefined" && image) {
  535.             var tryList = ["fastCapture", "screenshot", "captureScreen", "capture"];
  536.             for (var ti = 0; ti < tryList.length; ti++) {
  537.                 var fnName = tryList[ti];
  538.                 try {
  539.                     if (typeof image[fnName] === "function") {
  540.                         var img3 = image[fnName]();
  541.                         if (img3) {
  542.                             var w3 = 0, h3 = 0;
  543.                             try { w3 = img3.getWidth(); } catch (ew3) {}
  544.                             try { h3 = img3.getHeight(); } catch (eh3) {}
  545.                             var b64_3 = "" + img3.toBase64();
  546.                             try { img3.recycle(); } catch (er) {}
  547.                             var sizeKB3 = Math.floor((b64_3.length * 0.75) / 1024);
  548.                             LOG("INFO", "截图 OK (image." + fnName + ") size=" + sizeKB3 + "KB");
  549.                             return { base64: b64_3, size_kb: sizeKB3, width: w3, height: h3 };
  550.                         }
  551.                     }
  552.                 } catch (e3) { errs.push(fnName + ":" + e3.message); }
  553.             }
  554.         }

  556.         LOG("ERROR", "所有截图 API 均失败: " + errs.join(" | "));
  557.         LOG("ERROR", "常见原因：(1) AIWROK 未开启「投屏/截图」权限；(2) 应用未启动前台服务；(3) Android 10+ 需要 MediaProjection 授权");
  558.         return null;
  559.     } catch (eOuter) {
  560.         try { LOG("ERROR", "截图最外层异常: " + (eOuter.message || String(eOuter))); } catch (eLog) {}
  561.         return null;
  562.     }
  563. }

  565. function sendScreenshotChunked(shotID) {
  566.     // ⚠️ 最外层 try-catch：防止 java/Android 底层异常直接变成【错误】#0
  567.     try {
  568.         var shot = takeScreenshotRobust();
  569.         if (!shot) {
  570.             // 把失败原因回传给控制面板（便于显示）
  571.             try { sendMsg("SCREENSHOT_FAIL", { id: shotID || "", reason: "capture_failed" }, { no_ack: true }); } catch (eSend) {}
  572.             return { ok: false, reason: "capture_failed", error_msg: "所有截图API均失败，请检查AIWROK投屏权限" };
  573.         }
  574.         var sizeKB = shot.size_kb;
  575.         var b64 = shot.base64;

  577.         if (sizeKB < CONFIG.LARGE_IMG_THRESHOLD_KB) {
  578.             // 小图直接发
  579.             sendMsg("SCREENSHOT", {
  580.                 id: shotID, format: "jpeg",
  581.                 width: shot.width, height: shot.height,
  582.                 size_kb: sizeKB, image_base64: b64
  583.             }, { no_ack: true });
  584.             return { ok: true, size_kb: sizeKB, width: shot.width, height: shot.height, chunked: false };
  585.         }

  587.         // 大图分片
  588.         var transferId = "tf_" + new Date().getTime();
  589.         var chunkSize = CONFIG.CHUNK_SIZE;
  590.         var totalChunks = Math.ceil(b64.length / chunkSize);

  592.         LOG("INFO", "分片传输 transferId=" + transferId + " 总片数=" + totalChunks + " size=" + sizeKB + "KB");

  594.         // 保留原始 Base64 和参数，用于 CHUNK_RESEND 重传
  595.         G.lastSentChunks[transferId] = {
  596.             b64: b64,
  597.             chunkSize: chunkSize,
  598.             width: shot.width,
  599.             height: shot.height,
  600.             sizeKB: sizeKB,
  601.             totalChunks: totalChunks,
  602.             ts: new Date().getTime()
  603.         };
  604.         // 清理过期记录，避免内存无限增长
  605.         var _keepMs = CONFIG.CHUNK_RETAIN_LAST_MS || 60000;
  606.         var _now = new Date().getTime();
  607.         var _keys = [];
  608.         for (var _k in G.lastSentChunks) if (G.lastSentChunks.hasOwnProperty(_k)) _keys.push(_k);
  609.         for (var _ki = 0; _ki < _keys.length; _ki++) {
  610.             if (_now - (G.lastSentChunks[_keys[_ki]].ts || 0) > _keepMs) delete G.lastSentChunks[_keys[_ki]];
  611.         }

  613.         sendMsg("CHUNK_START", {
  614.             transfer_id: transferId,
  615.             total_chunks: totalChunks,
  616.             mime: "jpeg",
  617.             width: shot.width,
  618.             height: shot.height,
  619.             size_kb: sizeKB
  620.         });

  622.         for (var i = 0; i < totalChunks; i++) {
  623.             var start = i * chunkSize;
  624.             var end = Math.min(start + chunkSize, b64.length);
  625.             var chunk = b64.substring(start, end);
  626.             sendMsg("CHUNK_DATA", {
  627.                 transfer_id: transferId,
  628.                 chunk_index: i,
  629.                 data_base64: chunk
  630.             });
  631.             // 分片之间 1ms 让步即可，不再 5 片睡 10ms（绕过背压后不需要额外节流）
  632.             if ((i + 1) % 20 === 0) {
  633.                 try { sleep.millisecond(1); } catch (e) {}
  634.             }
  635.         }

  637.         sendMsg("CHUNK_END", { transfer_id: transferId });
  638.         LOG("INFO", "分片传输完成 transferId=" + transferId);
  639.         return { ok: true, size_kb: sizeKB, width: shot.width, height: shot.height, chunked: true, transfer_id: transferId, total_chunks: totalChunks };
  640.     } catch (eOuter) {
  641.         try { LOG("ERROR", "sendScreenshotChunked 最外层异常: " + (eOuter.message || String(eOuter))); } catch (eLog) {}
  642.         try { sendMsg("SCREENSHOT_FAIL", { id: shotID || "", reason: "exception", error_msg: (eOuter.message || String(eOuter)) }, { no_ack: true }); } catch (eSend) {}
  643.         return { ok: false, reason: "exception", error_msg: (eOuter.message || String(eOuter)) };
  644.     }
  645. }

  647. // ============================================================
  648. //  辅助函数 Polyfill（AIWROK 环境全局函数缺失兜底）
  649. //  ⚠️ 关键策略：所有函数同时挂载到全局变量 + PhoneCtrl 对象
  650. //     即使变量名与 AIWROK 引擎保留名冲突导致赋值失败，
  651. //     PhoneCtrl 对象上的函数仍然可用，handleRemoteCommand 会优先使用
  652. // ============================================================
  653. var PhoneCtrl = PhoneCtrl || {};

  655. (function _polyfill_helpers() {
  656.     try {
  657.     function _has(obj, name) { return !!(obj && typeof obj[name] === "function"); }

  659.     // 尝试在全局作用域赋值（安全方式，使用全局对象属性）
  660.     function _tryAssignGlobal(name, fn) {
  661.         try {
  662.             var g = (typeof window !== "undefined") ? window :
  663.                     (typeof globalThis !== "undefined") ? globalThis :
  664.                     (typeof runtime !== "undefined") ? runtime : this;
  665.             g[name] = fn;
  666.             return true;
  667.         } catch (e) {
  668.             return false;
  669.         }
  670.     }

  672.     // 尝试在全局作用域读取（安全方式）
  673.     function _tryGetGlobal(name) {
  674.         try {
  675.             var g = (typeof window !== "undefined") ? window :
  676.                     (typeof globalThis !== "undefined") ? globalThis :
  677.                     (typeof runtime !== "undefined") ? runtime : this;
  678.             return g[name];
  679.         } catch (e) { return undefined; }
  680.     }

  682.     // 通用：auto API 直接调用兜底
  683.     var _autoClick = function (x, y) {
  684.         if (_has(auto, "clickPoint")) return auto.clickPoint(x, y);
  685.         if (_has(auto, "clickPercent")) {
  686.             var sw = screen.getScreenWidth(), sh = screen.getScreenHeight();
  687.             return auto.clickPercent(x / sw, y / sh);
  688.         }
  689.         throw new Error("no_click_api");
  690.     };
  691.     var _autoSwipe = function (x1, y1, x2, y2, dur) {
  692.         if (_has(auto, "swip")) return auto.swip(x1, y1, x2, y2, dur, 0);
  693.         throw new Error("no_swipe_api");
  694.     };
  695.     var _autoInput = function (text) {
  696.         if (_has(auto, "input")) return auto.input(text);
  697.         if (_has(auto, "sendText")) return auto.sendText(text);
  698.         if (_has(auto, "inputText")) return auto.inputText(text);
  699.         throw new Error("no_input_api");
  700.     };
  701.     var _autoPress = function (fnName) {
  702.         if (_has(auto, fnName)) return auto[fnName]();
  703.         throw new Error("auto." + fnName + "_not_found");
  704.     };
  705.     var _keyPress = function (keyName, keyCode) {
  706.         if (_has(device, keyName)) return device[keyName]();
  707.         if (_has(device, "pressKey")) return device.pressKey(keyCode);
  708.         if (_has(device, "press")) return device.press(keyCode);
  709.         try {
  710.             var KeyEvent = android.view.KeyEvent;
  711.             if (_has(runtime, "postEvent")) return runtime.postEvent(KeyEvent.ACTION_DOWN, keyCode);
  712.         } catch (e) {}
  713.         throw new Error("no_" + keyName + "_api");
  714.     };

  716.     // click
  717.     PhoneCtrl.click = function (x, y) {
  718.         x = parseInt(x || 0); y = parseInt(y || 0);
  719.         try { return _autoClick(x, y); } catch (e1) {}
  720.         try { if (_has(gesture, "click")) return gesture.click(x, y); } catch (e2) {}
  721.         try { if (_has(device, "click")) return device.click(x, y); } catch (e3) {}
  722.         throw new Error("click_failed");
  723.     };
  724.     _tryAssignGlobal("click", PhoneCtrl.click);

  726.     // swipe
  727.     PhoneCtrl.swipe = function (x1, y1, x2, y2, duration) {
  728.         x1 = parseInt(x1 || 0); y1 = parseInt(y1 || 0);
  729.         x2 = parseInt(x2 || 0); y2 = parseInt(y2 || 0);
  730.         duration = parseInt(duration || 400);
  731.         try { return _autoSwipe(x1, y1, x2, y2, duration); } catch (e1) {}
  732.         try {
  733.             if (_has(auto, "dispatchGesture")) {
  734.                 gesture.setDurTime(duration);
  735.                 gesture.addPoint(x1, y1);
  736.                 gesture.addPoint(x2, y2);
  737.                 return auto.dispatchGesture([gesture]);
  738.             }
  739.         } catch (e2) {}
  740.         try { if (_has(gesture, "swipe")) return gesture.swipe(x1, y1, x2, y2, duration); } catch (e3) {}
  741.         try { if (_has(device, "swipe")) return device.swipe(x1, y1, x2, y2, duration); } catch (e4) {}
  742.         throw new Error("swipe_failed");
  743.     };
  744.     _tryAssignGlobal("swipe", PhoneCtrl.swipe);

  746.     // input
  747.     PhoneCtrl.input = function (text) {
  748.         text = String(text == null ? "" : text);
  749.         try { return _autoInput(text); } catch (e1) {}
  750.         try { if (_has(device, "input")) return device.input(text); } catch (e2) {}
  751.         throw new Error("input_failed");
  752.     };
  753.     _tryAssignGlobal("input", PhoneCtrl.input);

  755.     // home / back / menu / power / search / camera
  756.     PhoneCtrl.home = function () {
  757.         try { return _autoPress("home"); } catch (e) {}
  758.         return _keyPress("home", 3);
  759.     };
  760.     PhoneCtrl.back = function () {
  761.         try { return _autoPress("back"); } catch (e) {}
  762.         return _keyPress("back", 4);
  763.     };
  764.     PhoneCtrl.menu = function () {
  765.         try { return _autoPress("menu"); } catch (e) {}
  766.         return _keyPress("menu", 82);
  767.     };
  768.     PhoneCtrl.power = function () {
  769.         try { return _autoPress("power"); } catch (e) {}
  770.         return _keyPress("power", 26);
  771.     };
  772.     PhoneCtrl.search = function () {
  773.         try { return _autoPress("search"); } catch (e) {}
  774.         return _keyPress("search", 84);
  775.     };
  776.     PhoneCtrl.camera = function () {
  777.         try { return _autoPress("camera"); } catch (e) {}
  778.         return _keyPress("camera", 27);
  779.     };

  781.     // recentApps
  782.     PhoneCtrl.recentApps = function () {
  783.         try { return _autoPress("recents"); } catch (e1) {}
  784.         try { return _autoPress("recentApps"); } catch (e2) {}
  785.         try {
  786.             var sw = screen.getScreenWidth(), sh = screen.getScreenHeight();
  787.             return PhoneCtrl.swipe(Math.floor(sw/2), sh - 20, Math.floor(sw/2), Math.floor(sh/2), 300);
  788.         } catch (e3) {}
  789.         return _keyPress("recentApps", 187);
  790.     };

  792.     // expandNotificationBar
  793.     PhoneCtrl.expandNotificationBar = function () {
  794.         try { return _autoPress("statusBar"); } catch (e1) {}
  795.         try { return _autoPress("notification"); } catch (e2) {}
  796.         try {
  797.             var sw = screen.getScreenWidth();
  798.             return PhoneCtrl.swipe(Math.floor(sw/2), 10, Math.floor(sw/2), 400, 300);
  799.         } catch (e3) { throw new Error("no_noti_api"); }
  800.     };

  802.     // openApp
  803.     PhoneCtrl.openApp = function (pkg) {
  804.         pkg = String(pkg || "");
  805.         try {
  806.             if (typeof app !== "undefined" && app) {
  807.                 if (_has(app, "openApp")) return app.openApp(pkg);
  808.                 if (_has(app, "openAppv2")) return app.openAppv2(pkg);
  809.                 if (_has(app, "openAppSeting")) return app.openAppSeting(pkg);
  810.                 if (_has(app, "launch")) return app.launch(pkg);
  811.                 if (_has(app, "open")) return app.open(pkg);
  812.             }
  813.         } catch (e1) {}
  814.         try {
  815.             if (typeof device !== "undefined" && device) {
  816.                 if (_has(device, "startApp")) return device.startApp(pkg);
  817.                 if (_has(device, "launchApp")) return device.launchApp(pkg);
  818.                 if (_has(device, "openApp")) return device.openApp(pkg);
  819.             }
  820.         } catch (e2) {}
  821.         try {
  822.             var ctxt = context || runtime.getContext();
  823.             var Intent = android.content.Intent;
  824.             var pm = ctxt.getPackageManager();
  825.             var launchIntent = pm.getLaunchIntentForPackage(pkg);
  826.             if (launchIntent) {
  827.                 launchIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
  828.                 ctxt.startActivity(launchIntent);
  829.                 return true;
  830.             }
  831.             throw new Error("no_launch_intent");
  832.         } catch (e3) { throw new Error("openApp_fail: " + e3.message); }
  833.     };

  835.     // openAppName
  836.     PhoneCtrl.openAppName = function (name) {
  837.         name = String(name || "");
  838.         try {
  839.             if (typeof app !== "undefined" && app) {
  840.                 if (_has(app, "openApp")) return app.openApp(name);
  841.                 if (_has(app, "openAppv2")) return app.openAppv2(name);
  842.                 if (_has(app, "launchByName")) return app.launchByName(name);
  843.                 if (_has(app, "openByName")) return app.openByName(name);
  844.             }
  845.         } catch (e1) {}
  846.         try {
  847.             if (typeof device !== "undefined" && device) {
  848.                 if (_has(device, "openAppByName")) return device.openAppByName(name);
  849.                 if (_has(device, "launchByName")) return device.launchByName(name);
  850.             }
  851.         } catch (e2) {}
  852.         try {
  853.             var ctxt = context || runtime.getContext();
  854.             var pm = ctxt.getPackageManager();
  855.             var apps = pm.getInstalledApplications(0);
  856.             var target = name.toLowerCase();
  857.             var iter = apps.iterator();
  858.             while (iter.hasNext()) {
  859.                 var ai = iter.next();
  860.                 var label = String(pm.getApplicationLabel(ai) || "").toLowerCase();
  861.                 var pkg = String(ai.packageName || "").toLowerCase();
  862.                 if (label === target || pkg === target || label.indexOf(target) !== -1 || pkg.indexOf(target) !== -1) {
  863.                     return PhoneCtrl.openApp(ai.packageName);
  864.                 }
  865.             }
  866.             throw new Error("pkg_not_found_for_name_" + name);
  867.         } catch (e3) { throw new Error("openAppName_fail: " + e3.message); }
  868.     };

  870.     // killApp
  871.     PhoneCtrl.killApp = function (pkg) {
  872.         pkg = String(pkg || "");
  873.         try {
  874.             if (typeof app !== "undefined" && app) {
  875.                 if (_has(app, "forceStop")) return app.forceStop(pkg);
  876.                 if (_has(app, "kill")) return app.kill(pkg);
  877.                 if (_has(app, "close")) return app.close(pkg);
  878.             }
  879.         } catch (e1) {}
  880.         try {
  881.             if (typeof device !== "undefined" && device) {
  882.                 if (_has(device, "forceStopApp")) return device.forceStopApp(pkg);
  883.                 if (_has(device, "killApp")) return device.killApp(pkg);
  884.                 if (_has(device, "killBackgroundProcesses")) return device.killBackgroundProcesses(pkg);
  885.             }
  886.         } catch (e2) {}
  887.         try {
  888.             var ctxt = context || runtime.getContext();
  889.             var actMan = ctxt.getSystemService(android.content.Context.ACTIVITY_SERVICE);
  890.             actMan.killBackgroundProcesses(pkg);
  891.             return true;
  892.         } catch (e3) { throw new Error("killApp_fail: " + e3.message); }
  893.     };

  895.     // 全局变量赋值（尽力而为，失败不影响 PhoneCtrl 上的函数）
  896.     _tryAssignGlobal("home", PhoneCtrl.home);
  897.     _tryAssignGlobal("back", PhoneCtrl.back);
  898.     _tryAssignGlobal("menu", PhoneCtrl.menu);
  899.     _tryAssignGlobal("power", PhoneCtrl.power);
  900.     _tryAssignGlobal("search", PhoneCtrl.search);
  901.     _tryAssignGlobal("camera", PhoneCtrl.camera);
  902.     _tryAssignGlobal("recentApps", PhoneCtrl.recentApps);
  903.     _tryAssignGlobal("expandNotificationBar", PhoneCtrl.expandNotificationBar);
  904.     _tryAssignGlobal("openApp", PhoneCtrl.openApp);
  905.     _tryAssignGlobal("openAppName", PhoneCtrl.openAppName);
  906.     _tryAssignGlobal("killApp", PhoneCtrl.killApp);

  908.     LOG("INFO", "Polyfill 初始化完成 PhoneCtrl.click/swipe/input/home/back 等已就绪");
  909.     } catch (ePolyOuter) {
  910.         try { LOG("WARN", "polyfill 异常: " + (ePolyOuter.message || String(ePolyOuter))); } catch (eLog) {}
  911.     }
  912. })();

  914. /**
  915. * 接收端：组装分片（如果手机也需要接收大文件的话）
  916. */
  917. function handleChunkStart(data) {
  918.     G.chunkTransfers[data.transfer_id] = {
  919.         chunks: {},
  920.         totalChunks: data.total_chunks,
  921.         received: 0,
  922.         meta: data
  923.     };
  924.     LOG("DEBUG", "分片接收开始 transferId=" + data.transfer_id + " 总片数=" + data.totalChunks);
  925. }

  927. function handleChunkData(data) {
  928.     var transfer = G.chunkTransfers[data.transfer_id];
  929.     if (!transfer) {
  930.         LOG("WARN", "未知分片传输 transferId=" + data.transfer_id);
  931.         return;
  932.     }
  933.     transfer.chunks[data.chunk_index] = data.data_base64;
  934.     transfer.received++;

  936.     // 进度
  937.     var pct = Math.floor(transfer.received / transfer.totalChunks * 100);
  938.     if (transfer.received % 10 === 0 || transfer.received === transfer.totalChunks) {
  939.         LOG("DEBUG", "分片接收进度 " + pct + "% (" + transfer.received + "/" + transfer.totalChunks + ")");
  940.     }
  941. }

  943. function handleChunkEnd(data) {
  944.     var transfer = G.chunkTransfers[data.transfer_id];
  945.     if (!transfer) return;

  947.     if (transfer.received < transfer.totalChunks) {
  948.         LOG("WARN", "分片不完整 " + transfer.received + "/" + transfer.totalChunks);
  949.         // 可请求重传缺失的片
  950.         var missing = [];
  951.         for (var i = 0; i < transfer.totalChunks; i++) {
  952.             if (!transfer.chunks[i]) missing.push(i);
  953.         }
  954.         sendMsg("CHUNK_RESEND", {
  955.             transfer_id: data.transfer_id,
  956.             missing_indices: missing
  957.         });
  958.         return;
  959.     }

  961.     // 组装
  962.     var fullB64 = "";
  963.     for (var i = 0; i < transfer.totalChunks; i++) {
  964.         fullB64 += transfer.chunks[i];
  965.     }
  966.     LOG("INFO", "分片组装完成 transferId=" + data.transfer_id + " 总大小=" + Math.floor(fullB64.length / 1024) + "KB");

  968.     // 这里可以解码 Base64 → Bitmap → 保存文件等
  969.     delete G.chunkTransfers[data.transfer_id];
  970. }

  972. /**
  973. * 处理对端发来的 CHUNK_RESEND（缺失分片重传请求）
  974. * 从 G.lastSentChunks 中取出该 transferId 的原始 b64，按索引重新发送对应片
  975. */
  976. function handleChunkResend(data) {
  977.     var transferId = data.transfer_id;
  978.     var missing = data.missing_indices || [];
  979.     var cached = G.lastSentChunks[transferId];
  980.     if (!cached) {
  981.         LOG("WARN", "收到 CHUNK_RESEND 但本地已无缓存 transferId=" + transferId);
  982.         return;
  983.     }
  984.     LOG("INFO", "收到 CHUNK_RESEND transferId=" + transferId + " 缺失片数=" + missing.length);
  985.     var b64 = cached.b64;
  986.     var chunkSize = cached.chunkSize;
  987.     var reSentCount = 0;
  988.     for (var mi = 0; mi < missing.length; mi++) {
  989.         var idx = parseInt(missing[mi]);
  990.         if (isNaN(idx) || idx < 0) continue;
  991.         var start = idx * chunkSize;
  992.         if (start >= b64.length) continue;
  993.         var end = Math.min(start + chunkSize, b64.length);
  994.         var chunk = b64.substring(start, end);
  995.         sendMsg("CHUNK_DATA", {
  996.             transfer_id: transferId,
  997.             chunk_index: idx,
  998.             data_base64: chunk
  999.         });
  1000.         reSentCount++;
  1001.         // 每 20 片让 1ms
  1002.         if (reSentCount % 20 === 0) { try { sleep.millisecond(1); } catch (e) {} }
  1003.     }
  1004.     LOG("INFO", "CHUNK_RESEND 已重传 " + reSentCount + " 片 transferId=" + transferId);
  1005. }

  1007. // ============================================================
  1008. //  模式 6：自适应心跳
  1009. //
  1010. //  根据网络质量动态调整心跳间隔：
  1011. //    good → 15s   fair → 30s   poor → 60s
  1012. //  网络质量评估依据：PING RTT + 最近是否断线频繁
  1013. // ============================================================
  1014. function assessNetworkQuality() {
  1015.     var rtt = G.pingRtt || 0;
  1016.     var oldQ = G.networkQuality;

  1018.     if (rtt === 0 || rtt < 100) {
  1019.         G.networkQuality = "good";
  1020.         G.currentHeartbeatMs = CONFIG.HEARTBEAT_MIN_MS;
  1021.     } else if (rtt < 500) {
  1022.         G.networkQuality = "fair";
  1023.         G.currentHeartbeatMs = Math.floor((CONFIG.HEARTBEAT_MIN_MS + CONFIG.HEARTBEAT_MAX_MS) / 2);
  1024.     } else {
  1025.         G.networkQuality = "poor";
  1026.         G.currentHeartbeatMs = CONFIG.HEARTBEAT_MAX_MS;
  1027.     }

  1029.     if (oldQ !== G.networkQuality) {
  1030.         LOG("INFO", "网络质量变化 " + oldQ + " → " + G.networkQuality + " (RTT=" + rtt + "ms) 心跳=" + (G.currentHeartbeatMs / 1000) + "s");
  1031.         // 重启心跳
  1032.         startHeartbeat();
  1033.     }
  1034. }

  1036. function startHeartbeat() {
  1037.     stopHeartbeat();
  1038.     G.lastPongAt = new Date().getTime();

  1040.     function tick() {
  1041.         if (!G.connected) return;

  1043.         var now = new Date().getTime();
  1044.         var timeoutThresh = G.currentHeartbeatMs + CONFIG.HEARTBEAT_TIMEOUT_MS;
  1045.         var sincePong = now - G.lastPongAt;
  1046.         if (sincePong > timeoutThresh) {
  1047.             if (CONFIG.RELAXED_MODE && CONFIG.RELAXED_HEARTBEAT_SOFT_FAIL) {
  1048.                 // 降级模式：不主动断开，只降级网络质量 + 发警告
  1049.                 if (G.networkQuality === "good") { G.networkQuality = "fair"; G.currentHeartbeatMs = Math.floor((CONFIG.HEARTBEAT_MIN_MS + CONFIG.HEARTBEAT_MAX_MS) / 2); }
  1050.                 else if (G.networkQuality === "fair") { G.networkQuality = "poor"; G.currentHeartbeatMs = CONFIG.HEARTBEAT_MAX_MS; }
  1051.                 LOG("WARN", "心跳未收到 PONG 已 " + (sincePong / 1000).toFixed(0) + "s，降级网络质量为 " + G.networkQuality + "（降级模式不断线）");
  1052.                 G.lastPongAt = now; // 重置计时，避免反复告警风暴
  1053.             } else {
  1054.                 LOG("WARN", "心跳超时 主动断开");
  1055.                 try { G.ws.close(); } catch (e) {}
  1056.                 return;
  1057.             }
  1058.         }

  1060.         var pingTs = new Date().getTime();
  1061.         sendMsg("PING", { t: pingTs }, { no_ack: true });

  1063.         // 下一次延迟 = 当前自适应心跳间隔
  1064.         G.heartbeatTimer = runTime.setTimeout(tick, G.currentHeartbeatMs);
  1065.     }

  1067.     // 注意：AIWROK 中 onopen 回调执行顺序可能延迟，这里也设置 lastPongAt
  1068.     G.lastPongAt = new Date().getTime();
  1069.     G.heartbeatTimer = runTime.setTimeout(tick, G.currentHeartbeatMs);
  1070.     LOG("DEBUG", "心跳已启动 间隔=" + (G.currentHeartbeatMs / 1000) + "s 质量=" + G.networkQuality + (CONFIG.RELAXED_MODE ? " 降级模式=开" : ""));
  1071. }

  1073. function stopHeartbeat() {
  1074.     if (G.heartbeatTimer) {
  1075.         try { runTime.stopTimeout(G.heartbeatTimer); } catch (e) {}
  1076.         G.heartbeatTimer = null;
  1077.     }
  1078. }

  1080. // 定时评估网络质量
  1081. var networkCheckTimer = null;
  1082. function startNetworkCheck() {
  1083.     stopNetworkCheck();
  1084.     networkCheckTimer = runTime.setTimeout(function check() {
  1085.         assessNetworkQuality();
  1086.         // 每 30 秒同步一次最新设备状态给控制面板（电量/存储/网络等实时更新）
  1087.         if (G.connected) {
  1088.             try {
  1089.                 var s = collectStatusFull();
  1090.                 if (s) sendMsg("STATUS", s, { no_ack: true });
  1091.             } catch (eStatus) {
  1092.                 try { LOG("DEBUG", "周期状态上报失败: " + eStatus.message); } catch (eLog) {}
  1093.             }
  1094.         }
  1095.         networkCheckTimer = runTime.setTimeout(check, CONFIG.NETWORK_CHECK_INTERVAL_MS);
  1096.     }, CONFIG.NETWORK_CHECK_INTERVAL_MS);
  1097. }

  1099. function stopNetworkCheck() {
  1100.     if (networkCheckTimer) {
  1101.         try { runTime.stopTimeout(networkCheckTimer); } catch (e) {}
  1102.         networkCheckTimer = null;
  1103.     }
  1104. }

  1106. // ============================================================
  1107. //  模式 7：背压控制
  1108. //  已在 sendMsg() 中实现，核心逻辑：
  1109. //    - 两次发送至少间隔 SEND_RATE_LIMIT_MS
  1110. //    - 允许突发 SEND_BURST_MAX 条
  1111. //    - 超限则入离线队列等待
  1112. // ============================================================

  1114. // ============================================================
  1115. //  模式 8：频道订阅模式
  1116. //
  1117. //  客户端可以动态订阅/取消订阅事件频道。
  1118. //  服务端只推送已订阅频道的消息。
  1119. //
  1120. //  subscribe("cmd")     → 服务端开始推送 cmd 频道消息
  1121. //  unsubscribe("cmd")   → 服务端停止推送
  1122. // ============================================================
  1123. function subscribe(channel) {
  1124.     G.subscribedChannels[channel] = true;
  1125.     sendMsg("SUBSCRIBE", { channel: channel });
  1126.     LOG("INFO", "订阅频道 " + channel);
  1127. }

  1129. function unsubscribe(channel) {
  1130.     delete G.subscribedChannels[channel];
  1131.     sendMsg("UNSUBSCRIBE", { channel: channel });
  1132.     LOG("INFO", "取消订阅 " + channel);
  1133. }

  1135. function autoSubscribeChannels() {
  1136.     for (var i = 0; i < CONFIG.AUTO_SUBSCRIBE_CHANNELS.length; i++) {
  1137.         subscribe(CONFIG.AUTO_SUBSCRIBE_CHANNELS[i]);
  1138.     }
  1139. }

  1141. // ============================================================
  1142. //  服务器消息处理
  1143. // ============================================================
  1144. function handleServerMessage(raw) {
  1145.     // AIWROK 中回调参数可能是 bytes / java object / string，先统一转字符串
  1146.     if (raw === null || raw === undefined) return;
  1147.     if (typeof raw !== "string") {
  1148.         try {
  1149.             if (typeof raw === "object" && typeof raw.toString === "function") {
  1150.                 var s = raw.toString();
  1151.                 // Java 字节数组或其他对象
  1152.                 if (s && (s.indexOf("[B@") === 0 || s.indexOf("[object") === 0)) {
  1153.                     // 尝试通过其他方式解码
  1154.                     try { s = String(new java.lang.String(raw, "UTF-8")); } catch (e) {}
  1155.                 }
  1156.                 raw = s;
  1157.             } else {
  1158.                 raw = String(raw);
  1159.             }
  1160.         } catch (e) {
  1161.             LOG("DEBUG", "无法转换消息类型: " + (typeof raw));
  1162.             return;
  1163.         }
  1164.     }
  1165.     if (!raw || typeof raw !== "string") return;

  1167.     // 只要收到服务器任何有效消息，就刷新 lastPongAt（比等 PONG 更可靠）
  1168.     var nowTs = new Date().getTime();
  1169.     G.lastPongAt = nowTs;

  1171.     // 兼容旧版文本协议
  1172.     if (raw.indexOf("WELCOME|") === 0) {
  1173.         LOG("INFO", "服务器欢迎 " + raw.split("|")[1]);
  1174.         return;
  1175.     }
  1176.     if (raw === "PONG" || raw.indexOf("ECHO|") === 0) {
  1177.         return;
  1178.     }

  1180.     // JSON 协议
  1181.     var obj = null;
  1182.     try { obj = JSON.parse(raw); } catch (e) {
  1183.         LOG("DEBUG", "非JSON消息: " + raw.substring(0, 60));
  1184.         return;
  1185.     }
  1186.     if (!obj || typeof obj !== "object") return;

  1188.     // 模式 1：处理 ACK
  1189.     if (obj.type === "ACK" && obj.ack_for) {
  1190.         handleAck(obj.ack_for);
  1191.         return;
  1192.     }

  1194.     // 模式 2：处理响应
  1195.     if (obj.type === "RESPONSE" && obj.req_id) {
  1196.         handleResponse(obj);
  1197.         return;
  1198.     }

  1200.     // 模式 3：序列号检查
  1201.     if (obj.seq && !handleIncomingSeq(obj.seq)) {
  1202.         return; // 重复消息，丢弃
  1203.     }

  1205.     // 按类型分发（外层 try-catch 防止 #0 崩溃）
  1206.     try {
  1207.         switch (obj.type) {
  1208.             case "PONG":
  1209.                 var pingSentAt = (obj.data && obj.data.t) ? obj.data.t : (obj.ack_for ? obj.ack_for : nowTs);
  1210.                 G.pingRtt = (pingSentAt && pingSentAt < nowTs) ? (nowTs - pingSentAt) : 0;
  1211.                 LOG("DEBUG", "PONG RTT=" + G.pingRtt + "ms");
  1212.                 break;

  1214.             case "PING":
  1215.                 sendMsg("PONG", { echo_ts: obj.ts || 0, t: new Date().getTime() }, { no_ack: true });
  1216.                 break;

  1218.             case "CMD":
  1219.                 handleRemoteCommand(obj.cmd, obj.params, obj.req_id);
  1220.                 break;

  1222.             // 模式 5：分片接收
  1223.             case "CHUNK_START":
  1224.                 handleChunkStart(obj.data);
  1225.                 break;
  1226.             case "CHUNK_DATA":
  1227.                 handleChunkData(obj.data);
  1228.                 break;
  1229.             case "CHUNK_END":
  1230.                 handleChunkEnd(obj.data);
  1231.                 break;

  1233.             // 模式 5 补充：服务端/控制面板请求重传缺失分片
  1234.             case "CHUNK_RESEND":
  1235.                 handleChunkResend(obj.data || {});
  1236.                 break;

  1238.             // 频道消息
  1239.             case "CHANNEL":
  1240.                 LOG("INFO", "频道消息 ch=" + (obj.data.channel || "?") + " content=" + JSON.stringify(obj.data.payload || "").substring(0, 100));
  1241.                 break;

  1243.             case "RESYNC":
  1244.                 // 服务端补发的消息
  1245.                 LOG("INFO", "收到补发消息 seq=" + obj.seq);
  1246.                 break;

  1248.             case "RESPONSE":
  1249.                 // 服务器转发的其他客户端的响应（忽略，我们已在 handleResponse 处理）
  1250.                 LOG("DEBUG", "收到 RESPONSE req_id=" + (obj.req_id || "?"));
  1251.                 break;

  1253.             case "WELCOME":
  1254.                 LOG("INFO", "服务器欢迎 " + (obj.data ? obj.data.client_id : "?"));
  1255.                 break;

  1257.             default:
  1258.                 LOG("DEBUG", "未知消息 type=" + obj.type);
  1259.         }
  1260.     } catch (eSwitch) {
  1261.         LOG("WARN", "消息分发异常 type=" + obj.type + " err=" + (eSwitch.message || String(eSwitch)));
  1262.     }

  1264.     // 模式 1：收到消息后自动回 ACK（除非标记 no_ack）
  1265.     if (obj.seq && !obj.no_ack) {
  1266.         sendMsg("ACK", { ack_for: obj.seq }, { no_ack: true });
  1267.     }
  1268. }

  1270. // 远程指令（对齐 WebSocket手机端常用实例.js 的 9 类 CMD，使控制面板能直接操作手机）
  1271. function handleRemoteCommand(cmd, params, reqId) {
  1272.     params = params || {};
  1273.     LOG("CMD", cmd + " params=" + JSON.stringify(params).substring(0, 200));

  1275.     var result = { ok: true, data: null, error: "" };

  1277.     try {
  1278.         // 终极策略：直接使用 auto/device/app 对象的原生 API
  1279.         //   彻底绕开 click/swipe 等 AIWROK 引擎保留名冲突
  1280.         function _HAS(obj, name) { return !!(obj && typeof obj[name] === "function"); }

  1282.         // ===== 触控 =====
  1283.         function _doClick(x, y) {
  1284.             x = parseInt(x || 0); y = parseInt(y || 0);
  1285.             if (_HAS(auto, "clickPoint")) return auto.clickPoint(x, y);
  1286.             if (_HAS(auto, "clickPercent")) {
  1287.                 var sw = screen.getScreenWidth(), sh = screen.getScreenHeight();
  1288.                 return auto.clickPercent(x / sw, y / sh);
  1289.             }
  1290.             if (_HAS(gesture, "click")) return gesture.click(x, y);
  1291.             if (_HAS(device, "click")) return device.click(x, y);
  1292.             throw new Error("click_api_not_found");
  1293.         }
  1294.         function _doSwipe(x1, y1, x2, y2, d) {
  1295.             x1 = parseInt(x1 || 0); y1 = parseInt(y1 || 0);
  1296.             x2 = parseInt(x2 || 0); y2 = parseInt(y2 || 0);
  1297.             d = parseInt(d || 400);
  1298.             if (_HAS(auto, "swip")) return auto.swip(x1, y1, x2, y2, d, 0);
  1299.             if (_HAS(auto, "dispatchGesture") && _HAS(gesture, "setDurTime")) {
  1300.                 gesture.setDurTime(d);
  1301.                 gesture.addPoint(x1, y1);
  1302.                 gesture.addPoint(x2, y2);
  1303.                 return auto.dispatchGesture([gesture]);
  1304.             }
  1305.             if (_HAS(gesture, "swipe")) return gesture.swipe(x1, y1, x2, y2, d);
  1306.             if (_HAS(device, "swipe")) return device.swipe(x1, y1, x2, y2, d);
  1307.             throw new Error("swipe_api_not_found");
  1308.         }
  1309.         function _doInput(t) {
  1310.             t = String(t == null ? "" : t);
  1311.             if (_HAS(auto, "input")) return auto.input(t);
  1312.             if (_HAS(auto, "sendText")) return auto.sendText(t);
  1313.             if (_HAS(auto, "inputText")) return auto.inputText(t);
  1314.             if (_HAS(device, "input")) return device.input(t);
  1315.             throw new Error("input_api_not_found");
  1316.         }

  1318.         // ===== 按键 =====
  1319.         function _doKey(fnName, keyCode, keyName) {
  1320.             if (_HAS(auto, fnName)) return auto[fnName]();
  1321.             if (_HAS(device, keyName)) return device[keyName]();
  1322.             if (_HAS(device, "pressKey")) return device.pressKey(keyCode);
  1323.             if (_HAS(device, "press")) return device.press(keyCode);
  1324.             if (_HAS(runtime, "postEvent")) {
  1325.                 var KEv = android.view.KeyEvent;
  1326.                 return runtime.postEvent(KEv.ACTION_DOWN, keyCode);
  1327.             }
  1328.             throw new Error("key_" + fnName + "_not_found");
  1329.         }

  1331.         // ===== 应用管理 =====
  1332.         function _openAppDirect(pkg) {
  1333.             pkg = String(pkg || "");
  1334.             if (_HAS(app, "openApp")) return app.openApp(pkg);
  1335.             if (_HAS(app, "openAppv2")) return app.openAppv2(pkg);
  1336.             if (_HAS(app, "openAppSeting")) return app.openAppSeting(pkg);
  1337.             if (_HAS(app, "launch")) return app.launch(pkg);
  1338.             if (_HAS(app, "open")) return app.open(pkg);
  1339.             if (_HAS(device, "startApp")) return device.startApp(pkg);
  1340.             if (_HAS(device, "launchApp")) return device.launchApp(pkg);
  1341.             if (_HAS(device, "openApp")) return device.openApp(pkg);
  1342.             var ctxt = context || runtime.getContext();
  1343.             var Intent = android.content.Intent;
  1344.             var pm = ctxt.getPackageManager();
  1345.             var li = pm.getLaunchIntentForPackage(pkg);
  1346.             if (li) { li.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); ctxt.startActivity(li); return true; }
  1347.             throw new Error("openApp_intent_fail");
  1348.         }
  1349.         function _openByNameDirect(name) {
  1350.             name = String(name || "");
  1351.             if (_HAS(app, "openApp")) { try { return app.openApp(name); } catch (e1) {} }
  1352.             if (_HAS(app, "openAppv2")) { try { return app.openAppv2(name); } catch (e2) {} }
  1353.             if (_HAS(app, "launchByName")) { try { return app.launchByName(name); } catch (e3) {} }
  1354.             if (_HAS(app, "openByName")) { try { return app.openByName(name); } catch (e4) {} }
  1355.             if (_HAS(device, "openAppByName")) { try { return device.openAppByName(name); } catch (e5) {} }
  1356.             if (_HAS(device, "launchByName")) { try { return device.launchByName(name); } catch (e6) {} }
  1357.             // 模糊匹配
  1358.             var ctxt2 = context || runtime.getContext();
  1359.             var pm2 = ctxt2.getPackageManager();
  1360.             var apps = pm2.getInstalledApplications(0);
  1361.             var target = name.toLowerCase();
  1362.             var iter = apps.iterator();
  1363.             while (iter.hasNext()) {
  1364.                 var ai = iter.next();
  1365.                 var label = String(pm2.getApplicationLabel(ai) || "").toLowerCase();
  1366.                 var pkg = String(ai.packageName || "").toLowerCase();
  1367.                 if (label === target || pkg === target || label.indexOf(target) !== -1 || pkg.indexOf(target) !== -1) {
  1368.                     return _openAppDirect(ai.packageName);
  1369.                 }
  1370.             }
  1371.             throw new Error("app_name_not_found:" + name);
  1372.         }
  1373.         function _killAppDirect(pkg) {
  1374.             pkg = String(pkg || "");
  1375.             if (_HAS(app, "forceStop")) return app.forceStop(pkg);
  1376.             if (_HAS(app, "kill")) return app.kill(pkg);
  1377.             if (_HAS(app, "close")) return app.close(pkg);
  1378.             if (_HAS(device, "forceStopApp")) return device.forceStopApp(pkg);
  1379.             if (_HAS(device, "killApp")) return device.killApp(pkg);
  1380.             if (_HAS(device, "killBackgroundProcesses")) return device.killBackgroundProcesses(pkg);
  1381.             var ctxt3 = context || runtime.getContext();
  1382.             var am = ctxt3.getSystemService(android.content.Context.ACTIVITY_SERVICE);
  1383.             am.killBackgroundProcesses(pkg);
  1384.             return true;
  1385.         }

  1387.         switch (cmd) {
  1388.             case "SCREENSHOT":
  1389.                 var shotRes = sendScreenshotChunked(params.id || ("shot_" + new Date().getTime()));
  1390.                 if (shotRes && shotRes.ok) {
  1391.                     result.data = shotRes;
  1392.                 } else {
  1393.                     result.ok = false;
  1394.                     result.error = (shotRes && shotRes.error_msg) ? shotRes.error_msg : "screenshot_failed";
  1395.                     result.data = shotRes || {};
  1396.                 }
  1397.                 break;

  1399.             case "CLICK":
  1400.                 if (params.x != null && params.y != null) {
  1401.                     var cx = parseInt(params.x);
  1402.                     var cy = parseInt(params.y);
  1403.                     try { _doClick(cx, cy); result.data = { x: cx, y: cy }; }
  1404.                     catch (e) { result.ok = false; result.error = e.message; }
  1405.                 } else {
  1406.                     result.ok = false; result.error = "missing_xy";
  1407.                 }
  1408.                 break;

  1410.             case "SWIPE":
  1411.                 if (params.x1 != null && params.y1 != null && params.x2 != null && params.y2 != null) {
  1412.                     var x1 = parseInt(params.x1); var y1 = parseInt(params.y1);
  1413.                     var x2 = parseInt(params.x2); var y2 = parseInt(params.y2);
  1414.                     var dur = parseInt(params.duration_ms || 400);
  1415.                     try { _doSwipe(x1, y1, x2, y2, dur); result.data = { x1: x1, y1: y1, x2: x2, y2: y2, duration_ms: dur }; }
  1416.                     catch (e) { result.ok = false; result.error = e.message; }
  1417.                 } else {
  1418.                     result.ok = false; result.error = "missing_points";
  1419.                 }
  1420.                 break;

  1422.             case "INPUT_TEXT":
  1423.                 if (params.text != null) {
  1424.                     var txt = String(params.text);
  1425.                     try { _doInput(txt); result.data = { text: txt }; }
  1426.                     catch (e) { result.ok = false; result.error = e.message; }
  1427.                 } else {
  1428.                     result.ok = false; result.error = "missing_text";
  1429.                 }
  1430.                 break;

  1432.             case "KEYCODE":
  1433.                 if (params.code) {
  1434.                     var code = String(params.code).toUpperCase();
  1435.                     try {
  1436.                         switch (code) {
  1437.                             case "HOME":      _doKey("home", 3, "home"); break;
  1438.                             case "BACK":      _doKey("back", 4, "back"); break;
  1439.                             case "RECENT":
  1440.                             case "APP_SWITCH":
  1441.                             case "TASK":
  1442.                                 try { _doKey("recents", 187, "recentApps"); } catch (eA) { _doKey("recentApps", 187, "recentApps"); }
  1443.                                 break;
  1444.                             case "NOTIFICATION":
  1445.                             case "STATUS_BAR":
  1446.                                 try { _doKey("statusBar", 83, "statusBar"); } catch (eB) { _doKey("notification", 83, "notification"); }
  1447.                                 break;
  1448.                             case "POWER":     _doKey("power", 26, "power"); break;
  1449.                             case "VOL_UP":
  1450.                                 try { device.setMusicVolume(device.getMusicVolume() + 1); } catch (e) { throw new Error("vol_up_failed"); }
  1451.                                 break;
  1452.                             case "VOL_DOWN":
  1453.                                 try { device.setMusicVolume(Math.max(0, device.getMusicVolume() - 1)); } catch (e) { throw new Error("vol_down_failed"); }
  1454.                                 break;
  1455.                             case "MENU":      _doKey("menu", 82, "menu"); break;
  1456.                             case "SEARCH":    _doKey("search", 84, "search"); break;
  1457.                             case "CAMERA":    _doKey("camera", 27, "camera"); break;
  1458.                             case "ENTER":     try { _doInput("\n"); } catch (e) {} break;
  1459.                             case "DEL":
  1460.                             case "BACKSPACE":
  1461.                                 try { var et = device.getFocusEditText(); if (et) { et.setText(""); } } catch (e) { throw new Error("del_failed"); }
  1462.                                 break;
  1463.                             default:
  1464.                                 throw new Error("unknown_keycode_" + code);
  1465.                         }
  1466.                         result.data = { code: code };
  1467.                     } catch (e) {
  1468.                         result.ok = false; result.error = e.message;
  1469.                     }
  1470.                 } else {
  1471.                     result.ok = false; result.error = "missing_code";
  1472.                 }
  1473.                 break;

  1475.             case "OPEN_APP":
  1476.                 try {
  1477.                     if (params.pkg) {
  1478.                         _openAppDirect(String(params.pkg));
  1479.                         result.data = { opened: "pkg:" + params.pkg };
  1480.                     } else if (params.name) {
  1481.                         _openByNameDirect(String(params.name));
  1482.                         result.data = { opened: "name:" + params.name };
  1483.                     } else if (params.package_name) {
  1484.                         _openAppDirect(String(params.package_name));
  1485.                         result.data = { opened: "pkg:" + params.package_name };
  1486.                     } else {
  1487.                         result.ok = false; result.error = "missing_pkg_or_name";
  1488.                     }
  1489.                 } catch (e) {
  1490.                     result.ok = false; result.error = e.message;
  1491.                 }
  1492.                 break;

  1494.             case "KILL_APP":
  1495.                 try {
  1496.                     var pkg = params.pkg || params.package_name;
  1497.                     if (pkg) {
  1498.                         _killAppDirect(String(pkg));
  1499.                         result.data = { killed: pkg };
  1500.                     } else {
  1501.                         result.ok = false; result.error = "missing_pkg";
  1502.                     }
  1503.                 } catch (e) {
  1504.                     result.ok = false; result.error = e.message;
  1505.                 }
  1506.                 break;

  1508.             case "REPORT_STATUS":
  1509.             case "GET_STATUS":
  1510.                 result.data = collectStatusFull();
  1511.                 break;

  1513.             case "RUN_SCRIPT":
  1514.                 if (params.code != null) {
  1515.                     try {
  1516.                         var codeStr = String(params.code);
  1517.                         var r = (new Function(codeStr))();
  1518.                         result.data = { returned: (r === undefined ? null : (typeof r === "object" ? r : String(r))) };
  1519.                     } catch (e) {
  1520.                         result.ok = false; result.error = e.message;
  1521.                     }
  1522.                 } else {
  1523.                     result.ok = false; result.error = "missing_code";
  1524.                 }
  1525.                 break;

  1527.             case "SUBSCRIBE":
  1528.                 if (params.channel) subscribe(params.channel);
  1529.                 result.data = "subscribed";
  1530.                 break;

  1532.             case "UNSUBSCRIBE":
  1533.                 if (params.channel) unsubscribe(params.channel);
  1534.                 result.data = "unsubscribed";
  1535.                 break;

  1537.             case "ECHO":
  1538.                 result.data = params;
  1539.                 break;

  1541.             case "QUIT":
  1542.                 result.data = "bye";
  1543.                 sendMsg("RESPONSE", result, { req_id: reqId, no_ack: true });
  1544.                 G.running = false;
  1545.                 try { G.ws.close(); } catch (e) {}
  1546.                 return;

  1548.             default:
  1549.                 result.ok = false;
  1550.                 result.error = "unknown_cmd_" + cmd;
  1551.         }
  1552.     } catch (e) {
  1553.         result.ok = false;
  1554.         result.error = e.message;
  1555.     }

  1557.     // 以 RESPONSE 形式回复（模式 2：请求-响应配对）
  1558.     // ⚠️ 必须通过 opts.req_id 把 req_id 放到消息顶层，服务器 obj.get("req_id") 才能取到
  1559.     //    不要把 req_id 包在第二个参数 data 里，否则 buildMsg 会变成 msg.data.req_id
  1560.     if (reqId) {
  1561.         sendMsg("RESPONSE", result, { req_id: reqId, no_ack: true });
  1562.     }
  1563. }

  1565. function collectStatus() {
  1566.     // 兼容旧调用方：字段名全部对齐"新规范"，避免返回老名字 battery/charging
  1567.     var s = {
  1568.         battery_level: 0,
  1569.         battery_charging: false,
  1570.         network_type: "unknown",
  1571.         storage_free_mb: 0
  1572.     };
  1573.     try { s.battery_level = device.getBatteryLevel(); } catch (e) {}
  1574.     try { s.battery_charging = device.isCharging(); } catch (e) {}
  1575.     try { s.network_type = device.getNetworkType(); } catch (e) {}
  1576.     // 旧字段（保留防止老代码依赖）
  1577.     try { s.battery = s.battery_level; } catch (e) {}
  1578.     try { s.charging = s.battery_charging; } catch (e) {}
  1579.     try { s.network = s.network_type; } catch (e) {}
  1580.     return s;
  1581. }

  1583. // 完整的状态上报（所有情况下都保证字段名以"新规范"优先出现，不会有 null）
  1584. function collectStatusFull() {
  1585.     var s = {
  1586.         battery_level: 0,
  1587.         battery_charging: false,
  1588.         network_type: "unknown",
  1589.         signal_level: 0,
  1590.         storage_total_mb: 0,
  1591.         storage_free_mb: 0,
  1592.         ram_free_mb: 0,
  1593.         screen_on: true,
  1594.         brightness: 0,
  1595.         volume: 0,
  1596.         sdk: 0,
  1597.         brand: "",
  1598.         model: "",
  1599.         debug: ""
  1600.     };
  1601.     var errors = [];
  1602.     var gotInfo = false;
  1603.     try {
  1604.         var info = device.getInfo && device.getInfo();
  1605.         if (info && typeof info === "object") {
  1606.             for (var k in info) if (info.hasOwnProperty(k)) {
  1607.                 try { s[k] = info[k]; } catch (e) {}
  1608.             }
  1609.             gotInfo = true;
  1610.         }
  1611.     } catch (e) { errors.push("getInfo:" + e.message); }

  1613.     // 逐字段兜底（getInfo 里的字段名可能五花八门，所以每个都重新单独读一次覆盖）
  1614.     try { s.battery_level = device.getBatteryLevel(); } catch (e) { errors.push("battery:" + e.message); }
  1615.     try { s.battery_charging = device.isCharging(); } catch (e) { errors.push("charging:" + e.message); }
  1616.     try { s.network_type = device.getNetworkType(); } catch (e) { errors.push("net:" + e.message); }
  1617.     try { s.signal_level = device.getSignalLevel(); } catch (e) { errors.push("signal:" + e.message); }
  1618.     try { s.storage_total_mb = device.getTotalInternalMemorySize() / 1048576; } catch (e) { errors.push("stotal:" + e.message); }
  1619.     try { s.storage_free_mb = device.getAvailableInternalMemorySize() / 1048576; } catch (e) { errors.push("sfree:" + e.message); }
  1620.     try { s.ram_free_mb = device.getAvailableMemorySize() / 1048576; } catch (e) { errors.push("ram:" + e.message); }
  1621.     try { s.screen_on = device.isScreenOn(); } catch (e) { errors.push("screen:" + e.message); }
  1622.     try { s.brightness = device.getScreenBrightness(); } catch (e) { errors.push("bright:" + e.message); }
  1623.     try { s.volume = device.getMusicVolume(); } catch (e) { errors.push("vol:" + e.message); }
  1624.     try { s.sdk = device.getSdkVersion(); } catch (e) { errors.push("sdk:" + e.message); }
  1625.     try { s.brand = device.getBrand(); } catch (e) { errors.push("brand:" + e.message); }
  1626.     try { s.model = device.getModel(); } catch (e) { errors.push("model:" + e.message); }

  1628.     // 关键：老字段名 → 新字段名 反向同步（getInfo 里可能只有老名字，而单独API又抛异常失败）
  1629.     try {
  1630.         if ((s.battery_level === 0 || s.battery_level == null) && s.battery && typeof s.battery === "number") {
  1631.             s.battery_level = s.battery;
  1632.         }
  1633.     } catch (e) {}
  1634.     try {
  1635.         if (s.battery_charging == null && s.charging != null) {
  1636.             s.battery_charging = !!s.charging;
  1637.         }
  1638.     } catch (e) {}
  1639.     try {
  1640.         if ((!s.network_type || s.network_type === "unknown") && s.network) {
  1641.             s.network_type = String(s.network);
  1642.         }
  1643.     } catch (e) {}
  1644.     try {
  1645.         if (s.signal_level === 0 && s.signal != null && typeof s.signal === "number") {
  1646.             s.signal_level = s.signal;
  1647.         }
  1648.     } catch (e) {}
  1649.     try {
  1650.         if (s.storage_free_mb === 0 && s.storage_free != null && typeof s.storage_free === "number") {
  1651.             s.storage_free_mb = s.storage_free;
  1652.         }
  1653.     } catch (e) {}
  1654.     try {
  1655.         if (s.ram_free_mb === 0 && s.ram_free != null && typeof s.ram_free === "number") {
  1656.             s.ram_free_mb = s.ram_free;
  1657.         }
  1658.     } catch (e) {}

  1660.     // 同时保证"老字段名"也存在（兼容旧的上层逻辑 / 旧控制面板）
  1661.     try { if (s.battery == null) s.battery = s.battery_level; } catch (e) {}
  1662.     try { if (s.charging == null) s.charging = s.battery_charging; } catch (e) {}
  1663.     try { if (!s.network) s.network = s.network_type; } catch (e) {}
  1664.     if (errors.length) s.debug = errors.join("; ");
  1665.     s._info_ok = gotInfo;
  1666.     return s;
  1667. }

  1669. function clearPendingTimers() {
  1670.     // 清理所有 ACK 等待中的定时器（断线后不应继续重传，等重连后由离线队列重发）
  1671.     var keys = [];
  1672.     for (var k in G.pendingAcks) if (G.pendingAcks.hasOwnProperty(k)) keys.push(k);
  1673.     for (var i = 0; i < keys.length; i++) {
  1674.         var entry = G.pendingAcks[keys[i]];
  1675.         if (entry && entry.timerId) {
  1676.             try { runTime.stopTimeout(entry.timerId); } catch (e) {}
  1677.         }
  1678.     }
  1679.     G.pendingAcks = {};

  1681.     // 清理所有请求等待中的定时器
  1682.     var rkeys = [];
  1683.     for (var rk in G.pendingRequests) if (G.pendingRequests.hasOwnProperty(rk)) rkeys.push(rk);
  1684.     for (var j = 0; j < rkeys.length; j++) {
  1685.         var rentry = G.pendingRequests[rkeys[j]];
  1686.         if (rentry && rentry.timerId) {
  1687.             try { runTime.stopTimeout(rentry.timerId); } catch (e) {}
  1688.             // 不删除 entry，让 flushOfflineQueue 可以把请求重新发出
  1689.         }
  1690.     }
  1691. }

  1693. // ============================================================
  1694. //  连接 & 重连
  1695. // ============================================================
  1696. function doConnect() {
  1697.     G.connected = false;
  1698.     var ws = new websocket();
  1699.     G.ws = ws;

  1701.     try { ws.setSocketID(G.socketID); } catch (e) {}

  1703.     try {
  1704.         ws.event(
  1705.             function () { // onopen
  1706.                 G.connected = true;
  1707.                 G.retryCount = 0;
  1708.                 LOG("OK", "连接成功");

  1710.                 // 模式 3：重连后请求补发
  1711.                 requestResyncOnReconnect();

  1713.                 // 模式 4：flush 离线队列
  1714.                 flushOfflineQueue();

  1716.                 // 模式 6：启动自适应心跳
  1717.                 startHeartbeat();
  1718.                 startNetworkCheck();

  1720.                 // 模式 8：自动订阅频道
  1721.                 autoSubscribeChannels();

  1723.                 // 发送注册（携带设备信息给控制面板展示品牌/型号）
  1724.                 var brand = ""; var model = "";
  1725.                 try { brand = device.getBrand(); } catch (e) {}
  1726.                 try { model = device.getModel(); } catch (e) {}
  1727.                 sendMsg("REGISTER", {
  1728.                     socket_id: G.socketID,
  1729.                     version: "2.0",
  1730.                     features: ["ack", "req_resp", "resync", "offline_queue",
  1731.                                "chunked", "adaptive_heartbeat", "backpressure", "channels"]
  1732.                 });
  1733.                 // 上线后立刻报一次状态，让控制面板能看到
  1734.                 try {
  1735.                     var s = collectStatusFull();
  1736.                     if (s) sendMsg("STATUS", s, { no_ack: true });
  1737.                 } catch (e) {}
  1738.             },
  1739.             function (msg) { // onmessage
  1740.                 try { handleServerMessage(msg); }
  1741.                 catch (e) { LOG("ERROR", "消息处理异常: " + e.message); }
  1742.             },
  1743.             function (err) { // onerror
  1744.                 LOG("WARN", "连接失败");
  1745.                 G.connected = false;
  1746.                 stopHeartbeat();
  1747.                 stopNetworkCheck();
  1748.                 clearPendingTimers();
  1749.             },
  1750.             function () { // onclose
  1751.                 G.connected = false;
  1752.                 stopHeartbeat();
  1753.                 stopNetworkCheck();
  1754.                 clearPendingTimers();
  1755.             }
  1756.         );
  1757.     } catch (e) {
  1758.         LOG("ERROR", "event注册失败: " + e.message);
  1759.         return false;
  1760.     }

  1762.     var url = "ws://" + CONFIG.SERVER_IP + ":" + CONFIG.SERVER_PORT + CONFIG.WS_PATH;
  1763.     try {
  1764.         ws.connet(url);
  1765.         return true;
  1766.     } catch (e) {
  1767.         LOG("ERROR", "connet异常: " + e.message);
  1768.         return false;
  1769.     }
  1770. }

  1772. function computeRetryMs(n) {
  1773.     var ms = CONFIG.RETRY_BASE_MS * Math.pow(2, n);
  1774.     return Math.min(ms, CONFIG.RETRY_MAX_MS) + Math.floor(Math.random() * 1000);
  1775. }

  1777. // ============================================================
  1778. //  主循环
  1779. // ============================================================
  1780. function main() {
  1781.     LOG("INFO", "=== WebSocket 高级技巧合集 v2.0 启动 ===");
  1782.     LOG("INFO", "8大模式: ACK重传 / 请求响应 / 序列号补偿 / 离线队列 / 分片传输 / 自适应心跳 / 背压 / 频道订阅");

  1784.     while (G.running) {
  1785.         G.retryCount++;
  1786.         doConnect();

  1788.         var wait = 0;
  1789.         while (!G.connected && wait < 150) {
  1790.             sleep.millisecond(100);
  1791.             wait++;
  1792.         }

  1794.         if (!G.connected) {
  1795.             var ms = computeRetryMs(G.retryCount - 1);
  1796.             LOG("WARN", "连接失败 " + (ms / 1000).toFixed(1) + "s 后重试");
  1797.             try { G.ws.close(); } catch (e) {}
  1798.             sleep.millisecond(ms);
  1799.             continue;
  1800.         }

  1802.         while (G.running && G.connected) {
  1803.             sleep.millisecond(500);
  1804.         }

  1806.         if (!G.running) break;

  1808.         var ms2 = computeRetryMs(G.retryCount - 1);
  1809.         LOG("WARN", "断线 " + (ms2 / 1000).toFixed(1) + "s 后重连");
  1810.         try { G.ws.close(); } catch (e) {}
  1811.         sleep.millisecond(ms2);
  1812.     }

  1814.     // 清理
  1815.     stopHeartbeat();
  1816.     stopNetworkCheck();
  1817.     try { G.ws.close(); } catch (e) {}
  1818.     LOG("INFO", "脚本结束");
  1819.     exit();
  1820. }

  1822. // 启动
  1823. try {
  1824.     main();
  1825. } catch (e) {
  1826.     LOG("FATAL", e.message + "\n" + (e.stack || ""));
  1827.     try { G.ws.close(); } catch (e2) {}
  1828.     exit();
  1829. }
复制代码



AIWROK, AIWROK软件
楼主新帖
楼主热帖
untoWebSocket调试okhttp版nextnocontent

相关帖子
回复

使用道具 举报

返回列表 发帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

相关导读了
    采集亚马逊正版群发工具有没有？
    Apr.20旅行X心语今天来说说YYPOST新功能的一个灵活用法，采集亚马逊商品信息，并且获得排名的软件，亚马逊现在越来越多客户做，淘宝的水是越来越清了，以前做电商的客户，现在都转战到外国，最赚钱的要数一些客户往亚马逊里堆了吧，拿我这个YYPOST的客户，最多的是采集，分析排名，刷价格，刷数量，改价，刷访问量等等技术
    企业发展B2B网站有什么东东软件可以发呢
    标题企业发展网B2B软件，现在虽然B2B网站收录不错，可愁的是心急的人们，他们太想一口吃撑胖子了，发帖宣传虽然不能像佛系那样淡定，但也不能像跑火车那般急躁对待，自己内容不收录，完全是自己操作内容问题，可以参考一下别人的内容是怎么弄的，然后自己要试着转变，而且收录这个内容，常常会变化的，不是一种规则就吃到老
    搜房天下房聊软件哪一个好呢
    本帖最后由 发帖软件 于 2019-5-22 16:15 编辑 2搜房天下群发房聊信息软件，开始本来打算做58同城的，但发一个就要一次点触验证码，这就让人没有感觉到存在的价值了吧，都是卖二手房和新房的搜房天下倒是可以发即时聊天信息，也没有发现他这个网站有啥子限制，登陆一个搜房天下账号，然后采集回来分类列表的网址，然后就一
    大家坛有没有好用的群发工具下载呢
    当你的笑容给我礼貌的招呼，大家坛全自动发帖软件，宣传推广是一场持久战，总是有一些人把软件用了一天，或是几个小时，就觉得自己付出太多了，那加进来的粉丝，或是流量，应该是和宣传多少成正比的，其实没有这么便宜的事，就像很多阅读量超过一百万的视频，或是电影，真正会在屏幕打赏的人不会超过三千，真正大额打赏给主
    群发正版软件中国塑料网
    中国塑料网群发软件YYPOST脚本下载地址，这个网站会有一个很奇怪的问题就是你在首页登陆无半个验证码，但在登陆网址登陆就会有一个验证码，所以我们灵活一些，在首页登陆就不用输入验证码了哈。网站秒收录比较高，但发的都是五金和建筑行业，先前有很多人都是发土建工程的大公司操作的，现在这个网站专为那个行业诞生的吧。
    OpenStreetMap网站正版2019年发帖工具下载
    本帖最后由 发帖软件 于 2019-5-21 11:13 编辑 OpenStreetMap网站全自动群发，OpenStreetMapOpenStreetMap（简称OSM，中文是公开地图）是一个网上地图协作计划，目标是创造一个内容自由且能让所有人编辑的世界地图。有的人编辑地图然后等收录，有的人发日志等收录，我们这里也是利用地图日志做为宣传的目标，简单的脚本理
    搜房天下全自动收短信全自动识别验证码注册账号软件
    房天下自动注册机，这个脚本是前几天发房聊的脚本廷伸品种，这个脚本能做到自动注册账号，自动保存账号，自动发房聊的效果，不过今天我们主要说一说怎么注册账号写脚本吧，这个搜房天天下的账号，可以发提问，可以发房聊，发论坛，发博客，还有发个人中心页都是有秒收的效果的，这样就省去了去买号，去乱花钱的效果了吧，而
    企业邮箱安卓端有什么APP软件可以发的呢
    请输入标题企业邮箱安卓发发送邮箱脚本，这个脚本是利用企业邮箱进行群发的，全程是一种模拟手工操作的过程，所以封号是很少的，而且企业邮箱群发到普通QQ邮箱不容易进垃圾箱中的，所以这个脚本也是这样的原理，不过最好是利用一些多开器，登陆多点的QQ邮箱账号会比较流畅一些，然后用软件一个一个的切换APP进行群发邮件会
    头条留评论软件有没有好用的呢？
    今天整一个今日头条留言软件，对于留言YYPOST是优势是比较大的存在，因为他往往专注一些下拉定位的优点，像今日头条这样，还是需要一些特殊下拉定位的，因为他新闻有长有短，有图有视频的，所以综合起来定位是比较难的，如果用POST也不是很轻松可以破解他的加密参数。这个脚本也是有一个不好的地方就是换号会比较麻烦，您电
    单网页生成神器
    最近新技术，网页生成机占领了整个网络的半壁江山，效果很疯狂，虽然不知道能持续多久，作为开发软件的领头者，一直在找收录的方法，一直在努力创新着，一直被人模仿，却从没有被超越过，这个网页生成机，已经出来有一段时间了，一直没有拿出来分享，醉过醉过，它是利用的一些小小收录漏洞整的，您最好用一些老站域名，进行
关闭
本站开发自动发帖软件是目前效果最好的发贴工具，软件可以兼容所有的论坛，进行群发贴子，可以对各大论坛自主录制操作流程，自动识别 验证码，自动注册账号，自动群发贴子，还可以设置成自动抢沙发，是推广宣传的神级软件，软件可以兼容任何IE能顶贴发贴论坛，完全可以 做成论坛发贴软件，生成脚本，对各大论坛程序完美支持的。软件不但发的贴子收录快，而且只用法简单，使用方便，价格便宜，软件客服16 小时在线全程协助，为您的宣传保驾护航。用最少的投资，实现最大的收益，用最简单的方式，完全最复杂的操作。 QQ

Copyright © 2014 ( 京ICP备09078825号 )

Powered by Discuz! X3.2

群发软件发帖工具
快速回复 返回列表 返回顶部
本站自动发贴软件，是现在最流行的做脚本软件，这种发贴工具，不但发贴收录快，而且抢占好的先机，完全自由编辑，实现针对性群发模拟操作，软件可以顶贴，也可以发贴，可以兼容支持Discuz、PHPWind、Dvbbs三大主流论坛，有手机验证码收件，邮件收发的功能，支持验证码识别，注册问题识别，多线程任务，自动上传头像，自动激活注册邮件，兼容防注册插件，本站软件原创正版，更新效率最快的原创软件。 『网络推广软件』『自动发帖软件』『 自动发帖』