SMC-CET/smc_cet_financials_backend
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

camunda_return_issue:GWM

Browse Source
This commit is contained in:
sriramv 2021-10-08 12:29:43 +05:30
parent a1b71ab08f
commit d59c8e7a9f
3 changed files with 63 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
app/controllers/financial.controller.js
View File

@ -710,26 +710,53 @@ exports.camunda = async (req, res) => {
const cin = "test"; const cin = "test";
const user = "test"; const user = "test";
//let promise = Promise.resolve(); var camunda_status;
promiseA = new Promise((resolve, reject) => {
instancesid = "33f6a13d-272f-11ec-a4f4-42010a800002"; instancesid = "33f6a13d-272f-11ec-a4f4-42010a800002";
taskid = camundaHelper.financialsListOfProcessInstances(instancesid); const taskid = camundaHelper.financialsListOfProcessInstances(instancesid);
return taskid; taskid.then(function(result){
const formVariable = camundaHelper.financialsFormVariables(result);
formVariable.then(function(form_result){ camunda_status = form_result });
}); });
setTimeout(function(){ setTimeout(function(){
promiseB = promiseA.then(function(taskid){ console.log(camunda_status);
console.log(taskid); res.send(camunda_status);
camunda_status = camundaHelper.financialsFormVariables(taskid);
return camunda_status;
})
},2000);
setTimeout(function(){ },5000);
promiseB.then(function(camunda_status){ //console.log(camunda_status);
Promise.resolve(res.send({'status':200,'camunda': camunda_status })) // function one(){
}) // console.log("one")
},2000); // instancesid = "33f6a13d-272f-11ec-a4f4-42010a800002";
// taskid = camundaHelper.financialsListOfProcessInstances(instancesid);
// return taskid;
// console.log(taskid);
// }
// one().then(function(taskid){ console.log(taskid); });
//let promise = Promise.resolve();
// promiseA = new Promise((resolve, reject) => {
// instancesid = "33f6a13d-272f-11ec-a4f4-42010a800002";
// taskid = camundaHelper.financialsListOfProcessInstances(instancesid);
// taskid.then(function(taskid){
// console.log(taskid);
// })
// });
// setTimeout(function(){
// promiseB = promiseA.then(function(taskid){
// console.log(taskid);
// camunda_status = camundaHelper.financialsFormVariables(taskid);
// return camunda_status;
// })
// },2000);
// setTimeout(function(){
// promiseB.then(function(camunda_status){
// Promise.resolve(res.send({'status':200,'camunda': camunda_status }))
// })
// },2000);
} catch(err) { } catch(err) {

2
app/routes/routes.js
View File

@ -8,7 +8,7 @@ module.exports = app => {
var router = require("express").Router(); var router = require("express").Router();
//router.get("/camunda", financials.camunda); router.get("/camunda", financials.camunda);
/** /**
* @swagger * @swagger
* /api/ConsolidatedSummary: * /api/ConsolidatedSummary:

17
app/services/camunda.helper.js
View File

@ -15,6 +15,7 @@ const URL = process.env.CAMUNDA_URL
"user":{"value": user } "user":{"value": user }
},"businessKey": businessKey },"businessKey": businessKey
}; };
return new Promise((resolve, reject) => {
request({ request({
url: start_url, url: start_url,
method: "POST", method: "POST",
@ -23,9 +24,10 @@ const URL = process.env.CAMUNDA_URL
}, function (error, response, body){ }, function (error, response, body){
let data = body; let data = body;
instancesid = data.id; instancesid = data.id;
return instancesid; resolve(instancesid);
}); });
});
} }
catch (error) catch (error)
{ {
@ -33,12 +35,13 @@ const URL = process.env.CAMUNDA_URL
} }
} }
function financialsListOfProcessInstances(instancesid) function financialsListOfProcessInstances(instancesid,req,res)
{ {
try try
{ {
const task_id_url = URL+"task"; const task_id_url = URL+"task";
const myJSONObject = { "processInstanceIdIn":[instancesid] }; const myJSONObject = { "processInstanceIdIn":[instancesid] };
return new Promise((resolve, reject) => {
request({ request({
url: task_id_url, url: task_id_url,
method: "POST", method: "POST",
@ -46,10 +49,11 @@ const URL = process.env.CAMUNDA_URL
body: myJSONObject body: myJSONObject
}, function (error, response, body){ }, function (error, response, body){
let data = body; let data = body;
task_id =data[0].id; task_id = data[0].id;
return task_id; resolve(task_id);
}); });
});
} }
catch (error) catch (error)
{ {
@ -86,12 +90,15 @@ const URL = process.env.CAMUNDA_URL
try try
{ {
const form_variable_url = URL+"task/"+taskid+"/form-variables"; const form_variable_url = URL+"task/"+taskid+"/form-variables";
return new Promise((resolve, reject) => {
request({ request({
url: form_variable_url, url: form_variable_url,
method: "GET" method: "GET"
}, function (error, response, body){ }, function (error, response, body){
return body; resolve(body);
})
}); });
} }