/**
|
* 第三方支付相关数据库操作
|
* 请勿修改此处代码，因为插件更新后此处代码会被覆盖。
|
* 作者：VK
|
*/
|
const dbNamePayOrders = "uni-pay-orders"; // 数据库表名 - 第三方支付订单表
|
|
const fnUtil = require('../fnUtil');
|
|
const db = uniCloud.database();
|
const _ = db.command;
|
var dao = {};
|
|
/**
|
* 添加 - 第三方支付订单数据
|
await payDao.addPayOrders({
|
status: 0,
|
pay_type : payType,
|
out_trade_no : outTradeNo,
|
openid : openid,
|
totalFee : totalFee,
|
appid : appId,
|
original_data : event.body,
|
wxpay_info : wxpay_info,
|
alipay_info : alipay_info,
|
user_order_success: userOrderSuccess
|
});
|
*/
|
dao.addPayOrders = async (dataJson = {}) => {
|
// 数据库操作开始-----------------------------------------------------------
|
let date = new Date();
|
let _add_time = date.getTime();
|
let _add_time_str = fnUtil.timeFormat(date, "yyyy-MM-dd hh:mm:ss");
|
let res = await db.collection(dbNamePayOrders).add({
|
_add_time,
|
_add_time_str,
|
...dataJson
|
});
|
// 数据库操作结束-----------------------------------------------------------
|
return res.id ? res.id : null;
|
};
|
|
/**
|
* 获取 - 第三方支付订单数据
|
await payDao.findPayOrdersByOutTradeNo(outTradeNo);
|
*/
|
dao.findPayOrdersByOutTradeNo = async (out_trade_no = "___") => {
|
let res = await db.collection(dbNamePayOrders)
|
.where({
|
out_trade_no
|
})
|
.limit(1)
|
.get();
|
if (res.data && res.data.length > 0) {
|
return res.data[0];
|
} else {
|
return null;
|
}
|
return res;
|
};
|
|
/**
|
* 修改 - 第三方支付订单数据
|
await payDao.updatePayOrdersById(id, {
|
|
});
|
*/
|
dao.updatePayOrdersById = async (id = "___", dataJson) => {
|
// 数据库操作开始-----------------------------------------------------------
|
let res = await db.collection(dbNamePayOrders).doc(id).update(dataJson);
|
// 数据库操作结束-----------------------------------------------------------
|
return res ? res.updated : 0;
|
};
|
/**
|
* 修改 - 第三方支付订单数据
|
await payDao.updatePayOrdersByWhereJson({
|
whereJson:{
|
status:0,
|
out_trade_no
|
},
|
dataJson:{
|
|
}
|
});
|
*/
|
dao.updatePayOrdersByWhereJson = async (obj) => {
|
let { whereJson, dataJson } = obj;
|
// 数据库操作开始-----------------------------------------------------------
|
let res = await db.collection(dbNamePayOrders).where(whereJson).update(dataJson);
|
// 数据库操作结束-----------------------------------------------------------
|
return res ? res.updated : 0;
|
};
|
/**
|
* 删除超过1天还未支付款的订单
|
await payDao.deleteExpPayOrders();
|
*/
|
dao.deleteExpPayOrders = async () => {
|
// 数据库操作开始-----------------------------------------------------------
|
let time = new Date().getTime() - 1000 * 3600 * 24;
|
let res = await db.collection(dbNamePayOrders)
|
.where({
|
status: 0,
|
_add_time: _.lt(time)
|
})
|
.remove();
|
// 数据库操作结束-----------------------------------------------------------
|
return res ? res.updated : 0;
|
};
|
|
module.exports = dao;
|
