projects
This commit is contained in:
139
server/src/modules/projects/router.ts
Normal file
139
server/src/modules/projects/router.ts
Normal file
@@ -0,0 +1,139 @@
|
||||
import { permissions, projectPriorities, projectStatuses } from "@mrp/shared";
|
||||
import { Router } from "express";
|
||||
import { z } from "zod";
|
||||
|
||||
import { fail, ok } from "../../lib/http.js";
|
||||
import { requirePermissions } from "../../lib/rbac.js";
|
||||
import {
|
||||
createProject,
|
||||
getProjectById,
|
||||
listProjectCustomerOptions,
|
||||
listProjectOrderOptions,
|
||||
listProjectOwnerOptions,
|
||||
listProjects,
|
||||
listProjectQuoteOptions,
|
||||
listProjectShipmentOptions,
|
||||
updateProject,
|
||||
} from "./service.js";
|
||||
|
||||
const projectSchema = z.object({
|
||||
name: z.string().trim().min(1).max(160),
|
||||
status: z.enum(projectStatuses),
|
||||
priority: z.enum(projectPriorities),
|
||||
customerId: z.string().trim().min(1),
|
||||
salesQuoteId: z.string().trim().min(1).nullable(),
|
||||
salesOrderId: z.string().trim().min(1).nullable(),
|
||||
shipmentId: z.string().trim().min(1).nullable(),
|
||||
ownerId: z.string().trim().min(1).nullable(),
|
||||
dueDate: z.string().datetime().nullable(),
|
||||
notes: z.string(),
|
||||
});
|
||||
|
||||
const projectListQuerySchema = z.object({
|
||||
q: z.string().optional(),
|
||||
status: z.enum(projectStatuses).optional(),
|
||||
priority: z.enum(projectPriorities).optional(),
|
||||
customerId: z.string().optional(),
|
||||
ownerId: z.string().optional(),
|
||||
});
|
||||
|
||||
const projectOptionQuerySchema = z.object({
|
||||
customerId: z.string().optional(),
|
||||
});
|
||||
|
||||
function getRouteParam(value: unknown) {
|
||||
return typeof value === "string" ? value : null;
|
||||
}
|
||||
|
||||
export const projectsRouter = Router();
|
||||
|
||||
projectsRouter.get("/customers/options", requirePermissions([permissions.projectsRead]), async (_request, response) => {
|
||||
return ok(response, await listProjectCustomerOptions());
|
||||
});
|
||||
|
||||
projectsRouter.get("/owners/options", requirePermissions([permissions.projectsRead]), async (_request, response) => {
|
||||
return ok(response, await listProjectOwnerOptions());
|
||||
});
|
||||
|
||||
projectsRouter.get("/quotes/options", requirePermissions([permissions.projectsRead]), async (request, response) => {
|
||||
const parsed = projectOptionQuerySchema.safeParse(request.query);
|
||||
if (!parsed.success) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project quote filters are invalid.");
|
||||
}
|
||||
|
||||
return ok(response, await listProjectQuoteOptions(parsed.data.customerId));
|
||||
});
|
||||
|
||||
projectsRouter.get("/orders/options", requirePermissions([permissions.projectsRead]), async (request, response) => {
|
||||
const parsed = projectOptionQuerySchema.safeParse(request.query);
|
||||
if (!parsed.success) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project order filters are invalid.");
|
||||
}
|
||||
|
||||
return ok(response, await listProjectOrderOptions(parsed.data.customerId));
|
||||
});
|
||||
|
||||
projectsRouter.get("/shipments/options", requirePermissions([permissions.projectsRead]), async (request, response) => {
|
||||
const parsed = projectOptionQuerySchema.safeParse(request.query);
|
||||
if (!parsed.success) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project shipment filters are invalid.");
|
||||
}
|
||||
|
||||
return ok(response, await listProjectShipmentOptions(parsed.data.customerId));
|
||||
});
|
||||
|
||||
projectsRouter.get("/", requirePermissions([permissions.projectsRead]), async (request, response) => {
|
||||
const parsed = projectListQuerySchema.safeParse(request.query);
|
||||
if (!parsed.success) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project filters are invalid.");
|
||||
}
|
||||
|
||||
return ok(response, await listProjects(parsed.data));
|
||||
});
|
||||
|
||||
projectsRouter.get("/:projectId", requirePermissions([permissions.projectsRead]), async (request, response) => {
|
||||
const projectId = getRouteParam(request.params.projectId);
|
||||
if (!projectId) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project id is invalid.");
|
||||
}
|
||||
|
||||
const project = await getProjectById(projectId);
|
||||
if (!project) {
|
||||
return fail(response, 404, "PROJECT_NOT_FOUND", "Project was not found.");
|
||||
}
|
||||
|
||||
return ok(response, project);
|
||||
});
|
||||
|
||||
projectsRouter.post("/", requirePermissions([permissions.projectsWrite]), async (request, response) => {
|
||||
const parsed = projectSchema.safeParse(request.body);
|
||||
if (!parsed.success) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project payload is invalid.");
|
||||
}
|
||||
|
||||
const result = await createProject(parsed.data);
|
||||
if (!result.ok) {
|
||||
return fail(response, 400, "INVALID_INPUT", result.reason);
|
||||
}
|
||||
|
||||
return ok(response, result.project, 201);
|
||||
});
|
||||
|
||||
projectsRouter.put("/:projectId", requirePermissions([permissions.projectsWrite]), async (request, response) => {
|
||||
const projectId = getRouteParam(request.params.projectId);
|
||||
if (!projectId) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project id is invalid.");
|
||||
}
|
||||
|
||||
const parsed = projectSchema.safeParse(request.body);
|
||||
if (!parsed.success) {
|
||||
return fail(response, 400, "INVALID_INPUT", "Project payload is invalid.");
|
||||
}
|
||||
|
||||
const result = await updateProject(projectId, parsed.data);
|
||||
if (!result.ok) {
|
||||
return fail(response, 400, "INVALID_INPUT", result.reason);
|
||||
}
|
||||
|
||||
return ok(response, result.project);
|
||||
});
|
||||
425
server/src/modules/projects/service.ts
Normal file
425
server/src/modules/projects/service.ts
Normal file
@@ -0,0 +1,425 @@
|
||||
import type {
|
||||
ProjectCustomerOptionDto,
|
||||
ProjectDetailDto,
|
||||
ProjectDocumentOptionDto,
|
||||
ProjectInput,
|
||||
ProjectOwnerOptionDto,
|
||||
ProjectPriority,
|
||||
ProjectShipmentOptionDto,
|
||||
ProjectStatus,
|
||||
ProjectSummaryDto,
|
||||
} from "@mrp/shared";
|
||||
|
||||
import { prisma } from "../../lib/prisma.js";
|
||||
|
||||
const projectModel = (prisma as any).project;
|
||||
|
||||
type ProjectRecord = {
|
||||
id: string;
|
||||
projectNumber: string;
|
||||
name: string;
|
||||
status: string;
|
||||
priority: string;
|
||||
dueDate: Date | null;
|
||||
notes: string;
|
||||
createdAt: Date;
|
||||
updatedAt: Date;
|
||||
customer: {
|
||||
id: string;
|
||||
name: string;
|
||||
email: string;
|
||||
phone: string;
|
||||
};
|
||||
owner: {
|
||||
id: string;
|
||||
firstName: string;
|
||||
lastName: string;
|
||||
} | null;
|
||||
salesQuote: {
|
||||
id: string;
|
||||
documentNumber: string;
|
||||
} | null;
|
||||
salesOrder: {
|
||||
id: string;
|
||||
documentNumber: string;
|
||||
} | null;
|
||||
shipment: {
|
||||
id: string;
|
||||
shipmentNumber: string;
|
||||
} | null;
|
||||
};
|
||||
|
||||
function getOwnerName(owner: ProjectRecord["owner"]) {
|
||||
return owner ? `${owner.firstName} ${owner.lastName}`.trim() : null;
|
||||
}
|
||||
|
||||
function mapProjectSummary(record: ProjectRecord): ProjectSummaryDto {
|
||||
return {
|
||||
id: record.id,
|
||||
projectNumber: record.projectNumber,
|
||||
name: record.name,
|
||||
status: record.status as ProjectStatus,
|
||||
priority: record.priority as ProjectPriority,
|
||||
customerId: record.customer.id,
|
||||
customerName: record.customer.name,
|
||||
ownerId: record.owner?.id ?? null,
|
||||
ownerName: getOwnerName(record.owner),
|
||||
dueDate: record.dueDate ? record.dueDate.toISOString() : null,
|
||||
updatedAt: record.updatedAt.toISOString(),
|
||||
};
|
||||
}
|
||||
|
||||
function mapProjectDetail(record: ProjectRecord): ProjectDetailDto {
|
||||
return {
|
||||
...mapProjectSummary(record),
|
||||
notes: record.notes,
|
||||
createdAt: record.createdAt.toISOString(),
|
||||
salesQuoteId: record.salesQuote?.id ?? null,
|
||||
salesQuoteNumber: record.salesQuote?.documentNumber ?? null,
|
||||
salesOrderId: record.salesOrder?.id ?? null,
|
||||
salesOrderNumber: record.salesOrder?.documentNumber ?? null,
|
||||
shipmentId: record.shipment?.id ?? null,
|
||||
shipmentNumber: record.shipment?.shipmentNumber ?? null,
|
||||
customerEmail: record.customer.email,
|
||||
customerPhone: record.customer.phone,
|
||||
};
|
||||
}
|
||||
|
||||
function buildInclude() {
|
||||
return {
|
||||
customer: {
|
||||
select: {
|
||||
id: true,
|
||||
name: true,
|
||||
email: true,
|
||||
phone: true,
|
||||
},
|
||||
},
|
||||
owner: {
|
||||
select: {
|
||||
id: true,
|
||||
firstName: true,
|
||||
lastName: true,
|
||||
},
|
||||
},
|
||||
salesQuote: {
|
||||
select: {
|
||||
id: true,
|
||||
documentNumber: true,
|
||||
},
|
||||
},
|
||||
salesOrder: {
|
||||
select: {
|
||||
id: true,
|
||||
documentNumber: true,
|
||||
},
|
||||
},
|
||||
shipment: {
|
||||
select: {
|
||||
id: true,
|
||||
shipmentNumber: true,
|
||||
},
|
||||
},
|
||||
};
|
||||
}
|
||||
|
||||
async function nextProjectNumber() {
|
||||
const next = (await projectModel.count()) + 1;
|
||||
return `PRJ-${String(next).padStart(5, "0")}`;
|
||||
}
|
||||
|
||||
async function validateProjectInput(payload: ProjectInput) {
|
||||
const customer = await prisma.customer.findUnique({
|
||||
where: { id: payload.customerId },
|
||||
select: { id: true },
|
||||
});
|
||||
|
||||
if (!customer) {
|
||||
return { ok: false as const, reason: "Customer was not found." };
|
||||
}
|
||||
|
||||
if (payload.ownerId) {
|
||||
const owner = await prisma.user.findUnique({
|
||||
where: { id: payload.ownerId },
|
||||
select: { id: true, isActive: true },
|
||||
});
|
||||
|
||||
if (!owner?.isActive) {
|
||||
return { ok: false as const, reason: "Project owner was not found." };
|
||||
}
|
||||
}
|
||||
|
||||
if (payload.salesQuoteId) {
|
||||
const quote = await prisma.salesQuote.findUnique({
|
||||
where: { id: payload.salesQuoteId },
|
||||
select: { id: true, customerId: true },
|
||||
});
|
||||
|
||||
if (!quote) {
|
||||
return { ok: false as const, reason: "Linked quote was not found." };
|
||||
}
|
||||
|
||||
if (quote.customerId !== payload.customerId) {
|
||||
return { ok: false as const, reason: "Linked quote must belong to the selected customer." };
|
||||
}
|
||||
}
|
||||
|
||||
if (payload.salesOrderId) {
|
||||
const order = await prisma.salesOrder.findUnique({
|
||||
where: { id: payload.salesOrderId },
|
||||
select: { id: true, customerId: true },
|
||||
});
|
||||
|
||||
if (!order) {
|
||||
return { ok: false as const, reason: "Linked sales order was not found." };
|
||||
}
|
||||
|
||||
if (order.customerId !== payload.customerId) {
|
||||
return { ok: false as const, reason: "Linked sales order must belong to the selected customer." };
|
||||
}
|
||||
}
|
||||
|
||||
if (payload.shipmentId) {
|
||||
const shipment = await prisma.shipment.findUnique({
|
||||
where: { id: payload.shipmentId },
|
||||
include: {
|
||||
salesOrder: {
|
||||
select: {
|
||||
customerId: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
if (!shipment) {
|
||||
return { ok: false as const, reason: "Linked shipment was not found." };
|
||||
}
|
||||
|
||||
if (shipment.salesOrder.customerId !== payload.customerId) {
|
||||
return { ok: false as const, reason: "Linked shipment must belong to the selected customer." };
|
||||
}
|
||||
}
|
||||
|
||||
return { ok: true as const };
|
||||
}
|
||||
|
||||
export async function listProjectCustomerOptions(): Promise<ProjectCustomerOptionDto[]> {
|
||||
const customers = await prisma.customer.findMany({
|
||||
where: {
|
||||
status: {
|
||||
not: "INACTIVE",
|
||||
},
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
name: true,
|
||||
email: true,
|
||||
},
|
||||
orderBy: [{ name: "asc" }],
|
||||
});
|
||||
|
||||
return customers;
|
||||
}
|
||||
|
||||
export async function listProjectOwnerOptions(): Promise<ProjectOwnerOptionDto[]> {
|
||||
const users = await prisma.user.findMany({
|
||||
where: {
|
||||
isActive: true,
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
firstName: true,
|
||||
lastName: true,
|
||||
email: true,
|
||||
},
|
||||
orderBy: [{ firstName: "asc" }, { lastName: "asc" }],
|
||||
});
|
||||
|
||||
return users.map((user) => ({
|
||||
id: user.id,
|
||||
fullName: `${user.firstName} ${user.lastName}`.trim(),
|
||||
email: user.email,
|
||||
}));
|
||||
}
|
||||
|
||||
export async function listProjectQuoteOptions(customerId?: string | null): Promise<ProjectDocumentOptionDto[]> {
|
||||
const quotes = await prisma.salesQuote.findMany({
|
||||
where: {
|
||||
...(customerId ? { customerId } : {}),
|
||||
},
|
||||
include: {
|
||||
customer: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
orderBy: [{ issueDate: "desc" }, { createdAt: "desc" }],
|
||||
});
|
||||
|
||||
return quotes.map((quote) => ({
|
||||
id: quote.id,
|
||||
documentNumber: quote.documentNumber,
|
||||
customerName: quote.customer.name,
|
||||
status: quote.status,
|
||||
}));
|
||||
}
|
||||
|
||||
export async function listProjectOrderOptions(customerId?: string | null): Promise<ProjectDocumentOptionDto[]> {
|
||||
const orders = await prisma.salesOrder.findMany({
|
||||
where: {
|
||||
...(customerId ? { customerId } : {}),
|
||||
},
|
||||
include: {
|
||||
customer: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
orderBy: [{ issueDate: "desc" }, { createdAt: "desc" }],
|
||||
});
|
||||
|
||||
return orders.map((order) => ({
|
||||
id: order.id,
|
||||
documentNumber: order.documentNumber,
|
||||
customerName: order.customer.name,
|
||||
status: order.status,
|
||||
}));
|
||||
}
|
||||
|
||||
export async function listProjectShipmentOptions(customerId?: string | null): Promise<ProjectShipmentOptionDto[]> {
|
||||
const shipments = await prisma.shipment.findMany({
|
||||
where: {
|
||||
...(customerId ? { salesOrder: { customerId } } : {}),
|
||||
},
|
||||
include: {
|
||||
salesOrder: {
|
||||
include: {
|
||||
customer: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
orderBy: [{ createdAt: "desc" }],
|
||||
});
|
||||
|
||||
return shipments.map((shipment) => ({
|
||||
id: shipment.id,
|
||||
shipmentNumber: shipment.shipmentNumber,
|
||||
salesOrderNumber: shipment.salesOrder.documentNumber,
|
||||
customerName: shipment.salesOrder.customer.name,
|
||||
status: shipment.status,
|
||||
}));
|
||||
}
|
||||
|
||||
export async function listProjects(filters: {
|
||||
q?: string;
|
||||
status?: ProjectStatus;
|
||||
priority?: ProjectPriority;
|
||||
customerId?: string;
|
||||
ownerId?: string;
|
||||
} = {}) {
|
||||
const query = filters.q?.trim();
|
||||
const projects = await projectModel.findMany({
|
||||
where: {
|
||||
...(filters.status ? { status: filters.status } : {}),
|
||||
...(filters.priority ? { priority: filters.priority } : {}),
|
||||
...(filters.customerId ? { customerId: filters.customerId } : {}),
|
||||
...(filters.ownerId ? { ownerId: filters.ownerId } : {}),
|
||||
...(query
|
||||
? {
|
||||
OR: [
|
||||
{ projectNumber: { contains: query } },
|
||||
{ name: { contains: query } },
|
||||
{ customer: { name: { contains: query } } },
|
||||
],
|
||||
}
|
||||
: {}),
|
||||
},
|
||||
include: buildInclude(),
|
||||
orderBy: [{ dueDate: "asc" }, { updatedAt: "desc" }],
|
||||
});
|
||||
|
||||
return projects.map((project: unknown) => mapProjectSummary(project as ProjectRecord));
|
||||
}
|
||||
|
||||
export async function getProjectById(projectId: string) {
|
||||
const project = await projectModel.findUnique({
|
||||
where: { id: projectId },
|
||||
include: buildInclude(),
|
||||
});
|
||||
|
||||
return project ? mapProjectDetail(project as ProjectRecord) : null;
|
||||
}
|
||||
|
||||
export async function createProject(payload: ProjectInput) {
|
||||
const validated = await validateProjectInput(payload);
|
||||
if (!validated.ok) {
|
||||
return { ok: false as const, reason: validated.reason };
|
||||
}
|
||||
|
||||
const projectNumber = await nextProjectNumber();
|
||||
const created = await projectModel.create({
|
||||
data: {
|
||||
projectNumber,
|
||||
name: payload.name.trim(),
|
||||
status: payload.status,
|
||||
priority: payload.priority,
|
||||
customerId: payload.customerId,
|
||||
salesQuoteId: payload.salesQuoteId,
|
||||
salesOrderId: payload.salesOrderId,
|
||||
shipmentId: payload.shipmentId,
|
||||
ownerId: payload.ownerId,
|
||||
dueDate: payload.dueDate ? new Date(payload.dueDate) : null,
|
||||
notes: payload.notes,
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
},
|
||||
});
|
||||
|
||||
const project = await getProjectById(created.id);
|
||||
return project ? { ok: true as const, project } : { ok: false as const, reason: "Unable to load saved project." };
|
||||
}
|
||||
|
||||
export async function updateProject(projectId: string, payload: ProjectInput) {
|
||||
const existing = await projectModel.findUnique({
|
||||
where: { id: projectId },
|
||||
select: { id: true },
|
||||
});
|
||||
|
||||
if (!existing) {
|
||||
return { ok: false as const, reason: "Project was not found." };
|
||||
}
|
||||
|
||||
const validated = await validateProjectInput(payload);
|
||||
if (!validated.ok) {
|
||||
return { ok: false as const, reason: validated.reason };
|
||||
}
|
||||
|
||||
await projectModel.update({
|
||||
where: { id: projectId },
|
||||
data: {
|
||||
name: payload.name.trim(),
|
||||
status: payload.status,
|
||||
priority: payload.priority,
|
||||
customerId: payload.customerId,
|
||||
salesQuoteId: payload.salesQuoteId,
|
||||
salesOrderId: payload.salesOrderId,
|
||||
shipmentId: payload.shipmentId,
|
||||
ownerId: payload.ownerId,
|
||||
dueDate: payload.dueDate ? new Date(payload.dueDate) : null,
|
||||
notes: payload.notes,
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
},
|
||||
});
|
||||
|
||||
const project = await getProjectById(projectId);
|
||||
return project ? { ok: true as const, project } : { ok: false as const, reason: "Unable to load saved project." };
|
||||
}
|
||||
Reference in New Issue
Block a user