From b72d90cf3e754e4b55cf1d78dfa3ae38a57dd0ab Mon Sep 17 00:00:00 2001
From: TimSpan <cat20201314@163.com>
Date: Tue, 20 Aug 2024 15:27:06 +0800
Subject: [PATCH] Update index.html

---
 public/cw_/index.html | 159 +++++++++++++++++++++---------------------
 1 file changed, 81 insertions(+), 78 deletions(-)

diff --git a/public/cw_/index.html b/public/cw_/index.html
index 95f7d6d5..afccd02d 100644
--- a/public/cw_/index.html
+++ b/public/cw_/index.html
@@ -68,7 +68,7 @@
 
   <script type="text/javascript">
     let stream, audioContext, source, processor;
-
+    var PLAYURL
     window.onload = function () {
       self.player = new Player($("#playerBox"));
       function getParams(key) {
@@ -100,7 +100,7 @@
           data: { ...requestBody }
         }).then(res => {
           // console.log(res);
-          var PLAYURL = res.data.data.videoUrl
+          PLAYURL = res.data.data.videoUrl
           self.player.play(PLAYURL, true, "");
 
         }).catch(function (error) {
@@ -114,6 +114,9 @@
       var socket
       var wsUrl = ''
       document.getElementById("talk-real-server").onclick = function () {
+        wsUrl = 'ws://222.245.132.168:19555/talk/pcma/stream/COWN-ZK9-Z2-C3E/QsTzeGZPrpiCxmlok44NMsdE'
+        self.player.talkUrl = wsUrl;
+        self.player.play(PLAYURL, true, "");
         console.log(1111);
         axios({
           method: 'post',
@@ -122,100 +125,100 @@
         }).then(res => {
           console.log('talk/channel', res);
           // wsUrl = res.data.data.videoUrl
-          wsUrl = 'ws://222.245.132.168:19555/talk/pcma/stream/COWN-ZK9-Z2-C3E/QsTzeGZPrpiCxmlok44NMsdE'
+
           // 创建 WebSocket 连接
-          socket = new WebSocket(wsUrl);
+          // socket = new WebSocket(wsUrl);
 
-          // 监听 WebSocket 连接的打开事件
-          socket.onopen = function (event) {
-            console.log('WebSocket 连接已打开');
-            console.log('socket_______________', socket);
+          // // 监听 WebSocket 连接的打开事件
+          // socket.onopen = function (event) {
+          //   console.log('WebSocket 连接已打开');
+          //   console.log('socket_______________', socket);
 
 
-            // 获取麦克风的音频流
-            if (navigator.mediaDevices && navigator.mediaDevices.getUserMedia) {
-              console.log("支持 getUserMedia");
-            } else {
-              console.error("当前浏览器不支持 getUserMedia");
-            }
-            // 转换格式
-            function encodeALaw(sample) {
-              const ALAW_MAX = 0xFFF; // 12-bit max value
-              const ALAW_BIAS = 0x84; // 132
+          //   // 获取麦克风的音频流
+          //   if (navigator.mediaDevices && navigator.mediaDevices.getUserMedia) {
+          //     console.log("支持 getUserMedia");
+          //   } else {
+          //     console.error("当前浏览器不支持 getUserMedia");
+          //   }
+          //   // 转换格式
+          //   function encodeALaw(sample) {
+          //     const ALAW_MAX = 0xFFF; // 12-bit max value
+          //     const ALAW_BIAS = 0x84; // 132
 
-              let sign = (sample & 0x8000) >> 8; // 提取符号位
-              if (sign !== 0) sample = -sample;  // 如果是负数，取反
+          //     let sign = (sample & 0x8000) >> 8; // 提取符号位
+          //     if (sign !== 0) sample = -sample;  // 如果是负数，取反
 
-              if (sample > ALAW_MAX) sample = ALAW_MAX; // 限制最大值
+          //     if (sample > ALAW_MAX) sample = ALAW_MAX; // 限制最大值
 
-              // A-Law 编码公式
-              let magnitude;
-              if (sample >= 256) {
-                magnitude = (sample >> 8) & 0x7F;
-                magnitude += 8;
-              } else {
-                magnitude = (sample >> 4) & 0x0F;
-              }
+          //     // A-Law 编码公式
+          //     let magnitude;
+          //     if (sample >= 256) {
+          //       magnitude = (sample >> 8) & 0x7F;
+          //       magnitude += 8;
+          //     } else {
+          //       magnitude = (sample >> 4) & 0x0F;
+          //     }
 
-              let aLawByte = sign | magnitude;
+          //     let aLawByte = sign | magnitude;
 
-              return aLawByte ^ 0xD5; // 反转特定位以匹配 A-Law 规范
-            }
+          //     return aLawByte ^ 0xD5; // 反转特定位以匹配 A-Law 规范
+          //   }
 
-            // 示例代码：将 PCM 数据转换为 A-Law 数据
-            navigator.mediaDevices.getUserMedia({ audio: true })
-              .then(audioStream => {
-                stream = audioStream
-                audioContext = new AudioContext({ sampleRate: 8000 });
-                source = audioContext.createMediaStreamSource(stream);
-                processor = audioContext.createScriptProcessor(4096, 1, 1);
+          //   // 示例代码：将 PCM 数据转换为 A-Law 数据
+          //   navigator.mediaDevices.getUserMedia({ audio: true })
+          //     .then(audioStream => {
+          //       stream = audioStream
+          //       audioContext = new AudioContext({ sampleRate: 8000 });
+          //       source = audioContext.createMediaStreamSource(stream);
+          //       processor = audioContext.createScriptProcessor(4096, 1, 1);
 
-                processor.onaudioprocess = function (event) {
-                  const audioData = event.inputBuffer.getChannelData(0);
-                  const int16Array = new Int16Array(audioData.length);
+          //       processor.onaudioprocess = function (event) {
+          //         const audioData = event.inputBuffer.getChannelData(0);
+          //         const int16Array = new Int16Array(audioData.length);
 
-                  // 转换为 16 位 PCM 数据
-                  for (let i = 0; i < audioData.length; i++) {
-                    int16Array[i] = Math.max(-1, Math.min(1, audioData[i])) * 0x7FFF;
-                  }
+          //         // 转换为 16 位 PCM 数据
+          //         for (let i = 0; i < audioData.length; i++) {
+          //           int16Array[i] = Math.max(-1, Math.min(1, audioData[i])) * 0x7FFF;
+          //         }
 
-                  // 将 16 位 PCM 转换为 A-Law 编码
-                  const aLawData = new Uint8Array(int16Array.length);
-                  for (let i = 0; i < int16Array.length; i++) {
-                    aLawData[i] = encodeALaw(int16Array[i]);
-                  }
+          //         // 将 16 位 PCM 转换为 A-Law 编码
+          //         const aLawData = new Uint8Array(int16Array.length);
+          //         for (let i = 0; i < int16Array.length; i++) {
+          //           aLawData[i] = encodeALaw(int16Array[i]);
+          //         }
 
-                  // 分块发送 A-Law 数据，块大小可以为 320, 480, 640 或 960 字节
-                  const blockSize = 320;
-                  for (let j = 0; j < aLawData.length; j += blockSize) {
-                    const chunk = aLawData.slice(j, j + blockSize);
-                    socket.send(chunk.buffer);
-                    console.log('发送音频数据块：', chunk);
-                  }
-                };
+          //         // 分块发送 A-Law 数据，块大小可以为 320, 480, 640 或 960 字节
+          //         const blockSize = 320;
+          //         for (let j = 0; j < aLawData.length; j += blockSize) {
+          //           const chunk = aLawData.slice(j, j + blockSize);
+          //           socket.send(chunk.buffer);
+          //           console.log('发送音频数据块：', chunk);
+          //         }
+          //       };
 
-                source.connect(processor);
-                processor.connect(audioContext.destination);
-              })
-              .catch(error => {
-                console.error('获取音频流失败:', error);
-              });
-          };
+          //       source.connect(processor);
+          //       processor.connect(audioContext.destination);
+          //     })
+          //     .catch(error => {
+          //       console.error('获取音频流失败:', error);
+          //     });
+          // };
 
-          // 监听 WebSocket 收到消息事件
-          socket.onmessage = function (event) {
-            console.log('收到消息:', event.data);
-          };
+          // // 监听 WebSocket 收到消息事件
+          // socket.onmessage = function (event) {
+          //   console.log('收到消息:', event.data);
+          // };
 
-          // 监听 WebSocket 连接关闭事件
-          socket.onclose = function (event) {
-            console.log('WebSocket 连接已关闭');
-          };
+          // // 监听 WebSocket 连接关闭事件
+          // socket.onclose = function (event) {
+          //   console.log('WebSocket 连接已关闭');
+          // };
 
-          // 监听 WebSocket 连接出错事件
-          socket.onerror = function (event) {
-            console.error('WebSocket 错误:', event);
-          };
+          // // 监听 WebSocket 连接出错事件
+          // socket.onerror = function (event) {
+          //   console.error('WebSocket 错误:', event);
+          // };
 
         }).catch(function (error) {
           console.log(error)