Skip to content

Z
zhichan
Commit 6187456a by v_vjyjiang
Options

gyq

parent a5ea8963
Showing with 44 additions and 44 deletions
center-manage/app/base/service/impl/common/channelhandlers/tx.js
...@@ -8,7 +8,6 @@ class TxHandler { ...@@ -8,7 +8,6 @@ class TxHandler {
this.userService = system.getObject("service.auth.userSve"); this.userService = system.getObject("service.auth.userSve");
this.msgService = system.getObject("service.msg.msgSve") this.msgService = system.getObject("service.msg.msgSve")
this.cacheManager = system.getObject("db.common.cacheManager"); this.cacheManager = system.getObject("db.common.cacheManager");
this.queueUrl = settings.bpushUrl();
this.bookUrl = settings.bookUrl() + "/web/bizchance"; this.bookUrl = settings.bookUrl() + "/web/bizchance";
} }
...@@ -538,7 +537,7 @@ class TxHandler { ...@@ -538,7 +537,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
async ServiceUpdate(datajson) { //更新融易算服务信息到队列 async ServiceUpdate(datajson) { //更新融易算服务信息到队列
...@@ -553,7 +552,7 @@ class TxHandler { ...@@ -553,7 +552,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
//融易算创建需求 //融易算创建需求
...@@ -569,7 +568,7 @@ class TxHandler { ...@@ -569,7 +568,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
//融易算更新需求状态 //融易算更新需求状态
...@@ -585,7 +584,7 @@ class TxHandler { ...@@ -585,7 +584,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
...@@ -604,7 +603,7 @@ class TxHandler { ...@@ -604,7 +603,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
//融易算报表确认 //融易算报表确认
...@@ -624,7 +623,7 @@ class TxHandler { ...@@ -624,7 +623,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
//融易算报税确认 //融易算报税确认
...@@ -644,7 +643,7 @@ class TxHandler { ...@@ -644,7 +643,7 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
//融易算接收票据快递单号 //融易算接收票据快递单号
...@@ -660,30 +659,37 @@ class TxHandler { ...@@ -660,30 +659,37 @@ class TxHandler {
} }
} }
return systetm.rysQueueOper(obj); return system.rysQueueOper(obj);
} }
async test(datajson){
var rc = system.getObject("util.execClient");
var reqUrl = this.bookUrl + "/bizOptCtl/insertInfo";
var result = await rc.execPost3(datajson, reqUrl);
//var j = JSON.parse(result.stdout);
return result;
}
} }
module.exports = new TxHandler(); module.exports = new TxHandler();
// (async () => { (async () => {
// var task = new TxHandler(); var task = new TxHandler();
// var obj = { var obj = {
// "requestId": "825da0a74432-738f-4bed-b48d-d51aa808", "requestId": "825da0a74432-738f-4bed-b48d-d51aa808",
// "bizId": "5892748825678", "bizId": "5892748825678",
// "contactsPhone": "18510669321", "contactsPhone": "18510669321",
// "userId": "10973452443103825", "userId": "10973452443103825",
// "orderId": "341184456620456778900", "orderId": "341184456620456778900",
// "areatype": "city", "areatype": "city",
// "area": "100010", "area": "100010",
// "topOrgCode": "rong_yi_suan", "topOrgCode": "rong_yi_suan",
// "taxpayerType": 1 "taxpayerType": 1
// } }
// var d = await task.ServiceCreate(obj); var d = await task.test(obj);
// console.log("ddddddddddddd"); console.log("ddddddddddddd");
// console.log(JSON.stringify(d)); console.log(JSON.stringify(d));
// console.log("dddddddddddddd"); console.log("dddddddddddddd");
// })() })()
center-manage/app/base/system.js
...@@ -376,25 +376,26 @@ class System { ...@@ -376,25 +376,26 @@ class System {
requestId string 请求id requestId string 请求id
*/ */
static async rysQueueOper(obj) { static async rysQueueOper(obj) {
console.log("obj-----------------------",obj);
if (obj.pushUrl && obj.actionType && obj.messageBody) { if (obj.pushUrl && obj.actionType && obj.messageBody) {
try { try {
var rc = this.getObject("util.execClient"); var rc = this.getObject("util.execClient");
var reqUrl = settings.queueUrl; var reqUrl = settings.pushUrl;
var reqId = uuidv4(); var reqId = uuidv4();
var param = { var param = {
actionType: "produceData", "actionType": "produceData",
actionBody: { "actionBody": {
pushUrl: obj.pushUrl, "pushUrl": obj.pushUrl,
actionType: obj.actionType, "actionType": obj.actionType,
identifyCode: "book-manage", "identifyCode": "book-manage",
messageBody: obj.messageBody "messageBody": obj.messageBody
} }
} }
if (obj.notifyUrl) { if (obj.notifyUrl) {
param.actionBody.notifyUrl = obj.notifyUrl; param.actionBody.notifyUrl = obj.notifyUrl;
} }
if (obj.headData) { if (obj.headData) {
param.actionBody.headData; param.actionBody.headData = obj.headData;
} }
if (obj.requestId) { if (obj.requestId) {
param.requestId = obj.requestId; param.requestId = obj.requestId;
......
center-manage/app/config/settings.js
...@@ -49,7 +49,7 @@ var settings = { ...@@ -49,7 +49,7 @@ var settings = {
}, },
bookUrl: function () { bookUrl: function () {
if (this.env == "localhost") { if (this.env == "localhost") {
return "http://192.168.1.19:8889"; return "http://192.168.210.185:8889";
} else { } else {
return "http://icdeliver-service"; return "http://icdeliver-service";
} }
...@@ -63,14 +63,7 @@ var settings = { ...@@ -63,14 +63,7 @@ var settings = {
}, },
pushUrl: function () { pushUrl: function () {
if (this.env == "localhost") { if (this.env == "localhost") {
return "http://192.168.18.101:4018/api/queueAction/producer/springBoard"; return "http://192.168.18.101:4018/api/queueAction/plsroducer/springBoard";
} else {
return "http://logs-sytxpublic-msgq-service/api/queueAction/producer/springBoard";
}
},
bpushUrl: function () {
if (this.env == "localhost") {
return "http://192.168.1.19:4018/api/queueAction/producer/springBoard";
} else { } else {
return "http://logs-sytxpublic-msgq-service/api/queueAction/producer/springBoard"; return "http://logs-sytxpublic-msgq-service/api/queueAction/producer/springBoard";
} }
......
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