Skip to content

Z
zhichan
Commit 681163dd by 王栋源
Options

wdy

parent 912781ca
Showing with 164 additions and 188 deletions
igirl-channel-gateway/app/base/api/impl/action/intentionapi.js
...@@ -39,6 +39,9 @@ class TradetransferAPI extends APIBase { ...@@ -39,6 +39,9 @@ class TradetransferAPI extends APIBase {
case "receiveFeedback"://接收方案反馈信息 case "receiveFeedback"://接收方案反馈信息
opResult = await this.utilsNeedSve.reqcenterchannel(pobj); opResult = await this.utilsNeedSve.reqcenterchannel(pobj);
break; break;
case "icpFeedbackSubmit"://接收方案反馈信息
opResult = await this.utilsNeedSve.reqcenterchannel(pobj);
break;
case "paySuccess"://支付回调 case "paySuccess"://支付回调
opResult = await this.utilsNeedSve.paySuccess(pobj); opResult = await this.utilsNeedSve.paySuccess(pobj);
break; break;
......
igirl-channel-gateway/app/base/service/impl/common/gatewaypushlogSve.js
...@@ -174,66 +174,165 @@ class GatewaypushlogService extends ServiceBase { ...@@ -174,66 +174,165 @@ class GatewaypushlogService extends ServiceBase {
} }
pobj.type = pobj.consultType; pobj.type = pobj.consultType;
pobj.mobile = pobj.phone; pobj.mobile = pobj.phone;
var param = { pobj.action_type = "submitNeed";
requestId: self.getUUID(), if (pobj.area) {
requestUrl: "/api/ali/tm/consultation/submit", // switch (action_type) {
requestjson: JSON.stringify(pobj),//请求地址 // case "1":
pushUrl: "/action/intentionapi/queryOrderState",//调用地址 // pobj.area = "";
pushActionType: "submitNeed",//调用参数 // break;
pushtimes: 0,//推送次数 // case "2":
pushStatus: "wts",//推送状态 // pobj.area = "";
} // break;
await self.create(param); // case "3":
return self.getResultSuccess(param.requestId); // pobj.area = "";
} // break;
// case "4":
// pobj.area = "";
// break;
// case "5":
// pobj.area = "";
// break;
// case "6":
// pobj.area = "";
// break;
// case "7":
// pobj.area = "";
// break;
// case "8":
// pobj.area = "";
// break;
// case "9":
// pobj.area = "";
// break;
// case "10":
// pobj.area = "";
// break;
// case "11":
// pobj.area = "";
// break;
// case "12":
// pobj.area = "";
// break;
// case "13":
// pobj.area = "";
// break;
// case "14":
// pobj.area = "";
// break;
// case "15":
// pobj.area = "";
// break;
// case "16":
// pobj.area = "";
// break;
// case "17":
// pobj.area = "";
// break;
// case "18":
// pobj.area = "";
// break;
// case "19":
// pobj.area = "";
// break;
// case "20":
// pobj.area = "";
// break;
// case "21":
// pobj.area = "";
// break;
// case "22":
// pobj.area = "";
// break;
// case "23":
// pobj.area = "";
// break;
// case "24":
// pobj.area = "";
// break;
// case "25":
// pobj.area = "";
// break;
// case "26":
// pobj.area = "";
// break;
// case "27":
// pobj.area = "";
// break;
// case "28":
// pobj.area = "";
// break;
// case "29":
// pobj.area = "";
// break;
// case "30":
// pobj.area = "";
// break;
//icp需求反馈 // default:
async icpFeedbackSubmit(pobj) { // opResult = system.getResult(null, "action_type参数错误");
var self = this; // break;
if (!pobj.intentionBizId) { }
return self.getResultFail("intentionBizId不能为空"); var param = {
} requestId: self.getUUID(),
if (!pobj.description) { requestUrl: "/api/ali/tm/consultation/submit",
return self.getResultFail("description不能为空"); requestjson: JSON.stringify(pobj),//请求地址
} pushUrl: "/action/intentionapi/springBoard",//调用地址
if (!pobj.intentionStatus) { pushActionType: "submitNeed",//调用参数
return self.getResultFail("intentionStatus不能为空"); pushtimes: 0,//推送次数
} pushStatus: "wts",//推送状态
var param = { }
requestId: self.getUUID(), await self.create(param);
requestUrl: "/api/ali/tm/feedback/submit", return self.getResultSuccess(param.requestId);
requestjson: JSON.stringify(pobj),//请求地址
pushUrl: "/action/intentionapi/queryOrderState",//调用地址
pushActionType: "icpFeedbackSubmit",//调用参数
pushtimes: 0,//推送次数
pushStatus: "wts",//推送状态
} }
await self.create(param);
return self.getResultSuccess(param.requestId);
}
//icp状态变更 //icp需求反馈
async icpNotify(pobj) { async icpFeedbackSubmit(pobj) {
var self = this; var self = this;
if (!pobj.bizId) { if (!pobj.intentionBizId) {
return self.getResultFail("bizId不能为空"); return self.getResultFail("intentionBizId不能为空");
} }
if (!pobj.status) { if (!pobj.description) {
return self.getResultFail("status不能为空"); return self.getResultFail("description不能为空");
}
if (!pobj.intentionStatus) {
return self.getResultFail("intentionStatus不能为空");
}
var param = {
requestId: self.getUUID(),
requestUrl: "/api/ali/tm/feedback/submit",
requestjson: JSON.stringify(pobj),//请求地址
pushUrl: "/action/intentionapi/springBoard",//调用地址
pushActionType: "icpFeedbackSubmit",//调用参数
pushtimes: 0,//推送次数
pushStatus: "wts",//推送状态
}
await self.create(param);
return self.getResultSuccess(param.requestId);
} }
var param = {
requestId: self.getUUID(), //icp状态变更
requestUrl: "/api/ali/tm/feedback/submit", async icpNotify(pobj) {
requestjson: JSON.stringify(pobj),//请求地址 var self = this;
pushUrl: "/action/intentionapi/queryOrderState",//调用地址 if (!pobj.bizId) {
pushActionType: "icpNotify",//调用参数 return self.getResultFail("bizId不能为空");
pushtimes: 0,//推送次数 }
pushStatus: "wts",//推送状态 if (!pobj.status) {
return self.getResultFail("status不能为空");
}
pobj.action_type="queryOrderState";
var param = {
requestId: self.getUUID(),
requestUrl: "/api/ali/tm/status/notify",
requestjson: JSON.stringify(pobj),//请求地址
pushUrl: "/action/intentionapi/springBoard",//调用地址
pushActionType: "icpNotify",//调用参数
pushtimes: 0,//推送次数
pushStatus: "wts",//推送状态
}
await self.create(param);
return self.getResultSuccess(param.requestId);
} }
await self.create(param);
return self.getResultSuccess(param.requestId);
}
} }
module.exports = GatewaypushlogService; module.exports = GatewaypushlogService;
\ No newline at end of file
igirl-channel-gateway/app/base/service/impl/utilsSve/utilsNeedSve.js
...@@ -84,6 +84,7 @@ class UtilsNeedSve extends AppServiceBase { ...@@ -84,6 +84,7 @@ class UtilsNeedSve extends AppServiceBase {
if (!userpin) { if (!userpin) {
return system.getResultFail(-88, "获取userpin失败!!"); return system.getResultFail(-88, "获取userpin失败!!");
} }
} }
//带userpin请求 //带userpin请求
url = settings.centerChannelUrl() + "/api/opreceive/need/springBoard"; url = settings.centerChannelUrl() + "/api/opreceive/need/springBoard";
...@@ -312,11 +313,13 @@ class UtilsNeedSve extends AppServiceBase { ...@@ -312,11 +313,13 @@ class UtilsNeedSve extends AppServiceBase {
pobj.publishMobile = result.data.publishMobile; pobj.publishMobile = result.data.publishMobile;
pobj.channelNeedNo = result.data.channelNeedNo; pobj.channelNeedNo = result.data.channelNeedNo;
pobj.needNo = result.data.needNo; pobj.needNo = result.data.needNo;
pobj.channelTypeCode = result.data.channelTypeCode;
pobj.province = result.data.province;
var sobj = { var sobj = {
"actionType": "icpNotify", "actionType": "icpNotify",
"actionBody": pobj "actionBody": pobj
} }
var result = await this.execlient.execDataPostByTokenUserPin(sobj, url, token,userpinResultTmp.data.userpin); var rtn = await this.execlient.execDataPostByTokenUserPin(sobj, url, token,userpinResultTmp.data.userpin);
if (!rtn || !rtn.stdout) { if (!rtn || !rtn.stdout) {
return { return {
"requestId": self.getUUID(), "requestId": self.getUUID(),
......
igirl-channel-gateway/app/config/routes/api.js
...@@ -136,136 +136,6 @@ module.exports = function (app) { ...@@ -136,136 +136,6 @@ module.exports = function (app) {
}); });
// //test
// app.use('/api/alitest/esp/intention/submit', async function (req, res) {
// try {
// console.log(req.headers['content-type'])
// if (req.headers['content-type'].indexOf('application/octet-stream')>-1 ) {
// await logCtl.applicationOctetStream2Json(req);
// }
// var client_ip = system.get_client_ip(req);
// 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,
// op: "api/ali/esp/intention/submit",
// content: "回调参数：" + JSON.stringify(req.body) + "回调处理订单结果：" + JSON.stringify(result),
// clientIp: client_ip || ""
// });
// res.end(JSON.stringify(result));
// return JSON.stringify(result);
// } catch (error) {
// logCtl.error({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调处理结果异常：，method=" + req.body.trxcode,
// op: "/api/ali/esp/intention/submit",
// content: "回调参数：" + JSON.stringify(req.body) + "error：" + error.stack,
// clientIp: client_ip || ""
// });
// return JSON.stringify(result);
// }
// });
// app.use('/api/alitest/esp/intention/solution/feedback', async function (req, res) {
// try {
// if (req.headers['content-type'].indexOf('application/octet-stream')>-1 ) {
// await logCtl.applicationOctetStream2Json(req);
// }
// var client_ip = system.get_client_ip(req);
// 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,
// op: "/api/ali/esp/intention/solution/feedback",
// content: "回调参数：" + JSON.stringify(req.body) + "回调处理订单结果：" + JSON.stringify(result),
// clientIp: client_ip || ""
// });
// res.end(JSON.stringify(result));
// return JSON.stringify(result);
// } catch (error) {
// logCtl.error({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调处理结果异常：，method=" + req.body.trxcode,
// op: "/api/ali/esp/intention/solution/feedback",
// content: "回调参数：" + JSON.stringify(req.body) + "error：" + error.stack,
// clientIp: client_ip || ""
// });
// }
// });
// app.use('/api/alitest/ic/paySuccess', async function (req, res) {
// try {
// if (req.headers['content-type'].indexOf('application/octet-stream')>-1 ) {
// await logCtl.applicationOctetStream2Json(req);
// }
// var client_ip = system.get_client_ip(req);
// 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,
// op: "/api/ali/ic/paySuccess",
// content: "回调参数：" + JSON.stringify(req.body) + "回调处理订单结果：" + JSON.stringify(result),
// clientIp: client_ip || ""
// });
// res.end(JSON.stringify(result));
// return JSON.stringify(result);
// } catch (error) {
// logCtl.error({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调处理结果异常：，method=" + req.body.trxcode,
// op: "/api/ali/ic/paySuccess",
// content: "回调参数：" + JSON.stringify(req.body) + "error：" + error.stack,
// clientIp: client_ip || ""
// });
// }
// });
// app.use('/api/alitest/ic/close', async function (req, res) {
// try {
// if (req.headers['content-type'].indexOf('application/octet-stream')>-1 ) {
// await logCtl.applicationOctetStream2Json(req);
// }
// var client_ip = system.get_client_ip(req);
// req.body.action_type = "orderClose";
// var result = await utilsNeedSve.orderClose(req.body, client_ip);
// logCtl.info({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "回调处理订单结果：，method=" + req.body.trxcode,
// op: "/api/ali/ic/close",
// content: "回调参数：" + JSON.stringify(req.body) + "回调处理订单结果：" + JSON.stringify(result),
// clientIp: client_ip || ""
// });
// res.end(JSON.stringify(result));
// return JSON.stringify(result);
// } catch (error) {
// logCtl.error({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调处理结果异常：，method=" + req.body.trxcode,
// op: "/api/ali/ic/close",
// content: "回调参数：" + JSON.stringify(req.body) + "error：" + error.stack,
// clientIp: client_ip || ""
// });
// }
// });
// app.use('/api/alitest/esp/intention/close', async function (req, res) {
// try {
// if (req.headers['content-type'].indexOf('application/octet-stream')>-1 ) {
// await logCtl.applicationOctetStream2Json(req);
// }
// var client_ip = system.get_client_ip(req);
// 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,
// op: "/api/ali/esp/intention/close",
// content: "回调参数：" + JSON.stringify(req.body) + "回调处理订单结果：" + JSON.stringify(result),
// clientIp: client_ip || ""
// });
// res.end(JSON.stringify(result));
// return JSON.stringify(result);
// } catch (error) {
// logCtl.error({
// optitle: (new Date()).Format("yyyy-MM-dd hh:mm:ss") + "记录回调处理结果异常：，method=" + req.body.trxcode,
// op: "/api/ali/esp/intention/close",
// content: "回调参数：" + JSON.stringify(req.body) + "error：" + error.stack,
// clientIp: client_ip || ""
// });
// }
// });
app.use('/api/ali/tm/consultation/submit', async function (req, res) { app.use('/api/ali/tm/consultation/submit', async function (req, res) {
try { try {
console.log(req.headers['content-type']) console.log(req.headers['content-type'])
......
igirl-channel-gateway/app/config/settings.js
...@@ -33,14 +33,14 @@ var settings = { ...@@ -33,14 +33,14 @@ var settings = {
}, },
channelApiUrl: function () {//----igirl-channel channelApiUrl: function () {//----igirl-channel
if (this.env == "dev") { if (this.env == "dev") {
return "http://gsb.qifu.gongsibao.com:4003"; return "http://192.168.210.192:4003";
} else { } else {
return "http://zc-channel-service"; return "http://zc-channel-service";
} }
}, },
centerChannelUrl: function () {//---------center-channel centerChannelUrl: function () {//---------center-channel
if (this.env == "dev") { if (this.env == "dev") {
return "http://gsb.qifu.gongsibao.com:4012";//localsettings.reqEsDevUrl; return "http://gsbweb.qifu-dev.gongsibao.com";//localsettings.reqEsDevUrl;
} else { } else {
return "http://center-channel-service"; return "http://center-channel-service";
} }
......
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