# 2、接收付款成功异步通知

在你发起支付的api中,有个 type 属性,这个 type 属性的值你填了什么,最终回调的时候就会执行什么。

type 填了 goods,则回调的时候会执行这里的 goods.js 内的代码。

在云函数 vk-payservice/pay-notify 目录创建以下3个文件,用于编写异步回调后自己的业务逻辑

1、goods.js
2、recharge.js
3、vip.js
1
2
3

goods : 商品订单

recharge : 余额充值订单

vip : vip购买订单

goods

# 示例

# goods

'use strict';
/**
 * 此处建议只改下订单状态,保证能及时返回给第三方支付服务器成功状态
 * 且where条件可以增加判断服务器推送过来的金额和订单表中订单需支付金额是否一致
 * 将消息发送、返佣、业绩结算等业务逻辑异步处理(写入异步任务队列表)
 * 如开启定时器每隔5秒触发一次,处理订单
 */
module.exports = async (obj, originalParam) => {
  let user_order_success = true;
  let { data = {}, verifyResult } = obj;
  let { db, _ } = originalParam;
  let {
    out_trade_no,
    total_fee
  } = data;
  // 此处写你自己的支付成功逻辑开始-----------------------------------------------------------
  // 设置订单为已付款
  // 有三种方式
  // 方式一:直接写数据库操作(原生数据库语句)
  // 方式二:使用 await uniCloud.callFunction 调用其他云函数
  // 方式三:使用 await uniCloud.httpclient.request 调用http接口地址

  // 此处写你自己的支付成功逻辑结束-----------------------------------------------------------
  // user_order_success =  true 代表你自己的逻辑处理成功 返回 false 代表你自己的处理逻辑失败。
  return user_order_success;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

# recharge

'use strict';
/**
 * 此处建议只改下订单状态,保证能及时返回给第三方支付服务器成功状态
 * 且where条件可以增加判断服务器推送过来的金额和订单表中订单需支付金额是否一致
 * 将消息发送、返佣、业绩结算等业务逻辑异步处理(写入异步任务队列表)
 * 如开启定时器每隔5秒触发一次,处理订单
 */
module.exports = async (obj, originalParam) => {
  let user_order_success = true;
  let { data = {}, verifyResult } = obj;
  let { db, _ } = originalParam;
  let {
    out_trade_no,
    total_fee,
    user_id,
    recharge_balance
  } = data;
  // 此处写你自己的支付成功逻辑开始-----------------------------------------------------------
  // 给用户充值余额
  // 有三种方式
  // 方式一:直接写数据库操作(原生数据库语句)
  // 方式二:使用 await uniCloud.callFunction 调用其他云函数
  // 方式三:使用 await uniCloud.httpclient.request 调用http接口地址

  // 示例:给用户充值余额(可以去数据库查看余额是否有增加)
  let res = await db.collection("uni-id-users").doc(user_id).update({
    balance: _.inc(recharge_balance)
  });
  if (res.updated) {
    user_order_success = true;
  } else {
    user_order_success = false;
  }
  // 此处写你自己的支付成功逻辑结束-----------------------------------------------------------
  // user_order_success =  true 代表你自己的逻辑处理成功 返回 false 代表你自己的处理逻辑失败。
  return user_order_success;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

# vip

'use strict';
/**
 * 此处建议只改下订单状态,保证能及时返回给第三方支付服务器成功状态
 * 且where条件可以增加判断服务器推送过来的金额和订单表中订单需支付金额是否一致
 * 将消息发送、返佣、业绩结算等业务逻辑异步处理(写入异步任务队列表)
 * 如开启定时器每隔5秒触发一次,处理订单
 */
module.exports = async (obj, originalParam) => {
  let user_order_success = true;
  let { data = {}, verifyResult } = obj;
  let { db, _ } = originalParam;
  let {
    out_trade_no,
    total_fee
  } = data;
  // 此处写你自己的支付成功逻辑开始-----------------------------------------------------------
  // 充值VIP付款成功
  // 有三种方式
  // 方式一:直接写数据库操作(原生数据库语句)
  // 方式二:使用 await uniCloud.callFunction 调用其他云函数
  // 方式三:使用 await uniCloud.httpclient.request 调用http接口地址

  // 此处写你自己的支付成功逻辑结束-----------------------------------------------------------
  // user_order_success =  true 代表你自己的逻辑处理成功 返回 false 代表你自己的处理逻辑失败。
  return user_order_success;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

# 回调处理方式

回调处理大致有三种方式

# 方式一:直接写数据库操作

优势:无需鉴权,无需加密解密(插件已帮你验证签名,能进到这里,就是已经通过签名验证)

代码示例

'use strict';
/**
 * 此处建议只改下订单状态,保证能及时返回给第三方支付服务器成功状态
 * 且where条件可以增加判断服务器推送过来的金额和订单表中订单需支付金额是否一致
 * 将消息发送、返佣、业绩结算等业务逻辑异步处理(写入异步任务队列表)
 * 如开启定时器每隔5秒触发一次,处理订单
 */
module.exports = async (obj, originalParam) => {
	let user_order_success = true;
	let { data = {}, verifyResult } = obj;
	let { db, _ } = originalParam;
	let {
		out_trade_no,
		transaction_id,
		total_fee,
		user_id,
		recharge_balance
	} = data;
	// 此处写你自己的支付成功逻辑开始-----------------------------------------------------------
	// 方式一:直接写数据库操作(原生数据库语句)
	// 示例:给用户充值余额(可以去数据库查看余额是否有增加)
	let res = await db.collection("uni-id-users").doc(user_id).update({
	  balance: _.inc(recharge_balance)
	});
	if (res.updated) {
	  user_order_success = true;
	} else {
	  user_order_success = false;
	}
	// 此处写你自己的支付成功逻辑结束-----------------------------------------------------------
	// user_order_success =  true 代表你自己的逻辑处理成功 返回 false 代表你自己的处理逻辑失败。
	return user_order_success;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

# 方式二:调用其他云函数

使用 await uniCloud.callFunction 调用其他云函数

优势:可以访问其他云函数,适用于回调函数的主要逻辑在另外一个云函数中执行,如router

代码示例

'use strict';
/**
 * 此处建议只改下订单状态,保证能及时返回给第三方支付服务器成功状态
 * 且where条件可以增加判断服务器推送过来的金额和订单表中订单需支付金额是否一致
 * 将消息发送、返佣、业绩结算等业务逻辑异步处理(写入异步任务队列表)
 * 如开启定时器每隔5秒触发一次,处理订单
 */
module.exports = async (obj, originalParam) => {
  let user_order_success = true;
  let { data = {}, verifyResult } = obj;
  let { db, _ } = originalParam;
  let {
    out_trade_no,
    transaction_id,
    total_fee,
  } = data;
  // 此处写你自己的支付成功逻辑开始-----------------------------------------------------------
  // 设置订单为已付款
  // 方式二:使用 await uniCloud.callFunction 调用其他云函数
  
  // 加密
  let encryptedData = vkPay.crypto.aes.encrypt({
    data: data
  });
  // 调用其他云函数(在该云函数中需要解密,加密方式见文档最后)
  let callFunctionRes = await uniCloud.callFunction({
    name: "router",
    data: {
      $url: "template/test/pub/http",
      data: {
        encryptedData
      }
    }
  });
  // 云函数执行成功后需要返回{ code: 0 }
  if (callFunctionRes.result.code === 0) {
    user_order_success = true; // 表示你后端执行成功了
  } else {
    user_order_success = false; // 表示你后端执行失败了
  }
  // 此处写你自己的支付成功逻辑结束-----------------------------------------------------------
  // user_order_success =  true 代表你自己的逻辑处理成功 返回 false 代表你自己的处理逻辑失败。
  return user_order_success;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

# 方式三:调用http接口地址(对接外部系统)

使用 await uniCloud.httpclient.request 调用http接口地址(对接外部系统)

优势:可以访问java或php写的后端接口,适用于回调函数的主要逻辑在另外一个系统中执行。

代码示例

'use strict';
/**
 * 此处建议只改下订单状态,保证能及时返回给第三方支付服务器成功状态
 * 且where条件可以增加判断服务器推送过来的金额和订单表中订单需支付金额是否一致
 * 将消息发送、返佣、业绩结算等业务逻辑异步处理(写入异步任务队列表)
 * 如开启定时器每隔5秒触发一次,处理订单
 */
module.exports = async (obj, originalParam) => {
	let user_order_success = true;
	let { data = {}, verifyResult } = obj;
	let { db, _ } = originalParam;
	let {
		out_trade_no,
		transaction_id,
		total_fee,
	} = data;
	// 此处写你自己的支付成功逻辑开始-----------------------------------------------------------
	// 设置订单为已付款
	// 方式三:使用 await uniCloud.httpclient.request 调用http接口地址
	let res = await uniCloud.httpclient.request("https://xxxx.com/xxx", {
		method: "POST",
		data: {
			...data,
			key: "与你后端约定的口令", // 你后端接受key参数,判断key等于约定的口令,则视为正常推送订单,否则,拦截
		},
		contentType: "json",
		dataType: "json"
	});
	// 后端执行成功后需要返回{ code: 0 }
	if (res && res.data && res.data.code === 0) {
		user_order_success = true; // 表示你后端执行成功了
	} else {
		user_order_success = false; // 表示你后端执行失败了
	}
	// 此处写你自己的支付成功逻辑结束-----------------------------------------------------------
	// user_order_success =  true 代表你自己的逻辑处理成功 返回 false 代表你自己的处理逻辑失败。
	return user_order_success;
};
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

注意:

非方式一会因为跨云函数运行,所以涉及到请求过程中的数据防篡改问题。

这里插件提供了 aes 加密API(需要配置 uni-config-center/uni-pay/config.js 内的 notifyKey

// 引入vkPay模块
const vkPay = require("vk-uni-pay");
// 对数据进行加密
let encryptedData = vkPay.crypto.aes.encrypt({
  data: {
    out_trade_no, // 订单号
    recharge_balance, // 充值余额的数量
    user_id, // 用户id
  }
});
1
2
3
4
5
6
7
8
9
10
// 引入vkPay模块
const vkPay = require("vk-uni-pay");
// 对数据进行解密
let decryptedRes;
try {
  decryptedRes = vkPay.crypto.aes.decrypt({
    data: encryptedData, // 待解密的原文
  });
} catch (err) {
  console.log("解密失败", err);
  throw err;
}
let {
  out_trade_no, // 订单号
  recharge_balance, // 充值余额的数量
  user_id, // 用户id
} = decryptedRes;
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

如果是java和php,点击此处查看加密解密算法示例 (opens new window)

也可以直接传密钥key,你的后端接受key参数,判断key等于约定的口令,则视为正常推送订单,否则,拦截(因为是服务端与服务器端的交互,理论上只要key不暴露给前端,则是安全的,当然安全系数会比通过加密和解密方式稍低点,但也是安全的)

当然加密方式不仅限此方案,如果你有自己的加密方案,则可以使用自己的方案来解决。