andrey.cunha/fluig
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

att

Browse Source
This commit is contained in:
Andrey Cunha
2026-05-11 21:54:49 -03:00
parent ba5d7dae57
commit a71f963e37
17 changed files with 3091 additions and 4186 deletions
Download Patch File Download Diff File Expand all files Collapse all files
compras_digital/datasets/dsSolicCompraProtheus.js
+16 -45
View File
@@ -4,13 +4,13 @@ function createDataset(fields, constraints, sortFields) {
dataset.addColumn("mensagem");
dataset.addColumn("erro");
log.info("### Enviando dados para Protheus com autenticação ###");
log.info("### Enviando dados para Protheus via fluigAPI ###");
try {
var jsonData = "{}";
if (constraints) {
for (var i = 0; i < constraints.length; i++) {
if (constraints[i].fieldName == "params" && constraints[i].initialValue) {
if (constraints[i].fieldName === "params" && constraints[i].initialValue) {
jsonData = constraints[i].initialValue;
break;
}
@@ -18,54 +18,25 @@ function createDataset(fields, constraints, sortFields) {
}
log.info("Dados recebidos: " + jsonData);
var url = "https://rest.grupoginseng.com.br/rest/uf_mata010";
var urlObj = new java.net.URL(url);
var httpConn = urlObj.openConnection();
var clientService = fluigAPI.getAuthorizeClientService();
var data = {
companyId: String(getValue("WKCompany") || "1"),
serviceCode: "Postprod",
endpoint: "/rest/uf_mata010",
method: "post",
timeoutService: "60000",
params: JSON.parse(jsonData),
headers: { "Content-Type": "application/json" }
};
var usuario = "fluig";
var senha = "Ginseng@";
var authString = usuario + ":" + senha;
var authBytes = new java.lang.String(authString).getBytes("UTF-8");
var encodedAuth = java.util.Base64.getEncoder().encodeToString(authBytes);
var vo = clientService.invoke(JSON.stringify(data));
var response = vo ? String(vo.getResult() || "") : "";
httpConn.setDoOutput(true);
httpConn.setRequestMethod("POST");
httpConn.setRequestProperty("Content-Type", "application/json");
httpConn.setRequestProperty("Accept", "application/json");
httpConn.setRequestProperty("Authorization", "Basic " + encodedAuth);
httpConn.setConnectTimeout(30000);
httpConn.setReadTimeout(30000);
var outputStream = httpConn.getOutputStream();
var writer = new java.io.OutputStreamWriter(outputStream, "UTF-8");
writer.write(jsonData);
writer.flush();
writer.close();
outputStream.close();
// Ler resposta ou erro
var response = "";
try {
var inputStream = httpConn.getInputStream();
var scanner = new java.util.Scanner(inputStream, "UTF-8");
response = scanner.useDelimiter("\\A").hasNext() ? scanner.next() : "";
scanner.close();
} catch (e) {
var errorStream = httpConn.getErrorStream();
if (errorStream != null) {
var scanner = new java.util.Scanner(errorStream, "UTF-8");
response = scanner.useDelimiter("\\A").hasNext() ? scanner.next() : "";
scanner.close();
}
}
log.info("Response bruto: " + response);
// Adiciona no dataset sempre, sem depender do status HTTP
log.info("Response: " + response);
dataset.addRow(["OK", response, ""]);
} catch (error) {
log.error("Erro completo: " + error.toString());
log.error("Erro: " + error.toString());
dataset.addRow(["Erro", "", error.toString()]);
}