@@ -320,7 +329,7 @@ routerAdd('GET', '/manage/product-manage', function (e) {
const copyModelInputEl = document.getElementById('copyModelInput')
const loadingMaskEl = document.getElementById('loadingMask')
const loadingTextEl = document.getElementById('loadingText')
- const iconPreviewEl = document.getElementById('iconPreview')
+ const iconPreviewListEl = document.getElementById('iconPreviewList')
const iconEmptyEl = document.getElementById('iconEmpty')
const statusFilterEl = document.getElementById('statusFilter')
const categoryFilterEl = document.getElementById('categoryFilter')
@@ -366,8 +375,8 @@ routerAdd('GET', '/manage/product-manage', function (e) {
tags: [],
},
parameterRows: [],
- currentIconAttachment: null,
- pendingIconFile: null,
+ currentIconAttachments: [],
+ pendingIconFiles: [],
copySourceProductId: '',
}
@@ -779,25 +788,108 @@ routerAdd('GET', '/manage/product-manage', function (e) {
}).join('')
}
- function setIconPreview(url) {
- if (!url) {
- iconPreviewEl.style.display = 'none'
- iconPreviewEl.src = ''
- iconEmptyEl.style.display = 'block'
- return
+ function normalizePositiveInteger(value) {
+ const text = normalizeText(value)
+ if (!text) {
+ return null
}
- iconPreviewEl.style.display = 'block'
- iconPreviewEl.src = url
- iconEmptyEl.style.display = 'none'
+
+ const num = Number(text)
+ if (!Number.isFinite(num) || num <= 0 || Math.floor(num) !== num) {
+ return null
+ }
+
+ return num
+ }
+
+ function buildParameterRow(name, value, sort) {
+ return {
+ name: normalizeText(name),
+ value: value === null || typeof value === 'undefined' ? '' : String(value),
+ sort: normalizePositiveInteger(sort),
+ }
+ }
+
+ function findInvalidParameterSortRow(rows) {
+ for (let i = 0; i < rows.length; i += 1) {
+ const rawSort = normalizeText(rows[i] && rows[i].sort)
+ if (!rawSort) {
+ continue
+ }
+ if (normalizePositiveInteger(rawSort) === null) {
+ return i + 1
+ }
+ }
+ return 0
}
function clearPendingIconPreview() {
- if (state.pendingIconFile && state.pendingIconFile.previewUrl) {
+ for (let i = 0; i < state.pendingIconFiles.length; i += 1) {
+ const item = state.pendingIconFiles[i]
+ if (!item || !item.previewUrl) {
+ continue
+ }
+
try {
- URL.revokeObjectURL(state.pendingIconFile.previewUrl)
+ URL.revokeObjectURL(item.previewUrl)
} catch (_error) {}
}
- state.pendingIconFile = null
+ state.pendingIconFiles = []
+ }
+
+ function getCollectedIconIds() {
+ return state.currentIconAttachments.map(function (item) {
+ return normalizeText(item && item.attachments_id)
+ }).filter(function (item) {
+ return !!item
+ })
+ }
+
+ function renderIconPreview() {
+ const cards = []
+
+ for (let i = 0; i < state.currentIconAttachments.length; i += 1) {
+ const item = state.currentIconAttachments[i]
+ cards.push(
+ '
'
+ + '
 + ')
'
+ + '
已保存
'
+ + '
'
+ + '
'
+ )
+ }
+
+ for (let i = 0; i < state.pendingIconFiles.length; i += 1) {
+ const item = state.pendingIconFiles[i]
+ cards.push(
+ '
'
+ + '
 + ')
'
+ + '
待上传
'
+ + '
'
+ + '
'
+ )
+ }
+
+ iconPreviewListEl.innerHTML = cards.join('')
+ iconEmptyEl.style.display = cards.length ? 'none' : 'block'
+ }
+
+ function sortParameterList(rows) {
+ return rows
+ .slice()
+ .sort(function (a, b) {
+ const sortA = normalizePositiveInteger(a.sort)
+ const sortB = normalizePositiveInteger(b.sort)
+ const safeSortA = sortA === null ? Number.MAX_SAFE_INTEGER : sortA
+ const safeSortB = sortB === null ? Number.MAX_SAFE_INTEGER : sortB
+ if (safeSortA !== safeSortB) {
+ return safeSortA - safeSortB
+ }
+ return Number(a.__inputIndex || 0) - Number(b.__inputIndex || 0)
+ })
+ .map(function (item) {
+ return buildParameterRow(item.name, item.value, item.sort)
+ })
}
function renderParameterRows() {
@@ -810,7 +902,10 @@ routerAdd('GET', '/manage/product-manage', function (e) {
return '
'
+ ' | '
+ ' | '
- + ' | '
+ + ''
+ + ''
+ + ''
+ + ' | '
+ '
'
}).join('')
}
@@ -830,25 +925,15 @@ routerAdd('GET', '/manage/product-manage', function (e) {
return
}
- if (!parsed || typeof parsed !== 'object' || Array.isArray(parsed)) {
- setStatus('JSON 仅支持对象格式，例如：{"属性名":"属性值","电压":"220v"}。', 'error')
- return
- }
-
- const incomingRows = []
- const keys = Object.keys(parsed)
- for (let i = 0; i < keys.length; i += 1) {
- const name = normalizeText(keys[i])
- if (!name) {
- continue
+ if (Array.isArray(parsed)) {
+ const invalidRow = findInvalidParameterSortRow(parsed)
+ if (invalidRow) {
+ setStatus('导入失败：第 ' + invalidRow + ' 项 sort 必须为正整数。', 'error')
+ return
}
- const value = parsed[keys[i]]
- incomingRows.push({
- name: name,
- value: value === null || typeof value === 'undefined' ? '' : String(value),
- })
}
+ const incomingRows = normalizeParameterRows(parsed)
if (!incomingRows.length) {
setStatus('导入内容为空，请至少提供一个有效属性。', 'error')
return
@@ -871,10 +956,10 @@ routerAdd('GET', '/manage/product-manage', function (e) {
const row = incomingRows[i]
const idx = existingIndexMap[row.name]
if (typeof idx === 'number') {
- state.parameterRows[idx].value = row.value
+ state.parameterRows[idx] = buildParameterRow(row.name, row.value, row.sort)
updatedCount += 1
} else {
- state.parameterRows.push({ name: row.name, value: row.value })
+ state.parameterRows.push(buildParameterRow(row.name, row.value, row.sort))
existingIndexMap[row.name] = state.parameterRows.length - 1
addedCount += 1
}
@@ -887,6 +972,17 @@ routerAdd('GET', '/manage/product-manage', function (e) {
function collectParameterArray() {
const result = []
const indexByName = {}
+ let nextAutoSort = 1
+
+ function getAutoSort() {
+ while (result.some(function (item) { return Number(item.sort) === nextAutoSort })) {
+ nextAutoSort += 1
+ }
+ const current = nextAutoSort
+ nextAutoSort += 1
+ return current
+ }
+
for (let i = 0; i < state.parameterRows.length; i += 1) {
const name = normalizeText(state.parameterRows[i].name)
const value = normalizeText(state.parameterRows[i].value)
@@ -894,41 +990,45 @@ routerAdd('GET', '/manage/product-manage', function (e) {
continue
}
+ const rawSort = normalizeText(state.parameterRows[i].sort)
+ const explicitSort = normalizePositiveInteger(rawSort)
+ if (rawSort && explicitSort === null) {
+ throw new Error('第 ' + (i + 1) + ' 行参数排序必须为正整数')
+ }
+ const sortValue = explicitSort === null ? getAutoSort() : explicitSort
const existingIndex = indexByName[name]
if (typeof existingIndex === 'number') {
result[existingIndex].value = value
+ result[existingIndex].sort = sortValue
} else {
indexByName[name] = result.length
result.push({
name: name,
value: value,
+ sort: sortValue,
+ __inputIndex: i + 1,
})
}
}
- return result
+
+ return sortParameterList(result)
}
async function exportParametersToJson() {
- const rows = collectParameterArray()
- const exportObject = {}
-
- for (let i = 0; i < rows.length; i += 1) {
- const name = normalizeText(rows[i].name)
- if (!name) {
- continue
- }
- exportObject[name] = rows[i].value === null || typeof rows[i].value === 'undefined'
- ? ''
- : String(rows[i].value)
+ let rows = []
+ try {
+ rows = collectParameterArray()
+ } catch (err) {
+ setStatus(err.message || '参数导出失败', 'error')
+ return
}
- const keys = Object.keys(exportObject)
- if (!keys.length) {
+ if (!rows.length) {
setStatus('当前参数表为空，暂无可导出的内容。', 'error')
return
}
- const jsonText = JSON.stringify(exportObject, null, 2)
+ const jsonText = JSON.stringify(rows, null, 2)
fields.paramsJsonInput.value = jsonText
let copied = false
@@ -961,18 +1061,19 @@ routerAdd('GET', '/manage/product-manage', function (e) {
const rows = []
const indexByName = {}
- function upsert(nameValue, rawValue) {
+ function upsert(nameValue, rawValue, rawSort, inputIndex) {
const name = normalizeText(nameValue)
if (!name) {
return
}
- const normalizedValue = rawValue === null || typeof rawValue === 'undefined' ? '' : String(rawValue)
+
+ const currentRow = buildParameterRow(name, rawValue, rawSort || inputIndex)
const existingIndex = indexByName[name]
if (typeof existingIndex === 'number') {
- rows[existingIndex].value = normalizedValue
+ rows[existingIndex] = Object.assign({ __inputIndex: inputIndex }, currentRow)
} else {
indexByName[name] = rows.length
- rows.push({ name: name, value: normalizedValue })
+ rows.push(Object.assign({ __inputIndex: inputIndex }, currentRow))
}
}
@@ -982,26 +1083,25 @@ routerAdd('GET', '/manage/product-manage', function (e) {
if (!item) {
continue
}
- upsert(item.name || item.key, item.value)
+ upsert(item.name || item.key, item.value, item.sort, i + 1)
}
- return rows
+ return sortParameterList(rows)
}
if (typeof source !== 'object') {
return []
}
- // Some PocketBase/Goja payloads are object-like values; roundtrip makes keys enumerable.
try {
source = JSON.parse(JSON.stringify(source))
} catch (_error) {}
const keys = Object.keys(source)
for (let i = 0; i < keys.length; i += 1) {
- upsert(keys[i], source[keys[i]])
+ upsert(keys[i], source[keys[i]], i + 1, i + 1)
}
- return rows
+ return sortParameterList(rows)
}
function updateEditorMode() {
@@ -1041,9 +1141,9 @@ routerAdd('GET', '/manage/product-manage', function (e) {
state.selections.powerSupply = []
state.selections.tags = []
state.parameterRows = []
- state.currentIconAttachment = null
+ state.currentIconAttachments = []
clearPendingIconPreview()
- setIconPreview('')
+ renderIconPreview()
renderProductStatusSelector()
renderAllMultiOptionLists()
renderTagOptions()
@@ -1086,14 +1186,16 @@ routerAdd('GET', '/manage/product-manage', function (e) {
state.selections.powerSupply = splitPipe(item.prod_list_power_supply)
state.selections.tags = splitPipe(item.prod_list_tags)
state.parameterRows = normalizeParameterRows(item.prod_list_parameters)
- state.currentIconAttachment = item.prod_list_icon_attachment || null
+ state.currentIconAttachments = Array.isArray(item.prod_list_icon_attachments)
+ ? item.prod_list_icon_attachments.slice()
+ : (item.prod_list_icon_attachment ? [item.prod_list_icon_attachment] : [])
clearPendingIconPreview()
renderProductStatusSelector()
renderAllMultiOptionLists()
renderTagOptions()
renderParameterRows()
- setIconPreview(item.prod_list_icon_url || '')
+ renderIconPreview()
renderSortRankHint()
}
@@ -1257,6 +1359,37 @@ routerAdd('GET', '/manage/product-manage', function (e) {
}
}
+ async function submitProductSilently() {
+ if (state.mode !== 'create' && state.mode !== 'edit') {
+ return true
+ }
+
+ if (!normalizeText(fields.name.value)) {
+ return false
+ }
+
+ try {
+ await submitProduct()
+ return true
+ } catch (_err) {
+ return false
+ }
+ }
+
+ async function saveAndHideEditorBeforeProductQuery() {
+ if (state.mode === 'create' || state.mode === 'edit') {
+ try {
+ await submitProductSilently()
+ } catch (_error) {}
+ enterIdleMode()
+ }
+ }
+
+ async function queryProductsWithAutoSave() {
+ await saveAndHideEditorBeforeProductQuery()
+ await loadProducts()
+ }
+
async function enterEditMode(productId) {
showLoading('正在加载产品详情...')
try {
@@ -1305,22 +1438,27 @@ routerAdd('GET', '/manage/product-manage', function (e) {
showLoading(state.mode === 'edit' ? '正在保存产品修改...' : '正在创建产品...')
const uploadedAttachments = []
- let finalIconId = state.currentIconAttachment && state.currentIconAttachment.attachments_id
- ? state.currentIconAttachment.attachments_id
- : ''
+ let finalIconIds = getCollectedIconIds()
try {
- if (state.pendingIconFile && state.pendingIconFile.file) {
- const uploaded = await uploadAttachment(state.pendingIconFile.file)
+ for (let i = 0; i < state.pendingIconFiles.length; i += 1) {
+ const pendingFile = state.pendingIconFiles[i]
+ if (!pendingFile || !pendingFile.file) {
+ continue
+ }
+
+ const uploaded = await uploadAttachment(pendingFile.file)
uploadedAttachments.push(uploaded)
- finalIconId = uploaded.attachments_id || ''
+ if (uploaded && uploaded.attachments_id) {
+ finalIconIds.push(uploaded.attachments_id)
+ }
}
const payload = {
prod_list_id: state.mode === 'edit' ? state.editingId : '',
prod_list_name: normalizeText(fields.name.value),
prod_list_modelnumber: normalizeText(fields.model.value),
- prod_list_icon: finalIconId,
+ prod_list_icon: joinPipe(finalIconIds),
prod_list_description: normalizeText(fields.description.value),
prod_list_feature: normalizeText(fields.feature.value),
prod_list_parameters: collectParameterArray(),
@@ -1332,6 +1470,7 @@ routerAdd('GET', '/manage/product-manage', function (e) {
prod_list_tags: joinPipe(state.selections.tags),
prod_list_status: normalizeText(state.productStatus) || '有效',
prod_list_basic_price: normalizeText(fields.basicPrice.value),
+ prod_list_sort: normalizeText(fields.sort.value),
prod_list_remark: normalizeText(fields.remark.value),
}
@@ -1474,19 +1613,30 @@ routerAdd('GET', '/manage/product-manage', function (e) {
return
}
+ if (target.matches('input[data-param-sort]')) {
+ const index = Number(target.getAttribute('data-param-sort'))
+ if (Number.isInteger(index) && state.parameterRows[index]) {
+ state.parameterRows[index].sort = target.value
+ }
+ return
+ }
+
if (target === fields.iconFile) {
- const file = target.files && target.files.length ? target.files[0] : null
- clearPendingIconPreview()
- if (!file) {
- setIconPreview(state.currentIconAttachment ? (state.currentIconAttachment.attachments_url || '') : '')
+ const fileList = target.files ? Array.prototype.slice.call(target.files) : []
+ if (!fileList.length) {
return
}
- state.pendingIconFile = {
- file: file,
- previewUrl: URL.createObjectURL(file),
+ for (let i = 0; i < fileList.length; i += 1) {
+ const file = fileList[i]
+ state.pendingIconFiles.push({
+ key: 'pending-' + Date.now() + '-' + i + '-' + Math.random().toString(36).slice(2, 8),
+ file: file,
+ previewUrl: URL.createObjectURL(file),
+ })
}
- setIconPreview(state.pendingIconFile.previewUrl)
+ fields.iconFile.value = ''
+ renderIconPreview()
}
})
@@ -1502,15 +1652,42 @@ routerAdd('GET', '/manage/product-manage', function (e) {
state.parameterRows.splice(index, 1)
renderParameterRows()
}
+ return
+ }
+
+ if (target.matches('button[data-icon-remove-existing]')) {
+ const index = Number(target.getAttribute('data-icon-remove-existing'))
+ if (Number.isInteger(index) && index >= 0 && index < state.currentIconAttachments.length) {
+ state.currentIconAttachments.splice(index, 1)
+ renderIconPreview()
+ }
+ return
+ }
+
+ if (target.matches('button[data-icon-remove-pending]')) {
+ const key = normalizeText(target.getAttribute('data-icon-remove-pending'))
+ const nextFiles = []
+ for (let i = 0; i < state.pendingIconFiles.length; i += 1) {
+ const item = state.pendingIconFiles[i]
+ if (item.key === key) {
+ try {
+ URL.revokeObjectURL(item.previewUrl)
+ } catch (_error) {}
+ continue
+ }
+ nextFiles.push(item)
+ }
+ state.pendingIconFiles = nextFiles
+ renderIconPreview()
}
})
document.getElementById('reloadBtn').addEventListener('click', function () {
- loadProducts()
+ queryProductsWithAutoSave()
})
document.getElementById('searchBtn').addEventListener('click', function () {
- loadProducts()
+ queryProductsWithAutoSave()
})
document.getElementById('createModeBtn').addEventListener('click', function () {
@@ -1522,7 +1699,7 @@ routerAdd('GET', '/manage/product-manage', function (e) {
})
document.getElementById('addParamBtn').addEventListener('click', function () {
- state.parameterRows.push({ name: '', value: '' })
+ state.parameterRows.push(buildParameterRow('', '', ''))
renderParameterRows()
})
@@ -1544,10 +1721,10 @@ routerAdd('GET', '/manage/product-manage', function (e) {
}
document.getElementById('clearIconBtn').addEventListener('click', function () {
- state.currentIconAttachment = null
+ state.currentIconAttachments = []
clearPendingIconPreview()
fields.iconFile.value = ''
- setIconPreview('')
+ renderIconPreview()
})
document.getElementById('copyCancelBtn').addEventListener('click', function () {
diff --git a/pocket-base/spec/openapi-wx.yaml b/pocket-base/spec/openapi-wx.yaml
index b6ffa77..32433e7 100644
--- a/pocket-base/spec/openapi-wx.yaml
+++ b/pocket-base/spec/openapi-wx.yaml
@@ -4,7 +4,13 @@ info:
version: 1.0.0-wx
description: |
面向微信端的小程序接口文档。
- 本文档只包含微信登录、微信资料完善，以及微信端会共用的系统接口。
+ 本文档包含微信登录、微信资料完善，以及微信小程序侧会直接调用的业务接口。
+
+ 微信小程序调用适配说明：
+ - 除 `/pb/api/wechat/login` 外，其余购物车 / 订单接口都需要在请求头中携带 `Authorization: Bearer
`
+ - `token` 取自 `/pb/api/wechat/login` 成功返回的认证 token
+ - 小程序端应统一使用 HTTPS + JSON 请求体，不依赖 Cookie / Session
+ - 购物车与订单接口的 owner 字段由服务端根据当前 token 自动绑定到 `tbl_auth_users.openid`
license:
name: Proprietary
identifier: LicenseRef-Proprietary
@@ -26,9 +32,15 @@ tags:
description: 通过 PocketBase 原生 records API 访问 `tbl_product_list`
- name: 文档信息
description: 通过 PocketBase 原生 records API 访问 `tbl_document`
+ - name: 购物车
+ description: 微信小程序侧购物车 CRUD 接口
+ - name: 订单
+ description: 微信小程序侧订单 CRUD 接口
+security: []
paths:
/pb/api/system/users-count:
post:
+ security: []
operationId: postSystemUsersCount
tags:
- 系统
@@ -55,6 +67,9 @@ paths:
$ref: '#/components/schemas/ErrorResponse'
/pb/api/system/refresh-token:
post:
+ security:
+ - BearerAuth: []
+ - {}
operationId: postSystemRefreshToken
tags:
- 系统
@@ -113,6 +128,7 @@ paths:
$ref: '#/components/schemas/ErrorResponse'
/pb/api/wechat/login:
post:
+ security: []
operationId: postWechatLogin
tags:
- 微信认证
@@ -165,6 +181,8 @@ paths:
$ref: '#/components/schemas/ErrorResponse'
/pb/api/wechat/profile:
post:
+ security:
+ - BearerAuth: []
operationId: postWechatProfile
tags:
- 微信认证
@@ -984,7 +1002,591 @@ paths:
application/json:
schema:
$ref: '#/components/schemas/PocketBaseNativeError'
+ /pb/api/cart/list:
+ post:
+ operationId: postCartList
+ tags:
+ - 购物车
+ summary: 查询当前登录用户的购物车列表
+ description: |
+ 返回当前 `Authorization` 对应 openid 名下的购物车记录。
+ 小程序端不需要传 `cart_owner`，服务端会自动基于 token 过滤。
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartListRequest'
+ responses:
+ '200':
+ description: 查询成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartListResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/cart/detail:
+ post:
+ operationId: postCartDetail
+ tags:
+ - 购物车
+ summary: 查询当前登录用户的购物车详情
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartDetailRequest'
+ responses:
+ '200':
+ description: 查询成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartDetailResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '404':
+ description: 购物车记录不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/cart/create:
+ post:
+ operationId: postCartCreate
+ tags:
+ - 购物车
+ summary: 创建购物车记录
+ description: |
+ `cart_owner`、`cart_create` 由服务端自动处理。
+ 小程序端只需要提交商品、数量、价格和可选备注。
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartCreateRequest'
+ responses:
+ '200':
+ description: 创建成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartMutationResponse'
+ '400':
+ description: 请求参数错误或产品不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '429':
+ description: 请求过于频繁
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/cart/update:
+ post:
+ operationId: postCartUpdate
+ tags:
+ - 购物车
+ summary: 更新购物车记录
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartUpdateRequest'
+ responses:
+ '200':
+ description: 更新成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartMutationResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '404':
+ description: 购物车记录不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '429':
+ description: 请求过于频繁
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/cart/delete:
+ post:
+ operationId: postCartDelete
+ tags:
+ - 购物车
+ summary: 删除购物车记录
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartDeleteRequest'
+ responses:
+ '200':
+ description: 删除成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/CartDeleteResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '404':
+ description: 购物车记录不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '429':
+ description: 请求过于频繁
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/order/list:
+ post:
+ operationId: postOrderList
+ tags:
+ - 订单
+ summary: 查询当前登录用户的订单列表
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderListRequest'
+ responses:
+ '200':
+ description: 查询成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderListResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/order/detail:
+ post:
+ operationId: postOrderDetail
+ tags:
+ - 订单
+ summary: 查询当前登录用户的订单详情
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderDetailRequest'
+ responses:
+ '200':
+ description: 查询成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderDetailResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '404':
+ description: 订单记录不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/order/create:
+ post:
+ operationId: postOrderCreate
+ tags:
+ - 订单
+ summary: 创建订单
+ description: |
+ `order_owner`、`order_create` 由服务端自动处理。
+ 小程序端需要提交订单来源、来源 ID、订单快照和订单金额。
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderCreateRequest'
+ responses:
+ '200':
+ description: 创建成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderMutationResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '429':
+ description: 请求过于频繁
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/order/update:
+ post:
+ operationId: postOrderUpdate
+ tags:
+ - 订单
+ summary: 更新订单
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderUpdateRequest'
+ responses:
+ '200':
+ description: 更新成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderMutationResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '404':
+ description: 订单记录不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '429':
+ description: 请求过于频繁
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ /pb/api/order/delete:
+ post:
+ operationId: postOrderDelete
+ tags:
+ - 订单
+ summary: 删除订单
+ security:
+ - BearerAuth: []
+ requestBody:
+ required: true
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderDeleteRequest'
+ responses:
+ '200':
+ description: 删除成功
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/OrderDeleteResponse'
+ '400':
+ description: 请求参数错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '401':
+ description: token 缺失、无效或已过期
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '403':
+ description: 无权访问目标数据
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '404':
+ description: 订单记录不存在
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '415':
+ description: 请求体不是 JSON
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '429':
+ description: 请求过于频繁
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
+ '500':
+ description: 服务端错误
+ content:
+ application/json:
+ schema:
+ $ref: '#/components/schemas/ErrorResponse'
components:
+ securitySchemes:
+ BearerAuth:
+ type: http
+ scheme: bearer
+ bearerFormat: JWT
schemas:
ApiResponseBase:
type: object
@@ -1038,6 +1640,281 @@ components:
errMsg: 失败原因提示 | string
data:
任意错误字段: 错误附加信息 | object
+ CartRecord:
+ type: object
+ required:
+ - cart_id
+ - cart_number
+ - cart_create
+ - cart_owner
+ - cart_product_id
+ - cart_product_quantity
+ - cart_status
+ - cart_at_price
+ properties:
+ pb_id:
+ type: string
+ cart_id:
+ type: string
+ cart_number:
+ type: string
+ cart_create:
+ type: string
+ description: 购物车项创建时间
+ cart_owner:
+ type: string
+ description: 当前登录用户 openid
+ cart_product_id:
+ type: string
+ cart_product_quantity:
+ type: integer
+ cart_status:
+ type: string
+ cart_at_price:
+ type: number
+ cart_remark:
+ type: string
+ product_name:
+ type: string
+ product_modelnumber:
+ type: string
+ product_basic_price:
+ type:
+ - number
+ - 'null'
+ created:
+ type: string
+ updated:
+ type: string
+ CartListRequest:
+ type: object
+ properties:
+ keyword:
+ type: string
+ description: 按购物车编号、商品 ID、商品名称模糊搜索
+ cart_status:
+ type: string
+ cart_number:
+ type: string
+ CartDetailRequest:
+ type: object
+ required:
+ - cart_id
+ properties:
+ cart_id:
+ type: string
+ CartCreateRequest:
+ type: object
+ required:
+ - cart_product_id
+ - cart_product_quantity
+ - cart_at_price
+ properties:
+ cart_number:
+ type: string
+ cart_product_id:
+ type: string
+ cart_product_quantity:
+ type: integer
+ cart_status:
+ type: string
+ cart_at_price:
+ type: number
+ cart_remark:
+ type: string
+ CartUpdateRequest:
+ type: object
+ required:
+ - cart_id
+ properties:
+ cart_id:
+ type: string
+ cart_number:
+ type: string
+ cart_product_id:
+ type: string
+ cart_product_quantity:
+ type: integer
+ cart_status:
+ type: string
+ cart_at_price:
+ type: number
+ cart_remark:
+ type: string
+ CartDeleteRequest:
+ type: object
+ required:
+ - cart_id
+ properties:
+ cart_id:
+ type: string
+ CartListResponse:
+ type: object
+ required:
+ - items
+ properties:
+ items:
+ type: array
+ items:
+ $ref: '#/components/schemas/CartRecord'
+ CartDetailResponse:
+ $ref: '#/components/schemas/CartRecord'
+ CartMutationResponse:
+ $ref: '#/components/schemas/CartRecord'
+ CartDeleteResponse:
+ type: object
+ required:
+ - cart_id
+ properties:
+ cart_id:
+ type: string
+ OrderRecord:
+ type: object
+ required:
+ - order_id
+ - order_number
+ - order_create
+ - order_owner
+ - order_source
+ - order_status
+ - order_source_id
+ - order_snap
+ - order_amount
+ properties:
+ pb_id:
+ type: string
+ order_id:
+ type: string
+ order_number:
+ type: string
+ order_create:
+ type: string
+ description: 订单创建时间
+ order_owner:
+ type: string
+ description: 当前登录用户 openid
+ order_source:
+ type: string
+ order_status:
+ type: string
+ order_source_id:
+ type: string
+ order_snap:
+ description: 下单快照
+ oneOf:
+ - type: object
+ additionalProperties: true
+ - type: array
+ items:
+ type: object
+ additionalProperties: true
+ order_amount:
+ type: number
+ order_remark:
+ type: string
+ created:
+ type: string
+ updated:
+ type: string
+ OrderListRequest:
+ type: object
+ properties:
+ keyword:
+ type: string
+ description: 按订单编号、订单 ID、来源 ID 模糊搜索
+ order_status:
+ type: string
+ order_source:
+ type: string
+ OrderDetailRequest:
+ type: object
+ required:
+ - order_id
+ properties:
+ order_id:
+ type: string
+ OrderCreateRequest:
+ type: object
+ required:
+ - order_source
+ - order_source_id
+ - order_snap
+ - order_amount
+ properties:
+ order_number:
+ type: string
+ order_source:
+ type: string
+ order_status:
+ type: string
+ order_source_id:
+ type: string
+ order_snap:
+ oneOf:
+ - type: object
+ additionalProperties: true
+ - type: array
+ items:
+ type: object
+ additionalProperties: true
+ order_amount:
+ type: number
+ order_remark:
+ type: string
+ OrderUpdateRequest:
+ type: object
+ required:
+ - order_id
+ properties:
+ order_id:
+ type: string
+ order_number:
+ type: string
+ order_source:
+ type: string
+ order_status:
+ type: string
+ order_source_id:
+ type: string
+ order_snap:
+ oneOf:
+ - type: object
+ additionalProperties: true
+ - type: array
+ items:
+ type: object
+ additionalProperties: true
+ order_amount:
+ type: number
+ order_remark:
+ type: string
+ OrderDeleteRequest:
+ type: object
+ required:
+ - order_id
+ properties:
+ order_id:
+ type: string
+ OrderListResponse:
+ type: object
+ required:
+ - items
+ properties:
+ items:
+ type: array
+ items:
+ $ref: '#/components/schemas/OrderRecord'
+ OrderDetailResponse:
+ $ref: '#/components/schemas/OrderRecord'
+ OrderMutationResponse:
+ $ref: '#/components/schemas/OrderRecord'
+ OrderDeleteResponse:
+ type: object
+ required:
+ - order_id
+ properties:
+ order_id:
+ type: string
CompanyInfo:
anyOf:
- type: object
@@ -2449,4 +3326,3 @@ components:
errMsg: 业务提示信息 | string
data:
total_users: 用户总数 | integer
-
diff --git a/script/pocketbase.cart-order.js b/script/pocketbase.cart-order.js
new file mode 100644
index 0000000..34eb88d
--- /dev/null
+++ b/script/pocketbase.cart-order.js
@@ -0,0 +1,282 @@
+import { createRequire } from 'module';
+import PocketBase from 'pocketbase';
+
+const require = createRequire(import.meta.url);
+
+let runtimeConfig = {};
+try {
+ runtimeConfig = require('../pocket-base/bai_api_pb_hooks/bai_api_shared/config/runtime.js');
+} catch (_error) {
+ runtimeConfig = {};
+}
+
+const PB_URL = (process.env.PB_URL || 'https://bai-api.blv-oa.com/pb').replace(/\/+$/, '');
+const AUTH_TOKEN = process.env.POCKETBASE_AUTH_TOKEN || runtimeConfig.POCKETBASE_AUTH_TOKEN || '';
+const OWNER_AUTH_RULE = '@request.auth.id != ""';
+const CART_OWNER_MATCH_RULE = 'cart_owner = @request.auth.openid';
+const ORDER_OWNER_MATCH_RULE = 'order_owner = @request.auth.openid';
+
+if (!AUTH_TOKEN) {
+ console.error('❌ 缺少 POCKETBASE_AUTH_TOKEN，无法执行建表。');
+ process.exit(1);
+}
+
+const pb = new PocketBase(PB_URL);
+
+const collections = [
+ {
+ name: 'tbl_cart',
+ type: 'base',
+ listRule: `${OWNER_AUTH_RULE} && ${CART_OWNER_MATCH_RULE}`,
+ viewRule: `${OWNER_AUTH_RULE} && ${CART_OWNER_MATCH_RULE}`,
+ createRule: `${OWNER_AUTH_RULE} && @request.body.cart_owner = @request.auth.openid`,
+ updateRule: `${OWNER_AUTH_RULE} && ${CART_OWNER_MATCH_RULE}`,
+ deleteRule: `${OWNER_AUTH_RULE} && ${CART_OWNER_MATCH_RULE}`,
+ fields: [
+ { name: 'cart_id', type: 'text', required: true },
+ { name: 'cart_number', type: 'text', required: true },
+ { name: 'cart_create', type: 'autodate', onCreate: true, onUpdate: false },
+ { name: 'cart_owner', type: 'text', required: true },
+ { name: 'cart_product_id', type: 'text', required: true },
+ { name: 'cart_product_quantity', type: 'number', required: true },
+ { name: 'cart_status', type: 'text', required: true },
+ { name: 'cart_at_price', type: 'number', required: true },
+ { name: 'cart_remark', type: 'text' },
+ ],
+ indexes: [
+ 'CREATE UNIQUE INDEX idx_tbl_cart_cart_id ON tbl_cart (cart_id)',
+ 'CREATE INDEX idx_tbl_cart_cart_number ON tbl_cart (cart_number)',
+ 'CREATE INDEX idx_tbl_cart_cart_owner ON tbl_cart (cart_owner)',
+ 'CREATE INDEX idx_tbl_cart_cart_product_id ON tbl_cart (cart_product_id)',
+ 'CREATE INDEX idx_tbl_cart_cart_status ON tbl_cart (cart_status)',
+ 'CREATE INDEX idx_tbl_cart_cart_create ON tbl_cart (cart_create)',
+ 'CREATE INDEX idx_tbl_cart_owner_number ON tbl_cart (cart_owner, cart_number)',
+ 'CREATE INDEX idx_tbl_cart_owner_status ON tbl_cart (cart_owner, cart_status)',
+ ],
+ },
+ {
+ name: 'tbl_order',
+ type: 'base',
+ listRule: `${OWNER_AUTH_RULE} && ${ORDER_OWNER_MATCH_RULE}`,
+ viewRule: `${OWNER_AUTH_RULE} && ${ORDER_OWNER_MATCH_RULE}`,
+ createRule: `${OWNER_AUTH_RULE} && @request.body.order_owner = @request.auth.openid`,
+ updateRule: `${OWNER_AUTH_RULE} && ${ORDER_OWNER_MATCH_RULE}`,
+ deleteRule: `${OWNER_AUTH_RULE} && ${ORDER_OWNER_MATCH_RULE}`,
+ fields: [
+ { name: 'order_id', type: 'text', required: true },
+ { name: 'order_number', type: 'text', required: true },
+ { name: 'order_create', type: 'autodate', onCreate: true, onUpdate: false },
+ { name: 'order_owner', type: 'text', required: true },
+ { name: 'order_source', type: 'text', required: true },
+ { name: 'order_status', type: 'text', required: true },
+ { name: 'order_source_id', type: 'text', required: true },
+ { name: 'order_snap', type: 'json', required: true },
+ { name: 'order_amount', type: 'number', required: true },
+ { name: 'order_remark', type: 'text' },
+ ],
+ indexes: [
+ 'CREATE UNIQUE INDEX idx_tbl_order_order_id ON tbl_order (order_id)',
+ 'CREATE UNIQUE INDEX idx_tbl_order_order_number ON tbl_order (order_number)',
+ 'CREATE INDEX idx_tbl_order_order_owner ON tbl_order (order_owner)',
+ 'CREATE INDEX idx_tbl_order_order_source ON tbl_order (order_source)',
+ 'CREATE INDEX idx_tbl_order_order_status ON tbl_order (order_status)',
+ 'CREATE INDEX idx_tbl_order_order_source_id ON tbl_order (order_source_id)',
+ 'CREATE INDEX idx_tbl_order_order_create ON tbl_order (order_create)',
+ 'CREATE INDEX idx_tbl_order_owner_status ON tbl_order (order_owner, order_status)',
+ ],
+ },
+];
+
+function normalizeFieldPayload(field, existingField) {
+ const payload = existingField
+ ? Object.assign({}, existingField)
+ : {
+ name: field.name,
+ type: field.type,
+ };
+
+ if (existingField && existingField.id) {
+ payload.id = existingField.id;
+ }
+
+ payload.name = field.name;
+ payload.type = field.type;
+
+ if (typeof field.required !== 'undefined') {
+ payload.required = field.required;
+ }
+
+ if (field.type === 'autodate') {
+ payload.onCreate = typeof field.onCreate === 'boolean' ? field.onCreate : true;
+ payload.onUpdate = typeof field.onUpdate === 'boolean' ? field.onUpdate : false;
+ }
+
+ return payload;
+}
+
+function buildCollectionPayload(collectionData, existingCollection) {
+ if (!existingCollection) {
+ return {
+ name: collectionData.name,
+ type: collectionData.type,
+ listRule: Object.prototype.hasOwnProperty.call(collectionData, 'listRule') ? collectionData.listRule : null,
+ viewRule: Object.prototype.hasOwnProperty.call(collectionData, 'viewRule') ? collectionData.viewRule : null,
+ createRule: Object.prototype.hasOwnProperty.call(collectionData, 'createRule') ? collectionData.createRule : null,
+ updateRule: Object.prototype.hasOwnProperty.call(collectionData, 'updateRule') ? collectionData.updateRule : null,
+ deleteRule: Object.prototype.hasOwnProperty.call(collectionData, 'deleteRule') ? collectionData.deleteRule : null,
+ fields: collectionData.fields.map((field) => normalizeFieldPayload(field, null)),
+ indexes: collectionData.indexes,
+ };
+ }
+
+ const targetFieldMap = new Map(collectionData.fields.map((field) => [field.name, field]));
+ const fields = (existingCollection.fields || []).map((existingField) => {
+ const targetField = targetFieldMap.get(existingField.name);
+ if (!targetField) {
+ return existingField;
+ }
+
+ targetFieldMap.delete(existingField.name);
+ return normalizeFieldPayload(targetField, existingField);
+ });
+
+ for (const field of targetFieldMap.values()) {
+ fields.push(normalizeFieldPayload(field, null));
+ }
+
+ return {
+ name: collectionData.name,
+ type: collectionData.type,
+ listRule: Object.prototype.hasOwnProperty.call(collectionData, 'listRule') ? collectionData.listRule : existingCollection.listRule,
+ viewRule: Object.prototype.hasOwnProperty.call(collectionData, 'viewRule') ? collectionData.viewRule : existingCollection.viewRule,
+ createRule: Object.prototype.hasOwnProperty.call(collectionData, 'createRule') ? collectionData.createRule : existingCollection.createRule,
+ updateRule: Object.prototype.hasOwnProperty.call(collectionData, 'updateRule') ? collectionData.updateRule : existingCollection.updateRule,
+ deleteRule: Object.prototype.hasOwnProperty.call(collectionData, 'deleteRule') ? collectionData.deleteRule : existingCollection.deleteRule,
+ fields: fields,
+ indexes: collectionData.indexes,
+ };
+}
+
+function normalizeFieldList(fields) {
+ return (fields || []).map((field) => ({
+ name: field.name,
+ type: field.type,
+ required: !!field.required,
+ }));
+}
+
+async function createOrUpdateCollection(collectionData) {
+ console.log(`🔄 正在处理表: ${collectionData.name} ...`);
+
+ try {
+ const list = await pb.collections.getFullList({
+ sort: '-created',
+ });
+ const existing = list.find((item) => item.name === collectionData.name);
+
+ if (existing) {
+ await pb.collections.update(existing.id, buildCollectionPayload(collectionData, existing));
+ console.log(`♻️ ${collectionData.name} 已存在，已按最新结构更新。`);
+ return;
+ }
+
+ await pb.collections.create(buildCollectionPayload(collectionData, null));
+ console.log(`✅ ${collectionData.name} 创建完成。`);
+ } catch (error) {
+ console.error(`❌ 处理集合 ${collectionData.name} 失败:`, {
+ status: error.status,
+ message: error.message,
+ response: error.response,
+ });
+ throw error;
+ }
+}
+
+async function getCollectionByName(collectionName) {
+ const list = await pb.collections.getFullList({
+ sort: '-created',
+ });
+ return list.find((item) => item.name === collectionName) || null;
+}
+
+async function verifyCollections(targetCollections) {
+ console.log('\n🔍 开始校验购物车与订单表结构及索引...');
+
+ for (const target of targetCollections) {
+ const remote = await getCollectionByName(target.name);
+ if (!remote) {
+ throw new Error(`${target.name} 不存在`);
+ }
+
+ const remoteFields = normalizeFieldList(remote.fields);
+ const targetFields = normalizeFieldList(target.fields);
+ const remoteFieldMap = new Map(remoteFields.map((field) => [field.name, field.type]));
+ const remoteRequiredMap = new Map(remoteFields.map((field) => [field.name, field.required]));
+ const missingFields = [];
+ const mismatchedTypes = [];
+ const mismatchedRequired = [];
+
+ for (const field of targetFields) {
+ if (!remoteFieldMap.has(field.name)) {
+ missingFields.push(field.name);
+ continue;
+ }
+
+ if (remoteFieldMap.get(field.name) !== field.type) {
+ mismatchedTypes.push(`${field.name}:${remoteFieldMap.get(field.name)}!=${field.type}`);
+ }
+
+ if (remoteRequiredMap.get(field.name) !== !!field.required) {
+ mismatchedRequired.push(`${field.name}:${remoteRequiredMap.get(field.name)}!=${!!field.required}`);
+ }
+ }
+
+ const remoteIndexes = new Set(remote.indexes || []);
+ const missingIndexes = target.indexes.filter((indexSql) => !remoteIndexes.has(indexSql));
+
+ if (remote.type !== target.type) {
+ throw new Error(`${target.name} 类型不匹配，期望 ${target.type}，实际 ${remote.type}`);
+ }
+
+ if (!missingFields.length && !mismatchedTypes.length && !mismatchedRequired.length && !missingIndexes.length) {
+ console.log(`✅ ${target.name} 校验通过。`);
+ continue;
+ }
+
+ console.log(`❌ ${target.name} 校验失败：`);
+ if (missingFields.length) {
+ console.log(` - 缺失字段: ${missingFields.join(', ')}`);
+ }
+ if (mismatchedTypes.length) {
+ console.log(` - 字段类型不匹配: ${mismatchedTypes.join(', ')}`);
+ }
+ if (mismatchedRequired.length) {
+ console.log(` - 字段必填属性不匹配: ${mismatchedRequired.join(', ')}`);
+ }
+ if (missingIndexes.length) {
+ console.log(` - 缺失索引: ${missingIndexes.join(' | ')}`);
+ }
+
+ throw new Error(`${target.name} 结构与预期不一致`);
+ }
+}
+
+async function init() {
+ try {
+ console.log(`🔄 正在连接 PocketBase: ${PB_URL}`);
+ pb.authStore.save(AUTH_TOKEN, null);
+ console.log('✅ 已使用 POCKETBASE_AUTH_TOKEN 载入认证状态。');
+
+ for (const collectionData of collections) {
+ await createOrUpdateCollection(collectionData);
+ }
+
+ await verifyCollections(collections);
+ console.log('\n🎉 购物车与订单表结构初始化并校验完成！');
+ } catch (error) {
+ console.error('❌ 初始化失败:', error.response?.data || error.message);
+ process.exitCode = 1;
+ }
+}
+
+init();