52 lines
1.7 KiB
TypeScript
52 lines
1.7 KiB
TypeScript
|
import type { UniqueID } from "@repo/rdx-ddd";
|
||
|
|
import type { Transaction } from "sequelize";
|
||
|
|
|
||
|
|
import type { Asset } from "../../domain/asset.aggregate";
|
||
|
|
|
||
|
|
import {
|
||
|
|
WorkstationAssetModel,
|
||
|
|
WorkstationModel,
|
||
|
|
WorkstationRevisionModel,
|
||
|
|
} from "./workstation.model";
|
||
|
|
import { WorkstationPersistenceMapper } from "./workstation-persistence.mapper";
|
||
|
|
export async function loadWorkstations(
|
||
|
|
companyId: UniqueID,
|
||
|
|
transaction: Transaction,
|
||
|
|
assets: readonly Asset[],
|
||
|
|
sites: readonly { id: string }[],
|
||
|
|
people: readonly { id: string }[]
|
||
|
|
) {
|
||
|
|
const rows = await WorkstationModel.findAll({
|
||
|
|
where: { companyId: companyId.toPrimitive() },
|
||
|
|
transaction,
|
||
|
|
});
|
||
|
|
const revisions = rows.length
|
||
|
|
? await WorkstationRevisionModel.findAll({
|
||
|
|
where: { workstationId: rows.map((item) => item.id) },
|
||
|
|
transaction,
|
||
|
|
})
|
||
|
|
: [];
|
||
|
|
const references = await WorkstationAssetModel.findAll({
|
||
|
|
where: { companyId: companyId.toPrimitive() },
|
||
|
|
transaction,
|
||
|
|
});
|
||
|
|
return rows.map((row) => {
|
||
|
|
const item = new WorkstationPersistenceMapper().toDomain(
|
||
|
|
row,
|
||
|
|
revisions.filter((revision) => revision.workstationId === row.id),
|
||
|
|
references.filter((reference) => reference.workstationId === row.id)
|
||
|
|
);
|
||
|
|
for (const revision of item.history) {
|
||
|
|
const values = revision.values.toPrimitive();
|
||
|
|
if (
|
||
|
|
(values.siteId && !sites.some((site) => site.id === values.siteId)) ||
|
||
|
|
(values.personId && !people.some((person) => person.id === values.personId)) ||
|
||
|
|
values.assetIds.some((id) => !assets.some((asset) => asset.id.toPrimitive() === id))
|
||
|
|
) {
|
||
|
|
throw new Error("Puesto de trabajo fuera de su compañía.");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return item;
|
||
|
|
});
|
||
|
|
}
|