pis #12
@ -5,25 +5,25 @@ const log = require('../utils/log.utils')
|
|||||||
const clean = require('../utils/sanitizer.utils')
|
const clean = require('../utils/sanitizer.utils')
|
||||||
|
|
||||||
async function findPisByOrigDest(start,end) {
|
async function findPisByOrigDest(start,end) {
|
||||||
log.out(`pisServices.findPisByOrigDest: Searching for PIS for Orig: ${start}, Dest: ${end}`, "dbug")
|
log.out(`pisServices.findPisByOrigDest: Searching for PIS for Orig: ${start}, Dest: ${end}`, 'dbug')
|
||||||
const firstCrs = clean.cleanApiEndpointTxt(start.toLowerCase())
|
const firstCrs = clean.cleanApiEndpointTxt(start.toLowerCase())
|
||||||
const lastCrs = clean.cleanApiEndpointTxt(end.toLowerCase())
|
const lastCrs = clean.cleanApiEndpointTxt(end.toLowerCase())
|
||||||
const query = {
|
const query = {
|
||||||
stops: {
|
stops: {
|
||||||
$all: [
|
$all: [
|
||||||
{ $elemMatch: { $eq: firstCrs } },
|
{ $elemMatch: { $eq: firstCrs } },
|
||||||
{ $elemMatch: { $eq: lastCrs } }
|
{ $elemMatch: { $eq: lastCrs } }
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
$expr: {
|
$expr: {
|
||||||
$and: [
|
$and: [
|
||||||
{ $eq: [{ $arrayElemAt: [ "$stops", -1 ] }, lastCrs] },
|
{ $eq: [{ $arrayElemAt: [ '$stops', -1 ] }, lastCrs] },
|
||||||
{ $eq: [{ $arrayElemAt: [ "$stops", 0 ] }, firstCrs] }
|
{ $eq: [{ $arrayElemAt: [ '$stops', 0 ] }, firstCrs] }
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
//const oldQuery = {$and:[{$expr:{$eq:[{$first:"$stops"},firstCrs]}},{$expr:{$eq:[{$last:"$stops"},lastCrs]}}]}
|
//const oldQuery = {$and:[{$expr:{$eq:[{$first:"$stops"},firstCrs]}},{$expr:{$eq:[{$last:"$stops"},lastCrs]}}]}
|
||||||
const search = db.query("pis", query)
|
const search = db.query('pis', query)
|
||||||
return search
|
return search
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user