59 lines
1.4 KiB
JavaScript
59 lines
1.4 KiB
JavaScript
// 初始化io对象
|
||
// import { host } from "@/utils/config.js";
|
||
import io from '@hyoga/uni-socket.io';
|
||
let mq = [];
|
||
let audio = null;
|
||
function makeVoice(msg) {
|
||
audio = new Audio(msg);
|
||
audio.play();
|
||
audio.addEventListener("ended", endCall);
|
||
}
|
||
|
||
function endCall() {
|
||
if (audio) {
|
||
audio.removeEventListener("ended", endCall);
|
||
console.log("消息播放完毕");
|
||
}
|
||
mq.shift();
|
||
if (mq.length) {
|
||
makeVoice(mq[0]);
|
||
}
|
||
}
|
||
|
||
let socket = io('http://7and5.cn' + ":2120");
|
||
// uid 其实就是网点ID，每个网点的ID是唯一的
|
||
// 当socket连接后发送登录请求
|
||
socket.on("connect", function () {
|
||
console.log("socket连接成功");
|
||
mq = [];
|
||
const uid = localStorage.getItem("outlets_id");
|
||
uid && socket.emit("login", uid);
|
||
});
|
||
socket.on("connect_error", function (err) {
|
||
console.log("socket连接失败,尝试重新连接");
|
||
setTimeout(() => {
|
||
socket.connect();
|
||
}, 1000);
|
||
});
|
||
socket.on("disconnect", function () {
|
||
console.log("socket断开连接,重新连接");
|
||
setTimeout(() => {
|
||
socket.connect();
|
||
}, 1000);
|
||
});
|
||
// 当服务端推送来消息时触发
|
||
socket.on("new_msg", function (msg) {
|
||
console.log(msg);
|
||
const data = JSON.parse(msg);
|
||
const path = host + data.data.path;
|
||
mq.push(path);
|
||
if (mq.length === 1) {
|
||
// 当前队列中存在语音播报，不立即播放，存入语音队列
|
||
makeVoice(path);
|
||
}
|
||
});
|
||
|
||
export function reconnect() {
|
||
socket.disconnect();
|
||
}
|