' + escapeHtml(meta.desc) + "
"; - if (status === "pending" && timeLeft > 0) { - html += '剩余支付时间 ' + timeLeft + " 秒"; - } - html += "原因：' + escapeHtml(reasonLabel) + "
"; - if (applyDesc !== "") html += '申请理由：' + escapeHtml(applyDesc).replace(/\r\n|\r|\n/g, "
") + "
' + escapeHtml(item.reason).replace(/\r\n|\r|\n/g, "
") + "
支付状态可能仍在同步，请刷新后查看。
"; - html += ''; - html += "订单不存在
'; - return; - } - renderDetail(state, data, session); - }, - onData: function (data) { - if (refresh) { - delete state.operationKeys[actionKey]; - invalidateOrder(orderNumber, data); - } - }, - }; - } - - function openDetail(state, orderNumber) { - if (!orderNumber) return; - state.detailSession = null; - state.detailReplacement = false; - state.detailReplacementSession = null; - state.detailOrderNumber = orderNumber; - window.AksrtModalRuntime.openRemote(detailOptions(state, orderNumber, false)); - } - - function refreshDetail(state, orderNumber) { - if (!orderNumber || !activeDetail(state, orderNumber)) return; - state.detailReplacement = true; - state.detailReplacementSession = state.detailSession; - var refreshPromise = window.AksrtModalRuntime.openRemote(detailOptions(state, orderNumber, true)); - refreshPromise.then(function () { - state.detailReplacement = false; - state.detailReplacementSession = null; - }, function () { - state.detailReplacement = false; - state.detailReplacementSession = null; - }); - } - - function currentViewPath(state) { - var query = new URLSearchParams(); - if (state.query.status && state.query.status !== "all") query.set("order_status", state.query.status); - if (state.query.type) query.set("order_type", state.query.type); - if (state.query.orderNumber) query.set("order_number", state.query.orderNumber); - if (Number(state.query.page) > 1) query.set("order_page", String(state.query.page)); - return "/orders/view" + (query.toString() ? "?" + query.toString() : ""); - } - - function actionHtml(order) { - var allowedActions = order.allowed_actions || {}; - var afterSale = order.after_sale || {}; - var html = ''; - if (allowedActions.can_cancel) html += ''; - if (allowedActions.can_pay) html += ''; - // 售后入口：申请售后 / 售后详细走 order-after-sale.js 的独立弹窗。 - if (afterSale.enabled) html += afterSaleButtons(order); - return html; - } - - // 售后按钮（列表卡片与订单详情弹窗共用）：已申请 → 售后详细，否则 → 申请售后。 - // 载荷与 PHP 模板同构（order-after-sale.js 同步消费），点击即弹窗、无前置请求。 - function afterSalePayload(order) { - var afterSale = order.after_sale || {}; - return escapeHtml(JSON.stringify({ - order_number: order.order_number || "", - product_name: order.product_name || "", - amount: order.amount || "0", - is_points: !!order.is_points, - currency_symbol: order.currency_symbol || "", - status_label: order.status_label || "", - after_sale: afterSale, - })); - } - - function afterSaleButtons(order) { - var afterSale = order.after_sale || {}; - var html = ""; - if (!afterSale.enabled) return html; - var payload = afterSalePayload(order); - if (afterSale.has_application) { - html += ''; - return html; - } - html += ''; - return html; - } - - function cardHtml(order) { - var image = order.image - ? '订单号 " + escapeHtml(order.order_number) + "
换个条件试试，或清除当前筛选。
'; - list.classList.remove("aksrt-orders-page__list"); - list.classList.add("aksrt-orders-page__empty"); - } else { - list.classList.remove("aksrt-orders-page__empty"); - list.classList.add("aksrt-orders-page__list"); - list.innerHTML = items.map(cardHtml).join(""); - } - renderPagination(state, view); - syncControls(state); - updateCountdowns(state); - } - - function syncControls(state) { - state.root.querySelectorAll("[data-aksrt-order-filter]").forEach(function (button) { - var field = button.getAttribute("data-aksrt-order-filter"); - var expected = field === "status" ? state.query.status : state.query.type; - var active = button.getAttribute("data-aksrt-order-filter-value") === expected; - button.classList.toggle("is-active", active); - button.setAttribute("aria-pressed", active ? "true" : "false"); - }); - var input = state.root.querySelector("#aksrt-order-number"); - if (input && input.value !== state.query.orderNumber) input.value = state.query.orderNumber; - } - - function setViewLoading(state, loading) { - state.root.classList.toggle("is-loading", loading); - state.root.setAttribute("aria-busy", loading ? "true" : "false"); - } - - function loadView(state, patch) { - Object.keys(patch || {}).forEach(function (key) { state.query[key] = patch[key]; }); - var requestId = ++state.viewRequest; - setViewLoading(state, true); - return request(currentViewPath(state), undefined, "GET").then(function (result) { - if (requestId !== state.viewRequest) return null; - if (!result || !result.data) throw new Error("刷新失败"); - renderView(state, result.data); - return result.data; - }).catch(function (error) { - if (requestId === state.viewRequest) notyf(errorMessage(error, "订单加载失败，请稍后重试"), "danger"); - return null; - }).finally(function () { - if (requestId === state.viewRequest) setViewLoading(state, false); - }); - } - - function refreshView(state) { - return loadView(state); - } - - function startPayment(state, button) { - var number = button.getAttribute("data-aksrt-order-pay") || ""; - var method = button.getAttribute("data-aksrt-order-method") || ""; - if (!number || button.disabled) return; - var actionKey = "pay:" + number; - if (!state.operationKeys[actionKey]) state.operationKeys[actionKey] = window.AksrtRequest.createIdempotencyKey(); - button.disabled = true; - request(orderPath(number, "/pay"), method ? { payment_method: method } : {}, "POST", state.operationKeys[actionKey]).then(function (result) { - delete state.operationKeys[actionKey]; - var data = result.data || {}; - invalidateOrder(number, data.order); - if (data.redirect && data.payment_url) { - window.location.assign(data.payment_url); - return; - } - notyf(data.message || "支付成功", "success"); - refreshView(state); - if (activeDetail(state, number)) openDetail(state, number); - }).catch(function (error) { - button.disabled = false; - notyf(errorMessage(error, "网络错误，请稍后重试"), "danger"); - }); - } - - function closeOrder(state, button) { - var number = button.getAttribute("data-aksrt-order-cancel") || ""; - if (!number || button.disabled) return; - if (button.getAttribute("data-aksrt-confirm") !== "true") { - button.setAttribute("data-aksrt-confirm", "true"); - button.textContent = "确认关闭"; - return; - } - button.disabled = true; - var actionKey = "cancel:" + number; - if (!state.operationKeys[actionKey]) state.operationKeys[actionKey] = window.AksrtRequest.createIdempotencyKey(); - request(orderPath(number, "/cancel"), {}, "POST", state.operationKeys[actionKey]).then(function (result) { - delete state.operationKeys[actionKey]; - var data = result.data || {}; - invalidateOrder(number, data.order); - notyf("订单已关闭", "success"); - refreshView(state); - if (activeDetail(state, number)) openDetail(state, number); - }).catch(function (error) { - button.disabled = false; - button.removeAttribute("data-aksrt-confirm"); - button.textContent = "关闭订单"; - notyf(errorMessage(error, "网络错误，请稍后重试"), "danger"); - }); - } - - function copyOrderValue(button) { - var value = button.getAttribute("data-aksrt-order-copy") || ""; - if (!value) return; - var icon = button.querySelector("i"); - var settle = function (ok) { - notyf(ok ? "订单号已复制" : "复制失败，请手动选择复制", ok ? "success" : "danger"); - if (!ok) return; - button.classList.add("is-copied"); - if (icon) icon.className = "fa fas fa-check"; - window.setTimeout(function () { - button.classList.remove("is-copied"); - if (icon) icon.className = "fa fas fa-copy"; - }, 1600); - }; - var fallback = function () { - try { - var field = document.createElement("textarea"); - field.value = value; - field.setAttribute("readonly", "readonly"); - field.style.position = "fixed"; - field.style.top = "-1000px"; - field.style.opacity = "0"; - document.body.appendChild(field); - field.select(); - document.execCommand("copy"); - document.body.removeChild(field); - settle(true); - } catch (error) { - settle(false); - } - }; - if (navigator.clipboard && navigator.clipboard.writeText) { - navigator.clipboard.writeText(value).then(function () { settle(true); }, fallback); - return; - } - fallback(); - } - - function closest(target, selector) { - return target && target.closest ? target.closest(selector) : null; - } - - function initRoot(root) { - if (instances.has(root)) return; - var state = { - root: root, - detailOrderNumber: "", - detailSession: null, - detailReplacement: false, - detailReplacementSession: null, - countdownTimer: null, - operationKeys: {}, - query: { status: "all", type: "", orderNumber: "", page: 1 }, - viewRequest: 0, - }; - - state.onRootClick = function (event) { - var filterToggle = closest(event.target, "[data-aksrt-orders-filter-toggle]"); - if (filterToggle && root.contains(filterToggle)) { - var panel = root.querySelector("[data-aksrt-orders-filter-panel]"); - var expanded = filterToggle.getAttribute("aria-expanded") === "true"; - filterToggle.setAttribute("aria-expanded", String(!expanded)); - if (panel) panel.hidden = expanded; - return; - } - var filter = closest(event.target, "[data-aksrt-order-filter]"); - if (filter && root.contains(filter)) { - event.preventDefault(); - var field = filter.getAttribute("data-aksrt-order-filter"); - var patch = { page: 1 }; - patch[field] = filter.getAttribute("data-aksrt-order-filter-value") || ""; - loadView(state, patch); - return; - } - var page = closest(event.target, "[data-aksrt-order-page]"); - if (page && root.contains(page)) { - event.preventDefault(); - loadView(state, { page: Math.max(1, Number(page.getAttribute("data-aksrt-order-page") || 1)) }); - return; - } - var clear = closest(event.target, "[data-aksrt-orders-clear]"); - if (clear && root.contains(clear)) { - event.preventDefault(); - loadView(state, { status: "all", type: "", orderNumber: "", page: 1 }); - return; - } - var detail = closest(event.target, "[data-aksrt-order-detail]"); - if (detail && root.contains(detail)) { openDetail(state, detail.getAttribute("data-aksrt-order-detail")); return; } - var pay = closest(event.target, "[data-aksrt-order-pay]"); - if (pay && root.contains(pay)) { event.preventDefault(); startPayment(state, pay); return; } - var cancel = closest(event.target, "[data-aksrt-order-cancel]"); - if (cancel && root.contains(cancel)) { event.preventDefault(); closeOrder(state, cancel); } - }; - state.onRootSubmit = function (event) { - var form = closest(event.target, "[data-aksrt-orders-search]"); - if (!form || !root.contains(form)) return; - event.preventDefault(); - var input = form.querySelector("#aksrt-order-number"); - loadView(state, { orderNumber: input ? String(input.value || "").trim() : "", page: 1 }); - }; - state.onModalClose = function (event) { - var detail = event && event.detail ? event.detail : {}; - if (!state.detailSession || detail.session !== state.detailSession) return; - if (detail.reason === "replace" && state.detailReplacement && detail.session === state.detailReplacementSession) return; - state.detailSession = null; - state.detailOrderNumber = ""; - state.detailReplacement = false; - state.detailReplacementSession = null; - }; - state.onDocumentClick = function (event) { - var afterSaleCancel = closest(event.target, "[data-aksrt-after-sale-cancel]"); - if (afterSaleCancel && !event.__aksrtAfterSaleCancelHandled) { - var afterSaleNumber = afterSaleCancel.getAttribute("data-aksrt-after-sale-cancel") || ""; - if (activeDetail(state, afterSaleNumber)) { - event.__aksrtAfterSaleCancelHandled = true; - event.preventDefault(); - afterSaleCancel.disabled = true; - request(orderPath(afterSaleNumber, "/after-sale"), undefined, "DELETE", window.AksrtRequest.createIdempotencyKey()).then(function () { - notyf("售后申请已取消", "success"); - invalidateOrder(afterSaleNumber); - openDetail(state, afterSaleNumber); - refreshView(state); - }).catch(function (error) { - afterSaleCancel.disabled = false; - notyf(errorMessage(error, "取消申请失败"), "danger"); - }); - return; - } - } - if (!state.detailSession || window.AksrtModalRuntime.getActive() !== state.detailSession.shell) return; - var copy = closest(event.target, "[data-aksrt-order-copy]"); - if (copy) { - event.preventDefault(); - copyOrderValue(copy); - return; - } - var refresh = closest(event.target, "[data-aksrt-order-refresh]"); - if (refresh) { - event.preventDefault(); - refreshDetail(state, refresh.getAttribute("data-aksrt-order-refresh") || ""); - return; - } - var pay = closest(event.target, "[data-aksrt-order-pay]"); - if (pay && !root.contains(pay)) { - event.preventDefault(); - startPayment(state, pay); - return; - } - var cancel = closest(event.target, "[data-aksrt-order-cancel]"); - if (cancel && !root.contains(cancel)) { - event.preventDefault(); - closeOrder(state, cancel); - } - }; - - root.addEventListener("click", state.onRootClick); - root.addEventListener("submit", state.onRootSubmit); - document.addEventListener("aksrt:modal:close", state.onModalClose); - document.addEventListener("click", state.onDocumentClick); - state.countdownTimer = window.setInterval(function () { updateCountdowns(state); }, 1000); - instances.set(root, state); - liveStates.push(state); - } - - function rootsIn(root) { - if (!root) return []; - var roots = []; - if (root.matches && root.matches("[data-aksrt-order-center]")) roots.push(root); - if (root.querySelectorAll) root.querySelectorAll("[data-aksrt-order-center]").forEach(function (item) { roots.push(item); }); - return roots; - } - - function init(root) { - rootsIn(root || document).forEach(initRoot); - } - - function destroy(root) { - rootsIn(root).forEach(function (item) { - var state = instances.get(item); - if (!state) return; - if (activeDetail(state, state.detailOrderNumber)) window.AksrtModalRuntime.close("replace"); - item.removeEventListener("click", state.onRootClick); - item.removeEventListener("submit", state.onRootSubmit); - document.removeEventListener("aksrt:modal:close", state.onModalClose); - document.removeEventListener("click", state.onDocumentClick); - window.clearInterval(state.countdownTimer); - instances.delete(item); - liveStates = liveStates.filter(function (entry) { return entry !== state; }); - }); - } - - // refresh 供售后弹窗（order-after-sale.js）提交/取消后刷新列表与统计。 - function refresh(orderNumber) { - invalidateOrder(orderNumber); - liveStates.forEach(function (state) { - refreshView(state); - }); - } - - window.AKSRTOrderCenter = { init: init, destroy: destroy, refresh: refresh }; - jQuery(document).off("auto_fun.aksrt-order-center").on("auto_fun.aksrt-order-center", function () { init(document); }); -}()); +/** + * Knowledge-payment order center interactions. + * + * @package AKSRT + */ +(function () { + "use strict"; + + var instances = new WeakMap(); + var liveStates = []; + + function request(path, body, method, operationKey) { + var options = { method: method || "POST" }; + if (body !== undefined) options.body = JSON.stringify(body || {}); + if (operationKey) options.headers = { "Idempotency-Key": operationKey }; + return window.AksrtRequest.request(path, options); + } + + function orderPath(orderNumber, suffix) { + return "/orders/" + encodeURIComponent(orderNumber || "") + (suffix || ""); + } + + function errorMessage(error, fallback) { + if (error && error.message) return String(error.message); + return fallback || "请求失败"; + } + + function escapeHtml(value) { + return String(value == null ? "" : value) + .replace(/&/g, "&").replace(//g, ">").replace(/\"/g, """) + .replace(/'/g, "'"); + } + + function formatMoney(order) { + var raw = String(order && order.amount != null ? order.amount : "0"); + if (order && order.is_points) { + return escapeHtml(order.currency_symbol || "积分") + " " + (/^\d+$/.test(raw) ? raw : "0"); + } + var match = /^(0|[1-9]\d*)(?:\.(\d{1,2}))?$/.exec(raw); + var amount = match ? match[1] + "." + (match[2] || "").padEnd(2, "0") : "0.00"; + return "¥" + amount; + } + + function orderTag(orderNumber) { + return "order:" + String(orderNumber || "").toLowerCase(); + } + + function invalidateOrder(orderNumber, order) { + var tags = order && Array.isArray(order.invalidation_tags) ? order.invalidation_tags : [ + "orders", + orderTag(orderNumber), + ]; + window.AksrtModalRuntime.invalidate(tags); + } + + function activeDetail(state, number) { + return state.detailOrderNumber === number + && !!state.detailSession + && !state.detailSession.closed + && state.detailSession.options + && state.detailSession.options.kind === "orders" + && window.AksrtModalRuntime.getActive() === state.detailSession.shell; + } + + function detailSkeleton() { + return '' + escapeHtml(meta.desc) + "
"; + if (status === "pending" && timeLeft > 0) { + html += '剩余支付时间 ' + timeLeft + " 秒"; + } + html += "原因：' + escapeHtml(reasonLabel) + "
"; + if (applyDesc !== "") html += '申请理由：' + escapeHtml(applyDesc).replace(/\r\n|\r|\n/g, "
") + "
' + escapeHtml(item.reason).replace(/\r\n|\r|\n/g, "
") + "
支付状态可能仍在同步，请刷新后查看。
"; + html += ''; + html += "订单不存在
'; + return; + } + renderDetail(state, data, session); + }, + onData: function (data) { + if (refresh) { + delete state.operationKeys[actionKey]; + invalidateOrder(orderNumber, data); + } + }, + }; + } + + function openDetail(state, orderNumber) { + if (!orderNumber) return; + state.detailSession = null; + state.detailReplacement = false; + state.detailReplacementSession = null; + state.detailOrderNumber = orderNumber; + window.AksrtModalRuntime.openRemote(detailOptions(state, orderNumber, false)); + } + + function refreshDetail(state, orderNumber) { + if (!orderNumber || !activeDetail(state, orderNumber)) return; + state.detailReplacement = true; + state.detailReplacementSession = state.detailSession; + var refreshPromise = window.AksrtModalRuntime.openRemote(detailOptions(state, orderNumber, true)); + refreshPromise.then(function () { + state.detailReplacement = false; + state.detailReplacementSession = null; + }, function () { + state.detailReplacement = false; + state.detailReplacementSession = null; + }); + } + + function currentViewPath(state) { + var query = new URLSearchParams(); + if (state.query.status && state.query.status !== "all") query.set("order_status", state.query.status); + if (state.query.type) query.set("order_type", state.query.type); + if (state.query.orderNumber) query.set("order_number", state.query.orderNumber); + if (Number(state.query.page) > 1) query.set("order_page", String(state.query.page)); + return "/orders/view" + (query.toString() ? "?" + query.toString() : ""); + } + + function actionHtml(order) { + var allowedActions = order.allowed_actions || {}; + var afterSale = order.after_sale || {}; + var html = ''; + if (allowedActions.can_cancel) html += ''; + if (allowedActions.can_pay) html += ''; + // 售后入口：申请售后 / 售后详细走 order-after-sale.js 的独立弹窗。 + if (afterSale.enabled) html += afterSaleButtons(order); + return html; + } + + // 售后按钮（列表卡片与订单详情弹窗共用）：已申请 → 售后详细，否则 → 申请售后。 + // 载荷与 PHP 模板同构（order-after-sale.js 同步消费），点击即弹窗、无前置请求。 + function afterSalePayload(order) { + var afterSale = order.after_sale || {}; + return escapeHtml(JSON.stringify({ + order_number: order.order_number || "", + product_name: order.product_name || "", + amount: order.amount || "0", + is_points: !!order.is_points, + currency_symbol: order.currency_symbol || "", + status_label: order.status_label || "", + after_sale: afterSale, + })); + } + + function afterSaleButtons(order) { + var afterSale = order.after_sale || {}; + var html = ""; + if (!afterSale.enabled) return html; + var payload = afterSalePayload(order); + if (afterSale.has_application) { + html += ''; + return html; + } + html += ''; + return html; + } + + function cardHtml(order) { + var image = order.image + ? '订单号 " + escapeHtml(order.order_number) + "
换个条件试试，或清除当前筛选。
'; + list.classList.remove("aksrt-orders-page__list"); + list.classList.add("aksrt-orders-page__empty"); + } else { + list.classList.remove("aksrt-orders-page__empty"); + list.classList.add("aksrt-orders-page__list"); + list.innerHTML = items.map(cardHtml).join(""); + } + renderPagination(state, view); + syncControls(state); + updateCountdowns(state); + } + + function syncControls(state) { + state.root.querySelectorAll("[data-aksrt-order-filter]").forEach(function (button) { + var field = button.getAttribute("data-aksrt-order-filter"); + var expected = field === "status" ? state.query.status : state.query.type; + var active = button.getAttribute("data-aksrt-order-filter-value") === expected; + button.classList.toggle("is-active", active); + button.setAttribute("aria-pressed", active ? "true" : "false"); + }); + var input = state.root.querySelector("#aksrt-order-number"); + if (input && input.value !== state.query.orderNumber) input.value = state.query.orderNumber; + } + + function setViewLoading(state, loading) { + state.root.classList.toggle("is-loading", loading); + state.root.setAttribute("aria-busy", loading ? "true" : "false"); + } + + function loadView(state, patch) { + Object.keys(patch || {}).forEach(function (key) { state.query[key] = patch[key]; }); + var requestId = ++state.viewRequest; + setViewLoading(state, true); + return request(currentViewPath(state), undefined, "GET").then(function (result) { + if (requestId !== state.viewRequest) return null; + if (!result || !result.data) throw new Error("刷新失败"); + renderView(state, result.data); + return result.data; + }).catch(function (error) { + if (requestId === state.viewRequest) notyf(errorMessage(error, "订单加载失败，请稍后重试"), "danger"); + return null; + }).finally(function () { + if (requestId === state.viewRequest) setViewLoading(state, false); + }); + } + + function refreshView(state) { + return loadView(state); + } + + function startPayment(state, button) { + var number = button.getAttribute("data-aksrt-order-pay") || ""; + var method = button.getAttribute("data-aksrt-order-method") || ""; + if (!number || button.disabled) return; + var actionKey = "pay:" + number; + if (!state.operationKeys[actionKey]) state.operationKeys[actionKey] = window.AksrtRequest.createIdempotencyKey(); + button.disabled = true; + request(orderPath(number, "/pay"), method ? { payment_method: method } : {}, "POST", state.operationKeys[actionKey]).then(function (result) { + delete state.operationKeys[actionKey]; + var data = result.data || {}; + invalidateOrder(number, data.order); + if (data.redirect && data.payment_url) { + window.location.assign(data.payment_url); + return; + } + notyf(data.message || "支付成功", "success"); + refreshView(state); + if (activeDetail(state, number)) openDetail(state, number); + }).catch(function (error) { + button.disabled = false; + notyf(errorMessage(error, "网络错误，请稍后重试"), "danger"); + }); + } + + function closeOrder(state, button) { + var number = button.getAttribute("data-aksrt-order-cancel") || ""; + if (!number || button.disabled) return; + if (button.getAttribute("data-aksrt-confirm") !== "true") { + button.setAttribute("data-aksrt-confirm", "true"); + button.textContent = "确认关闭"; + return; + } + button.disabled = true; + var actionKey = "cancel:" + number; + if (!state.operationKeys[actionKey]) state.operationKeys[actionKey] = window.AksrtRequest.createIdempotencyKey(); + request(orderPath(number, "/cancel"), {}, "POST", state.operationKeys[actionKey]).then(function (result) { + delete state.operationKeys[actionKey]; + var data = result.data || {}; + invalidateOrder(number, data.order); + notyf("订单已关闭", "success"); + refreshView(state); + if (activeDetail(state, number)) openDetail(state, number); + }).catch(function (error) { + button.disabled = false; + button.removeAttribute("data-aksrt-confirm"); + button.textContent = "关闭订单"; + notyf(errorMessage(error, "网络错误，请稍后重试"), "danger"); + }); + } + + function copyOrderValue(button) { + var value = button.getAttribute("data-aksrt-order-copy") || ""; + if (!value) return; + var icon = button.querySelector("i"); + var settle = function (ok) { + notyf(ok ? "订单号已复制" : "复制失败，请手动选择复制", ok ? "success" : "danger"); + if (!ok) return; + button.classList.add("is-copied"); + if (icon) icon.className = "fa fas fa-check"; + window.setTimeout(function () { + button.classList.remove("is-copied"); + if (icon) icon.className = "fa fas fa-copy"; + }, 1600); + }; + var fallback = function () { + try { + var field = document.createElement("textarea"); + field.value = value; + field.setAttribute("readonly", "readonly"); + field.style.position = "fixed"; + field.style.top = "-1000px"; + field.style.opacity = "0"; + document.body.appendChild(field); + field.select(); + document.execCommand("copy"); + document.body.removeChild(field); + settle(true); + } catch (error) { + settle(false); + } + }; + if (navigator.clipboard && navigator.clipboard.writeText) { + navigator.clipboard.writeText(value).then(function () { settle(true); }, fallback); + return; + } + fallback(); + } + + function closest(target, selector) { + return target && target.closest ? target.closest(selector) : null; + } + + function initRoot(root) { + if (instances.has(root)) return; + var state = { + root: root, + detailOrderNumber: "", + detailSession: null, + detailReplacement: false, + detailReplacementSession: null, + countdownTimer: null, + operationKeys: {}, + query: { status: "all", type: "", orderNumber: "", page: 1 }, + viewRequest: 0, + }; + + state.onRootClick = function (event) { + var filterToggle = closest(event.target, "[data-aksrt-orders-filter-toggle]"); + if (filterToggle && root.contains(filterToggle)) { + var panel = root.querySelector("[data-aksrt-orders-filter-panel]"); + var expanded = filterToggle.getAttribute("aria-expanded") === "true"; + filterToggle.setAttribute("aria-expanded", String(!expanded)); + if (panel) panel.hidden = expanded; + return; + } + var filter = closest(event.target, "[data-aksrt-order-filter]"); + if (filter && root.contains(filter)) { + event.preventDefault(); + var field = filter.getAttribute("data-aksrt-order-filter"); + var patch = { page: 1 }; + patch[field] = filter.getAttribute("data-aksrt-order-filter-value") || ""; + loadView(state, patch); + return; + } + var page = closest(event.target, "[data-aksrt-order-page]"); + if (page && root.contains(page)) { + event.preventDefault(); + loadView(state, { page: Math.max(1, Number(page.getAttribute("data-aksrt-order-page") || 1)) }); + return; + } + var clear = closest(event.target, "[data-aksrt-orders-clear]"); + if (clear && root.contains(clear)) { + event.preventDefault(); + loadView(state, { status: "all", type: "", orderNumber: "", page: 1 }); + return; + } + var detail = closest(event.target, "[data-aksrt-order-detail]"); + if (detail && root.contains(detail)) { openDetail(state, detail.getAttribute("data-aksrt-order-detail")); return; } + var pay = closest(event.target, "[data-aksrt-order-pay]"); + if (pay && root.contains(pay)) { event.preventDefault(); startPayment(state, pay); return; } + var cancel = closest(event.target, "[data-aksrt-order-cancel]"); + if (cancel && root.contains(cancel)) { event.preventDefault(); closeOrder(state, cancel); } + }; + state.onRootSubmit = function (event) { + var form = closest(event.target, "[data-aksrt-orders-search]"); + if (!form || !root.contains(form)) return; + event.preventDefault(); + var input = form.querySelector("#aksrt-order-number"); + loadView(state, { orderNumber: input ? String(input.value || "").trim() : "", page: 1 }); + }; + state.onModalClose = function (event) { + var detail = event && event.detail ? event.detail : {}; + if (!state.detailSession || detail.session !== state.detailSession) return; + if (detail.reason === "replace" && state.detailReplacement && detail.session === state.detailReplacementSession) return; + state.detailSession = null; + state.detailOrderNumber = ""; + state.detailReplacement = false; + state.detailReplacementSession = null; + }; + state.onDocumentClick = function (event) { + var afterSaleCancel = closest(event.target, "[data-aksrt-after-sale-cancel]"); + if (afterSaleCancel && !event.__aksrtAfterSaleCancelHandled) { + var afterSaleNumber = afterSaleCancel.getAttribute("data-aksrt-after-sale-cancel") || ""; + if (activeDetail(state, afterSaleNumber)) { + event.__aksrtAfterSaleCancelHandled = true; + event.preventDefault(); + afterSaleCancel.disabled = true; + request(orderPath(afterSaleNumber, "/after-sale"), undefined, "DELETE", window.AksrtRequest.createIdempotencyKey()).then(function () { + notyf("售后申请已取消", "success"); + invalidateOrder(afterSaleNumber); + openDetail(state, afterSaleNumber); + refreshView(state); + }).catch(function (error) { + afterSaleCancel.disabled = false; + notyf(errorMessage(error, "取消申请失败"), "danger"); + }); + return; + } + } + if (!state.detailSession || window.AksrtModalRuntime.getActive() !== state.detailSession.shell) return; + var copy = closest(event.target, "[data-aksrt-order-copy]"); + if (copy) { + event.preventDefault(); + copyOrderValue(copy); + return; + } + var refresh = closest(event.target, "[data-aksrt-order-refresh]"); + if (refresh) { + event.preventDefault(); + refreshDetail(state, refresh.getAttribute("data-aksrt-order-refresh") || ""); + return; + } + var pay = closest(event.target, "[data-aksrt-order-pay]"); + if (pay && !root.contains(pay)) { + event.preventDefault(); + startPayment(state, pay); + return; + } + var cancel = closest(event.target, "[data-aksrt-order-cancel]"); + if (cancel && !root.contains(cancel)) { + event.preventDefault(); + closeOrder(state, cancel); + } + }; + + root.addEventListener("click", state.onRootClick); + root.addEventListener("submit", state.onRootSubmit); + document.addEventListener("aksrt:modal:close", state.onModalClose); + document.addEventListener("click", state.onDocumentClick); + state.countdownTimer = window.setInterval(function () { updateCountdowns(state); }, 1000); + instances.set(root, state); + liveStates.push(state); + } + + function rootsIn(root) { + if (!root) return []; + var roots = []; + if (root.matches && root.matches("[data-aksrt-order-center]")) roots.push(root); + if (root.querySelectorAll) root.querySelectorAll("[data-aksrt-order-center]").forEach(function (item) { roots.push(item); }); + return roots; + } + + function init(root) { + rootsIn(root || document).forEach(initRoot); + } + + function destroy(root) { + rootsIn(root).forEach(function (item) { + var state = instances.get(item); + if (!state) return; + if (activeDetail(state, state.detailOrderNumber)) window.AksrtModalRuntime.close("replace"); + item.removeEventListener("click", state.onRootClick); + item.removeEventListener("submit", state.onRootSubmit); + document.removeEventListener("aksrt:modal:close", state.onModalClose); + document.removeEventListener("click", state.onDocumentClick); + window.clearInterval(state.countdownTimer); + instances.delete(item); + liveStates = liveStates.filter(function (entry) { return entry !== state; }); + }); + } + + // refresh 供售后弹窗（order-after-sale.js）提交/取消后刷新列表与统计。 + function refresh(orderNumber) { + invalidateOrder(orderNumber); + liveStates.forEach(function (state) { + refreshView(state); + }); + } + + window.AKSRTOrderCenter = { init: init, destroy: destroy, refresh: refresh }; + jQuery(document).off("auto_fun.aksrt-order-center").on("auto_fun.aksrt-order-center", function () { init(document); }); +}()); diff --git a/src/Core/DBMigrator.php b/src/Core/DBMigrator.php index d36ded0d..e6e1acf0 100644 --- a/src/Core/DBMigrator.php +++ b/src/Core/DBMigrator.php @@ -1,44 +1,44 @@ -get_charset_collate(); - $prefix = $wpdb->prefix; - - // ---------- 1. 统一资产账户与不可变账本 ---------- - $sql_asset_account = "CREATE TABLE {$prefix}aksrt_asset_account ( - user_id BIGINT UNSIGNED NOT NULL, - asset VARCHAR(16) NOT NULL, - balance_minor BIGINT UNSIGNED NOT NULL DEFAULT 0, - version BIGINT UNSIGNED NOT NULL DEFAULT 0, - updated_at DATETIME(6) NOT NULL, - PRIMARY KEY (user_id, asset), - KEY idx_asset_balance (asset, balance_minor) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_asset_account); - - $sql_asset_transaction = "CREATE TABLE {$prefix}aksrt_asset_transaction ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - operation_key VARCHAR(191) NOT NULL, - payload_hash CHAR(64) NOT NULL, - reason VARCHAR(64) NOT NULL, - ref_type VARCHAR(32) DEFAULT NULL, - ref_key VARCHAR(191) DEFAULT NULL, - actor_user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - metadata LONGTEXT DEFAULT NULL, - ip VARCHAR(64) DEFAULT NULL, - ua VARCHAR(255) DEFAULT NULL, - created_at DATETIME(6) NOT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_operation_key (operation_key), - KEY idx_reason_time (reason, created_at), - KEY idx_reference (ref_type, ref_key) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_asset_transaction); - - $sql_asset_entry = "CREATE TABLE {$prefix}aksrt_asset_entry ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - transaction_id BIGINT UNSIGNED NOT NULL, - line_no SMALLINT UNSIGNED NOT NULL, - user_id BIGINT UNSIGNED NOT NULL, - asset VARCHAR(16) NOT NULL, - entry_type VARCHAR(32) NOT NULL, - delta_minor BIGINT NOT NULL, - balance_after_minor BIGINT UNSIGNED NOT NULL, - counterparty_user_id BIGINT UNSIGNED DEFAULT NULL, - remark VARCHAR(255) DEFAULT NULL, - created_at DATETIME(6) NOT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_transaction_line (transaction_id, line_no), - KEY idx_user_asset_time (user_id, asset, created_at, id), - KEY idx_transaction (transaction_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_asset_entry); - - // 后台「资金流水」页的默认查询是 WHERE 1=1 ORDER BY created_at DESC, id DESC LIMIT n - // 外加同条件的 COUNT(*)，且界面上的日期区间筛选也只有 created_at 可用。 - // 索引必须能以 created_at 为前导列，否则每次翻页都是全表扫描 + filesort， - // 而 idx_flow_event_time 的前导列是 event_type（筛选时可空），救不了这两条查询。 - $sql_financial_flow = "CREATE TABLE {$prefix}aksrt_financial_flow ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - flow_number VARCHAR(32) NOT NULL, - operation_key VARCHAR(191) NOT NULL, - event_type VARCHAR(64) NOT NULL, - ref_type VARCHAR(32) DEFAULT NULL, - ref_key VARCHAR(191) DEFAULT NULL, - order_number VARCHAR(32) DEFAULT NULL, - withdrawal_number VARCHAR(32) DEFAULT NULL, - ledger_transaction_id BIGINT UNSIGNED DEFAULT NULL, - provider_transaction_id VARCHAR(128) DEFAULT NULL, - metadata LONGTEXT DEFAULT NULL, - created_at DATETIME(6) NOT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_flow_number (flow_number), - UNIQUE KEY uniq_flow_operation (operation_key), - UNIQUE KEY uniq_flow_ledger_transaction (ledger_transaction_id), - KEY idx_flow_created (created_at), - KEY idx_flow_event_time (event_type, created_at), - KEY idx_flow_order (order_number), - KEY idx_flow_withdrawal (withdrawal_number), - KEY idx_flow_reference (ref_type, ref_key), - KEY idx_flow_provider_transaction (provider_transaction_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_financial_flow); - - $sql_financial_flow_entry = "CREATE TABLE {$prefix}aksrt_financial_flow_entry ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - flow_id BIGINT UNSIGNED NOT NULL, - line_no SMALLINT UNSIGNED NOT NULL, - user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - asset VARCHAR(16) NOT NULL, - direction VARCHAR(8) NOT NULL, - entry_type VARCHAR(32) NOT NULL, - delta_minor BIGINT NOT NULL, - balance_after_minor BIGINT UNSIGNED DEFAULT NULL, - counterparty_user_id BIGINT UNSIGNED DEFAULT NULL, - remark VARCHAR(255) DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_flow_line (flow_id, line_no), - KEY idx_flow_entry_user (user_id, flow_id), - KEY idx_flow_entry_asset (asset, flow_id), - KEY idx_flow_entry_direction (direction, flow_id), - KEY idx_flow_entry_counterparty (counterparty_user_id, flow_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_financial_flow_entry); - - // ---------- 2. 签到 ---------- - $sql_signin = "CREATE TABLE {$prefix}aksrt_signin_log ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - user_id BIGINT UNSIGNED NOT NULL, - signin_date DATE NOT NULL, - streak INT NOT NULL DEFAULT 1, - reward INT NOT NULL DEFAULT 0, - PRIMARY KEY (id), - UNIQUE KEY uniq_user_date (user_id, signin_date), - KEY idx_user (user_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_signin); - - // ---------- 3. 下载 token ---------- - $sql_dl_token = "CREATE TABLE {$prefix}aksrt_dl_token ( - token CHAR(48) NOT NULL, - user_id BIGINT UNSIGNED NOT NULL, - post_id BIGINT UNSIGNED NOT NULL, - source_index INT NOT NULL DEFAULT 0, - cost INT NOT NULL DEFAULT 0, - ip_bind VARCHAR(64) DEFAULT NULL, - ua_hash CHAR(40) DEFAULT NULL, - used_count INT NOT NULL DEFAULT 0, - max_uses INT NOT NULL DEFAULT 1, - expires_at DATETIME NOT NULL, - created_at DATETIME NOT NULL, - PRIMARY KEY (token), - KEY idx_expires (expires_at), - KEY idx_user (user_id), - KEY idx_post (post_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_dl_token); - - // ---------- 5. 用户通知收件箱 ---------- - $sql_notification = "CREATE TABLE {$prefix}aksrt_notification ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - user_id BIGINT UNSIGNED NOT NULL, - type VARCHAR(32) NOT NULL, - title VARCHAR(191) NOT NULL, - description TEXT DEFAULT NULL, - target_url TEXT DEFAULT NULL, - is_read TINYINT(1) NOT NULL DEFAULT 0, - created_at DATETIME NOT NULL, - read_at DATETIME DEFAULT NULL, - PRIMARY KEY (id), - KEY idx_user_created (user_id, created_at), - KEY idx_user_read (user_id, is_read) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_notification); - - // ---------- 8. 订单表 ---------- - $sql_order = "CREATE TABLE {$prefix}aksrt_order ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - order_number VARCHAR(32) NOT NULL, - request_key VARCHAR(191) DEFAULT NULL, - user_id BIGINT UNSIGNED NOT NULL, - product_type VARCHAR(32) NOT NULL DEFAULT '', - product_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - amount DECIMAL(10,2) NOT NULL DEFAULT 0, - currency VARCHAR(8) NOT NULL DEFAULT 'CNY', - status VARCHAR(20) NOT NULL DEFAULT 'pending', - shipping_status TINYINT NOT NULL DEFAULT 0, - payment_method VARCHAR(32) NOT NULL DEFAULT '', - payment_transaction_id VARCHAR(128) NOT NULL DEFAULT '', - created_at DATETIME NOT NULL, - paid_at DATETIME DEFAULT NULL, - delivered_at DATETIME DEFAULT NULL, - completed_at DATETIME DEFAULT NULL, - cancelled_at DATETIME DEFAULT NULL, - refunded_at DATETIME DEFAULT NULL, - expires_at DATETIME DEFAULT NULL, - note TEXT DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_order_number (order_number), - UNIQUE KEY uniq_request_key (request_key), - KEY idx_user (user_id), - KEY idx_user_status_created (user_id, status, created_at), - KEY idx_status (status), - KEY idx_created (created_at), - KEY idx_product (product_type, product_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_order); - - // ---------- order after-sales ---------- - $sql_order_aftersale = "CREATE TABLE {$prefix}aksrt_order_aftersale ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - order_number VARCHAR(32) NOT NULL, - user_id BIGINT UNSIGNED NOT NULL, - aftersale_type VARCHAR(24) NOT NULL DEFAULT 'refund', - reason TEXT NOT NULL, - apply_form LONGTEXT DEFAULT NULL, - images LONGTEXT DEFAULT NULL, - refund_amount VARCHAR(32) NOT NULL DEFAULT '0', - status VARCHAR(20) NOT NULL DEFAULT 'pending', - admin_note TEXT DEFAULT NULL, - gateway_request_id VARCHAR(128) DEFAULT NULL, - gateway_refund_id VARCHAR(128) DEFAULT NULL, - gateway_result LONGTEXT DEFAULT NULL, - created_at DATETIME NOT NULL, - reviewed_at DATETIME DEFAULT NULL, - completed_at DATETIME DEFAULT NULL, - PRIMARY KEY (id), - KEY idx_order_status (order_number, status), - KEY idx_user_created (user_id, created_at), - KEY idx_status_created (status, created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_order_aftersale); - - // ---------- 9. 作者收益台账 ---------- - $sql_revenue = "CREATE TABLE {$prefix}aksrt_revenue ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - author_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - order_number VARCHAR(32) NOT NULL DEFAULT '', - post_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - buyer_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - currency VARCHAR(8) NOT NULL DEFAULT 'CNY', - original_amount DECIMAL(18,2) NOT NULL DEFAULT 0, - share_ratio DECIMAL(5,2) NOT NULL DEFAULT 0, - author_level TINYINT UNSIGNED NOT NULL DEFAULT 0, - amount DECIMAL(18,2) NOT NULL DEFAULT 0, - type VARCHAR(32) NOT NULL DEFAULT 'order', - status VARCHAR(20) NOT NULL DEFAULT 'pending', - reversal_amount DECIMAL(18,2) NOT NULL DEFAULT 0, - error_message TEXT DEFAULT NULL, - audit_json LONGTEXT DEFAULT NULL, - created_at DATETIME NOT NULL, - settled_at DATETIME DEFAULT NULL, - reversed_at DATETIME DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_creator_order (author_id, order_number), - KEY idx_author (author_id), - KEY idx_order (order_number), - KEY idx_post (post_id), - KEY idx_buyer (buyer_id), - KEY idx_currency (currency), - KEY idx_status (status), - KEY idx_created (created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_revenue); - - // ---------- 10. 提现台账 ---------- - $sql_withdrawal = "CREATE TABLE {$prefix}aksrt_withdrawal ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - withdrawal_number VARCHAR(32) NOT NULL, - user_id BIGINT UNSIGNED NOT NULL, - amount DECIMAL(10,2) NOT NULL DEFAULT 0, - gross_amount DECIMAL(10,2) NOT NULL DEFAULT 0, - method VARCHAR(32) NOT NULL DEFAULT '', - account_info TEXT DEFAULT NULL, - status VARCHAR(20) NOT NULL DEFAULT 'pending', - operation_key VARCHAR(191) DEFAULT NULL, - ledger_transaction_id BIGINT UNSIGNED DEFAULT NULL, - created_at DATETIME NOT NULL, - processed_at DATETIME DEFAULT NULL, - note TEXT DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_withdrawal_number (withdrawal_number), - UNIQUE KEY uniq_withdrawal_operation (operation_key), - UNIQUE KEY uniq_ledger_transaction (ledger_transaction_id), - KEY idx_user (user_id), - KEY idx_user_created (user_id, created_at), - KEY idx_status (status), - KEY idx_created (created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_withdrawal); - - // ---------- 11. 举报工单 ---------- - $sql_report = "CREATE TABLE {$prefix}aksrt_report ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - reporter_id BIGINT UNSIGNED NOT NULL, - target_type VARCHAR(20) NOT NULL, - target_id BIGINT UNSIGNED NOT NULL, - reason TEXT NOT NULL, - category VARCHAR(40) NOT NULL DEFAULT '', - status VARCHAR(20) NOT NULL DEFAULT 'pending', - created_at DATETIME NOT NULL, - updated_at DATETIME DEFAULT NULL, - notes_json TEXT DEFAULT NULL, - PRIMARY KEY (id), - KEY idx_status (status), - KEY idx_target (target_type, target_id), - KEY idx_reporter (reporter_id), - KEY idx_created (created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_report); - - // ---------- 12. 用户限制/封禁 ---------- - $sql_restriction = "CREATE TABLE {$prefix}aksrt_user_restriction ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - user_id BIGINT UNSIGNED NOT NULL, - type VARCHAR(20) NOT NULL DEFAULT 'warn', - reason TEXT NOT NULL, - scope VARCHAR(20) NOT NULL DEFAULT 'global', - expires_at DATETIME DEFAULT NULL, - created_by BIGINT UNSIGNED NOT NULL DEFAULT 0, - created_at DATETIME NOT NULL, - PRIMARY KEY (id), - KEY idx_user (user_id), - KEY idx_type (type), - KEY idx_scope (scope), - KEY idx_expires (expires_at), - KEY idx_created (created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_restriction); - - // ── follow ── - $sql_follow = "CREATE TABLE {$prefix}aksrt_follow ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - follower_id BIGINT UNSIGNED NOT NULL, - following_id BIGINT UNSIGNED NOT NULL, - created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (id), - UNIQUE KEY idx_pair (follower_id, following_id), - KEY idx_following (following_id), - KEY idx_created (created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_follow); - - // ── coupon ── - $sql_coupon = "CREATE TABLE {$prefix}aksrt_coupon ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - code VARCHAR(60) NOT NULL DEFAULT '', - type VARCHAR(20) NOT NULL DEFAULT 'fixed', - value DECIMAL(10,2) NOT NULL DEFAULT 0, - min_amount DECIMAL(10,2) NOT NULL DEFAULT 0, - usage_limit INT UNSIGNED NOT NULL DEFAULT 0, - used_count INT UNSIGNED NOT NULL DEFAULT 0, - expires_at DATETIME DEFAULT NULL, - per_user_limit INT UNSIGNED NOT NULL DEFAULT 0, - product_scope TEXT DEFAULT NULL, - max_discount DECIMAL(10,2) NOT NULL DEFAULT 0, - status VARCHAR(20) NOT NULL DEFAULT 'active', - created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (id), - UNIQUE KEY idx_code (code), - KEY idx_status (status), - KEY idx_expires (expires_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_coupon); - - // ── coupon_usage (R68) ── - $sql_coupon_usage = "CREATE TABLE {$prefix}aksrt_coupon_usage ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - coupon_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - order_number VARCHAR(32) NOT NULL DEFAULT '', - discount DECIMAL(10,2) NOT NULL DEFAULT 0, - created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', - PRIMARY KEY (id), - KEY idx_coupon (coupon_id), - KEY idx_user (user_id), - UNIQUE KEY uniq_coupon_usage_order (order_number) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_coupon_usage); - - // ── typed charge cards ── - $sql_charge_card = "CREATE TABLE {$prefix}aksrt_charge_card ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - card VARCHAR(60) NOT NULL DEFAULT '', - password VARCHAR(80) NOT NULL DEFAULT '', - type VARCHAR(20) NOT NULL DEFAULT 'balance', - amount DECIMAL(10,2) NOT NULL DEFAULT 0, - balance DECIMAL(10,2) NOT NULL DEFAULT 0, - status VARCHAR(20) NOT NULL DEFAULT 'active', - meta LONGTEXT DEFAULT NULL, - order_number VARCHAR(32) NOT NULL DEFAULT '', - used_by BIGINT UNSIGNED DEFAULT NULL, - used_at DATETIME DEFAULT NULL, - expires_at DATETIME DEFAULT NULL, - created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', - note TEXT DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY idx_password (password), - KEY idx_card (card), - KEY idx_type (type), - KEY idx_status (status), - KEY idx_used_by (used_by), - KEY idx_order_number (order_number), - KEY idx_expires (expires_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_charge_card); - - // ── one-time invite codes (registration gate + per-batch rewards) ── - $sql_invite_code = "CREATE TABLE {$prefix}aksrt_invite_code ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - code VARCHAR(32) NOT NULL, - batch_id VARCHAR(32) NOT NULL DEFAULT '', - remark VARCHAR(191) NOT NULL DEFAULT '', - rewards TEXT DEFAULT NULL, - max_uses INT UNSIGNED NOT NULL DEFAULT 1, - used_count INT UNSIGNED NOT NULL DEFAULT 0, - status VARCHAR(20) NOT NULL DEFAULT 'active', - expires_at DATETIME DEFAULT NULL, - created_by BIGINT UNSIGNED NOT NULL DEFAULT 0, - created_at DATETIME NOT NULL, - updated_at DATETIME NOT NULL DEFAULT '1970-01-01 00:00:00', - PRIMARY KEY (id), - UNIQUE KEY uniq_invite_code (code), - KEY idx_batch (batch_id), - KEY idx_status (status), - KEY idx_expires (expires_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_invite_code); - - // ── invite-code usage log (who consumed which code) ── - $sql_invite_code_usage = "CREATE TABLE {$prefix}aksrt_invite_code_usage ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - code_id BIGINT UNSIGNED NOT NULL, - user_id BIGINT UNSIGNED NOT NULL, - used_at DATETIME NOT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_invite_usage (code_id, user_id), - KEY idx_usage_user (user_id), - KEY idx_usage_code (code_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_invite_code_usage); - - // ── canonical Ref attribution and permanent user binding ── - $sql_affiliate_relation = "CREATE TABLE {$prefix}aksrt_affiliate_relation ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - referral_code VARCHAR(32) NOT NULL, - promoter_id BIGINT UNSIGNED NOT NULL, - invitee_id BIGINT UNSIGNED DEFAULT NULL, - first_touch_at DATETIME NOT NULL, - bound_at DATETIME DEFAULT NULL, - status VARCHAR(20) NOT NULL DEFAULT 'captured', - reward_status VARCHAR(20) NOT NULL DEFAULT 'skipped', - rewarded_at DATETIME DEFAULT NULL, - registration_ip VARCHAR(64) DEFAULT NULL, - created_at DATETIME NOT NULL, - PRIMARY KEY (id), - KEY idx_referral_code (referral_code), - UNIQUE KEY uniq_invitee (invitee_id), - KEY idx_promoter (promoter_id), - KEY idx_status_touch (status, first_touch_at), - KEY idx_reward_status (reward_status), - KEY idx_reward_ip (registration_ip, rewarded_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_affiliate_relation); - - // ── immutable commission ledger ── - // 佣金即时入账（无冻结/结算期）：下单支付即 credit 到 COMMISSION 资金池， - // 本表仅作佣金明细账 + 退款冲正的溯源记录。status: credited | cancelled。 - $sql_commission_ledger = "CREATE TABLE {$prefix}aksrt_commission_ledger ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - promoter_id BIGINT UNSIGNED NOT NULL, - source_user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - order_number VARCHAR(64) NOT NULL, - order_type VARCHAR(32) NOT NULL, - eligible_base DECIMAL(18,2) NOT NULL DEFAULT 0, - ratio DECIMAL(8,4) NOT NULL DEFAULT 0, - original_amount DECIMAL(18,2) NOT NULL DEFAULT 0, - adjustment_total DECIMAL(18,2) NOT NULL DEFAULT 0, - status VARCHAR(20) NOT NULL DEFAULT 'credited', - idempotency_key VARCHAR(128) NOT NULL, - cancel_operation_key VARCHAR(191) DEFAULT NULL, - cancel_payload_hash CHAR(64) DEFAULT NULL, - created_at DATETIME NOT NULL, - note TEXT DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_commission_idempotency (idempotency_key), - UNIQUE KEY uniq_commission_cancel_operation (cancel_operation_key), - KEY idx_promoter_status (promoter_id, status), - KEY idx_order_type (order_number, order_type), - KEY idx_created (created_at) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_commission_ledger); - - // 佣金欠款挂账：退款全额收回后，若佣金池不足产生的差额记为欠款， - // 后续新增佣金先抵扣欠款再入池。每用户一行。 - $sql_commission_debt = "CREATE TABLE {$prefix}aksrt_commission_debt ( - user_id BIGINT UNSIGNED NOT NULL, - debt_minor BIGINT UNSIGNED NOT NULL DEFAULT 0, - updated_at DATETIME NOT NULL, - PRIMARY KEY (user_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_commission_debt); - - // ── immutable commission adjustments (refund/debt/manual) ── - $sql_commission_adjustment = "CREATE TABLE {$prefix}aksrt_commission_adjustment ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - ledger_id BIGINT UNSIGNED NOT NULL, - promoter_id BIGINT UNSIGNED NOT NULL, - amount DECIMAL(18,2) NOT NULL DEFAULT 0, - reason VARCHAR(32) NOT NULL, - source_key VARCHAR(128) NOT NULL, - operator_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - created_at DATETIME NOT NULL, - note TEXT DEFAULT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_adjustment_source (source_key), - KEY idx_ledger (ledger_id), - KEY idx_promoter (promoter_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_commission_adjustment); - - // ── payout account snapshots ── - $sql_payout_account = "CREATE TABLE {$prefix}aksrt_payout_account ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - user_id BIGINT UNSIGNED NOT NULL, - channel VARCHAR(20) NOT NULL, - attachment_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - account_hash CHAR(64) NOT NULL DEFAULT '', - status VARCHAR(20) NOT NULL DEFAULT 'active', - created_at DATETIME NOT NULL, - updated_at DATETIME NOT NULL, - PRIMARY KEY (id), - UNIQUE KEY uniq_user_channel (user_id, channel), - KEY idx_user_status (user_id, status) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_payout_account); - - // ── order_items (§6.5 多商品多商家) ── - $sql_order_items = "CREATE TABLE {$prefix}aksrt_order_item ( - id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, - order_number VARCHAR(32) NOT NULL DEFAULT '', - product_id BIGINT UNSIGNED NOT NULL DEFAULT 0, - product_title VARCHAR(255) NOT NULL DEFAULT '', - options_key VARCHAR(255) NOT NULL DEFAULT '', - options_label VARCHAR(255) NOT NULL DEFAULT '', - quantity INT UNSIGNED NOT NULL DEFAULT 1, - unit_price DECIMAL(10,2) NOT NULL DEFAULT 0, - total_price DECIMAL(10,2) NOT NULL DEFAULT 0, - discount_amount DECIMAL(10,2) NOT NULL DEFAULT 0, - shipping_fee DECIMAL(10,2) NOT NULL DEFAULT 0, - pay_price DECIMAL(10,2) NOT NULL DEFAULT 0, - shipping_type VARCHAR(20) NOT NULL DEFAULT 'express', - auto_delivery_content TEXT DEFAULT NULL, - discount_hit TEXT DEFAULT NULL, - gift_data TEXT DEFAULT NULL, - image VARCHAR(512) NOT NULL DEFAULT '', - PRIMARY KEY (id), - KEY idx_order (order_number), - KEY idx_product (product_id) - ) ENGINE=InnoDB {$charset_collate};"; - dbDelta($sql_order_items); - - self::migrate_identity_tables($prefix, $charset_collate); - self::migrate_vip_tables($prefix, $charset_collate); - } -} +get_charset_collate(); + $prefix = $wpdb->prefix; + + // ---------- 1. 统一资产账户与不可变账本 ---------- + $sql_asset_account = "CREATE TABLE {$prefix}aksrt_asset_account ( + user_id BIGINT UNSIGNED NOT NULL, + asset VARCHAR(16) NOT NULL, + balance_minor BIGINT UNSIGNED NOT NULL DEFAULT 0, + version BIGINT UNSIGNED NOT NULL DEFAULT 0, + updated_at DATETIME(6) NOT NULL, + PRIMARY KEY (user_id, asset), + KEY idx_asset_balance (asset, balance_minor) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_asset_account); + + $sql_asset_transaction = "CREATE TABLE {$prefix}aksrt_asset_transaction ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + operation_key VARCHAR(191) NOT NULL, + payload_hash CHAR(64) NOT NULL, + reason VARCHAR(64) NOT NULL, + ref_type VARCHAR(32) DEFAULT NULL, + ref_key VARCHAR(191) DEFAULT NULL, + actor_user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + metadata LONGTEXT DEFAULT NULL, + ip VARCHAR(64) DEFAULT NULL, + ua VARCHAR(255) DEFAULT NULL, + created_at DATETIME(6) NOT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_operation_key (operation_key), + KEY idx_reason_time (reason, created_at), + KEY idx_reference (ref_type, ref_key) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_asset_transaction); + + $sql_asset_entry = "CREATE TABLE {$prefix}aksrt_asset_entry ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + transaction_id BIGINT UNSIGNED NOT NULL, + line_no SMALLINT UNSIGNED NOT NULL, + user_id BIGINT UNSIGNED NOT NULL, + asset VARCHAR(16) NOT NULL, + entry_type VARCHAR(32) NOT NULL, + delta_minor BIGINT NOT NULL, + balance_after_minor BIGINT UNSIGNED NOT NULL, + counterparty_user_id BIGINT UNSIGNED DEFAULT NULL, + remark VARCHAR(255) DEFAULT NULL, + created_at DATETIME(6) NOT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_transaction_line (transaction_id, line_no), + KEY idx_user_asset_time (user_id, asset, created_at, id), + KEY idx_transaction (transaction_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_asset_entry); + + // 后台「资金流水」页的默认查询是 WHERE 1=1 ORDER BY created_at DESC, id DESC LIMIT n + // 外加同条件的 COUNT(*)，且界面上的日期区间筛选也只有 created_at 可用。 + // 索引必须能以 created_at 为前导列，否则每次翻页都是全表扫描 + filesort， + // 而 idx_flow_event_time 的前导列是 event_type（筛选时可空），救不了这两条查询。 + $sql_financial_flow = "CREATE TABLE {$prefix}aksrt_financial_flow ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + flow_number VARCHAR(32) NOT NULL, + operation_key VARCHAR(191) NOT NULL, + event_type VARCHAR(64) NOT NULL, + ref_type VARCHAR(32) DEFAULT NULL, + ref_key VARCHAR(191) DEFAULT NULL, + order_number VARCHAR(32) DEFAULT NULL, + withdrawal_number VARCHAR(32) DEFAULT NULL, + ledger_transaction_id BIGINT UNSIGNED DEFAULT NULL, + provider_transaction_id VARCHAR(128) DEFAULT NULL, + metadata LONGTEXT DEFAULT NULL, + created_at DATETIME(6) NOT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_flow_number (flow_number), + UNIQUE KEY uniq_flow_operation (operation_key), + UNIQUE KEY uniq_flow_ledger_transaction (ledger_transaction_id), + KEY idx_flow_created (created_at), + KEY idx_flow_event_time (event_type, created_at), + KEY idx_flow_order (order_number), + KEY idx_flow_withdrawal (withdrawal_number), + KEY idx_flow_reference (ref_type, ref_key), + KEY idx_flow_provider_transaction (provider_transaction_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_financial_flow); + + $sql_financial_flow_entry = "CREATE TABLE {$prefix}aksrt_financial_flow_entry ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + flow_id BIGINT UNSIGNED NOT NULL, + line_no SMALLINT UNSIGNED NOT NULL, + user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + asset VARCHAR(16) NOT NULL, + direction VARCHAR(8) NOT NULL, + entry_type VARCHAR(32) NOT NULL, + delta_minor BIGINT NOT NULL, + balance_after_minor BIGINT UNSIGNED DEFAULT NULL, + counterparty_user_id BIGINT UNSIGNED DEFAULT NULL, + remark VARCHAR(255) DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_flow_line (flow_id, line_no), + KEY idx_flow_entry_user (user_id, flow_id), + KEY idx_flow_entry_asset (asset, flow_id), + KEY idx_flow_entry_direction (direction, flow_id), + KEY idx_flow_entry_counterparty (counterparty_user_id, flow_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_financial_flow_entry); + + // ---------- 2. 签到 ---------- + $sql_signin = "CREATE TABLE {$prefix}aksrt_signin_log ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + user_id BIGINT UNSIGNED NOT NULL, + signin_date DATE NOT NULL, + streak INT NOT NULL DEFAULT 1, + reward INT NOT NULL DEFAULT 0, + PRIMARY KEY (id), + UNIQUE KEY uniq_user_date (user_id, signin_date), + KEY idx_user (user_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_signin); + + // ---------- 3. 下载 token ---------- + $sql_dl_token = "CREATE TABLE {$prefix}aksrt_dl_token ( + token CHAR(48) NOT NULL, + user_id BIGINT UNSIGNED NOT NULL, + post_id BIGINT UNSIGNED NOT NULL, + source_index INT NOT NULL DEFAULT 0, + cost INT NOT NULL DEFAULT 0, + ip_bind VARCHAR(64) DEFAULT NULL, + ua_hash CHAR(40) DEFAULT NULL, + used_count INT NOT NULL DEFAULT 0, + max_uses INT NOT NULL DEFAULT 1, + expires_at DATETIME NOT NULL, + created_at DATETIME NOT NULL, + PRIMARY KEY (token), + KEY idx_expires (expires_at), + KEY idx_user (user_id), + KEY idx_post (post_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_dl_token); + + // ---------- 5. 用户通知收件箱 ---------- + $sql_notification = "CREATE TABLE {$prefix}aksrt_notification ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + user_id BIGINT UNSIGNED NOT NULL, + type VARCHAR(32) NOT NULL, + title VARCHAR(191) NOT NULL, + description TEXT DEFAULT NULL, + target_url TEXT DEFAULT NULL, + is_read TINYINT(1) NOT NULL DEFAULT 0, + created_at DATETIME NOT NULL, + read_at DATETIME DEFAULT NULL, + PRIMARY KEY (id), + KEY idx_user_created (user_id, created_at), + KEY idx_user_read (user_id, is_read) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_notification); + + // ---------- 8. 订单表 ---------- + $sql_order = "CREATE TABLE {$prefix}aksrt_order ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + order_number VARCHAR(32) NOT NULL, + request_key VARCHAR(191) DEFAULT NULL, + user_id BIGINT UNSIGNED NOT NULL, + product_type VARCHAR(32) NOT NULL DEFAULT '', + product_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + amount DECIMAL(10,2) NOT NULL DEFAULT 0, + currency VARCHAR(8) NOT NULL DEFAULT 'CNY', + status VARCHAR(20) NOT NULL DEFAULT 'pending', + shipping_status TINYINT NOT NULL DEFAULT 0, + payment_method VARCHAR(32) NOT NULL DEFAULT '', + payment_transaction_id VARCHAR(128) NOT NULL DEFAULT '', + created_at DATETIME NOT NULL, + paid_at DATETIME DEFAULT NULL, + delivered_at DATETIME DEFAULT NULL, + completed_at DATETIME DEFAULT NULL, + cancelled_at DATETIME DEFAULT NULL, + refunded_at DATETIME DEFAULT NULL, + expires_at DATETIME DEFAULT NULL, + note TEXT DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_order_number (order_number), + UNIQUE KEY uniq_request_key (request_key), + KEY idx_user (user_id), + KEY idx_user_status_created (user_id, status, created_at), + KEY idx_status (status), + KEY idx_created (created_at), + KEY idx_product (product_type, product_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_order); + + // ---------- order after-sales ---------- + $sql_order_aftersale = "CREATE TABLE {$prefix}aksrt_order_aftersale ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + order_number VARCHAR(32) NOT NULL, + user_id BIGINT UNSIGNED NOT NULL, + aftersale_type VARCHAR(24) NOT NULL DEFAULT 'refund', + reason TEXT NOT NULL, + apply_form LONGTEXT DEFAULT NULL, + images LONGTEXT DEFAULT NULL, + refund_amount VARCHAR(32) NOT NULL DEFAULT '0', + status VARCHAR(20) NOT NULL DEFAULT 'pending', + admin_note TEXT DEFAULT NULL, + gateway_request_id VARCHAR(128) DEFAULT NULL, + gateway_refund_id VARCHAR(128) DEFAULT NULL, + gateway_result LONGTEXT DEFAULT NULL, + created_at DATETIME NOT NULL, + reviewed_at DATETIME DEFAULT NULL, + completed_at DATETIME DEFAULT NULL, + PRIMARY KEY (id), + KEY idx_order_status (order_number, status), + KEY idx_user_created (user_id, created_at), + KEY idx_status_created (status, created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_order_aftersale); + + // ---------- 9. 作者收益台账 ---------- + $sql_revenue = "CREATE TABLE {$prefix}aksrt_revenue ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + author_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + order_number VARCHAR(32) NOT NULL DEFAULT '', + post_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + buyer_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + currency VARCHAR(8) NOT NULL DEFAULT 'CNY', + original_amount DECIMAL(18,2) NOT NULL DEFAULT 0, + share_ratio DECIMAL(5,2) NOT NULL DEFAULT 0, + author_level TINYINT UNSIGNED NOT NULL DEFAULT 0, + amount DECIMAL(18,2) NOT NULL DEFAULT 0, + type VARCHAR(32) NOT NULL DEFAULT 'order', + status VARCHAR(20) NOT NULL DEFAULT 'pending', + reversal_amount DECIMAL(18,2) NOT NULL DEFAULT 0, + error_message TEXT DEFAULT NULL, + audit_json LONGTEXT DEFAULT NULL, + created_at DATETIME NOT NULL, + settled_at DATETIME DEFAULT NULL, + reversed_at DATETIME DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_creator_order (author_id, order_number), + KEY idx_author (author_id), + KEY idx_order (order_number), + KEY idx_post (post_id), + KEY idx_buyer (buyer_id), + KEY idx_currency (currency), + KEY idx_status (status), + KEY idx_created (created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_revenue); + + // ---------- 10. 提现台账 ---------- + $sql_withdrawal = "CREATE TABLE {$prefix}aksrt_withdrawal ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + withdrawal_number VARCHAR(32) NOT NULL, + user_id BIGINT UNSIGNED NOT NULL, + amount DECIMAL(10,2) NOT NULL DEFAULT 0, + gross_amount DECIMAL(10,2) NOT NULL DEFAULT 0, + method VARCHAR(32) NOT NULL DEFAULT '', + account_info TEXT DEFAULT NULL, + status VARCHAR(20) NOT NULL DEFAULT 'pending', + operation_key VARCHAR(191) DEFAULT NULL, + ledger_transaction_id BIGINT UNSIGNED DEFAULT NULL, + created_at DATETIME NOT NULL, + processed_at DATETIME DEFAULT NULL, + note TEXT DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_withdrawal_number (withdrawal_number), + UNIQUE KEY uniq_withdrawal_operation (operation_key), + UNIQUE KEY uniq_ledger_transaction (ledger_transaction_id), + KEY idx_user (user_id), + KEY idx_user_created (user_id, created_at), + KEY idx_status (status), + KEY idx_created (created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_withdrawal); + + // ---------- 11. 举报工单 ---------- + $sql_report = "CREATE TABLE {$prefix}aksrt_report ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + reporter_id BIGINT UNSIGNED NOT NULL, + target_type VARCHAR(20) NOT NULL, + target_id BIGINT UNSIGNED NOT NULL, + reason TEXT NOT NULL, + category VARCHAR(40) NOT NULL DEFAULT '', + status VARCHAR(20) NOT NULL DEFAULT 'pending', + created_at DATETIME NOT NULL, + updated_at DATETIME DEFAULT NULL, + notes_json TEXT DEFAULT NULL, + PRIMARY KEY (id), + KEY idx_status (status), + KEY idx_target (target_type, target_id), + KEY idx_reporter (reporter_id), + KEY idx_created (created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_report); + + // ---------- 12. 用户限制/封禁 ---------- + $sql_restriction = "CREATE TABLE {$prefix}aksrt_user_restriction ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + user_id BIGINT UNSIGNED NOT NULL, + type VARCHAR(20) NOT NULL DEFAULT 'warn', + reason TEXT NOT NULL, + scope VARCHAR(20) NOT NULL DEFAULT 'global', + expires_at DATETIME DEFAULT NULL, + created_by BIGINT UNSIGNED NOT NULL DEFAULT 0, + created_at DATETIME NOT NULL, + PRIMARY KEY (id), + KEY idx_user (user_id), + KEY idx_type (type), + KEY idx_scope (scope), + KEY idx_expires (expires_at), + KEY idx_created (created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_restriction); + + // ── follow ── + $sql_follow = "CREATE TABLE {$prefix}aksrt_follow ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + follower_id BIGINT UNSIGNED NOT NULL, + following_id BIGINT UNSIGNED NOT NULL, + created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', + PRIMARY KEY (id), + UNIQUE KEY idx_pair (follower_id, following_id), + KEY idx_following (following_id), + KEY idx_created (created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_follow); + + // ── coupon ── + $sql_coupon = "CREATE TABLE {$prefix}aksrt_coupon ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + code VARCHAR(60) NOT NULL DEFAULT '', + type VARCHAR(20) NOT NULL DEFAULT 'fixed', + value DECIMAL(10,2) NOT NULL DEFAULT 0, + min_amount DECIMAL(10,2) NOT NULL DEFAULT 0, + usage_limit INT UNSIGNED NOT NULL DEFAULT 0, + used_count INT UNSIGNED NOT NULL DEFAULT 0, + expires_at DATETIME DEFAULT NULL, + per_user_limit INT UNSIGNED NOT NULL DEFAULT 0, + product_scope TEXT DEFAULT NULL, + max_discount DECIMAL(10,2) NOT NULL DEFAULT 0, + status VARCHAR(20) NOT NULL DEFAULT 'active', + created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', + PRIMARY KEY (id), + UNIQUE KEY idx_code (code), + KEY idx_status (status), + KEY idx_expires (expires_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_coupon); + + // ── coupon_usage (R68) ── + $sql_coupon_usage = "CREATE TABLE {$prefix}aksrt_coupon_usage ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + coupon_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + order_number VARCHAR(32) NOT NULL DEFAULT '', + discount DECIMAL(10,2) NOT NULL DEFAULT 0, + created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', + PRIMARY KEY (id), + KEY idx_coupon (coupon_id), + KEY idx_user (user_id), + UNIQUE KEY uniq_coupon_usage_order (order_number) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_coupon_usage); + + // ── typed charge cards ── + $sql_charge_card = "CREATE TABLE {$prefix}aksrt_charge_card ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + card VARCHAR(60) NOT NULL DEFAULT '', + password VARCHAR(80) NOT NULL DEFAULT '', + type VARCHAR(20) NOT NULL DEFAULT 'balance', + amount DECIMAL(10,2) NOT NULL DEFAULT 0, + balance DECIMAL(10,2) NOT NULL DEFAULT 0, + status VARCHAR(20) NOT NULL DEFAULT 'active', + meta LONGTEXT DEFAULT NULL, + order_number VARCHAR(32) NOT NULL DEFAULT '', + used_by BIGINT UNSIGNED DEFAULT NULL, + used_at DATETIME DEFAULT NULL, + expires_at DATETIME DEFAULT NULL, + created_at DATETIME NOT NULL DEFAULT '0000-00-00 00:00:00', + note TEXT DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY idx_password (password), + KEY idx_card (card), + KEY idx_type (type), + KEY idx_status (status), + KEY idx_used_by (used_by), + KEY idx_order_number (order_number), + KEY idx_expires (expires_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_charge_card); + + // ── one-time invite codes (registration gate + per-batch rewards) ── + $sql_invite_code = "CREATE TABLE {$prefix}aksrt_invite_code ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + code VARCHAR(32) NOT NULL, + batch_id VARCHAR(32) NOT NULL DEFAULT '', + remark VARCHAR(191) NOT NULL DEFAULT '', + rewards TEXT DEFAULT NULL, + max_uses INT UNSIGNED NOT NULL DEFAULT 1, + used_count INT UNSIGNED NOT NULL DEFAULT 0, + status VARCHAR(20) NOT NULL DEFAULT 'active', + expires_at DATETIME DEFAULT NULL, + created_by BIGINT UNSIGNED NOT NULL DEFAULT 0, + created_at DATETIME NOT NULL, + updated_at DATETIME NOT NULL DEFAULT '1970-01-01 00:00:00', + PRIMARY KEY (id), + UNIQUE KEY uniq_invite_code (code), + KEY idx_batch (batch_id), + KEY idx_status (status), + KEY idx_expires (expires_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_invite_code); + + // ── invite-code usage log (who consumed which code) ── + $sql_invite_code_usage = "CREATE TABLE {$prefix}aksrt_invite_code_usage ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + code_id BIGINT UNSIGNED NOT NULL, + user_id BIGINT UNSIGNED NOT NULL, + used_at DATETIME NOT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_invite_usage (code_id, user_id), + KEY idx_usage_user (user_id), + KEY idx_usage_code (code_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_invite_code_usage); + + // ── canonical Ref attribution and permanent user binding ── + $sql_affiliate_relation = "CREATE TABLE {$prefix}aksrt_affiliate_relation ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + referral_code VARCHAR(32) NOT NULL, + promoter_id BIGINT UNSIGNED NOT NULL, + invitee_id BIGINT UNSIGNED DEFAULT NULL, + first_touch_at DATETIME NOT NULL, + bound_at DATETIME DEFAULT NULL, + status VARCHAR(20) NOT NULL DEFAULT 'captured', + reward_status VARCHAR(20) NOT NULL DEFAULT 'skipped', + rewarded_at DATETIME DEFAULT NULL, + registration_ip VARCHAR(64) DEFAULT NULL, + created_at DATETIME NOT NULL, + PRIMARY KEY (id), + KEY idx_referral_code (referral_code), + UNIQUE KEY uniq_invitee (invitee_id), + KEY idx_promoter (promoter_id), + KEY idx_status_touch (status, first_touch_at), + KEY idx_reward_status (reward_status), + KEY idx_reward_ip (registration_ip, rewarded_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_affiliate_relation); + + // ── immutable commission ledger ── + // 佣金即时入账（无冻结/结算期）：下单支付即 credit 到 COMMISSION 资金池， + // 本表仅作佣金明细账 + 退款冲正的溯源记录。status: credited | cancelled。 + $sql_commission_ledger = "CREATE TABLE {$prefix}aksrt_commission_ledger ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + promoter_id BIGINT UNSIGNED NOT NULL, + source_user_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + order_number VARCHAR(64) NOT NULL, + order_type VARCHAR(32) NOT NULL, + eligible_base DECIMAL(18,2) NOT NULL DEFAULT 0, + ratio DECIMAL(8,4) NOT NULL DEFAULT 0, + original_amount DECIMAL(18,2) NOT NULL DEFAULT 0, + adjustment_total DECIMAL(18,2) NOT NULL DEFAULT 0, + status VARCHAR(20) NOT NULL DEFAULT 'credited', + idempotency_key VARCHAR(128) NOT NULL, + cancel_operation_key VARCHAR(191) DEFAULT NULL, + cancel_payload_hash CHAR(64) DEFAULT NULL, + created_at DATETIME NOT NULL, + note TEXT DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_commission_idempotency (idempotency_key), + UNIQUE KEY uniq_commission_cancel_operation (cancel_operation_key), + KEY idx_promoter_status (promoter_id, status), + KEY idx_order_type (order_number, order_type), + KEY idx_created (created_at) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_commission_ledger); + + // 佣金欠款挂账：退款全额收回后，若佣金池不足产生的差额记为欠款， + // 后续新增佣金先抵扣欠款再入池。每用户一行。 + $sql_commission_debt = "CREATE TABLE {$prefix}aksrt_commission_debt ( + user_id BIGINT UNSIGNED NOT NULL, + debt_minor BIGINT UNSIGNED NOT NULL DEFAULT 0, + updated_at DATETIME NOT NULL, + PRIMARY KEY (user_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_commission_debt); + + // ── immutable commission adjustments (refund/debt/manual) ── + $sql_commission_adjustment = "CREATE TABLE {$prefix}aksrt_commission_adjustment ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + ledger_id BIGINT UNSIGNED NOT NULL, + promoter_id BIGINT UNSIGNED NOT NULL, + amount DECIMAL(18,2) NOT NULL DEFAULT 0, + reason VARCHAR(32) NOT NULL, + source_key VARCHAR(128) NOT NULL, + operator_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + created_at DATETIME NOT NULL, + note TEXT DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_adjustment_source (source_key), + KEY idx_ledger (ledger_id), + KEY idx_promoter (promoter_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_commission_adjustment); + + // ── payout account snapshots ── + $sql_payout_account = "CREATE TABLE {$prefix}aksrt_payout_account ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + user_id BIGINT UNSIGNED NOT NULL, + channel VARCHAR(20) NOT NULL, + attachment_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + account_hash CHAR(64) NOT NULL DEFAULT '', + status VARCHAR(20) NOT NULL DEFAULT 'active', + created_at DATETIME NOT NULL, + updated_at DATETIME NOT NULL, + PRIMARY KEY (id), + UNIQUE KEY uniq_user_channel (user_id, channel), + KEY idx_user_status (user_id, status) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_payout_account); + + // ── order_items (§6.5 多商品多商家) ── + $sql_order_items = "CREATE TABLE {$prefix}aksrt_order_item ( + id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, + order_number VARCHAR(32) NOT NULL DEFAULT '', + product_id BIGINT UNSIGNED NOT NULL DEFAULT 0, + product_title VARCHAR(255) NOT NULL DEFAULT '', + options_key VARCHAR(255) NOT NULL DEFAULT '', + options_label VARCHAR(255) NOT NULL DEFAULT '', + quantity INT UNSIGNED NOT NULL DEFAULT 1, + unit_price DECIMAL(10,2) NOT NULL DEFAULT 0, + total_price DECIMAL(10,2) NOT NULL DEFAULT 0, + discount_amount DECIMAL(10,2) NOT NULL DEFAULT 0, + shipping_fee DECIMAL(10,2) NOT NULL DEFAULT 0, + pay_price DECIMAL(10,2) NOT NULL DEFAULT 0, + shipping_type VARCHAR(20) NOT NULL DEFAULT 'express', + auto_delivery_content TEXT DEFAULT NULL, + discount_hit TEXT DEFAULT NULL, + gift_data TEXT DEFAULT NULL, + image VARCHAR(512) NOT NULL DEFAULT '', + PRIMARY KEY (id), + KEY idx_order (order_number), + KEY idx_product (product_id) + ) ENGINE=InnoDB {$charset_collate};"; + dbDelta($sql_order_items); + + self::migrate_identity_tables($prefix, $charset_collate); + self::migrate_vip_tables($prefix, $charset_collate); + } +} diff --git a/src/Payment/AfterSaleService.php b/src/Payment/AfterSaleService.php index 7ad2509c..473bc530 100644 --- a/src/Payment/AfterSaleService.php +++ b/src/Payment/AfterSaleService.php @@ -1,680 +1,680 @@ -[0-9]{20}|[0-9]{22})'; - register_rest_route('aksrt/v1', '/orders/' . $number . '/after-sale', [ - ['methods' => \WP_REST_Server::CREATABLE, 'callback' => [$this, 'rest_submit'], 'permission_callback' => [$this, 'require_user'], 'args' => [ - 'order_number' => ['required' => true, 'sanitize_callback' => 'sanitize_text_field'], - 'reason' => ['required' => true, 'sanitize_callback' => 'sanitize_textarea_field'], - 'reason_label' => ['required' => false, 'sanitize_callback' => 'sanitize_text_field'], - 'materials' => ['required' => false, 'type' => 'array', 'validate_callback' => static function ($value): bool { - if (!is_array($value) || count($value) > 10) return false; - foreach ($value as $item) { - if (!is_array($item)) return false; - foreach (['label', 'value'] as $key) { - if (isset($item[$key]) && !is_string($item[$key])) return false; - } - } - return true; - }], - 'description' => ['required' => false, 'sanitize_callback' => 'sanitize_textarea_field'], - 'images' => ['required' => false, 'type' => 'array', 'validate_callback' => static function ($value): bool { - return is_array($value) && count($value) <= 3; - }], - ]], - ['methods' => \WP_REST_Server::READABLE, 'callback' => [$this, 'rest_list'], 'permission_callback' => [$this, 'require_user'], 'args' => [ - 'order_number' => ['required' => true, 'sanitize_callback' => 'sanitize_text_field'], - ]], - ['methods' => 'DELETE', 'callback' => [$this, 'rest_cancel'], 'permission_callback' => [$this, 'require_user'], 'args' => [ - 'order_number' => ['required' => true, 'sanitize_callback' => 'sanitize_text_field'], - ]], - ]); - // 售后举证图片上传：复用评论图片上传链路（大小 / 类型 / 内容审核同一套校验）。 - register_rest_route('aksrt/v1', '/orders/' . $number . '/after-sale/upload-image', [ - ['methods' => \WP_REST_Server::CREATABLE, 'callback' => [$this, 'rest_upload_image'], 'permission_callback' => [$this, 'require_after_sale_image']], - ]); - } - - /** 售后举证图片上传权限：登录 + nonce + 售后开启 + 图片开关开启 + 订单归属本人。 */ - public function require_after_sale_image(\WP_REST_Request $request) { - $user = $this->require_user($request); - if (is_wp_error($user)) { - return $user; - } - if (!class_exists('\AKSRT\Settings\PaymentRuntime')) { - return new \WP_Error('aksrt_after_sale_forbidden', __('售后功能暂未开启', 'aksrt'), ['status' => 403]); - } - $settings = \AKSRT\Settings\PaymentRuntime::get_after_sale_settings(); - if (empty($settings['enabled']) || empty($settings['img_enabled'])) { - return new \WP_Error('aksrt_after_sale_forbidden', __('售后图片上传未开启', 'aksrt'), ['status' => 403]); - } - $number = sanitize_text_field((string) $request->get_param('order_number')); - if (!OrderRepository::get_instance()->get_user_order(get_current_user_id(), $number)) { - return new \WP_Error('aksrt_order_missing', __('订单不存在', 'aksrt'), ['status' => 404]); - } - return true; - } - - public function rest_upload_image(\WP_REST_Request $request) { - if (!class_exists('\AKSRT\Admin\UserController')) { - return new \WP_Error('aksrt_after_sale_upload', __('上传服务不可用', 'aksrt'), ['status' => 500]); - } - return \AKSRT\Admin\UserController::get_instance()->rest_upload_comment_image($request); - } - - public function require_user(\WP_REST_Request $request) { - if (!is_user_logged_in()) return new \WP_Error('aksrt_need_login', __('请先登录', 'aksrt'), ['status' => 401]); - $nonce = (string) $request->get_header('X-WP-Nonce'); - return $nonce !== '' && wp_verify_nonce($nonce, 'wp_rest') ? true : new \WP_Error('aksrt_rest_nonce', __('安全验证失败，请刷新页面后重试', 'aksrt'), ['status' => 403]); - } - - public function rest_submit(\WP_REST_Request $request) { - $images = $request->get_param('images'); - $materials = $request->get_param('materials'); - $result = $this->create( - get_current_user_id(), - (string) $request->get_param('order_number'), - (string) $request->get_param('reason'), - is_array($images) ? $images : [], - [ - 'reason_label' => (string) $request->get_param('reason_label'), - 'materials' => is_array($materials) ? $materials : [], - 'description' => (string) $request->get_param('description'), - ] - ); - return is_wp_error($result) ? $result : rest_ensure_response(['success' => true, 'data' => $result]); - } - - public function rest_list(\WP_REST_Request $request) { - $number = sanitize_text_field((string) $request->get_param('order_number')); - if (!OrderRepository::get_instance()->get_user_order(get_current_user_id(), $number)) return new \WP_Error('aksrt_order_missing', __('订单不存在', 'aksrt'), ['status' => 404]); - return rest_ensure_response(['success' => true, 'data' => $this->list_for_order($number)]); - } - - public function rest_cancel(\WP_REST_Request $request) { - $result = $this->cancel_for_user(get_current_user_id(), (string) $request->get_param('order_number')); - return is_wp_error($result) ? $result : rest_ensure_response(['success' => true, 'data' => $result]); - } - - /** @param array