设为首页收藏本站
开启辅助访问

信息发布软件,b2b软件,广告发布软件

 找回密码
 立即注册
搜索
返回列表 发新帖
查看: 1|回复: 0
打印 上一主题 下一主题

[宣传软件网站动态] 实战使用桌面控制WebSocket

[复制链接]
群发软件

1955

主题

1965

帖子

1万

积分

积分
11458
跳转到指定楼层
宣传软件楼主
发表于 1 小时前 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式

资讯缩略图：

资讯发布日期：2026-08-14

资讯发布简介：实战使用桌面控制WebSocket

资讯关键词：实战使用桌面控制WebSocket

资讯所属分类：IT资讯 SEO资讯 

联系：

① 本信息收集于网络，如有不对的地方欢迎联系我纠正！
② 本信息免费收录，不存在价格的问题！
③ 如果您的网站也想这样出现在这里，请您加好友情链接，我当天会审核通过！

④友情链接关键字：软件网站分类目录 网址：http://www.postbbs.com/

资讯详细描述
实战使用桌面控制WebSocket
实战使用桌面控制WebSocket b2b软件

  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
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

相关导读
群发软件实战使用桌面控制WebSocket
实战使用桌面控制WebSocket
群发软件WebSocket调试okhttp版
WebSocket调试okhttp版
群发软件快手极速版自动刷视频
快手极速版自动刷视频
群发软件极速视频APP刷金币
极速视频APP刷金币
群发软件语音合成核心模块AIWROK 单文件版
语音合成核心模块AIWROK 单文件版
群发软件AIWROK软件自动文字转语音例子
AIWROK软件自动文字转语音例子
群发软件AIWROK adb.exec() 实用工具库 —— 常用功能直接调用版
AIWROK adb.exec() 实用工具库 —— 常用功能直接调用版
群发软件安卓AIWROK获取包名所有方法汇总
安卓AIWROK获取包名所有方法汇总
群发软件AIWROK软件番茄小说自动阅读刷金币示例
AIWROK软件番茄小说自动阅读刷金币示例
信息发布软件AIWROK软件无碍模式一键删除所有APP版示例
AIWROK软件无碍模式一键删除所有APP版示例
信息发布软件AIWROK软件无碍模式auto模块抖音极速版滑动刷视频
AIWROK软件无碍模式auto模块抖音极速版滑动刷视频
信息发布软件快手极速版自动刷视频无障碍模式
快手极速版自动刷视频无障碍模式
信息发布软件AIWROK软件代理模式一键删除桌面所有APP版示例
AIWROK软件代理模式一键删除桌面所有APP版示例
信息发布软件AIWROK软件自动找图利用agent代理模式删除应用版示例
AIWROK软件自动找图利用agent代理模式删除应用版示例
信息发布软件解析Kimi返回的拖动距离示例
解析Kimi返回的拖动距离示例
信息发布软件自动截图并发送给DEEPSEEK识别示例过程
自动截图并发送给DEEPSEEK识别示例过程
信息发布软件AIWROK软件测试文心识别识别验证码示例
AIWROK软件测试文心识别识别验证码示例
信息发布软件元宝截图B站验证码示例测试
元宝截图B站验证码示例测试
信息发布软件示例千问自动采集文章保存记事本
示例千问自动采集文章保存记事本
信息发布软件豆包识别验证码加拖动验证码示例
豆包识别验证码加拖动验证码示例
信息发布软件豆包对话采集示例
豆包对话采集示例
信息发布软件启动自动百度贴吧发图片
启动自动百度贴吧发图片
信息发布软件自动百度贴吧示例
自动百度贴吧示例
信息发布软件代理模式简书自动流程
代理模式简书自动流程
信息发布软件启动极速版任务页看小说赚钱自动阅读
启动极速版任务页看小说赚钱自动阅读
信息发布软件agent代理模式功能小结
agent代理模式功能小结
信息发布软件完整苹果IOS小脚本文本输入与粘贴流程
完整苹果IOS小脚本文本输入与粘贴流程
信息发布软件AIWROK使用activity列表开关与进度条的协同交互
AIWROK使用activity列表开关与进度条的协同交互
群发软件苹果脚本找图后Detect对象各种方法演示
苹果脚本找图后Detect对象各种方法演示
群发软件苹果脚本网络API监控与数据管理工具
苹果脚本网络API监控与数据管理工具
群发软件IOS苹果脚本TXT文件读写H5日志打印完整示例
IOS苹果脚本TXT文件读写H5日志打印完整示例
群发软件AIWROK软件演示多线程创建暂停恢复
AIWROK软件演示多线程创建暂停恢复
群发软件AIWROK软件定时检查页面状态防止卡死技巧
AIWROK软件定时检查页面状态防止卡死技巧
群发软件安卓脚本runTime相关功能示例
安卓脚本runTime相关功能示例
群发软件floatUI实例秒显示秒关闭吐司功能
floatUI实例秒显示秒关闭吐司功能
群发软件苹果脚本HID多行实例粘帖板示例
苹果脚本HID多行实例粘帖板示例
群发软件安卓脚本HID节点查找完整方法示例
HID节点查找完整方法示例
群发软件AIWROK软件框架的抖音自动化营销系统
AIWROK软件框架的抖音自动化营销系统
群发软件赛博朋克任务控制中心H5示例
赛博朋克任务控制中心H5示例
群发软件苹果脚本现代深色UI设计风格
现代深色UI设计风格
群发软件AIWROK软件智能任务监控悬浮窗
AIWROK软件智能任务监控悬浮窗
群发软件AIWROK软件事件监听示例
AIWROK软件事件监听示例
群发软件QZ掘金原生UI界面
QZ掘金原生UI界面
群发软件安卓脚本auto方法完整示例
安卓脚本auto方法完整示例
群发软件安卓脚本暂停弹出确认对话框
安卓脚本暂停弹出确认对话框
群发软件苹果iOS脚本天气信息查询工具
苹果iOS脚本天气信息查询工具
群发软件安卓脚本简化版H5日志输出窗口
安卓脚本简化版H5日志输出窗口
群发软件安卓脚本简化版H5日志输出窗口
安卓脚本简化版H5日志输出窗口
群发软件安卓脚本应用重置、代理模式监控及补丁升级
安卓脚本应用重置、代理模式监控及补丁升级
群发软件安卓脚本里的打开关闭安装以及卡密授权信息
安卓脚本里的打开关闭安装以及卡密授权信息
群发软件AIWROK软件脚本GET下载文件并检测0KB工具
AIWROK软件脚本GET下载文件并检测0KB工具
群发软件安卓脚本HID按键方法完整示例
安卓脚本HID按键方法完整示例
群发软件AIWROK软件键鼠HID滑动所有方法功能演示
AIWROK软件键鼠HID滑动所有方法功能演示
群发软件苹果脚本里HID的5种滑动方法的使用
苹果脚本里HID的5种滑动方法的使用
群发软件苹果脚本示例7种不同的OCR识别和点击方法
苹果脚本示例7种不同的OCR识别和点击方法
群发软件AIWROK软件安卓脚本FTP上传下载例子
AIWROK软件安卓脚本FTP上传下载例子
群发软件AIWROK软件脚本JSON转换示例
AIWROK软件脚本JSON转换示例
群发软件AIWROK软件运算符高级应用实例
AIWROK软件运算符高级应用实例
群发软件JavaScript语法小示例
JavaScript语法小示例
群发软件展示JavaScript各种语句标识符的实际应用
展示JavaScript各种语句标识符的实际应用
群发软件AIWROK条件语句实用示例智能活动推荐系统
AIWROK条件语句实用示例智能活动推荐系统
群发软件AIWROK软件示例数组方法实战应用
AIWROK软件示例数组方法实战应用
群发软件示例JavaScript的 try-catch-finally-throw用法
示例JavaScript的 try-catch-finally-throw用法
群发软件JavaScript 高级错误处理实战示例
JavaScript 高级错误处理实战示例
群发软件安卓脚本AIWROK软件示例JS函数高级用法
安卓脚本AIWROK软件示例JS函数高级用法

QQ|( 京ICP备09078825号 )

本网站信息发布软件，是可以发布论坛，发送信息到各大博客，各大b2b软件自动发布，好不夸张的说：只要手工能发在电脑打开IE能发的网站，用这个宣传软件就可以仿制动作，进行推送发到您想发送的B2B网站或是信息发布平台上，不管是后台，还是前台，都可以进行最方便的广告发布，这个广告发布软件，可以按月购买，还可以试用软件，对网站的验证码也可以完全自动对信息发布，让客户自动找上门,使企业轻松实现b2b发布，这个信息发布软件，均是本站原创正版开发，拥有正版的血统，想要新功能，欢迎提意见给我，一好的分类信息群发软件在手，舍我其谁。QQ896757558

GMT+8, 2026-8-14 08:22 , Processed in 0.279552 second(s), 52 queries .

宣传软件--信息发布软件--b2b软件【广告发布软件】

快速回复 返回顶部 返回列表