注册 登录
发贴工具
自动发帖软件»群发软件 › 群发软件公告教程 › AIWORK源码分享 › 语音合成核心模块AIWROK 单文件版
返回列表 发帖
查看: 4|回复: 0
打印 上一主题 下一主题

[24小时收录超级好的网站] 语音合成核心模块AIWROK 单文件版

[复制链接]

2601

主题

2649

帖子

1万

积分

积分
15782
跳转到指定楼层
楼主
发帖软件 发表于 2 小时前 | 只看该作者 |只看大图 回帖奖励 |正序浏览 |阅读模式
语音合成核心模块AIWROK 单文件版
语音合成核心模块AIWROK 单文件版 群发软件发帖工具
  1. /**
  2. * ============================================================================
  3. *  AIWROK TTS CORE - 语音合成核心模块（AIWROK 单文件版）
  4. * ============================================================================
  5. */

  7. // ==================== 导入 Java 类（AIWROK 内置） ====================

  9. importClass(Packages.java.lang.Thread);
  10. importClass(Packages.java.io.File);
  11. importClass(Packages.java.io.FileOutputStream);
  12. importClass(Packages.java.io.BufferedOutputStream);
  13. importClass(Packages.java.security.MessageDigest);
  14. // 注意：Array 和 Byte 不做 importClass，会和 JS 全局对象冲突
  15. // 代码里直接用完整类名：java.lang.reflect.Array / java.lang.Byte
  16. importClass(Packages.okhttp3.OkHttpClient);
  17. importClass(Packages.okhttp3.Request);
  18. importClass(Packages.okhttp3.RequestBody);
  19. importClass(Packages.okhttp3.WebSocketListener);
  20. importClass(Packages.okio.ByteString);
  21. importClass(Packages.okio.Buffer);
  22. importClass(Packages.java.util.concurrent.TimeUnit);

  24. // ==================== 音色列表 ====================

  26. var EDGE_VOICES = [
  27.     { id: "zh-CN-XiaoxiaoNeural",   name: "晓晓 (甜美女声)" },
  28.     { id: "zh-CN-XiaoyiNeural",     name: "晓伊 (软萌少女)" },
  29.     { id: "zh-CN-XiaohanNeural",    name: "晓涵 (知性御姐)" },
  30.     { id: "zh-CN-XiaomengNeural",   name: "晓梦 (温柔治愈)" },
  31.     { id: "zh-CN-XiaomoNeural",     name: "晓墨 (成熟稳重)" },
  32.     { id: "zh-CN-XiaoxuanNeural",   name: "晓萱 (活泼可爱)" },
  33.     { id: "zh-CN-XiaoyanNeural",    name: "晓颜 (新闻女主播)" },
  34.     { id: "zh-CN-XiaochenNeural",   name: "晓辰 (温暖女声)" },
  35.     { id: "zh-CN-XiaoshuangNeural", name: "晓双 (儿童女声)" },
  36.     { id: "zh-CN-XiaoruiNeural",    name: "晓睿 (老年女声)" },
  37.     { id: "zh-CN-YunxiNeural",      name: "云希 (年轻男声)" },
  38.     { id: "zh-CN-YunjianNeural",    name: "云健 (成熟男声)" },
  39.     { id: "zh-CN-YunyangNeural",    name: "云扬 (新闻播音)" },
  40.     { id: "zh-CN-YunxiaNeural",     name: "云夏 (少年男声)" },
  41.     { id: "zh-CN-YunyeNeural",      name: "云野 (故事讲述)" },
  42.     { id: "zh-CN-YunfengNeural",    name: "云枫 (老年男声)" },
  43.     { id: "zh-TW-HsiaoChenNeural",  name: "曉臻 (台湾女声)" },
  44.     { id: "zh-TW-YunJheNeural",     name: "雲哲 (台湾男声)" },
  45.     { id: "zh-HK-HiuMaanNeural",    name: "曉曼 (粤语女声)" },
  46.     { id: "zh-HK-WanLungNeural",    name: "雲龍 (粤语男声)" }
  47. ];

  49. var DOUBAO_VOICES = [
  50.     { id: "zh_female_taozi_conversation_v4_wvae_bigtts",  name: "桃子 (温柔女声)" },
  51.     { id: "zh_male_wennuanahu_radar_v4_wvae_bigtts",      name: "温暖 (男声)" },
  52.     { id: "zh_female_qingxinahu_radar_v4_wvae_bigtts",    name: "清新 (女声)" },
  53.     { id: "zh_male_zhiyu_radar_v5_wvae_bigtts",           name: "治愈 (男声)" },
  54.     { id: "zh_female_wanwanxiaohe_moon_bigtts",           name: "弯弯小贺 (女童)" },
  55.     { id: "zh_female_linjiaxiaoyu_moon_bigtts",           name: "邻家小语 (少女)" }
  56. ];

  58. var DEFAULT_EDGE_VOICE = "zh-CN-XiaoxiaoNeural";
  59. var DEFAULT_DOUBAO_VOICE = "zh_female_taozi_conversation_v4_wvae_bigtts";

  61. // ==================== 通用工具函数 ====================

  63. /**
  64. * 生成 UUID v4（Rhino ES5 兼容）
  65. */
  66. function uuid() {
  67.     var chars = '0123456789abcdef';
  68.     var s = [];
  69.     for (var i = 0; i < 36; i++) s[i] = chars[Math.floor(Math.random() * 16)];
  70.     s[14] = '4';
  71.     s[19] = chars[(parseInt(s[19], 16) & 0x3) | 0x8];
  72.     s[8] = s[13] = s[18] = s[23] = '-';
  73.     return s.join('');
  74. }

  76. /** XML 转义 */
  77. function escapeXml(str) {
  78.     return String(str)
  79.         .replace(/&/g, '&')
  80.         .replace(/</g, '<')
  81.         .replace(/>/g, '>')
  82.         .replace(/"/g, '"')
  83.         .replace(/'/g, ''');
  84. }

  86. /**
  87. * 把 JS 的 ArrayBuffer / Uint8Array / number[] 转成 Java byte[]
  88. * Rhino 里 ByteString.of() 和 Java IO 都需要原生 byte[]
  89. */
  90. function toJavaBytes(data) {
  91.     var view;
  92.     if (data instanceof ArrayBuffer) {
  93.         view = new Uint8Array(data);
  94.     } else if (data instanceof Uint8Array) {
  95.         view = data;
  96.     } else if (data && typeof data.length === 'number') {
  97.         view = new Uint8Array(data.length);
  98.         for (var i2 = 0; i2 < data.length; i2++) view[i2] = data[i2];
  99.     } else {
  100.         return java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, 0);
  101.     }
  102.     var jBytes = java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, view.length);
  103.     for (var k = 0; k < view.length; k++) {
  104.         var v = view[k] & 0xff;
  105.         jBytes[k] = (v > 127) ? (v - 256) : v;
  106.     }
  107.     return jBytes;
  108. }

  110. /**
  111. * 把 Uint8Array / number[] / ArrayBuffer 写入文件
  112. * @param {string} path
  113. * @param {Uint8Array|number[]|ArrayBuffer} data
  114. * @return {boolean}
  115. */
  116. function writeBinaryFile(path, data) {
  117.     try {
  118.         var jBytes = toJavaBytes(data);
  119.         if (!jBytes || jBytes.length === 0) return false;

  121.         // 确保父目录存在
  122.         var f = new java.io.File(path);
  123.         var parent = f.getParentFile();
  124.         if (parent && !parent.exists()) parent.mkdirs();

  126.         var fos = new java.io.FileOutputStream(f);
  127.         var out = new java.io.BufferedOutputStream(fos);
  128.         out.write(jBytes);
  129.         out.flush();
  130.         out.close();
  131.         fos.close();
  132.         return true;
  133.     } catch (e) {
  134.         print.log("[writeBinaryFile] 失败: " + e);
  135.         return false;
  136.     }
  137. }

  139. /**
  140. * 简易 sleep（不抛异常）
  141. */
  142. function sleep(ms) {
  143.     try { java.lang.Thread.sleep(ms); } catch (e) {}
  144. }

  146. /**
  147. * 字符串左侧补齐（Rhino 不支持 padStart）
  148. */
  149. function padStart(s, len, ch) {
  150.     s = String(s);
  151.     while (s.length < len) s = ch + s;
  152.     return s;
  153. }

  155. // ==================== Protobuf 编解码（豆包用） ====================

  157. function encodeVarint(v) {
  158.     var out = [];
  159.     v = v >>> 0;
  160.     while (v > 0x7f) {
  161.         out.push((v & 0x7f) | 0x80);
  162.         v = v >>> 7;
  163.     }
  164.     out.push(v & 0x7f);
  165.     return out;
  166. }

  168. function encodeBytesField(fieldNum, data) {
  169.     var bytes;
  170.     if (typeof data === 'string') {
  171.         // UTF-8 编码（不能用 unescape，中文会乱码）
  172.         var u8 = unescape(encodeURIComponent(data));
  173.         bytes = [];
  174.         for (var i = 0; i < u8.length; i++) bytes.push(u8.charCodeAt(i) & 0xff);
  175.     } else if (data && data.length !== undefined) {
  176.         bytes = [];
  177.         for (var j = 0; j < data.length; j++) bytes.push(data[j] & 0xff);
  178.     } else {
  179.         bytes = [];
  180.     }
  181.     var tag = (fieldNum << 3) | 2;
  182.     return encodeVarint(tag).concat(encodeVarint(bytes.length), bytes);
  183. }

  185. /**
  186. * 构造完整的 VoiceGenie 请求帧，返回 ArrayBuffer
  187. */
  188. function buildRequestFrame(event, payload, sessionId) {
  189.     var frame = [];
  190.     frame = frame.concat(encodeBytesField(2, 'GOqQpfo1fO7slHv8'));
  191.     frame = frame.concat(encodeBytesField(3, 'VoiceGenie'));
  192.     frame = frame.concat(encodeBytesField(5, event));
  193.     frame = frame.concat(encodeBytesField(6, payload));
  194.     if (sessionId) {
  195.         frame = frame.concat(encodeBytesField(8, sessionId));
  196.     }
  197.     // number[] → ArrayBuffer
  198.     var ab = new ArrayBuffer(frame.length);
  199.     var v = new Uint8Array(ab);
  200.     for (var i = 0; i < frame.length; i++) v[i] = frame[i];
  201.     return ab;
  202. }

  204. /**
  205. * 解析服务器返回的 protobuf 帧
  206. */
  207. function parseResponseFrame(buf) {
  208.     var a = (buf instanceof Uint8Array) ? buf : new Uint8Array(buf);
  209.     var fields = [];
  210.     var i = 0;

  212.     function readVarint() {
  213.         var v = 0, s = 0;
  214.         while (i < a.length) {
  215.             var b = a[i++];
  216.             v |= (b & 0x7f) << s;
  217.             if (!(b & 0x80)) return v >>> 0;
  218.             s += 7;
  219.             if (s > 35) break;
  220.         }
  221.         return v >>> 0;
  222.     }

  224.     while (i < a.length) {
  225.         var tag;
  226.         try { tag = readVarint(); } catch (e) { break; }
  227.         if (tag === 0) break;
  228.         var fieldNum = tag >> 3;
  229.         var wireType = tag & 7;
  230.         var field = { fieldNum: fieldNum, wireType: wireType };

  232.         if (wireType === 0) {
  233.             field.value = readVarint();
  234.         } else if (wireType === 2) {
  235.             var len = readVarint();
  236.             // 兼容 Rhino Uint8Array.subarray/slice
  237.             var sliceArr = [];
  238.             for (var kk = 0; kk < len; kk++) sliceArr.push(a[i + kk]);
  239.             field.data = sliceArr; // number[]
  240.             i += len;
  241.             if (len <= 8000) {
  242.                 try {
  243.                     // 转 Java byte[] 再 UTF-8 解码（中文安全）
  244.                     var jb = java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, len);
  245.                     for (var m = 0; m < len; m++) {
  246.                         var bv = a[i - len + m] & 0xff;
  247.                         jb[m] = (bv > 127) ? (bv - 256) : bv;
  248.                     }
  249.                     field.asString = String(new java.lang.String(jb, "UTF-8"));
  250.                 } catch (e) {}
  251.             }
  252.         } else if (wireType === 5) {
  253.             i += 4;
  254.         } else if (wireType === 1) {
  255.             i += 8;
  256.         } else {
  257.             break;
  258.         }
  259.         fields.push(field);
  260.     }

  262.     var result = { eventType: null, payload: null, audioData: null, seq: -1, sessionId: null };
  263.     for (var f = 0; f < fields.length; f++) {
  264.         var fld = fields[f];
  265.         if (fld.fieldNum === 1) result.sessionId = fld.asString || null;
  266.         if (fld.fieldNum === 4) result.eventType = fld.asString || null;
  267.         if (fld.fieldNum === 7) result.payload = fld.data || null;
  268.         if (fld.fieldNum === 8) result.audioData = fld.data; // number[]
  269.         if (fld.fieldNum === 9) result.seq = fld.value;
  270.     }
  271.     return result;
  272. }

  274. // ==================== 豆包 Cookie / UID 工具 ====================

  276. function cookieObjToString(cookies) {
  277.     if (typeof cookies === 'string') return cookies;
  278.     if (cookies && typeof cookies === 'object') {
  279.         // ES5 没有 Object.entries
  280.         var parts = [];
  281.         for (var k in cookies) {
  282.             if (cookies.hasOwnProperty(k)) {
  283.                 parts.push(k + '=' + cookies[k]);
  284.             }
  285.         }
  286.         return parts.join('; ');
  287.     }
  288.     return '';
  289. }

  291. function getCookieFromStr(cookieStr, name) {
  292.     if (!cookieStr) return null;
  293.     var m = cookieStr.match(new RegExp('(?:^|;\\s*)' + name + '=([^;]+)'));
  294.     return m ? m[1] : null;
  295. }

  297. function getUid(cookieStr) {
  298.     var uidCookie = getCookieFromStr(cookieStr, 'uid_tt') || getCookieFromStr(cookieStr, 'uid');
  299.     if (uidCookie) {
  300.         try {
  301.             // 用 Java BASE64 解码（Rhino 没有 atob）
  302.             var decoded = String(java.util.Base64.getDecoder().decode(uidCookie));
  303.             if (/^\d+$/.test(decoded)) return decoded;
  304.         } catch (e) {}
  305.         if (/^\d+$/.test(uidCookie)) return uidCookie;
  306.     }
  307.     return String(Date.now() % 1000000000000);
  308. }

  310. function buildDoubaoWsUrl(cookieStr) {
  311.     var deviceId = getCookieFromStr(cookieStr, 'device_id') ||
  312.                    getCookieFromStr(cookieStr, 's_v_web_id') ||
  313.                    (String(Date.now()) + padStart(String(Math.floor(Math.random() * 1e6)), 6, '0'));
  314.     var webId = getCookieFromStr(cookieStr, 'web_id') ||
  315.                 getCookieFromStr(cookieStr, 's_v_web_id') ||
  316.                 deviceId;

  318.     var params = [
  319.         'api_app_key=GOqQpfo1fO7slHv8',
  320.         'namespace=VoiceGenie',
  321.         'version_code=20800',
  322.         'language=zh',
  323.         'device_platform=web',
  324.         'pkg_type=release_version',
  325.         'pc_version=3.30.5',
  326.         'region=CN',
  327.         'sys_region=CN',
  328.         'samantha_web=1',
  329.         'use-olympus-account=1',
  330.         'doubao_device_platform=web',
  331.         'aid=497858',
  332.         'real_aid=497858',
  333.         'device_id=' + deviceId,
  334.         'doubao_pc_version=3.30.5',
  335.         'web_id=' + webId,
  336.         'tea_uuid=' + webId,
  337.         'web_platform=browser',
  338.         'web_tab_id=' + uuid()
  339.     ];
  340.     return 'wss://frontier-audio-web-ws.doubao.com/api/v2/sami/voicegenie?' + params.join('&');
  341. }

  343. function buildDoubaoSessionPayload(opts) {
  344.     var replyUniqueKey = uuid();
  345.     var queryLocalMessageId = uuid();
  346.     var uid = getUid(opts.cookieStr);

  348.     var payload = {
  349.         business: 1,
  350.         conversation_id: opts.conversationId,
  351.         chat: {
  352.             bot_id: '7338286299411103781',
  353.             conversation_id: opts.conversationId,
  354.             question_id: opts.questionId,
  355.             message_id: opts.messageId,
  356.             uid: uid,
  357.             new_conversation: false,
  358.             chat_next: '1',
  359.             enable_toast_reading: 'true',
  360.             extra: { chat_next: '1', reply_unique_key: replyUniqueKey, query_local_message_id: queryLocalMessageId },
  361.             reply_unique_key: replyUniqueKey,
  362.             section_id: opts.sectionId,
  363.             local_message_id: uuid(),
  364.             query_local_message_id: queryLocalMessageId
  365.         },
  366.         request_type: 4,
  367.         enable_text_reading: true,
  368.         interrupt_type: 0,
  369.         query_mode: 2,
  370.         tts: {
  371.             speaker: opts.speaker,
  372.             audio_config: opts.audioConfig,
  373.             extra: {
  374.                 chat_next: '1',
  375.                 query_local_message_id: queryLocalMessageId,
  376.                 post_process: { pitch: opts.pitch || 0, speech_rate: opts.speechRate || 1.0 }
  377.             }
  378.         },
  379.         extra: {
  380.             enable_toast_reading: 'true',
  381.             chat_next: '1',
  382.             uid: uid,
  383.             section_id: opts.sectionId,
  384.             reply_unique_key: replyUniqueKey,
  385.             query_local_message_id: queryLocalMessageId,
  386.             enable_text_simple_report: true,
  387.             enable_section_report: true,
  388.             enable_card_simple_report: true,
  389.             enable_image_asr_ctx: true,
  390.             disable_markdown_filter: true,
  391.             enable_asr_audio_context: false,
  392.             is_server_error_retry: false
  393.         }
  394.     };
  395.     return JSON.stringify(payload);
  396. }

  398. // ==================== Edge TTS 核心（1:1 对应 Python rany2/edge-tts 官方算法） ====================

  400. var EDGE_TTS_WS_URL = 'wss://speech.platform.bing.com/consumer/speech/synthesize/readaloud/edge/v1';
  401. var EDGE_TTS_TOKEN = '6A5AA1D4EAFF4E9FB37E23D68491D6F4';

  403. // 完全对齐官方 constants.py CHROMIUM_FULL_VERSION
  404. var EDGE_CHROMIUM_FULL_VERSION = '143.0.3650.75';
  405. var EDGE_CHROMIUM_MAJOR_VERSION  = '143';
  406. var EDGE_TTS_GEC_VERSION = '1-' + EDGE_CHROMIUM_FULL_VERSION;
  407. var EDGE_WIN_EPOCH_SECONDS = 11644473600;

  409. /**
  410. * 全局 DRM 时钟偏差（单位秒，正数=服务器比本地快）
  411. * 官方：DRM.clock_skew_seconds，403失败时从服务器 Date 头校准后自动重试
  412. */
  413. var EDGE_CLOCK_SKEW_SECONDS = 0.0;

  415. /**
  416. * 解析 RFC 2616 GMT 日期（RFC_1123_DATE_TIME 格式）
  417. * 优先使用 Java DateTimeFormatter，避免自己正则解析出错。
  418. *
  419. * @param {string|null|undefined} dateStr 例如 "Sat, 08 Aug 2026 07:20:58 GMT"
  420. * @returns {number|null} UTC 秒数（float），失败返回 null
  421. */
  422. function parseRfc2616Date(dateStr) {
  423.     if (!dateStr) return null;
  424.     var s = String(dateStr).trim();
  425.     try {
  426.         // === 方案1：Java 8+ java.time（安卓 7.0+ 支持，AIWROK 运行环境一般都有） ===
  427.         var formatter = java.time.format.DateTimeFormatter.RFC_1123_DATE_TIME;
  428.         var temporal = formatter.parse(s);
  429.         var zdt = java.time.ZonedDateTime.from(temporal);
  430.         var epochSec = zdt.toEpochSecond();  // long
  431.         // 注意：RFC 2616 日期不提供毫秒，只到秒
  432.         return parseFloat(String(epochSec));
  433.     } catch (e1) {
  434.         try {
  435.             // === 方案2：老安卓 SimpleDateFormat ===
  436.             var sdf = new java.text.SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss zzz", java.util.Locale.US);
  437.             sdf.setTimeZone(java.util.TimeZone.getTimeZone("GMT"));
  438.             var d = sdf.parse(s);
  439.             return parseFloat(String(d.getTime())) / 1000.0;
  440.         } catch (e2) {
  441.             // === 方案3：最后兜底 Rhino JS 原生 Date.parse ===
  442.             try {
  443.                 var fb = Date.parse(s);
  444.                 if (!isNaN(fb)) return fb / 1000.0;
  445.             } catch (e3) {}
  446.             return null;
  447.         }
  448.     }
  449. }

  451. /**
  452. * 生成 MUID（32位随机大写HEX）
  453. * 官方 DRM.generate_muid → headers_with_muid 塞到 Cookie 里
  454. */
  455. function generateEdgeMuid() {
  456.     var hex = '0123456789ABCDEF';
  457.     var sb = '';
  458.     for (var i = 0; i < 32; i++) {
  459.         sb += hex.charAt(Math.floor(Math.random() * 16));
  460.     }
  461.     return sb;
  462. }

  464. /**
  465. * 生成 Sec-MS-GEC 签名（严格对齐官方 drm.py DRM.generate_sec_ms_gec + clock_skew）
  466. *
  467. * 官方 Python 流程：
  468. *   ticks = dt.now(tz.utc).timestamp() + DRM.clock_skew_seconds
  469. *   ticks += WIN_EPOCH
  470. *   ticks -= ticks % 300
  471. *   ticks *= 1e7
  472. *   str = f"{ticks:.0f}{TOKEN}"
  473. *   return sha256(str.encode("ascii")).hexdigest().upper()
  474. */
  475. var _EDGE_GEC_LOG_ONCE = false;  // 只打印一次避免刷屏
  476. function generateSecMsGec() {
  477.     try {
  478.         var unixSecFloat = (java.lang.System.currentTimeMillis() / 1000.0) + EDGE_CLOCK_SKEW_SECONDS;
  479.         var ticks = unixSecFloat + EDGE_WIN_EPOCH_SECONDS;
  480.         // 对负数取模对齐 Python：Python % 永远非负，Rhino/JS 可能返回负数 → 手动归一化
  481.         var mod = ticks % 300;
  482.         if (mod < 0) mod += 300;
  483.         ticks = ticks - mod;
  484.         ticks = ticks * 10000000.0;
  485.         var ticksLong = java.lang.Math.round(ticks);
  486.         var ticksStr = String(ticksLong);
  487.         var src = ticksStr + EDGE_TTS_TOKEN;
  488.         var md = MessageDigest.getInstance('SHA-256');
  489.         var srcBytes = new java.lang.String(src).getBytes('US-ASCII');
  490.         var hash = md.digest(srcBytes);
  491.         var sb = new java.lang.StringBuilder(hash.length * 2);
  492.         for (var i = 0; i < hash.length; i++) {
  493.             var h = hash[i] & 0xff;
  494.             // ============================================================
  495.             // 修复 Rhino 平台大坑：
  496.             // java.lang.Integer.toHexString() 返回的是 java.lang.String（不是 JS String！）
  497.             // → java.lang.String 的 .length 是 METHOD/FUNCTION，不是 JS 数值属性 length
  498.             // → 旧代码：if (s.length < 2) → NaN < 2 → 永远 FALSE！
  499.             // → 结果：只要 byte < 0x10（高位为 0），补零就被跳过！
  500.             // → 每少一个零就错位 4 bit，导致整个 GEC 和官方差好几个字符 → 微软 403
  501.             // ============================================================
  502.             var hexJava = java.lang.Integer.toHexString(h);
  503.             // ① 强转为 JS 原生 String（此时 .length 就是数值属性）
  504.             var hex = String(hexJava);
  505.             // ② 也可以用 Java 方法 .length() 双重保险（任一方式都可以）
  506.             if (hex.length < 2) sb.append('0');
  507.             sb.append(hex);
  508.         }
  509.         var gec = String(sb.toString()).toUpperCase();

  511.         // ===== DEBUG：每次生成 GEC 时，只在第一次 / 403 前后打印关键参数 =====
  512.         // 用户可复制下面这行到 Python gec_verify.py 做 1:1 对撞
  513.         if (!_EDGE_GEC_LOG_ONCE || EDGE_CLOCK_SKEW_SECONDS !== 0.0) {
  514.             var dbgLine = '[Edge TTS][GEC] ticks_input=' + java.lang.String.format("%.6f", unixSecFloat)
  515.                         + ' skew=' + EDGE_CLOCK_SKEW_SECONDS.toFixed(4)
  516.                         + ' mod300=' + mod.toFixed(6)
  517.                         + ' ticksLong=' + ticksLong
  518.                         + ' ticksStr_len=' + ticksStr.length
  519.                         + ' src_preview=' + ticksStr.substring(0, Math.min(12, ticksStr.length)) + '...'
  520.                         + ' gec=' + gec;
  521.             print.log(dbgLine);
  522.             _EDGE_GEC_LOG_ONCE = true;
  523.         }

  525.         return gec;
  526.     } catch (e) {
  527.         print.log('[Edge TTS] 生成 Sec-MS-GEC 失败: ' + e);
  528.         return null;
  529.     }
  530. }

  532. function buildSSML(text, voice, rate, volume, pitch) {
  533.     return "<speak version='1.0' xmlns='http://www.w3.org/2001/10/synthesis' " +
  534.            "xmlns:mstts='https://www.w3.org/2001/mstts' xml:lang='zh-CN'>" +
  535.            "<voice name='" + voice + "'>" +
  536.            "<prosody rate='" + rate + "' volume='" + volume + "' pitch='" + pitch + "'>" +
  537.            escapeXml(text) +
  538.            "</prosody></voice></speak>";
  539. }

  541. /**
  542. * Edge TTS 单次握手尝试（内部函数，供 generateEdge 做自动重试）
  543. * @returns {Object} { ok, code, message, serverDate, output }
  544. */
  545. function tryEdgeOnce(sessionOpts) {
  546.     var text = sessionOpts.text;
  547.     var voice = sessionOpts.voice;
  548.     var rate = sessionOpts.rate;
  549.     var volume = sessionOpts.volume;
  550.     var pitch = sessionOpts.pitch;
  551.     var output = sessionOpts.output;

  553.     var requestId = uuid().replace(/-/g, '');
  554.     var gec = generateSecMsGec();
  555.     var wsUrl = EDGE_TTS_WS_URL
  556.               + '?TrustedClientToken=' + EDGE_TTS_TOKEN
  557.               + '&ConnectionId=' + requestId;
  558.     if (gec) {
  559.         wsUrl += '&Sec-MS-GEC=' + gec
  560.               +  '&Sec-MS-GEC-Version=' + EDGE_TTS_GEC_VERSION;
  561.     }

  563.     var state = {
  564.         connected: false,
  565.         closed: false,
  566.         err: null,
  567.         httpCode: 0,
  568.         serverDate: null,
  569.         audioChunks: [],
  570.         totalLen: 0,
  571.         _loggedFirstFrame: false
  572.     };

  574.     var listener = new WebSocketListener({
  575.         onOpen: function (ws, response) {
  576.             state.connected = true;
  577.             var code = 0;
  578.             try { code = response ? response.code() : 0; } catch(e){}
  579.             print.log('[Edge TTS][WS] ✅ onOpen 已触发，HTTP code=' + code + ' (期望 101 Switching Protocols)');
  580.             try {
  581.                 var xts = (function isoZ() {
  582.                     var d = new Date();
  583.                     var pad = function (n, w) { n = String(n); while (n.length < w) n = '0' + n; return n; };
  584.                     return d.getUTCFullYear() + '-' + pad(d.getUTCMonth() + 1, 2) + '-' + pad(d.getUTCDate(), 2)
  585.                          + 'T' + pad(d.getUTCHours(), 2) + ':' + pad(d.getUTCMinutes(), 2) + ':' + pad(d.getUTCSeconds(), 2) + '.000Z';
  586.                 })();

  588.                 var configMsg = JSON.stringify({
  589.                     context: {
  590.                         synthesis: {
  591.                             audio: {
  592.                                 metadataoptions: { sentenceBoundaryEnabled: false, wordBoundaryEnabled: false },
  593.                                 outputFormat: 'audio-24khz-48kbitrate-mono-mp3'
  594.                             }
  595.                         }
  596.                     }
  597.                 });
  598.                 ws.send('X-Timestamp:' + xts + '\r\nContent-Type:application/json; charset=utf-8\r\nPath:speech.config\r\n\r\n' + configMsg);

  600.                 var ssml = buildSSML(text, voice, rate, volume, pitch);
  601.                 ws.send('X-RequestId:' + requestId + '\r\nContent-Type:application/ssml+xml\r\nX-Timestamp:' + xts + '\r\nPath:ssml\r\n\r\n' + ssml);
  602.             } catch (e) {
  603.                 state.err = '发送失败: ' + e;
  604.                 print.log('[Edge TTS][WS] onOpen 内部发送失败: ' + e);
  605.             }
  606.         },

  608.         onMessage: function (ws, message) {
  609.             try {
  610.                 // ========== 1. 兼容 Rhino/OkHttp 多种消息类型 ==========
  611.                 if (message === null || message === undefined) return;
  612.                 // ----------- 文本消息：静默忽略（TEXT 帧是 turn.start / response / audio.metadata / turn.end 等控制消息） -----------
  613.                 var isJavaString = false;
  614.                 try {
  615.                     if (typeof message === 'string') {
  616.                         isJavaString = true;
  617.                     } else if (message && message.getClass) {
  618.                         var cls = message.getClass();
  619.                         if (cls === java.lang.String.class) isJavaString = true;
  620.                         // 再次兜底：如果是 okhttp 传过来的 String（比如某些版本会用
  621.                         // java.lang.CharSequence impl），调用 toString() 之后再检查
  622.                         // 是否全是可打印字符也可以 → 用 instanceof 更稳
  623.                         else if (java.lang.String.class.isInstance(message)) isJavaString = true;
  624.                     }
  625.                 } catch (e_ignore) {}
  626.                 if (isJavaString) return;

  628.                 // 二进制消息：可能是 okhttp3 ByteString (有 toByteArray())，可能是原生 byte[]，可能是 Buffer/ByteString 其它
  629.                 var jBytes = null;
  630.                 try {
  631.                     if (typeof message.toByteArray === 'function') {
  632.                         jBytes = message.toByteArray();
  633.                     } else if (typeof message.length === 'number') {
  634.                         // 可能是 JS ArrayBuffer / Uint8Array？ AIWROK Rhino 里 byte[] 也有 length 属性
  635.                         var maybeLen = message.length;
  636.                         if (maybeLen === 0 || (maybeLen > 0 && typeof message[0] === 'number')) {
  637.                             // JS Uint8Array 风格，转 Java byte[]
  638.                             jBytes = java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, maybeLen);
  639.                             for (var _k = 0; _k < maybeLen; _k++) {
  640.                                 var _bv = message[_k] & 0xff;
  641.                                 jBytes[_k] = (_bv > 127) ? (_bv - 256) : _bv;
  642.                             }
  643.                         } else if (maybeLen > 0 && message.getClass && message.getClass().isArray()) {
  644.                             // 原生 Java byte[]
  645.                             jBytes = message;
  646.                         }
  647.                     }
  648.                 } catch (convErr) {
  649.                     // 转换失败通常是文本控制帧，静默忽略即可
  650.                     return;
  651.                 }
  652.                 if (!jBytes) {
  653.                     // 非二进制消息（文本/其他控制帧），静默忽略
  654.                     return;
  655.                 }

  657.                 var len = jBytes.length;
  658.                 if (len < 2) {
  659.                     print.log('[Edge TTS][bin] frame too small, len=' + len);
  660.                     return;
  661.                 }
  662.                 // ========== 2. 按官方公式：header_length = 前 2 bytes big-endian ==========
  663.                 var headerLength = ((jBytes[0] & 0xff) << 8) | (jBytes[1] & 0xff);
  664.                 // 官方 get_headers_and_data: data[header_length+2:] （这里的 data 就是整个 jBytes）
  665.                 // 所以 header_length 必须 <= len - 2（后面至少留 2 字节给 start index）
  666.                 if (headerLength < 0 || (headerLength + 2) > len) {
  667.                     print.log('[Edge TTS][bin] invalid: headerLength=' + headerLength + ' totalLen=' + len);
  668.                     return;
  669.                 }
  670.                 var audioStart = headerLength + 2;   // 官方 1:1
  671.                 var audioLen = len - audioStart;     // 官方 1:1

  673.                 // ========== 3. 解析 header（官方：line.split(b":", 1)，不 strip value） ==========
  674.                 var pathVal = null;
  675.                 var contentTypeVal = null;
  676.                 try {
  677.                     // jBytes[2 : 2 + headerLength] = header bytes
  678.                     var headerArr = java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, headerLength);
  679.                     for (var _hi = 0; _hi < headerLength; _hi++) headerArr[_hi] = jBytes[2 + _hi];
  680.                     var headerStr = String(new java.lang.String(headerArr, 'US-ASCII'));
  681.                     var lines = headerStr.split('\r\n');
  682.                     for (var _li = 0; _li < lines.length; _li++) {
  683.                         var ln = lines[_li];
  684.                         if (!ln) continue;
  685.                         var colon = ln.indexOf(':');
  686.                         if (colon === -1) continue;
  687.                         var rawK = ln.substring(0, colon);
  688.                         var rawV = ln.substring(colon + 1);
  689.                         // Rhino String: 正常 key，也可能带 \x00\x80 前缀（如抓包中第一个 key = \x00\x80X-RequestId）
  690.                         // 所以 trim() key 是安全的（去掉\x00这类控制符会更好），然后 toLowerCase
  691.                         var k = rawK.replace(/[\x00-\x1f\x7f]/g, '').trim().toLowerCase();
  692.                         var v = rawV.replace(/[\x00-\x1f\x7f]/g, '').trim().toLowerCase();
  693.                         if (k === 'path') pathVal = v;
  694.                         if (k === 'content-type') contentTypeVal = v;
  695.                     }
  696.                 } catch (parseErr) {
  697.                     print.log('[Edge TTS][bin] header parse error: ' + parseErr);
  698.                     pathVal = null; contentTypeVal = null;
  699.                 }

  701.                 // 日志（不打每帧，只在首次 audio 成功和总计打，避免日志爆炸）
  702.                 if (!state._loggedFirstFrame) {
  703.                     print.log('[Edge TTS][bin] first frame: total=' + len + ' headerLen=' + headerLength + ' audioLen=' + audioLen + ' Path=' + (pathVal||'<NULL>') + ' Content-Type=' + (contentTypeVal||'<NULL>'));
  704.                 }

  706.                 // ========== 4. 按官方判断：Path == 'audio' 且 (Content-Type == 'audio/mpeg' 或 NULL) ==========
  707.                 if (pathVal !== 'audio') {
  708.                     return;  // 非音频帧（例如 WebRTC 心跳等二进制帧）
  709.                 }
  710.                 if (contentTypeVal !== 'audio/mpeg') {
  711.                     // Content-Type 为 NULL 且 data 为空 = 终止帧，直接跳过
  712.                     if (contentTypeVal === null && audioLen === 0) return;
  713.                     // 有 data 但没有 Content-Type = UnexpectedResponse（官方抛异常），这里直接记日志跳过
  714.                     if (contentTypeVal === null) {
  715.                         print.log('[Edge TTS][bin] WARN: Path=audio, no Content-Type but data exists, audioLen=' + audioLen);
  716.                         return;
  717.                     }
  718.                     return;
  719.                 }
  720.                 if (audioLen <= 0) return;

  722.                 // ========== 5. 收集音频 ==========
  723.                 var chunk = new Array(audioLen);
  724.                 for (var kk2 = 0; kk2 < audioLen; kk2++) chunk[kk2] = jBytes[audioStart + kk2] & 0xff;
  725.                 state.audioChunks.push(chunk);
  726.                 state.totalLen += audioLen;
  727.                 if (!state._loggedFirstFrame) {
  728.                     state._loggedFirstFrame = true;
  729.                     var first2 = chunk[0].toString(16) + (chunk[1] < 16 ? '0' : '') + chunk[1].toString(16);
  730.                     print.log('[Edge TTS][bin] first audio bytes: 0x' + first2.toUpperCase() + ' (expect MP3: FFF3/FFF2)');
  731.                 }
  732.             } catch (e) {
  733.                 try { print.log('[Edge TTS] onMessage uncaught error: ' + e); } catch(ee){}
  734.             }
  735.         },

  737.         onClosed: function (ws, code, reason) {
  738.             state.closed = true;
  739.             state.connected = false;
  740.             try { print.log('[Edge TTS][WS] onClosed 触发 code=' + code + ' reason=' + reason); } catch(e){}
  741.         },

  743.         onFailure: function (ws, t, response) {
  744.             state.closed = true;
  745.             state.connected = false;
  746.             state.err = t ? String(t.getMessage()) : 'ws_error';
  747.             try {
  748.                 if (response) {
  749.                     try {
  750.                         state.httpCode = response.code() || 0;
  751.                     } catch (ee) {}
  752.                     try {
  753.                         var hd = response.header('Date');
  754.                         if (hd) state.serverDate = String(hd);
  755.                     } catch (ee) {}
  756.                 }
  757.             } catch (e) {}
  758.             try {
  759.                 print.log('[Edge TTS][WS] ❌ onFailure: err_msg=' + (state.err || '')
  760.                         + ' HTTP_code=' + state.httpCode
  761.                         + ' Date=' + (state.serverDate || '<none>')
  762.                         + ' Throwable_type=' + (t ? String(t.getClass().getName()) : 'null'));
  763.             } catch(e2) {}
  764.         }
  765.     });

  767.     var client = new OkHttpClient.Builder()
  768.         .pingInterval(10, TimeUnit.SECONDS)
  769.         .connectTimeout(25, TimeUnit.SECONDS)
  770.         .readTimeout(40, TimeUnit.SECONDS)
  771.         .build();

  773.     var muid = generateEdgeMuid();
  774.     var edgeUA = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36'
  775.               + ' (KHTML, like Gecko) Chrome/' + EDGE_CHROMIUM_MAJOR_VERSION + '.0.0.0 Safari/537.36'
  776.               + ' Edg/' + EDGE_CHROMIUM_MAJOR_VERSION + '.0.0.0';

  778.     var request = new Request.Builder()
  779.         .url(wsUrl)
  780.         .addHeader('User-Agent', edgeUA)
  781.         .addHeader('Accept-Encoding', 'gzip, deflate, br, zstd')
  782.         .addHeader('Accept-Language', 'en-US,en;q=0.9')
  783.         .addHeader('Pragma', 'no-cache')
  784.         .addHeader('Cache-Control', 'no-cache')
  785.         .addHeader('Origin', 'chrome-extension://jdiccldimpdaibmpdkjnbmckianbfold')
  786.         .addHeader('Sec-WebSocket-Version', '13')
  787.         .addHeader('Cookie', 'muid=' + muid + ';')
  788.         .build();

  790.     var ws = client.newWebSocket(request, listener);

  792.     print.log('[Edge TTS][WS] newWebSocket 已发起，等待 onOpen / onFailure / 25s timeout...');

  794.     var w = 0;
  795.     while (!state.connected && !state.err && w < 25000) {
  796.         sleep(100);
  797.         w += 100;
  798.     }
  799.     if (state.err) {
  800.         try { ws.close(1000, 'err'); } catch (e) {}
  801.         try { client.dispatcher().executorService().shutdown(); } catch (e) {}
  802.         var code = 'error';
  803.         if (state.httpCode === 403) code = '403';
  804.         return { ok: false, code: code, message: state.err, serverDate: state.serverDate };
  805.     }
  806.     if (!state.connected) {
  807.         try { ws.close(1000, 'timeout'); } catch (e) {}
  808.         try { client.dispatcher().executorService().shutdown(); } catch (e) {}
  809.         print.log('[Edge TTS][WS] ⏱️  onOpen 等待超时（25秒）未触发，已等待' + (w/1000).toFixed(1) + '秒，err=' + (state.err || '<none>'));
  810.         return { ok: false, code: 'timeout', message: 'WebSocket 连接超时（25秒）', serverDate: state.serverDate };
  811.     }

  813.     w = 0;
  814.     var lastLen = 0;
  815.     var noGrowthMs = 0;
  816.     while (!state.closed && !state.err && w < 45000) {
  817.         sleep(200);
  818.         w += 200;
  819.         if (state.totalLen !== lastLen) {
  820.             lastLen = state.totalLen;
  821.             noGrowthMs = 0;
  822.         } else {
  823.             noGrowthMs += 200;
  824.             if (state.totalLen > 100 && noGrowthMs > 2000) break;
  825.         }
  826.     }
  827.     print.log('[Edge TTS][WS] 接收循环结束：等待=' + (w/1000).toFixed(1) + '秒 audioBytes_total=' + state.totalLen + ' closed=' + state.closed + ' err=' + (state.err||'<none>'));

  829.     try { ws.close(1000, 'done'); } catch (e) {}
  830.     try { client.dispatcher().executorService().shutdown(); } catch (e) {}

  832.     if (state.err) {
  833.         var code2 = 'error';
  834.         if (state.httpCode === 403) code2 = '403';
  835.         return { ok: false, code: code2, message: state.err, serverDate: state.serverDate };
  836.     }
  837.     if (state.totalLen < 100) {
  838.         return { ok: false, code: 'noaudio', message: '未获取到音频数据，请检查网络或参数', serverDate: state.serverDate };
  839.     }

  841.     var merged = new Uint8Array(state.totalLen);
  842.     var offset = 0;
  843.     for (var ci = 0; ci < state.audioChunks.length; ci++) {
  844.         var chunk = state.audioChunks[ci];
  845.         for (var cj = 0; cj < chunk.length; cj++) merged[offset + cj] = chunk[cj];
  846.         offset += chunk.length;
  847.     }

  849.     if (output) {
  850.         if (!writeBinaryFile(output, merged)) {
  851.             return { ok: false, code: 'write', message: '写入文件失败: ' + output, serverDate: state.serverDate };
  852.         }
  853.         print.log('[Edge TTS] 已保存: ' + output + ' (' + state.totalLen + ' 字节)');
  854.         return { ok: true, output: output, serverDate: state.serverDate };
  855.     }
  856.     return { ok: true, output: merged, serverDate: state.serverDate };
  857. }

  859. /**
  860. * Edge TTS 核心生成（同步阻塞，关键字接口）—— 带官方 DRM 时钟偏移自动校准+重试
  861. *
  862. * @param {Object} options
  863. * @param {string} options.text       - 要合成的文字（必填）
  864. * @param {string} [options.voice]    - 音色ID，默认 zh-CN-XiaoxiaoNeural
  865. * @param {string} [options.rate]     - 语速 "+0%" / "-20%" / "+50%"
  866. * @param {string} [options.volume]   - 音量 "+0%" / "+50%"
  867. * @param {string} [options.pitch]    - 音调 "+0Hz" / "-10Hz"
  868. * @param {string} [options.output]   - 输出路径(.mp3)，不填返回 Uint8Array
  869. * @returns {string|Uint8Array|null}  成功返回路径或 Uint8Array，失败返回 null
  870. */
  871. function generateEdge(options) {
  872.     var opts = options || {};
  873.     if (!opts.text || !String(opts.text).trim()) {
  874.         print.log('[Edge TTS] 缺少必填参数: text');
  875.         return null;
  876.     }
  877.     var sessionOpts = {
  878.         text: opts.text,
  879.         voice: opts.voice || DEFAULT_EDGE_VOICE,
  880.         rate: opts.rate || '+0%',
  881.         volume: opts.volume || '+0%',
  882.         pitch: opts.pitch || '+0Hz',
  883.         output: opts.output || null
  884.     };

  886.     // 第 1 次尝试
  887.     var r = tryEdgeOnce(sessionOpts);
  888.     if (r.ok) return r.output;

  890.     // 官方 DRM.handle_client_response_error：
  891.     // 若失败且带 Date 头 → 计算 skew = serverDate - localNow → 修正 skew → 自动重试
  892.     if (r.code === '403' && r.serverDate) {
  893.         print.log('[Edge TTS][403] 收到服务器 Date 头: ' + String(r.serverDate));
  894.         var serverTs = parseRfc2616Date(r.serverDate);
  895.         var localTsNow = java.lang.System.currentTimeMillis() / 1000.0;
  896.         if (serverTs !== null) {
  897.             var skew = serverTs - localTsNow;
  898.             print.log('[Edge TTS][403] serverTs_parsed=' + serverTs.toFixed(3)
  899.                      + ' localNow=' + localTsNow.toFixed(3)
  900.                      + ' skew=' + skew.toFixed(3));
  901.             var oldSkew = EDGE_CLOCK_SKEW_SECONDS;
  902.             EDGE_CLOCK_SKEW_SECONDS += skew;
  903.             print.log('[Edge TTS] 校准时钟偏差: old_skew=' + oldSkew.toFixed(3)
  904.                      + ' +delta=' + skew.toFixed(3)
  905.                      + ' → new_skew=' + EDGE_CLOCK_SKEW_SECONDS.toFixed(3) + ' 秒（403 后自动重试）');
  906.             var r2 = tryEdgeOnce(sessionOpts);
  907.             if (r2.ok) return r2.output;
  908.             print.log('[Edge TTS] 重试后仍失败: code=' + r2.code + ' msg=' + r2.message
  909.                     + (r2.serverDate ? ' serverDate=' + r2.serverDate : ''));
  910.             return null;
  911.         } else {
  912.             print.log('[Edge TTS][403] 日期解析失败！无法计算时钟偏差，放弃重试');
  913.         }
  914.     }

  916.     // 无 Date 头或非 403 错误，直接打印
  917.     print.log('[Edge TTS] 失败(' + r.code + '): ' + r.message);
  918.     return null;
  919. }

  921. // ==================== 豆包 VoiceGenie TTS 核心 ====================

  923. var DOUBAO_AUDIO_CONFIG = { bit_rate: 32000, format: 'ogg_opus', sample_rate: 24000 };

  925. /**
  926. * 豆包 VoiceGenie TTS 核心生成（同步阻塞，关键字接口）
  927. */
  928. function generateDoubao(options) {
  929.     var opts = options || {};
  930.     var cookies = opts.cookies;
  931.     var conversationId = opts.conversationId;
  932.     var messageId = opts.messageId;
  933.     var questionId = opts.questionId || null;
  934.     var sectionId = opts.sectionId || '0';
  935.     var speaker = opts.speaker || DEFAULT_DOUBAO_VOICE;
  936.     var speechRate = opts.speechRate || 1.0;
  937.     var pitch = opts.pitch || 0;
  938.     var audioConfig = opts.audioConfig || DOUBAO_AUDIO_CONFIG;
  939.     var output = opts.output || null;

  941.     if (!cookies) { print.log('[豆包 TTS] 缺少必填参数: cookies'); return null; }
  942.     if (!conversationId) { print.log('[豆包 TTS] 缺少必填参数: conversationId'); return null; }
  943.     if (!messageId) { print.log('[豆包 TTS] 缺少必填参数: messageId'); return null; }

  945.     var cookieStr = cookieObjToString(cookies);
  946.     var qId = questionId || messageId;
  947.     var sessionOpts = {
  948.         conversationId: conversationId, questionId: qId, messageId: messageId,
  949.         sectionId: sectionId, speaker: speaker, speechRate: speechRate,
  950.         pitch: pitch, audioConfig: audioConfig, cookieStr: cookieStr
  951.     };

  953.     var state = {
  954.         connected: false,
  955.         closed: false,
  956.         sessionId: null,
  957.         gotTTSEnded: false,
  958.         audioChunks: [],
  959.         totalLen: 0,
  960.         err: null
  961.     };

  963.     var wsUrl = buildDoubaoWsUrl(cookieStr);

  965.     var listener = new WebSocketListener({
  966.         onOpen: function (ws, response) {
  967.             state.connected = true;
  968.             try {
  969.                 ws.send(ByteString.of(toJavaBytes(buildRequestFrame('StartTask', '{}', null))));
  970.                 ws.send(ByteString.of(toJavaBytes(buildRequestFrame('Ping', '{}', null))));
  971.             } catch (e) {
  972.                 state.err = '发送 StartTask 失败: ' + e;
  973.             }
  974.         },

  976.         onMessage: function (ws, message) {
  977.             try {
  978.                 if (typeof message === 'string') return;
  979.                 if (!message || !message.toByteArray) return;

  981.                 var jBytes = message.toByteArray();
  982.                 var u8 = new Uint8Array(jBytes.length);
  983.                 for (var i = 0; i < jBytes.length; i++) u8[i] = jBytes[i] & 0xff;

  985.                 var parsed = parseResponseFrame(u8);
  986.                 var ev = parsed.eventType;

  988.                 if (ev === 'TaskStarted') {
  989.                     var payload1 = buildDoubaoSessionPayload(sessionOpts);
  990.                     ws.send(ByteString.of(toJavaBytes(buildRequestFrame('StartSession', payload1, null))));

  992.                 } else if (ev === 'SessionStarted') {
  993.                     state.sessionId = uuid();
  994.                     ws.send(ByteString.of(toJavaBytes(buildRequestFrame('Ping', '{}', state.sessionId))));
  995.                     var payload2 = buildDoubaoSessionPayload(sessionOpts);
  996.                     ws.send(ByteString.of(toJavaBytes(buildRequestFrame('StartTTS', payload2, state.sessionId))));

  998.                 } else if (ev === 'TTSResponse') {
  999.                     if (parsed.audioData && parsed.audioData.length > 0) {
  1000.                         state.audioChunks.push({ seq: parsed.seq, data: parsed.audioData });
  1001.                         state.totalLen += parsed.audioData.length;
  1002.                     }

  1004.                 } else if (ev === 'TTSEnded') {
  1005.                     state.gotTTSEnded = true;
  1006.                     try { ws.close(1000, 'done'); } catch (e) {}
  1007.                 }
  1008.             } catch (e) {}
  1009.         },

  1011.         onClosed: function (ws, code, reason) {
  1012.             state.closed = true;
  1013.             state.connected = false;
  1014.         },

  1016.         onFailure: function (ws, t, response) {
  1017.             state.closed = true;
  1018.             state.connected = false;
  1019.             state.err = t ? String(t.getMessage()) : 'ws_error';
  1020.         }
  1021.     });

  1023.     var client = new OkHttpClient.Builder()
  1024.         .pingInterval(10, TimeUnit.SECONDS)
  1025.         .connectTimeout(15, TimeUnit.SECONDS)
  1026.         .readTimeout(60, TimeUnit.SECONDS)
  1027.         .build();

  1029.     var request = new Request.Builder()
  1030.         .url(wsUrl)
  1031.         .addHeader('Cookie', cookieStr)
  1032.         .addHeader('User-Agent', 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/128.0.0.0 Safari/537.36')
  1033.         .addHeader('Origin', 'https://www.doubao.com')
  1034.         .build();

  1036.     var ws = client.newWebSocket(request, listener);

  1038.     var w = 0;
  1039.     while (!state.connected && !state.err && w < 15000) {
  1040.         sleep(100);
  1041.         w += 100;
  1042.     }
  1043.     if (state.err) {
  1044.         print.log('[豆包 TTS] 连接失败: ' + state.err);
  1045.         try { ws.close(1000, 'err'); } catch (e) {}
  1046.         try { client.dispatcher().executorService().shutdown(); } catch (e) {}
  1047.         return null;
  1048.     }
  1049.     if (!state.connected) {
  1050.         print.log('[豆包 TTS] WebSocket 连接超时 (15秒)');
  1051.         try { ws.close(1000, 'timeout'); } catch (e) {}
  1052.         try { client.dispatcher().executorService().shutdown(); } catch (e) {}
  1053.         return null;
  1054.     }

  1056.     w = 0;
  1057.     var lastLen = 0;
  1058.     var noGrowthMs = 0;
  1059.     while (!state.closed && !state.gotTTSEnded && !state.err && w < 60000) {
  1060.         sleep(200);
  1061.         w += 200;
  1062.         if (state.totalLen !== lastLen) {
  1063.             lastLen = state.totalLen;
  1064.             noGrowthMs = 0;
  1065.         } else {
  1066.             noGrowthMs += 200;
  1067.             if (state.totalLen > 0 && noGrowthMs > 3000) break;
  1068.         }
  1069.     }

  1071.     try { ws.close(1000, 'done'); } catch (e) {}
  1072.     try { client.dispatcher().executorService().shutdown(); } catch (e) {}

  1074.     if (state.err) {
  1075.         print.log('[豆包 TTS] ' + state.err);
  1076.         return null;
  1077.     }
  1078.     if (state.audioChunks.length === 0) {
  1079.         print.log('[豆包 TTS] 未收到任何音频数据，请检查 cookies/对话参数');
  1080.         return null;
  1081.     }

  1083.     state.audioChunks.sort(function (a, b) { return a.seq - b.seq; });
  1084.     var merged = new Uint8Array(state.totalLen);
  1085.     var offset = 0;
  1086.     for (var ci = 0; ci < state.audioChunks.length; ci++) {
  1087.         var data = state.audioChunks[ci].data;
  1088.         for (var cj = 0; cj < data.length; cj++) {
  1089.             merged[offset + cj] = data[cj];
  1090.         }
  1091.         offset += data.length;
  1092.     }

  1094.     if (output) {
  1095.         if (writeBinaryFile(output, merged)) {
  1096.             print.log('[豆包 TTS] 已保存: ' + output + ' (' + state.totalLen + ' 字节)');
  1097.             return output;
  1098.         }
  1099.         print.log('[豆包 TTS] 写入文件失败: ' + output);
  1100.         return null;
  1101.     }
  1102.     return merged;
  1103. }

  1105. // ==================== 直接运行示例 ====================

  1107. (function runDemo() {
  1108.     print.log('=== AIWROK TTS CORE 单文件版 ===');
  1109.     print.log('时间: ' + new Date().toString());
  1110.     print.log('');

  1112.     // --- Edge TTS 示例 ---
  1113.     print.log('[1] Edge TTS 生成中...');
  1114.     var demoText = '庚子年后京城的买卖不好做，前门大街倒了三家茶馆，唯独德顺的王掌柜，日子反倒越过越舒展。'
  1115.         + '熟客们都打趣，说老王是祖坟冒了青烟，平白无故的好运往怀里撞。'
  1116.         + '王掌柜有个旁人瞧不上的小习惯：每天天刚蒙蒙亮，伙计还没上门，他先搬条凳坐柜台后头，'
  1117.         + '就着油灯的光，在麻纸本子上写半页字。写的不是什么圣贤文章，全是鸡零狗碎的闲事：'
  1118.         + '张二爷爱喝焖得酽的香片，李三赊了俩铜子儿的茶钱，驴打滚剩了八块卖不动，街对过杂货铺的东家爱喝茉莉双熏。'
  1119.         + '常来蹭茶喝的混混儿刘四笑他：“王掌柜，你这是要考秀才啊？开茶馆卖水得了，费那洋劲干嘛？”'
  1120.         + '王掌柜也不恼，嘿嘿一笑，把本子收进抽屉，第二天照旧写。'
  1121.         + '那年春上茶叶价涨得邪乎，别家茶馆要么涨价把客人挤走，要么换碎茶末子砸招牌。'
  1122.         + '唯独德顺，价没大涨，茶味还跟从前一样地道。满街的人都说老王运气好，提前囤着好茶了。'
  1123.         + '哪是运气？他那半页纸上，早记着“每年开春茶价必涨三成，头年秋里定货最稳”。'
  1124.         + '这不是他天生会算，是天天写、年年记，摸出来的老规矩。旁人年年临渴掘井，他早把井挖在了前头。'
  1125.         + '还有一回，有个南下的绸缎商来城里收贷，进茶馆歇脚。王掌柜一眼就想起，'
  1126.         + '前阵子本子上记过这位客官爱喝碧螺春，还托人打听过京里靠谱的绸缎庄。'
  1127.         + '他一边上茶一边顺嘴提了两家字号，连东家的脾气秉性都顺带说了。'
  1128.         + '那商人感激不尽，往后带了好几拨同行来，成了固定的大主顾。'
  1129.         + '旁人又说，老王会来事，平白撞上了贵人。其实哪是撞的？是他天天记着客人的喜好，机会递到跟前，伸手就接住了。'
  1130.         + '日子久了，德顺的生意越做越稳，别家倒闭的伙计都来投奔。'
  1131.         + '有人专门来讨教“转运”的法子，王掌柜就把那本麻纸本子翻出来给人看：'
  1132.         + '“哪有什么好运？我就是每天早起写半页纸，写着写着，账也清了，人也熟了，该避的坑避了，该抓的机会也没跑。”'
  1133.         + '私塾的陈先生呷了口茶，慢悠悠补了句：“这就叫拱心石的习惯。看着是每天半页纸的小事，'
  1134.         + '实则把记性、眼力、心思都串起来了。习惯成了本能，就不用天天费脑子琢磨运气。'
  1135.         + '提示是开门点灯，动作是记账识人，甜头是买卖顺当，日子一长，好运就成了自然而然的事儿。”'
  1136.         + '也有人不服气，买了本子回去学，没半个月就嫌麻烦，扔在了墙角。'
  1137.         + '照旧是稀里糊涂过日子，赔了赚了都不知道根由，遇着不顺心就怨命不好。'
  1138.         + '王掌柜后来常跟伙计说，天底下的好运，从来不是天上掉下来的。'
  1139.         + '就像这茶馆的门轴，天天擦着润着，开门就顺当；锈住了，再使劲也推不开。'
  1140.         + '每天半页纸，就是那点润轴的油，看着不起眼，日子久了，就能撑起整份日子的安稳。';
  1141.     var edgeOut = generateEdge({
  1142.         text: demoText,
  1143.         voice: DEFAULT_EDGE_VOICE,
  1144.         rate: '+0%',
  1145.         volume: '+0%',
  1146.         pitch: '+0Hz',
  1147.         output: '/sdcard/edge_tts_demo.mp3'
  1148.     });
  1149.     if (edgeOut) {
  1150.         print.log('    生成成功: ' + edgeOut);
  1151.     } else {
  1152.         print.log('    生成失败');
  1153.     }
  1154.     print.log('');

  1156.     // --- 豆包 TTS 示例（需真实参数，否则会失败） ---
  1157.     print.log('[2] 豆包 TTS 示例（需填入真实参数才能运行）...');
  1158.     var doubaoOut = generateDoubao({
  1159.         cookies: 'sessionid=YOUR_SESSIONID; session_ss=YOUR_SESSION_SS',
  1160.         conversationId: 'YOUR_CONVERSATION_ID',
  1161.         messageId: 'YOUR_MESSAGE_ID',
  1162.         speaker: DEFAULT_DOUBAO_VOICE,
  1163.         speechRate: 1.0,
  1164.         output: '/sdcard/doubao_tts_demo.ogg'
  1165.     });
  1166.     if (doubaoOut) {
  1167.         print.log('    生成成功: ' + doubaoOut);
  1168.     } else {
  1169.         print.log('    预期失败（参数未填）');
  1170.     }

  1172.     // --- 打印音色列表 ---
  1173.     print.log('');
  1174.     print.log('=== 可用音色 ===');
  1175.     print.log('Edge TTS (' + EDGE_VOICES.length + ' 个):');
  1176.     for (var i = 0; i < EDGE_VOICES.length; i++) {
  1177.         print.log('  ' + EDGE_VOICES[i].id + '  [' + EDGE_VOICES[i].name + ']');
  1178.     }
  1179.     print.log('');
  1180.     print.log('豆包 TTS (' + DOUBAO_VOICES.length + ' 个):');
  1181.     for (var j = 0; j < DOUBAO_VOICES.length; j++) {
  1182.         print.log('  ' + DOUBAO_VOICES[j].id + '  [' + DOUBAO_VOICES[j].name + ']');
  1183.     }
  1184. })();

  1186. exit();
复制代码


AIWROK, AIWROK软件
楼主新帖
楼主热帖
untoAIWROK软件自动文字转语音例子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三大主流论坛，有手机验证码收件，邮件收发的功能，支持验证码识别，注册问题识别，多线程任务，自动上传头像，自动激活注册邮件，兼容防注册插件，本站软件原创正版，更新效率最快的原创软件。 『网络推广软件』『自动发帖软件』『 自动发帖』