u
This commit is contained in:
@@ -1106,6 +1106,45 @@
|
||||
* type: string
|
||||
* sort:
|
||||
* type: integer
|
||||
* CategoryProperty:
|
||||
* type: object
|
||||
* required: [id, propertyId, name, exclusive, value, sort]
|
||||
* properties:
|
||||
* id:
|
||||
* type: integer
|
||||
* categoryId:
|
||||
* type: integer
|
||||
* propertyId:
|
||||
* type: integer
|
||||
* name:
|
||||
* type: string
|
||||
* exclusive:
|
||||
* type: boolean
|
||||
* value:
|
||||
* type: string
|
||||
* sort:
|
||||
* type: integer
|
||||
* CategoryAttributeValue:
|
||||
* type: object
|
||||
* required: [id, attributeId, attributeName, attributeValueId, value, sort]
|
||||
* properties:
|
||||
* id:
|
||||
* type: integer
|
||||
* categoryId:
|
||||
* type: integer
|
||||
* attributeId:
|
||||
* type: integer
|
||||
* attributeName:
|
||||
* type: string
|
||||
* exclusive:
|
||||
* type: boolean
|
||||
* attributeValueId:
|
||||
* type: integer
|
||||
* value:
|
||||
* type: string
|
||||
* sort:
|
||||
* type: integer
|
||||
*/
|
||||
|
||||
export {};
|
||||
|
||||
|
||||
164
src/api/routes/categoryattributevalue.js
Normal file
164
src/api/routes/categoryattributevalue.js
Normal file
@@ -0,0 +1,164 @@
|
||||
import * as db from '../../db/categoryattributevalue.js';
|
||||
import { emit } from '../sse.js';
|
||||
|
||||
function requireSelectedCompany(req) {
|
||||
const companyId = req.user?.selectedCompanyId;
|
||||
if (companyId == null) {
|
||||
return { error: 'No company selected' };
|
||||
}
|
||||
return { companyId };
|
||||
}
|
||||
|
||||
function parsePositiveInt(value, field) {
|
||||
const id = Number(value);
|
||||
if (!Number.isInteger(id) || id <= 0) {
|
||||
return { error: `${field} is required` };
|
||||
}
|
||||
return { id };
|
||||
}
|
||||
|
||||
function emitCategorySignal(req) {
|
||||
const companyId = req.user?.selectedCompanyId;
|
||||
if (companyId == null) return;
|
||||
emit('category', { companyId });
|
||||
}
|
||||
|
||||
function categoryAttributeValueErrorStatus(error) {
|
||||
if (error.message === 'No company selected') return 400;
|
||||
if (error.message === 'Not authorized') return 403;
|
||||
if (error.message === 'Company not found' || error.message === 'Category not found' || error.message === 'Parent not found') return 404;
|
||||
if (error.message?.startsWith('Attribute value not found')) return 404;
|
||||
if (error.message?.includes('exclusive')) return 400;
|
||||
if (error.message === 'Invalid attribute values array' || error.message === 'Invalid attributeValueId' || error.message === 'Duplicate attributeValueId') return 400;
|
||||
return 500;
|
||||
}
|
||||
|
||||
/**
|
||||
* Registers categoryattributevalue routes under `/category/:id/attributevalue`.
|
||||
* @param {import('express').Application} app
|
||||
* @param {string} [basePath='']
|
||||
*/
|
||||
export function register(app, basePath = '') {
|
||||
/**
|
||||
* @openapi
|
||||
* /category/{id}/attributevalue:
|
||||
* get:
|
||||
* tags: [Category]
|
||||
* summary: List category attribute values
|
||||
* description: Fetches all attribute values assigned to a category.
|
||||
* security:
|
||||
* - cookieAuth: []
|
||||
* parameters:
|
||||
* - in: path
|
||||
* name: id
|
||||
* required: true
|
||||
* schema:
|
||||
* type: integer
|
||||
* description: Category ID
|
||||
* responses:
|
||||
* 200:
|
||||
* description: List of attribute values assigned to this category
|
||||
* content:
|
||||
* application/json:
|
||||
* schema:
|
||||
* type: object
|
||||
* properties:
|
||||
* attributevalues:
|
||||
* type: array
|
||||
* items:
|
||||
* $ref: '#/components/schemas/CategoryAttributeValue'
|
||||
* put:
|
||||
* tags: [Category]
|
||||
* summary: Bulk set category attribute values
|
||||
* description: Replaces all attribute values for a category. Enforces exclusive constraint (max one value per exclusive attribute).
|
||||
* security:
|
||||
* - cookieAuth: []
|
||||
* parameters:
|
||||
* - in: path
|
||||
* name: id
|
||||
* required: true
|
||||
* schema:
|
||||
* type: integer
|
||||
* description: Category ID
|
||||
* requestBody:
|
||||
* required: true
|
||||
* content:
|
||||
* application/json:
|
||||
* schema:
|
||||
* type: object
|
||||
* required: [attributevalues]
|
||||
* properties:
|
||||
* attributevalues:
|
||||
* type: array
|
||||
* description: Array of attribute value IDs (numbers) or objects with id or attributeValueId
|
||||
* items:
|
||||
* oneOf:
|
||||
* - type: integer
|
||||
* description: Attribute value ID
|
||||
* - type: object
|
||||
* properties:
|
||||
* id:
|
||||
* type: integer
|
||||
* description: Attribute value ID
|
||||
* attributeValueId:
|
||||
* type: integer
|
||||
* description: Attribute value ID
|
||||
* sort:
|
||||
* type: integer
|
||||
* responses:
|
||||
* 200:
|
||||
* description: Updated category attribute values
|
||||
* content:
|
||||
* application/json:
|
||||
* schema:
|
||||
* type: object
|
||||
* properties:
|
||||
* attributevalues:
|
||||
* type: array
|
||||
* items:
|
||||
* $ref: '#/components/schemas/CategoryAttributeValue'
|
||||
*/
|
||||
app.get(`${basePath}/category/:id/attributevalue`, async (req, res) => {
|
||||
const selected = requireSelectedCompany(req);
|
||||
if (selected.error) {
|
||||
return res.status(400).json({ error: selected.error });
|
||||
}
|
||||
|
||||
const idParsed = parsePositiveInt(req.params.id, 'categoryId');
|
||||
if (idParsed.error) {
|
||||
return res.status(400).json({ error: idParsed.error });
|
||||
}
|
||||
|
||||
try {
|
||||
const attributevalues = await db.listByCategoryId(req.user.id, idParsed.id);
|
||||
res.json({ attributevalues });
|
||||
} catch (error) {
|
||||
res.status(categoryAttributeValueErrorStatus(error)).json({ error: error.message });
|
||||
}
|
||||
});
|
||||
|
||||
app.put(`${basePath}/category/:id/attributevalue`, async (req, res) => {
|
||||
const selected = requireSelectedCompany(req);
|
||||
if (selected.error) {
|
||||
return res.status(400).json({ error: selected.error });
|
||||
}
|
||||
|
||||
const idParsed = parsePositiveInt(req.params.id, 'categoryId');
|
||||
if (idParsed.error) {
|
||||
return res.status(400).json({ error: idParsed.error });
|
||||
}
|
||||
|
||||
const valuesInput = req.body?.attributevalues ?? req.body?.attributeValues ?? req.body?.attribute_values ?? req.body?.values ?? req.body;
|
||||
if (!Array.isArray(valuesInput)) {
|
||||
return res.status(400).json({ error: 'attributevalues array required' });
|
||||
}
|
||||
|
||||
try {
|
||||
const attributevalues = await db.setByCategoryId(req.user.id, idParsed.id, valuesInput);
|
||||
emitCategorySignal(req);
|
||||
res.json({ attributevalues });
|
||||
} catch (error) {
|
||||
res.status(categoryAttributeValueErrorStatus(error)).json({ error: error.message });
|
||||
}
|
||||
});
|
||||
}
|
||||
204
src/api/routes/categoryproperty.js
Normal file
204
src/api/routes/categoryproperty.js
Normal file
@@ -0,0 +1,204 @@
|
||||
import * as db from '../../db/categoryproperty.js';
|
||||
import { emit } from '../sse.js';
|
||||
|
||||
function requireSelectedCompany(req) {
|
||||
const companyId = req.user?.selectedCompanyId;
|
||||
if (companyId == null) {
|
||||
return { error: 'No company selected' };
|
||||
}
|
||||
return { companyId };
|
||||
}
|
||||
|
||||
function parsePositiveInt(value, field) {
|
||||
const id = Number(value);
|
||||
if (!Number.isInteger(id) || id <= 0) {
|
||||
return { error: `${field} is required` };
|
||||
}
|
||||
return { id };
|
||||
}
|
||||
|
||||
function emitCategorySignal(req) {
|
||||
const companyId = req.user?.selectedCompanyId;
|
||||
if (companyId == null) return;
|
||||
emit('category', { companyId });
|
||||
}
|
||||
|
||||
function categoryPropertyErrorStatus(error) {
|
||||
if (error.message === 'No company selected') return 400;
|
||||
if (error.message === 'Not authorized') return 403;
|
||||
if (error.message === 'Company not found' || error.message === 'Category not found' || error.message === 'Parent not found') return 404;
|
||||
if (error.message?.startsWith('Property not found')) return 404;
|
||||
if (error.message?.includes('exclusive')) return 400;
|
||||
if (error.message === 'Invalid properties array' || error.message === 'Invalid propertyId' || error.message === 'Duplicate propertyId') return 400;
|
||||
return 500;
|
||||
}
|
||||
|
||||
/**
|
||||
* Registers categoryproperty routes under `/category/:id/property`.
|
||||
* @param {import('express').Application} app
|
||||
* @param {string} [basePath='']
|
||||
*/
|
||||
export function register(app, basePath = '') {
|
||||
/**
|
||||
* @openapi
|
||||
* /category/{id}/property:
|
||||
* get:
|
||||
* tags: [Category]
|
||||
* summary: List category properties
|
||||
* description: Fetches all free-form properties set on a category.
|
||||
* security:
|
||||
* - cookieAuth: []
|
||||
* parameters:
|
||||
* - in: path
|
||||
* name: id
|
||||
* required: true
|
||||
* schema:
|
||||
* type: integer
|
||||
* description: Category ID
|
||||
* responses:
|
||||
* 200:
|
||||
* description: List of properties for this category
|
||||
* content:
|
||||
* application/json:
|
||||
* schema:
|
||||
* type: object
|
||||
* properties:
|
||||
* properties:
|
||||
* type: array
|
||||
* items:
|
||||
* $ref: '#/components/schemas/CategoryProperty'
|
||||
* put:
|
||||
* tags: [Category]
|
||||
* summary: Bulk set category properties
|
||||
* description: Replaces all properties for a category.
|
||||
* security:
|
||||
* - cookieAuth: []
|
||||
* parameters:
|
||||
* - in: path
|
||||
* name: id
|
||||
* required: true
|
||||
* schema:
|
||||
* type: integer
|
||||
* description: Category ID
|
||||
* requestBody:
|
||||
* required: true
|
||||
* content:
|
||||
* application/json:
|
||||
* schema:
|
||||
* type: object
|
||||
* required: [properties]
|
||||
* properties:
|
||||
* properties:
|
||||
* type: array
|
||||
* items:
|
||||
* type: object
|
||||
* required: [propertyId, value]
|
||||
* properties:
|
||||
* propertyId:
|
||||
* type: integer
|
||||
* value:
|
||||
* type: string
|
||||
* sort:
|
||||
* type: integer
|
||||
* responses:
|
||||
* 200:
|
||||
* description: Updated category properties
|
||||
* content:
|
||||
* application/json:
|
||||
* schema:
|
||||
* type: object
|
||||
* properties:
|
||||
* properties:
|
||||
* type: array
|
||||
* items:
|
||||
* $ref: '#/components/schemas/CategoryProperty'
|
||||
*/
|
||||
app.get(`${basePath}/category/:id/property`, async (req, res) => {
|
||||
const selected = requireSelectedCompany(req);
|
||||
if (selected.error) {
|
||||
return res.status(400).json({ error: selected.error });
|
||||
}
|
||||
|
||||
const idParsed = parsePositiveInt(req.params.id, 'categoryId');
|
||||
if (idParsed.error) {
|
||||
return res.status(400).json({ error: idParsed.error });
|
||||
}
|
||||
|
||||
try {
|
||||
const properties = await db.listByCategoryId(req.user.id, idParsed.id);
|
||||
res.json({ properties });
|
||||
} catch (error) {
|
||||
res.status(categoryPropertyErrorStatus(error)).json({ error: error.message });
|
||||
}
|
||||
});
|
||||
|
||||
app.put(`${basePath}/category/:id/property`, async (req, res) => {
|
||||
const selected = requireSelectedCompany(req);
|
||||
if (selected.error) {
|
||||
return res.status(400).json({ error: selected.error });
|
||||
}
|
||||
|
||||
const idParsed = parsePositiveInt(req.params.id, 'categoryId');
|
||||
if (idParsed.error) {
|
||||
return res.status(400).json({ error: idParsed.error });
|
||||
}
|
||||
|
||||
const propertiesInput = req.body?.properties ?? req.body;
|
||||
if (!Array.isArray(propertiesInput)) {
|
||||
return res.status(400).json({ error: 'properties array required' });
|
||||
}
|
||||
|
||||
try {
|
||||
const properties = await db.setByCategoryId(req.user.id, idParsed.id, propertiesInput);
|
||||
emitCategorySignal(req);
|
||||
res.json({ properties });
|
||||
} catch (error) {
|
||||
res.status(categoryPropertyErrorStatus(error)).json({ error: error.message });
|
||||
}
|
||||
});
|
||||
|
||||
/**
|
||||
* @openapi
|
||||
* /category/{id}/property/{propertyId}:
|
||||
* delete:
|
||||
* tags: [Category]
|
||||
* summary: Delete category property
|
||||
* description: Removes a single property from a category.
|
||||
* security:
|
||||
* - cookieAuth: []
|
||||
* parameters:
|
||||
* - in: path
|
||||
* name: id
|
||||
* required: true
|
||||
* schema:
|
||||
* type: integer
|
||||
* - in: path
|
||||
* name: propertyId
|
||||
* required: true
|
||||
* schema:
|
||||
* type: integer
|
||||
* responses:
|
||||
* 200:
|
||||
* description: Deleted successfully
|
||||
*/
|
||||
app.delete(`${basePath}/category/:id/property/:propertyId`, async (req, res) => {
|
||||
const selected = requireSelectedCompany(req);
|
||||
if (selected.error) {
|
||||
return res.status(400).json({ error: selected.error });
|
||||
}
|
||||
|
||||
const idParsed = parsePositiveInt(req.params.id, 'categoryId');
|
||||
if (idParsed.error) {
|
||||
return res.status(400).json({ error: idParsed.error });
|
||||
}
|
||||
|
||||
try {
|
||||
const propertyId = Number(req.params.propertyId);
|
||||
await db.remove(req.user.id, idParsed.id, propertyId);
|
||||
emitCategorySignal(req);
|
||||
res.json({ ok: true });
|
||||
} catch (error) {
|
||||
res.status(categoryPropertyErrorStatus(error)).json({ error: error.message });
|
||||
}
|
||||
});
|
||||
}
|
||||
11
src/db/categoryattributevalue.js
Normal file
11
src/db/categoryattributevalue.js
Normal file
@@ -0,0 +1,11 @@
|
||||
import { getStore } from './store.js';
|
||||
|
||||
export async function listByCategoryId(googleAuthId, categoryId) {
|
||||
const store = await getStore();
|
||||
return store.categoryattributevalue.listByCategoryId(googleAuthId, categoryId);
|
||||
}
|
||||
|
||||
export async function setByCategoryId(googleAuthId, categoryId, values) {
|
||||
const store = await getStore();
|
||||
return store.categoryattributevalue.setByCategoryId(googleAuthId, categoryId, values);
|
||||
}
|
||||
16
src/db/categoryproperty.js
Normal file
16
src/db/categoryproperty.js
Normal file
@@ -0,0 +1,16 @@
|
||||
import { getStore } from './store.js';
|
||||
|
||||
export async function listByCategoryId(googleAuthId, categoryId) {
|
||||
const store = await getStore();
|
||||
return store.categoryproperty.listByCategoryId(googleAuthId, categoryId);
|
||||
}
|
||||
|
||||
export async function setByCategoryId(googleAuthId, categoryId, properties) {
|
||||
const store = await getStore();
|
||||
return store.categoryproperty.setByCategoryId(googleAuthId, categoryId, properties);
|
||||
}
|
||||
|
||||
export async function remove(googleAuthId, categoryId, propertyId) {
|
||||
const store = await getStore();
|
||||
return store.categoryproperty.delete(googleAuthId, categoryId, propertyId);
|
||||
}
|
||||
@@ -95,3 +95,9 @@ export async function getProductList(params) {
|
||||
return store.posterminal.getProductList(params);
|
||||
}
|
||||
|
||||
export async function setMaxKnownTombstoneId(id, maxknowntombstoneid) {
|
||||
const store = await getStore();
|
||||
return store.posterminal.setMaxKnownTombstoneId(id, maxknowntombstoneid);
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -39,9 +39,11 @@ const STORE_NAMESPACES = [
|
||||
'stock',
|
||||
'propertyname',
|
||||
'articleproperty',
|
||||
'categoryproperty',
|
||||
'attributename',
|
||||
'attributevalue',
|
||||
'articleattributevalue',
|
||||
'categoryattributevalue',
|
||||
];
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user