Compare commits
27 Commits
new-race-m
...
33d28c6a45
| Author | SHA1 | Date | |
|---|---|---|---|
| 33d28c6a45 | |||
| 301fc4ee42 | |||
| 6596ea977d | |||
| f272df912b | |||
| cbb7bce746 | |||
| a5c6afe647 | |||
| 0b93d99688 | |||
| 3bc2e6c14b | |||
| ff64fab323 | |||
| 43123df18f | |||
| 860b01d5eb | |||
| 9c554a9366 | |||
| 8d918b008e | |||
| a66d8a03c6 | |||
| b168fd54a4 | |||
| da023c60f5 | |||
| cb4027418d | |||
| 96cc69f041 | |||
| 860cdbe332 | |||
| 8b9c862b96 | |||
| 19391808ef | |||
| 9cc6ef4b88 | |||
| fc14489ab3 | |||
| aba2da56d7 | |||
| 24314e5ec8 | |||
| 4dcfdeda68 | |||
| a6becf67ff |
2
.gitignore
vendored
2
.gitignore
vendored
@@ -12,7 +12,7 @@ node_modules
|
||||
.github
|
||||
openspec
|
||||
CLAUDE.md
|
||||
docs
|
||||
dosc
|
||||
.DS_Store
|
||||
dist
|
||||
*.local
|
||||
|
||||
@@ -25,7 +25,6 @@
|
||||
"@dcloudio/uni-quickapp-webview": "3.0.0-4060620250520001",
|
||||
"@dcloudio/uni-ui": "^1.5.11",
|
||||
"pinia": "2.0.36",
|
||||
"pinia-plugin-persistedstate": "3.2.1",
|
||||
"vue": "^3.4.21",
|
||||
"vue-i18n": "^9.1.9"
|
||||
},
|
||||
|
||||
23
src/App.vue
23
src/App.vue
@@ -21,7 +21,10 @@
|
||||
} = storeToRefs(store);
|
||||
const {
|
||||
updateUser,
|
||||
updateOnline
|
||||
updateOnline,
|
||||
updateDevice,
|
||||
updateGame,
|
||||
updateRoomNumber
|
||||
} = store;
|
||||
|
||||
watch(
|
||||
@@ -46,6 +49,22 @@
|
||||
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() {
|
||||
const data = await getDeviceBatteryAPI();
|
||||
updateOnline(data.online);
|
||||
@@ -65,6 +84,7 @@
|
||||
onShow(() => {
|
||||
uni.$on("update-user", emitUpdateUser);
|
||||
uni.$on("update-online", emitUpdateOnline);
|
||||
uni.$on("session-kicked-out", onSessionKickedOut);
|
||||
const token = uni.getStorageSync(
|
||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
||||
);
|
||||
@@ -77,6 +97,7 @@
|
||||
onHide(() => {
|
||||
uni.$off("update-user", emitUpdateUser);
|
||||
uni.$off("update-online", emitUpdateOnline);
|
||||
uni.$off("session-kicked-out", onSessionKickedOut);
|
||||
websocket.closeWebSocket();
|
||||
});
|
||||
</script>
|
||||
|
||||
@@ -46,6 +46,8 @@ function request(method, url, data = {}) {
|
||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
||||
);
|
||||
uni.$emit("update-user");
|
||||
reject({ type: "AUTH_INVALID", message });
|
||||
return;
|
||||
}
|
||||
if (message === "ROOM_FULL") {
|
||||
resolve({full: true});
|
||||
|
||||
@@ -1,8 +1,4 @@
|
||||
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",
|
||||
"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",
|
||||
// 激光已校准:
|
||||
// "https://static.shelingxingqiu.com/attachment/2025-10-29/ddupaur1vdkyhzaqdc.mp3",
|
||||
胜利: "https://static.shelingxingqiu.com/attachment/2025-09-17/dcuo9yjp0kt5msvmvd.mp3",
|
||||
@@ -40,7 +36,7 @@ export const audioFils = {
|
||||
请开始射击:
|
||||
"https://static.shelingxingqiu.com/attachment/2025-09-17/dcutzdrl5u0iromqhf.mp3",
|
||||
射击无效:
|
||||
"https://static.shelingxingqiu.com/shootmini/static/audio/%E5%B0%84%E7%AE%AD%E6%97%A0%E6%95%88%E6%A3%80%E6%9F%A5%E8%B7%9D%E7%A6%BB%E5%92%8C%E9%9D%B6%E7%BA%B8.mp3",
|
||||
"https://static.shelingxingqiu.com/attachment/2025-09-17/dcutya55ufiiw8oo55.mp3",
|
||||
未上靶:
|
||||
"https://static.shelingxingqiu.com/attachment/2025-11-12/de6n45o3tsm1v4unam.mp3",
|
||||
"1环":
|
||||
|
||||
@@ -31,7 +31,7 @@ function handleTabClick(index) {
|
||||
v-for="(tab, index) in tabs"
|
||||
:key="index"
|
||||
class="tab-item"
|
||||
@click="$clickSound(() => handleTabClick(index))"
|
||||
@click="handleTabClick(index)"
|
||||
:style="{
|
||||
width: index === 1 ? '36%' : '20%',
|
||||
}"
|
||||
|
||||
@@ -19,12 +19,8 @@ const props = defineProps({
|
||||
});
|
||||
const loading = ref(false);
|
||||
|
||||
/** 统一获取当前环境 token,用于守卫:无有效 token 时不发起接口请求 */
|
||||
const getToken = () =>
|
||||
uni.getStorageSync(`${uni.getAccountInfoSync().miniProgram.envVersion}_token`);
|
||||
|
||||
onShow(async () => {
|
||||
if (user.value.id && getToken()) {
|
||||
if (user.value.id) {
|
||||
setTimeout(async () => {
|
||||
const state = await getUserGameState();
|
||||
updateGame(state.gaming, state.roomId);
|
||||
@@ -37,8 +33,7 @@ watch(
|
||||
async (value) => {
|
||||
if (!value.id) {
|
||||
updateGame(false, "");
|
||||
} else if (getToken()) {
|
||||
// 有有效 token 时才查询在局状态,避免 token 失效时反复发起无效请求
|
||||
} else {
|
||||
const state = await getUserGameState();
|
||||
updateGame(state.gaming, state.roomId);
|
||||
}
|
||||
|
||||
@@ -206,7 +206,7 @@ const goCalibration = async () => {
|
||||
<button hover-class="none" @click="() => (showHint = false)">
|
||||
取消
|
||||
</button>
|
||||
<button hover-class="none" @click="$clickSound(cancelMatching)">确认</button>
|
||||
<button hover-class="none" @click="cancelMatching">确认</button>
|
||||
</view>
|
||||
</view>
|
||||
<view v-if="hintType === 4" class="tip-content">
|
||||
|
||||
@@ -112,7 +112,7 @@ const createRoom = debounce(async () => {
|
||||
<text>40厘米全环靶</text>
|
||||
</view>
|
||||
</view>
|
||||
<SButton :onClick="() => $clickSound(createRoom)">创建房间</SButton>
|
||||
<SButton :onClick="createRoom">创建房间</SButton>
|
||||
</view>
|
||||
</template>
|
||||
|
||||
|
||||
@@ -19,17 +19,12 @@ const ended = ref(false);
|
||||
const halfTime = ref(false);
|
||||
const currentShot = ref(0);
|
||||
const totalShot = ref(0);
|
||||
/** 标记组件是否已完成挂载,防止 immediate watcher 在挂载前用旧 store 值触发意外播音 */
|
||||
const isMounted = ref(false);
|
||||
|
||||
watch(
|
||||
() => tips.value,
|
||||
(newVal) => {
|
||||
// 挂载完成前不播音(避免 immediate store watcher 用旧值触发多余播报)
|
||||
if (!isMounted.value) return;
|
||||
// 空字符串或含"重回"的 tips 均不播音
|
||||
if (!newVal || newVal.includes("重回")) return;
|
||||
let key = [];
|
||||
if (newVal.includes("重回")) return;
|
||||
if (currentRoundEnded.value) {
|
||||
// 播放当前轮次语音
|
||||
key.push(`第${["一", "二", "三", "四", "五"][currentRound.value]}轮`);
|
||||
@@ -65,12 +60,8 @@ async function onReceiveMessage(message) {
|
||||
audioManager.play("比赛结束", false);
|
||||
} else if (type === MESSAGETYPESV2.ShootResult) {
|
||||
if (melee.value && current.playerId !== user.value.id) return;
|
||||
// 从 indexMap 按当前用户 id 取已射箭数,由后端维护准确值,不在前端自增。
|
||||
// 注意:后端在 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;
|
||||
// 从 indexMap 按当前用户 id 取已射箭数,由后端维护准确值,不在前端自增
|
||||
if (current.playerId === user.value.id) currentShot.value = current.indexMap?.[user.value.id] ?? currentShot.value;
|
||||
if (message.shootData) {
|
||||
let key = [];
|
||||
key.push(
|
||||
@@ -122,7 +113,6 @@ watch(() => store.game.tips, (newVal) => {
|
||||
}, { immediate: true });
|
||||
|
||||
onMounted(() => {
|
||||
isMounted.value = true;
|
||||
uni.$on("update-tips", onUpdateTips);
|
||||
uni.$on("socket-inbox", onReceiveMessage);
|
||||
uni.$on("play-sound", playSound);
|
||||
|
||||
@@ -123,7 +123,7 @@ onBeforeUnmount(() => {
|
||||
</text>
|
||||
</view>
|
||||
</view>
|
||||
<button hover-class="none" @click="$clickSound(stopMatch)">取消匹配</button>
|
||||
<button hover-class="none" @click="stopMatch">取消匹配</button>
|
||||
</view>
|
||||
</template>
|
||||
|
||||
|
||||
15
src/main.js
15
src/main.js
@@ -1,26 +1,11 @@
|
||||
import { createSSRApp } from 'vue'
|
||||
import { createPinia } from 'pinia'
|
||||
import piniaPluginPersistedstate from 'pinia-plugin-persistedstate'
|
||||
import App from './App.vue'
|
||||
import audioManager from './audioManager'
|
||||
|
||||
export function createApp() {
|
||||
const app = createSSRApp(App)
|
||||
const pinia = createPinia()
|
||||
pinia.use(piniaPluginPersistedstate)
|
||||
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 {
|
||||
app
|
||||
}
|
||||
|
||||
@@ -17,7 +17,6 @@ import {
|
||||
import { MESSAGETYPES, MESSAGETYPESV2 } from "@/constants";
|
||||
import useStore from "@/store";
|
||||
import { storeToRefs } from "pinia";
|
||||
import audioManager from "@/audioManager";
|
||||
const store = useStore();
|
||||
const { user } = storeToRefs(store);
|
||||
|
||||
@@ -56,8 +55,6 @@ const ready = ref(false);
|
||||
const allReady = ref(false);
|
||||
const timer = ref(null);
|
||||
const goBattle = ref(false);
|
||||
/** 从结算页返回时为 true,跳过进场靶纸语音 */
|
||||
const skipTargetAudio = ref(false);
|
||||
|
||||
/**
|
||||
* 从服务端刷新当前房间数据,更新成员列表、准备状态等信息
|
||||
@@ -266,18 +263,19 @@ const shareTitle = computed(() => {
|
||||
});
|
||||
|
||||
/**
|
||||
* 根据对战类型和靶纸尺寸动态返回分享封面图路径,共 4 张图:
|
||||
* contest_share_20.png — 约战/对抗赛 + 20cm 靶
|
||||
* contest_share_40.png — 约战/对抗赛 + 40cm 靶
|
||||
* melee_share_20.png — 多人乱斗 + 20cm 靶
|
||||
* melee_share_40.png — 多人乱斗 + 40cm 靶
|
||||
* 根据对战类型动态返回分享封面图路径
|
||||
* battleType === 2(多人乱斗)→ melee_share.jpg
|
||||
* 其余(好友约战 / 组队对战)→ contest_share.jpg
|
||||
*
|
||||
* 当 targetSize 未知时默认取 20cm 图。
|
||||
* 网络图片:
|
||||
* https://static.shelingxingqiu.com/shootmini/static/share/melee_share.jpg
|
||||
* https://static.shelingxingqiu.com/shootmini/static/share/contest_share.jpg
|
||||
*/
|
||||
const shareImage = computed(() => {
|
||||
const type = room.value.battleType === 2 ? 'melee' : 'contest';
|
||||
const size = targetSize.value === 40 ? '40' : '20';
|
||||
return `https://static.shelingxingqiu.com/shootmini/static/share/${type}_share_${size}.png`;
|
||||
if (room.value.battleType === 2) {
|
||||
return 'https://static.shelingxingqiu.com/shootmini/static/share/melee_share.jpg';
|
||||
}
|
||||
return 'https://static.shelingxingqiu.com/shootmini/static/share/contest_share.jpg';
|
||||
});
|
||||
|
||||
onShareAppMessage(() => {
|
||||
@@ -304,8 +302,6 @@ onShow(() => {
|
||||
* - 同步到 Pinia Store(供 Header 组件展示房号胶囊)
|
||||
*/
|
||||
onLoad(async (options) => {
|
||||
// 从结算页跳回时携带 fromResult=1,标记跳过进场语音
|
||||
if (options.fromResult) skipTargetAudio.value = true;
|
||||
if (options.roomNumber) {
|
||||
roomNumber.value = options.roomNumber;
|
||||
store.updateRoomNumber(options.roomNumber);
|
||||
@@ -330,13 +326,6 @@ onMounted(() => {
|
||||
keepScreenOn: true,
|
||||
});
|
||||
uni.$on("socket-inbox", onReceiveMessage);
|
||||
// 页面加载完成 1 秒后根据靶纸尺寸播报对应语音;从结算页返回时跳过
|
||||
setTimeout(() => {
|
||||
if (!skipTargetAudio.value) {
|
||||
const key = targetSize.value === 40 ? '40CM全环靶' : '20CM全环靶';
|
||||
audioManager.play(key);
|
||||
}
|
||||
}, 1000);
|
||||
});
|
||||
|
||||
onBeforeUnmount(() => {
|
||||
@@ -443,7 +432,7 @@ onBeforeUnmount(() => {
|
||||
<PlayerSeats v-if="room.battleType === 2" :total="room.count || 10" :players="players"
|
||||
:removePlayer="removePlayer" :isOwner="owner.id === user.id" />
|
||||
<view>
|
||||
<SButton :disabled="!canClick" :onClick="() => $clickSound(getReady)">
|
||||
<SButton :disabled="!canClick" :onClick="getReady">
|
||||
{{
|
||||
allReady.value
|
||||
? "即将进入对局..."
|
||||
|
||||
@@ -240,7 +240,7 @@ function closeOverlay() {
|
||||
/**
|
||||
* 底部按钮文案:好友约战显示“返回房间”,排位赛等其他模式显示“返回”
|
||||
*/
|
||||
const exitBtnText = computed(() => data.value.way === 1 ? '再来一局' : '返回');
|
||||
const exitBtnText = computed(() => data.value.way === 1 ? '返回房间' : '返回');
|
||||
|
||||
/**
|
||||
* 点击底部按钮跳转
|
||||
@@ -275,7 +275,7 @@ async function exit() {
|
||||
return;
|
||||
}
|
||||
uni.redirectTo({
|
||||
url: `/pages/battle-room?roomNumber=${data.value.roomId}&fromResult=1`,
|
||||
url: `/pages/battle-room?roomNumber=${data.value.roomId}`,
|
||||
});
|
||||
} else {
|
||||
uni.redirectTo({
|
||||
|
||||
@@ -98,10 +98,8 @@ onLoad(async (options) => {
|
||||
<Container title="好友约战" :showBackToGame="true">
|
||||
<view :style="{ width: '100%', height: '100%' }">
|
||||
<GuideTwo>
|
||||
<view class="guide-tips">
|
||||
<text class="guide-tips__main">约上朋友开几局,欢乐多,不寂寞</text>
|
||||
<text class="guide-tips__sub">一起练升级更快,早日加入全国排位赛!</text>
|
||||
</view>
|
||||
<text :style="{color: 'rgba(255,217,71,0.8)'}">约上朋友开几局,欢乐多,不寂寞</text>
|
||||
<text>一起练升级更快,早日加入全国排位赛!</text>
|
||||
</GuideTwo>
|
||||
<view class="my-data">
|
||||
<view>
|
||||
@@ -141,7 +139,7 @@ onLoad(async (options) => {
|
||||
<image src="../static/founded-room.png" mode="widthFix" />
|
||||
<view>
|
||||
<input placeholder="输入房间号" v-model="roomNumber" placeholder-style="color: #ccc" />
|
||||
<view @click="$clickSound(() => enterRoom(roomNumber))">进入房间</view>
|
||||
<view @click="enterRoom(roomNumber)">进入房间</view>
|
||||
</view>
|
||||
</view>
|
||||
<view class="create-room">
|
||||
@@ -155,7 +153,7 @@ onLoad(async (options) => {
|
||||
</view>
|
||||
</view>
|
||||
<view>
|
||||
<SButton width="80%" :rounded="30" :onClick="() => $clickSound(onCreateRoom)">
|
||||
<SButton width="80%" :rounded="30" :onClick="onCreateRoom">
|
||||
创建约战房
|
||||
</SButton>
|
||||
</view>
|
||||
@@ -173,24 +171,6 @@ onLoad(async (options) => {
|
||||
</template>
|
||||
|
||||
<style scoped>
|
||||
.guide-tips {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
padding-left: 112rpx;
|
||||
width: 100%;
|
||||
}
|
||||
.guide-tips__main {
|
||||
font-weight: 400;
|
||||
font-size: 26rpx;
|
||||
color: rgba(255, 217, 71, 0.8);
|
||||
}
|
||||
.guide-tips__sub {
|
||||
font-weight: 400;
|
||||
font-size: 22rpx;
|
||||
color: rgba(255, 255, 255, 0.8);
|
||||
margin-top: 6rpx;
|
||||
}
|
||||
|
||||
.founded-room {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
|
||||
@@ -159,10 +159,10 @@ onShareTimeline(() => {
|
||||
<Container :isHome="true" :showBackToGame="true">
|
||||
<view class="container">
|
||||
<view class="top-theme">
|
||||
<!-- <image
|
||||
<image
|
||||
src="https://static.shelingxingqiu.com/attachment/2025-12-31/dfc9dxrq4xn7e6y2pp.png"
|
||||
mode="widthFix"
|
||||
/> -->
|
||||
/>
|
||||
</view>
|
||||
<UserHeader showRank :onSignin="() => (showModal = true)"/>
|
||||
<view :style="{ padding: '12px 10px' }">
|
||||
@@ -178,7 +178,7 @@ onShareTimeline(() => {
|
||||
v-else
|
||||
src="https://static.shelingxingqiu.com/attachment/2026-01-04/dffohwtk1gwh0xfa6h.png"
|
||||
mode="widthFix"
|
||||
@click="$clickSound(() => toPage('/pages/my-device'))"
|
||||
@click="() => toPage('/pages/my-device')"
|
||||
/>
|
||||
<block v-if="user.id">
|
||||
<text v-if="!device.deviceId">绑定我的智能弓</text>
|
||||
@@ -196,10 +196,10 @@ onShareTimeline(() => {
|
||||
</BubbleTip>
|
||||
</view>
|
||||
<view class="play-card">
|
||||
<view @click="$clickSound(() => toPage('/pages/practise'))">
|
||||
<view @click="() => toPage('/pages/practise')">
|
||||
<image src="../static/my-practise.png" mode="widthFix"/>
|
||||
</view>
|
||||
<view @click="$clickSound(() => toPage('/pages/friend-battle'))">
|
||||
<view @click="() => toPage('/pages/friend-battle')">
|
||||
<image src="../static/friend-battle.png" mode="widthFix"/>
|
||||
</view>
|
||||
</view>
|
||||
@@ -211,7 +211,7 @@ onShareTimeline(() => {
|
||||
/>
|
||||
<button
|
||||
class="into-btn"
|
||||
@click="$clickSound(() => toPage('/pages/ranking'))"
|
||||
@click="() => toPage('/pages/ranking')"
|
||||
hover-class="none"
|
||||
></button>
|
||||
<view class="ranking-players" @click="toRankListPage">
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
<script setup>
|
||||
import { ref, onMounted, onBeforeUnmount, watch, nextTick } from "vue";
|
||||
import { ref, onMounted, onBeforeUnmount, watch } from "vue";
|
||||
import { onLoad, onShow, onHide } from "@dcloudio/uni-app";
|
||||
import Container from "@/components/Container.vue";
|
||||
import BowTarget from "@/components/BowTarget.vue";
|
||||
@@ -32,8 +32,6 @@ const halfTimeTip = ref(false);
|
||||
const halfRest = ref(false);
|
||||
/** 控制设备离线提示弹窗的显示状态 */
|
||||
const showOfflineModal = ref(false);
|
||||
/** 记录每位玩家当前半场连续 X 环数,key 为 playerId,用于触发 tententen 音效 */
|
||||
const xRingStreaks = ref({});
|
||||
|
||||
/**
|
||||
* 监听设备在线状态,大乱斗比赛进行中设备离线时弹窗提示用户
|
||||
@@ -122,28 +120,6 @@ 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) {
|
||||
if (Array.isArray(msg)) return;
|
||||
if (msg.type === MESSAGETYPESV2.BattleStart) {
|
||||
@@ -151,28 +127,7 @@ async function onReceiveMessage(msg) {
|
||||
halfRest.value = false;
|
||||
recoverData(msg);
|
||||
} 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);
|
||||
// 对比更新后数据找出箭数增加的玩家(即本次射手),并读取其最新箭的 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) {
|
||||
halfTimeTip.value = true;
|
||||
halfRest.value = true;
|
||||
|
||||
@@ -130,7 +130,7 @@ onShow(() => {
|
||||
<template>
|
||||
<Container title="弓箭绑定">
|
||||
<view v-if="!device.deviceId" class="scan-code">
|
||||
<button hover-class="none" @click="$clickSound(handleScan)">
|
||||
<button hover-class="none" @click="handleScan">
|
||||
<image src="../static/scan.png" mode="widthFix" />
|
||||
</button>
|
||||
<button hover-class="none" @click="showTip = true">
|
||||
@@ -269,7 +269,7 @@ onShow(() => {
|
||||
</view>
|
||||
</view>
|
||||
<view :style="{ marginTop: '240rpx' }">
|
||||
<SButton :onClick="() => $clickSound(unbindDevice)" width="80vw" :rounded="40"
|
||||
<SButton :onClick="unbindDevice" width="80vw" :rounded="40"
|
||||
>解绑</SButton
|
||||
>
|
||||
</view>
|
||||
|
||||
@@ -114,7 +114,7 @@ onMounted(async () => {
|
||||
/>
|
||||
</view>
|
||||
<template #bottom>
|
||||
<SButton :rounded="50" :onClick="() => $clickSound(toEditPage)">下一步</SButton>
|
||||
<SButton :rounded="50" :onClick="toEditPage">下一步</SButton>
|
||||
</template>
|
||||
</Container>
|
||||
</template>
|
||||
|
||||
@@ -198,7 +198,7 @@ onLoad((options) => {
|
||||
</ScreenHint2>
|
||||
</view>
|
||||
<template #bottom>
|
||||
<SButton :rounded="50" :onClick="() => $clickSound(onSubmit)">
|
||||
<SButton :rounded="50" :onClick="onSubmit">
|
||||
{{ currentGroup === groups ? "保存并查看分析" : "下一组" }}
|
||||
</SButton>
|
||||
</template>
|
||||
|
||||
@@ -329,10 +329,10 @@ onShareTimeline(() => {
|
||||
</view>
|
||||
</view>
|
||||
<view>
|
||||
<button hover-class="none" @click="$clickSound(toRecordPage)" class="image-btn">
|
||||
<button hover-class="none" @click="toRecordPage" class="image-btn">
|
||||
<image src="../static/record-btn.png" mode="widthFix" />
|
||||
</button>
|
||||
<button hover-class="none" @click="$clickSound(startScoring)" class="image-btn">
|
||||
<button hover-class="none" @click="startScoring" class="image-btn">
|
||||
<image src="../static/start-scoring.png" mode="widthFix" />
|
||||
</button>
|
||||
</view>
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
<script setup>
|
||||
import { ref, onMounted, onBeforeUnmount, nextTick } from "vue";
|
||||
import { ref, onMounted, onBeforeUnmount } from "vue";
|
||||
import { onLoad } from "@dcloudio/uni-app";
|
||||
import Container from "@/components/Container.vue";
|
||||
import ShootProgress from "@/components/ShootProgress.vue";
|
||||
@@ -31,8 +31,6 @@ const { user } = storeToRefs(store);
|
||||
const start = ref(false);
|
||||
const scores = ref([]);
|
||||
const total = 12;
|
||||
/** 当前练习中连续 X 环计数,用于触发 tententen 音效 */
|
||||
const xRingStreak = ref(0);
|
||||
const practiseResult = ref({});
|
||||
const practiseId = ref("");
|
||||
const showGuide = ref(false);
|
||||
@@ -48,7 +46,6 @@ onLoad((options) => {
|
||||
const onReady = async () => {
|
||||
await startPractiseAPI();
|
||||
scores.value = [];
|
||||
xRingStreak.value = 0; // 新一局开始,重置 X 环连续计数
|
||||
start.value = true;
|
||||
audioManager.play("练习开始");
|
||||
};
|
||||
@@ -58,33 +55,9 @@ const onOver = async () => {
|
||||
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) {
|
||||
if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||
const prevLen = scores.value.length;
|
||||
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) {
|
||||
// setTimeout(onOver, 1500);
|
||||
}
|
||||
@@ -101,7 +74,6 @@ async function onComplete() {
|
||||
practiseResult.value = {};
|
||||
start.value = false;
|
||||
scores.value = [];
|
||||
xRingStreak.value = 0; // 重新开始练习,重置 X 环连续计数
|
||||
const result = await createPractiseAPI(total, 120);
|
||||
if (result) practiseId.value = result.id;
|
||||
}
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
<script setup>
|
||||
import { ref, onMounted, onBeforeUnmount, nextTick } from "vue";
|
||||
import { ref, onMounted, onBeforeUnmount } from "vue";
|
||||
import Container from "@/components/Container.vue";
|
||||
import ShootProgress from "@/components/ShootProgress.vue";
|
||||
import BowTarget from "@/components/BowTarget.vue";
|
||||
@@ -31,8 +31,6 @@ const { user } = storeToRefs(store);
|
||||
const start = ref(false);
|
||||
const scores = ref([]);
|
||||
const total = 36;
|
||||
/** 当前练习中连续 X 环计数,用于触发 tententen 音效 */
|
||||
const xRingStreak = ref(0);
|
||||
const practiseResult = ref({});
|
||||
const practiseId = ref("");
|
||||
const showGuide = ref(false);
|
||||
@@ -47,7 +45,6 @@ onLoad((options) => {
|
||||
const onReady = async () => {
|
||||
await startPractiseAPI();
|
||||
scores.value = [];
|
||||
xRingStreak.value = 0; // 新一局开始,重置 X 环连续计数
|
||||
start.value = true;
|
||||
audioManager.play("练习开始");
|
||||
};
|
||||
@@ -57,33 +54,9 @@ const onOver = async () => {
|
||||
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) {
|
||||
if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||
const prevLen = scores.value.length;
|
||||
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) {
|
||||
setTimeout(onOver, 1500);
|
||||
}
|
||||
@@ -116,8 +89,7 @@ async function onComplete() {
|
||||
practiseResult.value = {};
|
||||
start.value = false;
|
||||
scores.value = [];
|
||||
xRingStreak.value = 0; // 重新开始练习,重置 X 环连续计数
|
||||
const result = await createPractiseAPI(total, 360);
|
||||
const result = await createPractiseAPI(total, 3600);
|
||||
if (result) practiseId.value = result.id;
|
||||
}
|
||||
}
|
||||
@@ -133,7 +105,7 @@ onMounted(async () => {
|
||||
});
|
||||
uni.$on("socket-inbox", onReceiveMessage);
|
||||
uni.$on("share-image", onClickShare);
|
||||
const result = await createPractiseAPI(total, 360, targetType.value);
|
||||
const result = await createPractiseAPI(total, 3600, targetType.value);
|
||||
if (result) practiseId.value = result.id;
|
||||
});
|
||||
|
||||
@@ -160,7 +132,7 @@ onBeforeUnmount(() => {
|
||||
<ShootProgress
|
||||
:tips="`请连续射${total}支箭`"
|
||||
:start="start"
|
||||
:total="360"
|
||||
:total="3600"
|
||||
:onStop="onOver"
|
||||
/>
|
||||
<view class="user-row">
|
||||
|
||||
@@ -281,27 +281,27 @@ onShow(async () => {
|
||||
<image
|
||||
src="../static/rank/battle1v1.svg"
|
||||
mode="widthFix"
|
||||
@click.stop="$clickSound(() => toMatchPage(1, 2))"
|
||||
@click.stop="() => toMatchPage(1, 2)"
|
||||
/>
|
||||
<image
|
||||
src="../static/rank/battle2v2.svg"
|
||||
mode="widthFix"
|
||||
@click.stop="$clickSound(() => toMatchPage(2, 4))"
|
||||
@click.stop="() => toMatchPage(2, 4)"
|
||||
/>
|
||||
<image
|
||||
src="../static/rank/battle3v3.svg"
|
||||
mode="widthFix"
|
||||
@click.stop="$clickSound(() => toMatchPage(3, 6))"
|
||||
@click.stop="() => toMatchPage(3, 6)"
|
||||
/>
|
||||
<image
|
||||
src="../static/rank/battle5.svg"
|
||||
mode="widthFix"
|
||||
@click.stop="$clickSound(() => toMatchPage(4, 5))"
|
||||
@click.stop="() => toMatchPage(4, 5)"
|
||||
/>
|
||||
<image
|
||||
src="../static/rank/battle10.svg"
|
||||
mode="widthFix"
|
||||
@click.stop="$clickSound(() => toMatchPage(5, 10))"
|
||||
@click.stop="() => toMatchPage(5, 10)"
|
||||
/>
|
||||
</view>
|
||||
</view>
|
||||
|
||||
@@ -49,8 +49,6 @@ const battleWay = ref(0);
|
||||
const lastToSomeoneShootKey = ref("");
|
||||
/** 控制设备离线提示弹窗的显示状态 */
|
||||
const showOfflineModal = ref(false);
|
||||
/** 记录每位玩家当前轮连续 X 环数,key 为 playerId,用于触发 tententen 音效 */
|
||||
const xRingStreaks = ref({});
|
||||
|
||||
/**
|
||||
* 监听设备在线状态,比赛进行中设备离线时弹窗提示用户
|
||||
@@ -104,7 +102,8 @@ const recoverData = (battleInfo, {force = false, arrowOnly = false} = {}) => {
|
||||
let nextTips = redPlayer ? "请红队射箭" : "请蓝队射箭";
|
||||
if (force) nextTips += "重回";
|
||||
if (
|
||||
battleInfo.current.playerId === user.value.id
|
||||
battleInfo.current.playerId === user.value.id &&
|
||||
redTeam.value.length > 1
|
||||
) {
|
||||
nextTips += "你";
|
||||
}
|
||||
@@ -133,18 +132,8 @@ const recoverData = (battleInfo, {force = false, arrowOnly = false} = {}) => {
|
||||
// ShootProgress2(v-if="start")尚未挂载,update-remain 事件会被丢弃。
|
||||
// 同时 HeaderProgress 对含"重回"的 tips 拦截音频,倒计时无法依赖
|
||||
// onAudioEnded 驱动,需在 nextTick 后直接启动。
|
||||
|
||||
// playerId=0 表示后端处于过渡状态(上一位射手已完成、下一位尚未分配)
|
||||
// 此时 startTime/targetTeam 均不可靠,停止进度条并等待 WS ToSomeoneShoot 驱动
|
||||
if (!battleInfo.current.playerId) {
|
||||
nextTick(() => {
|
||||
uni.$emit("update-tips", nextTips);
|
||||
uni.$emit("update-remain", {stop: true});
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
const elapsed = (Date.now() - battleInfo.current.startTime) / 1000;
|
||||
console.log(`当前轮已进行${elapsed}秒`);
|
||||
if (elapsed > 0 && elapsed < shootTimeTotal.value) {
|
||||
updateRemainSecond.value = shootTimeTotal.value - elapsed - 0.2;
|
||||
}
|
||||
@@ -212,9 +201,6 @@ function onBattleEnd() {
|
||||
function onNewRound(msg, prevRound) {
|
||||
showRoundTip.value = true;
|
||||
isFinalShoot.value = msg.current.goldRound;
|
||||
// 新轮次开始时立即清空靶纸箭迹,避免残留上一轮落点至新轮次第一箭到来
|
||||
scores.value = [];
|
||||
blueScores.value = [];
|
||||
// 决金轮箭数不确定(平局后可能再加一箭),清零 totalShot 隐藏箭数显示
|
||||
if (msg.current.goldRound) {
|
||||
store.updateShotInfo(0, 0);
|
||||
@@ -233,27 +219,6 @@ 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) {
|
||||
if (Array.isArray(msg)) return;
|
||||
if (msg.type === MESSAGETYPESV2.BattleStart) {
|
||||
@@ -268,9 +233,6 @@ async function onReceiveMessage(msg) {
|
||||
} else if (msg.type === MESSAGETYPESV2.ShootResult) {
|
||||
showRoundTip.value = false;
|
||||
recoverData(msg, {arrowOnly: true});
|
||||
// 检测同一玩家三箭全 X 环,触发 tententen 音效
|
||||
// currentShooterId 在 ToSomeoneShoot 时写入,ShootResult 不会覆盖,可靠识别本次射手
|
||||
checkAndPlayTententen(currentShooterId.value, !!(msg.shootData?.ringX && msg.shootData?.ring));
|
||||
} else if (msg.type === MESSAGETYPESV2.NewRound) {
|
||||
// 在进入延迟前先捕获当前轮次,供 onNewRound 使用,防止 800ms 内 ToSomeoneShoot 提前更新 currentRound 造成 Tip 展示错轮
|
||||
const prevRound = currentRound.value;
|
||||
@@ -322,8 +284,6 @@ onBeforeUnmount(() => {
|
||||
const refreshTimer = ref(null);
|
||||
onShow(async () => {
|
||||
if (battleId.value) {
|
||||
// 延迟 300ms 等待网络恢复,避免小程序从后台切回时网络尚未就绪导致请求失败报错
|
||||
await new Promise(resolve => setTimeout(resolve, 300));
|
||||
const result = await getBattleAPI(battleId.value);
|
||||
if (!result) return;
|
||||
if (result.status === 2) {
|
||||
|
||||
@@ -145,7 +145,7 @@ const buildVersion = typeof __BUILD_TIME__ !== 'undefined' ? __BUILD_TIME__ : ''
|
||||
v-if="showLogout"
|
||||
/>
|
||||
<UserItem
|
||||
title="版本信息(仅用于测试)"
|
||||
title="版本信息"
|
||||
v-if="showLogout"
|
||||
>{{ buildVersion }}</UserItem>
|
||||
<UserItem
|
||||
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 4.6 KiB After Width: | Height: | Size: 5.8 KiB |
16
src/store.js
16
src/store.js
@@ -154,14 +154,14 @@ export default defineStore("store", {
|
||||
},
|
||||
},
|
||||
|
||||
// 数据持久化(via pinia-plugin-persistedstate)
|
||||
// 仅持久化 user 和 device:身份凭证需在冷启动时恢复(如从分享链接进入)
|
||||
// config、game 等运行时状态不持久化,每次联网后重新拉取
|
||||
// 开启数据持久化
|
||||
persist: {
|
||||
storage: {
|
||||
getItem: (key) => uni.getStorageSync(key),
|
||||
setItem: (key, value) => uni.setStorageSync(key, value),
|
||||
},
|
||||
paths: ['user', 'device'],
|
||||
enabled: true,
|
||||
strategies: [
|
||||
{
|
||||
storage: uni.getStorageSync,
|
||||
paths: ["user", "device", "config"], // 只持久化用户信息
|
||||
},
|
||||
],
|
||||
},
|
||||
});
|
||||
|
||||
158
src/websocket.js
158
src/websocket.js
@@ -1,12 +1,22 @@
|
||||
import { MESSAGETYPES, getMessageTypeName } from "@/constants";
|
||||
import { getUserGameState } from "@/apis";
|
||||
|
||||
let socket = null;
|
||||
let heartbeatInterval = null;
|
||||
let reconnectTimer = null;
|
||||
let manualClose = false;
|
||||
let checkingSession = false;
|
||||
let kickedOut = false;
|
||||
let isConnecting = false;
|
||||
|
||||
/**
|
||||
* 建立 WebSocket 连接
|
||||
*/
|
||||
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";
|
||||
try {
|
||||
const accountInfo = uni.getAccountInfoSync();
|
||||
@@ -20,42 +30,65 @@ function createWebSocket(token, onMessage) {
|
||||
case "trial": // 体验版
|
||||
url = "wss://apitest.shelingxingqiu.com/socket";
|
||||
break;
|
||||
case "release": // 正式版
|
||||
case "trial":
|
||||
url = "wss://apitest.shelingxingqiu.com/socket";
|
||||
break;
|
||||
case "release":
|
||||
url = "wss://api.shelingxingqiu.com/socket";
|
||||
break;
|
||||
default:
|
||||
// 保持默认值
|
||||
break;
|
||||
}
|
||||
} catch (e) {
|
||||
console.error("获取环境信息失败,使用默认正式环境", e);
|
||||
console.error("获取 WebSocket 环境信息失败,使用默认正式环境", e);
|
||||
}
|
||||
|
||||
url += `?authorization=${token}`;
|
||||
socket = uni.connectSocket({
|
||||
const socketTask = uni.connectSocket({
|
||||
url,
|
||||
success: () => {
|
||||
console.log("websocket 连接成功");
|
||||
// 启动心跳
|
||||
startHeartbeat(onMessage);
|
||||
console.log("WebSocket 已发起连接");
|
||||
},
|
||||
fail: () => {
|
||||
fail: (err) => {
|
||||
if (socket !== socketTask) return;
|
||||
console.error("WebSocket 连接失败", err);
|
||||
socket = null;
|
||||
isConnecting = false;
|
||||
reconnect(onMessage);
|
||||
},
|
||||
});
|
||||
|
||||
// 接收消息
|
||||
uni.onSocketMessage((res) => {
|
||||
socket = socketTask;
|
||||
|
||||
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);
|
||||
if (event === "pong") return;
|
||||
if (data.type) {
|
||||
console.log("收到消息:", getMessageTypeName(data.type), data.data);
|
||||
console.log(
|
||||
"收到 WebSocket 消息",
|
||||
getMessageTypeName(data.type),
|
||||
data.data
|
||||
);
|
||||
if (onMessage) onMessage({ ...(data.data || {}), type: data.type });
|
||||
return;
|
||||
}
|
||||
if (onMessage && data.updates) onMessage(data.updates);
|
||||
const msg = data.updates[0];
|
||||
if (msg) {
|
||||
console.log("收到消息:", getMessageTypeName(msg.constructor), msg);
|
||||
console.log(
|
||||
"收到 WebSocket 更新",
|
||||
getMessageTypeName(msg.constructor),
|
||||
msg
|
||||
);
|
||||
if (msg.constructor === MESSAGETYPES.RankUpdate) {
|
||||
uni.setStorageSync("latestRank", msg.lvl);
|
||||
} else if (msg.constructor === MESSAGETYPES.LvlUpdate) {
|
||||
@@ -68,84 +101,109 @@ function createWebSocket(token, onMessage) {
|
||||
}
|
||||
});
|
||||
|
||||
// 错误处理
|
||||
uni.onSocketError((err) => {
|
||||
socketTask.onError((err) => {
|
||||
if (socket !== socketTask) return;
|
||||
console.error("WebSocket 错误", err);
|
||||
reconnect(onMessage);
|
||||
});
|
||||
|
||||
uni.onSocketClose((result) => {
|
||||
socketTask.onClose(async (result) => {
|
||||
if (socket !== socketTask) return;
|
||||
console.log("WebSocket 已关闭", result);
|
||||
stopHeartbeat();
|
||||
reconnect(onMessage);
|
||||
socket = null;
|
||||
isConnecting = false;
|
||||
|
||||
if (manualClose || kickedOut) return;
|
||||
await handleUnexpectedClose(onMessage);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* 重连机制
|
||||
*/
|
||||
function reconnect(onMessage) {
|
||||
reconnectTimer && clearTimeout(reconnectTimer);
|
||||
closeWebSocket(); // 确保关闭旧连接
|
||||
async function handleUnexpectedClose(onMessage) {
|
||||
if (checkingSession || manualClose || kickedOut) return;
|
||||
|
||||
const token = uni.getStorageSync(
|
||||
`${uni.getAccountInfoSync().miniProgram.envVersion}_token`
|
||||
);
|
||||
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(() => {
|
||||
console.log("reconnecting...");
|
||||
if (manualClose || kickedOut || socket || isConnecting) return;
|
||||
console.log("WebSocket 正在重连...");
|
||||
createWebSocket(token, onMessage);
|
||||
}, 1000);
|
||||
}
|
||||
|
||||
function closeWebSocket() {
|
||||
function closeWebSocket(isManual = true) {
|
||||
manualClose = isManual;
|
||||
reconnectTimer && clearTimeout(reconnectTimer);
|
||||
stopHeartbeat();
|
||||
isConnecting = false;
|
||||
|
||||
if (socket) {
|
||||
reconnectTimer && clearTimeout(reconnectTimer);
|
||||
stopHeartbeat();
|
||||
const currentSocket = socket;
|
||||
socket = null;
|
||||
|
||||
try {
|
||||
socket.close();
|
||||
currentSocket.close();
|
||||
} catch (err) {
|
||||
console.error("关闭WebSocket连接失败", err);
|
||||
console.error("关闭 WebSocket 失败", err);
|
||||
}
|
||||
|
||||
socket = null; // 清除socket引用
|
||||
}
|
||||
}
|
||||
|
||||
function sendHeartbeat(onMessage) {
|
||||
uni.sendSocketMessage({
|
||||
if (!socket) return;
|
||||
|
||||
const currentSocket = socket;
|
||||
currentSocket.send({
|
||||
data: JSON.stringify({ event: "ping", data: {} }),
|
||||
success: () => {
|
||||
// console.log("发送心跳成功");
|
||||
},
|
||||
success: () => {},
|
||||
fail: (err) => {
|
||||
console.error("发送心跳失败", err);
|
||||
if (socket !== currentSocket) return;
|
||||
console.error("心跳发送失败", err);
|
||||
stopHeartbeat();
|
||||
closeWebSocket(); // 关闭失效的连接
|
||||
reconnect(onMessage); // 触发重连
|
||||
closeWebSocket(false);
|
||||
reconnect(onMessage);
|
||||
},
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* 启动心跳
|
||||
*/
|
||||
function startHeartbeat(onMessage) {
|
||||
stopHeartbeat(); // 防止重复启动
|
||||
stopHeartbeat();
|
||||
|
||||
heartbeatInterval = setInterval(() => {
|
||||
if (socket && socket.readyState === 1) {
|
||||
// 检查连接状态
|
||||
if (socket) {
|
||||
sendHeartbeat(onMessage);
|
||||
}
|
||||
}, 10000);
|
||||
}
|
||||
|
||||
/**
|
||||
* 停止心跳
|
||||
*/
|
||||
function stopHeartbeat() {
|
||||
if (heartbeatInterval) {
|
||||
clearInterval(heartbeatInterval);
|
||||
|
||||
@@ -3468,11 +3468,6 @@ pify@^2.3.0:
|
||||
resolved "https://registry.npmjs.org/pify/-/pify-2.3.0.tgz"
|
||||
integrity sha512-udgsAY+fTnvv7kI7aaxbqwWNb0AHiB0qBO89PZKPkoTmGOgdbrHDKD+0B2X4uTfJ/FT1R09r9gTsjUjNJotuog==
|
||||
|
||||
pinia-plugin-persistedstate@3.2.1:
|
||||
version "3.2.1"
|
||||
resolved "https://registry.npmmirror.com/pinia-plugin-persistedstate/-/pinia-plugin-persistedstate-3.2.1.tgz#66780602aecd6c7b152dd7e3ddc249a1f7a13fe5"
|
||||
integrity sha512-MK++8LRUsGF7r45PjBFES82ISnPzyO6IZx3CH5vyPseFLZCk1g2kgx6l/nW8pEBKxxd4do0P6bJw+mUSZIEZUQ==
|
||||
|
||||
pinia@2.0.36:
|
||||
version "2.0.36"
|
||||
resolved "https://registry.npmjs.org/pinia/-/pinia-2.0.36.tgz"
|
||||
|
||||
Reference in New Issue
Block a user