小程序 AI 能力集成实战

// 小程序端：拍照后调用 OCR 服务
async function recognizeBill(filePath) {
  const res = await wx.serviceMarket.invokeService({
    service: 'ocr-bill',
    api: 'recognize',
    data: {
      img_url: filePath
    },
    clientMsgId: 'bill_ocr_' + Date.now()
  });

  const { errCode, data } = res;
  if (errCode === 0) {
    return parseBillFields(data.items);
  }
  throw new Error('OCR 识别失败：' + errCode);
}

wx.chooseMedia 选图
    ↓ wx.compressImage 压缩（限制 2M 以内）
服务端接收图片
    ↓ 服务端调用 OCR 服务（可复用 token）
OCR 结果回传客户端渲染

// 小程序端：压缩后上传
async function uploadForOcr(filePath) {
  const { tempFilePath } = await wx.compressImage({
    src: filePath,
    quality: 80
  });

  return new Promise((resolve, reject) => {
    wx.uploadFile({
      url: 'https://api.example.com/ocr',
      filePath: tempFilePath,
      name: 'image',
      success: (res) => resolve(JSON.parse(res.data)),
      fail: reject
    });
  });
}

// 小程序端：录制语音
const recorder = wx.getRecorderManager();

function startRecord() {
  recorder.start({
    duration: 60000,
    format: 'mp3',
    sampleRate: 16000,
    numberOfChannels: 1
  });
}

recorder.onStop((res) => {
  uploadForAsr(res.tempFilePath);   // 上传到服务端做识别
});

function uploadForAsr(filePath) {
  wx.uploadFile({
    url: 'https://api.example.com/asr',
    filePath,
    name: 'audio',
    success: (res) => {
      const data = JSON.parse(res.data);
      this.setData({ transcript: data.text });
    }
  });
}

function playTts(text) {
  const audio = wx.createInnerAudioContext();
  audio.src = 'https://api.example.com/tts?text=' + encodeURIComponent(text);
  audio.play();
  audio.onEnded(() => audio.destroy());
}

小程序端 → BFF/服务端 → 大模型 API
    （鉴权）     （持密钥、限流）

// 服务端：大模型调用封装（含限流与配额）
const LIMIT = { perUser: 20, perMinute: 5 };

async function chatCompletion(ctx, messages) {
  const key = 'llm_quota:' + ctx.openid;
  const used = await redis.incr(key);
  if (used === 1) redis.expire(key, 86400);

  if (used > LIMIT.perUser) {
    throw bizError(40001, '今日对话次数已达上限');
  }

  // 持密钥调用大模型
  const resp = await fetch(LLM_ENDPOINT, {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer ' + process.env.LLM_API_KEY,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      model: 'qwen-max',
      messages,
      stream: ctx.stream === true
    })
  });

  return resp;
}

// 服务端：系统提示词 + 会话上下文
function buildMessages(userId, userInput) {
  const history = sessionStore.get(userId);   // 最近 10 轮
  return [
    { role: 'system', content: '你是一个专业的小程序智能助手，回答简洁、准确。' },
    ...history,
    { role: 'user', content: userInput }
  ];
}

// 小程序端：通过 WebSocket 接收流式结果
const socket = wx.connectSocket({
  url: 'wss://api.example.com/llm/stream'
});

socket.onMessage((res) => {
  const chunk = JSON.parse(res.data).delta;
  this.setData({
    answer: this.data.answer + chunk
  });
});

// 展示层兜底
function decorateAnswer(text) {
  const warnings = detectRiskyClaims(text);   // 命中金额/日期等
  return {
    text,
    disclaimer: warnings.length > 0 ? '以上内容由 AI 生成，请以官方信息为准' : ''
  };
}

用户输入 → 输入过滤（防注入、防敏感）
大模型生成 → 内容安全服务检测（文本+图片）
    ↓ 通过
回传客户端 → 客户端本地兜底拦截

// 服务端：输出内容安全检测
async function checkContent(text) {
  const res = await securityService.check({ content: text });
  if (res.risky) {
    throw bizError(50002, '内容涉及违规，已被拦截');
  }
  return text;
}