## 一、新增腳本

點(diǎn)擊新增腳本，創(chuàng)建腳本。

## 二、腳本配置

腳本名稱(chēng)：可自定義腳本名稱(chēng)
腳本使用場(chǎng)景碼：請(qǐng)輸入英文
腳本類(lèi)型：支持 java、JS、python
腳本源代碼：可輸入或直接粘貼代碼

## 三、腳本示例

### 1、簽名腳本

如何使用簽名腳本：
（1）首先在腳本管理中創(chuàng)建腳本

![](/media/202310/2023-10-19_101649_7262700.15524074678125077.png)

![](/media/202310/2023-10-19_101804_2404220.5491600903521338.png)
腳本名稱(chēng)可以可以自己定義，腳本使用場(chǎng)景編碼使用英文命名，如：sign;腳本類(lèi)型可以選擇自己使用的開(kāi)發(fā)語(yǔ)言。

（2）編寫(xiě)腳本

在應(yīng)用 shuhuan-ipaas-app-libs 的 signer 目錄下開(kāi)發(fā)簽名類(lèi)，簽名算法改成通過(guò) java 執(zhí)行=腳本=的方案實(shí)現(xiàn)簽名算法，簽名類(lèi)需要繼承 JavaScriptRunner 類(lèi)重寫(xiě) execute 方法

```
/**
 * @author yunmu
 * @date 2022-03-04 6:44 下午
 */
public abstract class JavaScriptRunner {

public abstract <T> T execute(Object params);
}
```

params 是一個(gè) Map 對(duì)象，Map 中會(huì)包含以下數(shù)據(jù)：

* 上下文參數(shù)數(shù)據(jù)
* signRequest 待簽名的 http 請(qǐng)求獲取方式：

```
HttpApiRequest apiRequest = (HttpApiRequest) paramsMap.get(SignConfigConstant.SIGN_REQUEST);
```

* 簽名配置中的 signInField 中的信息
* signOutField 簽名的輸出字段

簽名=腳本=示例：

```
package com.shuhuan.ipaas.applibs.signer;

import com.aliyun.unicorn.http.MultipartFormData;
import com.aliyun.unicorn.http.MultipartFormValue;
import com.aliyun.unicorn.http.QueryString;
import com.aliyun.unicorn.sdk.HttpApiRequest;
import com.aliyun.unicorn.type.Consumer;
import com.aliyun.unicorn.type.Parameter;
import com.shuhuan.ipaas.common.ResultCode;
import com.shuhuan.ipaas.core.encryption.Md5Util;
import com.shuhuan.ipaas.exception.IpaasException;
import com.shuhuan.ipaas.meta.constants.SignConfigConstant;
import com.shuhuan.ipaas.script.java.JavaScriptRunner;
import org.apache.commons.lang3.StringUtils;

import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.TreeMap;

/**
 * @author yunmu
 * @date 2022-03-05 4:22 下午
 */
public class BanniuScriptSigner extends JavaScriptRunner {

private static final String METHOD = "method";
    private static final String ACCESS_TOKEN = "access_token";
    public static final String TIMESTAMP = "timestamp";
    private static final String SIGN = "sign";
   private static final String APP_KEY = "app_key"; 
   private static final String APP_SECRET=app_secret

@Override
    public <T> T execute(Object params) {
        if (!(params instanceof Map)){
            throw new IpaasException(ResultCode.PARAM_ERROR, "params is not map");
        }
        Map<String,Object> paramsMap = (Map<String, Object>) params;
        //固定寫(xiě)法 ，獲取 rquest 
HttpApiRequest apiRequest = (HttpApiRequest) paramsMap.get(SignConfigConstant.SIGN_REQUEST);
     
       // 獲取參數(shù)
        String appKey = (String) paramsMap.get(APP_KEY);
        String appSecret = (String) paramsMap.get(APP_SECRET);
       //獲取 http 請(qǐng)求的數(shù)據(jù)
        QueryString queryString = apiRequest.getQueryString();

// ******開(kāi)始業(yè)務(wù)邏輯，根據(jù)實(shí)際的簽名要求編寫(xiě)
        TreeMap<String, String> pmap = new TreeMap<>();
        queryString.foreachValues((paramKey, value) -> {
            pmap.put(paramKey, value);
        });

MultipartFormData formData = apiRequest.getForm();
        if (formData != null && !formData.isMultipart()) {
            apiRequest.getForm().foreach(new Consumer<Parameter<MultipartFormValue>>() {
                @Override
                public void accept(Parameter<MultipartFormValue> a) {
                    String v = a.getFirstValue() != null ? a.getFirstValue().getValue() : null;
                    if (METHOD.equals(a.getName())) {
                        pmap.put(METHOD, v);
                    }
                    if (ACCESS_TOKEN.equals(a.getName())) {
                        pmap.put(ACCESS_TOKEN, v);
                    }
                    if (TIMESTAMP.equals(a.getName())) {
                        pmap.put(METHOD, v);
                    }
                    if (ACCESS_TOKEN.equals(a.getName())) {
                        pmap.put(ACCESS_TOKEN, v);
                    }
                }
            });
        }

String stringToSign = sign(pmap, appSecret);
        String signature = Md5Util.md5(stringToSign, "utf-8").toUpperCase();
      //把簽名放入 http 參數(shù)
        queryString.add(SIGN, signature);
       // ****結(jié)束業(yè)務(wù)邏輯
      
        //以下為固定格式，不要?jiǎng)?        Map<String, String> resultMap = new HashMap<>();
        resultMap.put(SignConfigConstant.SIGNATURE, signature);
        resultMap.put(SignConfigConstant.STRING_TO_SIGN, stringToSign);
        return (T) resultMap;
    }

// 代碼一, 簽名排序代碼.
    // pmap 為所有參數(shù), TreeMap 表示為樹(shù)形結(jié)構(gòu)的哈希容器
    // appSecret 班牛分配給您的密鑰
    private String sign(TreeMap<String, String> pmap, String appSecret) {
        StringBuilder sb = new StringBuilder(appSecret);
        Iterator i$ = pmap.entrySet().iterator();
        while (i$.hasNext()) {
            Map.Entry<String, String> entry = (Map.Entry) i$.next();
            String name = entry.getKey();
            String value = entry.getValue();
            if (StringUtils.isNoneEmpty(new String[]{name, value})) {
                sb.append(name).append(value);
            }
        }
        sb.append(appSecret);

return sb.toString();
    }
}
```

（3）在執(zhí)行動(dòng)作中使用簽名
點(diǎn)擊簽名配置，選擇新增
![](/media/202310/2023-10-19_102319_9760820.3506176920065096.png)

![](/media/202310/2023-10-19_102443_6651520.2512401254686798.png)
選擇已經(jīng)創(chuàng)建好的腳本，且可以向腳本中傳遞參數(shù)，參數(shù)的 key 可以自己命名，參數(shù)的值可以自己寫(xiě)成固定的，也可以使用授權(quán)時(shí)寫(xiě)入的變量；
如授權(quán)時(shí)的參數(shù)：
![](/media/202310/2023-10-19_102835_5336670.33633673773969575.png)
則可以通過(guò)如下形式獲取變量：
![](/media/202310/2023-10-19_102959_0048230.8558484581910276.png)
在腳本簽名代碼中通過(guò)如下方式獲取到數(shù)據(jù)：
private static final String APP_KEY = "app_key";
private static final String APP_SECRET="app_secret";

![](/media/202310/2023-10-19_102722_7032780.9069110896787689.png)

### 2、觸發(fā)器腳本

有些應(yīng)用會(huì)推送消息，需要接收消息并處理接收到的數(shù)據(jù)，譬如解密數(shù)據(jù)、判斷數(shù)據(jù)是否符合要求，這時(shí)需要通過(guò)腳本來(lái)處理。

（1）定義觸發(fā)器

![](/media/202310/2023-10-19_104238_6511060.9550918358610807.png)
觸發(fā)器需要輸入動(dòng)作的名稱(chēng)和動(dòng)作 key，動(dòng)作 key 非常重要，不能重復(fù)，必須和代碼中的 eventType 值一樣。
（2）編碼觸發(fā)消息處理腳本

編寫(xiě)事件回調(diào)數(shù)據(jù)處理 =腳本= 。
例如 java 腳本，必須繼承  JavaScriptRunner，

```
package com.shuhuan.ipaas.applibs.dealPushEventContent.caoliao;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists;
import com.shuhuan.ipaas.script.java.JavaScriptRunner;
import lombok.extern.slf4j.Slf4j;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**

* 推送事件  數(shù)據(jù)處理
* 文檔地址: https://cli.im/help/65847
  */
  @Slf4j
  public class caoliaoDemo extends JavaScriptRunner {
  
  //以下定義的變量是固定的，不要改
  private static final String EVENT_TYPE = "eventType";
  
  private static final String BODY = "body";
  
  private static final String EVENT_CONTENTS = "eventContents";
  
  private static final String EVENT_CONTENT = "eventContent";
  
  private static final String ASSET = "asset";
  
  private static final String RESULT = "result";
  //結(jié)束固定變量定義
  
  @Override
  public <T> T execute(Object params) {
  return (T) buildPushEventOutput(params);
  }
  /*
  {
  "asset": {},
  "body": {
  "time": "2022-06-30 17:06:39",
  "event": "FORM_DATA_SUBMIT",
  "data": {
  "ref_data": {
  "created_at": "2022-06-30 17:06:39",
  "serial_number": "L1000001",
  "form": {
  "number": "D20",
  "name": "會(huì)議簽到"
  },
  "fields": {
  "姓名": "草料",
  "手機(jī)": "18888648888",
  "微信名": "CHEN",
  "身份證號(hào)": "330200000000000000",
  "工號(hào)": "FBI100",
  "單選項(xiàng)": "是"
  }
  }
  }
  }
  @return {
  "result": {
  "code": 200,
  "message": "success"
  },
  "eventContents": [{
  "eventType": "FORM_DATA_SUBMIT",
  "eventContent": {
  "ref_data": {
  "created_at": "2022-06-30 17:06:39",
  "serial_number": "L1000001",
  "form": {
  "number": "D20",
  "name": "會(huì)議簽到"
  },
  "fields": {
  "姓名": "草料",
  "手機(jī)": "18888648888",
  "微信名": "CHEN",
  "身份證號(hào)": "330200000000000000",
  "工號(hào)": "FBI100",
  "單選項(xiàng)": "是"
  }
  }
  }
  }]
  }
  */
  
  public static JSONObject buildPushEventOutput(Object params) {
  JSONObject output = new JSONObject();
  if (!(params instanceof Map)) {
  log.error("當(dāng)前腳本入?yún)㈩?lèi)型錯(cuò)誤！期望是 Map，但是實(shí)際為{}，具體值為{}", params.getClass().getName(), JSON.toJSONString(params));
  return output;
  }
  JSONObject input = (JSONObject) params;
  
  /**
  
  * 這里的事件內(nèi)容的數(shù)據(jù)類(lèi)型，有可能是數(shù)組，也可能是對(duì)象，具體按照推送方格式為準(zhǔn)，作匹配的處理：
  * 1.解密（不是所有的消息都需要做）
  * 2.獲取事件的標(biāo)識(shí)
  * 3.將事件標(biāo)識(shí)轉(zhuǎn)換為觸發(fā)器的 key
  * 4.構(gòu)造接口返回，務(wù)必與推送方要求保持一致
    */

/* 1. 解密
該參數(shù)包含秘鑰等信息，如果推送數(shù)據(jù)是密文，可以用該參數(shù)里的秘鑰進(jìn)行解密，例如：
首先獲取授權(quán)時(shí)填寫(xiě)的信息
JSONObject asset = input.getJSONObject(ASSET);
String encrypt = input.getJSONObject(BODY).getString("encrypt");
獲取授權(quán)時(shí)填寫(xiě)的解密秘鑰
String encoding_aes_key = asset.getString("encoding_aes_key");
//按照文檔給的算法進(jìn)行解密
String CIPHER_ALGORITHM = "AES/CBC/PKCS5Padding";
String KEY_ALGORITHM = "AES";
String CHARSET = "UTF-8";
Cipher cipher = Cipher.getInstance(CIPHER_ALGORITHM);
byte[] key = Base64.decodeBase64(encoding_aes_key);
SecretKeySpec keySpec = new SecretKeySpec(key, KEY_ALGORITHM);
cipher.init(Cipher.DECRYPT_MODE, keySpec, new IvParameterSpec(new byte[16]));
String body =  new String(cipher.doFinal(Base64.decodeBase64(encrypt)), CHARSET);
*/
List<JSONObject> eventContents = Lists.newArrayList();
JSONObject data = (JSONObject) input.get(BODY);
JSONObject item = new JSONObject();
//2. 獲取對(duì)應(yīng)事件的 key。
String event = (String) data.get("event");
//3. 做觸發(fā)器的 key 與事件的 key 映射
if ("FORM_DATA_SUBMIT".equals(event)) {
item.put(EVENT_TYPE, "FORM_DATA_SUBMIT");
} else if ("FORM_DATA_EDITED".equals(event)) {
item.put(EVENT_TYPE, "FORM_DATA_EDITED");
} else if ("FORM_DATA_REVIEW".equals(event)) {
item.put(EVENT_TYPE, "FORM_DATA_REVIEW");
}
//4. 對(duì)應(yīng)事件的輸出內(nèi)容，這里的內(nèi)容是外部應(yīng)用推送過(guò)來(lái)的原始數(shù)據(jù)，與觸發(fā)器的輸出字段保持一致
item.put(EVENT_CONTENT, JSON.parseObject(data.getString("data")));
eventContents.add(item);
output.put(EVENT_CONTENTS, eventContents);

//推送事件后的響應(yīng)結(jié)果，必須和推送方要求的返回結(jié)果一致,固定寫(xiě)法
Map<String, Object> result = new HashMap<>(16);
result.put("code", 0);
result.put("message", "success");
output.put(RESULT, result);
return output;
}

}

腳本返回?cái)?shù)據(jù)格式必須是
{
"result": {
			"code": 200,
			"message": "success"
		},
		"eventContents": [{
			"eventType": "FORM_DATA_SUBMIT",
			"eventContent": {
                         //外部推送的數(shù)據(jù)
			}
		}]
	}

如：
 
{
		"result": {
			"code": 200,
			"message": "success"
		},
		"eventContents": [{
			"eventType": "FORM_DATA_SUBMIT",
			"eventContent": {

//外部推送的數(shù)據(jù)
				"ref_data": {
					"created_at": "2022-06-30 17:06:39",
					"serial_number": "L1000001",
					"form": {
						"number": "D20",
						"name": "會(huì)議簽到"
					},
					"fields": {
						"姓名": "草料",
						"手機(jī)": "18888648888",
						"微信名": "CHEN",
						"身份證號(hào)": "330200000000000000",
						"工號(hào)": "FBI100",
						"單選項(xiàng)": "是"
					}
				}

}
		}]
	}
```

## 四、腳本 SDK 下載

Java 腳本 SDK：[shuhuan-ipaas-script-demo.zip](https://sh-assets.oss-cn-hangzhou.aliyuncs.com/sdk/shuhuan-ipaas-script-demo.zip)

*注：可在下載 SDK Demo 中進(jìn)行編寫(xiě)腳本，SDK Demo 中所引用的依賴(lài)均可以在數(shù)環(huán)通腳本中使用。*

腳本配置說(shuō)明