Merge branch 'center-channel' of http://gitlab.gongsibao.com/jiangyong/zhichan into center-channel

center-channel/app/base/utils/execClient.js

@@ -9,7 +9,7 @@ class ExecClient {
         this.cmdPushDataPostPattern = "curl -k -H 'Content-type: application/json' -H 'token:{tk}' -H 'request-id:{requestId}' -d '{data}' {url}";
         this.cmdPushDataPostPattern = "curl -k -H 'Content-type: application/json' -H 'token:{tk}' -H 'request-id:{requestId}' -d '{data}' {url}";
         this.cmdFeishuGetPattern = "curl -X GET -k -H 'Content-Type: application/json' -H 'Authorization: {Authorization}' -d '{data}' {url} ";
         this.cmdFeishuGetPattern = "curl -X GET -k -H 'Content-Type: application/json' -H 'Authorization: {Authorization}' -d '{data}' {url} ";
         this.cmdFeishuPostPattern = "curl -k -H 'Content-type: application/json' -H 'Authorization: {Authorization}'  -d '{data}' {url}";
         this.cmdFeishuPostPattern = "curl -k -H 'Content-type: application/json' -H 'Authorization: {Authorization}'  -d '{data}' {url}";
-        
+
     }
     }
     getUUID() {
     getUUID() {
         var uuid = uuidv4();
         var uuid = uuidv4();
@@ -17,7 +17,7 @@ class ExecClient {
         return u;
         return u;
     }
     }
     async exec(cmd) {
     async exec(cmd) {
-        //await后面表达式返回的promise对象，是then的语法糖，await返回then函数的返回值
+        //await后面表达式返回的promise对象， 是then的语法糖，await返回then函数的返回值
         //异常需要try/catch自己捕获或外部catch捕获
         //异常需要try/catch自己捕获或外部catch捕获
         const { stdout, stderr } = await exec(cmd);
         const { stdout, stderr } = await exec(cmd);
         return { stdout, stderr };
         return { stdout, stderr };
@@ -38,7 +38,7 @@ class ExecClient {
     FetchFeishuPostCmd(subData, url) {
     FetchFeishuPostCmd(subData, url) {
         var data = JSON.stringify(subData);
         var data = JSON.stringify(subData);
         var cmd = this.cmdFeishuPostPattern.replace(/\{data\}/g,
         var cmd = this.cmdFeishuPostPattern.replace(/\{data\}/g,
-            data).replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer "+subData.token);
+            data).replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer " + subData.token);
         console.log(cmd);
         console.log(cmd);
         return cmd;
         return cmd;
     }
     }
@@ -62,7 +62,10 @@ class ExecClient {
     }
     }
     async execPushDataPost(subData, url, token, requestId) {
     async execPushDataPost(subData, url, token, requestId) {
         let cmd = this.FetchPushDataPostCmd(subData, url, token, requestId);
         let cmd = this.FetchPushDataPostCmd(subData, url, token, requestId);
-        var result = await this.exec(cmd);
+        var options = {
+            maxBuffer: 1024 * 1024 * 20
+        };
+        var result = await this.exec(cmd, options);
         return result;
         return result;
     }
     }
     async execPost2(subData, url) {
     async execPost2(subData, url) {
@@ -78,7 +81,7 @@ class ExecClient {
         return cmd;
         return cmd;
     }
     }
     FetchFqGetCmd(subData, url) {
     FetchFqGetCmd(subData, url) {
-        var cmd = this.cmdFeishuGetPattern.replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer "+subData.Authorization);
+        var cmd = this.cmdFeishuGetPattern.replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer " + subData.Authorization);
         console.log(cmd);
         console.log(cmd);
         return cmd;
         return cmd;
     }
     }
@@ -86,7 +89,7 @@ class ExecClient {
     //飞书小程序GET请求
     //飞书小程序GET请求
     FetchFeishuGetCmd(subData, url) {
     FetchFeishuGetCmd(subData, url) {
         var cmd = this.cmdFeishuGetPattern.replace(
         var cmd = this.cmdFeishuGetPattern.replace(
-            /\{data\}/g, subData).replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer "+subData.user_access_token);
+            /\{data\}/g, subData).replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer " + subData.user_access_token);
         console.log(cmd);
         console.log(cmd);
         return cmd;
         return cmd;
     }
     }
@@ -103,8 +106,8 @@ class ExecClient {
         return result;
         return result;
     }
     }
 
 
-    async execFqGet(subData,url){
-        let cmd = this.FetchFqGetCmd(subData,url);
+    async execFqGet(subData, url) {
+        let cmd = this.FetchFqGetCmd(subData, url);
         console.log(cmd);
         console.log(cmd);
         var result = await this.exec(cmd);
         var result = await this.exec(cmd);
         return result;
         return result;