Commit 8a56e81f by 王勇飞

gyq

parent 425b8b69
...@@ -532,6 +532,7 @@ class TxHandler { ...@@ -532,6 +532,7 @@ class TxHandler {
} }
async ServiceCreate(datajson) { //获取融易算服务实例到队列 async ServiceCreate(datajson) { //获取融易算服务实例到队列
console.log("ServiceCreate----------------------------------------------",datajson);
var obj = { var obj = {
"pushUrl": this.bookUrl + "/deliverybillCtl/insertInfo", "pushUrl": this.bookUrl + "/deliverybillCtl/insertInfo",
"actionType": "insertInfo", "actionType": "insertInfo",
...@@ -547,6 +548,7 @@ class TxHandler { ...@@ -547,6 +548,7 @@ class TxHandler {
} }
async ServiceUpdate(datajson) { //更新融易算服务信息到队列 async ServiceUpdate(datajson) { //更新融易算服务信息到队列
console.log("ServiceUpdate----------------------------------------------",datajson);
var obj = { var obj = {
"pushUrl": this.bookUrl + "/deliverybillCtl/updateServer", "pushUrl": this.bookUrl + "/deliverybillCtl/updateServer",
"actionType": "updateServer", "actionType": "updateServer",
...@@ -563,6 +565,7 @@ class TxHandler { ...@@ -563,6 +565,7 @@ class TxHandler {
//融易算创建需求 //融易算创建需求
async LeadsCreate(datajson) { async LeadsCreate(datajson) {
console.log("LeadsCreate----------------------------------------------",datajson);
var obj = { var obj = {
"pushUrl": this.bookUrl + "/bizOptCtl/insertInfo", "pushUrl": this.bookUrl + "/bizOptCtl/insertInfo",
"actionType": "insertInfo", "actionType": "insertInfo",
...@@ -579,6 +582,7 @@ class TxHandler { ...@@ -579,6 +582,7 @@ class TxHandler {
//融易算更新需求状态 //融易算更新需求状态
async LeadsUpdate(datajson) { async LeadsUpdate(datajson) {
console.log("LeadsUpdate----------------------------------------------",datajson);
var obj = { var obj = {
"pushUrl": this.bookUrl + "/bizoptCtl/updatepayStatusByDemandCode", "pushUrl": this.bookUrl + "/bizoptCtl/updatepayStatusByDemandCode",
"actionType": "updatepayStatusByDemandCode", "actionType": "updatepayStatusByDemandCode",
...@@ -596,6 +600,7 @@ class TxHandler { ...@@ -596,6 +600,7 @@ class TxHandler {
// 融易算服务状态变更通知 // 融易算服务状态变更通知
async ServiceStatusNotify(datajson) { async ServiceStatusNotify(datajson) {
console.log("ServiceStatusNotify----------------------------------------------",datajson);
let ab = Object.assign({}, datajson); let ab = Object.assign({}, datajson);
ab.status = ab.status === 6 ? "inserivice" : "closed"; ab.status = ab.status === 6 ? "inserivice" : "closed";
var obj = { var obj = {
...@@ -614,6 +619,7 @@ class TxHandler { ...@@ -614,6 +619,7 @@ class TxHandler {
//融易算报表确认 //融易算报表确认
async ConfirmReport(datajson) { async ConfirmReport(datajson) {
console.log("ConfirmReport----------------------------------------------",datajson);
var messageBody = datajson; var messageBody = datajson;
messageBody.dataType = "2"; messageBody.dataType = "2";
messageBody.rysCheck = "1"; messageBody.rysCheck = "1";
...@@ -634,6 +640,7 @@ class TxHandler { ...@@ -634,6 +640,7 @@ class TxHandler {
//融易算报税确认 //融易算报税确认
async ConfirmTax(datajson) { async ConfirmTax(datajson) {
console.log("ConfirmTax----------------------------------------------",datajson);
var messageBody = datajson; var messageBody = datajson;
messageBody.dataType = "3"; messageBody.dataType = "3";
messageBody.rysCheck = "1"; messageBody.rysCheck = "1";
...@@ -654,6 +661,7 @@ class TxHandler { ...@@ -654,6 +661,7 @@ class TxHandler {
//融易算接收票据快递单号 //融易算接收票据快递单号
async ReceivePaperPost(datajson) { async ReceivePaperPost(datajson) {
console.log("ReceivePaperPost----------------------------------------------",datajson);
var obj = { var obj = {
"pushUrl": this.bookUrl + "/deliverybillCtl/receivePaperPost", "pushUrl": this.bookUrl + "/deliverybillCtl/receivePaperPost",
"actionType": "receivePaperPost", "actionType": "receivePaperPost",
...@@ -668,34 +676,26 @@ class TxHandler { ...@@ -668,34 +676,26 @@ class TxHandler {
return system.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": "3411844566204567789111", // "orderId": "3411844566204567789111",
"areatype": "city", // "areatype": "city",
"area": "100010", // "area": "100010",
"topOrgCode": "rong_yi_suan", // "topOrgCode": "rong_yi_suan",
"taxpayerType": 1 // "taxpayerType": 1
} // }
var d = await task.test(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");
})() // })()
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