farmcontrol/farmcontrol-api
2
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: farmcontrol:4458a1d82866eaf6a3f9147bdef233fe2465c85c
Branches Tags
farmcontrol:main
farmcontrol:config-updates
..
compare: farmcontrol:4ea168f17f53c9946a16dfda737dba4bb3fae79c
Branches Tags
farmcontrol:main
farmcontrol:config-updates

No commits in common. "4458a1d82866eaf6a3f9147bdef233fe2465c85c" and "4ea168f17f53c9946a16dfda737dba4bb3fae79c" have entirely different histories.
4458a1d828 ... 4ea168f17f

41 changed files with 497 additions and 1359 deletions
Show Stats Expand all files Collapse all files

2
.gitignore vendored
View File

@ -140,5 +140,3 @@ gocdefile/*
gcodefile
gcodefiles/*
gcodefiles
test-results.xml

2
src/database/schemas/inventory/filamentstock.schema.js
View File

@ -19,7 +19,7 @@ const filamentStockSchema = new Schema(
net: { type: Number, required: true },
gross: { type: Number, required: true },
},
filamentSku: { type: mongoose.Schema.Types.ObjectId, ref: 'filamentSku', required: true },
filament: { type: mongoose.Schema.Types.ObjectId, ref: 'filament', required: true },
},
{ timestamps: true }
);

104
src/database/schemas/inventory/orderitem.schema.js
View File

@ -2,12 +2,6 @@ import mongoose from 'mongoose';
import { purchaseOrderModel } from './purchaseorder.schema.js';
import { salesOrderModel } from '../sales/salesorder.schema.js';
import { taxRateModel } from '../management/taxrate.schema.js';
import { filamentModel } from '../management/filament.schema.js';
import { filamentSkuModel } from '../management/filamentsku.schema.js';
import { partModel } from '../management/part.schema.js';
import { partSkuModel } from '../management/partsku.schema.js';
import { productModel } from '../management/product.schema.js';
import { productSkuModel } from '../management/productsku.schema.js';
import {
aggregateRollups,
aggregateRollupsHistory,
@ -17,18 +11,6 @@ import {
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
const skuModelsByItemType = {
filament: filamentSkuModel,
part: partSkuModel,
product: productSkuModel,
};
const parentModelsByItemType = {
filament: filamentModel,
part: partModel,
product: productModel,
};
const orderItemSchema = new Schema(
{
_reference: { type: String, default: () => generateId()() },
@ -39,16 +21,7 @@ const orderItemSchema = new Schema(
},
order: { type: Schema.Types.ObjectId, refPath: 'orderType', required: true },
itemType: { type: String, required: true },
item: { type: Schema.Types.ObjectId, refPath: 'itemType', required: false },
sku: {
type: Schema.Types.ObjectId,
ref: function () {
return ['filament', 'part', 'product'].includes(this.itemType)
? this.itemType + 'Sku'
: null;
},
required: false,
},
item: { type: Schema.Types.ObjectId, refPath: 'itemType', required: true },
syncAmount: { type: String, required: false, default: null },
itemAmount: { type: Number, required: true },
quantity: { type: Number, required: true },
@ -115,55 +88,9 @@ orderItemSchema.statics.recalculate = async function (orderItem, user) {
return;
}
// If SKU present and syncAmount is set, check if override is on for the price mode and use that price instead
let effectiveItemAmount = orderItem.itemAmount;
const syncAmount = orderItem.syncAmount;
const skuId = orderItem.sku?._id || orderItem.sku;
const itemType = orderItem.itemType;
if (syncAmount && skuId && itemType && ['filament', 'part', 'product'].includes(itemType)) {
const skuModel = skuModelsByItemType[itemType];
const parentModel = parentModelsByItemType[itemType];
if (skuModel && parentModel) {
const sku = await getObject({
model: skuModel,
id: skuId,
cached: true,
});
if (sku) {
const parentId = sku.part?._id || sku.part || sku.product?._id || sku.product || sku.filament?._id || sku.filament;
if (syncAmount === 'itemCost') {
if (sku.overrideCost && sku.cost != null) {
effectiveItemAmount = sku.cost;
} else if (parentId) {
const parent = await getObject({
model: parentModel,
id: parentId,
cached: true,
});
if (parent && parent.cost != null) {
effectiveItemAmount = parent.cost;
}
}
} else if (syncAmount === 'itemPrice' && itemType !== 'filament') {
if (sku.overridePrice && sku.price != null) {
effectiveItemAmount = sku.price;
} else if (parentId) {
const parent = await getObject({
model: parentModel,
id: parentId,
cached: true,
});
if (parent && parent.price != null) {
effectiveItemAmount = parent.price;
}
}
}
}
}
}
var taxRate = orderItem.taxRate;
let taxRate = orderItem.taxRate;
if (orderItem.taxRate?._id && Object.keys(orderItem.taxRate).length === 1) {
if (orderItem.taxRate?._id && Object.keys(orderItem.taxRate).length == 1) {
taxRate = await getObject({
model: taxRateModel,
id: orderItem.taxRate._id,
@ -171,25 +98,18 @@ orderItemSchema.statics.recalculate = async function (orderItem, user) {
});
}
const orderTotalAmount = effectiveItemAmount * orderItem.quantity;
const orderTotalAmount = orderItem.itemAmount * orderItem.quantity;
const orderTotalAmountWithTax = orderTotalAmount * (1 + (taxRate?.rate || 0) / 100);
const orderItemUpdateData = {
totalAmount: orderTotalAmount,
totalAmountWithTax: orderTotalAmountWithTax,
invoicedAmountRemaining: orderTotalAmount - orderItem.invoicedAmount,
invoicedAmountWithTaxRemaining: orderTotalAmountWithTax - orderItem.invoicedAmountWithTax,
invoicedQuantityRemaining: orderItem.quantity - orderItem.invoicedQuantity,
};
if (effectiveItemAmount !== orderItem.itemAmount) {
orderItemUpdateData.itemAmount = effectiveItemAmount;
orderItem.itemAmount = effectiveItemAmount;
}
await editObject({
model: this,
model: orderItemModel,
id: orderItem._id,
updateData: orderItemUpdateData,
updateData: {
invoicedAmountRemaining: orderTotalAmount - orderItem.invoicedAmount,
invoicedAmountWithTaxRemaining: orderTotalAmountWithTax - orderItem.invoicedAmountWithTax,
invoicedQuantityRemaining: orderItem.quantity - orderItem.invoicedQuantity,
totalAmount: orderTotalAmount,
totalAmountWithTax: orderTotalAmountWithTax,
},
user,
recalculate: false,
});

2
src/database/schemas/inventory/partstock.schema.js
View File

@ -11,7 +11,7 @@ const partStockSchema = new Schema(
type: { type: String, required: true },
progress: { type: Number, required: false },
},
partSku: { type: mongoose.Schema.Types.ObjectId, ref: 'partSku', required: true },
part: { type: mongoose.Schema.Types.ObjectId, ref: 'part', required: true },
currentQuantity: { type: Number, required: true },
sourceType: { type: String, required: true },
source: { type: Schema.Types.ObjectId, refPath: 'sourceType', required: true },

4
src/database/schemas/inventory/productstock.schema.js
View File

@ -5,7 +5,7 @@ import { aggregateRollups, aggregateRollupsHistory } from '../../database.js';
const partStockUsageSchema = new Schema({
partStock: { type: Schema.Types.ObjectId, ref: 'partStock', required: false },
partSku: { type: Schema.Types.ObjectId, ref: 'partSku', required: true },
part: { type: Schema.Types.ObjectId, ref: 'part', required: true },
quantity: { type: Number, required: true },
});
@ -18,7 +18,7 @@ const productStockSchema = new Schema(
progress: { type: Number, required: false },
},
postedAt: { type: Date, required: false },
productSku: { type: mongoose.Schema.Types.ObjectId, ref: 'productSku', required: true },
product: { type: mongoose.Schema.Types.ObjectId, ref: 'product', required: true },
currentQuantity: { type: Number, required: true },
partStocks: [partStockUsageSchema],
},

32
src/database/schemas/management/filament.schema.js
View File

@ -2,21 +2,24 @@ import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
// Filament base - cost and tax; color and cost override at FilamentSKU
const filamentSchema = new mongoose.Schema({
_reference: { type: String, default: () => generateId()() },
name: { required: true, type: String },
barcode: { required: false, type: String },
url: { required: false, type: String },
image: { required: false, type: Buffer },
material: { type: Schema.Types.ObjectId, ref: 'material', required: true },
color: { required: true, type: String },
vendor: { type: Schema.Types.ObjectId, ref: 'vendor', required: true },
type: { required: true, type: String },
cost: { required: true, type: Number },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: true },
costWithTax: { required: true, type: Number },
diameter: { required: true, type: Number },
density: { required: true, type: Number },
createdAt: { required: true, type: Date },
updatedAt: { required: true, type: Date },
emptySpoolWeight: { required: true, type: Number },
cost: { type: Number, required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
costWithTax: { type: Number, required: false },
}, { timestamps: true });
});
filamentSchema.virtual('id').get(function () {
return this._id;
@ -24,21 +27,4 @@ filamentSchema.virtual('id').get(function () {
filamentSchema.set('toJSON', { virtuals: true });
filamentSchema.statics.recalculate = async function (filament, user) {
const orderItemModel = mongoose.model('orderItem');
const itemId = filament._id;
const draftOrderItems = await orderItemModel
.find({
'state.type': 'draft',
itemType: 'filament',
item: itemId,
})
.populate('order')
.lean();
for (const orderItem of draftOrderItems) {
await orderItemModel.recalculate(orderItem, user);
}
};
export const filamentModel = mongoose.model('filament', filamentSchema);

48
src/database/schemas/management/filamentsku.schema.js
View File

@ -1,48 +0,0 @@
import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
// Define the main filament SKU schema - color and cost live at SKU level
const filamentSkuSchema = new Schema(
{
_reference: { type: String, default: () => generateId()() },
barcode: { type: String, required: false },
filament: { type: Schema.Types.ObjectId, ref: 'filament', required: true },
name: { type: String, required: true },
description: { type: String, required: false },
color: { type: String, required: true },
cost: { type: Number, required: false },
overrideCost: { type: Boolean, default: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
costWithTax: { type: Number, required: false },
},
{ timestamps: true }
);
// Add virtual id getter
filamentSkuSchema.virtual('id').get(function () {
return this._id;
});
// Configure JSON serialization to include virtuals
filamentSkuSchema.set('toJSON', { virtuals: true });
filamentSkuSchema.statics.recalculate = async function (filamentSku, user) {
const orderItemModel = mongoose.model('orderItem');
const skuId = filamentSku._id;
const draftOrderItems = await orderItemModel
.find({
'state.type': 'draft',
itemType: 'filament',
sku: skuId,
})
.populate('order')
.lean();
for (const orderItem of draftOrderItems) {
await orderItemModel.recalculate(orderItem, user);
}
};
// Create and export the model
export const filamentSkuModel = mongoose.model('filamentSku', filamentSkuSchema);

16
src/database/schemas/management/material.schema.js
View File

@ -1,15 +1,13 @@
import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const materialSchema = new mongoose.Schema(
{
_reference: { type: String, default: () => generateId()() },
name: { required: true, type: String },
url: { required: false, type: String },
tags: [{ type: String }],
},
{ timestamps: true }
);
const materialSchema = new mongoose.Schema({
_reference: { type: String, default: () => generateId()() },
name: { required: true, type: String },
url: { required: false, type: String },
image: { required: false, type: Buffer },
tags: [{ type: String }],
});
materialSchema.virtual('id').get(function () {
return this._id;

31
src/database/schemas/management/part.schema.js
View File

@ -2,22 +2,22 @@ import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
// Define the main part schema - cost/price and tax; override at PartSku
// Define the main part schema
const partSchema = new Schema(
{
_reference: { type: String, default: () => generateId()() },
name: { type: String, required: true },
fileName: { type: String, required: false },
file: { type: mongoose.SchemaTypes.ObjectId, ref: 'file', required: false },
cost: { type: Number, required: false },
price: { type: Number, required: false },
priceMode: { type: String, default: 'margin' },
price: { type: Number, required: true },
cost: { type: Number, required: true },
margin: { type: Number, required: false },
amount: { type: Number, required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
vendor: { type: Schema.Types.ObjectId, ref: 'vendor', required: true },
file: { type: mongoose.SchemaTypes.ObjectId, ref: 'file', required: false },
priceTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
costWithTax: { type: Number, required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
priceWithTax: { type: Number, required: false },
costWithTax: { type: Number, required: false },
},
{ timestamps: true }
);
@ -30,22 +30,5 @@ partSchema.virtual('id').get(function () {
// Configure JSON serialization to include virtuals
partSchema.set('toJSON', { virtuals: true });
partSchema.statics.recalculate = async function (part, user) {
const orderItemModel = mongoose.model('orderItem');
const itemId = part._id;
const draftOrderItems = await orderItemModel
.find({
'state.type': 'draft',
itemType: 'part',
item: itemId,
})
.populate('order')
.lean();
for (const orderItem of draftOrderItems) {
await orderItemModel.recalculate(orderItem, user);
}
};
// Create and export the model
export const partModel = mongoose.model('part', partSchema);

54
src/database/schemas/management/partsku.schema.js
View File

@ -1,54 +0,0 @@
import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
// Define the main part SKU schema - pricing lives at SKU level
const partSkuSchema = new Schema(
{
_reference: { type: String, default: () => generateId()() },
barcode: { type: String, required: false },
part: { type: Schema.Types.ObjectId, ref: 'part', required: true },
name: { type: String, required: true },
description: { type: String, required: false },
priceMode: { type: String, default: 'margin' },
price: { type: Number, required: false },
cost: { type: Number, required: false },
overrideCost: { type: Boolean, default: false },
overridePrice: { type: Boolean, default: false },
margin: { type: Number, required: false },
amount: { type: Number, required: false },
priceTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
priceWithTax: { type: Number, required: false },
costWithTax: { type: Number, required: false },
},
{ timestamps: true }
);
// Add virtual id getter
partSkuSchema.virtual('id').get(function () {
return this._id;
});
// Configure JSON serialization to include virtuals
partSkuSchema.set('toJSON', { virtuals: true });
partSkuSchema.statics.recalculate = async function (partSku, user) {
const orderItemModel = mongoose.model('orderItem');
const skuId = partSku._id;
const draftOrderItems = await orderItemModel
.find({
'state.type': 'draft',
itemType: 'part',
sku: skuId,
})
.populate('order')
.lean();
for (const orderItem of draftOrderItems) {
await orderItemModel.recalculate(orderItem, user);
}
};
// Create and export the model
export const partSkuModel = mongoose.model('partSku', partSkuSchema);

31
src/database/schemas/management/product.schema.js
View File

@ -2,6 +2,11 @@ import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
const partSchema = new Schema({
part: { type: Schema.Types.ObjectId, ref: 'part', required: true },
quantity: { type: Number, required: true },
});
// Define the main product schema
const productSchema = new Schema(
{
@ -9,16 +14,13 @@ const productSchema = new Schema(
name: { type: String, required: true },
tags: [{ type: String }],
version: { type: String },
vendor: { type: Schema.Types.ObjectId, ref: 'vendor', required: true },
cost: { type: Number, required: false },
price: { type: Number, required: false },
priceMode: { type: String, default: 'margin' },
margin: { type: Number, required: false },
amount: { type: Number, required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
vendor: { type: Schema.Types.ObjectId, ref: 'vendor', required: true },
parts: [partSchema],
priceTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
costWithTax: { type: Number, required: false },
priceWithTax: { type: Number, required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
},
{ timestamps: true }
);
@ -30,22 +32,5 @@ productSchema.virtual('id').get(function () {
// Configure JSON serialization to include virtuals
productSchema.set('toJSON', { virtuals: true });
productSchema.statics.recalculate = async function (product, user) {
const orderItemModel = mongoose.model('orderItem');
const itemId = product._id;
const draftOrderItems = await orderItemModel
.find({
'state.type': 'draft',
itemType: 'product',
item: itemId,
})
.populate('order')
.lean();
for (const orderItem of draftOrderItems) {
await orderItemModel.recalculate(orderItem, user);
}
};
// Create and export the model
export const productModel = mongoose.model('product', productSchema);

36
src/database/schemas/management/productsku.schema.js
View File

@ -2,31 +2,14 @@ import mongoose from 'mongoose';
import { generateId } from '../../utils.js';
const { Schema } = mongoose;
const partSkuUsageSchema = new Schema({
partSku: { type: Schema.Types.ObjectId, ref: 'partSku', required: true },
quantity: { type: Number, required: true },
});
// Define the main product SKU schema
const productSkuSchema = new Schema(
{
_reference: { type: String, default: () => generateId()() },
barcode: { type: String, required: false },
sku: { type: String, required: true },
product: { type: Schema.Types.ObjectId, ref: 'product', required: true },
name: { type: String, required: true },
description: { type: String, required: false },
priceMode: { type: String, default: 'margin' },
price: { type: Number, required: false },
cost: { type: Number, required: false },
overrideCost: { type: Boolean, default: false },
overridePrice: { type: Boolean, default: false },
margin: { type: Number, required: false },
amount: { type: Number, required: false },
parts: [partSkuUsageSchema],
priceTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
costTaxRate: { type: Schema.Types.ObjectId, ref: 'taxRate', required: false },
priceWithTax: { type: Number, required: false },
costWithTax: { type: Number, required: false },
},
{ timestamps: true }
);
@ -39,22 +22,5 @@ productSkuSchema.virtual('id').get(function () {
// Configure JSON serialization to include virtuals
productSkuSchema.set('toJSON', { virtuals: true });
productSkuSchema.statics.recalculate = async function (productSku, user) {
const orderItemModel = mongoose.model('orderItem');
const skuId = productSku._id;
const draftOrderItems = await orderItemModel
.find({
'state.type': 'draft',
itemType: 'product',
sku: skuId,
})
.populate('order')
.lean();
for (const orderItem of draftOrderItems) {
await orderItemModel.recalculate(orderItem, user);
}
};
// Create and export the model
export const productSkuModel = mongoose.model('productSku', productSkuSchema);

24
src/database/schemas/models.js
View File

@ -2,14 +2,11 @@ import { jobModel } from './production/job.schema.js';
import { subJobModel } from './production/subjob.schema.js';
import { printerModel } from './production/printer.schema.js';
import { filamentModel } from './management/filament.schema.js';
import { filamentSkuModel } from './management/filamentsku.schema.js';
import { gcodeFileModel } from './production/gcodefile.schema.js';
import { partModel } from './management/part.schema.js';
import { partSkuModel } from './management/partsku.schema.js';
import { productModel } from './management/product.schema.js';
import { productSkuModel } from './management/productsku.schema.js';
import { vendorModel } from './management/vendor.schema.js';
import { materialModel } from './management/material.schema.js';
import { filamentStockModel } from './inventory/filamentstock.schema.js';
import { purchaseOrderModel } from './inventory/purchaseorder.schema.js';
import { orderItemModel } from './inventory/orderitem.schema.js';
@ -55,13 +52,6 @@ export const models = {
referenceField: '_reference',
label: 'Filament',
},
FSU: {
model: filamentSkuModel,
idField: '_id',
type: 'filamentSku',
referenceField: '_reference',
label: 'Filament SKU',
},
GCF: {
model: gcodeFileModel,
idField: '_id',
@ -77,13 +67,6 @@ export const models = {
referenceField: '_reference',
label: 'Part',
},
PSU: {
model: partSkuModel,
idField: '_id',
type: 'partSku',
referenceField: '_reference',
label: 'Part SKU',
},
PRD: {
model: productModel,
idField: '_id',
@ -105,13 +88,6 @@ export const models = {
referenceField: '_reference',
label: 'Vendor',
},
MAT: {
model: materialModel,
idField: '_id',
type: 'material',
referenceField: '_reference',
label: 'Material',
},
SJB: {
model: subJobModel,
idField: '_id',

2
src/database/schemas/production/gcodefile.schema.js
View File

@ -13,7 +13,7 @@ const gcodeFileSchema = new mongoose.Schema(
name: { required: true, type: String },
gcodeFileName: { required: false, type: String },
size: { type: Number, required: false },
filamentSku: { type: Schema.Types.ObjectId, ref: 'filamentSku', required: true },
filament: { type: Schema.Types.ObjectId, ref: 'filament', required: true },
parts: [partSchema],
file: { type: mongoose.SchemaTypes.ObjectId, ref: 'file', required: false },
cost: { type: Number, required: false },

4
src/index.js
View File

@ -14,10 +14,8 @@ import {
subJobRoutes,
gcodeFileRoutes,
filamentRoutes,
filamentSkuRoutes,
spotlightRoutes,
partRoutes,
partSkuRoutes,
productRoutes,
productSkuRoutes,
vendorRoutes,
@ -134,9 +132,7 @@ app.use('/jobs', jobRoutes);
app.use('/subjobs', subJobRoutes);
app.use('/gcodefiles', gcodeFileRoutes);
app.use('/filaments', filamentRoutes);
app.use('/filamentskus', filamentSkuRoutes);
app.use('/parts', partRoutes);
app.use('/partskus', partSkuRoutes);
app.use('/products', productRoutes);
app.use('/productskus', productSkuRoutes);
app.use('/vendors', vendorRoutes);

4
src/routes/index.js
View File

@ -8,10 +8,8 @@ import jobRoutes from './production/jobs.js';
import subJobRoutes from './production/subjobs.js';
import gcodeFileRoutes from './production/gcodefiles.js';
import filamentRoutes from './management/filaments.js';
import filamentSkuRoutes from './management/filamentskus.js';
import spotlightRoutes from './misc/spotlight.js';
import partRoutes from './management/parts.js';
import partSkuRoutes from './management/partskus.js';
import productRoutes from './management/products.js';
import productSkuRoutes from './management/productskus.js';
import vendorRoutes from './management/vendors.js';
@ -56,10 +54,8 @@ export {
subJobRoutes,
gcodeFileRoutes,
filamentRoutes,
filamentSkuRoutes,
spotlightRoutes,
partRoutes,
partSkuRoutes,
productRoutes,
productSkuRoutes,
vendorRoutes,

4
src/routes/inventory/filamentstocks.js
View File

@ -18,14 +18,14 @@ import {
// list of filament stocks
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const allowedFilters = ['filamentSku', 'state', 'startingWeight', 'currentWeight', 'filamentSku._id'];
const allowedFilters = ['filament', 'state', 'startingWeight', 'currentWeight', 'filament._id'];
const filter = getFilter(req.query, allowedFilters);
listFilamentStocksRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});
router.get('/properties', isAuthenticated, (req, res) => {
let properties = convertPropertiesString(req.query.properties);
const allowedFilters = ['filamentSku', 'state.type'];
const allowedFilters = ['filament', 'state.type'];
const filter = getFilter(req.query, allowedFilters, false);
var masterFilter = {};
if (req.query.masterFilter) {

2
src/routes/inventory/partstocks.js
View File

@ -18,7 +18,7 @@ import {
// list of part stocks
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const allowedFilters = ['partSku', 'state', 'startingQuantity', 'currentQuantity', 'partSku._id'];
const allowedFilters = ['part', 'state', 'startingQuantity', 'currentQuantity', 'part._id'];
const filter = getFilter(req.query, allowedFilters);
listPartStocksRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});

4
src/routes/inventory/productstocks.js
View File

@ -18,14 +18,14 @@ import {
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const allowedFilters = ['productSku', 'state', 'currentQuantity', 'productSku._id'];
const allowedFilters = ['product', 'state', 'currentQuantity', 'product._id'];
const filter = getFilter(req.query, allowedFilters);
listProductStocksRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});
router.get('/properties', isAuthenticated, (req, res) => {
let properties = convertPropertiesString(req.query.properties);
const allowedFilters = ['productSku', 'state.type'];
const allowedFilters = ['product', 'state.type'];
const filter = getFilter(req.query, allowedFilters, false);
var masterFilter = {};
if (req.query.masterFilter) {

8
src/routes/management/filaments.js
View File

@ -20,10 +20,12 @@ router.get('/', isAuthenticated, (req, res) => {
const allowedFilters = [
'_id',
'material',
'material._id',
'type',
'vendor.name',
'diameter',
'color',
'name',
'vendor._id',
'cost',
];
@ -42,7 +44,7 @@ router.get('/', isAuthenticated, (req, res) => {
router.get('/properties', isAuthenticated, (req, res) => {
let properties = convertPropertiesString(req.query.properties);
const allowedFilters = ['diameter', 'material'];
const allowedFilters = ['diameter', 'type', 'vendor'];
const filter = getFilter(req.query, allowedFilters, false);
listFilamentsByPropertiesRouteHandler(req, res, properties, filter);
});

59
src/routes/management/filamentskus.js
View File

@ -1,59 +0,0 @@
import express from 'express';
import { isAuthenticated } from '../../keycloak.js';
import { getFilter, convertPropertiesString } from '../../utils.js';
const router = express.Router();
import {
listFilamentSkusRouteHandler,
getFilamentSkuRouteHandler,
editFilamentSkuRouteHandler,
newFilamentSkuRouteHandler,
deleteFilamentSkuRouteHandler,
listFilamentSkusByPropertiesRouteHandler,
getFilamentSkuStatsRouteHandler,
getFilamentSkuHistoryRouteHandler,
} from '../../services/management/filamentskus.js';
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const allowedFilters = ['_id', 'barcode', 'filament', 'filament._id', 'name', 'color', 'cost'];
const filter = getFilter(req.query, allowedFilters);
listFilamentSkusRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});
router.get('/properties', isAuthenticated, (req, res) => {
let properties = convertPropertiesString(req.query.properties);
const allowedFilters = ['filament', 'filament._id'];
const filter = getFilter(req.query, allowedFilters, false);
let masterFilter = {};
if (req.query.masterFilter) {
masterFilter = JSON.parse(req.query.masterFilter);
}
listFilamentSkusByPropertiesRouteHandler(req, res, properties, filter, masterFilter);
});
router.post('/', isAuthenticated, (req, res) => {
newFilamentSkuRouteHandler(req, res);
});
router.get('/stats', isAuthenticated, (req, res) => {
getFilamentSkuStatsRouteHandler(req, res);
});
router.get('/history', isAuthenticated, (req, res) => {
getFilamentSkuHistoryRouteHandler(req, res);
});
router.get('/:id', isAuthenticated, (req, res) => {
getFilamentSkuRouteHandler(req, res);
});
router.put('/:id', isAuthenticated, async (req, res) => {
editFilamentSkuRouteHandler(req, res);
});
router.delete('/:id', isAuthenticated, async (req, res) => {
deleteFilamentSkuRouteHandler(req, res);
});
export default router;

25
src/routes/management/materials.js
View File

@ -1,11 +1,10 @@
import express from 'express';
import { isAuthenticated } from '../../keycloak.js';
import { convertPropertiesString, getFilter, parseFilter } from '../../utils.js';
import { parseFilter } from '../../utils.js';
const router = express.Router();
import {
listMaterialsRouteHandler,
listMaterialsByPropertiesRouteHandler,
getMaterialRouteHandler,
editMaterialRouteHandler,
newMaterialRouteHandler,
@ -15,26 +14,22 @@ import {
// list of materials
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const { page, limit, property } = req.query;
const allowedFilters = ['_id', 'name', 'tags'];
const allowedFilters = ['type', 'brand', 'diameter', 'color'];
var filter = {};
for (const [key, value] of Object.entries(req.query)) {
if (allowedFilters.includes(key)) {
filter = { ...filter, ...parseFilter(key, value) };
for (var i = 0; i < allowedFilters.length; i++) {
if (key == allowedFilters[i]) {
const parsedFilter = parseFilter(key, value);
filter = { ...filter, ...parsedFilter };
}
}
}
listMaterialsRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});
router.get('/properties', isAuthenticated, (req, res) => {
let properties = convertPropertiesString(req.query.properties);
const allowedFilters = ['name', 'tags'];
const filter = getFilter(req.query, allowedFilters, false);
listMaterialsByPropertiesRouteHandler(req, res, properties, filter);
listMaterialsRouteHandler(req, res, page, limit, property, filter);
});
router.post('/', isAuthenticated, (req, res) => {
@ -55,7 +50,7 @@ router.get('/:id', isAuthenticated, (req, res) => {
getMaterialRouteHandler(req, res);
});
// update material info
// update printer info
router.put('/:id', isAuthenticated, async (req, res) => {
editMaterialRouteHandler(req, res);
});

59
src/routes/management/partskus.js
View File

@ -1,59 +0,0 @@
import express from 'express';
import { isAuthenticated } from '../../keycloak.js';
import { getFilter, convertPropertiesString } from '../../utils.js';
const router = express.Router();
import {
listPartSkusRouteHandler,
getPartSkuRouteHandler,
editPartSkuRouteHandler,
newPartSkuRouteHandler,
deletePartSkuRouteHandler,
listPartSkusByPropertiesRouteHandler,
getPartSkuStatsRouteHandler,
getPartSkuHistoryRouteHandler,
} from '../../services/management/partskus.js';
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const allowedFilters = ['_id', 'barcode', 'part', 'part._id', 'name', 'cost', 'price'];
const filter = getFilter(req.query, allowedFilters);
listPartSkusRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});
router.get('/properties', isAuthenticated, (req, res) => {
let properties = convertPropertiesString(req.query.properties);
const allowedFilters = ['part', 'part._id'];
const filter = getFilter(req.query, allowedFilters, false);
let masterFilter = {};
if (req.query.masterFilter) {
masterFilter = JSON.parse(req.query.masterFilter);
}
listPartSkusByPropertiesRouteHandler(req, res, properties, filter, masterFilter);
});
router.post('/', isAuthenticated, (req, res) => {
newPartSkuRouteHandler(req, res);
});
router.get('/stats', isAuthenticated, (req, res) => {
getPartSkuStatsRouteHandler(req, res);
});
router.get('/history', isAuthenticated, (req, res) => {
getPartSkuHistoryRouteHandler(req, res);
});
router.get('/:id', isAuthenticated, (req, res) => {
getPartSkuRouteHandler(req, res);
});
router.put('/:id', isAuthenticated, async (req, res) => {
editPartSkuRouteHandler(req, res);
});
router.delete('/:id', isAuthenticated, async (req, res) => {
deletePartSkuRouteHandler(req, res);
});
export default router;

2
src/routes/management/productskus.js
View File

@ -16,7 +16,7 @@ import {
router.get('/', isAuthenticated, (req, res) => {
const { page, limit, property, search, sort, order } = req.query;
const allowedFilters = ['_id', 'barcode', 'product', 'product._id', 'name', 'cost', 'price'];
const allowedFilters = ['_id', 'sku', 'product', 'product._id', 'name'];
const filter = getFilter(req.query, allowedFilters);
listProductSkusRouteHandler(req, res, page, limit, property, filter, search, sort, order);
});

8
src/services/inventory/filamentstocks.js
View File

@ -36,7 +36,7 @@ export const listFilamentStocksRouteHandler = async (
search,
sort,
order,
populate: [{ path: 'filamentSku' }],
populate: [{ path: 'filament' }],
});
if (result?.error) {
@ -60,7 +60,7 @@ export const listFilamentStocksByPropertiesRouteHandler = async (
model: filamentStockModel,
properties,
filter,
populate: ['filamentSku'],
populate: ['filament'],
masterFilter,
});
@ -79,7 +79,7 @@ export const getFilamentStockRouteHandler = async (req, res) => {
const result = await getObject({
model: filamentStockModel,
id,
populate: [{ path: 'filamentSku' }],
populate: [{ path: 'filament' }],
});
if (result?.error) {
logger.warn(`Filament Stock not found with supplied id.`);
@ -146,7 +146,7 @@ export const newFilamentStockRouteHandler = async (req, res) => {
updatedAt: new Date(),
startingWeight: req.body.startingWeight,
currentWeight: req.body.currentWeight,
filamentSku: req.body.filamentSku,
filament: req.body.filament,
state: req.body.state,
};
const result = await newObject({

141
src/services/inventory/orderitems.js
View File

@ -1,6 +1,5 @@
import config from '../../config.js';
import { orderItemModel } from '../../database/schemas/inventory/orderitem.schema.js';
import { getModelByName } from '../misc/model.js';
import log4js from 'log4js';
import mongoose from 'mongoose';
import {
@ -51,39 +50,11 @@ export const listOrderItemsRouteHandler = async (
},
{
path: 'item',
populate: [
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
populate: { path: 'costTaxRate', strictPopulate: false },
},
{
path: 'sku',
strictPopulate: false,
populate: [
{
path: 'filament',
populate: { path: 'costTaxRate', strictPopulate: false },
strictPopulate: false,
},
{
path: 'part',
populate: [
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
strictPopulate: false,
},
{
path: 'product',
populate: [
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
strictPopulate: false,
},
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
path: 'item',
populate: { path: 'priceTaxRate', strictPopulate: false },
},
],
});
@ -138,40 +109,13 @@ export const getOrderItemRouteHandler = async (req, res) => {
},
{
path: 'item',
populate: [
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
populate: { path: 'costTaxRate', strictPopulate: false },
strictPopulate: false,
},
{
path: 'sku',
path: 'item',
populate: { path: 'priceTaxRate', strictPopulate: false },
strictPopulate: false,
populate: [
{
path: 'filament',
populate: { path: 'costTaxRate', strictPopulate: false },
strictPopulate: false,
},
{
path: 'part',
populate: [
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
strictPopulate: false,
},
{
path: 'product',
populate: [
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
strictPopulate: false,
},
{ path: 'costTaxRate', strictPopulate: false },
{ path: 'priceTaxRate', strictPopulate: false },
],
},
],
});
@ -189,39 +133,11 @@ export const editOrderItemRouteHandler = async (req, res) => {
logger.trace(`Order Item with ID: ${id}`);
const skuType =
req.body.sku && req.body.itemType ? req.body.itemType + 'Sku' : null;
let name = req.body.name;
if (!name && req.body.sku && skuType) {
const skuEntry = getModelByName(skuType);
if (skuEntry?.model) {
const sku = await getObject({
model: skuEntry.model,
id: req.body.sku,
cached: true,
});
name = sku?.name;
}
}
if (!name && req.body.item && req.body.itemType) {
const itemEntry = getModelByName(req.body.itemType);
if (itemEntry?.model) {
const item = await getObject({
model: itemEntry.model,
id: req.body.item,
cached: true,
});
name = item?.name;
}
}
const updateData = {
updatedAt: new Date(),
name: req.body.name ?? name,
name: req.body.name,
itemType: req.body.itemType,
item: req.body.item,
sku: req.body.sku,
orderType: req.body.orderType,
order: req.body.order,
syncAmount: req.body.syncAmount,
@ -242,7 +158,7 @@ export const editOrderItemRouteHandler = async (req, res) => {
if (result.error) {
logger.error('Error editing order item:', result.error);
res.status(result.code || 500).send(result);
res.status(result).send(result);
return;
}
@ -257,14 +173,13 @@ export const editMultipleOrderItemsRouteHandler = async (req, res) => {
name: update.name,
itemType: update.itemType,
item: update.item,
sku: update.sku,
orderType: update.orderType,
order: update.order,
syncAmount: update.syncAmount,
itemAmount: update.itemAmount,
quantity: update.quantity,
totalAmount: update.totalAmount,
shipment: update.shipment,
syncAmount: update.syncAmount,
itemAmount: update.itemAmount,
quantity: update.quantity,
totalAmount: update.totalAmount,
shipment: update.shipment,
taxRate: update.taxRate,
totalAmountWithTax: update.totalAmountWithTax,
}));
@ -291,41 +206,13 @@ export const editMultipleOrderItemsRouteHandler = async (req, res) => {
};
export const newOrderItemRouteHandler = async (req, res) => {
const skuType =
req.body.sku && req.body.itemType ? req.body.itemType + 'Sku' : null;
let name = req.body.name;
if (!name && req.body.sku && skuType) {
const skuEntry = getModelByName(skuType);
if (skuEntry?.model) {
const sku = await getObject({
model: skuEntry.model,
id: req.body.sku,
cached: true,
});
name = sku?.name;
}
}
if (!name && req.body.item && req.body.itemType) {
const itemEntry = getModelByName(req.body.itemType);
if (itemEntry?.model) {
const item = await getObject({
model: itemEntry.model,
id: req.body.item,
cached: true,
});
name = item?.name;
}
}
const newData = {
updatedAt: new Date(),
name: name || 'Order Item',
name: req.body.name,
purchaseOrder: req.body.purchaseOrder,
state: { type: 'draft' },
itemType: req.body.itemType,
item: req.body.item,
sku: req.body.sku,
orderType: req.body.orderType,
order: req.body.order,
syncAmount: req.body.syncAmount,

8
src/services/inventory/partstocks.js
View File

@ -36,7 +36,7 @@ export const listPartStocksRouteHandler = async (
search,
sort,
order,
populate: [{ path: 'partSku' }],
populate: [{ path: 'part' }],
});
if (result?.error) {
@ -60,7 +60,7 @@ export const listPartStocksByPropertiesRouteHandler = async (
model: partStockModel,
properties,
filter,
populate: ['partSku'],
populate: ['part'],
masterFilter,
});
@ -79,7 +79,7 @@ export const getPartStockRouteHandler = async (req, res) => {
const result = await getObject({
model: partStockModel,
id,
populate: [{ path: 'partSku' }],
populate: [{ path: 'part' }],
});
if (result?.error) {
logger.warn(`Part Stock not found with supplied id.`);
@ -146,7 +146,7 @@ export const newPartStockRouteHandler = async (req, res) => {
updatedAt: new Date(),
startingQuantity: req.body.startingQuantity,
currentQuantity: req.body.currentQuantity,
partSku: req.body.partSku,
part: req.body.part,
state: req.body.state,
};
const result = await newObject({

23
src/services/inventory/productstocks.js
View File

@ -14,7 +14,7 @@ import {
getModelHistory,
checkStates,
} from '../../database/database.js';
import { productSkuModel } from '../../database/schemas/management/productsku.schema.js';
import { productModel } from '../../database/schemas/management/product.schema.js';
const logger = log4js.getLogger('Product Stocks');
logger.level = config.server.logLevel;
@ -38,7 +38,7 @@ export const listProductStocksRouteHandler = async (
search,
sort,
order,
populate: [{ path: 'productSku' }, { path: 'partStocks.partStock' }],
populate: [{ path: 'product' }, { path: 'partStocks.partStock' }],
});
if (result?.error) {
@ -62,7 +62,7 @@ export const listProductStocksByPropertiesRouteHandler = async (
model: productStockModel,
properties,
filter,
populate: ['productSku', 'partStocks.partStock'],
populate: ['product', 'partStocks.partStock'],
masterFilter,
});
@ -81,7 +81,7 @@ export const getProductStockRouteHandler = async (req, res) => {
const result = await getObject({
model: productStockModel,
id,
populate: [{ path: 'partStocks.partSku' }, { path: 'partStocks.partStock' }, { path: 'productSku' }],
populate: [{ path: 'partStocks.part' }, { path: 'partStocks.partStock' }, { path: 'product' }],
});
if (result?.error) {
logger.warn(`Product Stock not found with supplied id.`);
@ -114,7 +114,6 @@ export const editProductStockRouteHandler = async (req, res) => {
partStocks: req.body?.partStocks?.map((partStock) => ({
quantity: partStock.quantity,
partStock: partStock.partStock,
partSku: partStock.partSku,
})),
};
@ -163,18 +162,18 @@ export const editMultipleProductStocksRouteHandler = async (req, res) => {
};
export const newProductStockRouteHandler = async (req, res) => {
const productSkuId = new mongoose.Types.ObjectId(req.body.productSku?._id);
const productSku = await getObject({
model: productSkuModel,
id: productSkuId,
const productId = new mongoose.Types.ObjectId(req.body.product?._id);
const product = await getObject({
model: productModel,
id: productId,
});
const newData = {
updatedAt: new Date(),
currentQuantity: req.body.currentQuantity,
productSku: req.body.productSku,
product: req.body.product,
state: req.body.state ?? { type: 'draft' },
partStocks: (productSku.parts || []).map((part) => ({
partSku: part.partSku,
partStocks: product.parts.map((part) => ({
part: part.part,
quantity: part.quantity,
partStock: undefined,
})),

45
src/services/management/filaments.js
View File

@ -36,7 +36,7 @@ export const listFilamentsRouteHandler = async (
search,
sort,
order,
populate: ['costTaxRate', 'material'],
populate: ['vendor', 'costTaxRate'],
});
if (result?.error) {
@ -59,7 +59,16 @@ export const listFilamentsByPropertiesRouteHandler = async (
model: filamentModel,
properties,
filter,
populate: [],
populate: [
{
path: 'vendor',
from: 'vendors',
},
{
path: 'costTaxRate',
from: 'taxrates',
},
],
});
if (result?.error) {
@ -77,7 +86,7 @@ export const getFilamentRouteHandler = async (req, res) => {
const result = await getObject({
model: filamentModel,
id,
populate: ['costTaxRate', 'material'],
populate: ['vendor', 'costTaxRate'],
});
if (result?.error) {
logger.warn(`Filament not found with supplied id.`);
@ -99,13 +108,15 @@ export const editFilamentRouteHandler = async (req, res) => {
barcode: req.body.barcode,
url: req.body.url,
image: req.body.image,
material: req.body.material?._id ?? req.body.material,
color: req.body.color,
vendor: req.body.vendor,
type: req.body.type,
cost: req.body.cost,
costTaxRate: req.body.costTaxRate,
costWithTax: req.body.costWithTax,
diameter: req.body.diameter,
density: req.body.density,
emptySpoolWeight: req.body.emptySpoolWeight,
cost: req.body?.cost,
costTaxRate: req.body?.costTaxRate,
costWithTax: req.body?.costWithTax,
};
const result = await editObject({
model: filamentModel,
@ -132,13 +143,15 @@ export const editMultipleFilamentsRouteHandler = async (req, res) => {
barcode: update.barcode,
url: update.url,
image: update.image,
material: update.material?._id ?? update.material,
diameter: update.diameter,
density: update.density,
emptySpoolWeight: update.emptySpoolWeight,
color: update.color,
vendor: update.vendor,
type: update.type,
cost: update.cost,
costTaxRate: update.costTaxRate,
costWithTax: update.costWithTax,
diameter: update.diameter,
density: update.density,
emptySpoolWeight: update.emptySpoolWeight,
}));
if (!Array.isArray(updates)) {
@ -170,13 +183,15 @@ export const newFilamentRouteHandler = async (req, res) => {
barcode: req.body.barcode,
url: req.body.url,
image: req.body.image,
material: req.body.material?._id ?? req.body.material,
color: req.body.color,
vendor: req.body.vendor,
type: req.body.type,
cost: req.body.cost,
costTaxRate: req.body.costTaxRate,
costWithTax: req.body.costWithTax,
diameter: req.body.diameter,
density: req.body.density,
emptySpoolWeight: req.body.emptySpoolWeight,
cost: req.body?.cost,
costTaxRate: req.body?.costTaxRate,
costWithTax: req.body?.costWithTax,
};
const result = await newObject({

196
src/services/management/filamentskus.js
View File

@ -1,196 +0,0 @@
import config from '../../config.js';
import { filamentSkuModel } from '../../database/schemas/management/filamentsku.schema.js';
import log4js from 'log4js';
import mongoose from 'mongoose';
import {
deleteObject,
listObjects,
getObject,
editObject,
newObject,
listObjectsByProperties,
getModelStats,
getModelHistory,
} from '../../database/database.js';
const logger = log4js.getLogger('Filament SKUs');
logger.level = config.server.logLevel;
export const listFilamentSkusRouteHandler = async (
req,
res,
page = 1,
limit = 25,
property = '',
filter = {},
search = '',
sort = '',
order = 'ascend'
) => {
const result = await listObjects({
model: filamentSkuModel,
page,
limit,
property,
filter,
search,
sort,
order,
populate: ['costTaxRate'],
});
if (result?.error) {
logger.error('Error listing filament SKUs.');
res.status(result.code).send(result);
return;
}
logger.debug(`List of filament SKUs (Page ${page}, Limit ${limit}). Count: ${result.length}.`);
res.send(result);
};
export const listFilamentSkusByPropertiesRouteHandler = async (
req,
res,
properties = '',
filter = {},
masterFilter = {}
) => {
const result = await listObjectsByProperties({
model: filamentSkuModel,
properties,
filter,
populate: ['costTaxRate'],
masterFilter,
});
if (result?.error) {
logger.error('Error listing filament SKUs.');
res.status(result.code).send(result);
return;
}
logger.debug(`List of filament SKUs. Count: ${result.length}`);
res.send(result);
};
export const getFilamentSkuRouteHandler = async (req, res) => {
const id = req.params.id;
const result = await getObject({
model: filamentSkuModel,
id,
populate: [{ path: 'filament', populate: 'costTaxRate' }, 'costTaxRate'],
});
if (result?.error) {
logger.warn(`Filament SKU not found with supplied id.`);
return res.status(result.code).send(result);
}
logger.debug(`Retrieved filament SKU with ID: ${id}`);
res.send(result);
};
export const editFilamentSkuRouteHandler = async (req, res) => {
const id = new mongoose.Types.ObjectId(req.params.id);
logger.trace(`Filament SKU with ID: ${id}`);
const overrideCost = req.body?.overrideCost;
const updateData = {
updatedAt: new Date(),
barcode: req.body?.barcode,
filament: req.body?.filament,
name: req.body?.name,
description: req.body?.description,
color: req.body?.color,
cost: overrideCost ? req.body?.cost : null,
overrideCost,
costTaxRate: overrideCost ? req.body?.costTaxRate : null,
costWithTax: overrideCost ? req.body?.costWithTax : null,
};
const result = await editObject({
model: filamentSkuModel,
id,
updateData,
user: req.user,
});
if (result.error) {
logger.error('Error editing filament SKU:', result.error);
res.status(result.code || 500).send(result);
return;
}
logger.debug(`Edited filament SKU with ID: ${id}`);
res.send(result);
};
export const newFilamentSkuRouteHandler = async (req, res) => {
const overrideCost = req.body?.overrideCost;
const newData = {
barcode: req.body?.barcode,
filament: req.body?.filament,
name: req.body?.name,
description: req.body?.description,
color: req.body?.color,
cost: overrideCost ? req.body?.cost : null,
overrideCost,
costTaxRate: overrideCost ? req.body?.costTaxRate : null,
costWithTax: overrideCost ? req.body?.costWithTax : null,
};
const result = await newObject({
model: filamentSkuModel,
newData,
user: req.user,
});
if (result.error) {
logger.error('No filament SKU created:', result.error);
return res.status(result.code).send(result);
}
logger.debug(`New filament SKU with ID: ${result._id}`);
res.send(result);
};
export const deleteFilamentSkuRouteHandler = async (req, res) => {
const id = new mongoose.Types.ObjectId(req.params.id);
logger.trace(`Filament SKU with ID: ${id}`);
const result = await deleteObject({
model: filamentSkuModel,
id,
user: req.user,
});
if (result.error) {
logger.error('No filament SKU deleted:', result.error);
return res.status(result.code).send(result);
}
logger.debug(`Deleted filament SKU with ID: ${id}`);
res.send(result);
};
export const getFilamentSkuStatsRouteHandler = async (req, res) => {
const result = await getModelStats({ model: filamentSkuModel });
if (result?.error) {
logger.error('Error fetching filament SKU stats:', result.error);
return res.status(result.code).send(result);
}
logger.trace('Filament SKU stats:', result);
res.send(result);
};
export const getFilamentSkuHistoryRouteHandler = async (req, res) => {
const from = req.query.from;
const to = req.query.to;
const result = await getModelHistory({ model: filamentSkuModel, from, to });
if (result?.error) {
logger.error('Error fetching filament SKU history:', result.error);
return res.status(result.code).send(result);
}
logger.trace('Filament SKU history:', result);
res.send(result);
};

196
src/services/management/materials.js
View File

@ -2,16 +2,7 @@ import config from '../../config.js';
import { materialModel } from '../../database/schemas/management/material.schema.js';
import log4js from 'log4js';
import mongoose from 'mongoose';
import {
getObject,
listObjects,
listObjectsByProperties,
editObject,
newObject,
getModelStats,
getModelHistory,
} from '../../database/database.js';
import { getModelStats, getModelHistory } from '../../database/database.js';
const logger = log4js.getLogger('Materials');
logger.level = config.server.logLevel;
@ -21,121 +12,118 @@ export const listMaterialsRouteHandler = async (
page = 1,
limit = 25,
property = '',
filter = {},
search = '',
sort = '',
order = 'ascend'
) => {
const result = await listObjects({
model: materialModel,
page,
limit,
property,
filter,
search,
sort,
order,
populate: [],
});
if (result?.error) {
logger.error('Error listing materials.');
res.status(result.code).send(result);
return;
}
logger.debug(`List of materials (Page ${page}, Limit ${limit}). Count: ${result.length}`);
res.send(result);
};
export const listMaterialsByPropertiesRouteHandler = async (
req,
res,
properties = [],
filter = {}
) => {
const result = await listObjectsByProperties({
model: materialModel,
properties,
filter,
populate: [],
});
try {
// Calculate the skip value based on the page number and limit
const skip = (page - 1) * limit;
if (result?.error) {
logger.error('Error listing materials.');
res.status(result.code).send(result);
return;
let material;
let aggregateCommand = [];
if (filter != {}) {
// use filtering if present
aggregateCommand.push({ $match: filter });
}
if (property != '') {
aggregateCommand.push({ $group: { _id: `$${property}` } }); // group all same properties
aggregateCommand.push({ $project: { _id: 0, [property]: '$_id' } }); // rename _id to the property name
} else {
aggregateCommand.push({ $project: { image: 0, url: 0 } });
}
aggregateCommand.push({ $skip: skip });
aggregateCommand.push({ $limit: Number(limit) });
material = await materialModel.aggregate(aggregateCommand);
logger.trace(
`List of materials (Page ${page}, Limit ${limit}, Property ${property}):`,
material
);
res.send(material);
} catch (error) {
logger.error('Error listing materials:', error);
res.status(500).send({ error: error });
}
logger.debug(`List of materials. Count: ${result.length}`);
res.send(result);
};
export const getMaterialRouteHandler = async (req, res) => {
const id = req.params.id;
const result = await getObject({
model: materialModel,
id,
populate: [],
});
if (result?.error) {
logger.warn(`Material not found with supplied id.`);
return res.status(result.code).send(result);
try {
// Get ID from params
const id = new mongoose.Types.ObjectId(req.params.id);
// Fetch the material with the given remote address
const material = await materialModel.findOne({
_id: id,
});
if (!material) {
logger.warn(`Material not found with supplied id.`);
return res.status(404).send({ error: 'Print job not found.' });
}
logger.trace(`Material with ID: ${id}:`, material);
res.send(material);
} catch (error) {
logger.error('Error fetching Material:', error);
res.status(500).send({ error: error.message });
}
logger.debug(`Retrieved material with ID: ${id}`);
res.send(result);
};
export const editMaterialRouteHandler = async (req, res) => {
const id = new mongoose.Types.ObjectId(req.params.id);
try {
// Get ID from params
const id = new mongoose.Types.ObjectId(req.params.id);
// Fetch the material with the given remote address
const material = await materialModel.findOne({ _id: id });
logger.trace(`Material with ID: ${id}`);
if (!material) {
// Error handling
logger.warn(`Material not found with supplied id.`);
return res.status(404).send({ error: 'Print job not found.' });
}
const updateData = {
updatedAt: new Date(),
name: req.body.name,
url: req.body.url,
tags: req.body.tags,
};
logger.trace(`Material with ID: ${id}:`, material);
const result = await editObject({
model: materialModel,
id,
updateData,
user: req.user,
});
try {
const updateData = req.body;
if (result.error) {
logger.error('Error editing material:', result.error);
res.status(result.code).send(result);
return;
const result = await materialModel.updateOne({ _id: id }, { $set: updateData });
if (result.nModified === 0) {
logger.error('No Material updated.');
res.status(500).send({ error: 'No materials updated.' });
}
} catch (updateError) {
logger.error('Error updating material:', updateError);
res.status(500).send({ error: updateError.message });
}
res.send('OK');
} catch (fetchError) {
logger.error('Error fetching material:', fetchError);
res.status(500).send({ error: fetchError.message });
}
logger.debug(`Edited material with ID: ${id}`);
res.send(result);
};
export const newMaterialRouteHandler = async (req, res) => {
const newData = {
createdAt: new Date(),
updatedAt: new Date(),
name: req.body.name,
url: req.body.url,
tags: req.body.tags,
};
try {
let { ...newMaterial } = req.body;
newMaterial = {
...newMaterial,
createdAt: new Date(),
updatedAt: new Date(),
};
const result = await newObject({
model: materialModel,
newData,
user: req.user,
});
if (result.error) {
logger.error('No material created:', result.error);
return res.status(result.code).send(result);
const result = await materialModel.create(newMaterial);
if (result.nCreated === 0) {
logger.error('No material created.');
res.status(500).send({ error: 'No material created.' });
}
res.status(200).send({ status: 'ok' });
} catch (updateError) {
logger.error('Error updating material:', updateError);
res.status(500).send({ error: updateError.message });
}
logger.debug(`New material with ID: ${result._id}`);
res.send(result);
};
export const getMaterialStatsRouteHandler = async (req, res) => {

43
src/services/management/parts.js
View File

@ -35,7 +35,7 @@ export const listPartsRouteHandler = async (
search,
sort,
order,
populate: ['costTaxRate', 'priceTaxRate'],
populate: ['vendor'],
});
if (result?.error) {
@ -53,7 +53,20 @@ export const listPartsByPropertiesRouteHandler = async (req, res, properties = '
model: partModel,
properties,
filter,
populate: [],
populate: [
{
path: 'vendor',
from: 'vendors',
},
{
path: 'priceTaxRate',
from: 'taxrates',
},
{
path: 'costTaxRate',
from: 'taxrates',
},
],
});
if (result?.error) {
@ -71,7 +84,7 @@ export const getPartRouteHandler = async (req, res) => {
const result = await getObject({
model: partModel,
id,
populate: ['costTaxRate', 'priceTaxRate'],
populate: ['vendor', 'priceTaxRate', 'costTaxRate'],
});
if (result?.error) {
logger.warn(`Part not found with supplied id.`);
@ -90,16 +103,16 @@ export const editPartRouteHandler = async (req, res) => {
const updateData = {
updatedAt: new Date(),
name: req.body?.name,
fileName: req.body?.fileName,
file: req.body?.file,
cost: req.body?.cost,
price: req.body?.price,
priceMode: req.body?.priceMode,
vendor: req.body?.vendor,
margin: req.body?.margin,
costTaxRate: req.body?.costTaxRate,
price: req.body?.price,
cost: req.body?.cost,
priceMode: req.body?.priceMode,
priceTaxRate: req.body?.priceTaxRate,
costWithTax: req.body?.costWithTax,
costTaxRate: req.body?.costTaxRate,
priceWithTax: req.body?.priceWithTax,
costWithTax: req.body?.costWithTax,
};
// Create audit log before updating
const result = await editObject({
@ -124,16 +137,16 @@ export const newPartRouteHandler = async (req, res) => {
const newData = {
updatedAt: new Date(),
name: req.body?.name,
fileName: req.body?.fileName,
file: req.body?.file,
cost: req.body?.cost,
price: req.body?.price,
priceMode: req.body?.priceMode,
vendor: req.body?.vendor,
margin: req.body?.margin,
costTaxRate: req.body?.costTaxRate,
price: req.body?.price,
cost: req.body?.cost,
priceMode: req.body?.priceMode,
priceTaxRate: req.body?.priceTaxRate,
costWithTax: req.body?.costWithTax,
costTaxRate: req.body?.costTaxRate,
priceWithTax: req.body?.priceWithTax,
costWithTax: req.body?.costWithTax,
};
const result = await newObject({

212
src/services/management/partskus.js
View File

@ -1,212 +0,0 @@
import config from '../../config.js';
import { partSkuModel } from '../../database/schemas/management/partsku.schema.js';
import log4js from 'log4js';
import mongoose from 'mongoose';
import {
deleteObject,
listObjects,
getObject,
editObject,
newObject,
listObjectsByProperties,
getModelStats,
getModelHistory,
} from '../../database/database.js';
const logger = log4js.getLogger('Part SKUs');
logger.level = config.server.logLevel;
export const listPartSkusRouteHandler = async (
req,
res,
page = 1,
limit = 25,
property = '',
filter = {},
search = '',
sort = '',
order = 'ascend'
) => {
const result = await listObjects({
model: partSkuModel,
page,
limit,
property,
filter,
search,
sort,
order,
populate: ['priceTaxRate', 'costTaxRate'],
});
if (result?.error) {
logger.error('Error listing part SKUs.');
res.status(result.code).send(result);
return;
}
logger.debug(`List of part SKUs (Page ${page}, Limit ${limit}). Count: ${result.length}.`);
res.send(result);
};
export const listPartSkusByPropertiesRouteHandler = async (
req,
res,
properties = '',
filter = {},
masterFilter = {}
) => {
const result = await listObjectsByProperties({
model: partSkuModel,
properties,
filter,
populate: ['priceTaxRate', 'costTaxRate'],
masterFilter,
});
if (result?.error) {
logger.error('Error listing part SKUs.');
res.status(result.code).send(result);
return;
}
logger.debug(`List of part SKUs. Count: ${result.length}`);
res.send(result);
};
export const getPartSkuRouteHandler = async (req, res) => {
const id = req.params.id;
const result = await getObject({
model: partSkuModel,
id,
populate: [
{ path: 'part', populate: ['costTaxRate', 'priceTaxRate'] },
'priceTaxRate',
'costTaxRate',
],
});
if (result?.error) {
logger.warn(`Part SKU not found with supplied id.`);
return res.status(result.code).send(result);
}
logger.debug(`Retrieved part SKU with ID: ${id}`);
res.send(result);
};
export const editPartSkuRouteHandler = async (req, res) => {
const id = new mongoose.Types.ObjectId(req.params.id);
logger.trace(`Part SKU with ID: ${id}`);
const overrideCost = req.body?.overrideCost;
const overridePrice = req.body?.overridePrice;
const updateData = {
updatedAt: new Date(),
barcode: req.body?.barcode,
part: req.body?.part,
name: req.body?.name,
description: req.body?.description,
priceMode: req.body?.priceMode,
price: overridePrice ? req.body?.price : null,
cost: overrideCost ? req.body?.cost : null,
overrideCost,
overridePrice,
margin: overridePrice ? req.body?.margin : null,
priceTaxRate: overridePrice ? req.body?.priceTaxRate : null,
costTaxRate: overrideCost ? req.body?.costTaxRate : null,
priceWithTax: overridePrice ? req.body?.priceWithTax : null,
costWithTax: overrideCost ? req.body?.costWithTax : null,
};
const result = await editObject({
model: partSkuModel,
id,
updateData,
user: req.user,
});
if (result.error) {
logger.error('Error editing part SKU:', result.error);
res.status(result.code || 500).send(result);
return;
}
logger.debug(`Edited part SKU with ID: ${id}`);
res.send(result);
};
export const newPartSkuRouteHandler = async (req, res) => {
const overrideCost = req.body?.overrideCost;
const overridePrice = req.body?.overridePrice;
const newData = {
barcode: req.body?.barcode,
part: req.body?.part,
name: req.body?.name,
description: req.body?.description,
priceMode: req.body?.priceMode,
price: overridePrice ? req.body?.price : null,
cost: overrideCost ? req.body?.cost : null,
overrideCost,
overridePrice,
margin: overridePrice ? req.body?.margin : null,
priceTaxRate: overridePrice ? req.body?.priceTaxRate : null,
costTaxRate: overrideCost ? req.body?.costTaxRate : null,
priceWithTax: overridePrice ? req.body?.priceWithTax : null,
costWithTax: overrideCost ? req.body?.costWithTax : null,
};
const result = await newObject({
model: partSkuModel,
newData,
user: req.user,
});
if (result.error) {
logger.error('No part SKU created:', result.error);
return res.status(result.code).send(result);
}
logger.debug(`New part SKU with ID: ${result._id}`);
res.send(result);
};
export const deletePartSkuRouteHandler = async (req, res) => {
const id = new mongoose.Types.ObjectId(req.params.id);
logger.trace(`Part SKU with ID: ${id}`);
const result = await deleteObject({
model: partSkuModel,
id,
user: req.user,
});
if (result.error) {
logger.error('No part SKU deleted:', result.error);
return res.status(result.code).send(result);
}
logger.debug(`Deleted part SKU with ID: ${id}`);
res.send(result);
};
export const getPartSkuStatsRouteHandler = async (req, res) => {
const result = await getModelStats({ model: partSkuModel });
if (result?.error) {
logger.error('Error fetching part SKU stats:', result.error);
return res.status(result.code).send(result);
}
logger.trace('Part SKU stats:', result);
res.send(result);
};
export const getPartSkuHistoryRouteHandler = async (req, res) => {
const from = req.query.from;
const to = req.query.to;
const result = await getModelHistory({ model: partSkuModel, from, to });
if (result?.error) {
logger.error('Error fetching part SKU history:', result.error);
return res.status(result.code).send(result);
}
logger.trace('Part SKU history:', result);
res.send(result);
};

28
src/services/management/products.js
View File

@ -35,7 +35,7 @@ export const listProductsRouteHandler = async (
search,
sort,
order,
populate: ['vendor', 'costTaxRate', 'priceTaxRate'],
populate: ['vendor'],
});
if (result?.error) {
@ -76,7 +76,7 @@ export const getProductRouteHandler = async (req, res) => {
const result = await getObject({
model: productModel,
id,
populate: ['vendor', 'costTaxRate', 'priceTaxRate'],
populate: ['vendor', 'parts.part'],
});
if (result?.error) {
logger.warn(`Product not found with supplied id.`);
@ -97,15 +97,11 @@ export const editProductRouteHandler = async (req, res) => {
name: req.body?.name,
tags: req.body?.tags,
version: req.body?.version,
margin: req.body.margin,
amount: req.body.amount,
priceMode: req.body.priceMode,
vendor: req.body.vendor,
cost: req.body?.cost,
price: req.body?.price,
priceMode: req.body?.priceMode,
margin: req.body?.margin,
costTaxRate: req.body?.costTaxRate,
priceTaxRate: req.body?.priceTaxRate,
costWithTax: req.body?.costWithTax,
priceWithTax: req.body?.priceWithTax,
parts: req.body.parts,
};
// Create audit log before updating
const result = await editObject({
@ -132,15 +128,11 @@ export const newProductRouteHandler = async (req, res) => {
name: req.body?.name,
tags: req.body?.tags,
version: req.body?.version,
margin: req.body.margin,
amount: req.body.amount,
priceMode: req.body.priceMode,
vendor: req.body.vendor,
cost: req.body?.cost,
price: req.body?.price,
priceMode: req.body?.priceMode,
margin: req.body?.margin,
costTaxRate: req.body?.costTaxRate,
priceTaxRate: req.body?.priceTaxRate,
costWithTax: req.body?.costWithTax,
priceWithTax: req.body?.priceWithTax,
parts: req.body.parts,
};
const result = await newObject({

43
src/services/management/productskus.js
View File

@ -35,7 +35,7 @@ export const listProductSkusRouteHandler = async (
search,
sort,
order,
populate: ['priceTaxRate', 'costTaxRate'],
populate: ['product'],
});
if (result?.error) {
@ -59,7 +59,7 @@ export const listProductSkusByPropertiesRouteHandler = async (
model: productSkuModel,
properties,
filter,
populate: ['priceTaxRate', 'costTaxRate'],
populate: ['product'],
masterFilter,
});
@ -78,12 +78,7 @@ export const getProductSkuRouteHandler = async (req, res) => {
const result = await getObject({
model: productSkuModel,
id,
populate: [
{ path: 'product', populate: ['costTaxRate', 'priceTaxRate'] },
'priceTaxRate',
'costTaxRate',
'parts.partSku',
],
populate: ['product'],
});
if (result?.error) {
logger.warn(`Product SKU not found with supplied id.`);
@ -98,26 +93,12 @@ export const editProductSkuRouteHandler = async (req, res) => {
logger.trace(`Product SKU with ID: ${id}`);
const overrideCost = req.body?.overrideCost;
const overridePrice = req.body?.overridePrice;
const updateData = {
updatedAt: new Date(),
barcode: req.body?.barcode,
sku: req.body?.sku,
product: req.body?.product,
name: req.body?.name,
description: req.body?.description,
priceMode: req.body?.priceMode,
price: overridePrice ? req.body?.price : null,
cost: overrideCost ? req.body?.cost : null,
overrideCost,
overridePrice,
margin: overridePrice ? req.body?.margin : null,
parts: req.body?.parts,
priceTaxRate: overridePrice ? req.body?.priceTaxRate : null,
costTaxRate: overrideCost ? req.body?.costTaxRate : null,
priceWithTax: overridePrice ? req.body?.priceWithTax : null,
costWithTax: overrideCost ? req.body?.costWithTax : null,
};
const result = await editObject({
@ -138,25 +119,11 @@ export const editProductSkuRouteHandler = async (req, res) => {
};
export const newProductSkuRouteHandler = async (req, res) => {
const overrideCost = req.body?.overrideCost;
const overridePrice = req.body?.overridePrice;
const newData = {
barcode: req.body?.barcode,
sku: req.body?.sku,
product: req.body?.product,
name: req.body?.name,
description: req.body?.description,
priceMode: req.body?.priceMode,
price: overridePrice ? req.body?.price : null,
cost: overrideCost ? req.body?.cost : null,
overrideCost,
overridePrice,
margin: overridePrice ? req.body?.margin : null,
parts: req.body?.parts,
priceTaxRate: overridePrice ? req.body?.priceTaxRate : null,
costTaxRate: overrideCost ? req.body?.costTaxRate : null,
priceWithTax: overridePrice ? req.body?.priceWithTax : null,
costWithTax: overrideCost ? req.body?.costWithTax : null,
};
const result = await newObject({

87
src/services/misc/csv.js
View File

@ -4,11 +4,96 @@ import { getModelByName } from './model.js';
import { listObjectsOData } from '../../database/odata.js';
import { getFilter } from '../../utils.js';
import { generateCsvTable } from '../../database/csv.js';
import { getModelFilterFields, parseOrderBy, rowToFlat } from './export.js';
const logger = log4js.getLogger('CSV');
logger.level = config.server.logLevel;
/**
* Flatten nested objects for CSV display.
* Objects become "key.subkey: value" or JSON string; arrays become comma-separated.
*/
function flattenForCsv(obj, prefix = '') {
if (obj === null || obj === undefined) return {};
if (typeof obj !== 'object') return { [prefix]: obj };
if (obj instanceof Date) return { [prefix]: obj };
if (Array.isArray(obj)) {
const str = obj
.map((v) => (v && typeof v === 'object' && !(v instanceof Date) ? JSON.stringify(v) : v))
.join(', ');
return { [prefix]: str };
}
const result = {};
for (const [k, v] of Object.entries(obj)) {
const key = prefix ? `${prefix}.${k}` : k;
if (v !== null && typeof v === 'object' && !(v instanceof Date) && !Array.isArray(v)) {
Object.assign(result, flattenForCsv(v, key));
} else {
result[key] = v;
}
}
return result;
}
/**
* Convert a row to flat key-value for CSV. Nested objects are flattened.
*/
function rowToFlat(row) {
const flat = {};
for (const [key, val] of Object.entries(row)) {
if (key.startsWith('@')) continue;
if (val !== null && typeof val === 'object' && !(val instanceof Date) && !Array.isArray(val)) {
Object.assign(flat, flattenForCsv(val, key));
} else {
flat[key] = val;
}
}
return flat;
}
/**
* Get allowed filter fields for CSV export (reuse OData logic).
*/
function getModelFilterFields(objectType) {
const base = ['_id'];
const byType = {
note: ['parent._id', 'noteType', 'user'],
notification: ['user'],
userNotifier: ['user', 'object', 'objectType'],
printer: ['host'],
job: ['printer', 'gcodeFile'],
subJob: ['job'],
filamentStock: ['filament'],
partStock: ['part'],
productStock: ['product'],
productSku: ['product'],
purchaseOrder: ['vendor'],
orderItem: ['order._id', 'orderType', 'item._id', 'itemType', 'shipment._id'],
shipment: ['order._id', 'orderType', 'courierService._id'],
stockEvent: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
stockAudit: ['filamentStock._id', 'partStock._id'],
documentJob: ['documentTemplate', 'documentPrinter', 'object._id', 'objectType'],
documentTemplate: ['parent._id', 'documentSize._id'],
salesOrder: ['client'],
invoice: ['to._id', 'from._id', 'order._id', 'orderType'],
auditLog: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
appPassword: ['name', 'user', 'active'],
};
const extra = byType[objectType] || [];
return [...base, ...extra];
}
function parseOrderBy(orderby) {
if (!orderby || typeof orderby !== 'string') {
return { sort: 'createdAt', order: 'ascend' };
}
const trimmed = orderby.trim();
const parts = trimmed.split(/\s+/);
const sort = parts[0] || 'createdAt';
const dir = (parts[1] || 'asc').toLowerCase();
const order = dir === 'desc' ? 'descend' : 'ascend';
return { sort, order };
}
/**
* Generate CSV file for the given object type.
* @param {Object} options

87
src/services/misc/excel.js
View File

@ -10,11 +10,96 @@ import {
incrementExcelTempRequestCount,
deleteExcelTempToken,
} from '../../database/excel.js';
import { getModelFilterFields, parseOrderBy, rowToFlat } from './export.js';
const logger = log4js.getLogger('Excel');
logger.level = config.server.logLevel;
/**
* Flatten nested objects for Excel display.
* Objects become "key.subkey: value" or JSON string; arrays become comma-separated.
*/
function flattenForExcel(obj, prefix = '') {
if (obj === null || obj === undefined) return {};
if (typeof obj !== 'object') return { [prefix]: obj };
if (obj instanceof Date) return { [prefix]: obj };
if (Array.isArray(obj)) {
const str = obj
.map((v) => (v && typeof v === 'object' && !(v instanceof Date) ? JSON.stringify(v) : v))
.join(', ');
return { [prefix]: str };
}
const result = {};
for (const [k, v] of Object.entries(obj)) {
const key = prefix ? `${prefix}.${k}` : k;
if (v !== null && typeof v === 'object' && !(v instanceof Date) && !Array.isArray(v)) {
Object.assign(result, flattenForExcel(v, key));
} else {
result[key] = v;
}
}
return result;
}
/**
* Convert a row to flat key-value for Excel. Nested objects are flattened.
*/
function rowToFlat(row) {
const flat = {};
for (const [key, val] of Object.entries(row)) {
if (key.startsWith('@')) continue;
if (val !== null && typeof val === 'object' && !(val instanceof Date) && !Array.isArray(val)) {
Object.assign(flat, flattenForExcel(val, key));
} else {
flat[key] = val;
}
}
return flat;
}
/**
* Get allowed filter fields for Excel export (reuse OData logic).
*/
function getModelFilterFields(objectType) {
const base = ['_id'];
const byType = {
note: ['parent._id', 'noteType', 'user'],
notification: ['user'],
userNotifier: ['user', 'object', 'objectType'],
printer: ['host'],
job: ['printer', 'gcodeFile'],
subJob: ['job'],
filamentStock: ['filament'],
partStock: ['part'],
productStock: ['product'],
productSku: ['product'],
purchaseOrder: ['vendor'],
orderItem: ['order._id', 'orderType', 'item._id', 'itemType', 'shipment._id'],
shipment: ['order._id', 'orderType', 'courierService._id'],
stockEvent: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
stockAudit: ['filamentStock._id', 'partStock._id'],
documentJob: ['documentTemplate', 'documentPrinter', 'object._id', 'objectType'],
documentTemplate: ['parent._id', 'documentSize._id'],
salesOrder: ['client'],
invoice: ['to._id', 'from._id', 'order._id', 'orderType'],
auditLog: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
appPassword: ['name', 'user', 'active'],
};
const extra = byType[objectType] || [];
return [...base, ...extra];
}
function parseOrderBy(orderby) {
if (!orderby || typeof orderby !== 'string') {
return { sort: 'createdAt', order: 'ascend' };
}
const trimmed = orderby.trim();
const parts = trimmed.split(/\s+/);
const sort = parts[0] || 'createdAt';
const dir = (parts[1] || 'asc').toLowerCase();
const order = dir === 'desc' ? 'descend' : 'ascend';
return { sort, order };
}
/**
* Generate Excel file for the given object type.
* @param {Object} options

110
src/services/misc/export.js
View File

@ -1,110 +0,0 @@
/**
* Shared export utilities for OData, CSV, and Excel.
* Centralizes filter fields, order-by parsing, and row flattening.
*/
/** Allowed filter fields per object type for OData/CSV/Excel exports */
export const EXPORT_FILTER_BY_TYPE = {
note: ['parent._id', 'noteType', 'user'],
notification: ['user'],
userNotifier: ['user', 'object', 'objectType'],
printer: ['host'],
job: ['printer', 'gcodeFile'],
subJob: ['job'],
filamentStock: ['filamentSku'],
filament: ['material', 'material._id', 'name', 'diameter', 'cost'],
filamentSku: ['filament', 'vendor', 'costTaxRate'],
material: ['name', 'tags'],
partStock: ['partSku'],
partSku: ['part', 'vendor', 'priceTaxRate', 'costTaxRate'],
productStock: ['productSku'],
productSku: ['product', 'vendor', 'priceTaxRate', 'costTaxRate'],
purchaseOrder: ['vendor'],
orderItem: ['order._id', 'orderType', 'item._id', 'itemType', 'sku._id', 'shipment._id'],
shipment: ['order._id', 'orderType', 'courierService._id'],
stockEvent: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
stockAudit: ['filamentStock._id', 'partStock._id'],
documentJob: ['documentTemplate', 'documentPrinter', 'object._id', 'objectType'],
documentTemplate: ['parent._id', 'documentSize._id'],
salesOrder: ['client'],
invoice: ['to._id', 'from._id', 'order._id', 'orderType'],
auditLog: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
appPassword: ['name', 'user', 'active'],
};
/**
* Get allowed filter fields for a given object type.
* @param {string} objectType - Model type (e.g. 'filament', 'material')
* @returns {string[]} Allowed filter field names
*/
export function getModelFilterFields(objectType) {
const base = ['_id'];
const extra = EXPORT_FILTER_BY_TYPE[objectType] || [];
return [...base, ...extra];
}
/**
* Parse OData $orderby or orderby string into sort and order.
* Supports "field asc", "field desc", or just "field" (defaults asc).
* @param {string} [orderby] - Orderby string (e.g. "createdAt desc")
* @returns {{ sort: string, order: 'ascend'|'descend' }}
*/
export function parseOrderBy(orderby) {
if (!orderby || typeof orderby !== 'string') {
return { sort: 'createdAt', order: 'ascend' };
}
const trimmed = orderby.trim();
const parts = trimmed.split(/\s+/);
const sort = parts[0] || 'createdAt';
const dir = (parts[1] || 'asc').toLowerCase();
const order = dir === 'desc' ? 'descend' : 'ascend';
return { sort, order };
}
/**
* Flatten nested objects for export display.
* Objects become "key.subkey: value"; arrays become comma-separated strings.
* @param {*} obj - Value to flatten
* @param {string} [prefix=''] - Key prefix for nested values
* @returns {Object} Flat key-value object
*/
export function flattenForExport(obj, prefix = '') {
if (obj === null || obj === undefined) return {};
if (typeof obj !== 'object') return { [prefix]: obj };
if (obj instanceof Date) return { [prefix]: obj };
if (Array.isArray(obj)) {
const str = obj
.map((v) => (v && typeof v === 'object' && !(v instanceof Date) ? JSON.stringify(v) : v))
.join(', ');
return { [prefix]: str };
}
const result = {};
for (const [k, v] of Object.entries(obj)) {
const key = prefix ? `${prefix}.${k}` : k;
if (v !== null && typeof v === 'object' && !(v instanceof Date) && !Array.isArray(v)) {
Object.assign(result, flattenForExport(v, key));
} else {
result[key] = v;
}
}
return result;
}
/**
* Convert a row (e.g. OData value item) to flat key-value for CSV/Excel.
* Nested objects are flattened; @odata.* keys are skipped.
* @param {Object} row - Row object
* @returns {Object} Flat key-value object
*/
export function rowToFlat(row) {
const flat = {};
for (const [key, val] of Object.entries(row)) {
if (key.startsWith('@')) continue;
if (val !== null && typeof val === 'object' && !(val instanceof Date) && !Array.isArray(val)) {
Object.assign(flat, flattenForExport(val, key));
} else {
flat[key] = val;
}
}
return flat;
}

49
src/services/misc/odata.js
View File

@ -4,7 +4,6 @@ import mongoose from 'mongoose';
import { getModelByName, getAllModels } from './model.js';
import { listObjectsOData } from '../../database/odata.js';
import { getFilter } from '../../utils.js';
import { getModelFilterFields, parseOrderBy } from './export.js';
const logger = log4js.getLogger('OData');
logger.level = config.server.logLevel;
@ -254,6 +253,22 @@ export const metadataODataRouteHandler = (req, res) => {
res.send(xml);
};
/**
* Parse OData $orderby into sort and order.
* Supports "field asc", "field desc", or just "field" (defaults asc).
*/
function parseOrderBy(orderby) {
if (!orderby || typeof orderby !== 'string') {
return { sort: 'createdAt', order: 'ascend' };
}
const trimmed = orderby.trim();
const parts = trimmed.split(/\s+/);
const sort = parts[0] || 'createdAt';
const dir = (parts[1] || 'asc').toLowerCase();
const order = dir === 'desc' ? 'descend' : 'ascend';
return { sort, order };
}
/**
* Route handler for GET /odata/:objectType
* Supports OData query options: $top, $skip, $orderby, $count, $select
@ -314,3 +329,35 @@ export const listODataRouteHandler = async (req, res) => {
res.send(result);
};
/**
* Return allowed filter fields for a given object type.
* Extends a base set with type-specific fields.
*/
function getModelFilterFields(objectType) {
const base = ['_id'];
const byType = {
note: ['parent._id', 'noteType', 'user'],
notification: ['user'],
userNotifier: ['user', 'object', 'objectType'],
printer: ['host'],
job: ['printer', 'gcodeFile'],
subJob: ['job'],
filamentStock: ['filament'],
partStock: ['part'],
productStock: ['product'],
productSku: ['product'],
purchaseOrder: ['vendor'],
orderItem: ['order._id', 'orderType', 'item._id', 'itemType', 'shipment._id'],
shipment: ['order._id', 'orderType', 'courierService._id'],
stockEvent: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
stockAudit: ['filamentStock._id', 'partStock._id'],
documentJob: ['documentTemplate', 'documentPrinter', 'object._id', 'objectType'],
documentTemplate: ['parent._id', 'documentSize._id'],
salesOrder: ['client'],
invoice: ['to._id', 'from._id', 'order._id', 'orderType'],
auditLog: ['parent._id', 'parentType', 'owner._id', 'ownerType'],
appPassword: ['name', 'user', 'active'],
};
const extra = byType[objectType] || [];
return [...base, ...extra];
}

10
src/services/production/gcodefiles.js
View File

@ -35,7 +35,7 @@ export const listGCodeFilesRouteHandler = async (
search,
sort,
order,
populate: ['filamentSku'],
populate: ['filament'],
});
if (result?.error) {
@ -58,7 +58,7 @@ export const listGCodeFilesByPropertiesRouteHandler = async (
model: gcodeFileModel,
properties,
filter,
populate: 'filamentSku',
populate: 'filament',
});
if (result?.error) {
@ -76,7 +76,7 @@ export const getGCodeFileRouteHandler = async (req, res) => {
const result = await getObject({
model: gcodeFileModel,
id,
populate: ['filamentSku', 'parts.partSku'],
populate: ['filament', 'parts.part'],
});
if (result?.error) {
logger.warn(`GCodeFile not found with supplied id.`);
@ -113,7 +113,7 @@ export const editGCodeFileRouteHandler = async (req, res) => {
updatedAt: new Date(),
name: req.body.name,
file: req.body.file,
filamentSku: req.body.filamentSku,
filament: req.body.filament,
parts: req.body.parts,
};
// Create audit log before updating
@ -140,7 +140,7 @@ export const newGCodeFileRouteHandler = async (req, res) => {
updatedAt: new Date(),
name: req.body.name,
file: req.body.file,
filamentSku: req.body.filamentSku,
filament: req.body.filament,
parts: req.body.parts,
};
const result = await newObject({

9
src/utils.js
View File

@ -858,10 +858,7 @@ function buildDeepPopulateSpec(object, model, populated = new Set()) {
const ref = directRef || arrayRef;
if (!ref) return;
const refName = typeof ref === 'function' ? ref.call(object) : ref;
if (!refName) return;
const refModel = model.db.model(refName);
const refModel = model.db.model(ref);
const childPopulate = buildDeepPopulateSpec(object, refModel, populated);
const id = object[pathname]?._id || object[pathname];
@ -869,9 +866,9 @@ function buildDeepPopulateSpec(object, model, populated = new Set()) {
if (id == null || !id) return;
if (childPopulate.length > 0) {
populateSpec.push({ path: pathname, populate: childPopulate, ref: refName, _id: id });
populateSpec.push({ path: pathname, populate: childPopulate, ref: ref, _id: id });
} else {
populateSpec.push({ path: pathname, ref: refName, _id: id });
populateSpec.push({ path: pathname, ref: ref, _id: id });
}
});