// Notes:
// Throw POST-Request to "HttpStartEvent" in Questetra BPMS workflow.
// Supports loop processing (Bulk Start) Increment of Line ID / Appends BPMS ProcessID started
// The line data in the TSV will be thrown. (eg "title={Ai} q_str0={Bi} q_num2={Ci}")
// System limit of "Number of License + 100", Process start in every 15 minutes (R2170)
// System limit of "transition of tokens up to 500 times". (M204)
// About "HttpStartEvent" [Message Start Event (HTTP)]
// - https://questetra.zendesk.com/hc/en-us/articles/360002245432-M221
// - https://support.questetra.com/bpmn-icons/message-start-event-http/
// Request parameter is configured in CSV format. (eg "title,q_str0,q_num2")
// If #of Cols of TSV data is less than #of parameters, complemented with an empty string.
// If "HttpStartEvent" located at the most downstream, transfer data can be implemented.
// MultilineString type, Files type not supported.
// Data Format https://questetra.zendesk.com/hc/en-us/articles/360016441572-R2210
// The thousands separator for numeric data must be removed. (eg. "1234.56")
//
// Notes (ja):
// Questetraワークフロー内の "HTTP開始イベント" に POST-Request を投げます。
// ループ処理に対応します(一括起動) 指定する行IDのインクリメント/開始されたProcessIDの追記
// TSV内の指定行にあるデータが送出されます(例 "title={Ai} q_str0={Bi} q_num2={Ci}")
// 「15分間に『ライセンス数 + 100』プロセス起動」のシステム制限があります。(R2170)
// 「トークンの遷移は500回まで」のシステム制限があります。(M204)
// "HTTP開始イベント" [メッセージ開始イベント(HTTP)] について
// - https://questetra.zendesk.com/hc/ja/articles/360002245432-M221
// - https://support.questetra.com/ja/bpmn-icons/message-start-event-http/
// RequestパラメータはCSV形式で設定します(例 "title,q_str0,q_num2")
// TSVデータの横要素数がパラメータ数に足りない場合、空文字列で補完されます。
// "HTTP開始イベント" を最下流に配置しておけば、移行データの流し込みにも応用できます。
// 複数行文字列・ファイル型データは投入できません。
// 送信データのFormat https://questetra.zendesk.com/hc/ja/articles/360016441572-R2210
// 数値型データの桁区切り文字は除去しておく必要があります。 (eg. "1234.56")
//////// START "main()" ////////////////////////////////////////////////////////////////
main();
function main(){
//// == Config Retrieving / 工程コンフィグの参照 ==
const eventUri = configs.get( "conf_EventUri" ) + ""; // required
const apiKey = configs.get( "conf_ApiKey" ) + ""; // required
const restParams = configs.get( "conf_RestParams" ) + ""; // required
const strTsv = configs.get( "conf_StrTsv" ) + ""; // required
const dataIdI = configs.get( "conf_DataIdI" ) + ""; // required
const increment = configs.get( "conf_Increment" ) + ""; // not required
const dataIdJ = configs.get( "conf_DataIdJ" ) + ""; // not required
engine.log( " AutomatedTask Config: Event URI: " + eventUri );
if( increment === "false" || increment === "FALSE" ){
engine.log( " AutomatedTask Config: Increment: " + increment );
}else{
engine.log( " AutomatedTask Config: Increment: true" );
}
//// == Data Retrieving / ワークフローデータの参照 ==
let intLineId = 0;
if( engine.findDataByNumber( dataIdI ) !== null ){
intLineId = engine.findDataByNumber( dataIdI ) - 0;
// convet 'java.math.BigDecimal' to 'javascript number'
}
let strBpmsProcessIds = "";
if( dataIdJ !== "" ){
if( engine.findDataByNumber( dataIdJ ) !== null ){
strBpmsProcessIds = engine.findDataByNumber( dataIdJ ) + "";
}
}
//// == Calculating / 演算 ==
// REST Parameters
let arrRestParams = restParams.split(",");
engine.log( " AutomatedTask Config: RestParams: " + restParams );
engine.log( " AutomatedTask: #of RestParams: " + arrRestParams.length );
// Data to Throw
const arrStrTsv = strTsv.split("\n");
engine.log( " AutomatedTask MultilineString:" +
" TSV {D}, #of lines: " + arrStrTsv.length );
engine.log( " AutomatedTask Thrown Data:" +
" LineID " + intLineId + ": " + arrStrTsv[intLineId] );
const arrThrow = arrStrTsv[intLineId].split("\t");
// POST-Request to HttpStartEvent
// com.questetra.bpms.core.event.scripttask.HttpClientWrapper
let apiRequest = httpClient.begin(); // HttpRequestWrapper
apiRequest = apiRequest.formParam( "key", apiKey );
for( let j = 0; j < arrRestParams.length; j++){
if( j < arrThrow.length ){
apiRequest = apiRequest.formParam( arrRestParams[j], arrThrow[j] );
}else{
apiRequest = apiRequest.formParam( arrRestParams[j], "" );
}
}
// request to API
engine.log( " AutomatedTask Trying: POST " + eventUri );
const response = apiRequest.post( eventUri );
const responseCode = response.getStatusCode() + "";
engine.log( " AutomatedTask ApiResponse: Status " + responseCode );
if( responseCode !== "200"){
throw new Error( "\n AutomatedTask UnexpectedResponseError: " +
responseCode + "\n" + response.getResponseAsString() + "\n" );
}
const responseStr = response.getResponseAsString() + "";
engine.log( " AutomatedTask BPMS-ProcessID:" +
responseStr );
if( strBpmsProcessIds === "" ){
strBpmsProcessIds = responseStr;
}else{
strBpmsProcessIds += "\n" + responseStr;
}
//// == Data Updating / ワークフローデータへの代入 ==
if( increment === "false" || increment === "FALSE" ){
engine.log( " AutomatedTask LoopSupport: (LineID not incremented)" );
}else{
intLineId = intLineId + 1;
engine.setDataByNumber( dataIdI, new java.math.BigDecimal( intLineId ) );
engine.log( " AutomatedTask LoopSupport: LineID incremented to " + intLineId );
}
if( dataIdJ !== "" ){
engine.setDataByNumber( dataIdJ, strBpmsProcessIds );
}
} //////// END "main()" ////////////////////////////////////////////////////////////////
Pingback: Connector (TSV Bulk Start) – Questetra Support