import {
|
resolveCurrentAppUserId
|
} from './app-user.js'
|
|
const PUSH_ALIAS_CACHE_KEY = 'jpushBoundAlias'
|
let lastHandledPushMessageId = ''
|
|
/**
|
* 读取当前设备上的极光插件实例。
|
*/
|
function getJPushModule() {
|
// #ifdef APP-PLUS
|
try {
|
return uni.requireNativePlugin('JG-JPush')
|
} catch (error) {
|
return null
|
}
|
// #endif
|
// #ifndef APP-PLUS
|
return null
|
// #endif
|
}
|
|
/**
|
* 将当前登录用户 ID 归一化为极光 alias。
|
*/
|
function resolveCurrentPushAlias() {
|
const userId = resolveCurrentAppUserId()
|
if (!userId) {
|
return ''
|
}
|
return String(userId)
|
}
|
|
/**
|
* 绑定当前登录用户到极光 alias，便于服务端按用户 ID 精准推送。
|
*/
|
export function syncJPushAliasWithCurrentUser() {
|
const alias = resolveCurrentPushAlias()
|
if (!alias) {
|
return false
|
}
|
const jpushModule = getJPushModule()
|
if (!jpushModule || typeof jpushModule.setAlias !== 'function') {
|
return false
|
}
|
const sequence = Date.now()
|
const invoked = tryInvoke(() => jpushModule.setAlias({
|
sequence,
|
alias
|
})) || tryInvoke(() => jpushModule.setAlias({
|
sequence: String(sequence),
|
alias
|
})) || tryInvoke(() => jpushModule.setAlias(alias)) || tryInvoke(() => jpushModule.setAlias(alias, sequence))
|
if (invoked) {
|
uni.setStorageSync(PUSH_ALIAS_CACHE_KEY, alias)
|
}
|
return invoked
|
}
|
|
/**
|
* 退出登录后清理本地 alias 缓存，并尽量解除极光别名。
|
*/
|
export function clearJPushAliasBinding() {
|
uni.removeStorageSync(PUSH_ALIAS_CACHE_KEY)
|
const jpushModule = getJPushModule()
|
if (!jpushModule) {
|
return false
|
}
|
const sequence = Date.now()
|
return tryInvoke(() => {
|
if (typeof jpushModule.deleteAlias === 'function') {
|
jpushModule.deleteAlias({
|
sequence
|
})
|
return
|
}
|
if (typeof jpushModule.setAlias === 'function') {
|
jpushModule.setAlias({
|
sequence,
|
alias: ''
|
})
|
}
|
})
|
}
|
|
/**
|
* 初始化极光推送，并在连接成功后补一次 alias 同步。
|
*/
|
export function initJPushLifecycle() {
|
const jpushModule = getJPushModule()
|
if (!jpushModule) {
|
return null
|
}
|
if (typeof jpushModule.setLoggerEnable === 'function') {
|
jpushModule.setLoggerEnable(false)
|
}
|
if (typeof jpushModule.initJPushService === 'function') {
|
jpushModule.initJPushService()
|
}
|
if (typeof jpushModule.addConnectEventListener === 'function') {
|
jpushModule.addConnectEventListener((result) => {
|
const connectEnable = !!(result && result.connectEnable)
|
if (!connectEnable) {
|
return
|
}
|
syncJPushAliasWithCurrentUser()
|
})
|
}
|
if (typeof jpushModule.addNotificationListener === 'function') {
|
jpushModule.addNotificationListener((result) => {
|
handleJPushNotification(result)
|
})
|
}
|
return jpushModule
|
}
|
|
/**
|
* 安全执行插件调用，避免因参数签名差异直接中断业务。
|
*/
|
function tryInvoke(executor) {
|
try {
|
executor()
|
return true
|
} catch (error) {
|
return false
|
}
|
}
|
|
/**
|
* 根据极光通知内容决定是否执行页面跳转。
|
*/
|
function handleJPushNotification(result) {
|
const notificationEventType = normalizeOptionalText(result?.notificationEventType)
|
const messageId = normalizeOptionalText(result?.messageID || result?.messageId || result?.android?.msgId)
|
const extras = resolveJPushExtras(result)
|
const targetUrl = resolvePushTargetUrl(extras)
|
if (!targetUrl) {
|
return
|
}
|
if (!shouldHandlePushNavigation(notificationEventType, messageId)) {
|
return
|
}
|
navigateByPush(targetUrl)
|
}
|
|
/**
|
* 从极光回调中提取扩展参数，优先读取已解析 extras，缺失时兜底解析 Android 原始 JSON。
|
*/
|
function resolveJPushExtras(result) {
|
const extras = result?.extras
|
if (extras && typeof extras === 'object') {
|
return extras
|
}
|
const notificationExtras = normalizeOptionalText(result?.android?.notificationExtras)
|
if (!notificationExtras) {
|
return {}
|
}
|
try {
|
const parsedExtras = JSON.parse(notificationExtras)
|
return parsedExtras && typeof parsedExtras === 'object' ? parsedExtras : {}
|
} catch (error) {
|
return {}
|
}
|
}
|
|
/**
|
* 将推送类型映射到应用内页面。
|
*/
|
function resolvePushTargetUrl(extras) {
|
const noticeTypeCode = normalizeOptionalText(extras?.noticeTypeCode)
|
switch (noticeTypeCode) {
|
case 'MEMBER_EXPIRE_REMIND':
|
return '/pages/vip/vip'
|
case 'LIVE_REMIND':
|
return resolveLiveRemindTargetUrl(extras)
|
case 'ACTIVITY_NOTICE':
|
return resolveActivityNoticeTargetUrl(extras)
|
case 'ORDER_STATUS_UPDATE':
|
return resolveOrderStatusUpdateTargetUrl(extras)
|
case 'HEALTH_COURSE_VIDEO':
|
return resolveHealthCourseVideoTargetUrl(extras)
|
default:
|
return ''
|
}
|
}
|
|
/**
|
* 解析直播提醒跳转地址，直播详情页当前读取的是 id 参数。
|
*/
|
function resolveLiveRemindTargetUrl(extras) {
|
const courseId = normalizeOptionalText(extras?.courseId)
|
if (!courseId) {
|
return ''
|
}
|
return `/pages/liveDetail/liveDetail?id=${encodeURIComponent(courseId)}`
|
}
|
|
/**
|
* 解析活动通知跳转地址，活动详情页当前读取的是 id 参数。
|
*/
|
function resolveActivityNoticeTargetUrl(extras) {
|
const activityNoticeId = normalizeOptionalText(extras?.activityNoticeId)
|
if (!activityNoticeId) {
|
return ''
|
}
|
return `/pages/activityNotice/activityNoticeDetail?id=${encodeURIComponent(activityNoticeId)}`
|
}
|
|
/**
|
* 解析兑换订单状态变更跳转地址，明细页当前读取的是 orderId 参数。
|
*/
|
function resolveOrderStatusUpdateTargetUrl(extras) {
|
const orderId = normalizeOptionalText(extras?.orderId)
|
if (!orderId) {
|
return ''
|
}
|
return `/pages/myPatientExchangeItems/myPatientExchangeItems?orderId=${encodeURIComponent(orderId)}`
|
}
|
|
/**
|
* 解析养生课程视频更新跳转地址，课程详情页当前读取的是 id 参数。
|
*/
|
function resolveHealthCourseVideoTargetUrl(extras) {
|
const courseId = normalizeOptionalText(extras?.courseId)
|
if (!courseId) {
|
return ''
|
}
|
return `/pages/courseDetail/courseDetail?id=${encodeURIComponent(courseId)}`
|
}
|
|
/**
|
* 仅在点击通知或首次收到未处理通知时执行跳转，避免重复打开相同页面。
|
*/
|
function shouldHandlePushNavigation(notificationEventType, messageId) {
|
const normalizedEventType = normalizeOptionalText(notificationEventType)
|
const canNavigate = normalizedEventType === 'notificationOpened' ||
|
normalizedEventType === 'notificationClicked' ||
|
normalizedEventType === 'notificationArrived'
|
if (!canNavigate) {
|
return false
|
}
|
if (messageId && messageId === lastHandledPushMessageId) {
|
return false
|
}
|
lastHandledPushMessageId = messageId
|
return true
|
}
|
|
/**
|
* 根据页面栈状态执行推送跳转，避免在当前页重复打开。
|
*/
|
function navigateByPush(targetUrl) {
|
const currentPages = getCurrentPages()
|
const currentRoute = currentPages && currentPages.length > 0 ? currentPages[currentPages.length - 1].route || '' :
|
''
|
const normalizedTargetRoute = targetUrl.replace(/^\//, '').split('?')[0]
|
if (currentRoute === normalizedTargetRoute) {
|
return
|
}
|
uni.navigateTo({
|
url: targetUrl,
|
fail: () => {
|
uni.reLaunch({
|
url: targetUrl
|
})
|
}
|
})
|
}
|
|
/**
|
* 将未知值归一化为可安全使用的文本。
|
*/
|
function normalizeOptionalText(value) {
|
if (typeof value !== 'string') {
|
return ''
|
}
|
return value.trim()
|
}
|
