微信小程序--云开发支付闭环

// pages/index/details.js
const app = getApp();
const db = wx.cloud.database();
var watcher = null
Page({

  /**
   * 页面的初始数据
   */
  data: {
    
  },
  //付费解锁
  payUnlock() {
    var that = this;
   
    this.setData({
      vis: true
    })
    //用户ID 即为OPENID
    let userid = this.data.selfcard._id;
    wx.cloud.callFunction({
      name: 'userpay',
      data: {
        fee: 1,
        paydata: {
          userid
        }
      },
      success: res => {
        console.log(res)
        //统一下单云函数中需要返回侦听器 需要的记录id
        that.payWatcher(res.result.docid);
        that.setData({
          vis: false
        })     
        //根据统一下单参数 请求支付接口
        const payment = res.result.payment
        wx.requestPayment({
          ...payment,
          success(ans) {
            console.log(ans)
          },
          fail(ans) {
            that.setData({
              errMsg: '调用支付失败'
            })
          }
        })
      }
    })
  },
  payWatcher(docid){
    var that = this;
    //为用户支付记录表设置侦听器，侦听docid信息的变动
    this.watcher =  db.collection('USERPAYLOG').doc(docid).watch({
      onChange: async function (snapshot) {
        //只打印变动的信息
        // console.log(snapshot)
        if (snapshot.docChanges.length != 0) {
          console.log(snapshot.docChanges)
          let paydoc = snapshot.docChanges[0].doc;
          //侦听到支付成功
          if(paydoc.paystatus == 1){
            that.setData({
              succMsg:'支付成功',
              locked:false,
              bottom:0
            })
          }
          // await that.watcher.close();
        }
      },
      onError: function (err) {
        console.error('the watch closed because of error', err)
      }
    })
  },
  /**
   * 生命周期函数--监听页面加载
   */
  onLoad: function (options) {

  },
  /**
   * 生命周期函数--监听页面卸载
   */
  onUnload: function () {
    try {
      this.watcher.close();
    } catch (error) {
      console.log('暂未启动支付侦听器')
    }
  }
})

const cloud = require('wx-server-sdk')
//需要在此处修改你的云环境ID
cloud.init({
  env: ''
})
const db = cloud.database();
const _ = db.command;
// 云函数入口函数
exports.main = async (event, context) => {
  const wxContext = cloud.getWXContext()
  var openid = event.openid || wxContext.OPENID
  //获取统一下单金额
  var fee = parseInt(event.fee);
  let paydata = event.paydata;
  //生成订单号
  let tradeno = GetTradeNo();
  //调用统一下单接口
  const res = await cloud.cloudPay.unifiedOrder({
    //填写你的商户主体信息 例如 xx商贸
    "body": "",
    "outTradeNo": tradeno,
    "spbillCreateIp": "127.0.0.1",
    //填写你的商户ID -- 可在云开发控制台中绑定获得（上图所示）
    "subMchId": "",
    "totalFee": fee,
    //填写你的云环境ID
    "envId": "",
    //填写你的回调函数名称
    "functionName": "userpaynotify"
  })
  console.log(res)
  res.outTradeNo = tradeno
  res.totalFee = fee
  //支付状态 0 为未支付
  paydata.tradeno = tradeno
  paydata.paystatus = 0
  paydata.totalfee = fee
  paydata.openid = openid
  paydata.paytime = TimeCode()
  //统一下单shuju
  paydata.uniOrder = res
  //拦截处理 为保持数据库字段一致性
  if (res.returnCode == 'SUCCESS' && res.resultCode == 'SUCCESS') {
    //在云数据库中写入未支付的订单信息
    let tdata = await db.collection('USERPAYLOG').add({
      data: paydata
    })
    console.log(tdata)
    //将该记录ID携带返回给小程序端
    res.docid = tdata._id;
    return res;
  }else{
    return res;
  }
}

function GetTradeNo() {
  var outTradeNo = ""; //订单号
  for (var i = 0; i < 6; i++) //6位随机数，用以加在时间戳后面。
  {
    outTradeNo += Math.floor(Math.random() * 10);
  }
  outTradeNo = "COP" + new Date().getTime() + outTradeNo; //时间戳，用来生成订单号。
  return outTradeNo;
}

function TimeCode() {
  var date = new Date();
  var year = date.getFullYear()
  var month = date.getMonth() + 1
  var day = date.getDate()

  var hour = date.getHours()
  var minute = date.getMinutes()
  var second = date.getSeconds()

  return [year, month, day].map(formatNumber).join('-') + ' ' + [hour, minute, second].map(formatNumber).join(':')
}

function formatNumber(n) {
  n = n.toString()
  return n[1] ? n : '0' + n
}

const cloud = require('wx-server-sdk')
//填写你的云环境ID
cloud.init({
  env: ''
})
const db = cloud.database();
const _ = db.command;
// 云函数入口函数
exports.main = async (event, context) => {

  console.log('支付成功回调函数触发')
  console.log(event)
  let tradeno = event.outTradeNo;
  try {
    //修改数据库中订单状态 为已支付
    db.collection('USERPAYLOG').where({
      tradeno:tradeno
    }).update({
      data:{
        paystatus:1
      }
    })
  } catch (error) {
    return {
      errmsg: 'SERVER_ERROR',
      errcode: -1
    }
  }
  return {
    errmsg: 'SUCCESS',
    errcode: 0
  }
}

{
	appid: '',

	bankType: 'OTHERS',

	cashFee: 1,

	feeType: 'CNY',

	isSubscribe: 'N',

	mchId: '',

	nonceStr: '',

	openid: '',

	outTradeNo: '',

	resultCode: 'SUCCESS',

	returnCode: 'SUCCESS',

	subAppid: '',

	subIsSubscribe: 'N',

	subMchId: '',

	subOpenid: '',

	timeEnd: '',

	totalFee: 1,

	tradeType: 'JSAPI',

	transactionId: '',

	userInfo:

	{
		appId: '',

		openId: ''
	}
}