Compare commits
8 Commits
de7b44aa34
...
new-race-m
| Author | SHA1 | Date | |
|---|---|---|---|
| 8c0a24fd44 | |||
| a151f2f293 | |||
| 4352fffde7 | |||
| 74ca0bb3d7 | |||
| f44c22c594 | |||
| 4518c66a65 | |||
| 72a3443ff1 | |||
| 131d3f70a2 |
23
src/App.vue
23
src/App.vue
@@ -21,10 +21,7 @@
|
|||||||
} = storeToRefs(store);
|
} = storeToRefs(store);
|
||||||
const {
|
const {
|
||||||
updateUser,
|
updateUser,
|
||||||
updateOnline,
|
updateOnline
|
||||||
updateDevice,
|
|
||||||
updateGame,
|
|
||||||
updateRoomNumber
|
|
||||||
} = store;
|
} = store;
|
||||||
|
|
||||||
watch(
|
watch(
|
||||||
@@ -49,22 +46,6 @@
|
|||||||
updateUser(value);
|
updateUser(value);
|
||||||
}
|
}
|
||||||
|
|
||||||
function onSessionKickedOut() {
|
|
||||||
uni.removeStorageSync(
|
|
||||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
|
||||||
);
|
|
||||||
updateUser();
|
|
||||||
updateDevice("", "");
|
|
||||||
updateOnline(false);
|
|
||||||
updateGame(false, "");
|
|
||||||
updateRoomNumber("");
|
|
||||||
uni.showModal({
|
|
||||||
title: "提示",
|
|
||||||
content: "账号已在其他设备登录",
|
|
||||||
showCancel: false,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async function emitUpdateOnline() {
|
async function emitUpdateOnline() {
|
||||||
const data = await getDeviceBatteryAPI();
|
const data = await getDeviceBatteryAPI();
|
||||||
updateOnline(data.online);
|
updateOnline(data.online);
|
||||||
@@ -84,7 +65,6 @@
|
|||||||
onShow(() => {
|
onShow(() => {
|
||||||
uni.$on("update-user", emitUpdateUser);
|
uni.$on("update-user", emitUpdateUser);
|
||||||
uni.$on("update-online", emitUpdateOnline);
|
uni.$on("update-online", emitUpdateOnline);
|
||||||
uni.$on("session-kicked-out", onSessionKickedOut);
|
|
||||||
const token = uni.getStorageSync(
|
const token = uni.getStorageSync(
|
||||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
||||||
);
|
);
|
||||||
@@ -97,7 +77,6 @@
|
|||||||
onHide(() => {
|
onHide(() => {
|
||||||
uni.$off("update-user", emitUpdateUser);
|
uni.$off("update-user", emitUpdateUser);
|
||||||
uni.$off("update-online", emitUpdateOnline);
|
uni.$off("update-online", emitUpdateOnline);
|
||||||
uni.$off("session-kicked-out", onSessionKickedOut);
|
|
||||||
websocket.closeWebSocket();
|
websocket.closeWebSocket();
|
||||||
});
|
});
|
||||||
</script>
|
</script>
|
||||||
|
|||||||
@@ -46,8 +46,6 @@ function request(method, url, data = {}) {
|
|||||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
||||||
);
|
);
|
||||||
uni.$emit("update-user");
|
uni.$emit("update-user");
|
||||||
reject({ type: "AUTH_INVALID", message });
|
|
||||||
return;
|
|
||||||
}
|
}
|
||||||
if (message === "ROOM_FULL") {
|
if (message === "ROOM_FULL") {
|
||||||
resolve({full: true});
|
resolve({full: true});
|
||||||
|
|||||||
@@ -1,4 +1,6 @@
|
|||||||
export const audioFils = {
|
export const audioFils = {
|
||||||
|
tententen: "https://static.shelingxingqiu.com/shootmini/static/audio/tententen.mp3",
|
||||||
|
点击按钮: "https://static.shelingxingqiu.com/shootmini/static/audio/%E7%82%B9%E5%87%BB%E6%8C%89%E9%92%AE.mp3",
|
||||||
"20CM全环靶": "https://static.shelingxingqiu.com/shootmini/static/audio/20CM%E5%85%A8%E7%8E%AF%E9%9D%B6-%E6%97%A0%E6%95%88.mp3",
|
"20CM全环靶": "https://static.shelingxingqiu.com/shootmini/static/audio/20CM%E5%85%A8%E7%8E%AF%E9%9D%B6-%E6%97%A0%E6%95%88.mp3",
|
||||||
"40CM全环靶": "https://static.shelingxingqiu.com/shootmini/static/audio/40CM%E5%85%A8%E7%8E%AF%E9%9D%B6-%E6%97%A0%E6%95%88.mp3",
|
"40CM全环靶": "https://static.shelingxingqiu.com/shootmini/static/audio/40CM%E5%85%A8%E7%8E%AF%E9%9D%B6-%E6%97%A0%E6%95%88.mp3",
|
||||||
// 激光已校准:
|
// 激光已校准:
|
||||||
|
|||||||
@@ -31,7 +31,7 @@ function handleTabClick(index) {
|
|||||||
v-for="(tab, index) in tabs"
|
v-for="(tab, index) in tabs"
|
||||||
:key="index"
|
:key="index"
|
||||||
class="tab-item"
|
class="tab-item"
|
||||||
@click="handleTabClick(index)"
|
@click="$clickSound(() => handleTabClick(index))"
|
||||||
:style="{
|
:style="{
|
||||||
width: index === 1 ? '36%' : '20%',
|
width: index === 1 ? '36%' : '20%',
|
||||||
}"
|
}"
|
||||||
|
|||||||
@@ -206,7 +206,7 @@ const goCalibration = async () => {
|
|||||||
<button hover-class="none" @click="() => (showHint = false)">
|
<button hover-class="none" @click="() => (showHint = false)">
|
||||||
取消
|
取消
|
||||||
</button>
|
</button>
|
||||||
<button hover-class="none" @click="cancelMatching">确认</button>
|
<button hover-class="none" @click="$clickSound(cancelMatching)">确认</button>
|
||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<view v-if="hintType === 4" class="tip-content">
|
<view v-if="hintType === 4" class="tip-content">
|
||||||
|
|||||||
@@ -112,7 +112,7 @@ const createRoom = debounce(async () => {
|
|||||||
<text>40厘米全环靶</text>
|
<text>40厘米全环靶</text>
|
||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<SButton :onClick="createRoom">创建房间</SButton>
|
<SButton :onClick="() => $clickSound(createRoom)">创建房间</SButton>
|
||||||
</view>
|
</view>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
|
|||||||
@@ -65,8 +65,12 @@ async function onReceiveMessage(message) {
|
|||||||
audioManager.play("比赛结束", false);
|
audioManager.play("比赛结束", false);
|
||||||
} else if (type === MESSAGETYPESV2.ShootResult) {
|
} else if (type === MESSAGETYPESV2.ShootResult) {
|
||||||
if (melee.value && current.playerId !== user.value.id) return;
|
if (melee.value && current.playerId !== user.value.id) return;
|
||||||
// 从 indexMap 按当前用户 id 取已射箭数,由后端维护准确值,不在前端自增
|
// 从 indexMap 按当前用户 id 取已射箭数,由后端维护准确值,不在前端自增。
|
||||||
if (current.playerId === user.value.id) currentShot.value = current.indexMap?.[user.value.id] ?? currentShot.value;
|
// 注意:后端在 ShootResult 中会将 playerId 重置为 0(无当前射手),
|
||||||
|
// 因此不能依赖 playerId === user.id 判断,改为直接读取 indexMap[user.id]。
|
||||||
|
// indexMap[user.id] 只在本人射箭后才增加,队友射箭时该值不变,逻辑等价且更准确。
|
||||||
|
const myShot = current.indexMap?.[user.value.id];
|
||||||
|
if (myShot !== undefined) currentShot.value = myShot;
|
||||||
if (message.shootData) {
|
if (message.shootData) {
|
||||||
let key = [];
|
let key = [];
|
||||||
key.push(
|
key.push(
|
||||||
|
|||||||
@@ -123,7 +123,7 @@ onBeforeUnmount(() => {
|
|||||||
</text>
|
</text>
|
||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<button hover-class="none" @click="stopMatch">取消匹配</button>
|
<button hover-class="none" @click="$clickSound(stopMatch)">取消匹配</button>
|
||||||
</view>
|
</view>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
|
|||||||
13
src/main.js
13
src/main.js
@@ -2,12 +2,25 @@ import { createSSRApp } from 'vue'
|
|||||||
import { createPinia } from 'pinia'
|
import { createPinia } from 'pinia'
|
||||||
import piniaPluginPersistedstate from 'pinia-plugin-persistedstate'
|
import piniaPluginPersistedstate from 'pinia-plugin-persistedstate'
|
||||||
import App from './App.vue'
|
import App from './App.vue'
|
||||||
|
import audioManager from './audioManager'
|
||||||
|
|
||||||
export function createApp() {
|
export function createApp() {
|
||||||
const app = createSSRApp(App)
|
const app = createSSRApp(App)
|
||||||
const pinia = createPinia()
|
const pinia = createPinia()
|
||||||
pinia.use(piniaPluginPersistedstate)
|
pinia.use(piniaPluginPersistedstate)
|
||||||
app.use(pinia)
|
app.use(pinia)
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 全局点击音效工具函数,用于在任意按钮/元素点击时自动播放音效。
|
||||||
|
* 用法:@click="$clickSound(handler)" 或 @click="$clickSound(() => doSomething())"
|
||||||
|
* @param {Function} handler - 原始点击回调函数(可选,点击时直接调用)
|
||||||
|
* @param {string} [soundKey='点击按钮'] - audioManager 中的音效 key
|
||||||
|
*/
|
||||||
|
app.config.globalProperties.$clickSound = (handler, soundKey = '点击按钮') => {
|
||||||
|
audioManager.play(soundKey);
|
||||||
|
if (typeof handler === 'function') handler();
|
||||||
|
};
|
||||||
|
|
||||||
return {
|
return {
|
||||||
app
|
app
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -443,7 +443,7 @@ onBeforeUnmount(() => {
|
|||||||
<PlayerSeats v-if="room.battleType === 2" :total="room.count || 10" :players="players"
|
<PlayerSeats v-if="room.battleType === 2" :total="room.count || 10" :players="players"
|
||||||
:removePlayer="removePlayer" :isOwner="owner.id === user.id" />
|
:removePlayer="removePlayer" :isOwner="owner.id === user.id" />
|
||||||
<view>
|
<view>
|
||||||
<SButton :disabled="!canClick" :onClick="getReady">
|
<SButton :disabled="!canClick" :onClick="() => $clickSound(getReady)">
|
||||||
{{
|
{{
|
||||||
allReady.value
|
allReady.value
|
||||||
? "即将进入对局..."
|
? "即将进入对局..."
|
||||||
|
|||||||
@@ -141,7 +141,7 @@ onLoad(async (options) => {
|
|||||||
<image src="../static/founded-room.png" mode="widthFix" />
|
<image src="../static/founded-room.png" mode="widthFix" />
|
||||||
<view>
|
<view>
|
||||||
<input placeholder="输入房间号" v-model="roomNumber" placeholder-style="color: #ccc" />
|
<input placeholder="输入房间号" v-model="roomNumber" placeholder-style="color: #ccc" />
|
||||||
<view @click="enterRoom(roomNumber)">进入房间</view>
|
<view @click="$clickSound(() => enterRoom(roomNumber))">进入房间</view>
|
||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<view class="create-room">
|
<view class="create-room">
|
||||||
@@ -155,7 +155,7 @@ onLoad(async (options) => {
|
|||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<view>
|
<view>
|
||||||
<SButton width="80%" :rounded="30" :onClick="onCreateRoom">
|
<SButton width="80%" :rounded="30" :onClick="() => $clickSound(onCreateRoom)">
|
||||||
创建约战房
|
创建约战房
|
||||||
</SButton>
|
</SButton>
|
||||||
</view>
|
</view>
|
||||||
|
|||||||
@@ -68,29 +68,28 @@ onShow(async () => {
|
|||||||
const token = uni.getStorageSync(`${env}_token`);
|
const token = uni.getStorageSync(`${env}_token`);
|
||||||
|
|
||||||
if (!user.value.id && !token) {
|
if (!user.value.id && !token) {
|
||||||
// showModal.value = true;
|
try {
|
||||||
// try {
|
const wxResult = await uni.login({provider: "weixin"});
|
||||||
// const wxResult = await uni.login({provider: "weixin"});
|
const bindResult = await checkUserBindAPI(wxResult.code);
|
||||||
// const bindResult = await checkUserBindAPI(wxResult.code);
|
if (bindResult.binded) {
|
||||||
// if (bindResult.binded) {
|
const newResult = await uni.login({provider: "weixin"});
|
||||||
// const newResult = await uni.login({provider: "weixin"});
|
const silentResult = await silentLoginAPI(newResult.code);
|
||||||
// const silentResult = await silentLoginAPI(newResult.code);
|
if (silentResult.user) updateUser(silentResult.user);
|
||||||
// if (silentResult.user) updateUser(silentResult.user);
|
const devices = await getMyDevicesAPI();
|
||||||
// const devices = await getMyDevicesAPI();
|
if (devices.bindings && devices.bindings.length) {
|
||||||
// if (devices.bindings && devices.bindings.length) {
|
updateDevice(
|
||||||
// updateDevice(
|
devices.bindings[0].deviceId,
|
||||||
// devices.bindings[0].deviceId,
|
devices.bindings[0].deviceName
|
||||||
// devices.bindings[0].deviceName
|
);
|
||||||
// );
|
const data = await getDeviceBatteryAPI();
|
||||||
// const data = await getDeviceBatteryAPI();
|
updateOnline(data.online);
|
||||||
// updateOnline(data.online);
|
}
|
||||||
// }
|
} else {
|
||||||
// } else {
|
showModal.value = true;
|
||||||
// showModal.value = true;
|
}
|
||||||
// }
|
} catch (e) {
|
||||||
// } catch (e) {
|
console.log("检查绑定状态失败", e);
|
||||||
// console.log("检查绑定状态失败", e);
|
}
|
||||||
// }
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const promises = [getScoreRankList(undefined, 1, 10)];
|
const promises = [getScoreRankList(undefined, 1, 10)];
|
||||||
@@ -179,7 +178,7 @@ onShareTimeline(() => {
|
|||||||
v-else
|
v-else
|
||||||
src="https://static.shelingxingqiu.com/attachment/2026-01-04/dffohwtk1gwh0xfa6h.png"
|
src="https://static.shelingxingqiu.com/attachment/2026-01-04/dffohwtk1gwh0xfa6h.png"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@click="() => toPage('/pages/my-device')"
|
@click="$clickSound(() => toPage('/pages/my-device'))"
|
||||||
/>
|
/>
|
||||||
<block v-if="user.id">
|
<block v-if="user.id">
|
||||||
<text v-if="!device.deviceId">绑定我的智能弓</text>
|
<text v-if="!device.deviceId">绑定我的智能弓</text>
|
||||||
@@ -197,10 +196,10 @@ onShareTimeline(() => {
|
|||||||
</BubbleTip>
|
</BubbleTip>
|
||||||
</view>
|
</view>
|
||||||
<view class="play-card">
|
<view class="play-card">
|
||||||
<view @click="() => toPage('/pages/practise')">
|
<view @click="$clickSound(() => toPage('/pages/practise'))">
|
||||||
<image src="../static/my-practise.png" mode="widthFix"/>
|
<image src="../static/my-practise.png" mode="widthFix"/>
|
||||||
</view>
|
</view>
|
||||||
<view @click="() => toPage('/pages/friend-battle')">
|
<view @click="$clickSound(() => toPage('/pages/friend-battle'))">
|
||||||
<image src="../static/friend-battle.png" mode="widthFix"/>
|
<image src="../static/friend-battle.png" mode="widthFix"/>
|
||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
@@ -212,7 +211,7 @@ onShareTimeline(() => {
|
|||||||
/>
|
/>
|
||||||
<button
|
<button
|
||||||
class="into-btn"
|
class="into-btn"
|
||||||
@click="() => toPage('/pages/ranking')"
|
@click="$clickSound(() => toPage('/pages/ranking'))"
|
||||||
hover-class="none"
|
hover-class="none"
|
||||||
></button>
|
></button>
|
||||||
<view class="ranking-players" @click="toRankListPage">
|
<view class="ranking-players" @click="toRankListPage">
|
||||||
@@ -476,7 +475,7 @@ onShareTimeline(() => {
|
|||||||
|
|
||||||
.top-theme {
|
.top-theme {
|
||||||
position: absolute;
|
position: absolute;
|
||||||
display: none;
|
display: flex;
|
||||||
align-items: center;
|
align-items: center;
|
||||||
justify-content: center;
|
justify-content: center;
|
||||||
width: 100%;
|
width: 100%;
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<script setup>
|
<script setup>
|
||||||
import { ref, onMounted, onBeforeUnmount, watch } from "vue";
|
import { ref, onMounted, onBeforeUnmount, watch, nextTick } from "vue";
|
||||||
import { onLoad, onShow, onHide } from "@dcloudio/uni-app";
|
import { onLoad, onShow, onHide } from "@dcloudio/uni-app";
|
||||||
import Container from "@/components/Container.vue";
|
import Container from "@/components/Container.vue";
|
||||||
import BowTarget from "@/components/BowTarget.vue";
|
import BowTarget from "@/components/BowTarget.vue";
|
||||||
@@ -32,6 +32,8 @@ const halfTimeTip = ref(false);
|
|||||||
const halfRest = ref(false);
|
const halfRest = ref(false);
|
||||||
/** 控制设备离线提示弹窗的显示状态 */
|
/** 控制设备离线提示弹窗的显示状态 */
|
||||||
const showOfflineModal = ref(false);
|
const showOfflineModal = ref(false);
|
||||||
|
/** 记录每位玩家当前半场连续 X 环数,key 为 playerId,用于触发 tententen 音效 */
|
||||||
|
const xRingStreaks = ref({});
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 监听设备在线状态,大乱斗比赛进行中设备离线时弹窗提示用户
|
* 监听设备在线状态,大乱斗比赛进行中设备离线时弹窗提示用户
|
||||||
@@ -120,6 +122,28 @@ onLoad(async (options) => {
|
|||||||
// });
|
// });
|
||||||
});
|
});
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检测指定玩家连续 X 环是否达到 3 箭,达到则在环数播报入队后追加 tententen 音效
|
||||||
|
* @param {number|string} playerId - 本次射手的 ID(大乱斗中 ShootResult 保留 playerId)
|
||||||
|
* @param {boolean} isXRing - 本次射击是否为 X 环
|
||||||
|
*/
|
||||||
|
function checkAndPlayTententen(playerId, isXRing) {
|
||||||
|
if (!playerId) return;
|
||||||
|
const id = parseInt(playerId);
|
||||||
|
if (isXRing) {
|
||||||
|
xRingStreaks.value[id] = (xRingStreaks.value[id] || 0) + 1;
|
||||||
|
// 同一玩家连续 3 箭均为 X 环,追加到环数音效队列尾部播放
|
||||||
|
if (xRingStreaks.value[id] >= 3) {
|
||||||
|
xRingStreaks.value[id] = 0;
|
||||||
|
// nextTick 确保 HeaderProgress 的环数播报已入队后再追加 tententen,避免播放顺序颠倒
|
||||||
|
nextTick(() => audioManager.play("tententen", false));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// 非 X 环则重置该玩家的连续计数
|
||||||
|
xRingStreaks.value[id] = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async function onReceiveMessage(msg) {
|
async function onReceiveMessage(msg) {
|
||||||
if (Array.isArray(msg)) return;
|
if (Array.isArray(msg)) return;
|
||||||
if (msg.type === MESSAGETYPESV2.BattleStart) {
|
if (msg.type === MESSAGETYPESV2.BattleStart) {
|
||||||
@@ -127,7 +151,28 @@ async function onReceiveMessage(msg) {
|
|||||||
halfRest.value = false;
|
halfRest.value = false;
|
||||||
recoverData(msg);
|
recoverData(msg);
|
||||||
} else if (msg.type === MESSAGETYPESV2.ShootResult) {
|
} else if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||||
|
// 更新前快照各玩家本轮已射箭数,用于事后识别本次射手
|
||||||
|
const curRound = playersScores.value[playersScores.value.length - 1] || {};
|
||||||
|
const prevCounts = {};
|
||||||
|
for (const pid of Object.keys(curRound)) {
|
||||||
|
prevCounts[pid] = (curRound[pid] || []).length;
|
||||||
|
}
|
||||||
recoverData(msg);
|
recoverData(msg);
|
||||||
|
// 对比更新后数据找出箭数增加的玩家(即本次射手),并读取其最新箭的 ring 数据
|
||||||
|
const newRound = playersScores.value[playersScores.value.length - 1] || {};
|
||||||
|
let shooterId = null;
|
||||||
|
let isXRing = false;
|
||||||
|
for (const pid of Object.keys(newRound)) {
|
||||||
|
const newLen = (newRound[pid] || []).length;
|
||||||
|
if (newLen > (prevCounts[pid] || 0)) {
|
||||||
|
shooterId = parseInt(pid);
|
||||||
|
const shot = newRound[pid][newLen - 1];
|
||||||
|
isXRing = !!(shot?.ringX && shot?.ring);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// 检测同一玩家三箭全 X 环,触发 tententen 音效
|
||||||
|
checkAndPlayTententen(shooterId, isXRing);
|
||||||
} else if (msg.type === MESSAGETYPESV2.HalfRest) {
|
} else if (msg.type === MESSAGETYPESV2.HalfRest) {
|
||||||
halfTimeTip.value = true;
|
halfTimeTip.value = true;
|
||||||
halfRest.value = true;
|
halfRest.value = true;
|
||||||
|
|||||||
@@ -130,7 +130,7 @@ onShow(() => {
|
|||||||
<template>
|
<template>
|
||||||
<Container title="弓箭绑定">
|
<Container title="弓箭绑定">
|
||||||
<view v-if="!device.deviceId" class="scan-code">
|
<view v-if="!device.deviceId" class="scan-code">
|
||||||
<button hover-class="none" @click="handleScan">
|
<button hover-class="none" @click="$clickSound(handleScan)">
|
||||||
<image src="../static/scan.png" mode="widthFix" />
|
<image src="../static/scan.png" mode="widthFix" />
|
||||||
</button>
|
</button>
|
||||||
<button hover-class="none" @click="showTip = true">
|
<button hover-class="none" @click="showTip = true">
|
||||||
@@ -269,7 +269,7 @@ onShow(() => {
|
|||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<view :style="{ marginTop: '240rpx' }">
|
<view :style="{ marginTop: '240rpx' }">
|
||||||
<SButton :onClick="unbindDevice" width="80vw" :rounded="40"
|
<SButton :onClick="() => $clickSound(unbindDevice)" width="80vw" :rounded="40"
|
||||||
>解绑</SButton
|
>解绑</SButton
|
||||||
>
|
>
|
||||||
</view>
|
</view>
|
||||||
|
|||||||
@@ -114,7 +114,7 @@ onMounted(async () => {
|
|||||||
/>
|
/>
|
||||||
</view>
|
</view>
|
||||||
<template #bottom>
|
<template #bottom>
|
||||||
<SButton :rounded="50" :onClick="toEditPage">下一步</SButton>
|
<SButton :rounded="50" :onClick="() => $clickSound(toEditPage)">下一步</SButton>
|
||||||
</template>
|
</template>
|
||||||
</Container>
|
</Container>
|
||||||
</template>
|
</template>
|
||||||
|
|||||||
@@ -198,7 +198,7 @@ onLoad((options) => {
|
|||||||
</ScreenHint2>
|
</ScreenHint2>
|
||||||
</view>
|
</view>
|
||||||
<template #bottom>
|
<template #bottom>
|
||||||
<SButton :rounded="50" :onClick="onSubmit">
|
<SButton :rounded="50" :onClick="() => $clickSound(onSubmit)">
|
||||||
{{ currentGroup === groups ? "保存并查看分析" : "下一组" }}
|
{{ currentGroup === groups ? "保存并查看分析" : "下一组" }}
|
||||||
</SButton>
|
</SButton>
|
||||||
</template>
|
</template>
|
||||||
|
|||||||
@@ -329,10 +329,10 @@ onShareTimeline(() => {
|
|||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
<view>
|
<view>
|
||||||
<button hover-class="none" @click="toRecordPage" class="image-btn">
|
<button hover-class="none" @click="$clickSound(toRecordPage)" class="image-btn">
|
||||||
<image src="../static/record-btn.png" mode="widthFix" />
|
<image src="../static/record-btn.png" mode="widthFix" />
|
||||||
</button>
|
</button>
|
||||||
<button hover-class="none" @click="startScoring" class="image-btn">
|
<button hover-class="none" @click="$clickSound(startScoring)" class="image-btn">
|
||||||
<image src="../static/start-scoring.png" mode="widthFix" />
|
<image src="../static/start-scoring.png" mode="widthFix" />
|
||||||
</button>
|
</button>
|
||||||
</view>
|
</view>
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<script setup>
|
<script setup>
|
||||||
import { ref, onMounted, onBeforeUnmount } from "vue";
|
import { ref, onMounted, onBeforeUnmount, nextTick } from "vue";
|
||||||
import { onLoad } from "@dcloudio/uni-app";
|
import { onLoad } from "@dcloudio/uni-app";
|
||||||
import Container from "@/components/Container.vue";
|
import Container from "@/components/Container.vue";
|
||||||
import ShootProgress from "@/components/ShootProgress.vue";
|
import ShootProgress from "@/components/ShootProgress.vue";
|
||||||
@@ -31,6 +31,8 @@ const { user } = storeToRefs(store);
|
|||||||
const start = ref(false);
|
const start = ref(false);
|
||||||
const scores = ref([]);
|
const scores = ref([]);
|
||||||
const total = 12;
|
const total = 12;
|
||||||
|
/** 当前练习中连续 X 环计数,用于触发 tententen 音效 */
|
||||||
|
const xRingStreak = ref(0);
|
||||||
const practiseResult = ref({});
|
const practiseResult = ref({});
|
||||||
const practiseId = ref("");
|
const practiseId = ref("");
|
||||||
const showGuide = ref(false);
|
const showGuide = ref(false);
|
||||||
@@ -46,6 +48,7 @@ onLoad((options) => {
|
|||||||
const onReady = async () => {
|
const onReady = async () => {
|
||||||
await startPractiseAPI();
|
await startPractiseAPI();
|
||||||
scores.value = [];
|
scores.value = [];
|
||||||
|
xRingStreak.value = 0; // 新一局开始,重置 X 环连续计数
|
||||||
start.value = true;
|
start.value = true;
|
||||||
audioManager.play("练习开始");
|
audioManager.play("练习开始");
|
||||||
};
|
};
|
||||||
@@ -55,9 +58,33 @@ const onOver = async () => {
|
|||||||
start.value = false;
|
start.value = false;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检测连续 X 环是否达到 3 箭,达到则播放 tententen 音效
|
||||||
|
* @param {boolean} isXRing - 本次射击是否为 X 环
|
||||||
|
*/
|
||||||
|
function checkAndPlayTententen(isXRing) {
|
||||||
|
if (isXRing) {
|
||||||
|
xRingStreak.value += 1;
|
||||||
|
// 连续 3 箭均为 X 环,在环数播报入队后追加 tententen,避免播放顺序颠倒
|
||||||
|
if (xRingStreak.value >= 3) {
|
||||||
|
xRingStreak.value = 0;
|
||||||
|
nextTick(() => audioManager.play("tententen", false));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// 非 X 环则重置连续计数
|
||||||
|
xRingStreak.value = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async function onReceiveMessage(msg) {
|
async function onReceiveMessage(msg) {
|
||||||
if (msg.type === MESSAGETYPESV2.ShootResult) {
|
if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||||
|
const prevLen = scores.value.length;
|
||||||
scores.value = msg.details;
|
scores.value = msg.details;
|
||||||
|
// 有新箭时取最后一箭判断是否 X 环并检测连续计数
|
||||||
|
if (scores.value.length > prevLen) {
|
||||||
|
const latestArrow = scores.value[scores.value.length - 1];
|
||||||
|
checkAndPlayTententen(!!(latestArrow?.ringX && latestArrow?.ring));
|
||||||
|
}
|
||||||
} else if (msg.type === MESSAGETYPESV2.BattleEnd) {
|
} else if (msg.type === MESSAGETYPESV2.BattleEnd) {
|
||||||
// setTimeout(onOver, 1500);
|
// setTimeout(onOver, 1500);
|
||||||
}
|
}
|
||||||
@@ -74,6 +101,7 @@ async function onComplete() {
|
|||||||
practiseResult.value = {};
|
practiseResult.value = {};
|
||||||
start.value = false;
|
start.value = false;
|
||||||
scores.value = [];
|
scores.value = [];
|
||||||
|
xRingStreak.value = 0; // 重新开始练习,重置 X 环连续计数
|
||||||
const result = await createPractiseAPI(total, 120);
|
const result = await createPractiseAPI(total, 120);
|
||||||
if (result) practiseId.value = result.id;
|
if (result) practiseId.value = result.id;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
<script setup>
|
<script setup>
|
||||||
import { ref, onMounted, onBeforeUnmount } from "vue";
|
import { ref, onMounted, onBeforeUnmount, nextTick } from "vue";
|
||||||
import Container from "@/components/Container.vue";
|
import Container from "@/components/Container.vue";
|
||||||
import ShootProgress from "@/components/ShootProgress.vue";
|
import ShootProgress from "@/components/ShootProgress.vue";
|
||||||
import BowTarget from "@/components/BowTarget.vue";
|
import BowTarget from "@/components/BowTarget.vue";
|
||||||
@@ -31,6 +31,8 @@ const { user } = storeToRefs(store);
|
|||||||
const start = ref(false);
|
const start = ref(false);
|
||||||
const scores = ref([]);
|
const scores = ref([]);
|
||||||
const total = 36;
|
const total = 36;
|
||||||
|
/** 当前练习中连续 X 环计数,用于触发 tententen 音效 */
|
||||||
|
const xRingStreak = ref(0);
|
||||||
const practiseResult = ref({});
|
const practiseResult = ref({});
|
||||||
const practiseId = ref("");
|
const practiseId = ref("");
|
||||||
const showGuide = ref(false);
|
const showGuide = ref(false);
|
||||||
@@ -45,6 +47,7 @@ onLoad((options) => {
|
|||||||
const onReady = async () => {
|
const onReady = async () => {
|
||||||
await startPractiseAPI();
|
await startPractiseAPI();
|
||||||
scores.value = [];
|
scores.value = [];
|
||||||
|
xRingStreak.value = 0; // 新一局开始,重置 X 环连续计数
|
||||||
start.value = true;
|
start.value = true;
|
||||||
audioManager.play("练习开始");
|
audioManager.play("练习开始");
|
||||||
};
|
};
|
||||||
@@ -54,9 +57,33 @@ const onOver = async () => {
|
|||||||
start.value = false;
|
start.value = false;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检测连续 X 环是否达到 3 箭,达到则播放 tententen 音效
|
||||||
|
* @param {boolean} isXRing - 本次射击是否为 X 环
|
||||||
|
*/
|
||||||
|
function checkAndPlayTententen(isXRing) {
|
||||||
|
if (isXRing) {
|
||||||
|
xRingStreak.value += 1;
|
||||||
|
// 连续 3 箭均为 X 环,在环数播报入队后追加 tententen,避免播放顺序颠倒
|
||||||
|
if (xRingStreak.value >= 3) {
|
||||||
|
xRingStreak.value = 0;
|
||||||
|
nextTick(() => audioManager.play("tententen", false));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// 非 X 环则重置连续计数
|
||||||
|
xRingStreak.value = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async function onReceiveMessage(msg) {
|
async function onReceiveMessage(msg) {
|
||||||
if (msg.type === MESSAGETYPESV2.ShootResult) {
|
if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||||
|
const prevLen = scores.value.length;
|
||||||
scores.value = msg.details;
|
scores.value = msg.details;
|
||||||
|
// 有新箭时取最后一箭判断是否 X 环并检测连续计数
|
||||||
|
if (scores.value.length > prevLen) {
|
||||||
|
const latestArrow = scores.value[scores.value.length - 1];
|
||||||
|
checkAndPlayTententen(!!(latestArrow?.ringX && latestArrow?.ring));
|
||||||
|
}
|
||||||
} else if (msg.type === MESSAGETYPESV2.BattleEnd) {
|
} else if (msg.type === MESSAGETYPESV2.BattleEnd) {
|
||||||
setTimeout(onOver, 1500);
|
setTimeout(onOver, 1500);
|
||||||
}
|
}
|
||||||
@@ -89,7 +116,8 @@ async function onComplete() {
|
|||||||
practiseResult.value = {};
|
practiseResult.value = {};
|
||||||
start.value = false;
|
start.value = false;
|
||||||
scores.value = [];
|
scores.value = [];
|
||||||
const result = await createPractiseAPI(total, 3600);
|
xRingStreak.value = 0; // 重新开始练习,重置 X 环连续计数
|
||||||
|
const result = await createPractiseAPI(total, 360);
|
||||||
if (result) practiseId.value = result.id;
|
if (result) practiseId.value = result.id;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -105,7 +133,7 @@ onMounted(async () => {
|
|||||||
});
|
});
|
||||||
uni.$on("socket-inbox", onReceiveMessage);
|
uni.$on("socket-inbox", onReceiveMessage);
|
||||||
uni.$on("share-image", onClickShare);
|
uni.$on("share-image", onClickShare);
|
||||||
const result = await createPractiseAPI(total, 3600, targetType.value);
|
const result = await createPractiseAPI(total, 360, targetType.value);
|
||||||
if (result) practiseId.value = result.id;
|
if (result) practiseId.value = result.id;
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -132,7 +160,7 @@ onBeforeUnmount(() => {
|
|||||||
<ShootProgress
|
<ShootProgress
|
||||||
:tips="`请连续射${total}支箭`"
|
:tips="`请连续射${total}支箭`"
|
||||||
:start="start"
|
:start="start"
|
||||||
:total="3600"
|
:total="360"
|
||||||
:onStop="onOver"
|
:onStop="onOver"
|
||||||
/>
|
/>
|
||||||
<view class="user-row">
|
<view class="user-row">
|
||||||
|
|||||||
@@ -281,27 +281,27 @@ onShow(async () => {
|
|||||||
<image
|
<image
|
||||||
src="../static/rank/battle1v1.svg"
|
src="../static/rank/battle1v1.svg"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@click.stop="() => toMatchPage(1, 2)"
|
@click.stop="$clickSound(() => toMatchPage(1, 2))"
|
||||||
/>
|
/>
|
||||||
<image
|
<image
|
||||||
src="../static/rank/battle2v2.svg"
|
src="../static/rank/battle2v2.svg"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@click.stop="() => toMatchPage(2, 4)"
|
@click.stop="$clickSound(() => toMatchPage(2, 4))"
|
||||||
/>
|
/>
|
||||||
<image
|
<image
|
||||||
src="../static/rank/battle3v3.svg"
|
src="../static/rank/battle3v3.svg"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@click.stop="() => toMatchPage(3, 6)"
|
@click.stop="$clickSound(() => toMatchPage(3, 6))"
|
||||||
/>
|
/>
|
||||||
<image
|
<image
|
||||||
src="../static/rank/battle5.svg"
|
src="../static/rank/battle5.svg"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@click.stop="() => toMatchPage(4, 5)"
|
@click.stop="$clickSound(() => toMatchPage(4, 5))"
|
||||||
/>
|
/>
|
||||||
<image
|
<image
|
||||||
src="../static/rank/battle10.svg"
|
src="../static/rank/battle10.svg"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@click.stop="() => toMatchPage(5, 10)"
|
@click.stop="$clickSound(() => toMatchPage(5, 10))"
|
||||||
/>
|
/>
|
||||||
</view>
|
</view>
|
||||||
</view>
|
</view>
|
||||||
@@ -323,7 +323,6 @@ onShow(async () => {
|
|||||||
>
|
>
|
||||||
<text>{{ seasonName }}</text>
|
<text>{{ seasonName }}</text>
|
||||||
<image
|
<image
|
||||||
class="triangle-icon"
|
|
||||||
v-show="seasonData.length > 1"
|
v-show="seasonData.length > 1"
|
||||||
src="../static/rank/triangle.png"
|
src="../static/rank/triangle.png"
|
||||||
mode="widthFix"
|
mode="widthFix"
|
||||||
@@ -593,7 +592,6 @@ onShow(async () => {
|
|||||||
.ranking-season > image {
|
.ranking-season > image {
|
||||||
width: 12px;
|
width: 12px;
|
||||||
height: 12px;
|
height: 12px;
|
||||||
transform: rotateX(180deg);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
.ranking-season > text {
|
.ranking-season > text {
|
||||||
@@ -809,18 +807,18 @@ onShow(async () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
.season-list {
|
.season-list {
|
||||||
background-color: rgba(0, 0, 0, 0.8);
|
background-color: #000c;
|
||||||
border-radius: 15px;
|
border-radius: 15px;
|
||||||
color: #fff;
|
color: #fff;
|
||||||
font-size: 12px;
|
font-size: 12px;
|
||||||
padding: 12px 0;
|
padding: 5px 0;
|
||||||
position: absolute;
|
position: absolute;
|
||||||
width: 220rpx;
|
width: 220rpx;
|
||||||
height: auto;
|
height: auto;
|
||||||
max-height: 400rpx;
|
max-height: 400rpx;
|
||||||
overflow: hidden;
|
overflow: hidden;
|
||||||
overflow-y: auto;
|
overflow-y: auto;
|
||||||
top: -42rpx;
|
top: -44rpx;
|
||||||
right: -30rpx;
|
right: -30rpx;
|
||||||
letter-spacing: 2px;
|
letter-spacing: 2px;
|
||||||
z-index: 10;
|
z-index: 10;
|
||||||
@@ -831,7 +829,7 @@ onShow(async () => {
|
|||||||
display: flex;
|
display: flex;
|
||||||
align-items: center;
|
align-items: center;
|
||||||
word-break: keep-all;
|
word-break: keep-all;
|
||||||
padding: 20rpx 10rpx;
|
padding: 20rpx 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
.season-list > view > text {
|
.season-list > view > text {
|
||||||
|
|||||||
@@ -49,6 +49,8 @@ const battleWay = ref(0);
|
|||||||
const lastToSomeoneShootKey = ref("");
|
const lastToSomeoneShootKey = ref("");
|
||||||
/** 控制设备离线提示弹窗的显示状态 */
|
/** 控制设备离线提示弹窗的显示状态 */
|
||||||
const showOfflineModal = ref(false);
|
const showOfflineModal = ref(false);
|
||||||
|
/** 记录每位玩家当前轮连续 X 环数,key 为 playerId,用于触发 tententen 音效 */
|
||||||
|
const xRingStreaks = ref({});
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 监听设备在线状态,比赛进行中设备离线时弹窗提示用户
|
* 监听设备在线状态,比赛进行中设备离线时弹窗提示用户
|
||||||
@@ -102,8 +104,7 @@ const recoverData = (battleInfo, {force = false, arrowOnly = false} = {}) => {
|
|||||||
let nextTips = redPlayer ? "请红队射箭" : "请蓝队射箭";
|
let nextTips = redPlayer ? "请红队射箭" : "请蓝队射箭";
|
||||||
if (force) nextTips += "重回";
|
if (force) nextTips += "重回";
|
||||||
if (
|
if (
|
||||||
battleInfo.current.playerId === user.value.id &&
|
battleInfo.current.playerId === user.value.id
|
||||||
redTeam.value.length > 1
|
|
||||||
) {
|
) {
|
||||||
nextTips += "你";
|
nextTips += "你";
|
||||||
}
|
}
|
||||||
@@ -211,6 +212,9 @@ function onBattleEnd() {
|
|||||||
function onNewRound(msg, prevRound) {
|
function onNewRound(msg, prevRound) {
|
||||||
showRoundTip.value = true;
|
showRoundTip.value = true;
|
||||||
isFinalShoot.value = msg.current.goldRound;
|
isFinalShoot.value = msg.current.goldRound;
|
||||||
|
// 新轮次开始时立即清空靶纸箭迹,避免残留上一轮落点至新轮次第一箭到来
|
||||||
|
scores.value = [];
|
||||||
|
blueScores.value = [];
|
||||||
// 决金轮箭数不确定(平局后可能再加一箭),清零 totalShot 隐藏箭数显示
|
// 决金轮箭数不确定(平局后可能再加一箭),清零 totalShot 隐藏箭数显示
|
||||||
if (msg.current.goldRound) {
|
if (msg.current.goldRound) {
|
||||||
store.updateShotInfo(0, 0);
|
store.updateShotInfo(0, 0);
|
||||||
@@ -229,6 +233,27 @@ function onNewRound(msg, prevRound) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 检测指定射手连续 X 环是否达到 3 箭,达到则在环数播报入队后追加 tententen 音效
|
||||||
|
* @param {number} shooterId - 本次射手的 ID(取自 currentShooterId.value)
|
||||||
|
* @param {boolean} isXRing - 本次射击是否为 X 环
|
||||||
|
*/
|
||||||
|
function checkAndPlayTententen(shooterId, isXRing) {
|
||||||
|
if (!shooterId) return;
|
||||||
|
if (isXRing) {
|
||||||
|
xRingStreaks.value[shooterId] = (xRingStreaks.value[shooterId] || 0) + 1;
|
||||||
|
// 同一玩家连续 3 箭均为 X 环,追加到环数音效队列尾部播放
|
||||||
|
if (xRingStreaks.value[shooterId] >= 3) {
|
||||||
|
xRingStreaks.value[shooterId] = 0;
|
||||||
|
// nextTick 确保 HeaderProgress 的环数播报已入队后再追加 tententen,避免播放顺序颠倒
|
||||||
|
nextTick(() => audioManager.play("tententen", false));
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// 非 X 环则重置该玩家的连续计数
|
||||||
|
xRingStreaks.value[shooterId] = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async function onReceiveMessage(msg) {
|
async function onReceiveMessage(msg) {
|
||||||
if (Array.isArray(msg)) return;
|
if (Array.isArray(msg)) return;
|
||||||
if (msg.type === MESSAGETYPESV2.BattleStart) {
|
if (msg.type === MESSAGETYPESV2.BattleStart) {
|
||||||
@@ -243,6 +268,9 @@ async function onReceiveMessage(msg) {
|
|||||||
} else if (msg.type === MESSAGETYPESV2.ShootResult) {
|
} else if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||||
showRoundTip.value = false;
|
showRoundTip.value = false;
|
||||||
recoverData(msg, {arrowOnly: true});
|
recoverData(msg, {arrowOnly: true});
|
||||||
|
// 检测同一玩家三箭全 X 环,触发 tententen 音效
|
||||||
|
// currentShooterId 在 ToSomeoneShoot 时写入,ShootResult 不会覆盖,可靠识别本次射手
|
||||||
|
checkAndPlayTententen(currentShooterId.value, !!(msg.shootData?.ringX && msg.shootData?.ring));
|
||||||
} else if (msg.type === MESSAGETYPESV2.NewRound) {
|
} else if (msg.type === MESSAGETYPESV2.NewRound) {
|
||||||
// 在进入延迟前先捕获当前轮次,供 onNewRound 使用,防止 800ms 内 ToSomeoneShoot 提前更新 currentRound 造成 Tip 展示错轮
|
// 在进入延迟前先捕获当前轮次,供 onNewRound 使用,防止 800ms 内 ToSomeoneShoot 提前更新 currentRound 造成 Tip 展示错轮
|
||||||
const prevRound = currentRound.value;
|
const prevRound = currentRound.value;
|
||||||
@@ -294,6 +322,8 @@ onBeforeUnmount(() => {
|
|||||||
const refreshTimer = ref(null);
|
const refreshTimer = ref(null);
|
||||||
onShow(async () => {
|
onShow(async () => {
|
||||||
if (battleId.value) {
|
if (battleId.value) {
|
||||||
|
// 延迟 300ms 等待网络恢复,避免小程序从后台切回时网络尚未就绪导致请求失败报错
|
||||||
|
await new Promise(resolve => setTimeout(resolve, 300));
|
||||||
const result = await getBattleAPI(battleId.value);
|
const result = await getBattleAPI(battleId.value);
|
||||||
if (!result) return;
|
if (!result) return;
|
||||||
if (result.status === 2) {
|
if (result.status === 2) {
|
||||||
|
|||||||
156
src/websocket.js
156
src/websocket.js
@@ -1,22 +1,12 @@
|
|||||||
import { MESSAGETYPES, getMessageTypeName } from "@/constants";
|
import { MESSAGETYPES, getMessageTypeName } from "@/constants";
|
||||||
import { getUserGameState } from "@/apis";
|
|
||||||
|
|
||||||
let socket = null;
|
let socket = null;
|
||||||
let heartbeatInterval = null;
|
let heartbeatInterval = null;
|
||||||
let reconnectTimer = null;
|
let reconnectTimer = null;
|
||||||
let manualClose = false;
|
|
||||||
let checkingSession = false;
|
|
||||||
let kickedOut = false;
|
|
||||||
let isConnecting = false;
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 建立 WebSocket 连接
|
||||||
|
*/
|
||||||
function createWebSocket(token, onMessage) {
|
function createWebSocket(token, onMessage) {
|
||||||
if (!token) return;
|
|
||||||
if (kickedOut) kickedOut = false;
|
|
||||||
if (socket || isConnecting) return;
|
|
||||||
|
|
||||||
manualClose = false;
|
|
||||||
isConnecting = true;
|
|
||||||
|
|
||||||
let url = "wss://api.shelingxingqiu.com/socket";
|
let url = "wss://api.shelingxingqiu.com/socket";
|
||||||
try {
|
try {
|
||||||
const accountInfo = uni.getAccountInfoSync();
|
const accountInfo = uni.getAccountInfoSync();
|
||||||
@@ -30,65 +20,42 @@ function createWebSocket(token, onMessage) {
|
|||||||
case "trial": // 体验版
|
case "trial": // 体验版
|
||||||
url = "wss://apitest.shelingxingqiu.com/socket";
|
url = "wss://apitest.shelingxingqiu.com/socket";
|
||||||
break;
|
break;
|
||||||
case "trial":
|
case "release": // 正式版
|
||||||
url = "wss://apitest.shelingxingqiu.com/socket";
|
|
||||||
break;
|
|
||||||
case "release":
|
|
||||||
url = "wss://api.shelingxingqiu.com/socket";
|
url = "wss://api.shelingxingqiu.com/socket";
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
|
// 保持默认值
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.error("获取 WebSocket 环境信息失败,使用默认正式环境", e);
|
console.error("获取环境信息失败,使用默认正式环境", e);
|
||||||
}
|
}
|
||||||
|
|
||||||
url += `?authorization=${token}`;
|
url += `?authorization=${token}`;
|
||||||
const socketTask = uni.connectSocket({
|
socket = uni.connectSocket({
|
||||||
url,
|
url,
|
||||||
success: () => {
|
success: () => {
|
||||||
console.log("WebSocket 已发起连接");
|
console.log("websocket 连接成功");
|
||||||
|
// 启动心跳
|
||||||
|
startHeartbeat(onMessage);
|
||||||
},
|
},
|
||||||
fail: (err) => {
|
fail: () => {
|
||||||
if (socket !== socketTask) return;
|
|
||||||
console.error("WebSocket 连接失败", err);
|
|
||||||
socket = null;
|
|
||||||
isConnecting = false;
|
|
||||||
reconnect(onMessage);
|
reconnect(onMessage);
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
socket = socketTask;
|
// 接收消息
|
||||||
|
uni.onSocketMessage((res) => {
|
||||||
socketTask.onOpen(() => {
|
|
||||||
if (socket !== socketTask) return;
|
|
||||||
console.log("WebSocket 连接成功");
|
|
||||||
isConnecting = false;
|
|
||||||
startHeartbeat(onMessage);
|
|
||||||
});
|
|
||||||
|
|
||||||
socketTask.onMessage((res) => {
|
|
||||||
if (socket !== socketTask) return;
|
|
||||||
|
|
||||||
const { data, event } = JSON.parse(res.data);
|
const { data, event } = JSON.parse(res.data);
|
||||||
if (event === "pong") return;
|
if (event === "pong") return;
|
||||||
if (data.type) {
|
if (data.type) {
|
||||||
console.log(
|
console.log("收到消息:", getMessageTypeName(data.type), data.data);
|
||||||
"收到 WebSocket 消息",
|
|
||||||
getMessageTypeName(data.type),
|
|
||||||
data.data
|
|
||||||
);
|
|
||||||
if (onMessage) onMessage({ ...(data.data || {}), type: data.type });
|
if (onMessage) onMessage({ ...(data.data || {}), type: data.type });
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (onMessage && data.updates) onMessage(data.updates);
|
if (onMessage && data.updates) onMessage(data.updates);
|
||||||
const msg = data.updates[0];
|
const msg = data.updates[0];
|
||||||
if (msg) {
|
if (msg) {
|
||||||
console.log(
|
console.log("收到消息:", getMessageTypeName(msg.constructor), msg);
|
||||||
"收到 WebSocket 更新",
|
|
||||||
getMessageTypeName(msg.constructor),
|
|
||||||
msg
|
|
||||||
);
|
|
||||||
if (msg.constructor === MESSAGETYPES.RankUpdate) {
|
if (msg.constructor === MESSAGETYPES.RankUpdate) {
|
||||||
uni.setStorageSync("latestRank", msg.lvl);
|
uni.setStorageSync("latestRank", msg.lvl);
|
||||||
} else if (msg.constructor === MESSAGETYPES.LvlUpdate) {
|
} else if (msg.constructor === MESSAGETYPES.LvlUpdate) {
|
||||||
@@ -101,109 +68,84 @@ function createWebSocket(token, onMessage) {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
socketTask.onError((err) => {
|
// 错误处理
|
||||||
if (socket !== socketTask) return;
|
uni.onSocketError((err) => {
|
||||||
console.error("WebSocket 错误", err);
|
console.error("WebSocket 错误", err);
|
||||||
|
reconnect(onMessage);
|
||||||
});
|
});
|
||||||
|
|
||||||
socketTask.onClose(async (result) => {
|
uni.onSocketClose((result) => {
|
||||||
if (socket !== socketTask) return;
|
|
||||||
console.log("WebSocket 已关闭", result);
|
console.log("WebSocket 已关闭", result);
|
||||||
stopHeartbeat();
|
stopHeartbeat();
|
||||||
socket = null;
|
reconnect(onMessage);
|
||||||
isConnecting = false;
|
|
||||||
|
|
||||||
if (manualClose || kickedOut) return;
|
|
||||||
await handleUnexpectedClose(onMessage);
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
async function handleUnexpectedClose(onMessage) {
|
/**
|
||||||
if (checkingSession || manualClose || kickedOut) return;
|
* 重连机制
|
||||||
|
*/
|
||||||
|
function reconnect(onMessage) {
|
||||||
|
reconnectTimer && clearTimeout(reconnectTimer);
|
||||||
|
closeWebSocket(); // 确保关闭旧连接
|
||||||
|
|
||||||
const token = uni.getStorageSync(
|
const token = uni.getStorageSync(
|
||||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
||||||
);
|
);
|
||||||
if (!token) return;
|
if (!token) return;
|
||||||
|
|
||||||
checkingSession = true;
|
|
||||||
try {
|
|
||||||
await getUserGameState();
|
|
||||||
if (!manualClose && !kickedOut) reconnect(onMessage);
|
|
||||||
} catch (err) {
|
|
||||||
if (err?.type === "AUTH_INVALID") {
|
|
||||||
kickedOut = true;
|
|
||||||
manualClose = true;
|
|
||||||
reconnectTimer && clearTimeout(reconnectTimer);
|
|
||||||
uni.$emit("session-kicked-out");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (!manualClose && !kickedOut) reconnect(onMessage);
|
|
||||||
} finally {
|
|
||||||
checkingSession = false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function reconnect(onMessage) {
|
|
||||||
reconnectTimer && clearTimeout(reconnectTimer);
|
|
||||||
|
|
||||||
const token = uni.getStorageSync(
|
|
||||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
|
||||||
);
|
|
||||||
if (!token || manualClose || kickedOut || socket || isConnecting) return;
|
|
||||||
|
|
||||||
reconnectTimer = setTimeout(() => {
|
reconnectTimer = setTimeout(() => {
|
||||||
if (manualClose || kickedOut || socket || isConnecting) return;
|
console.log("reconnecting...");
|
||||||
console.log("WebSocket 正在重连...");
|
|
||||||
createWebSocket(token, onMessage);
|
createWebSocket(token, onMessage);
|
||||||
}, 1000);
|
}, 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
function closeWebSocket(isManual = true) {
|
function closeWebSocket() {
|
||||||
manualClose = isManual;
|
if (socket) {
|
||||||
reconnectTimer && clearTimeout(reconnectTimer);
|
reconnectTimer && clearTimeout(reconnectTimer);
|
||||||
stopHeartbeat();
|
stopHeartbeat();
|
||||||
isConnecting = false;
|
|
||||||
|
|
||||||
if (socket) {
|
|
||||||
const currentSocket = socket;
|
|
||||||
socket = null;
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
currentSocket.close();
|
socket.close();
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error("关闭 WebSocket 失败", err);
|
console.error("关闭WebSocket连接失败", err);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
socket = null; // 清除socket引用
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function sendHeartbeat(onMessage) {
|
function sendHeartbeat(onMessage) {
|
||||||
if (!socket) return;
|
uni.sendSocketMessage({
|
||||||
|
|
||||||
const currentSocket = socket;
|
|
||||||
currentSocket.send({
|
|
||||||
data: JSON.stringify({ event: "ping", data: {} }),
|
data: JSON.stringify({ event: "ping", data: {} }),
|
||||||
success: () => {},
|
success: () => {
|
||||||
|
// console.log("发送心跳成功");
|
||||||
|
},
|
||||||
fail: (err) => {
|
fail: (err) => {
|
||||||
if (socket !== currentSocket) return;
|
console.error("发送心跳失败", err);
|
||||||
console.error("心跳发送失败", err);
|
|
||||||
stopHeartbeat();
|
stopHeartbeat();
|
||||||
closeWebSocket(false);
|
closeWebSocket(); // 关闭失效的连接
|
||||||
reconnect(onMessage);
|
reconnect(onMessage); // 触发重连
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 启动心跳
|
||||||
|
*/
|
||||||
function startHeartbeat(onMessage) {
|
function startHeartbeat(onMessage) {
|
||||||
stopHeartbeat();
|
stopHeartbeat(); // 防止重复启动
|
||||||
|
|
||||||
heartbeatInterval = setInterval(() => {
|
heartbeatInterval = setInterval(() => {
|
||||||
if (socket) {
|
if (socket && socket.readyState === 1) {
|
||||||
|
// 检查连接状态
|
||||||
sendHeartbeat(onMessage);
|
sendHeartbeat(onMessage);
|
||||||
}
|
}
|
||||||
}, 10000);
|
}, 10000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 停止心跳
|
||||||
|
*/
|
||||||
function stopHeartbeat() {
|
function stopHeartbeat() {
|
||||||
if (heartbeatInterval) {
|
if (heartbeatInterval) {
|
||||||
clearInterval(heartbeatInterval);
|
clearInterval(heartbeatInterval);
|
||||||
|
|||||||
Reference in New Issue
Block a user