require('dotenv').config(); const express = require('express'); var bodyParser = require('body-parser'); const server = express(); const pg = require('pg'); //---------read sql files into variables---------------- var fs = require('fs'); var readline = require('readline'); //------------------------------------------------------- var Postgres = new pg.Client({ user: process.env.user, password: process.env.password, host: process.env.host, port: process.env.port, database: process.env.database, ssl: false, application_name: "osm_api" }); Postgres.connect(); Postgres.FirstRow = function (inSQL, args, inResponse) { Postgres.query(inSQL, args, (err, res) => { if (err === null) { inResponse.json(res.rows[0]); return; } inResponse.json(err.stack); }); }; server.get('/scenario_totals', bodyParser.json(), function (req, res) { var w = ""; var c = 1; var args = []; for (var i in req.body) { //console.log(i); ///console.log(req.body[i]); if (c > 1) { w = w + ` AND ` } w = w + i + " = '" + req.body[i] + "'"; args.push(req.body[i]); c = c + 1; }; if (c == 1) { res.send("no body was sent"); return; } //console.log(w); //console.log(args); w = ` WITH ini AS ( SELECT order_season ,version ,iter ,SUM(units) units ,SUM(value_usd) value_usd FROM rlarp.osm_fcpool WHERE ` + w + ` GROUP BY order_season ,version ,iter ) SELECT jsonb_agg(row_to_json(ini)::jsonb) x FROM ini` console.log(w); Postgres.FirstRow(w, [], res) //res.json("hi") }) server.get('/scenario_package', bodyParser.json(), function (req, res) { var w = ""; var c = 1; var args = []; for (var i in req.body) { //console.log(i); ///console.log(req.body[i]); if (c > 1) { w = w + ` AND ` } w = w + i + " = '" + req.body[i] + "'"; args.push(req.body[i]); c = c + 1; }; if (c == 1) { res.send("no body was sent"); return; } //console.log(w); //console.log(args); w = ` WITH mseq AS ( SELECT * FROM ( VALUES ('Jun',1) ,('Jul',2) ,('Aug',3) ,('Sep',4) ,('Oct',5) ,('Nov',6) ,('Dec',7) ,('Jan',8) ,('Feb',9) ,('Mar',10) ,('Apr',11) ,('May',12) ) x(m,s) ) --select * from mseq ,base AS ( SELECT order_season ,order_month ,version ,iter ,part_descr ,bill_cust_descr ,ship_cust_descr ,SUM(units) units ,SUM(value_usd) value_usd FROM rlarp.osm_fcpool WHERE `+ w + `GROUP BY order_season ,order_month ,version ,iter ,part_descr ,bill_cust_descr ,ship_cust_descr ) ,months AS ( SELECT order_season ,version ,iter ,order_month ,mseq.s seq ,sum(units) units ,sum(value_usd) value_usd FROM base INNER JOIN mseq ON mseq.m = base.order_month GROUP BY order_season ,version ,iter ,order_month ,s ) ,mpvt AS ( SELECT order_month ,seq ,SUM(units) FILTER (WHERE order_season = 2019) "2019 qty" ,SUM(units) FILTER (WHERE order_season = 2020 AND iter = 'copy') "2020 base qty" ,SUM(units) FILTER (WHERE order_season = 2020 AND iter = 'adjustment') "2020 adj qty" ,SUM(units) FILTER (WHERE order_season = 2020 AND iter IN ('copy','adjustment')) "2020 tot qty" ,SUM(value_usd) FILTER (WHERE order_season = 2019) "2019 value_usd" ,SUM(value_usd) FILTER (WHERE order_season = 2020 AND iter = 'copy') "2020 base value_usd" ,SUM(value_usd) FILTER (WHERE order_season = 2020 AND iter = 'adjustment') "2020 adj value_usd" ,SUM(value_usd) FILTER (WHERE order_season = 2020 AND iter IN ('copy','adjustment')) "2020 tot value_usd" FROM months GROUP BY order_month ,seq ORDER BY seq ASC ) ,totals AS ( SELECT order_season ,version ,iter ,sum(units) units ,sum(value_usd) value_usd FROM months GROUP BY order_season ,version ,iter ) SELECT jsonb_build_object( 'months' ,(SELECT jsonb_agg(row_to_json(months)::jsonb) FROM months) ,'mpvt' ,(SELECT jsonb_agg(row_to_json(mpvt)::jsonb) FROM mpvt) ,'base' ,(SELECT jsonb_agg(row_to_json(base)::jsonb) FROM base) ,'totals' ,(SELECT jsonb_agg(row_to_json(totals)::jsonb) FROM totals) ) package` console.log(w); Postgres.FirstRow(w, [], res) //res.json("hi") }) server.get('/get_pool', bodyParser.json(), function (req, res) { var args = [req.body.quota_rep]; //------------------------------------------set base SQL------------------------------------ var w = ` WITH rows AS ( SELECT ---------customer info----------------- bill_cust_descr ,billto_group ,ship_cust_descr ,shipto_group ,quota_rep_descr ,director_descr ,segm ,mod_chan ,mod_chansub ---------product info------------------ ,majg_descr ,ming_descr ,majs_descr ,mins_descr ,brand ,part_family ,part_group ,branding ,color ,part_descr ---------dates------------------------- ,order_season ,order_month ,ship_season ,ship_month ,request_season ,request_month ,promo ,version ,iter --------values------------------------- ,sum(value_loc) value_loc ,sum(value_usd) value_usd ,sum(cost_loc) cost_loc ,sum(cost_usd) cost_usd ,sum(units) units FROM rlarp.osm_fcpool WHERE quota_rep_descr = $1 GROUP BY ---------customer info----------------- bill_cust_descr ,billto_group ,ship_cust_descr ,shipto_group ,quota_rep_descr ,director_descr ,segm ,mod_chan ,mod_chansub ---------product info------------------ ,majg_descr ,ming_descr ,majs_descr ,mins_descr ,brand ,part_family ,part_group ,branding ,color ,part_descr ---------dates------------------------- ,order_season ,order_month ,ship_season ,ship_month ,request_season ,request_month ,promo ,version ,iter ) SELECT json_agg(row_to_json(rows)) x FROM rows`; //-----------------replace default quota_rep---------------------------------------------------- console.log(w); Postgres.FirstRow(w, args, res) //res.json("hi") }) server.get('/', (req, res) => res.send('node.js express is running: 🎉')) server.get('/test_sql', function(req, res){ var path = './route_meta/scenario_totals.sql' var callback = function(arg){ res.send(arg) }; fs.readFile(path, 'utf8', function(err, data){ if (!err){ callback(data); } else { callback(err); } }); }); server.listen(3000, () => console.log('started'))