# 消息推送处理虚拟支付回调

// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
})

// 云函数入口函数
exports.main = async (event, context) => {
  console.log('收到虚拟支付回调：', event)

  try {
    const { Event, OpenId, OutTradeNo } = event

    // 根据不同的事件类型处理
    switch (Event) {
      case 'xpay_goods_deliver_notify':
        // TODO: 处理道具发货
        // 1. 检查订单是否已处理（幂等性）
        // 2. 发放道具到用户账户
        // 3. 更新订单状态
        break

      case 'xpay_coin_pay_notify':
        // TODO: 处理代币支付
        break

      case 'xpay_refund_notify':
        // TODO: 处理退款
        break

      case 'xpay_complaint_notify':
        // TODO: 处理用户投诉
        break

      case 'xpay_subscribe_signing_result_notify':
        // TODO: 处理订阅签约结果
        break

      case 'xpay_subscribe_pay_fail_notify':
        // TODO: 处理订阅支付失败
        break

      case 'xpay_subscribe_ios_refund_query_notify':
        // 处理 iOS 订阅退款问询（必须在 3 秒内响应，返回格式不同）
        // 根据业务规则判断是否建议退款
        return {
          result_code: 0,  // 0-建议退款，1-拒绝退款
          result_info: '建议退款',
          evidence: '订单未发货，建议退款'  // 必填，说明决策依据
        }

      default:
        console.log('未知事件类型：', Event)
    }

    // 返回成功响应
    return {
      ErrCode: 0,
      ErrMsg: 'success'
    }

  } catch (error) {
    console.error('处理回调失败：', error)
    // 返回错误，微信会自动重试
    return {
      ErrCode: -1,
      ErrMsg: error.message
    }
  }
}

wx.requestVirtualPayment({
  // 支付参数（需转为 JSON 字符串）
  signData: JSON.stringify({
    offerId: '123',               // 米大师侧申请的应用 id
    buyQuantity: 1,               // 购买数量
    env: 0,                       // 0：正式环境，1：沙箱环境
    currencyType: 'CNY',          // 币种
    productId: 'product_001',     // 道具 ID（道具直购时必填）
    goodsPrice: 100,              // 道具单价，单位：分（道具直购时必填）
    outTradeNo: 'ORDER_' + Date.now(),  // 业务订单号（8-32位）
    attach: 'extra_data'          // 透传数据，发货通知时会返回
  }),
  paySig: 'xxx',      // 支付签名，详见签名文档
  signature: 'xxx',   // 用户态签名，详见签名文档
  mode: 'short_series_goods',  // 道具直购
  success: (res) => {
    console.log('支付成功', res)
    // 注意：不要在此处发货！
    // 支付成功后，微信会推送回调到云函数，在云函数中发货
  },
  fail: ({ errMsg, errCode }) => {
    console.error('支付失败', errMsg, errCode)
  }
})

wx.requestVirtualPayment({
  signData: JSON.stringify({
    offerId: '123',
    buyQuantity: 100,       // 充值代币数量
    env: 0,
    currencyType: 'CNY',
    outTradeNo: 'COIN_' + Date.now(),
    attach: 'coin_recharge'
  }),
  paySig: 'xxx',
  signature: 'xxx',
  mode: 'short_series_coin',  // 代币充值
  success: (res) => {
    console.log('充值成功', res)
  },
  fail: ({ errMsg, errCode }) => {
    console.error('充值失败', errMsg, errCode)
  }
})

// 正确的返回格式
return {
  ErrCode: 0,
  ErrMsg: 'success'
}

// 使用订单号作为唯一标识，避免重复处理
const order = await db.collection('virtual_orders').where({
  bill_no: bill_no
}).get()

if (order.data.length > 0 && order.data[0].status === 'delivered') {
  console.log('订单已处理，跳过')
  return {
    ErrCode: 0,
    ErrMsg: 'success'
  }
}

// iOS 退款问询响应格式
return {
  result_code: 0,           // 0-建议退款，1-拒绝退款
  result_info: '建议退款',   // 结果描述
  evidence: '订单未发货，建议退款'  // 决策依据（必填）
}

// 其他虚拟支付回调的响应格式
return {
  ErrCode: 0,
  ErrMsg: 'success'
}

// 好的 evidence 示例
evidence: '订单未发货，建议退款'
evidence: '用户已使用 100 个道具，累计消耗 80%，不建议退款'
evidence: '用户已激活 VIP 权益并使用 15 天，不建议退款'

// 不好的 evidence 示例
evidence: '不同意'  // 过于简单
evidence: ''        // 空字符串

// 云函数：queryOrderStatus
const cloud = require('wx-server-sdk')
cloud.init()

exports.main = async (event, context) => {
  const { bill_no } = event

  // 调用查询订单接口
  // 注意：需要自行实现 HTTP 请求和签名逻辑
  const result = await queryOrderFromWechat(bill_no)

  if (result.order_status === 'paid') {
    // 发货
    await deliverGoods(bill_no)
  }

  return result
}