tj

center-channel/app/base/service/impl/utilsSve/utilsOrderSve.js

@@ -332,7 +332,7 @@ class UtilsOrderService extends AppServiceBase {
       }
       }
       //日志记录
       //日志记录
       this.logCtl.info({
       this.logCtl.info({
-        optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "：，method=" + parmas.trxcode,
+        optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调参数：，method=" + parmas.trxcode,
         op: "center-channel/app/base/service/impl/utilsSve/utilsOrderSve.js/receiveCallBackNotify",
         op: "center-channel/app/base/service/impl/utilsSve/utilsOrderSve.js/receiveCallBackNotify",
         content: JSON.stringify(parmas),
         content: JSON.stringify(parmas),
         clientIp: client_ip || ""
         clientIp: client_ip || ""

center-channel/app/config/routes/api.js

 var url = require("url");
 var url = require("url");
 var system = require("../../base/system");
 var system = require("../../base/system");
-var utilsAuthSve = system.getObject("service.utilsSve.utilsAuthSve");
+const utilsAuthSve = system.getObject("service.utilsSve.utilsAuthSve");
+const logCtl = system.getObject("service.common.oplogSve");
 module.exports = function (app) {
 module.exports = function (app) {
 	//-----------------------新的模式------------------开始
 	//-----------------------新的模式------------------开始
 	app.use('/tlpay/notify', function (req, res) {
 	app.use('/tlpay/notify', function (req, res) {
-		var client_ip = system.get_client_ip(req);
 		var utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
 		var utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
-		var p = utilsOrderSve.receiveCallBackNotify(req.body,client_ip);
-		p.then(r => {
-			res.end(JSON.stringify(r));
+		var client_ip = System.get_client_ip(req);
+		var result = await utilsOrderSve.receiveCallBackNotify(req.body, client_ip);
+		logCtl.info({
+			optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调处理结果：，method=" + req.body.trxcode,
+			op: "center-channel/tlpay/notify",
+			content: "回调参数：" + JSON.stringify(req.body) + "回调结果：" + JSON.stringify(result),
+			clientIp: client_ip || ""
 		});
 		});
+		res.end(result);
 	});
 	});
 
 
 	app.all("/web/*", async function (req, res, next) {
 	app.all("/web/*", async function (req, res, next) {