feat: parse music/subscribe/kefu appmsg cards into read-only share/system

2026-10-04 03:01:42 +08:00 · 2026-09-24 19:54:24 +08:00
parent 264d25b539
commit 7864cf001f
2 changed files with 205 additions and 0 deletions
@@ -550,6 +550,15 @@ function parseShareMessage(content: string): ParsedContent {
  if (/<productitem\b/i.test(content) && !extractXmlValue(content, 'title')) {
    return parseProductItem(content)
  }
+  if (looksLikeMusicShare(content)) {
+    return parseMusicShareCard(content)
+  }
+  if (looksLikeSubscribeCard(content)) {
+    return parseSubscribeCard(content)
+  }
+  if (looksLikeKefuCard(content)) {
+    return parseKefuCard(content)
+  }
  if (appMsgType === '19') {
    return parseForwardBundle(content)
  }
@@ -631,6 +640,9 @@ function parseShareMessage(content: string): ParsedContent {

  if (!title && !url) {
    if (/<productitem\b/i.test(content)) return parseProductItem(content)
+    if (looksLikeMusicShare(content)) return parseMusicShareCard(content)
+    if (looksLikeSubscribeCard(content)) return parseSubscribeCard(content)
+    if (looksLikeKefuCard(content)) return parseKefuCard(content)
    return { type: 'unknown', raw: content }
  }

@@ -774,6 +786,137 @@ function parseFriendVerifyMessage(content: string): ParsedContent {
  return { type: 'system', content: label || '好友验证消息', raw: content }
 }

+function looksLikeMusicShare(content: string): boolean {
+  return /songalbumurl|songlyric|musicShareItem|tingListenItem|ListenItem|music_share_item|musicurl|<songlyri|<songalbu/i.test(
+    content
+  )
+}
+
+function looksLikeSubscribeCard(content: string): boolean {
+  return /subscribeMessage|subscribe_msg|SubscribeMsg|updatablemsg|wadynamicpageinf|OnSubscriptionCustom/i.test(
+    content
+  )
+}
+
+function looksLikeKefuCard(content: string): boolean {
+  return /opencustomerservicemsg|wa_app_kefu_message|kefumenu|kf_order|kf_user_|ChatKfTemplate|AppReaderTemplate|template_header/i.test(
+    content
+  )
+}
+
+/** 音乐 / 听歌分享（`musicShareItem` / `ListenItem` / `songalbumurl`）→ 只读 share。 */
+function parseMusicShareCard(content: string): ParsedContent {
+  const decoded = decodeXmlEntities(stripChatroomPrefix(content))
+  const title =
+    extractXmlValue(decoded, 'title') ||
+    extractXmlValue(decoded, 'songname') ||
+    extractXmlValue(decoded, 'musicTitle') ||
+    '音乐分享'
+  const des =
+    extractXmlValue(decoded, 'des') ||
+    extractXmlValue(decoded, 'singername') ||
+    extractXmlValue(decoded, 'albumname') ||
+    undefined
+  const url =
+    decodeXmlUrl(
+      extractXmlValue(decoded, 'url') ||
+        extractXmlValue(decoded, 'musicurl') ||
+        extractXmlValue(decoded, 'streamweburl') ||
+        extractXmlValue(decoded, 'weburl')
+    ) || ''
+  const appname =
+    extractXmlValue(decoded, 'appname') ||
+    extractXmlValue(decoded, 'publisher') ||
+    (looksLikeListenItem(content) ? '听一听' : '音乐')
+  return {
+    type: 'share',
+    title,
+    des,
+    url,
+    appname,
+    typeVal: extractAppMsgType(content) || 'music'
+  }
+}
+
+function looksLikeListenItem(content: string): boolean {
+  return /tingListenItem|ListenItem|MMLISTEN_ITEM_TYPE/i.test(content)
+}
+
+/**
+ * 订阅号 / 可更新消息模板（`subscribeMessage` / `updatablemsg`）→ 只读 share。
+ * 模板头 `template_header` / `template_detail` 作标题与摘要。
+ */
+function parseSubscribeCard(content: string): ParsedContent {
+  const decoded = decodeXmlEntities(stripChatroomPrefix(content))
+  const title =
+    extractXmlValue(decoded, 'template_header') ||
+    extractXmlValue(decoded, 'title') ||
+    extractXmlValue(decoded, 'templatetitle') ||
+    '订阅消息'
+  const des =
+    extractXmlValue(decoded, 'template_detail') ||
+    extractXmlValue(decoded, 'des') ||
+    extractXmlValue(decoded, 'digest') ||
+    undefined
+  const url =
+    decodeXmlUrl(
+      extractXmlValue(decoded, 'url') ||
+        extractXmlValue(decoded, 'jumpUrl') ||
+        extractXmlValue(decoded, 'weburl')
+    ) || ''
+  return {
+    type: 'share',
+    title,
+    des,
+    url,
+    appname: extractXmlValue(decoded, 'appname') || '订阅消息',
+    typeVal: extractAppMsgType(content) || 'subscribe'
+  }
+}
+
+/**
+ * 客服 / 门店模板卡（`opencustomerservicemsg` / `wa_app_kefu_message` / `kefumenu`）
+ * → 只读 share；无 title 时退化为 system 文案，避免 unknown 黑块。
+ */
+function parseKefuCard(content: string): ParsedContent {
+  const decoded = decodeXmlEntities(stripChatroomPrefix(content))
+  const title =
+    extractXmlValue(decoded, 'template_header') ||
+    extractXmlValue(decoded, 'title') ||
+    extractXmlValue(decoded, 'kf_title') ||
+    extractXmlValue(decoded, 'templatetitle')
+  const des =
+    extractXmlValue(decoded, 'template_detail') ||
+    extractXmlValue(decoded, 'kf_order_text') ||
+    extractXmlValue(decoded, 'des') ||
+    extractXmlValue(decoded, 'content')
+  const url =
+    decodeXmlUrl(
+      extractXmlValue(decoded, 'url') ||
+        extractXmlValue(decoded, 'jumpUrl') ||
+        extractXmlValue(decoded, 'weburl')
+    ) || ''
+  const appname =
+    extractXmlValue(decoded, 'kf_user_name') ||
+    extractXmlValue(decoded, 'appname') ||
+    '客服消息'
+  if (!title && !des) {
+    return {
+      type: 'system',
+      content: normalizeSystemText(decoded.replace(/<[^>]+>/g, ' ')) || '客服消息',
+      raw: content
+    }
+  }
+  return {
+    type: 'share',
+    title: title || '客服消息',
+    des: des || undefined,
+    url: url || '',
+    appname,
+    typeVal: extractAppMsgType(content) || 'kefu'
+  }
+}
+
 function parseShareArticles(content: string): ShareArticle[] {
  if (!/<mmreader\b/i.test(content)) return []
  const articles = Array.from(
@@ -281,6 +281,68 @@ describe('message parser', () => {
    })
  })

+  it('parses music share cards from song/album fields', () => {
+    const xml = [
+      '<msg><appmsg>',
+      '<type>3</type>',
+      '<title><![CDATA[晴天]]></title>',
+      '<des><![CDATA[周杰伦]]></des>',
+      '<url><![CDATA[https://music.example/song]]></url>',
+      '<songalbumurl><![CDATA[https://music.example/cover]]></songalbumurl>',
+      '<songlyric><![CDATA[故事的小黄花]]></songlyric>',
+      '</appmsg></msg>'
+    ].join('')
+    const parsed = parseMessageContent(xml, 49)
+    expect(parsed).toMatchObject({
+      type: 'share',
+      title: '晴天',
+      des: '周杰伦',
+      url: 'https://music.example/song',
+      appname: '音乐',
+      typeVal: '3'
+    })
+  })
+
+  it('parses subscribe template cards', () => {
+    const clean = [
+      '<msg><appmsg>',
+      '<template_header><![CDATA[服务通知]]></template_header>',
+      '<template_detail><![CDATA[您的订单已发货]]></template_detail>',
+      '<url><![CDATA[https://mp.example/notice]]></url>',
+      '<updatablemsg></updatablemsg>',
+      '</appmsg></msg>'
+    ].join('')
+    const parsed = parseMessageContent(clean, 49)
+    expect(parsed).toMatchObject({
+      type: 'share',
+      title: '服务通知',
+      des: '您的订单已发货',
+      appname: '订阅消息',
+      typeVal: 'subscribe'
+    })
+  })
+
+  it('parses kefu template cards and falls back to system text', () => {
+    const card = [
+      '<msg><appmsg>',
+      '<template_header><![CDATA[店铺客服]]></template_header>',
+      '<template_detail><![CDATA[点击查看订单]]></template_detail>',
+      '<opencustomerservicemsg></opencustomerservicemsg>',
+      '</appmsg></msg>'
+    ].join('')
+    expect(parseMessageContent(card, 49)).toMatchObject({
+      type: 'share',
+      title: '店铺客服',
+      des: '点击查看订单',
+      typeVal: 'kefu'
+    })
+    const menu = '<msg><appmsg><kefumenu></kefumenu></appmsg></msg>'
+    expect(parseMessageContent(menu, 49)).toMatchObject({
+      type: 'system',
+      content: '客服消息'
+    })
+  })
+
  it('parses transfer wcpayinfo fields (type 2000)', () => {
    // 2026-09 真机转账采样字段名（含微信原文 transcationid 拼写）
    const xml = [