数据自愈迁移 + 后端同步幂等，版本号 v2.1.7 → v2.1.8

后端（server/src/index.js）——两处同步幂等： 1. deleteAnniversary 删除不存在的记录时返回 success:true。原先返回 false，被前端 sync.js:34 当作失败重新入队，那条删除会永远留在 pending_sync_queue 里每次启动重试且永远清不掉。 2. updateAnniversary / updatePerson 在记录不存在时退化为插入（upsert）。同一类问题：本地才是主真相源，若某条记录当初的 add 没同步成功，之后所有 update 都会失败并无限重试。前端 —— 新增 utils/migrate.js，在 app.js onLaunch 执行： 3. 补齐老数据缺失的农历字段。早期 lunar_birthday 类型只记公历日期，没有 lunarMonth/lunarDay，这类记录会被安全降级成按公历算——不崩，但每年日期是错的。用它存的公历日期反算回农历补齐。 4. 为孤儿纪念日重建人员。部分纪念日的 personId 指向已不存在的人（历史上删人没级联干净），首页按 persons 遍历所以隐形，日历页按 anniversaries 遍历会显示成「未知」。用记录自带的 personName 重建，并沿用原 personId，纪念日无需改动。迁移放在客户端而非后端跑 SQL：本地 wx.Storage 是主真相源，改服务端会被客户端同步覆盖。每次启动都跑而非记版本号：函数是纯检测式的，无坏数据时零写入零请求，还能顺带覆盖「从云端拉回坏数据」的情况。顺便把原本是死代码的 initData() 替换掉。 ⚠️ 本次后端有改动，需要重新部署；部署顺序应为先后端、后小程序。 Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
2026-08-15 15:55:44 +08:00
parent 1943fd5c1a
commit e9c7330f31
6 changed files with 1726 additions and 18 deletions
@@ -0,0 +1,106 @@
+# CLAUDE.md
+
+This file provides guidance to Claude Code (claude.ai/code) when working with code in this repository.
+
+## 项目简介
+
+微信小程序「生日提醒」+ 自建 Node.js 后端。小程序管理人员和纪念日，后端负责 openid 换取、数据云端备份、定时推送订阅消息。
+
+## 常用命令
+
+```bash
+# 后端本地开发（进 server 目录）
+cd server
+npm install
+npm run dev          # node --watch 热重载，监听 3000
+
+# 后端生产启动
+npm start
+
+# Docker 部署
+docker compose up -d --build
+
+# 手动触发一次提醒任务（调试用）
+curl -X POST http://localhost:3000/api/reminder/run
+```
+
+小程序侧无构建命令，用**微信开发者工具**直接打开项目根目录。
+
+## 架构总览
+
+### 两个独立部分
+
+| 部分 | 路径 | 说明 |
+|------|------|------|
+| 微信小程序 | `pages/` `utils/` `app.js` | 原生微信小程序，无框架 |
+| 自建后端 | `server/` | Express + better-sqlite3，Node ≥18 |
+
+> `cloudfunctions/` 目录是早期云开发遗留，已被 `server/` 取代，**不再使用**。
+
+### 小程序数据流
+
+```
+本地 wx.Storage（主存储）
+     ↕ 写时 fire-and-forget
+自建后端 SQLite（云端备份）
+```
+
+- **本地是主真相源**：所有读写先操作 wx.Storage 内存缓存（`utils/storage.js`），再异步同步后端。
+- **失败入队**：`utils/sync.js` 维护 `pending_sync_queue`，同步失败的操作下次启动时 `flush()`。
+- **新设备恢复**：`app.js` 启动时，若本地为空则调用 `storage.pullFromCloudIfEmpty()` 从后端拉取全量数据。
+
+### 后端 API 协议
+
+所有接口用统一的 `action` 字段区分操作，openid 通过 `x-openid` 请求头传递：
+
+```
+POST /api/login          # wx.login code → openid
+POST /api/person         # action: add / update / delete / sync / get
+POST /api/anniversary    # action: add / update / delete / sync / get
+POST /api/reminder/run   # 手动触发定时任务
+```
+
+前端 URL 自动选择：开发者工具 → `http://localhost:3000`；体验版/正式版 → `https://wxserver.ymxixi.space`（见 `utils/api.js:resolveBaseUrl`）。
+
+### 后端主要模块
+
+| 文件 | 职责 |
+|------|------|
+| `server/src/index.js` | Express 路由 + 所有 CRUD 函数 |
+| `server/src/db.js` | better-sqlite3 初始化、建表、旧库 ALTER 迁移 |
+| `server/src/reminder.js` | cron 定时任务，扫描 `remindEnabled=1` 的纪念日并发微信订阅消息 |
+| `server/src/wx.js` | 微信接口封装（code2session、sendSubscribeMessage） |
+| `server/src/lunar.js` | 农历转公历，与前端 `utils/lunar.js` 算法一致 |
+
+### 农历处理
+
+`utils/lunar.js`（小程序）和 `server/src/lunar.js`（后端）是同一套寿星万年历算法，覆盖 1900–2100 年。纪念日记录同时存储公历字段（`solarMonth/solarDay`）和农历字段（`lunarMonth/lunarDay/isLeapMonth`），`isLunar` 标志决定展示和计算逻辑用哪套。
+
+### 纪念日数据结构关键字段
+
+```js
+{
+  id, personId, personName,
+  type,           // 'birthday' | 'wedding' | 'engagement' | 'other'
+  customTypeName, // type='other' 时的自定义名称
+  isLunar,        // true = 农历生日
+  solarMonth, solarDay,           // 公历月日（必填，农历纪念日也存转换后的公历供排序）
+  lunarMonth, lunarDay, isLeapMonth, // 农历字段（isLunar=true 时有效）
+  importance,     // 'high' | 'medium' | 'low'
+  remindEnabled, remindDays
+}
+```
+
+`lunar_birthday` 是老数据兼容类型，与 `birthday` 等效，由 `isLunar` 决定是否农历，常量和后端均有兼容映射。
+
+## 后端环境变量
+
+参考 `server/.env.example`，关键变量：
+
+```
+WX_APPID          # 微信小程序 AppID
+WX_APPSECRET      # 微信小程序 AppSecret
+WX_TEMPLATE_ID    # 订阅消息模板 ID
+REMINDER_CRON     # 默认 "0 9 * * *"（每天9点，Asia/Shanghai）
+DB_PATH           # SQLite 路径，Docker 中挂载到 ./data/birthday.db
+```
@@ -1,25 +1,15 @@
 const api = require('./utils/api')
 const storage = require('./utils/storage')
 const sync = require('./utils/sync')
+const migrate = require('./utils/migrate')

 App({
  onLaunch() {
-    const logs = wx.getStorageSync('logs') || []
-    logs.unshift(Date.now())
-    wx.setStorageSync('logs', logs)
-
-    this.initData()
+    // 先修一遍本地数据，再走网络流程
+    migrate.run()
    this.getUserOpenId()
  },

-  initData() {
-    const persons = wx.getStorageSync('persons') || []
-    const anniversaries = wx.getStorageSync('anniversaries') || []
-    if (persons.length === 0 && anniversaries.length === 0) {
-      console.log('初始化数据结构')
-    }
-  },
-
  // 获取 openid：调自建后端 /api/login
  async getUserOpenId() {
    let openid = wx.getStorageSync('openid')
@@ -38,7 +28,11 @@ App({

    // 拿到 openid 后，本地无数据时从云端拉一次（新设备/重装恢复场景）
    const pulled = await storage.pullFromCloudIfEmpty()
-    if (pulled) console.log('已从云端恢复数据')
+    if (pulled) {
+      console.log('已从云端恢复数据')
+      // 云端可能存着老版本写上去的坏数据，拉回来后再修一遍（run 是幂等的）
+      migrate.run()
+    }

    // flush 之前同步失败的待重试队列
    sync.flush()
@@ -19,7 +19,7 @@ Page({
    personsCount: 0,
    anniversariesCount: 0,
    lastBackupText: '从未备份',
-    version: 'v2.1.7'
+    version: 'v2.1.8'
  },

  onLoad() {
@@ -117,9 +117,13 @@ function addAnniversary(openid, anniv) {
  return { success: true, id }
 }

+// 记录不存在时退化为插入（upsert）。
+// Why：本地 wx.Storage 才是主真相源，云端只是备份。若某条记录当初的 add 没同步成功，
+//      之后所有 update 都会失败，并卡在前端 pending_sync_queue 里每次启动无限重试。
+//      与 deleteAnniversary 的幂等处理是同一类问题。
 function updateAnniversary(openid, anniv) {
  const existing = db.prepare('SELECT * FROM anniversaries WHERE id = ? AND openid = ?').get(anniv.id, openid)
-  if (!existing) return { success: false, error: '纪念日不存在' }
+  if (!existing) return addAnniversary(openid, anniv)

  const merged = {
    ...existing,
@@ -136,9 +140,12 @@ function updateAnniversary(openid, anniv) {
  return { success: true }
 }

+// 删除是幂等的：记录本来就不存在时也算成功。
+// Why：前端 sync.js 把 success:false 当作失败重新入队，若这里对「已不存在」返回 false，
+//      那条删除操作会永远留在 pending_sync_queue 里，每次启动重试且永远清不掉。
 function deleteAnniversary(openid, id) {
  const info = db.prepare('DELETE FROM anniversaries WHERE id = ? AND openid = ?').run(id, openid)
-  return { success: info.changes > 0 }
+  return { success: true, deleted: info.changes }
 }

 function syncAnniversaries(openid, list) {
@@ -180,9 +187,10 @@ function addPerson(openid, person) {
  return { success: true, id: row.id }
 }

+// 同 updateAnniversary：记录不存在时退化为插入，避免同步队列里的 update 永远重试
 function updatePerson(openid, person) {
  const existing = db.prepare('SELECT * FROM persons WHERE id = ? AND openid = ?').get(person.id, openid)
-  if (!existing) return { success: false, error: '人员不存在' }
+  if (!existing) return addPerson(openid, person)
  const merged = { ...existing, ...person, openid, updateTime: Date.now() }
  const sets = PERSON_FIELDS.filter(f => f !== 'id' && f !== 'openid' && f !== 'createTime')
    .map(f => `${f} = @${f}`).join(', ')
@@ -0,0 +1,125 @@
+/**
+ * 数据自愈迁移
+ *
+ * Why 放在客户端而不是后端跑一次 SQL：
+ *   本项目「本地 wx.Storage 是主真相源，云端只是备份」。在服务端改数据，客户端下次同步
+ *   又会把本地的坏数据推上去覆盖掉。只有在每台设备上修，才能真正修干净。
+ *
+ * Why 每次启动都跑而不是用版本号只跑一次：
+ *   本函数是纯检测式的——没有坏数据时不写库、不发请求、零副作用，成本只是遍历一遍数组
+ *   （量级是个位数到几十条）。每次都跑还能顺带覆盖「从云端拉回来的坏数据」这种情况，
+ *   比记版本号更稳。
+ */
+
+const storage = require('./storage')
+const sync = require('./sync')
+const lunar = require('./lunar')
+
+const REBUILT_PERSON_REMARK = '自动恢复的联系人'
+const FALLBACK_PERSON_NAME = '未命名'
+
+/**
+ * 迁移一：补齐老数据缺失的农历字段
+ *
+ * 背景：早期版本有独立的 lunar_birthday 类型，只记公历日期，没有 lunarMonth/lunarDay。
+ * 后来改成用 isLunar 标志决定农历与否，这批老数据就变成了「声称是农历、却没有农历字段」。
+ * 这种记录会被日期计算安全降级成按公历算——不会崩，但每年的日期是错的。
+ * 用它存着的公历日期反算回农历，即可补齐。
+ *
+ * @returns {Array} 被修复的纪念日（已带上新字段）
+ */
+function _patchMissingLunarFields(anniversaries) {
+  const patched = []
+  const next = anniversaries.map(a => {
+    if (!a.isLunar) return a
+    if (a.lunarMonth && a.lunarDay) return a
+    // 没有公历基准就无从反算，保持原样（不制造假数据）
+    if (!a.solarYear || !a.solarMonth || !a.solarDay) return a
+
+    const ld = lunar.solarToLunar(new Date(a.solarYear, a.solarMonth - 1, a.solarDay))
+    const fixed = {
+      ...a,
+      lunarYear: ld.year,
+      lunarMonth: ld.month,
+      lunarDay: ld.day,
+      isLeapMonth: ld.isLeap,
+      updateTime: Date.now()
+    }
+    patched.push(fixed)
+    return fixed
+  })
+  return { next, patched }
+}
+
+/**
+ * 迁移二：为孤儿纪念日重建人员
+ *
+ * 背景：有些纪念日的 personId 指向已不存在的人员（历史上删人没级联干净）。
+ * 首页按 persons 遍历，所以这些记录是隐形的；日历页按 anniversaries 遍历，会显示成「未知」。
+ *
+ * 做法：用纪念日自带的 personName 重建人员，并且**沿用原来的 personId**，
+ * 这样纪念日记录一个字段都不用改，风险最小。
+ *
+ * @returns {Array} 新建出来的人员
+ */
+function _rebuildMissingPersons(persons, anniversaries) {
+  const known = new Set(persons.map(p => p.id))
+  const missing = new Map() // personId -> name
+
+  for (const a of anniversaries) {
+    if (!a.personId || known.has(a.personId)) continue
+    const name = (a.personName || '').trim()
+    const recorded = missing.get(a.personId)
+    // 同一个失踪 personId 可能对应多条纪念日，优先采用非空的姓名
+    if (!recorded || (recorded === FALLBACK_PERSON_NAME && name)) {
+      missing.set(a.personId, name || FALLBACK_PERSON_NAME)
+    }
+  }
+
+  if (missing.size === 0) return []
+
+  const now = Date.now()
+  return Array.from(missing.entries()).map(([id, name]) => ({
+    id,
+    name,
+    nickname: '',
+    avatar: '',
+    remark: REBUILT_PERSON_REMARK,
+    createTime: now,
+    updateTime: now
+  }))
+}
+
+/**
+ * 执行迁移。幂等，可重复调用。
+ * 任何异常都吞掉，绝不能因为迁移失败导致小程序起不来。
+ * @returns {{ lunarPatched: Number, personsRebuilt: Number }|null}
+ */
+function run() {
+  try {
+    const anniversaries = storage.getAnniversaries()
+    const { next, patched } = _patchMissingLunarFields(anniversaries)
+    if (patched.length > 0) {
+      storage.saveAnniversaries(next)
+      // 逐条推送更新；失败会自动入队，下次启动 flush
+      patched.forEach(a => sync.syncOrEnqueue({ kind: 'anniversary', action: 'update', data: a }))
+    }
+
+    const persons = storage.getPersons()
+    const rebuilt = _rebuildMissingPersons(persons, next)
+    if (rebuilt.length > 0) {
+      storage.savePersons(persons.concat(rebuilt))
+      rebuilt.forEach(p => sync.syncOrEnqueue({ kind: 'person', action: 'add', data: p }))
+    }
+
+    if (patched.length > 0 || rebuilt.length > 0) {
+      console.log(`[migrate] 补齐农历字段 ${patched.length} 条，重建人员 ${rebuilt.length} 个`)
+    }
+    return { lunarPatched: patched.length, personsRebuilt: rebuilt.length }
+  } catch (e) {
+    console.error('[migrate] 迁移失败，已跳过（不影响启动）', e)
+    return null
+  }
+}
+
+module.exports = { run }