tj

igirl-channel-gateway/app/base/service/impl/common/oplogSve.js

 const system = require("../../../system");
 const ServiceBase = require("../../sve.base");
 var settings = require("../../../../config/settings");
+const getRawBody = require('raw-body');
 class OplogService extends ServiceBase {
   constructor() {
     super("common", ServiceBase.getDaoName(OplogService));
@@ -76,5 +77,26 @@ class OplogService extends ServiceBase {
       this.dao.create(qobj);
     }
   }
+  async applicationOctetStream2Json(req) {
+    var promiseT = await new Promise((resv, rej) => {
+      getRawBody(req, {
+        length: req.headers['content-length'],
+        encoding: req.charset
+      }, function (err, string) {
+        if (err) {
+          rej(err);
+        } else {
+          resv(string);
+        }
+      });
+    });
+    if (promiseT.length > 0) {
+      var step1 = JSON.stringify(promiseT);
+      var step2 = JSON.parse(step1);
+      var step3 = new Buffer(step2);
+      var step4 = step3.toString();
+      req.body = JSON.parse(step4);
+    }
+  }
 }
 module.exports = OplogService;

igirl-channel-gateway/app/config/routes/api.js

@@ -5,24 +5,14 @@ const logCtl = system.getObject("service.common.oplogSve");
 const utilsNeedSve = system.getObject("service.utilsSve.utilsNeedSve");
 
 module.exports = function (app) {
-	// app.get("/auth", async function (req, res) {
-	// 	if (!req.query.opencode) {
-	// 		return system.getResult(null, "opencode参数不能为空");
-	// 	}
-	// 	return await userSve.authByCode(opencode);
-	// });
-// 	case "submitSolution"://提交需求
-// 	opResult = await this.needinfoSve.createicneedinfo(pobj);
-// 	break;
-// case "paySuccess"://支付成功回调
-// 	opResult = await this.orderinfoSve.createsolutionOrder(pobj);
-// 	break;
-// case "solutionClose"://需求关闭
-// 	opResult = await this.needinfoSve.solutionClose(pobj);
+
 	app.use('/api/ali/esp/intention/submit', async function (req, res) {
 		try {
+			if (req.headers['content-type'] === 'application/octet-stream') {
+				await logCtl.applicationOctetStream2Json(req);
+			}
 			var client_ip = system.get_client_ip(req);
-			req.body.action_type="submitNeed";
+			req.body.action_type = "submitNeed";
 			var result = await utilsNeedSve.reqcenterchannel(req.body, client_ip);
 			logCtl.info({
 				optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "回调处理订单结果：，method=" + req.body.trxcode,
@@ -44,8 +34,11 @@ module.exports = function (app) {
 	});
 	app.use('/api/ali/esp/intention/solution/feedback', async function (req, res) {
 		try {
+			if (req.headers['content-type'] === 'application/octet-stream') {
+				await logCtl.applicationOctetStream2Json(req);
+			}
 			var client_ip = system.get_client_ip(req);
-			req.body.action_type="receiveFeedback";
+			req.body.action_type = "receiveFeedback";
 			var result = await utilsNeedSve.reqcenterchannel(req.body, client_ip);
 			logCtl.info({
 				optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "回调处理订单结果：，method=" + req.body.trxcode,
@@ -66,8 +59,11 @@ module.exports = function (app) {
 	});
 	app.use('/api/ali/ic/paySuccess', async function (req, res) {
 		try {
+			if (req.headers['content-type'] === 'application/octet-stream') {
+				await logCtl.applicationOctetStream2Json(req);
+			}
 			var client_ip = system.get_client_ip(req);
-			req.body.action_type="paySuccess";
+			req.body.action_type = "paySuccess";
 			var result = await utilsNeedSve.paySuccess(req.body, client_ip);
 			logCtl.info({
 				optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "回调处理订单结果：，method=" + req.body.trxcode,
@@ -88,8 +84,11 @@ module.exports = function (app) {
 	});
 	app.use('/api/ali/esp/intention/close', async function (req, res) {
 		try {
+			if (req.headers['content-type'] === 'application/octet-stream') {
+				await logCtl.applicationOctetStream2Json(req);
+			}
 			var client_ip = system.get_client_ip(req);
-			req.body.action_type="needClose";
+			req.body.action_type = "needClose";
 			var result = await utilsNeedSve.reqcenterchannel(req.body, client_ip);
 			logCtl.info({
 				optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "回调处理订单结果：，method=" + req.body.trxcode,