Compare commits
4 Commits
ca996adac6
...
834d52a2a2
Author | SHA1 | Date | |
---|---|---|---|
|
834d52a2a2 | ||
|
3592120b54 | ||
|
17dc465cdc | ||
|
e3205a94c1 |
55
index.js
55
index.js
@ -217,6 +217,50 @@ server.post('/swap', bodyParser.json(), function(req, res) {
|
||||
};
|
||||
})
|
||||
|
||||
server.post('/cust_swap', bodyParser.json(), function(req, res) {
|
||||
|
||||
var sql = "";
|
||||
var w = "";
|
||||
var c = 1;
|
||||
var d = 1;
|
||||
var args = [];
|
||||
var path = './route_sql/swap_cust.sql';
|
||||
|
||||
fs.readFile(path, 'utf8', function(err, data) {
|
||||
if (!err) {
|
||||
callback(data);
|
||||
} else {
|
||||
console.log("fatal error pulling sql file")
|
||||
callback(err);
|
||||
}
|
||||
});
|
||||
|
||||
var callback = function(arg) {
|
||||
sql = arg;
|
||||
|
||||
//parse request body into a where clause
|
||||
({ c, w, d } = build_where(req, c, w, d, args));
|
||||
|
||||
//if there was no body sent, return with nothing
|
||||
if (c == 1) {
|
||||
res.send("no body was sent");
|
||||
return;
|
||||
}
|
||||
console.log(new Date().toISOString() + "-------------------------get swap fit:------------------------------")
|
||||
console.log(req.body);
|
||||
//parse the where clause into the main sql statement
|
||||
sql = sql.replace(new RegExp("where_clause", 'g'), w);
|
||||
sql = sql.replace(new RegExp("swap_doc", 'g'), JSON.stringify(req.body.swap));
|
||||
sql = sql.replace(new RegExp("replace_version", 'g'), req.body.scenario.version);
|
||||
sql = sql.replace(new RegExp("replace_source", 'g'), req.body.source);
|
||||
sql = sql.replace(new RegExp("replace_iterdef", 'g'), JSON.stringify(req.body));
|
||||
//execute the sql and send the result
|
||||
console.log(sql);
|
||||
res.json(null);
|
||||
//Postgres.FirstRow(sql, [], res)
|
||||
};
|
||||
})
|
||||
|
||||
server.get('/list_changes', bodyParser.json(), function(req, res) {
|
||||
|
||||
var sql = "";
|
||||
@ -238,10 +282,19 @@ server.get('/list_changes', bodyParser.json(), function(req, res) {
|
||||
var callback = function(arg) {
|
||||
sql = arg;
|
||||
|
||||
//parse request body into a where clause
|
||||
({ c, w, d } = build_where(req, c, w, d, args));
|
||||
|
||||
|
||||
//if there was no body sent, return with nothing
|
||||
if (c == 1) {
|
||||
res.send("no body was sent");
|
||||
return;
|
||||
}
|
||||
console.log(new Date().toISOString() + "-------------------------list changes:------------------------------")
|
||||
console.log(req.body);
|
||||
//parse the where clause into the main sql statement
|
||||
sql = sql.replace(new RegExp("replace_user", 'g'), req.body.quota_rep_descr)
|
||||
sql = sql.replace(new RegExp("where_clause", 'g'), w)
|
||||
//execute the sql and send the result
|
||||
console.log(sql);
|
||||
Postgres.FirstRow(sql, [], res)
|
||||
|
@ -14,7 +14,7 @@ from
|
||||
inner join rlarp.osm_pool on
|
||||
id = logid
|
||||
WHERE
|
||||
quota_rep_descr = 'replace_user'
|
||||
where_clause
|
||||
AND tag <> 'Initial Build'
|
||||
group BY
|
||||
ol.doc->>'user'
|
||||
|
@ -17,17 +17,17 @@ target AS (SELECT $$swap_doc$$::jsonb swap)
|
||||
SELECT
|
||||
billto
|
||||
,bill_r
|
||||
,bill_dba
|
||||
,bc.bvadr6 bill_dba
|
||||
,shipto
|
||||
,ship_r
|
||||
,ship_dba
|
||||
,sc.bvadr6 ship_dba
|
||||
--other stuff doesn't matter becuase it's getting overridden anyways
|
||||
FROM
|
||||
swap
|
||||
LEFT out JOIN lgdat.cust bc ON
|
||||
bc.bvcust = swap.bill_r
|
||||
LEFT out JOIN lgdat.cust sc ON
|
||||
bc.bvcust = swap.ship_r
|
||||
sc.bvcust = swap.ship_r
|
||||
)
|
||||
--put bill to and ship to back together and join in channel, terms, descriptions, etc
|
||||
,seg AS (
|
||||
@ -112,8 +112,9 @@ target AS (SELECT $$swap_doc$$::jsonb swap)
|
||||
FROM
|
||||
rlarp.osm_pool o
|
||||
CROSS JOIN log
|
||||
INNER JOIN pl ON
|
||||
pl.original = o.part
|
||||
INNER JOIN swap ON
|
||||
swap.bill_to = SUBSTRING(o.bill_cust_descr,1,8)
|
||||
swap.bill_to = SUBSTRING(o.ship_cust_descr,1,8)
|
||||
WHERE
|
||||
-----------------scenario----------------------------
|
||||
where_clause
|
||||
|
Loading…
Reference in New Issue
Block a user