Skip to content

Z
zhichan
Commit 00f0a8e5 by linboxuan
Options

alipayNotify

parent 2b77854a
Showing with 93 additions and 93 deletions
center-channel/app/base/service/impl/utilsSve/utilsOrderSve.js
...@@ -574,100 +574,100 @@ class UtilsOrderService extends AppServiceBase { ...@@ -574,100 +574,100 @@ class UtilsOrderService extends AppServiceBase {
console.log(typeof(parmas)) console.log(typeof(parmas))
console.log(parmas.toString()) console.log(parmas.toString())
console.log("支付宝回调参数信息--------------------end") console.log("支付宝回调参数信息--------------------end")
// //日志记录 //日志记录
this.logCtl.info({
optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "支付宝回调参数信息",
op: "service/impl/utilsSve/utilsOrderSve.js/aliPayNotify",
content: JSON.stringify(parmas),
// content: parmas.toString(),
clientIp: client_ip || ""
});
if (!parmas.trade_status) {
return system.getResult(null, "trade_status参数不能为空，100470");
}
if (parmas.trade_status != "TRADE_FINISHED" && parmas.trade_status != "TRADE_SUCCESS") {
return system.getResult(null, "trade_status状态有误，100473");
}
console.log("parmas.trade_status 校验通过--------------")
// 2020 0621 支付宝验签接口
var url = "https://yf-api.gongsibao.com/pay/v1/checkAliPaySign";
let params = {
"app": "ukgc", //应用名称 固定
"key": "a1519e2eab53dfb909e4c32a86b2ea2b", //应用 key 固定
"tData" : parmas
}
var sign = JSON.stringify(params);
// sign += "ab53dfb909e4c32a"
sign += this.paySecret
sign = md5(sign).toUpperCase()
params.sign = sign
// let res = await axios.post(url, params)
// this.logCtl.info({ // this.logCtl.info({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "支付宝回调参数信息", // optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "支付宝回调参数验签结果",
// op: "service/impl/utilsSve/utilsOrderSve.js/aliPayNotify",
// content: JSON.stringify(parmas),
// // content: parmas.toString(),
// clientIp: client_ip || ""
// });
// if (!parmas.trade_status) {
// return system.getResult(null, "trade_status参数不能为空，100470");
// }
// if (parmas.trade_status != "TRADE_FINISHED" && parmas.trade_status != "TRADE_SUCCESS") {
// return system.getResult(null, "trade_status状态有误，100473");
// }
// console.log("parmas.trade_status 校验通过--------------")
// // 2020 0621 支付宝验签接口
// var url = "https://yf-api.gongsibao.com/pay/v1/checkAliPaySign";
// let params = {
// "app": "ukgc", //应用名称 固定
// "key": "a1519e2eab53dfb909e4c32a86b2ea2b", //应用 key 固定
// "tData" : parmas
// }
// var sign = JSON.stringify(params);
// // sign += "ab53dfb909e4c32a"
// sign += this.paySecret
// sign = md5(sign).toUpperCase()
// params.sign = sign
// // let res = await axios.post(url, params)
// // this.logCtl.info({
// // optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "支付宝回调参数验签结果",
// // op: "service/impl/utilsSve/utilsOrderSve.js/aliPayNotify",
// // content: JSON.stringify(res),
// // clientIp: client_ip || ""
// // });
// // if (res.status != 0) {
// // res.msg = res.msg + "，100480";
// // return res;
// // }
// // 模拟验签结果
// var outTradeInfo = parmas.out_trade_no.split('-');
// console.log("模拟验签结果--------------",outTradeInfo)
// //
// var opResult = {}
// opResult.data = {
// orderNo: outTradeInfo[0],
// uappId: Number(outTradeInfo[1]),
// productId: outTradeInfo.length == 3 ? Number(outTradeInfo[2]) : 0
// }
// // 拿锁
// var locker = await this.cacheManager["TlPayLocker"].enter(opResult.data.orderNo);
// console.log("拿锁结果",locker)
// if (!locker || locker != "1") {
// this.logCtl.info({
// appid: opResult.data.uappId,
// appkey: "",
// op: "service/impl/utilsSve/utilsOrderSve.js/aliPayNotify", // op: "service/impl/utilsSve/utilsOrderSve.js/aliPayNotify",
// content: "参数=" + JSON.stringify(parmas), // content: JSON.stringify(res),
// clientIp: parmas.client_ip || "", // clientIp: client_ip || ""
// optitle: "阿里回调操作频繁---太频繁了，太频繁了" // });
// }); // if (res.status != 0) {
// return system.getResultFail(-200, "阿里回调操作频繁---太频繁了，太频繁了"); // res.msg = res.msg + "，100480";
// } // return res;
// parmas.appInfo = { appInfo: { uapp_id: opResult.data.uappId } };
// parmas.orderNo = opResult.data.orderNo;
// parmas.pay_type = "alipay";
// //修改并返回订单支付状态，创建收款单
// // 这里修改了order_info的状态（status/paytime等）
// var url = this.centerOrderUrl + "opaction/opPayOrder/receivePayCallBackNotifyByAliDing";
// var opOrderResult = await this.restPostUrl(parmas, url);
// if (opOrderResult.status != 0) {
// opOrderResult.data = null;
// return opOrderResult;
// }
// opOrderResult.data.appInfo = {
// uapp_id: opResult.data.uappId
// };
// opOrderResult.data.userInfo = {
// channel_userid: opOrderResult.data.order_info.channelUserId,
// channel_username: opOrderResult.data.order_info.channelUserId,
// channel_nickname: opOrderResult.data.order_info.channelUserId
// };
// opOrderResult.data.orderNo = opResult.data.orderNo;
// var pobj = {
// appInfo: opOrderResult.data.appInfo,
// actionBody: opOrderResult.data
// } // }
// this.utilsPushSve.pushBusInfo(pobj, "createAliTmApply", 1); // 模拟验签结果
// opOrderResult.data = null; var outTradeInfo = parmas.out_trade_no.split('-');
// return opOrderResult; console.log("模拟验签结果--------------",outTradeInfo)
//
var opResult = {}
opResult.data = {
orderNo: outTradeInfo[0],
uappId: Number(outTradeInfo[1]),
productId: outTradeInfo.length == 3 ? Number(outTradeInfo[2]) : 0
}
// 拿锁
var locker = await this.cacheManager["TlPayLocker"].enter(opResult.data.orderNo);
console.log("拿锁结果",locker)
if (!locker || locker != "1") {
this.logCtl.info({
appid: opResult.data.uappId,
appkey: "",
op: "service/impl/utilsSve/utilsOrderSve.js/aliPayNotify",
content: "参数=" + JSON.stringify(parmas),
clientIp: parmas.client_ip || "",
optitle: "阿里回调操作频繁---太频繁了，太频繁了"
});
return system.getResultFail(-200, "阿里回调操作频繁---太频繁了，太频繁了");
}
parmas.appInfo = { appInfo: { uapp_id: opResult.data.uappId } };
parmas.orderNo = opResult.data.orderNo;
parmas.pay_type = "alipay";
//修改并返回订单支付状态，创建收款单
// 这里修改了order_info的状态（status/paytime等）
var url = this.centerOrderUrl + "opaction/opPayOrder/receivePayCallBackNotifyByAliDing";
var opOrderResult = await this.restPostUrl(parmas, url);
if (opOrderResult.status != 0) {
opOrderResult.data = null;
return opOrderResult;
}
opOrderResult.data.appInfo = {
uapp_id: opResult.data.uappId
};
opOrderResult.data.userInfo = {
channel_userid: opOrderResult.data.order_info.channelUserId,
channel_username: opOrderResult.data.order_info.channelUserId,
channel_nickname: opOrderResult.data.order_info.channelUserId
};
opOrderResult.data.orderNo = opResult.data.orderNo;
var pobj = {
appInfo: opOrderResult.data.appInfo,
actionBody: opOrderResult.data
}
this.utilsPushSve.pushBusInfo(pobj, "createAliTmApply", 1);
opOrderResult.data = null;
return opOrderResult;
} catch (e) { } catch (e) {
await this.cacheManager["TlPayLocker"].release(parmas.out_trade_no); await this.cacheManager["TlPayLocker"].release(parmas.out_trade_no);
this.logCtl.error({ this.logCtl.error({
optitle: "回调处理订单---error异常", optitle: "回调处理订单---error异常",
op: "center-app/app/base/service/impl/utilsSve/utilstlbankSve.js/opBackNotify", op: "center-app/app/base/service/impl/utilsSve/utilsOrderSve.js/aliPayNotify",
content: "参数=" + JSON.stringify(parmas) + "，error：" + e.stack, content: "参数=" + JSON.stringify(parmas) + "，error：" + e.stack,
clientIp: client_ip || "" clientIp: client_ip || ""
}); });
......
center-channel/app/config/routes/api.js
...@@ -428,7 +428,7 @@ module.exports = function (app) { ...@@ -428,7 +428,7 @@ module.exports = function (app) {
var client_ip = system.get_client_ip(req); var client_ip = system.get_client_ip(req);
var result = await utilsOrderSve.aliPayNotify(req.body, client_ip); var result = await utilsOrderSve.aliPayNotify(req.body, client_ip);
logCtl.info({ logCtl.info({
optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录支付宝回调处理结果", optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录支付宝回调处理结果 api层",
op: "center-channel/orderNotify/aliPayNotify", op: "center-channel/orderNotify/aliPayNotify",
content: "支付回调处理结果：" + JSON.stringify(result), content: "支付回调处理结果：" + JSON.stringify(result),
clientIp: client_ip || "" clientIp: client_ip || ""
...@@ -437,11 +437,11 @@ module.exports = function (app) { ...@@ -437,11 +437,11 @@ module.exports = function (app) {
return res.end("FAIL"); return res.end("FAIL");
} }
return res.end("success"); return res.end("success");
} catch { } catch(e) {
logCtl.error({ logCtl.error({
optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "支付宝回调处理异常", optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "支付宝回调处理异常 api层",
op: "center-channel/orderNotify/aliPayNotify", op: "center-channel/orderNotify/aliPayNotify",
content: "回调参数：req=" + JSON.stringify(req) + "error：" + error.stack, content: "回调参数：req=" + JSON.stringify(req) + "error：" + e.stack,
clientIp: client_ip || "" clientIp: client_ip || ""
}); });
} }
...@@ -471,11 +471,11 @@ module.exports = function (app) { ...@@ -471,11 +471,11 @@ module.exports = function (app) {
}) })
}) })
} catch { } catch(e) {
logCtl.error({ logCtl.error({
optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "微信回调处理异常", optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "微信回调处理异常",
op: "center-channel/orderNotify/wxPayNotify", op: "center-channel/orderNotify/wxPayNotify",
content: "回调参数：req=" + JSON.stringify(req) + "error：" + error.stack, content: "回调参数：req=" + JSON.stringify(req) + "error：" + e.stack,
clientIp: client_ip || "" clientIp: client_ip || ""
}); });
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment