Eu tenho aqui um dataset que faz um GET em um serviço que cadastrei nos serviços REST do fluig.
Seto a url do serviço no fluig e identifico ela com o serviceCode, mostrado abaixo.
O endpoint funciona como path param, utilizo para fazer login no serviço
function defineStructure() {
addColumn("nom_sims");
addColumn("nom_abreviado");
addColumn("nom_cliente");
setKey(["nom_sims"]);
addIndex([ "nom_sims", "nom_abreviado", "nom_cliente"]);
}
function onSync(lastSyncDate) {
var dataset = DatasetBuilder.newDataset();
try{
var clientService = fluigAPI.getAuthorizeClientService();
var data = {
companyId : getValue("WKCompany") + '',
serviceCode : 'getCliente',
endpoint : 'usr=super&pwd=trs@super',
method : 'get',
timeoutService: '100'
}
var vo = clientService.invoke(JSON.stringify(data));
log.info(vo.getResult())
if(vo.getResult()== null || vo.getResult().isEmpty()){
throw new Exception("Retorno está vazio");
}else{
var y = vo.getResult().split("\n");
for(var i=1;i<y.length;i++){
var x = y[i].substr(4).split(" ");
x = x.filter(function(entry) { return entry.trim() != ''; });
dataset.addOrUpdateRow([ x[1], x[0], x[2]]);
}
}
} catch(err) {
log.info(err);
}
return dataset;
}