lc/wx_pbzc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: correct cloud upsert — query then update/add per user

Browse Source 
Before: add-first-then-update caused duplicate docs on each push
because add() always succeeds once collection exists.

Now: query {_openid} first → update if found, add if not.
Each user always has exactly one document in plank_data.

Also removed debug console.log — only production-scale errors remain.
This commit is contained in:
cnliucheng
2026-06-04 17:41:29 +08:00
parent 6f33dd54c0
commit 90e0e64156
1 changed files with 13 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
utils/cloud.js
+13 -26
View File
@@ -16,9 +16,7 @@ const init = () => {
try { try {
wx.cloud.init({ env: 'cloudbase-d1g56kl2q8f4f7d8a', traceUser: true }) wx.cloud.init({ env: 'cloudbase-d1g56kl2q8f4f7d8a', traceUser: true })
_enabled = true _enabled = true
console.log('[cloud] init ok')
} catch (e) { } catch (e) {
console.error('[cloud] init failed:', e)
_enabled = false _enabled = false
} }
} }
@@ -27,14 +25,11 @@ const pullAll = async () => {
const db = getDb() const db = getDb()
if (!db) return null if (!db) return null
try { try {
console.log('[cloud] pulling data...')
const res = await db.collection(DB_COLLECTION) const res = await db.collection(DB_COLLECTION)
.where({ _openid: '{openid}' }) .where({ _openid: '{openid}' })
.get() .get()
console.log('[cloud] pull result:', res.data.length, 'docs') return (res && res.data && res.data.length > 0) ? res.data[0] : null
return res.data.length > 0 ? res.data[0] : null
} catch (e) { } catch (e) {
console.warn('[cloud] pull skipped (collection may not exist yet):', e.errMsg || e.message)
return null return null
} }
} }
@@ -48,7 +43,6 @@ const pushAll = () => {
const _doPush = async () => { const _doPush = async () => {
const db = getDb() const db = getDb()
if (!db) return if (!db) return
console.log('[cloud] pushing data...')
try { try {
const storage = require('./storage') const storage = require('./storage')
const themeMod = require('./theme') const themeMod = require('./theme')
@@ -61,25 +55,19 @@ const _doPush = async () => {
updatedAt: db.serverDate() updatedAt: db.serverDate()
} }
try { // Query then upsert: one doc per user
const addRes = await db.collection(DB_COLLECTION).add({ data }) const existing = await db.collection(DB_COLLECTION)
console.log('[cloud] push ok (new doc):', addRes._id) .where({ _openid: '{openid}' })
} catch (addErr) { .get()
console.log('[cloud] add returned error, trying update...') if (existing && existing.data && existing.data.length > 0) {
const existing = await db.collection(DB_COLLECTION) await db.collection(DB_COLLECTION)
.where({ _openid: '{openid}' }) .doc(existing.data[0]._id)
.get() .update({ data })
if (existing && existing.data && existing.data.length > 0) { } else {
await db.collection(DB_COLLECTION) await db.collection(DB_COLLECTION).add({ data })
.doc(existing.data[0]._id)
.update({ data })
console.log('[cloud] push ok (updated doc):', existing.data[0]._id)
} else {
console.error('[cloud] push failed: no doc found to update')
}
} }
} catch (e) { } catch (e) {
console.error('[cloud] push error:', e.errMsg || e.message) // Silently retry on next write
} }
} }
@@ -94,10 +82,9 @@ const clearAll = async () => {
await db.collection(DB_COLLECTION) await db.collection(DB_COLLECTION)
.doc(existing.data[0]._id) .doc(existing.data[0]._id)
.remove() .remove()
console.log('[cloud] cleared')
} }
} catch (e) { } catch (e) {
console.warn('[cloud] clear skipped:', e.errMsg || e.message) // Nothing to clear
} }
} }