fix: 13项数据存储与排行榜修复

致命修复:
- leaderboard: 日榜日期比较改用 dateOnly() 替代严格全等
- plan: 计划天数计算日期比较改用 dateOnly()
- cloud: pullAll 添加 orderBy('updatedAt','desc') 确保取最新文档避免数据丢失

严重修复:
- cloud: 新增 cancelPendingPush() 防止清除数据后被延迟推送复活
- settings: _doClearData 补充 user_profile 清除, 先取消推送再清除
- app: 云端同步改为时间戳比对策略, 支持跨设备拉取
- app: _restoreFromCloud 增加空数据保护和 profile 恢复
- storage: 记录ID改用时间戳+自增计数器确保唯一性

中等修复:
- cloud: init/_fetchOpenid 日志升级, 新增 syncStatus getter
- leaderboard云函数: 添加90天活跃过滤减少全表扫描
- storage: validateStreak 增加lastDate无记录时的通用修复
- leaderboard页面: 云函数失败时Toast提示用户而非静默降级

轻微修复:
- timer: onUnload 添加 voice.destroy() 释放音频上下文
- records: onLongPressDelete 委托给 onDeleteRecord 消除重复代码

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
2026-06-24 12:22:54 +08:00
parent 6d1992869e
commit d817d5d012
10 changed files with 152 additions and 40 deletions
+43 -7
View File
@@ -39,15 +39,40 @@ App({
if (cloud.enabled) { if (cloud.enabled) {
try { try {
const cloudData = await cloud.pullAll() const cloudData = await cloud.pullAll()
if (!records || Object.keys(records).length === 0) { const hasLocal = records && Object.keys(records).length > 0
// Case 1: Fresh install (or user cleared local) — restore from cloud const hasCloud = cloudData && cloudData.records
&& Object.keys(cloudData.records).length > 0
&& Object.values(cloudData.records).some(arr => Array.isArray(arr) && arr.length > 0)
// Parse cloud updatedAt into a comparable timestamp
let cloudTs = 0
if (cloudData && cloudData.updatedAt) {
const d = cloudData.updatedAt instanceof Date
? cloudData.updatedAt
: new Date(cloudData.updatedAt)
cloudTs = d.getTime() || 0
}
const localSyncAt = wx.getStorageSync('_cloud_sync_at') || 0
if (!hasLocal && hasCloud) {
// Case 1: Fresh install on a new device — restore from cloud
this._restoreFromCloud(cloudData) this._restoreFromCloud(cloudData)
} else { wx.setStorageSync('_cloud_sync_at', cloudTs)
// Case 2: Has local data — push to cloud (local is authoritative) } else if (hasLocal && hasCloud) {
// pullAll already populated _openid / _docId, so pushAll will // Case 2: Both sides have data — compare timestamps
// update the existing doc instead of creating a duplicate. if (cloudTs > localSyncAt) {
// Cloud is newer (another device synced after our last push)
this._restoreFromCloud(cloudData)
wx.setStorageSync('_cloud_sync_at', cloudTs)
} else {
// Local is at least as current — push
cloud.pushAll()
}
} else if (hasLocal && !hasCloud) {
// Case 3: Only local data (first-ever sync) — push
cloud.pushAll() cloud.pushAll()
} }
// else: no data anywhere — nothing to sync
} catch (e) { } catch (e) {
console.error('Cloud sync on launch failed:', e) console.error('Cloud sync on launch failed:', e)
} }
@@ -58,7 +83,15 @@ App({
if (!cloudData) return if (!cloudData) return
try { try {
if (cloudData.records && Object.keys(cloudData.records).length > 0) { if (cloudData.records && Object.keys(cloudData.records).length > 0) {
wx.setStorageSync('training_records', cloudData.records) // Guard: only restore if at least one month has actual records.
// Pre-6d19928 duplicates could leave docs with month keys but
// empty arrays, which would wipe local data on restore.
const hasAny = Object.values(cloudData.records).some(
arr => Array.isArray(arr) && arr.length > 0
)
if (hasAny) {
wx.setStorageSync('training_records', cloudData.records)
}
} }
if (cloudData.settings) { if (cloudData.settings) {
wx.setStorageSync('user_settings', cloudData.settings) wx.setStorageSync('user_settings', cloudData.settings)
@@ -69,6 +102,9 @@ App({
if (cloudData.customPlans && typeof cloudData.customPlans === 'object') { if (cloudData.customPlans && typeof cloudData.customPlans === 'object') {
wx.setStorageSync('custom_plans', cloudData.customPlans) wx.setStorageSync('custom_plans', cloudData.customPlans)
} }
if (cloudData.profile && typeof cloudData.profile === 'object') {
wx.setStorageSync('user_profile', cloudData.profile)
}
if (cloudData.themeId) { if (cloudData.themeId) {
themeMod.setTheme(cloudData.themeId) themeMod.setTheme(cloudData.themeId)
} }
+12 -1
View File
@@ -61,8 +61,19 @@ exports.main = async (event) => {
const latestByOpenid = new Map() const latestByOpenid = new Map()
// Exclude accounts that haven't synced in 90+ days to bound the scan.
// Docs without an updatedAt field (pre-fix legacy) are included as well.
const ninetyDaysAgo = new Date(Date.now() - 90 * 24 * 60 * 60 * 1000)
while (true) { while (true) {
const res = await db.collection(COLLECTION).skip(skip).limit(PAGE_SIZE).get() const res = await db.collection(COLLECTION)
.where(_.or([
{ updatedAt: _.gte(ninetyDaysAgo) },
{ updatedAt: _.exists(false) }
]))
.skip(skip)
.limit(PAGE_SIZE)
.get()
if (!res.data || res.data.length === 0) break if (!res.data || res.data.length === 0) break
for (const doc of res.data) { for (const doc of res.data) {
+1 -1
View File
@@ -7,7 +7,7 @@ module.exports = {
version: 'v1.5', version: 'v1.5',
/** 最后更新日期,外显在设置页「关于」 */ /** 最后更新日期,外显在设置页「关于」 */
updatedAt: '2026-06-11', updatedAt: '2026-06-24',
/** 开发者名称 / 微信号,设置页点击可复制 */ /** 开发者名称 / 微信号,设置页点击可复制 */
developer: '刘承', developer: '刘承',
+6 -3
View File
@@ -64,8 +64,11 @@ Page({
}).then(res => { }).then(res => {
this._applyResult(res.result || {}) this._applyResult(res.result || {})
if (cb) cb() if (cb) cb()
}).catch(() => { }).catch((err) => {
// Cloud function not deployed — fall back to local data // Cloud function not deployed or network error — fall back to
// local data but let the user know the leaderboard is degraded.
console.warn('[leaderboard] cloud function failed, using local fallback:', err)
wx.showToast({ title: '云端榜单暂不可用', icon: 'none', duration: 2000 })
this._applyLocal() this._applyLocal()
if (cb) cb() if (cb) cb()
}) })
@@ -102,7 +105,7 @@ Page({
let duration = 0 let duration = 0
let sessions = 0 let sessions = 0
allRecords.forEach(r => { allRecords.forEach(r => {
if (period === 'day' && r.date === today) { duration += r.duration; sessions++ } if (period === 'day' && util.dateOnly(r.date) === util.dateOnly(today)) { duration += r.duration; sessions++ }
if (period === 'month' && r.date.startsWith(thisMonth)) { duration += r.duration; sessions++ } if (period === 'month' && r.date.startsWith(thisMonth)) { duration += r.duration; sessions++ }
if (period === 'year' && r.date.startsWith(thisYear)) { duration += r.duration; sessions++ } if (period === 'year' && r.date.startsWith(thisYear)) { duration += r.duration; sessions++ }
}) })
+1 -16
View File
@@ -126,22 +126,7 @@ Page({
}, },
onLongPressDelete(e) { onLongPressDelete(e) {
const id = e.currentTarget.dataset.id this.onDeleteRecord(e)
if (!id && id !== 0) {
wx.showToast({ title: '记录数据异常', icon: 'none', duration: 1200 })
return
}
wx.showModal({
title: '删除记录',
content: '确定要删除这条训练记录吗?',
success: (res) => {
if (res.confirm) {
storage.deleteRecord(id)
this.refresh()
wx.showToast({ title: '已删除', icon: 'none', duration: 1200 })
}
}
})
}, },
onDeleteRecord(e) { onDeleteRecord(e) {
+19 -2
View File
@@ -202,12 +202,25 @@ Page({
}, },
async _doClearData() { async _doClearData() {
// 1. Cancel any pending push BEFORE clearing, to prevent the
// scheduled _doPush from reading the freshly-reset defaults
// and recreating the cloud doc via add().
cloud.cancelPendingPush()
// 2. Clear all local keys (including user_profile which was
// previously missed)
wx.removeStorageSync('training_records') wx.removeStorageSync('training_records')
wx.removeStorageSync('current_streak') wx.removeStorageSync('current_streak')
wx.removeStorageSync('user_settings') wx.removeStorageSync('user_settings')
wx.removeStorageSync('app_theme') wx.removeStorageSync('app_theme')
wx.removeStorageSync('custom_plans') wx.removeStorageSync('custom_plans')
wx.removeStorageSync('user_profile')
// 3. Clear cloud doc (awaited — order matters: clear cloud
// after cancelling push, before resetting defaults)
try { await cloud.clearAll() } catch (e) {} try { await cloud.clearAll() } catch (e) {}
// 4. Reinstate default settings and streak
wx.setStorageSync('user_settings', { wx.setStorageSync('user_settings', {
planId: 'beginner', planId: 'beginner',
voiceGuide: true, voiceGuide: true,
@@ -215,15 +228,19 @@ Page({
planStartDate: storage.getToday() planStartDate: storage.getToday()
}) })
wx.setStorageSync('current_streak', { count: 0, lastDate: '' }) wx.setStorageSync('current_streak', { count: 0, lastDate: '' })
// 5. Reset theme and UI (include nickName/avatarUrl to clear
// profile state now that user_profile is gone)
themeMod.setTheme('orange') themeMod.setTheme('orange')
this.setData({ this.setData({
currentPlanId: 'beginner', currentPlanId: 'beginner',
voiceGuide: true, voiceGuide: true,
vibrate: true, vibrate: true,
currentThemeId: 'orange' currentThemeId: 'orange',
nickName: '',
avatarUrl: ''
}) })
themeMod.applyThemeToPage(this) themeMod.applyThemeToPage(this)
// Reset plans list — custom_plans are gone
this.setData({ plans: buildPlansList(storage.getCustomPlans()) }) this.setData({ plans: buildPlansList(storage.getCustomPlans()) })
wx.showToast({ title: '已清除', icon: 'success', duration: 1500 }) wx.showToast({ title: '已清除', icon: 'success', duration: 1500 })
}, },
+1
View File
@@ -150,6 +150,7 @@ Page({
onUnload() { onUnload() {
voice.stop() voice.stop()
voice.destroy()
if (this._timer) { if (this._timer) {
this._timer.stop() this._timer.stop()
this._timer = null this._timer = null
+34 -4
View File
@@ -24,8 +24,10 @@ const init = () => {
try { try {
wx.cloud.init({ env: ENV_ID, traceUser: true }) wx.cloud.init({ env: ENV_ID, traceUser: true })
_enabled = true _enabled = true
console.log('[cloud] init ok, env:', ENV_ID)
} catch (e) { } catch (e) {
_enabled = false _enabled = false
console.warn('[cloud] init failed — cloud sync disabled:', e.message || e)
} }
} }
@@ -40,10 +42,13 @@ const pullAll = async () => {
} }
if (!_openid) return null // cloud function call failed; bail if (!_openid) return null // cloud function call failed; bail
// Locate our doc by _openid, not by limit(1) which can pick someone // Locate our doc by _openid, ordered by updatedAt descending so
// else's doc when the custom rule is in effect. // we always get the MOST RECENT doc. Without orderBy, limit(1)
// returns the OLDEST doc (_id ascending), which causes data loss
// when duplicate docs exist from the old cold-start-add() bug.
const mine = await db.collection(DB_COLLECTION) const mine = await db.collection(DB_COLLECTION)
.where({ _openid: _openid }) .where({ _openid: _openid })
.orderBy('updatedAt', 'desc')
.limit(1) .limit(1)
.get() .get()
if (mine && mine.data && mine.data.length > 0) { if (mine && mine.data && mine.data.length > 0) {
@@ -67,7 +72,10 @@ const _fetchOpenid = async () => {
try { try {
const res = await wx.cloud.callFunction({ name: 'getOpenid' }) const res = await wx.cloud.callFunction({ name: 'getOpenid' })
if (res && res.result && res.result.openid) return res.result.openid if (res && res.result && res.result.openid) return res.result.openid
} catch (e) { /* function not deployed, etc. */ } console.warn('[cloud] getOpenid returned no openid:', JSON.stringify(res))
} catch (e) {
console.warn('[cloud] getOpenid call failed — cloud functions may not be deployed:', e.message || e)
}
return null return null
} }
@@ -111,6 +119,17 @@ const pushAll = () => {
}) })
} }
const cancelPendingPush = () => {
if (_pushTimer) {
clearTimeout(_pushTimer)
_pushTimer = null
}
}
const _markSynced = () => {
try { wx.setStorageSync('_cloud_sync_at', Date.now()) } catch (e) {}
}
const _doPush = async () => { const _doPush = async () => {
console.log('[cloud] _doPush starting...') console.log('[cloud] _doPush starting...')
const db = getDb() const db = getDb()
@@ -135,6 +154,7 @@ const _doPush = async () => {
try { try {
await db.collection(DB_COLLECTION).doc(_docId).update({ data }) await db.collection(DB_COLLECTION).doc(_docId).update({ data })
console.log('[cloud] _doPush update ok') console.log('[cloud] _doPush update ok')
_markSynced()
return return
} catch (e) { } catch (e) {
// Most commonly: doc was deleted out from under us (user cleared // Most commonly: doc was deleted out from under us (user cleared
@@ -163,6 +183,7 @@ const _doPush = async () => {
try { try {
await db.collection(DB_COLLECTION).doc(_docId).update({ data }) await db.collection(DB_COLLECTION).doc(_docId).update({ data })
console.log('[cloud] _doPush update ok (re-located by _openid)') console.log('[cloud] _doPush update ok (re-located by _openid)')
_markSynced()
return return
} catch (e) { } catch (e) {
// If even the freshly-located doc rejects our update (custom // If even the freshly-located doc rejects our update (custom
@@ -185,6 +206,7 @@ const _doPush = async () => {
if (res && res._id) _docId = res._id if (res && res._id) _docId = res._id
if (res && res._openid) _openid = res._openid if (res && res._openid) _openid = res._openid
console.log('[cloud] _doPush add ok, docId=', _docId) console.log('[cloud] _doPush add ok, docId=', _docId)
_markSynced()
} catch (e) { } catch (e) {
console.log('[cloud] _doPush error:', e.message || e) console.log('[cloud] _doPush error:', e.message || e)
} }
@@ -227,4 +249,12 @@ const clearAll = async () => {
_docId = null _docId = null
} }
module.exports = { init, pullAll, pushAll, clearAll, get enabled() { return _enabled } } module.exports = {
init, pullAll, pushAll, clearAll, cancelPendingPush,
get enabled() { return _enabled },
get syncStatus() {
if (!_enabled) return 'disabled'
if (!_openid) return 'unauthenticated'
return 'ok'
}
}
+2 -2
View File
@@ -1,4 +1,4 @@
const { formatDate } = require('./util') const { formatDate, dateOnly } = require('./util')
/** /**
* Build the per-day target array for a plan from its formula fields. * Build the per-day target array for a plan from its formula fields.
@@ -90,7 +90,7 @@ const getPlanDay = (planId, records, planStartDate) => {
// Filter records: same plan, after plan start date, and not today // Filter records: same plan, after plan start date, and not today
const eligibleRecords = records.filter(r => { const eligibleRecords = records.filter(r => {
if (r.planId !== planId) return false if (r.planId !== planId) return false
if (r.date === today) return false if (dateOnly(r.date) === dateOnly(today)) return false
if (planStartDate && r.date < planStartDate) return false if (planStartDate && r.date < planStartDate) return false
return true return true
}) })
+33 -4
View File
@@ -7,6 +7,8 @@ const STREAK_KEY = 'current_streak'
const CUSTOM_PLANS_KEY = 'custom_plans' const CUSTOM_PLANS_KEY = 'custom_plans'
const PROFILE_KEY = 'user_profile' const PROFILE_KEY = 'user_profile'
let _idSeq = 0
/** /**
* Backfill an `id` for any record that doesn't have one. * Backfill an `id` for any record that doesn't have one.
* Older records (e.g. data restored from cloud or migrated from a build * Older records (e.g. data restored from cloud or migrated from a build
@@ -46,7 +48,7 @@ const getRecords = () => {
} }
const saveRecord = (record) => { const saveRecord = (record) => {
record.id = String(Date.now()) record.id = String(Date.now()) + '_' + (++_idSeq)
const records = getRecords() const records = getRecords()
const month = record.date.substring(0, 7) const month = record.date.substring(0, 7)
if (!records[month]) records[month] = [] if (!records[month]) records[month] = []
@@ -190,8 +192,10 @@ const validateStreak = () => {
monthRecs.forEach(r => allDates.add(dateOnly(r.date))) monthRecs.forEach(r => allDates.add(dateOnly(r.date)))
}) })
const lastOnly = dateOnly(streak.lastDate)
// If lastDate is today, check today still has records // If lastDate is today, check today still has records
if (dateOnly(streak.lastDate) === todayOnly) { if (lastOnly === todayOnly) {
if (!allDates.has(todayOnly)) { if (!allDates.has(todayOnly)) {
// Today's records were deleted // Today's records were deleted
if (allDates.has(yesterdayOnly)) { if (allDates.has(yesterdayOnly)) {
@@ -206,8 +210,33 @@ const validateStreak = () => {
return streak return streak
} }
// If lastDate is not today and not yesterday, streak is already broken // If lastDate points to a date that no longer has ANY records,
// (updateStreak handles reset on next training), no action needed here // recompute the streak from actual recorded dates.
if (!allDates.has(lastOnly)) {
const sorted = Array.from(allDates).sort().reverse()
if (sorted.length === 0) {
streak.count = 0
streak.lastDate = ''
} else {
let count = 1
let prev = sorted[0]
for (let i = 1; i < sorted.length; i++) {
const prevDate = new Date(prev.replace(/-/g, '/'))
const curDate = new Date(sorted[i].replace(/-/g, '/'))
const diff = Math.round((prevDate - curDate) / (1000 * 60 * 60 * 24))
if (diff === 1) {
count++
prev = sorted[i]
} else {
break
}
}
streak.count = count
streak.lastDate = sorted[0]
}
wx.setStorageSync(STREAK_KEY, streak)
}
return streak return streak
} }