diff --git a/src/libs/jobs/download.js b/src/libs/jobs/download.js index eb8d30dddbba638676bff122376c0611a68c9d27..0cb1dad1040be9a611d9ff2eaf73b6dbf50b96d0 100644 --- a/src/libs/jobs/download.js +++ b/src/libs/jobs/download.js @@ -14,15 +14,16 @@ module.exports = function(agenda) { // Roda o COPY INTO // Cria o registro no mongo // Manda email notificando o usuário - let path = '/tmp/' + table + Date.now() + '.csv'; - log.debug(sql); + let path = '/tmp/' + table + '-' + Date.now() + '.csv'; let query = `COPY ${sql} INTO '${path}' USING DELIMITERS ';'`; execQuery(query, []).then((result) => { // If we're here then everything is ok. Result is empty let file = { name: table, - path + path, + table: table, + query: sql } request.post(config.cdn.url + '/api/v1/file', {form: file}, (err, response, body) => { if(err) { diff --git a/src/libs/routes/region.js b/src/libs/routes/region.js index 6a3dc40b7ecad7a78b8eb8357f7aa7d79bf11f21..b12083587b67e0f035a9d6e95f8fb5b1aa87ba75 100644 --- a/src/libs/routes/region.js +++ b/src/libs/routes/region.js @@ -54,13 +54,13 @@ regionApp.get('/', rqf.parse(), (req, res, next) => { next(); }, rqf.build(), query, response('region')); -const agenda = require(`${libs}/agenda`); +// const agenda = require(`${libs}/agenda`); -regionApp.get('/download', (req, res) => { - req.sql.from('regiao').field('*'); - let params = req.sql; - agenda.now('download database', {sql: req.sql.toString(), table: req.sql.tableFrom}); - res.json({msg: 'Wait for it...'}); -}); +// regionApp.get('/download', (req, res) => { +// req.sql.from('regiao').field('*'); +// let params = req.sql; +// agenda.now('download database', {sql: req.sql.toString(), table: req.sql.tableFrom}); +// res.json({msg: 'Wait for it...'}); +// }); module.exports = regionApp; diff --git a/src/libs/routes/school.js b/src/libs/routes/school.js index 40526cffc5947dda85b65c1c0fa567376c42c706..575b41c6110a5d050fc000cc328a8e27c7cf18b2 100644 --- a/src/libs/routes/school.js +++ b/src/libs/routes/school.js @@ -14,6 +14,8 @@ const id2str = require(`${libs}/middlewares/id2str`); const ReqQueryFields = require(`${libs}/middlewares/reqQueryFields`); +const agenda = require(`${libs}/agenda`); + let rqf = new ReqQueryFields(); let rqfCount = new ReqQueryFields(); @@ -872,4 +874,11 @@ schoolApp.get('/count', rqfCount.parse(), rqfCount.build(), (req, res, next) => next(); }, query, id2str.transform(), response('school')); +schoolApp.get('/download', rqf.parse(), rqf.build(), (req, res, next) => { + req.sql.from('escola') + .field('*'); + agenda.now('download database', {sql: req.sql.toString(), table: req.sql.tableFrom}); + res.json({msg: 'Wait for download email'}); +}); + module.exports = schoolApp;