add LeadsCreate by zqx

center-manage/app/base/service/impl/common/channelhandlers/tx.js

@@ -526,7 +526,7 @@ class TxHandler {
 
 
     }
     }
 
 
-  async ServiceCreate(datajson) {//获取融易算服务实例到队列
+    async ServiceCreate(datajson) { //获取融易算服务实例到队列
             try {
             try {
                 var rc = system.getObject("util.execClient");
                 var rc = system.getObject("util.execClient");
                 var requrl = this.queueUrl;
                 var requrl = this.queueUrl;
@@ -553,8 +553,7 @@ class TxHandler {
                         "errorMsg": "ok",
                         "errorMsg": "ok",
                         "data": null
                         "data": null
                     }
                     }
-      }
-      else {
+                } else {
                     return {
                     return {
                         "requestId": datajson.requestId,
                         "requestId": datajson.requestId,
                         "success": false,
                         "success": false,
@@ -564,8 +563,7 @@ class TxHandler {
                     }
                     }
                 }
                 }
 
 
-    }
-    catch (error) {
+            } catch (error) {
                 return {
                 return {
                     "requestId": datajson.requestId,
                     "requestId": datajson.requestId,
                     "success": false,
                     "success": false,
@@ -611,6 +609,33 @@ class TxHandler {
     //   }
     //   }
 
 
     // }
     // }
+    async LeadsCreate(datajson) {
+        try {
+            var rc = system.getObject("util.execClient");
+            var requrl = this.queueUrl //改队列
+            var params = {
+                "actionType":   "produceData",
+                "actionBody":  {          
+                    "pushUrl":  this.icUrl  +  "/bizOptCtl",
+                    "actionType":   "insertInfo",
+                    "identifyCode":   "book-manage",
+                    "messageBody":  datajson,
+                    "headData": null //
+                },
+                "requestId": datajson.requestId
+            }
+            var  rtn  =  await  rc.execPost(params,  requrl);      
+            var  j  =  JSON.parse(rtn.stdout);      
+            if  (j.status  ==  1)  {        
+                return  system.getResult("获取数据成功！");      
+            }      
+            else  {        
+                return  system.getResultError("获取数据失败！");      
+            }
+        } catch (error) {
+            return system.getResultError(error)
+        }
+    }
 }
 }
 
 
 module.exports = new TxHandler();
 module.exports = new TxHandler();
@@ -633,4 +658,3 @@ module.exports = new TxHandler();
 //   console.log(JSON.stringify(d));
 //   console.log(JSON.stringify(d));
 //   console.log("dddddddddddddd");
 //   console.log("dddddddddddddd");
 // })()
 // })()
\ No newline at end of file
-