文件
shanghaipeiwan/pwuniapp/common/subscribe.js
xcbyy cacc478d71 fix(subscribe): 订阅消息未下发原因可见 + 小程序真实授权
- 后台测试推送:未就绪返回 mode=SIMULATED 明确原因 + 配置自检(模板ID/openid/appId/appSecret/总开关),不再把模拟显示为成功

- 占位符 tmpl_xxx 视为未配置(测试推送与订阅模板接口均过滤),微信错误码中文化(43101/47003/40037/40001 等)

- 小程序「平台消息与通知」点击时真实调用 wx.requestSubscribeMessage 并回显授权状态,标签不再恒为已开启

- 管理端拦截器错误提示改用 message;文档补订阅消息排查顺序;新增回归护栏(86 套件/631 用例全绿)
2026-10-19 10:02:57 +08:00

91 行
3.2 KiB
JavaScript

此文件含有模棱两可的 Unicode 字符

此文件含有可能会与其他字符混淆的 Unicode 字符。 如果您是想特意这样的,可以安全地忽略该警告。 使用 Escape 按钮显示他们。

// 已读取AGENTS.md
// 微信订阅消息授权工具:预加载模板ID,在关键动作点击时同步请求授权。
// 说明:订阅消息为一次性订阅,需在用户点击(或确认弹窗)动作中调用 requestSubscribeFor。
import { getSubscribeTemplates } from './api.js';
const SCENE_KEYS = {
order: ['orderStatusTemplateId', 'verifyCodeTemplateId'],
withdraw: ['withdrawSuccessTemplateId'],
activity: ['activityJoinTemplateId']
};
let templates = null;
/** 页面加载时预加载模板配置(避免在点击时 await 丢失手势上下文) */
export async function preloadSubscribeTemplates() {
try {
templates = await getSubscribeTemplates();
} catch (_) {
templates = null;
}
return templates;
}
/** 过滤掉占位/空模板ID,只保留真实模板 */
function resolveTmplIds(scene) {
if (!templates || templates.enablePush === false) return [];
const keys = SCENE_KEYS[scene] || [];
return keys
.map((k) => templates[k])
.filter((x) => x && !String(x).startsWith('tmpl_'));
}
/**
* 在关键动作前请求订阅授权(同步调用,不阻塞业务)。
* scene: 'order' | 'withdraw' | 'activity'
*/
export function requestSubscribeFor(scene) {
try {
// #ifdef MP-WEIXIN
if (typeof uni.requestSubscribeMessage !== 'function') return;
const tmplIds = resolveTmplIds(scene);
if (tmplIds.length === 0) return;
uni.requestSubscribeMessage({
tmplIds,
complete: () => {}
});
// #endif
} catch (_) {
// 授权失败不影响主流程
}
}
/** 全部已配置的真实模板ID(过滤空值与 tmpl_ 占位符) */
function allTmplIds() {
if (!templates || templates.enablePush === false) return [];
return ['orderStatusTemplateId', 'activityJoinTemplateId', 'withdrawSuccessTemplateId', 'verifyCodeTemplateId']
.map((k) => templates[k])
.filter((x) => x && !String(x).startsWith('tmpl_'));
}
/**
* 主动请求全部订阅授权(用于「平台消息与通知」入口)。
* 注意:wx.requestSubscribeMessage 必须在用户点击手势中同步调用;本函数不 await 任何网络请求。
* 返回每项授权结果,便于界面给出真实提示(订阅消息为一次性订阅,每条授权仅可下发 1 条)。
*/
export function requestSubscribeAll() {
return new Promise((resolve) => {
try {
if (typeof uni.requestSubscribeMessage !== 'function') {
return resolve({ supported: false, tmplIds: [], accepted: [], rejected: [] });
}
const tmplIds = allTmplIds();
if (tmplIds.length === 0) {
return resolve({ supported: true, tmplIds: [], accepted: [], rejected: [], noTemplates: true });
}
uni.requestSubscribeMessage({
tmplIds,
success: (res) => {
const accepted = tmplIds.filter((id) => res && res[id] === 'accept');
const rejected = tmplIds.filter((id) => !res || res[id] !== 'accept');
resolve({ supported: true, tmplIds, accepted, rejected, raw: res });
},
fail: (err) => resolve({ supported: true, tmplIds, accepted: [], rejected: tmplIds, error: err }),
complete: () => {}
});
} catch (e) {
resolve({ supported: true, tmplIds: [], accepted: [], rejected: [], error: e });
}
});
}