baiduclient

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

 const co = require("co");
 var request = require("request");
+const crypto = require('crypto');
 const sha256 = require('sha256');
 var urlencode = require('urlencode');
 const system = require("../system");
 class baiduClient {
   constructor() {
     this.pushlogSve = system.getObject("service.common.pushlogSve");
+    this.execClient = system.getObject("util.execClient");
   }
   
   //2020 1027 laolan 调用百度网关
@@ -101,5 +103,69 @@ class baiduClient {
       return system.getResultFail(-200, "出现异常，error：" + e.stack);
     }
   }
+
+  async test(){
+    var obj={
+      path:"/api/bla/provider/plan",
+      reqbody:{
+        "area" : "北京",
+        "companyName" : "demoData",
+        "companyAddress" : "demoData",
+        "requirementId" : "TRE-nmnHtEoTjeE",
+        "type" : "ICP"
+      }
+    };
+    var actionBody = obj.reqbody;
+    var path = obj.path;
+    let domain = "https://gwgp-mwnn9gk4o4e.i.bdcloudapi.com";
+    let url = domain+path;
+    let version ="bce-auth-v1";
+    let accessKey =  "ed0f5c4c7c2d4e87aa335d9b07bf9bd4";
+    let secretKey = "f600c4e91f6d43998d637401e6e34ef9";
+    let timestamp = new Date().toISOString();
+    let signedHeaders = "host";
+    let extime = 1800;
+    var signArr = [];
+    var keys = Object.keys(actionBody).sort();
+    if (keys.length == 0) {
+      return system.getResult(null, "请求参数信息为空");
+    }
+    for (let k = 0; k < keys.length; k++) {
+      const tKey = keys[k];
+      if (tKey != "sign" && actionBody[tKey] && !(typeof (actionBody[tKey]) === "object")) {
+        signArr.push(urlencode(tKey) + "=" + urlencode(actionBody[tKey]));
+      }
+    }
+    let resultSignStr = signArr.join("&");
+    console.log('resultSignStr+++',resultSignStr)
+    let canonicalHeaders = "host:gwgp-mwnn9gk4o4e.i.bdcloudapi.com"
+    //中间结果1：规范化请求和前缀字符串
+    let canonicalRequest = "POST" + "\n" + path + "\n" + resultSignStr + "\n" + canonicalHeaders;
+    //authStringPrefix(前缀字符串，由除sk字段外的签名信息生成)
+    let authStringPrefix = version+"/"+accessKey+"/"+timestamp+"/"+extime;
+    //中间结果2：派生签名密钥 signingKey
+    let signingKey = crypto.createHmac('sha256', secretKey)
+                   .update(authStringPrefix)
+                   .digest('hex');
+    //中间结果3：签名摘要 signature
+    let signature = crypto.createHmac('sha256', signingKey)
+                   .update(canonicalRequest)
+                   .digest('hex');
+    //最终结果：认证字符串 authorization
+    let authorization = authStringPrefix+"/"+signedHeaders+"/"+signature;
+    var baiduObj={
+      authorization:authorization,
+      data:actionBody
+    }
+    var rtn = await this.execClient.execBaiduPost(baiduObj, url);
+    if (!rtn || !rtn.stdout) {
+      return system.getResult(null, "execPost data is empty");
+    }
+    var result = JSON.parse(rtn.stdout);
+    if(!result || !result.result ){
+      return system.getResultFail("推送失败");
+    }
+    return system.getResultSuccess();
+  }
 }
 module.exports = baiduClient;

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

@@ -12,6 +12,8 @@ class ExecClient {
         this.cmdFeishuPostPattern = "curl -k -H 'Content-type: application/json' -H 'Authorization: {Authorization}'  -d '{data}' {url}";
         //360
         this.cmd360PostPattern = "curl -u gongsibao:qPa4PsVsxbQ847i5pOKSmfPKrzRoNKqx -d '{data}' -X POST {url}"
+
+        this.cmdBaiduPostPattern = "curl -k -H 'Content-type: application/json' -H 'Authorization: {Authorization}'  -d '{data}' {url}";
     }
     getUUID() {
         var uuid = uuidv4();
@@ -44,6 +46,13 @@ class ExecClient {
         console.log(cmd);
         return cmd;
     }
+    FetchBaiduPostCmd(subData, url) {
+        var data = JSON.stringify(subData);
+        var cmd = this.cmdBaiduPostPattern.replace(/\{data\}/g,
+            data).replace(/\{url\}/g, url).replace(/\{Authorization\}/g, subData.authorization);
+        console.log(cmd);
+        return cmd;
+    }
     FetchPushDataPostCmd(subData, url, token, requestId) {
         var requestId = requestId || this.getUUID();
         var data = JSON.stringify(subData);
@@ -62,6 +71,11 @@ class ExecClient {
         var result = await this.exec(cmd);
         return result;
     }
+    async execBaiduPost(subData, url) {
+        let cmd = this.FetchBaiduPostCmd(subData, url);
+        var result = await this.exec(cmd);
+        return result;
+    }
     async execPushDataPost(subData, url, token, requestId) {
         let cmd = this.FetchPushDataPostCmd(subData, url, token, requestId);
         var options = {