Compare commits

...

6 commits

30 changed files with 939 additions and 58 deletions

View file

@ -1,4 +1,5 @@
export interface CreateDamageReportCommand {
title: string;
description: string;
location: string;
noteByReporter: string;
@ -15,9 +16,9 @@ export interface UpdateDamageReportCommand {
done: boolean;
}
export interface UpdateDamageReportRelatedMaintenanceCommand {
export interface UpdateDamageReportRelatedRepairCommand {
id: string;
maintenanceId: string;
repairId: string;
}
export interface DeleteDamageReportCommand {

View file

@ -1,3 +1,4 @@
import { EntityManager, In, UpdateResult } from "typeorm";
import { dataSource } from "../../data-source";
import { damageReport } from "../../entity/unit/damageReport";
import DatabaseActionException from "../../exceptions/databaseActionException";
@ -5,8 +6,9 @@ import {
CreateDamageReportCommand,
UpdateDamageReportCommand,
DeleteDamageReportCommand,
UpdateDamageReportRelatedMaintenanceCommand,
UpdateDamageReportRelatedRepairCommand,
} from "./damageReportCommand";
import DamageReportService from "../../service/unit/damageReportService";
export default abstract class DamageReportCommandHandler {
/**
@ -21,6 +23,7 @@ export default abstract class DamageReportCommandHandler {
.into(damageReport)
.values({
status: "eingereicht",
title: createDamageReport.title,
description: createDamageReport.description,
location: createDamageReport.location,
noteByReporter: createDamageReport.noteByReporter,
@ -66,14 +69,12 @@ export default abstract class DamageReportCommandHandler {
* @param {UpdateDamageReportCommand} updateDamageReport
* @returns {Promise<void>}
*/
static async updateRelatedMaintenance(
updateDamageReport: UpdateDamageReportRelatedMaintenanceCommand
): Promise<void> {
static async updateRelatedMaintenance(updateDamageReport: UpdateDamageReportRelatedRepairCommand): Promise<void> {
return await dataSource
.createQueryBuilder()
.update(damageReport)
.set({
maintenanceId: updateDamageReport.maintenanceId,
repairId: updateDamageReport.repairId,
})
.where("id = :id", { id: updateDamageReport.id })
.execute()
@ -83,6 +84,60 @@ export default abstract class DamageReportCommandHandler {
});
}
/**
* @description update damageReport related maintenance
* @returns {Promise<void>}
*/
static async updateRelatedMaintenanceMulti(repairId: string, reports: Array<string>): Promise<void> {
let [related] = await DamageReportService.getAllForRepair(repairId, { noLimit: true });
return await dataSource
.transaction(async (manager) => {
let added = reports.filter((id) => !related.some((r) => r.id === id));
let removed = related.map((r) => r.id).filter((id) => !reports.includes(id));
await manager
.createQueryBuilder()
.update(damageReport)
.set({
repairId: repairId,
})
.where({ id: In(added) })
.execute();
await manager
.createQueryBuilder()
.update(damageReport)
.set({
repairId: null,
})
.where({ id: In(removed) })
.execute();
})
.then(() => {})
.catch((err) => {
throw new DatabaseActionException("UPDATE", "damageReport->maintenance", err);
});
}
/**
* @description update damageReport related maintenance in transaction
* @param {UpdateDamageReportCommand} updateDamageReport
* @returns {Promise<void>}
*/
static async updateRelatedMaintenanceTransaction(
manager: EntityManager,
updateDamageReport: UpdateDamageReportRelatedRepairCommand
): Promise<UpdateResult> {
return await manager
.createQueryBuilder()
.update(damageReport)
.set({
repairId: updateDamageReport.repairId,
})
.where("id = :id", { id: updateDamageReport.id })
.execute();
}
/**
* @description delete damageReport
* @param {DeleteDamageReportCommand} deleteDamageReport

View file

@ -0,0 +1,25 @@
export interface CreateRepairCommand {
title: string;
description: string;
responsible: string;
affectedId: string;
affected: "equipment" | "vehicle" | "wearable";
reports: string[];
}
export interface UpdateRepairCommand {
id: string;
title: string;
description: string;
responsible: string;
}
export interface UpdateRepairStatusCommand {
id: string;
status: string;
done: boolean;
}
export interface DeleteRepairCommand {
id: string;
}

View file

@ -0,0 +1,115 @@
import { dataSource } from "../../data-source";
import { repair } from "../../entity/unit/repair";
import DatabaseActionException from "../../exceptions/databaseActionException";
import DamageReportCommandHandler from "./damageReportCommandHandler";
import {
CreateRepairCommand,
UpdateRepairCommand,
DeleteRepairCommand,
UpdateRepairStatusCommand,
} from "./repairCommand";
export default abstract class RepairCommandHandler {
/**
* @description create repair
* @param {CreateRepairCommand} createRepair
* @returns {Promise<string>}
*/
static async create(createRepair: CreateRepairCommand): Promise<string> {
let resultId = "";
return await dataSource
.transaction(async (manager) => {
await manager
.createQueryBuilder()
.insert()
.into(repair)
.values({
status: "in Arbeit",
title: createRepair.title,
description: createRepair.description,
responsible: createRepair.responsible,
equipmentId: createRepair.affected == "equipment" ? createRepair.affectedId : null,
vehicleId: createRepair.affected == "vehicle" ? createRepair.affectedId : null,
wearableId: createRepair.affected == "wearable" ? createRepair.affectedId : null,
})
.execute()
.then((result) => {
resultId = result.identifiers[0].id;
});
for (const report of createRepair.reports) {
await DamageReportCommandHandler.updateRelatedMaintenanceTransaction(manager, {
id: report,
repairId: resultId,
});
}
})
.then(() => {
return resultId;
})
.catch((err) => {
throw new DatabaseActionException("CREATE", "repair", err);
});
}
/**
* @description update repair
* @param {UpdateRepairCommand} updateRepair
* @returns {Promise<void>}
*/
static async update(updateRepair: UpdateRepairCommand): Promise<void> {
return await dataSource
.createQueryBuilder()
.update(repair)
.set({
title: updateRepair.title,
description: updateRepair.description,
responsible: updateRepair.responsible,
})
.where("id = :id", { id: updateRepair.id })
.execute()
.then(() => {})
.catch((err) => {
throw new DatabaseActionException("UPDATE", "repair", err);
});
}
/**
* @description update repair
* @param {UpdateRepairStatusCommand} updateRepair
* @returns {Promise<void>}
*/
static async updateStatus(updateRepair: UpdateRepairStatusCommand): Promise<void> {
return await dataSource
.createQueryBuilder()
.update(repair)
.set({
status: updateRepair.status,
finishedAt: updateRepair.done ? new Date() : null,
})
.where("id = :id", { id: updateRepair.id })
.execute()
.then(() => {})
.catch((err) => {
throw new DatabaseActionException("UPDATE", "repair", err);
});
}
/**
* @description delete repair
* @param {DeleteRepairCommand} deleteRepair
* @returns {Promise<void>}
*/
static async delete(deleteRepair: DeleteRepairCommand): Promise<void> {
return await dataSource
.createQueryBuilder()
.delete()
.from(repair)
.where("id = :id", { id: deleteRepair.id })
.execute()
.then(() => {})
.catch((err) => {
throw new DatabaseActionException("DELETE", "repair", err);
});
}
}

View file

@ -18,7 +18,7 @@ export async function getAllDamageReportsByStatus(req: Request, res: Response):
let count = parseInt((req.query.count as string) ?? "25");
let noLimit = req.query.noLimit === "true";
let [damageReports, total] = await DamageReportService.getAll(done, { offset, count, noLimit });
let [damageReports, total] = await DamageReportService.getAllByStatus(done, { offset, count, noLimit });
res.json({
damageReports: DamageReportFactory.mapToBase(damageReports),
@ -72,6 +72,25 @@ export async function getDamageReportById(req: Request, res: Response): Promise<
res.json(DamageReportFactory.mapToSingle(damageReport));
}
/**
* @description get reports by Ids
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function getDamageReportsByIds(req: Request, res: Response): Promise<any> {
let ids = req.body.ids as Array<string>;
let [damageReports, total] = await DamageReportService.getAll({ noLimit: true, ids });
res.json({
damageReports: DamageReportFactory.mapToBase(damageReports),
total: total,
offset: 0,
count: total,
});
}
/**
* @description provide uploaded image for damage report
* @param req {Request} Express req object
@ -94,6 +113,7 @@ export async function provideDamageReportImageUpload(req: Request, res: Response
* @returns {Promise<*>}
*/
export async function createDamageReport(req: Request, res: Response): Promise<any> {
const title = req.body.title;
const description = req.body.description;
const location = req.body.location;
const note = req.body.note;
@ -106,6 +126,7 @@ export async function createDamageReport(req: Request, res: Response): Promise<a
throw new BadRequestException("set assigned to equipment or vehicle or wearable");
let createDamageReport: CreateDamageReportCommand = {
title,
description,
location,
noteByReporter: note,

View file

@ -0,0 +1,168 @@
import { Request, Response } from "express";
import RepairService from "../../../service/unit/repairService";
import RepairFactory from "../../../factory/admin/unit/repair";
import {
CreateRepairCommand,
UpdateRepairCommand,
UpdateRepairStatusCommand,
} from "../../../command/unit/repairCommand";
import RepairCommandHandler from "../../../command/unit/repairCommandHandler";
import BadRequestException from "../../../exceptions/badRequestException";
import { FileSystemHelper } from "../../../helpers/fileSystemHelper";
import { UpdateDamageReportRelatedRepairCommand } from "../../../command/unit/damageReportCommand";
import DamageReportCommandHandler from "../../../command/unit/damageReportCommandHandler";
/**
* @description get all repairs by status
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function getAllRepairsByStatus(req: Request, res: Response): Promise<any> {
let done = req.query.done === "true";
let offset = parseInt((req.query.offset as string) ?? "0");
let count = parseInt((req.query.count as string) ?? "25");
let noLimit = req.query.noLimit === "true";
let [repairs, total] = await RepairService.getAll(done, { offset, count, noLimit });
res.json({
repairs: RepairFactory.mapToBase(repairs),
total: total,
offset: offset,
count: count,
});
}
/**
* @description get all repairs for related id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function getAllRepairsForRelated(req: Request, res: Response): Promise<any> {
let relation = req.params.related as "vehicle" | "equipment" | "wearable";
let relationId = req.params.relatedId as string;
let offset = parseInt((req.query.offset as string) ?? "0");
let count = parseInt((req.query.count as string) ?? "25");
let noLimit = req.query.noLimit === "true";
let where;
if (relation == "equipment") {
where = { equipmentId: relationId };
} else if (relation == "vehicle") {
where = { vehicleId: relationId };
} else {
where = { wearableId: relationId };
}
let [repairs, total] = await RepairService.getAllForRelated(where, { offset, count, noLimit });
res.json({
repairs: RepairFactory.mapToBase(repairs),
total: total,
offset: offset,
count: count,
});
}
/**
* @description get repair by id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function getRepairById(req: Request, res: Response): Promise<any> {
const repairId = req.params.id;
let repair = await RepairService.getById(repairId);
res.json(RepairFactory.mapToSingle(repair));
}
/**
* @description create repair
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function createRepair(req: Request, res: Response): Promise<any> {
const title = req.body.title;
const description = req.body.description;
const responsible = req.body.responsible;
const reports = req.body.reports;
const affectedId = req.body.affectedId;
const affected = req.body.affected;
if (affected != "equipment" && affected != "vehicle" && affected != "wearable")
throw new BadRequestException("set assigned to equipment or vehicle or wearable");
let createRepair: CreateRepairCommand = {
title,
description,
affectedId,
affected,
responsible,
reports,
};
let repairId = await RepairCommandHandler.create(createRepair);
res.status(200).send(repairId);
}
/**
* @description update repair by id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function updateRepairById(req: Request, res: Response): Promise<any> {
const repairId = req.params.id;
const title = req.body.title;
const description = req.body.description;
const responsible = req.body.responsible;
let updateRepair: UpdateRepairCommand = {
id: repairId,
title,
description,
responsible,
};
await RepairCommandHandler.update(updateRepair);
res.sendStatus(204);
}
/**
* @description update repair by id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function updateRepairReportsById(req: Request, res: Response): Promise<any> {
const repairId = req.params.id;
const reports = req.body.reports as Array<string>;
await DamageReportCommandHandler.updateRelatedMaintenanceMulti(repairId, reports);
res.sendStatus(204);
}
/**
* @description update repair by id
* @param req {Request} Express req object
* @param res {Response} Express res object
* @returns {Promise<*>}
*/
export async function updateRepairStatusById(req: Request, res: Response): Promise<any> {
const repairId = req.params.id;
const status = req.body.status;
const done = req.body.done;
let updateRepair: UpdateRepairStatusCommand = {
id: repairId,
status,
done,
};
await RepairCommandHandler.updateStatus(updateRepair);
res.sendStatus(204);
}

View file

@ -120,6 +120,7 @@ export async function createDamageReport(req: Request, res: Response): Promise<a
| MinifiedEquipmentViewModel
| MinifiedVehicleViewModel
| MinifiedWearableViewModel;
const title = req.body.title;
const description = req.body.description;
const location = req.body.location;
const note = req.body.note;
@ -127,6 +128,7 @@ export async function createDamageReport(req: Request, res: Response): Promise<a
const images = req.files as Express.Multer.File[];
let createDamageReport: CreateDamageReportCommand = {
title: title,
description: description,
location: location,
noteByReporter: note,

View file

@ -65,7 +65,8 @@ import { maintenance } from "./entity/unit/maintenance";
import { BackupAndResetDatabase1749296262915 } from "./migrations/1749296262915-BackupAndResetDatabase";
import { CreateSchema1749296280721 } from "./migrations/1749296280721-CreateSchema";
import { UpdateNewsletterQueryRelation1752502069178 } from "./migrations/1752502069178-updateNewsletterQueryRelation";
import { UnitBase1749361405703 } from "./migrations/1749361405703-UnitBase";
import { UnitBase1752914551204 } from "./migrations/1752914551204-UnitBase";
import { repair } from "./entity/unit/repair";
configCheck();
@ -131,6 +132,7 @@ const dataSource = new DataSource({
wearable,
damageReport,
maintenance,
repair,
inspectionPlan,
inspectionVersionedPlan,
inspectionPoint,
@ -140,8 +142,8 @@ const dataSource = new DataSource({
migrations: [
BackupAndResetDatabase1749296262915,
CreateSchema1749296280721,
UnitBase1752914551204,
UpdateNewsletterQueryRelation1752502069178,
UnitBase1749361405703,
],
migrationsRun: true,
migrationsTransactionMode: "each",

View file

@ -2,7 +2,7 @@ import { Column, CreateDateColumn, Entity, ManyToOne, PrimaryGeneratedColumn } f
import { equipment } from "./equipment/equipment";
import { wearable } from "./wearable/wearable";
import { vehicle } from "./vehicle/vehicle";
import { maintenance } from "./maintenance";
import { repair } from "./repair";
@Entity()
export class damageReport {
@ -18,6 +18,9 @@ export class damageReport {
@Column({ type: "boolean", default: false })
done: boolean;
@Column({ type: "varchar", length: 255 })
title: string;
@Column({ type: "text" })
description: string;
@ -34,9 +37,9 @@ export class damageReport {
type: "text",
transformer: {
from(value: string): Array<string> {
return value.split(",").filter((i) => !!i);
return (value ?? "").split(",").filter((i) => !!i);
},
to(value: Array<string>): string {
to(value: Array<string> = []): string {
return value.join(",");
},
},
@ -56,7 +59,7 @@ export class damageReport {
wearableId?: string;
@Column({ nullable: true, default: null })
maintenanceId?: string;
repairId?: string;
@ManyToOne(() => equipment, (e) => e.reports, {
nullable: true,
@ -79,10 +82,10 @@ export class damageReport {
})
wearable?: wearable;
@ManyToOne(() => maintenance, (m) => m.reports, {
@ManyToOne(() => repair, (m) => m.reports, {
nullable: true,
onDelete: "SET NULL",
onUpdate: "RESTRICT",
})
maintenance?: maintenance;
repair?: repair;
}

View file

@ -4,6 +4,7 @@ import { equipmentType } from "./equipmentType";
import { damageReport } from "../damageReport";
import { inspection } from "../inspection/inspection";
import { maintenance } from "../maintenance";
import { repair } from "../repair";
@Entity()
export class equipment {
@ -38,6 +39,9 @@ export class equipment {
@OneToMany(() => damageReport, (d) => d.equipment, { cascade: ["insert"] })
reports: damageReport[];
@OneToMany(() => repair, (d) => d.equipment, { cascade: ["insert"] })
repairs: repair[];
@OneToMany(() => maintenance, (m) => m.equipment, { cascade: ["insert"] })
maintenances: maintenance[];

View file

@ -1,8 +1,9 @@
import { Column, CreateDateColumn, Entity, ManyToOne, OneToMany, PrimaryGeneratedColumn } from "typeorm";
import { Column, ColumnType, CreateDateColumn, Entity, ManyToOne, OneToMany, PrimaryGeneratedColumn } from "typeorm";
import { equipment } from "./equipment/equipment";
import { wearable } from "./wearable/wearable";
import { vehicle } from "./vehicle/vehicle";
import { damageReport } from "./damageReport";
import { getTypeByORM } from "../../migrations/ormHelper";
@Entity()
export class maintenance {
@ -12,12 +13,12 @@ export class maintenance {
@CreateDateColumn()
createdAt: Date;
@Column({ type: getTypeByORM("datetime").type as ColumnType, nullable: true, default: null })
finishedAt?: Date;
@Column({ type: "varchar", length: 255 })
status: string;
@Column({ type: "boolean", default: false })
done: boolean;
@Column({ type: "text" })
description: string;
@ -50,7 +51,4 @@ export class maintenance {
onUpdate: "RESTRICT",
})
wearable?: wearable;
@OneToMany(() => damageReport, (dr) => dr.maintenance)
reports: damageReport[];
}

79
src/entity/unit/repair.ts Normal file
View file

@ -0,0 +1,79 @@
import { Column, ColumnType, CreateDateColumn, Entity, ManyToOne, OneToMany, PrimaryGeneratedColumn } from "typeorm";
import { equipment } from "./equipment/equipment";
import { wearable } from "./wearable/wearable";
import { vehicle } from "./vehicle/vehicle";
import { damageReport } from "./damageReport";
import { getTypeByORM } from "../../migrations/ormHelper";
@Entity()
export class repair {
@PrimaryGeneratedColumn("uuid")
id: string;
@CreateDateColumn()
createdAt: Date;
@Column({ type: getTypeByORM("datetime").type as ColumnType, nullable: true, default: null })
finishedAt?: Date;
@Column({ type: "varchar", length: 255 })
status: string;
@Column({ type: "varchar", length: 255 })
responsible: string;
@Column({ type: "varchar", length: 255 })
title: string;
@Column({ type: "text" })
description: string;
@Column({
type: "text",
transformer: {
from(value: string): Array<string> {
return (value ?? "").split(",").filter((i) => !!i);
},
to(value: Array<string> = []): string {
return value.join(",");
},
},
})
images: string[];
@Column({ type: "varchar", length: 255, nullable: true, default: null })
reportDocument?: string;
@Column({ nullable: true, default: null })
equipmentId?: string;
@Column({ nullable: true, default: null })
vehicleId?: string;
@Column({ nullable: true, default: null })
wearableId?: string;
@ManyToOne(() => equipment, (e) => e.maintenances, {
nullable: true,
onDelete: "CASCADE",
onUpdate: "RESTRICT",
})
equipment?: equipment;
@ManyToOne(() => vehicle, (v) => v.maintenances, {
nullable: true,
onDelete: "CASCADE",
onUpdate: "RESTRICT",
})
vehicle?: vehicle;
@ManyToOne(() => wearable, (w) => w.maintenances, {
nullable: true,
onDelete: "CASCADE",
onUpdate: "RESTRICT",
})
wearable?: wearable;
@OneToMany(() => damageReport, (dr) => dr.repair)
reports: damageReport[];
}

View file

@ -4,6 +4,7 @@ import { vehicleType } from "./vehicleType";
import { damageReport } from "../damageReport";
import { inspection } from "../inspection/inspection";
import { maintenance } from "../maintenance";
import { repair } from "../repair";
@Entity()
export class vehicle {
@ -38,6 +39,9 @@ export class vehicle {
@OneToMany(() => damageReport, (d) => d.vehicle, { cascade: ["insert"] })
reports: damageReport[];
@OneToMany(() => repair, (d) => d.vehicle, { cascade: ["insert"] })
repairs: repair[];
@OneToMany(() => maintenance, (m) => m.vehicle, { cascade: ["insert"] })
maintenances: maintenance[];

View file

@ -5,6 +5,7 @@ import { damageReport } from "../damageReport";
import { member } from "../../club/member/member";
import { inspection } from "../inspection/inspection";
import { maintenance } from "../maintenance";
import { repair } from "../repair";
@Entity()
export class wearable {
@ -49,6 +50,9 @@ export class wearable {
@OneToMany(() => damageReport, (d) => d.wearable, { cascade: ["insert"] })
reports: damageReport[];
@OneToMany(() => repair, (d) => d.wearable, { cascade: ["insert"] })
repairs: repair[];
@OneToMany(() => maintenance, (m) => m.wearable, { cascade: ["insert"] })
maintenances: maintenance[];

View file

@ -2,6 +2,7 @@ import { damageReport } from "../../../entity/unit/damageReport";
import { DamageReportAssigned, DamageReportViewModel } from "../../../viewmodel/admin/unit/damageReport.models";
import EquipmentFactory from "./equipment/equipment";
import MaintenanceFactory from "./maintenance";
import RepairFactory from "./repair";
import VehicleFactory from "./vehicle/vehicle";
import WearableFactory from "./wearable/wearable";
@ -17,19 +18,19 @@ export default abstract class DamageReportFactory {
assigned = {
relatedId: record.equipmentId,
assigned: "equipment",
related: EquipmentFactory.mapToSingle(record.equipment),
related: record.equipment ? EquipmentFactory.mapToSingle(record.equipment) : undefined,
};
} else if (record?.vehicleId) {
assigned = {
relatedId: record.vehicleId,
assigned: "vehicle",
related: VehicleFactory.mapToSingle(record.vehicle),
related: record.vehicle ? VehicleFactory.mapToSingle(record.vehicle) : undefined,
};
} else if (record?.wearableId) {
assigned = {
relatedId: record.wearableId,
assigned: "wearable",
related: WearableFactory.mapToSingle(record.wearable),
related: record.wearable ? WearableFactory.mapToSingle(record.wearable) : undefined,
};
} else {
assigned = {
@ -44,6 +45,7 @@ export default abstract class DamageReportFactory {
reportedAt: record.reportedAt,
status: record.status,
done: record.done,
title: record.title,
description: record.description,
location: record.location,
noteByReporter: record.noteByReporter,
@ -51,7 +53,7 @@ export default abstract class DamageReportFactory {
images: record.images,
reportedBy: record?.reportedBy,
...assigned,
maintenance: record.maintenance ? MaintenanceFactory.mapToSingle(record.maintenance) : null,
repair: record.repair ? RepairFactory.mapToSingle(record.repair) : null,
};
}

View file

@ -37,10 +37,8 @@ export default abstract class MaintenanceFactory {
id: record.id,
createdAt: record.createdAt,
status: record.status,
done: record.done,
description: record.description,
...assigned,
reports: record.reports ? DamageReportFactory.mapToBase(record.reports) : [],
};
}

View file

@ -0,0 +1,65 @@
import { repair } from "../../../entity/unit/repair";
import { RepairAssigned, RepairViewModel } from "../../../viewmodel/admin/unit/repair.models";
import DamageReportFactory from "./damageReport";
import EquipmentFactory from "./equipment/equipment";
import VehicleFactory from "./vehicle/vehicle";
import WearableFactory from "./wearable/wearable";
export default abstract class RepairFactory {
/**
* @description map record to repair
* @param {repair} record
* @returns {RepairViewModel}
*/
public static mapToSingle(record: repair): RepairViewModel {
let assigned: RepairAssigned;
if (record?.equipmentId) {
assigned = {
relatedId: record.equipmentId,
assigned: "equipment",
related: record.equipment ? EquipmentFactory.mapToSingle(record.equipment) : undefined,
};
} else if (record?.vehicleId) {
assigned = {
relatedId: record.vehicleId,
assigned: "vehicle",
related: record.vehicle ? VehicleFactory.mapToSingle(record.vehicle) : undefined,
};
} else if (record?.wearableId) {
assigned = {
relatedId: record.wearableId,
assigned: "wearable",
related: record.wearable ? WearableFactory.mapToSingle(record.wearable) : undefined,
};
} else {
assigned = {
relatedId: undefined,
assigned: undefined,
related: undefined,
};
}
return {
id: record.id,
createdAt: record.createdAt,
finishedAt: record.finishedAt,
status: record.status,
responsible: record.responsible,
title: record.title,
description: record.description,
images: record.images,
reportDocument: record.reportDocument,
reports: record.reports ? DamageReportFactory.mapToBase(record.reports) : [],
...assigned,
};
}
/**
* @description map records to repair
* @param {Array<repair>} records
* @returns {Array<RepairViewModel>}
*/
public static mapToBase(records: Array<repair>): Array<RepairViewModel> {
return records.map((r) => this.mapToSingle(r));
}
}

View file

@ -516,6 +516,7 @@ export default abstract class BackupHelper {
wearable: await dataSource.getRepository("wearable").find(),
maintenance: await dataSource.getRepository("maintenance").find(),
damage_report: await dataSource.getRepository("damage_report").find(),
repair: await dataSource.getRepository("repair").find(),
inspection: await dataSource.getRepository("inspection").find(),
inspection_point_result: await dataSource.getRepository("inspection_point_result").find(),
};
@ -903,23 +904,26 @@ export default abstract class BackupHelper {
await this.transactionManager.getRepository("setting").save(data);
}
private static async setUnitBase(data: { [key: string]: Array<any> }): Promise<void> {
await this.transactionManager.getRepository("equipment_type").save(data["equipment_type"]);
await this.transactionManager.getRepository("vehicle_type").save(data["vehicle_type"]);
await this.transactionManager.getRepository("wearable_type").save(data["wearable_type"]);
await this.transactionManager.getRepository("equipment_type").save(data["equipment_type"] ?? []);
await this.transactionManager.getRepository("vehicle_type").save(data["vehicle_type"] ?? []);
await this.transactionManager.getRepository("wearable_type").save(data["wearable_type"] ?? []);
await this.transactionManager.getRepository("inspection_plan").save(data["inspection_plan"]);
await this.transactionManager.getRepository("inspection_versioned_plan").save(data["inspection_versioned_plan"]);
await this.transactionManager.getRepository("inspection_point").save(data["inspection_point"]);
await this.transactionManager.getRepository("inspection_plan").save(data["inspection_plan"] ?? []);
await this.transactionManager
.getRepository("inspection_versioned_plan")
.save(data["inspection_versioned_plan"] ?? []);
await this.transactionManager.getRepository("inspection_point").save(data["inspection_point"] ?? []);
}
private static async setUnitInstances(data: { [key: string]: Array<any> }): Promise<void> {
await this.transactionManager.getRepository("equipment").save(data["equipment"]);
await this.transactionManager.getRepository("vehicle").save(data["vehicle"]);
await this.transactionManager.getRepository("wearable").save(data["wearable"]);
await this.transactionManager.getRepository("equipment").save(data["equipment"] ?? []);
await this.transactionManager.getRepository("vehicle").save(data["vehicle"] ?? []);
await this.transactionManager.getRepository("wearable").save(data["wearable"] ?? []);
await this.transactionManager.getRepository("damage_report").save(data["damage_report"]);
await this.transactionManager.getRepository("maintenance").save(data["maintenance"]);
await this.transactionManager.getRepository("repair").save(data["repair"] ?? []);
await this.transactionManager.getRepository("damage_report").save(data["damage_report"] ?? []);
await this.transactionManager.getRepository("maintenance").save(data["maintenance"] ?? []);
await this.transactionManager.getRepository("inspection").save(data["inspection"]);
await this.transactionManager.getRepository("inspection_point_result").save(data["inspection_point_result"]);
await this.transactionManager.getRepository("inspection").save(data["inspection"] ?? []);
await this.transactionManager.getRepository("inspection_point_result").save(data["inspection_point_result"] ?? []);
}
}

View file

@ -14,12 +14,12 @@ import {
wearable_type_table,
wearable_table,
} from "./baseSchemaTables/unit";
import { maintenance_table, damage_report_table } from "./baseSchemaTables/unit_extend";
import { maintenance_table, damage_report_table, repair_table } from "./baseSchemaTables/unit_extend";
import { availableTemplates } from "../type/templateTypes";
import { template_usage_table } from "./baseSchemaTables/query_template";
export class UnitBase1749361405703 implements MigrationInterface {
name = "UnitBase1749361405703";
export class UnitBase1752914551204 implements MigrationInterface {
name = "UnitBase1752914551204";
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.createTable(equipment_type_table, true, true, true);
@ -30,6 +30,7 @@ export class UnitBase1749361405703 implements MigrationInterface {
await queryRunner.createTable(wearable_table, true, true, true);
await queryRunner.createTable(maintenance_table, true, true, true);
await queryRunner.createTable(repair_table, true, true, true);
await queryRunner.createTable(damage_report_table, true, true, true);
await queryRunner.createTable(inspection_plan_table, true, true, true);
@ -61,6 +62,7 @@ export class UnitBase1749361405703 implements MigrationInterface {
await queryRunner.dropTable(inspection_plan_table, true, true, true);
await queryRunner.dropTable(damage_report_table, true, true, true);
await queryRunner.dropTable(repair_table, true, true, true);
await queryRunner.dropTable(maintenance_table, true, true, true);
await queryRunner.dropTable(wearable_table, true, true, true);

View file

@ -8,6 +8,7 @@ export const damage_report_table = new Table({
{ name: "reportedAt", ...getTypeByORM("datetime"), default: getDefaultByORM("currentTimestamp") },
{ name: "status", ...getTypeByORM("varchar") },
{ name: "done", ...getTypeByORM("boolean"), default: getDefaultByORM("boolean", false) },
{ name: "title", ...getTypeByORM("varchar") },
{ name: "description", ...getTypeByORM("text") },
{ name: "location", ...getTypeByORM("text") },
{ name: "noteByReporter", ...getTypeByORM("text") },
@ -17,7 +18,7 @@ export const damage_report_table = new Table({
{ name: "equipmentId", ...getTypeByORM("uuid", true) },
{ name: "vehicleId", ...getTypeByORM("uuid", true) },
{ name: "wearableId", ...getTypeByORM("uuid", true) },
{ name: "maintenanceId", ...getTypeByORM("uuid", true) },
{ name: "repairId", ...getTypeByORM("uuid", true) },
],
foreignKeys: [
new TableForeignKey({
@ -42,9 +43,9 @@ export const damage_report_table = new Table({
onUpdate: "RESTRICT",
}),
new TableForeignKey({
columnNames: ["maintenanceId"],
columnNames: ["repairId"],
referencedColumnNames: ["id"],
referencedTableName: "maintenance",
referencedTableName: "repair",
onDelete: "SET NULL",
onUpdate: "RESTRICT",
}),
@ -56,8 +57,8 @@ export const maintenance_table = new Table({
columns: [
{ name: "id", ...getTypeByORM("uuid"), ...isUUIDPrimary },
{ name: "createdAt", ...getTypeByORM("datetime"), default: getDefaultByORM("currentTimestamp") },
{ name: "finishedAt", ...getTypeByORM("datetime", true) },
{ name: "status", ...getTypeByORM("varchar") },
{ name: "done", ...getTypeByORM("boolean"), default: getDefaultByORM("boolean", false) },
{ name: "description", ...getTypeByORM("text") },
{ name: "equipmentId", ...getTypeByORM("uuid", true) },
{ name: "vehicleId", ...getTypeByORM("uuid", true) },
@ -87,3 +88,44 @@ export const maintenance_table = new Table({
}),
],
});
export const repair_table = new Table({
name: "repair",
columns: [
{ name: "id", ...getTypeByORM("uuid"), ...isUUIDPrimary },
{ name: "createdAt", ...getTypeByORM("datetime"), default: getDefaultByORM("currentTimestamp") },
{ name: "finishedAt", ...getTypeByORM("datetime", true) },
{ name: "status", ...getTypeByORM("varchar") },
{ name: "responsible", ...getTypeByORM("varchar") },
{ name: "title", ...getTypeByORM("varchar") },
{ name: "description", ...getTypeByORM("text") },
{ name: "images", ...getTypeByORM("text") },
{ name: "reportDocument", ...getTypeByORM("varchar", true) },
{ name: "equipmentId", ...getTypeByORM("uuid", true) },
{ name: "vehicleId", ...getTypeByORM("uuid", true) },
{ name: "wearableId", ...getTypeByORM("uuid", true) },
],
foreignKeys: [
new TableForeignKey({
columnNames: ["equipmentId"],
referencedColumnNames: ["id"],
referencedTableName: "equipment",
onDelete: "CASCADE",
onUpdate: "RESTRICT",
}),
new TableForeignKey({
columnNames: ["vehicleId"],
referencedColumnNames: ["id"],
referencedTableName: "vehicle",
onDelete: "CASCADE",
onUpdate: "RESTRICT",
}),
new TableForeignKey({
columnNames: ["wearableId"],
referencedColumnNames: ["id"],
referencedTableName: "wearable",
onDelete: "CASCADE",
onUpdate: "RESTRICT",
}),
],
});

View file

@ -43,6 +43,7 @@ import inspection from "./unit/inspection";
import inspectionPlan from "./unit/inspectionPlan";
import damageReport from "./unit/damageReport";
import maintenance from "./unit/maintenance";
import repair from "./unit/repair";
var router = express.Router({ mergeParams: true });
@ -283,5 +284,15 @@ router.use(
]),
maintenance
);
router.use(
"/repair",
PermissionHelper.passCheckSomeMiddleware([
{ requiredPermission: "read", section: "unit", module: "repair" },
{ requiredPermission: "read", section: "unit", module: "equipment" },
{ requiredPermission: "read", section: "unit", module: "vehicle" },
{ requiredPermission: "read", section: "unit", module: "wearable" },
]),
repair
);
export default router;

View file

@ -11,6 +11,7 @@ import {
getAllDamageReportsByStatus,
getAllDamageReportsForRelated,
getDamageReportById,
getDamageReportsByIds,
provideDamageReportImageUpload,
updateDamageReportById,
} from "../../../controller/admin/unit/damageReportController";
@ -40,6 +41,10 @@ router.get("/:id", async (req: Request, res: Response) => {
await getDamageReportById(req, res);
});
router.post("/ids", async (req: Request, res: Response) => {
await getDamageReportsByIds(req, res);
});
router.get("/:id/:filename", async (req: Request, res: Response) => {
await provideDamageReportImageUpload(req, res);
});

View file

@ -0,0 +1,70 @@
import express, { Request, Response } from "express";
import PermissionHelper from "../../../helpers/permissionHelper";
import {
createRepair,
getAllRepairsByStatus,
getAllRepairsForRelated,
getRepairById,
updateRepairById,
updateRepairReportsById,
updateRepairStatusById,
} from "../../../controller/admin/unit/repairController";
var router = express.Router({ mergeParams: true });
router.get("/", async (req: Request, res: Response) => {
await getAllRepairsByStatus(req, res);
});
router.get(
["/vehicle/:relatedId", "/equipment/:relatedId", "/wearable/:relatedId"],
async (req: Request, res: Response) => {
if (req.path.startsWith("/vehicle")) {
req.params.related = "vehicle";
} else if (req.path.startsWith("/equipment")) {
req.params.related = "equipment";
} else {
req.params.related = "wearable";
}
await getAllRepairsForRelated(req, res);
}
);
router.get("/:id", async (req: Request, res: Response) => {
await getRepairById(req, res);
});
router.post(
"/",
PermissionHelper.passCheckMiddleware("update", "unit", "repair"),
async (req: Request, res: Response) => {
await createRepair(req, res);
}
);
router.patch(
"/:id",
PermissionHelper.passCheckMiddleware("update", "unit", "repair"),
async (req: Request, res: Response) => {
await updateRepairById(req, res);
}
);
router.patch(
"/:id/reports",
PermissionHelper.passCheckMiddleware("update", "unit", "repair"),
async (req: Request, res: Response) => {
await updateRepairReportsById(req, res);
}
);
router.patch(
"/:id/status",
PermissionHelper.passCheckMiddleware("update", "unit", "repair"),
async (req: Request, res: Response) => {
await updateRepairStatusById(req, res);
}
);
export default router;

View file

@ -1,3 +1,4 @@
import { In } from "typeorm";
import { dataSource } from "../../data-source";
import { damageReport } from "../../entity/unit/damageReport";
import DatabaseActionException from "../../exceptions/databaseActionException";
@ -10,13 +11,48 @@ export default abstract class DamageReportService {
.leftJoinAndSelect("damageReport.equipment", "equipment")
.leftJoinAndSelect("damageReport.vehicle", "vehicle")
.leftJoinAndSelect("damageReport.wearable", "wearable")
.leftJoinAndSelect("damageReport.maintenance", "maintenance");
.leftJoinAndSelect("damageReport.repair", "repair");
/**
* @description get all damageReports By done
* @returns {Promise<[Array<damageReport>, number]>}
*/
static async getAll({
offset = 0,
count = 25,
noLimit = false,
ids = [],
}: {
offset?: number;
count?: number;
noLimit?: boolean;
ids?: Array<string>;
}): Promise<[Array<damageReport>, number]> {
let query = this.query();
if (ids.length != 0) {
query = query.where({ id: In(ids) });
}
if (!noLimit) {
query = query.offset(offset).limit(count);
}
return await query
.orderBy("damageReport.reportedAt", "ASC")
.getManyAndCount()
.then((res) => {
return res;
})
.catch((err) => {
throw new DatabaseActionException("SELECT", "damageReport", err);
});
}
/**
* @description get all damageReports By done
* @returns {Promise<[Array<damageReport>, number]>}
*/
static async getAll(
static async getAllByStatus(
done = false,
{
offset = 0,
@ -78,6 +114,39 @@ export default abstract class DamageReportService {
});
}
/**
* @description get all damageReport for repair
* @returns {Promise<[Array<damageReport>, number]>}
*/
static async getAllForRepair(
repairId: string,
{
offset = 0,
count = 25,
noLimit = false,
}: {
offset?: number;
count?: number;
noLimit?: boolean;
}
): Promise<[Array<damageReport>, number]> {
let query = this.query().where({ repairId });
if (!noLimit) {
query = query.offset(offset).limit(count);
}
return await query
.orderBy("damageReport.reportedAt", "ASC")
.getManyAndCount()
.then((res) => {
return res;
})
.catch((err) => {
throw new DatabaseActionException("SELECT", "damageReport", err);
});
}
/**
* @description get damageReport by id
* @returns {Promise<damageReport>}

View file

@ -1,3 +1,4 @@
import { Not, IsNull } from "typeorm";
import { dataSource } from "../../data-source";
import { maintenance } from "../../entity/unit/maintenance";
import DatabaseActionException from "../../exceptions/databaseActionException";
@ -9,8 +10,7 @@ export default abstract class MaintenanceService {
.createQueryBuilder("maintenance")
.leftJoinAndSelect("maintenance.equipment", "equipment")
.leftJoinAndSelect("maintenance.vehicle", "vehicle")
.leftJoinAndSelect("maintenance.wearable", "wearable")
.leftJoinAndSelect("maintenance.reports", "reports");
.leftJoinAndSelect("maintenance.wearable", "wearable");
/**
* @description get all maintenances
@ -28,7 +28,7 @@ export default abstract class MaintenanceService {
noLimit?: boolean;
}
): Promise<[Array<maintenance>, number]> {
let query = this.query().where({ done });
let query = this.query().where({ finishedAt: done ? Not(IsNull()) : IsNull() });
if (!noLimit) {
query = query.offset(offset).limit(count);
}

View file

@ -0,0 +1,96 @@
import { IsNull, Not } from "typeorm";
import { dataSource } from "../../data-source";
import { repair } from "../../entity/unit/repair";
import DatabaseActionException from "../../exceptions/databaseActionException";
export default abstract class RepairService {
private static query = () =>
dataSource
.getRepository(repair)
.createQueryBuilder("repair")
.leftJoinAndSelect("repair.equipment", "equipment")
.leftJoinAndSelect("repair.vehicle", "vehicle")
.leftJoinAndSelect("repair.wearable", "wearable")
.leftJoinAndSelect("repair.reports", "reports");
/**
* @description get all repairs
* @returns {Promise<[Array<repair>, number]>}
*/
static async getAll(
done = false,
{
offset = 0,
count = 25,
noLimit = false,
}: {
offset?: number;
count?: number;
noLimit?: boolean;
}
): Promise<[Array<repair>, number]> {
let query = this.query().where({ finishedAt: done ? Not(IsNull()) : IsNull() });
if (!noLimit) {
query = query.offset(offset).limit(count);
}
return await query
.orderBy("repair.createdAt", "ASC")
.getManyAndCount()
.then((res) => {
return res;
})
.catch((err) => {
throw new DatabaseActionException("SELECT", "repair", err);
});
}
/**
* @description get all repairs By related
* @returns {Promise<[Array<repair>, number]>}
*/
static async getAllForRelated(
where: { equipmentId: string } | { vehicleId: string } | { wearableId: string },
{
offset = 0,
count = 25,
noLimit = false,
}: {
offset?: number;
count?: number;
noLimit?: boolean;
}
): Promise<[Array<repair>, number]> {
let query = this.query().where(where);
if (!noLimit) {
query = query.offset(offset).limit(count);
}
return await query
.orderBy("repair.createdAt", "ASC")
.getManyAndCount()
.then((res) => {
return res;
})
.catch((err) => {
throw new DatabaseActionException("SELECT", "repair", err);
});
}
/**
* @description get repair by id
* @returns {Promise<repair>}
*/
static async getById(id: string): Promise<repair> {
return await this.query()
.where({ id })
.getOneOrFail()
.then((res) => {
return res;
})
.catch((err) => {
throw new DatabaseActionException("SELECT", "repair", err);
});
}
}

View file

@ -22,6 +22,7 @@ export type PermissionModule =
| "respiratory_mission"
| "damage_report"
| "maintenance"
| "repair"
// configuration
| "qualification"
| "award"
@ -97,6 +98,7 @@ export const permissionModules: Array<PermissionModule> = [
"respiratory_mission",
"damage_report",
"maintenance",
"repair",
// configuration
"qualification",
"award",
@ -134,6 +136,7 @@ export const sectionsAndModules: SectionsAndModulesObject = {
"respiratory_mission",
"damage_report",
"maintenance",
"repair",
],
configuration: [
"qualification",

View file

@ -1,5 +1,6 @@
import { EquipmentViewModel } from "./equipment/equipment.models";
import { MaintenanceViewModel } from "./maintenance.models";
import { RepairViewModel } from "./repair.models";
import { VehicleViewModel } from "./vehicle/vehicle.models";
import { WearableViewModel } from "./wearable/wearable.models";
@ -22,6 +23,7 @@ export type DamageReportAssigned = {
export type DamageReportViewModel = {
id: string;
title: string;
reportedAt: Date;
status: string;
done: boolean;
@ -31,5 +33,5 @@ export type DamageReportViewModel = {
noteByWorker: string;
images: string[];
reportedBy: string;
maintenance?: MaintenanceViewModel;
repair?: RepairViewModel;
} & DamageReportAssigned;

View file

@ -1,4 +1,3 @@
import { DamageReportViewModel } from "./damageReport.models";
import { EquipmentViewModel } from "./equipment/equipment.models";
import { VehicleViewModel } from "./vehicle/vehicle.models";
import { WearableViewModel } from "./wearable/wearable.models";
@ -24,7 +23,5 @@ export type MaintenanceViewModel = {
id: string;
createdAt: Date;
status: string;
done: boolean;
description: string;
reports: DamageReportViewModel[];
} & MaintenanceAssigned;

View file

@ -0,0 +1,34 @@
import { DamageReportViewModel } from "./damageReport.models";
import { EquipmentViewModel } from "./equipment/equipment.models";
import { VehicleViewModel } from "./vehicle/vehicle.models";
import { WearableViewModel } from "./wearable/wearable.models";
export type RepairAssigned = {
relatedId: string;
} & (
| {
assigned: "equipment";
related: EquipmentViewModel;
}
| {
assigned: "vehicle";
related: VehicleViewModel;
}
| {
assigned: "wearable";
related: WearableViewModel;
}
);
export type RepairViewModel = {
id: string;
createdAt: Date;
finishedAt?: Date;
status: string;
responsible: string;
title: string;
description: string;
images: string[];
reportDocument?: string;
reports: DamageReportViewModel[];
} & RepairAssigned;