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

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

const db = cloud.database()

exports.main = async (event) => {

  const wxContent = cloud.getWXContext() // openid等信息
  const openid = wxContent.OPENID
  const appid = wxContent.APPID

  const totalFee = event.totalFee // 支付金額（單位：分）
  const body = event.body // 商品名

  const outTradeNo = createOutTradeNo() // 訂單號(hào)

  // 獲取免鑒權(quán)支付參數(shù)
  const payMent = await cloud.cloudPay.unifiedOrder({
    "body": body,
    "outTradeNo": outTradeNo,
    "spbillCreateIp": "127.0.0.1",
    "subMchId": "商戶(hù)號(hào)", // 商戶(hù)號(hào)
    "totalFee": totalFee,
    "envId": "對(duì)應(yīng)的云環(huán)境id", // 云環(huán)境id
    "functionName": "payCallBack" // 支付回調(diào)云函數(shù)
  })

  // 創(chuàng)建訂單
  const nowTime = new Date().getTime()
  const orderObj = {
    _openid: openid,
    appid: appid,
    outTradeNo: outTradeNo,
    totalFee: totalFee * 0.01,
    payStatus: 'wait',
    createTime: nowTime,
    updateTime: nowTime,
    deleteTime: null,
  }
  await addOrder(orderObj)

  return payMent
}

/** 創(chuàng)建隨機(jī)的唯一訂單號(hào)(32位) */
const createOutTradeNo = () => {
  let outTradeNo = new Date().getTime() // 獲取當(dāng)前13位時(shí)間戳
  let numStr = '0123456789';
  let randomStr = '';
  for (let i = (32 - 13); i > 0; --i) {
    randomStr += numStr[Math.floor(Math.random() * numStr.length)];
  }
  outTradeNo += randomStr
  return outTradeNo
}

/** 向數(shù)據(jù)庫(kù)創(chuàng)建訂單 */
const addOrder = async (orderObj) => {
  return await db.collection('order')
    .add({
      data: orderObj
    })
    .then(res => {
      console.log("創(chuàng)建訂單成功 =====>", res, orderObj)
    })
    .catch(err => {
      console.log("創(chuàng)建訂單異常 =====>", err, orderObj)
    })
}

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

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

const db = cloud.database()

// 云函數(shù)入口函數(shù)
exports.main = async (event) => {
  console.log("回調(diào)返回對(duì)象 =====>", event)
	// 判斷條件
  if (event.returnCode == 'SUCCESS') {
    if (event.resultCode == 'SUCCESS') {
      // 查詢(xún)條件
      const whereObj = {
        appid: event.subAppid, // 小程序的APPID
        _openid: event.subOpenid, // 小程序用戶(hù)的openid
        outTradeNo: event.outTradeNo, // 商戶(hù)號(hào)的訂單號(hào)
      }
      // 更新對(duì)象
      const updateObj = {
        transactionId: event.transactionId, // 微信方的訂單號(hào)
        totalFee: event.totalFee * 0.01, // 微信方收到的金額
        timeEnd: event.timeEnd, // 支付結(jié)束時(shí)間
        payStatus: 'success',
        updateTime: new Date().getTime()
      }
      // 更新訂單
      await updateOrder(whereObj, updateObj)
    }
  }
  // 支付回調(diào)的返回協(xié)議和入?yún)f(xié)議（必須返回此結(jié)構(gòu)體，詳見(jiàn)文檔）
  return {
    errcode: 0,
    errmsg: event.resultCode
  }
}

/** 更新訂單的支付狀態(tài) */
const updateOrder = async (whereObj, updateObj) => {
  return await db.collection('order')
    .where(whereObj)
    .update({
      data: updateObj
    })
}

// pages/wxPay/wxPay.js
Page({

  /**
   * 頁(yè)面的初始數(shù)據(jù)
   */
  data: {

  },

  /**
   * 生命周期函數(shù)--監(jiān)聽(tīng)頁(yè)面加載
   */
  onLoad() {},

  /**
   * 生命周期函數(shù)--監(jiān)聽(tīng)頁(yè)面顯示
   */
  onShow() {},

  /** 支付點(diǎn)擊監(jiān)聽(tīng) */
  async payTap() {
    const totalFee = 2
    const body = '支付測(cè)試'
    wx.showLoading({
      title: '調(diào)起微信支付中',
      mask: true
    })

    // 獲取支付免鑒權(quán)參數(shù)
    const payMentRes = await this.getPayMent(totalFee, body)
    wx.hideLoading({
      success: (res) => {},
    })
    // 小程序支付API
    const payRes = await this.wxPay(payMentRes.result.payment)
    // 支付API返回結(jié)果打印
    console.log(payRes)
  },

  /**
   * 小程序支付API
   * @param {object} payment 支付免鑒權(quán)參數(shù)
   */
  wxPay(payment) {
    return new Promise((resolve, rejects) => {
      wx.requestPayment({
        ...payment,
        success(res) {
          resolve({
            status: 'success',
            res: res
          })
        },
        fail(err) {
          resolve({
            status: 'fail',
            res: err
          })
        }
      })
    })
  },

  /**
   * 獲取支付免鑒權(quán)參數(shù)
   * @param {number} totalFee 支付金額, 單位：分
   * @param {string} body 商品名稱(chēng)
   */
  getPayMent(totalFee, body) {
    return new Promise((resolve, rejects) => {
      wx.cloud.callFunction({
        name: 'wxPay',
        data: {
          totalFee,
          body
        },
        success(res) {
          resolve(res)
        },
        fail(err) {
          resolve(err)
        }
      })
    })
  },

})