wx_pbzc/app.js

const themeMod = require('./utils/theme')
const cloud = require('./utils/cloud')
const storage = require('./utils/storage')
const darkMod = require('./utils/darkMode')
const voice = require('./utils/voice')
const config = require('./config')

const refreshOpenThemeViews = () => {
  const pages = getCurrentPages()
  pages.forEach(p => {
    if (p && typeof p.applyThemeToPage === 'function') {
      p.applyThemeToPage()
    } else if (p && p.route) {
      try { themeMod.applyThemeToPage(p) } catch (e) {}
    }
    try {
      const tb = p && p.getTabBar && p.getTabBar()
      if (tb && typeof tb.updateTheme === 'function') tb.updateTheme()
    } catch (e) {}
  })
}

App({
  async onLaunch() {
    // 尽早设导航栏色 + 窗口背景:原生导航栏在 JS 执行前用 app.json 写死的
    // 橙色,这里在 onLaunch 第一时间切到用户主题色,缩小冷启动跳变窗口。
    themeMod.applyChrome()

    // Init dark mode listener (refreshes all open pages when system theme changes)
    darkMod.watchDarkMode((isDark) => {
      refreshOpenThemeViews()
    })

    // Init cloud storage (no-op if not configured)
    cloud.init()

    // P1 排行榜预热:App 启动即后台触发一次榜单请求,提前填充云函数实例/快照,
    // 用户点进排行榜时已是热路径,首开等待从 2-3s 降到近乎无感。
    // fire-and-forget,不 await,不阻塞启动链路;失败静默忽略。
    if (cloud.enabled) {
      wx.cloud.callFunction({
        name: 'leaderboard',
        data: { period: 'day', maxRank: config.leaderboardMaxRank }
      }).catch(() => {})
    }

    const settings = wx.getStorageSync('user_settings')
    if (!settings) {
      wx.setStorageSync('user_settings', {
        planId: 'beginner',
        voiceGuide: true,
        vibrate: true,
        planStartDate: storage.getToday()
      })
    } else if (!settings.planStartDate) {
      // Migrate: add planStartDate for existing users
      settings.planStartDate = storage.getToday()
      wx.setStorageSync('user_settings', settings)
    }

    // 预载语音到本地缓存:app 启动即后台下载,训练时即时播放(语音引导开启时)
    const _vs = wx.getStorageSync('user_settings') || {}
    if (_vs.voiceGuide !== false) voice.preload()

    const streak = wx.getStorageSync('current_streak')
    if (!streak) {
      wx.setStorageSync('current_streak', { count: 0, lastDate: '' })
    }

    this.globalData.theme = themeMod.getCurrentTheme()

    // Sync with cloud: always locate our doc first (pullAll caches
    // _openid / _docId), then either restore or push. The previous flow
    // only pulled when local was empty, so on a cold start with non-empty
    // local it pushed without locating — and because the module-level
    // _openid / _docId caches had been reset, pushAll fell through to
    // add() and created a duplicate cloud doc every cold start. The
    // leaderboard then summed duration across N docs for the same user.
    const records = wx.getStorageSync('training_records')
    if (cloud.enabled) {
      try {
        const cloudData = await cloud.pullAll()
        const hasLocal = records && Object.keys(records).length > 0
        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, cloudTs)
          wx.setStorageSync('_cloud_sync_at', cloudTs)
        } else if (hasLocal && hasCloud) {
          // Case 2: Both sides have data — compare timestamps
          if (cloudTs > localSyncAt) {
            // Cloud is newer (another device synced after our last push).
            // Merge cloud into local, then push the merged result back so
            // both sides converge (records union + local's unsynced edits).
            this._restoreFromCloud(cloudData, cloudTs)
            wx.setStorageSync('_cloud_sync_at', cloudTs)
            cloud.pushAll()
          } 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()
        }
        // else: no data anywhere — nothing to sync
      } catch (e) {
      }
    }
  },

  _restoreFromCloud(cloudData, cloudTs) {
    if (!cloudData) return
    try {
      // Records: MERGE instead of overwrite. A training saved during the
      // async pullAll (or edits from another device) would otherwise be
      // wiped by the cloud's older snapshot.
      if (cloudData.records) {
        const merged = storage.mergeRecords(cloudData.records)
        const hasAny = Object.values(merged).some(
          arr => Array.isArray(arr) && arr.length > 0
        )
        if (hasAny) {
          wx.setStorageSync('training_records', merged)
        }
      }

      // Single-value fields: only adopt the cloud version if the local
      // side hasn't changed since the cloud snapshot. Otherwise we'd
      // clobber unsynced local edits (e.g. a setting flipped mid-sync).
      const localChangedAt = wx.getStorageSync('_local_changed_at') || 0
      const keepLocal = cloudTs > 0 && localChangedAt > cloudTs
      if (keepLocal) {
      } else {
        if (cloudData.settings) {
          wx.setStorageSync('user_settings', cloudData.settings)
        }
        if (cloudData.customPlans && typeof cloudData.customPlans === 'object') {
          wx.setStorageSync('custom_plans', cloudData.customPlans)
        }
        if (cloudData.profile && typeof cloudData.profile === 'object') {
          wx.setStorageSync('user_profile', cloudData.profile)
        }
        if (cloudData.themeId) {
          themeMod.setTheme(cloudData.themeId)
          // Cloud restore is asynchronous: pages may have already rendered
          // with their initial orange data. Reapply immediately so they don't
          // wait for a later tab switch to reflect the restored theme.
          refreshOpenThemeViews()
        }
      }

      // Streak: never trust the cloud value - recompute from the merged
      // records so it reflects actual history on this device.
      storage.recomputeStreak()
    } catch (e) {
    }
  },

  globalData: {
    planId: 'beginner',
    theme: null
  }
})