创建泛微OA连接器

函数代码如下：

/**
 * common是平台提供的公共函数，包括方法有post和get请求
 *
 * const common = require("./common.js");
 * const headers = {};
 * const body = "";
 * 示例1：异步调用
 * common.httpRequest("http://localhost:8080/test", headers, body, "POST").then((data) => {
 *      if(data.code < 300){
 *         return data.body;
 *      }
 *      return {};
 * });
 *
 * 示例2：同步调用
 * const data = await common.httpRequest("http://localhost:8080/test", headers, body, "POST");
 * if(data.code < 300){
 *     return data.body;
 * }
 * return {};
 * 接口返回 data = {
 *                "headers": {},
 *               "body": string,
 *               "code": number,
 *               "error": string
 *               }
 */
/**
 *
 * mssiAuthData参数样例
 * {
 *      "header":{}, // 连接器认证header参数
 *      "path": {}, // 连接器认证path参数
 *      "query":{}, // 连接器认证query参数
 *      "body":{}, // 连接器认证body参数
 *      "host":"https://demo.com // API主机地址
 * }
 *
 */
const encryptpwd = require('node-jsencrypt')
const axios = require('axios')
function extractEventData(event, name) {
    let data = event[name]
    if (event.isBase64Encoded && data) {
        data = new Buffer(data, 'base64').toString()
    }
    return data ? JSON.parse(data) : {}
}
function getReqInfo(inputData, authData){
    let appid = inputData["appid"]
    let secret = inputData["secret"]
    let spk = inputData["spk"]
    let url = inputData["url"]
    let time = inputData["time"]
    let ct = new encryptpwd()
    ct.setPublicKey(spk)
    cry_secret = ct.encrypt(secret)
    let req_body = {
        "appid": appid,
        "secret": cry_secret,
        "time": time
    }
    // let req_url = authData["host"] + url
    let req_url = "http://110.41.7.110:6060" + url
    
    return {
        "req_url": req_url,
        "req_body": req_body
    }
}
// 发送请求获取token
async function getToken(mssiAuthData, inputData){
    let reqInfo = getReqInfo(inputData, mssiAuthData)
    let url = reqInfo["req_url"]
    let body = reqInfo["req_body"]
    let res = {}
    
    res = await axios.post(
        url,
        {},
        {"headers": {
            "appid": body["appid"],
            "secret": body["secret"]
        }}
    )
    
    
    return res.data
}
/**
 * 函数是方法的入口
 * @param {*} event  执行事件（event）， 包含用户定义的函数参数以及所选择的的连接器认证相关参数
 * @param {*} context  Runtime提供的函数执行上下文
 * @returns
 */
exports.handler = async function (event, context) {
    const inputData = extractEventData(event, 'body') // 用户定义的函数参数数据
    const mssiAuthData = extractEventData(event, 'mssiAuthData') // 连接器认证数据
    mssiAuthData.securityToken = context.getToken()
    const dataExtendConfig = extractEventData(event, 'dataExtendConfig')  // 流步骤扩展参数
    
    let result =  await getToken(mssiAuthData, inputData);
    return result
}

注意需要引入相关依赖包，其它参数默认值：