微信群二维码失效检测与动态更新系统的设计与实现

// groups 集合
{
  _id: "自动生成",
  name: "群名称",                    // String
  category: "建筑工程",              // String, 行业分类
  city: "成都",                     // String, 城市
  qrCodeUrl: "cloud://xxx.png",    // String, 二维码云存储地址
  status: "active",                 // String, active | expired | reported
  createdAt: Date,                 // Date, 创建时间
  updatedAt: Date,                 // Date, 最后更新时间
  expireAt: Date,                  // Date, 预计失效时间 (创建时间 + 7天)
  viewCount: 0,                    // Number, 查看次数
  reportCount: 0                   // Number, 用户举报次数
}

// cloudfunctions/checkQRCode/index.js
const cloud = require('wx-server-sdk')
cloud.init()

const db = cloud.database()
const _ = db.command

exports.main = async (event, context) => {
  const { groupId, qrCodeUrl } = event
  
  try {
    // 1. 从云存储下载二维码图片
    const fileResult = await cloud.downloadFile({
      fileID: qrCodeUrl
    })
    
    // 2. 调用微信开放能力的图像处理接口进行扫码检测
    // 注：此处使用云调用方式调用 img.scanQRCode
    const scanResult = await cloud.openapi.img.scanQRCode({
      imgUrl: qrCodeUrl,  // 或直接传递图片buffer
      scene: 1            // 1: 二维码
    })
    
    // 3. 根据返回结果判断二维码状态
    // 微信扫码接口返回的 status: 0-成功, 2-已取消, 3-已失效
    if (scanResult.status === 3) {
      // 二维码已失效，更新数据库状态
      await db.collection('groups').doc(groupId).update({
        data: {
          status: 'expired',
          updatedAt: new Date()
        }
      })
      return { valid: false, groupId }
    }
    
    // 4. 有效则更新检测时间
    await db.collection('groups').doc(groupId).update({
      data: {
        updatedAt: new Date(),
        status: 'active'
      }
    })
    
    return { valid: true, groupId }
    
  } catch (err) {
    console.error('检测失败:', err)
    // 检测异常时标记为待复查，不直接标记失效
    return { valid: null, groupId, error: err.message }
  }
}

{
  "permissions": {
    "openapi": [
      "img.scanQRCode"
    ]
  },
  "triggers": [
    {
      "name": "dailyCheck",
      "type": "timer",
      "config": "0 0 3 * * * *"   // 每天凌晨3点执行
    }
  ]
}

// cloudfunctions/batchCheck/index.js
const BATCH_SIZE = 20
const EXECUTION_LIMIT = 58000

exports.main = async (event, context) => {
  const { batchId, startOffset } = event
  
  // 1. 查询当前有效的群组（按创建时间排序）
  const total = await db.collection('groups')
    .where({ status: 'active' })
    .count()
  
  // 2. 分批获取
  const list = await db.collection('groups')
    .where({ status: 'active' })
    .skip(startOffset)
    .limit(BATCH_SIZE)
    .get()
  
  // 3. 并行检测
  const checkPromises = list.data.map(item => 
    checkQRCode(item._id, item.qrCodeUrl)
  )
  const results = await Promise.all(checkPromises)
  
  // 4. 统计并返回下一批的偏移量
  const expiredCount = results.filter(r => r.valid === false).length
  const nextOffset = startOffset + BATCH_SIZE
  
  return {
    batchId,
    processed: list.data.length,
    expired: expiredCount,
    nextOffset,
    hasMore: nextOffset < total.total
  }
}

// 前端：用户点击失效反馈
async function reportExpired(groupId) {
  const result = await wx.cloud.callFunction({
    name: 'reportExpired',
    data: { groupId }
  })
  
  if (result.success) {
    wx.showToast({ title: '反馈成功，感谢您的贡献' })
  }
}

// 云函数：处理失效反馈
exports.main = async (event, context) => {
  const { groupId } = event
  
  // 1. 增加举报计数
  await db.collection('groups').doc(groupId).update({
    data: {
      reportCount: _.inc(1),
      updatedAt: new Date()
    }
  })
  
  // 2. 当举报次数达到阈值(3次)时，自动下架
  const group = await db.collection('groups').doc(groupId).get()
  if (group.data.reportCount >= 3) {
    await db.collection('groups').doc(groupId).update({
      data: { status: 'expired' }
    })
  }
  
  return { success: true }
}