6 Commits
Author SHA1 Message Date
zhangyi b060d8f987 update:提交我的设备改版 2026-09-17 18:23:41 +08:00
zhangyi 46cbd37102 Merge branch 'test' into feat-shebei 2026-09-15 18:15:12 +08:00
zhangyi d4d690cb8e update:更新protocol 2026-09-15 18:12:39 +08:00
zhangyi b51813dd33 update:优化设备页 2026-09-15 17:56:36 +08:00
zhangyi a11e7f7532 Merge branch 'fix-audio' into feat-shebei 2026-09-15 15:49:26 +08:00
zhangyi 88febb92e5 update:更换语音 2026-09-15 15:44:14 +08:00
57 changed files with 1217 additions and 719 deletions
+22 -12
View File
@@ -8,9 +8,6 @@
} from "@dcloudio/uni-app"; } from "@dcloudio/uni-app";
import websocket from "@/websocket"; import websocket from "@/websocket";
import matchWebsocket from "@/matchWebsocket"; import matchWebsocket from "@/matchWebsocket";
import {
getDeviceBatteryAPI
} from "@/apis";
import { import {
MESSAGETYPES MESSAGETYPES
} from "@/constants"; } from "@/constants";
@@ -27,8 +24,9 @@
} = storeToRefs(store); } = storeToRefs(store);
const { const {
updateUser, updateUser,
updateOnline, updateDeviceStatus,
updateDeviceBattery, setDeviceOnline,
clearDeviceStatus,
showDeviceChargingDialog, showDeviceChargingDialog,
clearSessionState, clearSessionState,
clearDevice clearDevice
@@ -70,14 +68,19 @@
}); });
} }
async function emitUpdateOnline() { function emitUpdateOnline(nextOnline) {
const data = await getDeviceBatteryAPI();
const wasOnline = Boolean(online.value); const wasOnline = Boolean(online.value);
const nextOnline = Boolean(data.online); setDeviceOnline(nextOnline === true);
updateOnline(nextOnline); if (!device.value.deviceId || wasOnline === (nextOnline === true)) return;
updateDeviceBattery(nextOnline ? data?.battery ?? data?.power : null); audioManager.play(nextOnline === true ? "设备已连接" : "设备连接已断开");
if (!device.value.deviceId || wasOnline === nextOnline) return; }
audioManager.play(nextOnline ? "设备已连接" : "设备连接已断开");
function onDeviceStatusPush(status) {
updateDeviceStatus(status);
}
function onShootSocketDisconnected() {
clearDeviceStatus();
} }
function onDeviceBindInvalid() { function onDeviceBindInvalid() {
@@ -113,6 +116,10 @@
} }
function onShootWsMsg(content) { function onShootWsMsg(content) {
if (content?.event === "/addons/shoot/battery") {
onDeviceStatusPush(content.data);
return;
}
if(content.type === 'shoot-trigger'){ if(content.type === 'shoot-trigger'){
onDeviceShoot() onDeviceShoot()
} }
@@ -124,6 +131,7 @@
void audioManager.warmButton(); void audioManager.warmButton();
uni.$on("update-user", emitUpdateUser); uni.$on("update-user", emitUpdateUser);
uni.$on("update-online", emitUpdateOnline); uni.$on("update-online", emitUpdateOnline);
uni.$on("shoot-socket-disconnected", onShootSocketDisconnected);
uni.$on("session-kicked-out", onSessionKickedOut); uni.$on("session-kicked-out", onSessionKickedOut);
uni.$on("device-bind-invalid", onDeviceBindInvalid); uni.$on("device-bind-invalid", onDeviceBindInvalid);
uni.$on("device-charging", onDeviceCharging); uni.$on("device-charging", onDeviceCharging);
@@ -150,6 +158,7 @@
onHide(() => { onHide(() => {
uni.$off("update-user", emitUpdateUser); uni.$off("update-user", emitUpdateUser);
uni.$off("update-online", emitUpdateOnline); uni.$off("update-online", emitUpdateOnline);
uni.$off("shoot-socket-disconnected", onShootSocketDisconnected);
uni.$off("session-kicked-out", onSessionKickedOut); uni.$off("session-kicked-out", onSessionKickedOut);
uni.$off("device-bind-invalid", onDeviceBindInvalid); uni.$off("device-bind-invalid", onDeviceBindInvalid);
uni.$off("device-charging", onDeviceCharging); uni.$off("device-charging", onDeviceCharging);
@@ -159,6 +168,7 @@
matchWebsocket.closeMatchWebSocket({ matchWebsocket.closeMatchWebSocket({
reason: "app-hide" reason: "app-hide"
}); });
clearDeviceStatus();
websocket.closeWebSocket(); websocket.closeWebSocket();
}); });
</script> </script>
+4 -4
View File
@@ -285,6 +285,10 @@ export const getDeviceDetailAPI = (deviceId) => {
return request("GET", `/user/device/getDetail?deviceId=${encodeURIComponent(deviceId)}`); return request("GET", `/user/device/getDetail?deviceId=${encodeURIComponent(deviceId)}`);
}; };
export const updateDeviceAliasAPI = (deviceId, alias) => {
return request("POST", "/user/device/updateAlias", {deviceId, alias});
};
export const createPractiseAPI = (arrows, time, target) => { export const createPractiseAPI = (arrows, time, target) => {
return request("POST", "/user/practice/create", { return request("POST", "/user/practice/create", {
shootNumber: arrows, shootNumber: arrows,
@@ -565,10 +569,6 @@ export const laserCloseAPI = async () => {
return request("POST", "/user/device/closeAim"); return request("POST", "/user/device/closeAim");
}; };
export const getDeviceBatteryAPI = async () => {
return request("GET", "/user/device/battery");
};
// 设备连接指定 WiFi,只下发 WiFi 凭证,不触发 OTA 升级。 // 设备连接指定 WiFi,只下发 WiFi 凭证,不触发 OTA 升级。
export const connectDeviceWifiAPI = async (ssid, password) => { export const connectDeviceWifiAPI = async (ssid, password) => {
return request("POST", "/user/hardwareBox/connectWifi", {ssid, password}); return request("POST", "/user/hardwareBox/connectWifi", {ssid, password});
+5 -34
View File
@@ -1,44 +1,15 @@
<script setup> <script setup>
import { ref, onMounted, onBeforeUnmount } from "vue"; import useStore from "@/store";
import { getDeviceBatteryAPI } from "@/apis"; import { storeToRefs } from "pinia";
const power = ref(0); const store = useStore();
const timer = ref(null); const { deviceBattery: power } = storeToRefs(store);
let disposed = false;
let requestInFlight = false;
const refreshPower = async () => {
if (disposed || requestInFlight) return;
requestInFlight = true;
try {
const data = await getDeviceBatteryAPI();
if (!disposed) power.value = data.battery;
} catch (_) {
// 电量轮询失败时等待下一轮,避免产生未处理的 Promise 拒绝。
} finally {
requestInFlight = false;
}
};
onMounted(async () => {
await refreshPower();
if (disposed) return;
timer.value = setInterval(() => {
void refreshPower();
}, 1000 * 10);
});
onBeforeUnmount(() => {
disposed = true;
clearInterval(timer.value);
timer.value = null;
});
</script> </script>
<template> <template>
<view class="container"> <view class="container">
<image src="../static/b-power.png" mode="widthFix" /> <image src="../static/b-power.png" mode="widthFix" />
<view>电量{{ power || 1 }}%</view> <view>{{ power === null ? "电量--" : `电量${power}%` }}</view>
</view> </view>
</template> </template>
+11 -24
View File
@@ -1,10 +1,11 @@
<script setup> <script setup>
import { computed } from "vue"; import { computed } from "vue";
import { getDeviceBatteryAPI } from "@/apis"; import useStore from "@/store";
import { storeToRefs } from "pinia";
const OTA_MIN_BATTERY = 50;
const OTA_LOW_BATTERY_TEXT = "电量不足 50%,暂不支持 OTA 升级";
const OTA_OFFLINE_TEXT = "请先开启智能弓"; const OTA_OFFLINE_TEXT = "请先开启智能弓";
const store = useStore();
const { deviceStatus } = storeToRefs(store);
const props = defineProps({ const props = defineProps({
visible: { visible: {
@@ -48,27 +49,13 @@ const isFailure = computed(() => props.state === "update_failure");
// Clamp progress to keep the progress bar width within its container. // Clamp progress to keep the progress bar width within its container.
const progressValue = computed(() => Math.min(100, Math.max(0, Number(props.progress) || 0))); const progressValue = computed(() => Math.min(100, Math.max(0, Number(props.progress) || 0)));
// 点击立即更新前先校验设备在线状态,再校验设备电量 // 点击立即更新前先校验设备在线状态。
const handleUpdateClick = async () => { const handleUpdateClick = () => {
try { if (deviceStatus.value?.online !== true) {
const deviceStatus = await getDeviceBatteryAPI(); uni.showToast({
if (deviceStatus?.online !== true) { title: OTA_OFFLINE_TEXT,
uni.showToast({ icon: "none",
title: OTA_OFFLINE_TEXT, });
icon: "none",
});
return;
}
if (Number(deviceStatus?.battery) <= OTA_MIN_BATTERY) {
uni.showToast({
title: OTA_LOW_BATTERY_TEXT,
icon: "none",
});
return;
}
} catch (err) {
emit("update");
return; return;
} }
emit("update"); emit("update");
+1 -4
View File
@@ -12,12 +12,11 @@ import {
getHomeData, getHomeData,
getPhoneNumberAPI, getPhoneNumberAPI,
getPhoneNumberAPIv2, getPhoneNumberAPIv2,
getDeviceBatteryAPI,
} from "@/apis"; } from "@/apis";
import useStore from "@/store"; import useStore from "@/store";
const store = useStore(); const store = useStore();
const { updateUser, updateDevice, updateOnline, clearDevice } = store; const { updateUser, updateDevice, clearDevice } = store;
const props = defineProps({ const props = defineProps({
show: { show: {
@@ -125,8 +124,6 @@ async function doLogin() {
devices.bindings[0].deviceId, devices.bindings[0].deviceId,
devices.bindings[0].deviceName devices.bindings[0].deviceName
); );
const data = await getDeviceBatteryAPI();
updateOnline(data.online);
} else { } else {
clearDevice(); clearDevice();
} }
+3
View File
@@ -147,6 +147,9 @@
{ {
"path": "my-device" "path": "my-device"
}, },
{
"path": "device-qrcode"
},
{ {
"path": "device-bind-success" "path": "device-bind-success"
}, },
@@ -6,7 +6,6 @@ export function useDeviceBinding({
binding, binding,
updateDevice, updateDevice,
deviceDetails, deviceDetails,
refreshDeviceStatus,
}) { }) {
const showBindFailurePage = () => { const showBindFailurePage = () => {
uni.hideToast(); uni.hideToast();
@@ -63,7 +62,6 @@ export function useDeviceBinding({
const applyBoundDevice = () => { const applyBoundDevice = () => {
updateDevice(deviceId, deviceName); updateDevice(deviceId, deviceName);
deviceDetails.value = result || {}; deviceDetails.value = result || {};
void refreshDeviceStatus();
}; };
uni.navigateTo({ uni.navigateTo({
url: `/pages/device/device-bind-success?deviceId=${encodeURIComponent(deviceId)}`, url: `/pages/device/device-bind-success?deviceId=${encodeURIComponent(deviceId)}`,
+96 -25
View File
@@ -1,19 +1,23 @@
import { computed, ref } from "vue"; import { computed, ref } from "vue";
import { getDeviceBatteryAPI, getMyDevicesAPI, unbindDeviceAPI } from "@/apis"; import {
getDeviceDetailAPI,
getMyDevicesAPI,
unbindDeviceAPI,
} from "@/apis";
export const DEVICE_NAME_STORAGE_KEY = "device_name_overrides"; export const DEVICE_NAME_STORAGE_KEY = "device_name_overrides";
export function useDeviceStatus({ export function useDeviceStatus({
user, user,
device, device,
deviceStatus,
online, online,
updateDevice, updateDevice,
updateOnline,
clearDevice, clearDevice,
unbindDialogVisible, unbindDialogVisible,
}) { }) {
const deviceStatus = ref({});
const deviceDetails = ref({}); const deviceDetails = ref({});
let deviceDetailRequestVersion = 0;
const isDeviceOnline = computed( const isDeviceOnline = computed(
() => deviceStatus.value.online === true || online.value === true () => deviceStatus.value.online === true || online.value === true
@@ -23,16 +27,32 @@ export function useDeviceStatus({
isDeviceOnline.value ? "device-status--online" : "device-status--offline" isDeviceOnline.value ? "device-status--online" : "device-status--offline"
); );
const battery = computed(() => { const battery = computed(() => {
const value = Number( const rawValue = deviceStatus.value.battery ?? deviceStatus.value.power;
deviceStatus.value.battery ?? deviceStatus.value.power ?? 0 if (rawValue === null || rawValue === undefined || rawValue === "") return null;
); const value = Number(rawValue);
return Number.isFinite(value) && value > 0 ? Math.min(100, value) : 0; return Number.isFinite(value) ? Math.min(100, Math.max(0, value)) : null;
}); });
const batteryText = computed(() => const batteryText = computed(() =>
battery.value ? `${battery.value}%` : "暂无数据" battery.value === null ? "暂无数据" : `${battery.value}%`
);
const onlineDurationText = computed(() => {
const rawDuration = deviceStatus.value.onlineDuration;
if (rawDuration == null || String(rawDuration).trim() === "") return "--";
const seconds = Number(rawDuration);
if (!Number.isFinite(seconds) || seconds < 0) return "--";
// WS 推送秒数,页面按完整分钟展示累计使用时间。
const totalMinutes = Math.floor(seconds / 60);
const hours = Math.floor(totalMinutes / 60);
const minutes = totalMinutes % 60;
return hours > 0 ? `${hours}小时${minutes}分钟` : `${minutes}分钟`;
});
const networkType = computed(() =>
String(deviceStatus.value.netType ?? "").trim().toLowerCase()
); );
const networkText = computed(() => { const networkText = computed(() => {
const netType = String(deviceStatus.value.netType || "").toLowerCase(); const netType = networkType.value;
if (netType === "wifi") return "WiFi"; if (netType === "wifi") return "WiFi";
if (netType === "4g") return "4G"; if (netType === "4g") return "4G";
return isDeviceOnline.value ? "在线" : "未连接"; return isDeviceOnline.value ? "在线" : "未连接";
@@ -55,15 +75,37 @@ export function useDeviceStatus({
return value && typeof value === "object" ? value : {}; return value && typeof value === "object" ? value : {};
}; };
const refreshDeviceStatus = async () => { const refreshDeviceDetails = async () => {
if (!device.value.deviceId) return; const deviceId = device.value.deviceId;
if (!deviceId) return;
const requestVersion = ++deviceDetailRequestVersion;
try { try {
const result = await getDeviceBatteryAPI(); const detailResponse = await getDeviceDetailAPI(deviceId);
deviceStatus.value = result || {}; const detail = detailResponse?.detail || detailResponse?.data?.detail;
updateOnline(result?.online === true); if (
!detail ||
typeof detail !== "object" ||
requestVersion !== deviceDetailRequestVersion ||
device.value.deviceId !== deviceId
) {
return;
}
deviceDetails.value = {
...deviceDetails.value,
...detail,
deviceModelName: detail.deviceModelName ?? "",
bindTime: String(
detail.bindTime ?? deviceDetails.value.bindTime ?? ""
).trim(),
qrCodeUrl: String(
detail.qrCodeUrl ?? deviceDetails.value.qrCodeUrl ?? ""
).trim(),
};
} catch (error) { } catch (error) {
deviceStatus.value = {}; // 实时刷新失败时保留当前页面数据,等待下次通知或页面重新显示。
console.log("获取设备状态失败", error); console.log("刷新设备详情失败", error);
} }
}; };
@@ -74,19 +116,46 @@ export function useDeviceStatus({
if (Array.isArray(devices?.bindings) && devices.bindings.length > 0) { if (Array.isArray(devices?.bindings) && devices.bindings.length > 0) {
const currentDevice = devices.bindings[0]; const currentDevice = devices.bindings[0];
const nameOverrides = getDeviceNameOverrides(); const nameOverrides = getDeviceNameOverrides();
deviceDetails.value = currentDevice; // 二维码和绑定时间仅取详情接口,绑定列表不能作为这两项的回退数据。
let latestDevice = {
...currentDevice,
deviceModelName: "",
bindTime: "",
qrCodeUrl: "",
};
try {
const detailResponse = await getDeviceDetailAPI(currentDevice.deviceId);
const detail = detailResponse?.detail || detailResponse?.data?.detail;
if (detail && typeof detail === "object") {
latestDevice = {
...currentDevice,
...detail,
deviceModelName: detail.deviceModelName ?? "",
bindTime: String(detail.bindTime ?? "").trim(),
qrCodeUrl: String(detail.qrCodeUrl ?? "").trim(),
deviceName:
detail.deviceAlias || detail.deviceName || currentDevice.deviceName,
};
}
} catch (error) {
// 详情接口失败时保留绑定关系,二维码和绑定时间仍保持为空。
console.log("获取设备详情失败", error);
}
deviceDetails.value = latestDevice;
updateDevice( updateDevice(
currentDevice.deviceId, latestDevice.deviceId,
nameOverrides[currentDevice.deviceId] || nameOverrides[latestDevice.deviceId] ||
currentDevice.deviceName || latestDevice.deviceAlias ||
currentDevice.name || latestDevice.deviceName ||
latestDevice.name ||
"我的智能弓" "我的智能弓"
); );
await refreshDeviceStatus();
return; return;
} }
clearDevice(); clearDevice();
deviceStatus.value = {}; deviceDetailRequestVersion += 1;
deviceDetails.value = {}; deviceDetails.value = {};
} catch (error) { } catch (error) {
console.log("同步设备绑定失败", error); console.log("同步设备绑定失败", error);
@@ -99,7 +168,7 @@ export function useDeviceStatus({
await unbindDeviceAPI(device.value.deviceId); await unbindDeviceAPI(device.value.deviceId);
uni.setStorageSync("calibration", false); uni.setStorageSync("calibration", false);
clearDevice(); clearDevice();
deviceStatus.value = {}; deviceDetailRequestVersion += 1;
deviceDetails.value = {}; deviceDetails.value = {};
unbindDialogVisible.value = false; unbindDialogVisible.value = false;
uni.showToast({ title: "解绑成功", icon: "success" }); uni.showToast({ title: "解绑成功", icon: "success" });
@@ -120,7 +189,9 @@ export function useDeviceStatus({
isDeviceOnline, isDeviceOnline,
maskedDeviceId, maskedDeviceId,
networkText, networkText,
refreshDeviceStatus, networkType,
onlineDurationText,
refreshDeviceDetails,
statusClass, statusClass,
statusText, statusText,
syncDeviceBinding, syncDeviceBinding,
+192
View File
@@ -0,0 +1,192 @@
<script setup>
import { ref } from "vue";
import { onLoad } from "@dcloudio/uni-app";
import Container from "@/components/Container.vue";
import { getDeviceDetailAPI } from "@/apis";
import useStore from "@/store";
import { storeToRefs } from "pinia";
const store = useStore();
const { device } = storeToRefs(store);
const deviceId = ref("");
const qrImageUrl = ref("");
const qrSaved = ref(false);
const loading = ref(true);
const loadQrCode = async () => {
if (!deviceId.value) {
loading.value = false;
return;
}
try {
const response = await getDeviceDetailAPI(deviceId.value);
const detail = response?.detail || response?.data?.detail;
qrImageUrl.value = String(detail?.qrCodeUrl ?? "").trim();
} catch (error) {
console.error("获取设备二维码失败", error);
qrImageUrl.value = "";
} finally {
loading.value = false;
}
};
const saveQrCode = async () => {
if (!qrImageUrl.value) return;
let filePath = qrImageUrl.value;
try {
if (/^https?:\/\//.test(filePath)) {
filePath = await new Promise((resolve, reject) => {
uni.downloadFile({
url: filePath,
success: (result) =>
result.statusCode === 200
? resolve(result.tempFilePath)
: reject(new Error("二维码下载失败")),
fail: reject,
});
});
}
await new Promise((resolve, reject) => {
uni.saveImageToPhotosAlbum({ success: resolve, fail: reject, filePath });
});
qrSaved.value = true;
uni.showToast({ title: "已保存至相册", icon: "success" });
} catch (error) {
uni.showToast({ title: "请长按二维码保存", icon: "none" });
}
};
onLoad((options = {}) => {
try {
deviceId.value = decodeURIComponent(options.deviceId || "") || device.value.deviceId || "";
} catch (error) {
deviceId.value = device.value.deviceId || "";
}
void loadQrCode();
});
</script>
<template>
<Container :bgType="12" :scroll="false">
<view class="qr-page">
<view class="qr-corner qr-corner--top"></view>
<view class="qr-corner qr-corner--bottom"></view>
<view class="qr-canvas">
<text v-if="loading" class="qr-empty">二维码加载中...</text>
<template v-else-if="qrImageUrl">
<image class="qr-image" :src="qrImageUrl" mode="aspectFit" show-menu-by-longpress />
<text v-if="qrSaved" class="qr-device-id">设备ID{{ deviceId }}</text>
<view v-else class="qr-save-button" @click="saveQrCode">
<text>保存至相册</text>
</view>
<text class="qr-description">
该二维码为当前绑定弓箭的二维码你可以截图保存到相册以便当二维码丢失或不在身边时可以扫描二维码进行设备绑定
</text>
<text class="qr-note">解除绑定后将无法查看该二维码</text>
</template>
<text v-else class="qr-empty">暂无设备二维码</text>
</view>
</view>
</Container>
</template>
<style scoped>
.qr-page {
position: relative;
width: 100%;
height: 100%;
min-height: 0;
box-sizing: border-box;
overflow: hidden;
background: transparent;
}
.qr-corner {
position: absolute;
width: 300rpx;
height: 300rpx;
background: #ffeb00;
}
.qr-corner--top {
top: -220rpx;
right: -170rpx;
transform: rotate(42deg);
}
.qr-corner--bottom {
bottom: -220rpx;
left: -170rpx;
transform: rotate(42deg);
}
.qr-canvas {
position: relative;
z-index: 1;
display: flex;
width: 100%;
height: 100%;
min-height: 0;
box-sizing: border-box;
flex-direction: column;
align-items: center;
padding: 260rpx 62rpx 70rpx;
}
.qr-image {
width: 432rpx;
height: 432rpx;
box-sizing: border-box;
background: #ffffff;
}
.qr-save-button {
display: flex;
width: 360rpx;
height: 72rpx;
align-items: center;
justify-content: center;
margin-top: 34rpx;
border: 1rpx solid #e8c840;
border-radius: 36rpx;
color: #ffe846;
font-size: 26rpx;
}
.qr-device-id,
.qr-empty {
color: rgba(255, 255, 255, 0.72);
font-size: 26rpx;
line-height: 40rpx;
text-align: center;
}
.qr-device-id {
margin-top: 24rpx;
}
.qr-empty {
margin-top: 140rpx;
}
.qr-description,
.qr-note {
width: 100%;
color: rgba(255, 255, 255, 0.6);
font-size: 22rpx;
line-height: 36rpx;
text-align: center;
}
.qr-description {
margin-top: 42rpx;
}
.qr-note {
margin-top: 12rpx;
color: rgba(255, 232, 70, 0.7);
}
</style>
File diff suppressed because it is too large Load Diff
+74 -74
View File
@@ -1,15 +1,19 @@
<script setup> <script setup>
import { ref, computed, onMounted, onUnmounted } from "vue"; import { ref, computed, onMounted, onUnmounted, watch } from "vue";
import { onLoad, onShow } from "@dcloudio/uni-app"; import { onLoad, onShow } from "@dcloudio/uni-app";
import Container from "@/components/Container.vue"; import Container from "@/components/Container.vue";
import ScreenHint from "@/components/ScreenHint.vue"; import ScreenHint from "@/components/ScreenHint.vue";
import { import {
connectDeviceWifiAPI, connectDeviceWifiAPI,
getDeviceBatteryAPI,
getHardwareBoxTaskStatusAPI, getHardwareBoxTaskStatusAPI,
getHardwareBoxVersionAPI, getHardwareBoxVersionAPI,
sendHardwareBoxUpdateAPI, sendHardwareBoxUpdateAPI,
} from "@/apis"; } from "@/apis";
import useStore from "@/store";
import { storeToRefs } from "pinia";
const store = useStore();
const { deviceStatus } = storeToRefs(store);
const STATES = { const STATES = {
SCANNING: "SCANNING", SCANNING: "SCANNING",
@@ -48,14 +52,13 @@ const progress = ref(0);
let progressTimer = null; let progressTimer = null;
let timeoutTimer = null; let timeoutTimer = null;
let statusTimer = null; let statusTimer = null;
let wifiConnectTimer = null; let wifiConnectTimeoutTimer = null;
let stopWifiStatusWatcher = null;
let settleWifiConnectWaiting = null;
let wifiConnectRequestId = 0; let wifiConnectRequestId = 0;
let wifiConnectPollCount = 0; const WIFI_CONNECT_TIMEOUT = 60000;
const WIFI_CONNECT_POLL_INTERVAL = 2000; const DEVICE_STATUS_STALE_TIME = 6000;
const WIFI_CONNECT_MAX_POLL_COUNT = 30;
const WIFI_CONNECT_FAILED_TEXT = "连接失败,请检查WiFi密码或WiFi状态"; const WIFI_CONNECT_FAILED_TEXT = "连接失败,请检查WiFi密码或WiFi状态";
const OTA_MIN_BATTERY = 50;
const OTA_LOW_BATTERY_TEXT = "电量不足 50%,暂不支持 OTA 升级";
// 控制授权拒绝弹窗显示/隐藏 // 控制授权拒绝弹窗显示/隐藏
const wifiAuthDeniedVisible = ref(false); const wifiAuthDeniedVisible = ref(false);
@@ -207,7 +210,7 @@ const startScanning = () => {
// 选择列表中的 WiFi,并打开密码输入弹窗。 // 选择列表中的 WiFi,并打开密码输入弹窗。
const selectWifi = (wifi) => { const selectWifi = (wifi) => {
cancelWifiConnectPolling(); cancelWifiConnectWaiting();
connectingWifi.value = wifi; connectingWifi.value = wifi;
connectInput.value = { ssid: wifi.SSID, password: "" }; connectInput.value = { ssid: wifi.SSID, password: "" };
connectMode.value = wifi.secure ? "secure" : "open"; connectMode.value = wifi.secure ? "secure" : "open";
@@ -217,7 +220,7 @@ const selectWifi = (wifi) => {
// 选择手动输入 WiFi,并打开手动输入弹窗。 // 选择手动输入 WiFi,并打开手动输入弹窗。
const selectOther = () => { const selectOther = () => {
cancelWifiConnectPolling(); cancelWifiConnectWaiting();
connectingWifi.value = null; connectingWifi.value = null;
connectInput.value = { ssid: "", password: "" }; connectInput.value = { ssid: "", password: "" };
connectMode.value = "manual"; connectMode.value = "manual";
@@ -225,9 +228,9 @@ const selectOther = () => {
currentState.value = STATES.CONNECTING; currentState.value = STATES.CONNECTING;
}; };
// 关闭连接弹窗,并停止当前 WiFi 连接轮询 // 关闭连接弹窗,并停止等待当前 WiFi 连接结果
const closeConnectSheet = () => { const closeConnectSheet = () => {
cancelWifiConnectPolling(); cancelWifiConnectWaiting();
connectError.value = ""; connectError.value = "";
currentState.value = connectedWifi.value ? STATES.CONNECTED : STATES.LIST; currentState.value = connectedWifi.value ? STATES.CONNECTED : STATES.LIST;
}; };
@@ -257,89 +260,84 @@ const wifiListScrollHeight = computed(() => {
return `${Math.min(itemCount * 92, maxHeight)}rpx`; return `${Math.min(itemCount * 92, maxHeight)}rpx`;
}); });
// 清理 WiFi 连接轮询定时器。 // 清理本次 WiFi 连接状态监听和超时计时器。
const clearWifiConnectTimer = () => { const clearWifiConnectWatcher = () => {
clearTimeout(wifiConnectTimer); clearTimeout(wifiConnectTimeoutTimer);
wifiConnectTimer = null; wifiConnectTimeoutTimer = null;
wifiConnectPollCount = 0; if (stopWifiStatusWatcher) {
stopWifiStatusWatcher();
stopWifiStatusWatcher = null;
}
}; };
// 取消当前 WiFi 连接轮询,并恢复弹窗提交状态。 // 取消当前 WiFi 连接确认,并恢复弹窗提交状态。
const cancelWifiConnectPolling = () => { const cancelWifiConnectWaiting = () => {
wifiConnectRequestId += 1; wifiConnectRequestId += 1;
clearWifiConnectTimer(); if (settleWifiConnectWaiting) {
settleWifiConnectWaiting(false);
}
clearWifiConnectWatcher();
connectStatusText.value = ""; connectStatusText.value = "";
isSubmittingWifi.value = false; isSubmittingWifi.value = false;
uni.hideLoading(); uni.hideLoading();
}; };
// 判断设备电量接口返回的 online/netType 字段,确定设备是否已通过 WiFi 在线。 // 根据实时推送的 online/netType 判断设备是否已通过 WiFi 在线。
// 返回值含义:true → WiFi 在线成功;"net_fail" → 设备走 4g 失败;false → 未就绪,需继续轮询 // 返回值含义:true → WiFi 在线成功;"net_fail" → 设备走 4g 失败;false → 未就绪。
const isDeviceConnectedByWifi = (deviceStatus) => { const isDeviceConnectedByWifi = (deviceStatus) => {
// online 不为 true → 设备在线,继续轮询 // online 不为 true → 设备尚未在线,继续等待推送
if (deviceStatus?.online !== true) return false; if (deviceStatus?.online !== true) return false;
const netType = String(deviceStatus?.netType || "").toLowerCase(); const netType = String(deviceStatus?.netType || "").toLowerCase();
// online:true + netType:4g → 设备已切 4gWiFi 连接失败 // online:true + netType:4g → 设备已切 4gWiFi 连接失败
if (netType === "4g") return "net_fail"; if (netType === "4g") return "net_fail";
// online:true + netType:wifi → WiFi 连接成功 // online:true + netType:wifi → WiFi 连接成功
// online:true + netType:"" → 设备在线但 netType 暂未上报,继续轮询等待 // online:true + netType:"" → 设备在线但 netType 暂未上报,继续等待推送
return netType === "wifi"; return netType === "wifi";
}; };
// 轮询设备电量接口,等待设备切到 WiFi 在线;netType:4g 快速失败,超时 30 次后放弃 // 等待提交配置后的新 WS 状态;忽略提交前的旧状态,超时后按连接失败处理
const waitForDeviceWifiConnected = (requestId) => { const waitForDeviceWifiConnected = (requestId, receivedAfter) => {
return new Promise((resolve) => { return new Promise((resolve) => {
const poll = async () => { let settled = false;
if (requestId !== wifiConnectRequestId) { const finish = (result) => {
resolve(false); if (settled) return;
return; settled = true;
} clearWifiConnectWatcher();
settleWifiConnectWaiting = null;
wifiConnectPollCount += 1; resolve(result);
try {
const deviceStatus = await getDeviceBatteryAPI();
if (requestId !== wifiConnectRequestId) {
resolve(false);
return;
}
const connResult = isDeviceConnectedByWifi(deviceStatus);
// online:true + netType:wifi → 成功
if (connResult === true) {
resolve(true);
return;
}
// online:true + netType:4g → 立即失败(设备已切 4g,WiFi 连不上)
if (connResult === "net_fail") {
resolve(false);
return;
}
// online:false + netType:"" → 继续轮询
// online:true + netType:"" → 忽略,继续轮询(netType 暂未上报)
} catch (err) {
if (requestId !== wifiConnectRequestId) {
resolve(false);
return;
}
}
if (wifiConnectPollCount >= WIFI_CONNECT_MAX_POLL_COUNT) {
resolve(false);
return;
}
wifiConnectTimer = setTimeout(poll, WIFI_CONNECT_POLL_INTERVAL);
}; };
poll(); settleWifiConnectWaiting = finish;
stopWifiStatusWatcher = watch(
deviceStatus,
(status) => {
if (requestId !== wifiConnectRequestId) {
finish(false);
return;
}
if (Number(status?.receivedAt) <= receivedAfter) return;
const connResult = isDeviceConnectedByWifi(status);
if (connResult === true) {
finish(true);
} else if (connResult === "net_fail") {
finish(false);
}
}
);
wifiConnectTimeoutTimer = setTimeout(
() => finish(false),
WIFI_CONNECT_TIMEOUT
);
}); });
}; };
// 提交 WiFi 配置给游戏设备,并轮询确认设备真实连上 WiFi 后再展示成功。 // 提交 WiFi 配置给游戏设备,并通过 WS 确认设备真实连上 WiFi 后再展示成功。
const submitDeviceWifiConfig = async ({ ssid, password }) => { const submitDeviceWifiConfig = async ({ ssid, password }) => {
if (isSubmittingWifi.value) return; if (isSubmittingWifi.value) return;
wifiConnectRequestId += 1; wifiConnectRequestId += 1;
const requestId = wifiConnectRequestId; const requestId = wifiConnectRequestId;
clearWifiConnectTimer(); clearWifiConnectWatcher();
isSubmittingWifi.value = true; isSubmittingWifi.value = true;
connectStatusText.value = "WiFi连接中..."; connectStatusText.value = "WiFi连接中...";
uni.showLoading({ uni.showLoading({
@@ -348,7 +346,8 @@ const submitDeviceWifiConfig = async ({ ssid, password }) => {
}); });
try { try {
await connectDeviceWifiAPI(ssid, password); await connectDeviceWifiAPI(ssid, password);
const isConnected = await waitForDeviceWifiConnected(requestId); if (requestId !== wifiConnectRequestId) return;
const isConnected = await waitForDeviceWifiConnected(requestId, Date.now());
if (requestId !== wifiConnectRequestId) return; if (requestId !== wifiConnectRequestId) return;
if (!isConnected) { if (!isConnected) {
connectError.value = WIFI_CONNECT_FAILED_TEXT; connectError.value = WIFI_CONNECT_FAILED_TEXT;
@@ -369,7 +368,7 @@ const submitDeviceWifiConfig = async ({ ssid, password }) => {
} }
} finally { } finally {
if (requestId === wifiConnectRequestId) { if (requestId === wifiConnectRequestId) {
clearWifiConnectTimer(); clearWifiConnectWatcher();
connectStatusText.value = ""; connectStatusText.value = "";
isSubmittingWifi.value = false; isSubmittingWifi.value = false;
uni.hideLoading(); uni.hideLoading();
@@ -456,7 +455,9 @@ const pollUpdateTaskStatus = (taskId) => {
// 判断设备是否满足 OTA 更新条件,不满足时返回精确提示文案。 // 判断设备是否满足 OTA 更新条件,不满足时返回精确提示文案。
const getUpdateDisabledReason = (deviceStatus) => { const getUpdateDisabledReason = (deviceStatus) => {
if (deviceStatus?.online !== true) return "请先开启智能弓"; if (deviceStatus?.online !== true) return "请先开启智能弓";
if (Number(deviceStatus?.battery) <= OTA_MIN_BATTERY) return OTA_LOW_BATTERY_TEXT; if (Date.now() - Number(deviceStatus?.receivedAt || 0) > DEVICE_STATUS_STALE_TIME) {
return "设备状态同步中,请稍后重试";
}
if (String(deviceStatus?.netType || "").toLowerCase() !== "wifi") return "设备当前未连接 WiFi,请先连接 WiFi 后再更新"; if (String(deviceStatus?.netType || "").toLowerCase() !== "wifi") return "设备当前未连接 WiFi,请先连接 WiFi 后再更新";
return ""; return "";
}; };
@@ -480,8 +481,7 @@ const startUpdate = async () => {
isStartingUpdate.value = true; isStartingUpdate.value = true;
try { try {
const deviceStatus = await getDeviceBatteryAPI(); const disabledReason = getUpdateDisabledReason(deviceStatus.value);
const disabledReason = getUpdateDisabledReason(deviceStatus);
if (disabledReason) { if (disabledReason) {
isStartingUpdate.value = false; isStartingUpdate.value = false;
uni.showToast({ uni.showToast({
@@ -612,7 +612,7 @@ onUnmounted(() => {
if (typeof uni.offKeyboardHeightChange === "function") { if (typeof uni.offKeyboardHeightChange === "function") {
uni.offKeyboardHeightChange(handleKeyboardHeightChange); uni.offKeyboardHeightChange(handleKeyboardHeightChange);
} }
cancelWifiConnectPolling(); cancelWifiConnectWaiting();
clearUpdateTimers(); clearUpdateTimers();
wx.offGetWifiList && wx.offGetWifiList(); wx.offGetWifiList && wx.offGetWifiList();
}); });
+35 -131
View File
@@ -1,6 +1,6 @@
<script setup> <script setup>
import {computed, onMounted, onUnmounted, ref, watch} from "vue"; import {computed, onMounted, onUnmounted, ref, watch} from "vue";
import {onHide, onShareAppMessage, onShareTimeline, onShow} from "@dcloudio/uni-app"; import {onShareAppMessage, onShareTimeline, onShow} from "@dcloudio/uni-app";
import Container from "@/components/Container.vue"; import Container from "@/components/Container.vue";
import AppFooter from "@/components/AppFooter.vue"; import AppFooter from "@/components/AppFooter.vue";
import UserHeader from "@/components/UserHeader.vue"; import UserHeader from "@/components/UserHeader.vue";
@@ -11,7 +11,6 @@ import OtaModal from "@/components/OtaModal.vue";
import { import {
checkUserBindAPI, checkUserBindAPI,
getAppConfig, getAppConfig,
getDeviceBatteryAPI,
getHardwareBoxTaskStatusAPI, getHardwareBoxTaskStatusAPI,
getHardwareBoxVersionAPI, getHardwareBoxVersionAPI,
getHomeData, getHomeData,
@@ -33,103 +32,19 @@ const {
clearDevice, clearDevice,
getLvlName, getLvlName,
getLvlNameByScore, getLvlNameByScore,
updateOnline,
updateDeviceBattery,
} = store; } = store;
const {user, device, online, deviceBattery, game} = storeToRefs(store); const {user, device, deviceStatus, online, deviceBattery, game} = storeToRefs(store);
const showModal = ref(false); const showModal = ref(false);
const showGuide = ref(false); const showGuide = ref(false);
const scoreRankList = ref([]); const scoreRankList = ref([]);
const HOME_DEVICE_STATUS_POLL_INTERVAL = 10000; const DEVICE_STATUS_STALE_TIME = 6000;
let isHomePageVisible = false;
let homeDeviceStatusTimer = null;
let isHomeDeviceStatusRequesting = false;
// 设备状态接口可能返回布尔值、数字或字符串,统一成 true / false / null。
// null 表示接口没有给出可判断的状态,调用方应保留已有状态。
const normalizeDeviceOnline = (value) => {
if (typeof value === "boolean") return value;
if (typeof value === "number") return value === 1;
const normalized = String(value ?? "").trim().toLowerCase();
if (["true", "1", "online", "connected"].includes(normalized)) return true;
if (["false", "0", "offline", "disconnected"].includes(normalized)) return false;
return null;
};
// 将设备状态接口响应统一同步到首页 Store,离线时清空无效电量。
const applyHomeDeviceStatus = (data) => {
const normalizedOnline = normalizeDeviceOnline(data?.online);
if (normalizedOnline !== null) {
updateOnline(normalizedOnline);
}
if (normalizedOnline === false) {
updateDeviceBattery(null);
return;
}
const battery = data?.battery ?? data?.power;
if (battery !== undefined && battery !== null) {
updateDeviceBattery(battery);
}
};
// 刷新首页设备在线状态和电量;上一轮未结束时跳过,避免请求堆积。
const refreshHomeDeviceStatus = async () => {
if (
!isHomePageVisible ||
!user.value?.id ||
!device.value?.deviceId ||
isHomeDeviceStatusRequesting
) {
return;
}
isHomeDeviceStatusRequesting = true;
try {
const data = await getDeviceBatteryAPI();
if (isHomePageVisible) {
applyHomeDeviceStatus(data);
}
} catch (error) {
// 请求失败时保留上一次有效状态,等待下一轮自动恢复。
console.log("刷新首页设备状态失败", error);
} finally {
isHomeDeviceStatusRequesting = false;
}
};
const stopHomeDeviceStatusPolling = () => {
clearInterval(homeDeviceStatusTimer);
homeDeviceStatusTimer = null;
};
// 首页可见且用户已绑定设备时,每 10 秒刷新一次设备状态。
const startHomeDeviceStatusPolling = () => {
stopHomeDeviceStatusPolling();
if (!isHomePageVisible || !user.value?.id || !device.value?.deviceId) return;
homeDeviceStatusTimer = setInterval(() => {
void refreshHomeDeviceStatus();
}, HOME_DEVICE_STATUS_POLL_INTERVAL);
};
// 首页停留期间登录或绑定状态变化时,及时启停设备状态轮询。
watch(
[() => user.value?.id, () => device.value?.deviceId],
() => {
if (isHomePageVisible) {
startHomeDeviceStatusPolling();
}
}
);
// 首页设备卡片按“未绑定 / 已绑定未连接 / 已绑定已连接”三态展示。 // 首页设备卡片按“未绑定 / 已绑定未连接 / 已绑定已连接”三态展示。
const deviceCardState = computed(() => { const deviceCardState = computed(() => {
// 未登录时始终展示绑定入口,避免本地残留设备状态误显示为已绑定。 // 未登录时始终展示绑定入口,避免本地残留设备状态误显示为已绑定。
if (!user.value?.id || !device.value?.deviceId) return "unbound"; if (!user.value?.id || !device.value?.deviceId) return "unbound";
return normalizeDeviceOnline(online.value) === true ? "online" : "offline"; return online.value === true ? "online" : "offline";
}); });
const deviceCardAssets = { const deviceCardAssets = {
@@ -230,13 +145,7 @@ const checkOtaUpdate = async () => {
isCheckingOta = true; isCheckingOta = true;
try { try {
let deviceStatus; if (online.value !== true || otaVisible.value) return;
try {
deviceStatus = await getDeviceBatteryAPI();
} catch (err) {
return;
}
if (normalizeDeviceOnline(deviceStatus?.online) !== true || otaVisible.value) return;
let versionInfo; let versionInfo;
try { try {
@@ -388,19 +297,9 @@ const startHomeOtaUpdate = async () => {
const handleOtaUpdate = async () => { const handleOtaUpdate = async () => {
if (isStartingOta.value) return; if (isStartingOta.value) return;
isStartingOta.value = true; isStartingOta.value = true;
let deviceStatus; const currentDeviceStatus = deviceStatus.value;
try {
deviceStatus = await getDeviceBatteryAPI();
} catch (err) {
isStartingOta.value = false;
uni.showToast({
title: "获取设备状态失败,请重试",
icon: "none",
});
return;
}
if (normalizeDeviceOnline(deviceStatus?.online) !== true) { if (currentDeviceStatus?.online !== true) {
isStartingOta.value = false; isStartingOta.value = false;
uni.showToast({ uni.showToast({
title: "请先开启智能弓", title: "请先开启智能弓",
@@ -409,7 +308,19 @@ const handleOtaUpdate = async () => {
return; return;
} }
if (String(deviceStatus?.netType || "").toLowerCase() === "wifi") { if (
Date.now() - Number(currentDeviceStatus?.receivedAt || 0) >
DEVICE_STATUS_STALE_TIME
) {
isStartingOta.value = false;
uni.showToast({
title: "设备状态同步中,请稍后重试",
icon: "none",
});
return;
}
if (String(currentDeviceStatus?.netType || "").toLowerCase() === "wifi") {
startHomeOtaUpdate(); startHomeOtaUpdate();
return; return;
} }
@@ -489,26 +400,15 @@ const syncHomeDevice = async () => {
return; return;
} }
const previousDeviceId = String(device.value?.deviceId || "");
const deviceId = String(currentDevice.deviceId || ""); const deviceId = String(currentDevice.deviceId || "");
updateDevice( updateDevice(
deviceId, deviceId,
currentDevice.deviceName || currentDevice.name || "" currentDevice.deviceName || currentDevice.name || ""
); );
// 切换到新设备时先以离线态初始化,避免沿用上一台设备的在线状态。
if (previousDeviceId !== deviceId) {
updateOnline(false);
updateDeviceBattery(null);
}
await refreshHomeDeviceStatus();
}; };
onShow(async (options) => { onShow(async (options) => {
isHomePageVisible = true;
startHomeDeviceStatusPolling();
const env = uni.getAccountInfoSync().miniProgram.envVersion; const env = uni.getAccountInfoSync().miniProgram.envVersion;
const token = uni.getStorageSync(`${env}_token`); const token = uni.getStorageSync(`${env}_token`);
@@ -538,8 +438,6 @@ onShow(async (options) => {
// devices.bindings[0].deviceId, // devices.bindings[0].deviceId,
// devices.bindings[0].deviceName // devices.bindings[0].deviceName
// ); // );
// const data = await getDeviceBatteryAPI();
// updateOnline(data.online);
// } // }
// } else { // } else {
// showModal.value = true; // showModal.value = true;
@@ -579,13 +477,6 @@ onShow(async (options) => {
} }
} }
// 登录态或绑定设备可能在本次 onShow 中发生变化,按最新状态重建轮询。
startHomeDeviceStatusPolling();
});
onHide(() => {
isHomePageVisible = false;
stopHomeDeviceStatusPolling();
}); });
onMounted(async () => { onMounted(async () => {
@@ -595,8 +486,6 @@ onMounted(async () => {
}); });
onUnmounted(() => { onUnmounted(() => {
isHomePageVisible = false;
stopHomeDeviceStatusPolling();
invalidateOtaUpdateRun(); invalidateOtaUpdateRun();
}); });
@@ -657,6 +546,7 @@ onShareTimeline(() => {
/> />
<image <image
class="device-visual-bow" class="device-visual-bow"
:class="{ 'device-visual-bow--floating': deviceCardState === 'online' }"
:src="deviceCardAsset.bow" :src="deviceCardAsset.bow"
mode="scaleToFill" mode="scaleToFill"
/> />
@@ -878,6 +768,20 @@ onShareTimeline(() => {
height: 388rpx; height: 388rpx;
} }
.device-visual-bow--floating {
animation: device-bow-float 3s ease-in-out infinite;
}
@keyframes device-bow-float {
0%,
100% {
transform: translateY(0) rotate(-0.5deg);
}
50% {
transform: translateY(-10rpx) rotate(0.5deg);
}
}
.device-status-badge, .device-status-badge,
.device-action-badge { .device-action-badge {
display: flex; display: flex;
+5 -34
View File
@@ -1,44 +1,15 @@
<script setup> <script setup>
import { ref, onMounted, onBeforeUnmount } from "vue"; import useStore from "@/store";
import { getDeviceBatteryAPI } from "@/apis"; import { storeToRefs } from "pinia";
const power = ref(0); const store = useStore();
const timer = ref(null); const { deviceBattery: power } = storeToRefs(store);
let disposed = false;
let requestInFlight = false;
const refreshPower = async () => {
if (disposed || requestInFlight) return;
requestInFlight = true;
try {
const data = await getDeviceBatteryAPI();
if (!disposed) power.value = data.battery;
} catch (_) {
// 电量轮询失败时等待下一轮,避免产生未处理的 Promise 拒绝。
} finally {
requestInFlight = false;
}
};
onMounted(async () => {
await refreshPower();
if (disposed) return;
timer.value = setInterval(() => {
void refreshPower();
}, 1000 * 10);
});
onBeforeUnmount(() => {
disposed = true;
clearInterval(timer.value);
timer.value = null;
});
</script> </script>
<template> <template>
<view class="container"> <view class="container">
<image src="../../../static/b-power.png" mode="widthFix" /> <image src="../../../static/b-power.png" mode="widthFix" />
<view>电量{{ power || 1 }}%</view> <view>{{ power === null ? "电量--" : `电量${power}%` }}</view>
</view> </view>
</template> </template>
@@ -89,7 +89,7 @@ const previewLines = computed(() => {
} }
.difficulty-preview__copy { .difficulty-preview__copy {
width: 80%; width: 84%;
margin: 0 auto; margin: 0 auto;
display: block; display: block;
color: #ffffff; color: #ffffff;
Binary file not shown.

Before

Width:  |  Height:  |  Size: 12 KiB

After

Width:  |  Height:  |  Size: 12 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 172 KiB

After

Width:  |  Height:  |  Size: 48 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 62 KiB

After

Width:  |  Height:  |  Size: 14 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 102 KiB

After

Width:  |  Height:  |  Size: 24 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 102 KiB

After

Width:  |  Height:  |  Size: 24 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 107 KiB

After

Width:  |  Height:  |  Size: 30 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 44 KiB

After

Width:  |  Height:  |  Size: 15 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 519 B

After

Width:  |  Height:  |  Size: 433 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 33 KiB

After

Width:  |  Height:  |  Size: 15 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 12 KiB

After

Width:  |  Height:  |  Size: 12 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 33 KiB

After

Width:  |  Height:  |  Size: 15 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 630 KiB

After

Width:  |  Height:  |  Size: 162 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 519 B

After

Width:  |  Height:  |  Size: 433 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 13 KiB

After

Width:  |  Height:  |  Size: 12 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 190 KiB

After

Width:  |  Height:  |  Size: 90 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 7.1 KiB

After

Width:  |  Height:  |  Size: 5.2 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 24 KiB

After

Width:  |  Height:  |  Size: 5.9 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.7 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.5 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.5 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 850 B

Binary file not shown.

After

Width:  |  Height:  |  Size: 479 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 46 KiB

After

Width:  |  Height:  |  Size: 11 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 178 KiB

After

Width:  |  Height:  |  Size: 41 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 40 KiB

After

Width:  |  Height:  |  Size: 9.9 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 19 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 202 KiB

After

Width:  |  Height:  |  Size: 32 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 202 KiB

After

Width:  |  Height:  |  Size: 32 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 371 B

Binary file not shown.

After

Width:  |  Height:  |  Size: 294 B

Binary file not shown.

After

Width:  |  Height:  |  Size: 687 B

Binary file not shown.

After

Width:  |  Height:  |  Size: 6.2 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 11 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 47 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 681 B

After

Width:  |  Height:  |  Size: 329 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 895 B

After

Width:  |  Height:  |  Size: 413 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 972 B

After

Width:  |  Height:  |  Size: 444 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 1.8 KiB

After

Width:  |  Height:  |  Size: 841 B

Binary file not shown.

After

Width:  |  Height:  |  Size: 587 B

+54 -3
View File
@@ -17,6 +17,15 @@ const getDefaultDevice = () => ({
deviceName: "", deviceName: "",
}); });
const getDefaultDeviceStatus = () => ({
battery: null,
version: "",
online: false,
netType: "",
onlineDuration: null,
receivedAt: 0,
});
const getDefaultGame = () => ({ const getDefaultGame = () => ({
roomID: "", roomID: "",
inBattle: false, inBattle: false,
@@ -102,6 +111,8 @@ export default defineStore("store", {
online: false, online: false,
// 设备电量属于运行时状态,null 表示当前没有有效数据。 // 设备电量属于运行时状态,null 表示当前没有有效数据。
deviceBattery: null, deviceBattery: null,
// WebSocket 实时推送的设备状态,不参与持久化。
deviceStatus: getDefaultDeviceStatus(),
game: { game: {
roomID: "", roomID: "",
inBattle: false, inBattle: false,
@@ -136,7 +147,7 @@ export default defineStore("store", {
this.rankData = { ...(data || {}) }; this.rankData = { ...(data || {}) };
}, },
updateOnline(online) { updateOnline(online) {
this.online = online; this.setDeviceOnline(online);
}, },
updateDeviceBattery(value) { updateDeviceBattery(value) {
if (value === null || value === undefined || value === "") { if (value === null || value === undefined || value === "") {
@@ -149,6 +160,43 @@ export default defineStore("store", {
? Math.min(100, Math.max(0, battery)) ? Math.min(100, Math.max(0, battery))
: null; : null;
}, },
updateDeviceStatus(status = {}) {
const battery = Number(status.battery ?? status.power);
const onlineDuration = Number(status.onlineDuration);
const online = status.online === true;
const nextStatus = {
battery: Number.isFinite(battery)
? Math.min(100, Math.max(0, battery))
: null,
version: String(status.version ?? "").trim(),
online,
netType: String(status.netType ?? "").trim().toLowerCase(),
onlineDuration:
Number.isFinite(onlineDuration) && onlineDuration >= 0
? onlineDuration
: null,
receivedAt: Date.now(),
};
this.deviceStatus = nextStatus;
this.online = online;
this.deviceBattery = online ? nextStatus.battery : null;
},
setDeviceOnline(online) {
const nextOnline = online === true;
this.online = nextOnline;
if (nextOnline) {
this.deviceStatus = { ...this.deviceStatus, online: true };
return;
}
this.deviceBattery = null;
this.deviceStatus = getDefaultDeviceStatus();
},
clearDeviceStatus() {
this.online = false;
this.deviceBattery = null;
this.deviceStatus = getDefaultDeviceStatus();
},
async updateUser(user = {}) { async updateUser(user = {}) {
this.user = { ...getDefaultUser(), ...user }; this.user = { ...getDefaultUser(), ...user };
this.user.lvlName = getLvlNameByScore(this.user.scores, this.config.randInfos) this.user.lvlName = getLvlNameByScore(this.user.scores, this.config.randInfos)
@@ -158,13 +206,15 @@ export default defineStore("store", {
); );
}, },
updateDevice(deviceId, deviceName) { updateDevice(deviceId, deviceName) {
if (String(this.device.deviceId || "") !== String(deviceId || "")) {
this.clearDeviceStatus();
}
this.device.deviceId = deviceId; this.device.deviceId = deviceId;
this.device.deviceName = deviceName; this.device.deviceName = deviceName;
}, },
clearDevice() { clearDevice() {
this.device = getDefaultDevice(); this.device = getDefaultDevice();
this.online = false; this.clearDeviceStatus();
this.deviceBattery = null;
}, },
async updateConfig(config) { async updateConfig(config) {
this.config = config; this.config = config;
@@ -214,6 +264,7 @@ export default defineStore("store", {
device: getDefaultDevice(), device: getDefaultDevice(),
online: false, online: false,
deviceBattery: null, deviceBattery: null,
deviceStatus: getDefaultDeviceStatus(),
game: getDefaultGame(), game: getDefaultGame(),
dailyCount: getDefaultDailyCount(), dailyCount: getDefaultDailyCount(),
deviceChargingDialogVisible: false, deviceChargingDialogVisible: false,
+1 -1
View File
File diff suppressed because one or more lines are too long
+2 -2
View File
@@ -7,7 +7,7 @@ const { Reader, Writer } = protobuf;
// 所以这里使用 minimal Reader/Writer 做静态字段解码和客户端消息编码。 // 所以这里使用 minimal Reader/Writer 做静态字段解码和客户端消息编码。
// <match-schema-generated> // <match-schema-generated>
// 此区块由 scripts/generate-match-schema.mjs 自动生成,请勿手动修改。 // 此区块由 scripts/generate-match-schema.mjs 自动生成,请勿手动修改。
// 来源:src/utils/match.min.jssha256: bece92f31bde3072 // 来源:src/utils/match.min.jssha256: ec0371baeba9a9bf
// 协议命名空间:rpc;消息数:12;字段数:163 // 协议命名空间:rpc;消息数:12;字段数:163
export const ServerMessageType = { export const ServerMessageType = {
@@ -188,7 +188,7 @@ const SCHEMAS = {
43: { name: "calories", kind: "double" }, 43: { name: "calories", kind: "double" },
44: { name: "score_slot", kind: "int32" }, 44: { name: "score_slot", kind: "int32" },
45: { name: "current_energy", kind: "int32" }, 45: { name: "current_energy", kind: "int32" },
46: { name: "energy_cost_per_sec", kind: "int32" }, 46: { name: "energy_cost_per_sec", kind: "float" },
47: { name: "energy_per_hit", kind: "int32" }, 47: { name: "energy_per_hit", kind: "int32" },
48: { name: "energy_req_percent", kind: "int32" }, 48: { name: "energy_req_percent", kind: "int32" },
49: { name: "delta_current_energy", kind: "int32" }, 49: { name: "delta_current_energy", kind: "int32" },
+23 -6
View File
@@ -77,17 +77,33 @@ function createWebSocket(token, onMessage) {
socketTask.onMessage((res) => { socketTask.onMessage((res) => {
if (socket !== socketTask) return; if (socket !== socketTask) return;
const { data, event } = JSON.parse(res.data); let response;
try {
response = JSON.parse(res.data);
} catch (err) {
console.error("WebSocket 消息解析失败", err);
return;
}
const { data, event, code, timestamp } = response || {};
if (event === "pong") return; if (event === "pong") return;
if (data.type) { if (event === "/addons/shoot/battery") {
if ((code == null || Number(code) === 0) && onMessage && data && typeof data === "object") {
onMessage({ event, data, code, timestamp });
}
return;
}
if (data?.type) {
if (ENABLE_REALTIME_MESSAGE_LOG) { if (ENABLE_REALTIME_MESSAGE_LOG) {
console.log("收到 WebSocket 消息", getMessageTypeName(data.type)); console.log("收到 WebSocket 消息", getMessageTypeName(data.type));
} }
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); const updates = Array.isArray(data?.updates) ? data.updates : [];
const msg = data.updates[0]; if (!updates.length) return;
if (onMessage) onMessage(updates);
const msg = updates[0];
if (msg) { if (msg) {
if (ENABLE_REALTIME_MESSAGE_LOG) { if (ENABLE_REALTIME_MESSAGE_LOG) {
console.log( console.log(
@@ -101,9 +117,9 @@ function createWebSocket(token, onMessage) {
} else if (msg.constructor === MESSAGETYPES.LvlUpdate) { } else if (msg.constructor === MESSAGETYPES.LvlUpdate) {
uni.setStorageSync("latestLvl", msg.lvl); uni.setStorageSync("latestLvl", msg.lvl);
} else if (msg.constructor === MESSAGETYPES.DeviceOnline) { } else if (msg.constructor === MESSAGETYPES.DeviceOnline) {
uni.$emit("update-online"); uni.$emit("update-online", true);
} else if (msg.constructor === MESSAGETYPES.DeviceOffline) { } else if (msg.constructor === MESSAGETYPES.DeviceOffline) {
uni.$emit("update-online"); uni.$emit("update-online", false);
} else if (msg.constructor === MESSAGETYPES.DeviceCharging) { } else if (msg.constructor === MESSAGETYPES.DeviceCharging) {
uni.$emit("device-charging"); uni.$emit("device-charging");
} }
@@ -121,6 +137,7 @@ function createWebSocket(token, onMessage) {
stopHeartbeat(); stopHeartbeat();
socket = null; socket = null;
isConnecting = false; isConnecting = false;
uni.$emit("shoot-socket-disconnected");
if (manualClose || kickedOut) return; if (manualClose || kickedOut) return;
await handleUnexpectedClose(onMessage); await handleUnexpectedClose(onMessage);