refs #5995 Added getExternalCmrs #1703
|
@ -73,23 +73,7 @@ module.exports = Self => {
|
|||
};
|
||||
const conn = Self.dataSource.connector;
|
||||
|
||||
let where = buildFilter(params, (param, value) => {
|
||||
switch (param) {
|
||||
case 'cmrFk':
|
||||
return {'cmrFk': value};
|
||||
case 'ticketFk':
|
||||
return {'ticketFk': value};
|
||||
case 'country':
|
||||
return {'country': value};
|
||||
case 'clientFk':
|
||||
return {'clientFk': value};
|
||||
case 'hasCmrDms':
|
||||
return {'hasCmrDms': value};
|
||||
case 'shipped':
|
||||
return {'shipped': value};
|
||||
}
|
||||
});
|
||||
|
||||
let where = buildFilter(params, (param, value) => {return {[param]: value}});
|
||||
filter = mergeFilters(filter, {where});
|
||||
|
||||
if (!filter.where) {
|
||||
|
@ -140,10 +124,10 @@ module.exports = Self => {
|
|||
`);
|
||||
|
||||
stmt.merge(conn.makeSuffix(filter));
|
||||
let itemsIndex = stmts.push(stmt) - 1;
|
||||
const itemsIndex = stmts.push(stmt) - 1;
|
||||
|
||||
let sql = ParameterizedSQL.join(stmts, ';');
|
||||
let result = await conn.executeStmt(sql);
|
||||
const sql = ParameterizedSQL.join(stmts, ';');
|
||||
const result = await conn.executeStmt(sql);
|
||||
return itemsIndex === 0 ? result : result[itemsIndex];
|
||||
};
|
||||
};
|
||||
|
|
Loading…
Reference in New Issue