Merge remote-tracking branch 'origin/dev_NEW_pro' into dev_鹤壁_强信宇_pro

yuan

2026-05-22 fbe3c8e6bc44f8ac613517df05432f620bdfbf31

 src/components/AIChatSidebar/index.vue

@@ -227,6 +227,12 @@
                      :id="`ai-chart-${index}-${key}`"
                  ></div>
                </div>
                <div
                    v-else-if="message.chartMarkdownParseFailed"
                    class="chart-empty-state"
                >
                  图表解析失败，请稍后重试。
                </div>

                <!-- 表格内容 -->
                <div v-if="message.type === 'todo_list' && message.tableData" class="table-wrapper">
@@ -1007,7 +1013,7 @@
  sales_customer_profile_list: '客户档案',
  sales_quotation_list: '销售报价',
  sales_ledger_list: '销售台账',
  sales_return_list: '销售退货',
  sales_return_list: '销售退款/回款记录',
  sales_customer_interaction_list: '客户往来',
  sales_shipping_list: '发货台账',
  sales_dashboard: '销售指标统计',
@@ -1016,6 +1022,7 @@
}
const purchaseTypeLabelMap = {
  purchase_material_rank: '采购物料金额排行',
  purchase_stats: '采购统计',
  purchase_pending_payment_list: '待付款采购单'
}
const financialStructuredTypeSet = new Set([
@@ -1108,6 +1115,26 @@
  stockQty: '库存量'
}
Object.assign(structuredFieldLabelMap, {
  refundId: '退款/回款单号',
  collectionNumber: '收款单号',
  collectionAmount: '收款金额',
  actualAmount: '收款金额(兼容)',
  customerId: '客户ID',
  salesLedgerId: '销售台账ID',
  projectName: '项目名称',
  receiptPaymentDate: '收付款日期',
  receiptPaymentAmount: '收付款金额',
  receiptPaymentType: '收付款类型',
  registrant: '登记人',
  returnAmount: '回款金额汇总',
  totalReceiptAmount: '收款总额',
  customerCount: '客户数',
  paidAmount: '已付款金额',
  contractAmount: '合同金额',
  paymentCount: '付款笔数',
  invoiceCount: '发票笔数',
  paymentAmount: '付款金额',
  invoiceAmount: '发票金额',
  customerName: '客户名称',
  riskLevel: '风险等级',
  riskScore: '风险评分',
@@ -1554,12 +1581,41 @@
  return items.filter(item => isPlainObject(item))
}

const normalizeSalesReturnListItems = (items = []) => {
  return normalizeSalesListItems(items).map((item) => {
    const collectionAmount = item.collectionAmount ?? item.actualAmount
    const collectionNumber = item.collectionNumber || item.refundId || ''
    return {
      ...item,
      refundId: item.refundId || collectionNumber,
      collectionNumber,
      collectionAmount: collectionAmount ?? 0,
      actualAmount: item.actualAmount ?? collectionAmount ?? 0
    }
  })
}

const normalizeSalesTypeListItems = (type = '', items = []) => {
  if (type === 'sales_return_list') {
    return normalizeSalesReturnListItems(items)
  }
  return normalizeSalesListItems(items)
}

const inferSalesColumnsByType = (type = '', listItems = []) => {
  const columns = inferSalesColumns(listItems)
  if (type === 'sales_return_list') {
    return columns.filter(column => column !== 'actualAmount')
  }
  return columns
}

const buildSalesStructuredData = (parsedData) => {
  const type = String(parsedData?.type || '')
  if (!salesStructuredTypeSet.has(type)) return null

  const rawData = isPlainObject(parsedData?.data) ? parsedData.data : {}
  const listItems = normalizeSalesListItems(rawData.items)
  const listItems = normalizeSalesTypeListItems(type, rawData.items)
  const topCustomers = normalizeSalesListItems(rawData.topCustomers)
  const contractTrend = normalizeSalesListItems(rawData.contractTrend)

@@ -1567,7 +1623,7 @@
    type,
    summaryEntries: normalizeManufacturingSummaryEntries(parsedData?.summary),
    listItems,
    columns: inferSalesColumns(listItems),
    columns: inferSalesColumnsByType(type, listItems),
    topCustomers,
    topCustomerColumns: inferSalesColumns(topCustomers),
    contractTrend,
@@ -2062,6 +2118,7 @@
          purchaseData: null,
          purchaseIntentData: null,
          financeData: null,
          chartMarkdownParseFailed: false,
          localUploadFiles: isUser ? mapHistoryFilePathsToSnapshots(msg.filePaths, uuid.value, idx) : []
        }

@@ -2311,6 +2368,7 @@
  messageObj.purchaseData = null
  messageObj.purchaseIntentData = null
  messageObj.financeData = null
  messageObj.chartMarkdownParseFailed = false

  if (isPurchaseIntentNotRecognized) {
    messageObj.purchaseIntentData = normalizePurchaseIntentNotRecognizedData(parsedData)
@@ -2399,6 +2457,8 @@
    if (parsedData.type === 'sales_customer_churn_risk') return '已为您生成客户流失风险分析。'
    if (parsedData.type === 'sales_collection_quote_strategy') return '已为您生成回款与报价策略建议。'
    if (parsedData.type === 'sales_dashboard') return '已为您生成销售指标统计。'
    if (parsedData.type === 'sales_return_list') return '已返回销售退款/回款记录。'
    if (parsedData.type === 'sales_customer_interaction_list') return '已返回客户往来数据。'
    return '已返回销售查询结果。'
  }
  if (manufacturingStructuredTypeSet.has(parsedData.type)) {
@@ -2411,6 +2471,27 @@
  if (String(parsedData.type || '').startsWith('purchase_')) return '已返回采购查询结果。'
  if (parsedData.charts && Object.keys(parsedData.charts).length > 0) return '已为您生成分析图表。'
  return '正在为您展示分析结果...'
}

const resolveStructuredDescription = (parsedData) => {
  if (!parsedData) return ''
  if (parsedData.action === 'confirm_required') {
    return getPurchaseConfirmDescription(parsedData)
  }

  const description = String(parsedData.description || '').trim()
  if (!description) return ''

  if (parsedData.type === 'sales_customer_interaction_list') {
    if (description === 'no_customer_interactions') return '该时间范围暂无客户往来记录。'
    if (description === 'ok') return '已返回客户往来数据。'
  }

  if (description === 'ok' || description === 'success') {
    return getStructuredFallbackText(parsedData)
  }

  return description
}

const buildPurchaseMaterialRankCharts = (parsedData) => {
@@ -3542,7 +3623,8 @@
    salesData: null,
    purchaseData: null,
    purchaseIntentData: null,
    financeData: null
    financeData: null,
    chartMarkdownParseFailed: false
  })

  outputState.value[botMsgIndex] = {
@@ -3598,6 +3680,7 @@
    if (extracted) {
      applyStructuredMessageData(currentMsg, extracted.data, botMsgIndex, !outputState.value[botMsgIndex].hasRenderedChart)
    }
    currentMsg.htmlContent = convertStreamOutput(currentMsg.content || '', botMsgIndex)

    // 最终解析确保图表渲染
    if (currentMsg.chartOptions && !outputState.value[botMsgIndex].hasRenderedChart) {
@@ -3671,7 +3754,8 @@
    salesData: null,
    purchaseData: null,
    purchaseIntentData: null,
    financeData: null
    financeData: null,
    chartMarkdownParseFailed: false
  }
  messages.value.push(botMsg)

@@ -3721,6 +3805,7 @@
    if (extracted) {
      applyStructuredMessageData(currentMsg, extracted.data, botMsgIndex)
    }
    currentMsg.htmlContent = convertStreamOutput(currentMsg.content || '', botMsgIndex)
  }).catch(err => {
    if (err.name === 'CanceledError' || err.name === 'AbortError') {
      console.log('Request aborted by user')
@@ -3764,6 +3849,126 @@
      .replace(/\n/g, '<br>')
}

const localChartMarkdownImagePattern = /!\[[^\]]*]\((https?:\/\/local\/generate_chart\?[^)\s]+)\)/gi

const parseLocalChartOptionText = (optionText = '') => {
  const text = String(optionText || '').trim()
  if (!text) return null

  const parseCandidates = [text]
  try {
    const decoded = decodeURIComponent(text)
    if (decoded && decoded !== text) {
      parseCandidates.push(decoded)
    }
  } catch (err) {
    // Keep original text candidate.
  }

  for (const candidate of parseCandidates) {
    try {
      const parsed = JSON.parse(candidate)
      if (isPlainObject(parsed)) {
        return parsed
      }
    } catch (err) {
      continue
    }
  }

  return null
}

const parseLocalChartOptionFromUrl = (urlText = '') => {
  try {
    const url = new URL(String(urlText || '').trim())
    if (String(url.hostname || '').toLowerCase() !== 'local' || !String(url.pathname || '').includes('/generate_chart')) {
      return null
    }
    const optionText = url.searchParams.get('options')
    return parseLocalChartOptionText(optionText)
  } catch (err) {
    return null
  }
}

const extractLocalChartMarkdown = (text = '') => {
  const sourceText = String(text || '')
  if (!sourceText) {
    return {
      cleanedText: '',
      hasLocalChartMarkdown: false,
      chartOptions: null,
      parseFailed: false
    }
  }

  let hasLocalChartMarkdown = false
  let chartIndex = 0
  const chartOptions = {}

  const cleanedText = sourceText.replace(localChartMarkdownImagePattern, (fullMatch, chartUrl) => {
    hasLocalChartMarkdown = true
    const option = parseLocalChartOptionFromUrl(chartUrl)
    if (option) {
      chartOptions[`markdownChart_${chartIndex++}`] = option
    }
    return ''
  })

  const normalizedText = cleanedText
      .replace(/\n[ \t]*\n[ \t]*\n+/g, '\n\n')
      .trim()
  const hasParsedCharts = Object.keys(chartOptions).length > 0

  return {
    cleanedText: normalizedText,
    hasLocalChartMarkdown,
    chartOptions: hasParsedCharts ? chartOptions : null,
    parseFailed: hasLocalChartMarkdown && !hasParsedCharts
  }
}

const applyLocalChartMarkdownFallback = (displayText, msgIndex) => {
  const messageObj = messages.value[msgIndex]
  if (!messageObj || messageObj.isUser) return displayText

  const {
    cleanedText,
    hasLocalChartMarkdown,
    chartOptions,
    parseFailed
  } = extractLocalChartMarkdown(displayText)

  if (!hasLocalChartMarkdown) {
    return displayText
  }

  if (chartOptions) {
    messageObj.chartOptions = chartOptions
    messageObj.chartRenderReady = true
    messageObj.chartMarkdownParseFailed = false

    const streamState = outputState.value[msgIndex]
    if (!streamState || !streamState.hasRenderedChart) {
      renderCharts(msgIndex, chartOptions)
      if (streamState) {
        streamState.hasRenderedChart = true
      }
    }

    return cleanedText || '已为您生成分析图表。'
  }

  if (!messageObj.chartOptions || !messageObj.chartRenderReady) {
    messageObj.chartOptions = null
    messageObj.chartRenderReady = false
    messageObj.chartMarkdownParseFailed = parseFailed
  }

  return cleanedText || '图表解析失败，请稍后重试。'
}

const convertStreamOutput = (output, msgIndex) => {
  if (!output) return ''
  const state = outputState.value[msgIndex]
@@ -3790,10 +3995,9 @@
      display = ''
    }

    if (parsed.description) {
      display = parsed.action === 'confirm_required'
        ? getPurchaseConfirmDescription(parsed)
        : parsed.description
    const resolvedDescription = resolveStructuredDescription(parsed)
    if (resolvedDescription) {
      display = resolvedDescription
    }

    if (!display) {
@@ -3812,10 +4016,9 @@
          display = ''
        }

        if (parsed.description) {
          display = parsed.action === 'confirm_required'
            ? getPurchaseConfirmDescription(parsed)
            : parsed.description
        const resolvedDescription = resolveStructuredDescription(parsed)
        if (resolvedDescription) {
          display = resolvedDescription
        }

        if (!display) {
@@ -3831,6 +4034,7 @@
    }
  }

  display = applyLocalChartMarkdownFallback(display, msgIndex)
  let html = convertTextToHtml(display)

  // 还原代码块
@@ -4813,6 +5017,18 @@
  margin-bottom: 12px;
}

.chart-empty-state {
  margin-top: 12px;
  width: 100%;
  border-radius: 10px;
  border: 1px dashed rgba(148, 163, 184, 0.6);
  background: #f8fafc;
  color: #64748b;
  font-size: 13px;
  line-height: 1.6;
  padding: 12px;
}

.table-wrapper {
  margin-top: 12px;
  background: #fff;