wangsli/hyb-oa
1
0
派生 0
代码 工单 合并请求 工作流 8 软件包 项目 发布 百科 活动

feat(G2-1,G2-2,G2-3): 扩展预算编号与工作流跨域桥接

浏览代码
这个提交包含在：
wangsli
2026-03-07 18:59:44 +08:00
父节点 09b6f4fbb0
当前提交 52558f22c3
共修改 12 个文件，包含 1211 行新增和 175 行删除
下载 Patch 文件 下载 Diff 文件 展开所有文件 折叠所有文件
server/src/constants/permissions.js
+16
查看文件
@@ -55,6 +55,22 @@ const ENTITY_PERMISSION_MAP = {
approve: "leave.approve",
manage: "leave.manage",
},
purchase_request: {
create: "procurement.create",
view_own: "procurement.view_own",
view_all: "procurement.view_all",
submit: "procurement.submit",
approve: "procurement.approve",
manage: "procurement.manage",
},
procurement: {
create: "procurement.create",
view_own: "procurement.view_own",
view_all: "procurement.view_all",
submit: "procurement.submit",
approve: "procurement.approve",
manage: "procurement.manage",
},
};
const ROLE_PERMISSIONS = {
server/src/routes/budgets.js
+213 -52
查看文件
@@ -3,16 +3,26 @@ const { z } = require("zod");
const { AppError } = require("../utils/AppError");
const { sendData } = require("../utils/reply");
const { buildAuditLogData } = require("../utils/audit");
const {
resolveBudgetScope,
resolveBudgetScopeType,
} = require("../services/budgetPool");
const BUDGET_CREATE_SCHEMA = z.object({
code: z.string().trim().min(2).max(32),
name: z.string().trim().min(1).max(120),
departmentId: z.string().uuid().nullable().optional(),
periodStart: z.string().regex(/^\d{4}-\d{2}-\d{2}$/),
periodEnd: z.string().regex(/^\d{4}-\d{2}-\d{2}$/),
allocatedAmount: z.string().regex(/^\d+(?:\.\d{1,2})?$/),
warningThresholdPercent: z.coerce.number().int().min(1).max(100).optional(),
});
const UUID_SCHEMA = z.string().uuid();
const BUDGET_CREATE_SCHEMA = z
.object({
code: z.string().trim().min(2).max(32),
name: z.string().trim().min(1).max(120),
departmentId: UUID_SCHEMA.nullable().optional(),
legalEntityId: UUID_SCHEMA.nullable().optional(),
costCenterId: UUID_SCHEMA.nullable().optional(),
periodStart: z.string().regex(/^\d{4}-\d{2}-\d{2}$/),
periodEnd: z.string().regex(/^\d{4}-\d{2}-\d{2}$/),
allocatedAmount: z.string().regex(/^\d+(?:\.\d{1,2})?$/),
warningThresholdPercent: z.coerce.number().int().min(1).max(100).optional(),
})
.strict();
const BUDGET_PATCH_SCHEMA = z
.object({
@@ -25,11 +35,46 @@ const BUDGET_PATCH_SCHEMA = z
const BUDGET_LIST_QUERY_SCHEMA = z.object({
status: z.enum(["active", "archived"]).optional(),
departmentId: z.string().uuid().optional(),
departmentId: UUID_SCHEMA.optional(),
legalEntityId: UUID_SCHEMA.optional(),
costCenterId: UUID_SCHEMA.optional(),
page: z.coerce.number().int().min(1).optional(),
pageSize: z.coerce.number().int().min(1).max(100).optional(),
});
const BUDGET_RELATION_SELECT = {
department: {
select: {
id: true,
name: true,
},
},
legal_entity: {
select: {
id: true,
code: true,
name: true,
},
},
cost_center: {
select: {
id: true,
code: true,
name: true,
legal_entity_id: true,
},
},
};
function buildValidationError(details, statusCode = 400) {
return new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode,
details,
});
}
function toDate(value) {
return new Date(`${value}T00:00:00.000Z`);
}
@@ -46,12 +91,37 @@ function mapBudget(item) {
const allocated = Number(item.allocated_amount ?? 0);
const used = Number(item.used_amount ?? 0);
const remaining = allocated - used;
const scopeType = resolveBudgetScopeType(item);
return {
id: item.id,
code: item.code,
name: item.name,
scopeType,
departmentId: item.department_id ?? null,
legalEntityId: item.legal_entity_id ?? null,
costCenterId: item.cost_center_id ?? null,
department: item.department
? {
id: item.department.id,
name: item.department.name,
}
: null,
legalEntity: item.legal_entity
? {
id: item.legal_entity.id,
code: item.legal_entity.code,
name: item.legal_entity.name,
}
: null,
costCenter: item.cost_center
? {
id: item.cost_center.id,
code: item.cost_center.code,
name: item.cost_center.name,
legalEntityId: item.cost_center.legal_entity_id,
}
: null,
status: item.status,
periodStart: item.period_start?.toISOString?.()?.slice(0, 10) ?? null,
periodEnd: item.period_end?.toISOString?.()?.slice(0, 10) ?? null,
@@ -66,19 +136,105 @@ function mapBudget(item) {
}
function parseBudgetId(value) {
const parsed = z.string().uuid().safeParse(value);
const parsed = UUID_SCHEMA.safeParse(value);
if (!parsed.success) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: { id: "invalid_uuid" },
});
throw buildValidationError({ id: "invalid_uuid" });
}
return parsed.data;
}
async function ensureDepartmentAvailable(tx, departmentId) {
if (!departmentId) {
return null;
}
const department = await tx.department.findUnique({
where: { id: departmentId },
select: { id: true, name: true, archived_at: true },
});
if (!department) {
throw buildValidationError({ departmentId: "not_found" });
}
if (department.archived_at) {
throw buildValidationError({ departmentId: "archived" }, 409);
}
return department;
}
async function ensureLegalEntityAvailable(tx, legalEntityId) {
if (!legalEntityId) {
return null;
}
const legalEntity = await tx.legalEntity.findUnique({
where: { id: legalEntityId },
select: { id: true, code: true, name: true, archived_at: true, enabled: true },
});
if (!legalEntity) {
throw buildValidationError({ legalEntityId: "not_found" });
}
if (legalEntity.archived_at || !legalEntity.enabled) {
throw buildValidationError({ legalEntityId: "disabled_or_archived" }, 409);
}
return legalEntity;
}
async function ensureCostCenterAvailable(tx, { costCenterId, legalEntityId }) {
if (!costCenterId) {
return null;
}
const costCenter = await tx.costCenter.findUnique({
where: { id: costCenterId },
select: {
id: true,
code: true,
name: true,
legal_entity_id: true,
archived_at: true,
enabled: true,
},
});
if (!costCenter) {
throw buildValidationError({ costCenterId: "not_found" });
}
if (costCenter.archived_at || !costCenter.enabled) {
throw buildValidationError({ costCenterId: "disabled_or_archived" }, 409);
}
if (legalEntityId && costCenter.legal_entity_id !== legalEntityId) {
throw buildValidationError({ costCenterId: "legalEntityId_mismatch" }, 409);
}
return costCenter;
}
async function fetchBudgetPoolOrThrow(tx, budgetId) {
const budget = await tx.budgetPool.findUnique({
where: { id: budgetId },
include: BUDGET_RELATION_SELECT,
});
if (!budget) {
throw new AppError({
code: "SYS_404",
message: "Not Found",
statusCode: 404,
});
}
return budget;
}
async function budgetsRoutes(fastify) {
fastify.get(
"/budgets",
@@ -88,12 +244,7 @@ async function budgetsRoutes(fastify) {
async (request, reply) => {
const parsed = BUDGET_LIST_QUERY_SCHEMA.safeParse(request.query ?? {});
if (!parsed.success) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: parsed.error.flatten(),
});
throw buildValidationError(parsed.error.flatten());
}
const query = parsed.data;
@@ -104,6 +255,8 @@ async function budgetsRoutes(fastify) {
const where = {
...(query.status ? { status: query.status } : {}),
...(query.departmentId ? { department_id: query.departmentId } : {}),
...(query.legalEntityId ? { legal_entity_id: query.legalEntityId } : {}),
...(query.costCenterId ? { cost_center_id: query.costCenterId } : {}),
};
const [items, total] = await Promise.all([
@@ -112,6 +265,7 @@ async function budgetsRoutes(fastify) {
orderBy: [{ period_start: "desc" }, { created_at: "desc" }],
skip,
take: pageSize,
include: BUDGET_RELATION_SELECT,
}),
fastify.prisma.budgetPool.count({ where }),
]);
@@ -133,31 +287,36 @@ async function budgetsRoutes(fastify) {
async (request, reply) => {
const parsed = BUDGET_CREATE_SCHEMA.safeParse(request.body ?? {});
if (!parsed.success) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: parsed.error.flatten(),
});
throw buildValidationError(parsed.error.flatten());
}
const body = parsed.data;
const start = toDate(body.periodStart);
const end = toDate(body.periodEnd);
if (start > end) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: { periodEnd: "must_be_after_periodStart" },
});
throw buildValidationError({ periodEnd: "must_be_after_periodStart" });
}
const scope = resolveBudgetScope({
departmentId: body.departmentId ?? null,
legalEntityId: body.legalEntityId ?? null,
costCenterId: body.costCenterId ?? null,
});
await ensureDepartmentAvailable(fastify.prisma, scope.departmentId);
await ensureLegalEntityAvailable(fastify.prisma, scope.legalEntityId);
await ensureCostCenterAvailable(fastify.prisma, {
costCenterId: scope.costCenterId,
legalEntityId: scope.legalEntityId,
});
const created = await fastify.prisma.budgetPool.create({
data: {
code: body.code.toUpperCase(),
name: body.name,
department_id: body.departmentId ?? null,
code: body.code.trim().toUpperCase(),
name: body.name.trim(),
department_id: scope.departmentId,
legal_entity_id: scope.legalEntityId,
cost_center_id: scope.costCenterId,
status: "active",
period_start: start,
period_end: end,
@@ -167,6 +326,7 @@ async function budgetsRoutes(fastify) {
created_by: request.employee.id,
updated_by: request.employee.id,
},
include: BUDGET_RELATION_SELECT,
});
await fastify.prisma.auditLog.create({
@@ -177,6 +337,10 @@ async function budgetsRoutes(fastify) {
targetId: created.id,
extra: {
code: created.code,
scopeType: scope.scopeType,
departmentId: scope.departmentId,
legalEntityId: scope.legalEntityId,
costCenterId: scope.costCenterId,
allocatedAmount: created.allocated_amount,
},
}),
@@ -195,36 +359,30 @@ async function budgetsRoutes(fastify) {
const budgetId = parseBudgetId(request.params?.id);
const parsed = BUDGET_PATCH_SCHEMA.safeParse(request.body ?? {});
if (!parsed.success) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: parsed.error.flatten(),
});
throw buildValidationError(parsed.error.flatten());
}
if (!Object.keys(parsed.data).length) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: { body: "empty_patch" },
});
throw buildValidationError({ body: "empty_patch" });
}
await fetchBudgetPoolOrThrow(fastify.prisma, budgetId);
const patch = parsed.data;
const updated = await fastify.prisma.budgetPool.update({
where: { id: budgetId },
data: {
...(patch.name != null ? { name: patch.name } : {}),
...(patch.name != null ? { name: patch.name.trim() } : {}),
...(patch.allocatedAmount != null ? { allocated_amount: patch.allocatedAmount } : {}),
...(patch.warningThresholdPercent != null
? { warning_threshold_percent: patch.warningThresholdPercent }
: {}),
...(patch.status ? { status: patch.status } : {}),
...(patch.status === "archived" ? { archived_at: new Date() } : {}),
...(patch.status === "active" ? { archived_at: null } : {}),
updated_by: request.employee.id,
},
include: BUDGET_RELATION_SELECT,
});
await fastify.prisma.auditLog.create({
@@ -250,6 +408,7 @@ async function budgetsRoutes(fastify) {
},
async (request, reply) => {
const budgetId = parseBudgetId(request.params?.id);
const current = await fetchBudgetPoolOrThrow(fastify.prisma, budgetId);
const updated = await fastify.prisma.budgetPool.update({
where: { id: budgetId },
@@ -258,6 +417,7 @@ async function budgetsRoutes(fastify) {
archived_at: new Date(),
updated_by: request.employee.id,
},
include: BUDGET_RELATION_SELECT,
});
await fastify.prisma.auditLog.create({
@@ -267,7 +427,8 @@ async function budgetsRoutes(fastify) {
targetType: "budget_pool",
targetId: budgetId,
extra: {
code: updated.code,
code: current.code,
scopeType: resolveBudgetScopeType(current),
},
}),
});
server/src/routes/configRead.js
+55 -46
查看文件
@@ -2,11 +2,19 @@ const { z } = require("zod");
const { AppError } = require("../utils/AppError");
const { sendData } = require("../utils/reply");
const {
normalizeDocumentType,
resolveDocumentSequenceConfig,
} = require("../services/documentSequence");
const ENABLED_QUERY_SCHEMA = z.object({
enabled: z.enum(["true", "false", "1", "0"]).optional(),
});
const DOCUMENT_TYPE_PARAM_SCHEMA = z.object({
documentType: z.string().trim().min(1).max(64).regex(/^[a-z_]+$/),
});
function parseEnabledQuery(query) {
const parsed = ENABLED_QUERY_SCHEMA.safeParse(query ?? {});
if (!parsed.success) {
@@ -31,6 +39,20 @@ function parseEnabledQuery(query) {
return { enabled };
}
function parseDocumentTypeParams(params) {
const parsed = DOCUMENT_TYPE_PARAM_SCHEMA.safeParse(params ?? {});
if (!parsed.success) {
throw new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode: 400,
details: parsed.error.flatten(),
});
}
return normalizeDocumentType(parsed.data.documentType);
}
function mapApprovalRule(item) {
return {
id: item.id,
@@ -47,39 +69,30 @@ function mapApprovalRule(item) {
};
}
function mapDocumentSequence(item, exists) {
const fallback = {
documentType: "reimbursement",
prefix: "BX",
dateFormat: "YYYYMMDD",
separator: "-",
numberLength: 4,
resetPeriod: "none",
currentNumber: 0,
lastResetDate: null,
updatedAt: null,
updatedBy: null,
};
if (!item) {
return { exists, ...fallback };
}
function mapDocumentSequence(config) {
return {
exists,
documentType: item.document_type,
prefix: item.prefix,
dateFormat: item.date_format,
separator: item.separator,
numberLength: item.number_length,
resetPeriod: item.reset_period,
currentNumber: item.current_number,
lastResetDate: item.last_reset_date?.toISOString?.()?.slice(0, 10) ?? null,
updatedAt: item.updated_at?.toISOString?.() ?? null,
updatedBy: item.updated_by ?? null,
exists: Boolean(config.exists),
source: config.source,
documentType: config.documentType,
documentCategoryCode: config.documentCategoryCode ?? null,
prefix: config.prefix,
dateFormat: config.dateFormat,
separator: config.separator,
numberLength: config.numberLength,
resetPeriod: config.resetPeriod,
currentNumber: config.currentNumber,
lastResetDate: config.lastResetDate ?? null,
updatedAt: config.updatedAt ?? null,
updatedBy: config.updatedBy ?? null,
};
}
async function loadDocumentSequenceConfig(fastify, documentType) {
return resolveDocumentSequenceConfig(fastify.prisma, {
documentType,
});
}
async function configReadRoutes(fastify) {
fastify.get(
"/approval-rules",
@@ -122,26 +135,22 @@ async function configReadRoutes(fastify) {
preHandler: fastify.requirePermission("system.settings"),
},
async (request, reply) => {
const sequence = await fastify.prisma.documentSequence.findUnique({
where: { document_type: "reimbursement" },
select: {
document_type: true,
prefix: true,
date_format: true,
separator: true,
number_length: true,
reset_period: true,
current_number: true,
last_reset_date: true,
updated_at: true,
updated_by: true,
},
});
const config = await loadDocumentSequenceConfig(fastify, "reimbursement");
return sendData(reply, request, mapDocumentSequence(config));
},
);
return sendData(reply, request, mapDocumentSequence(sequence, Boolean(sequence)));
fastify.get(
"/document-sequences/:documentType",
{
preHandler: fastify.requirePermission("system.settings"),
},
async (request, reply) => {
const documentType = parseDocumentTypeParams(request.params);
const config = await loadDocumentSequenceConfig(fastify, documentType);
return sendData(reply, request, mapDocumentSequence(config));
},
);
}
module.exports = configReadRoutes;
server/src/routes/reimbursements.js
+12 -39
查看文件
@@ -2,7 +2,7 @@ const { z } = require("zod");
const { AppError } = require("../utils/AppError");
const { sendData } = require("../utils/reply");
const { buildAuditLogData } = require("../utils/audit");
const { compactDateString, currentDateString, parseDateOnlyString } = require("../utils/date");
const { currentDateString, parseDateOnlyString } = require("../utils/date");
const { findActiveDelegationForDelegate } = require("../utils/delegation");
const {
createNotifications,
@@ -12,6 +12,8 @@ const { sendNotificationEmailSafe } = require("../services/email");
const { enqueueIntegrationEvent } = require("../services/integrations/outbox");
const { buildErpPayload } = require("../services/integrations/erp");
const { FEATURE_FLAG_KEYS, evaluateFeatureFlag } = require("../services/featureFlags");
const { resolveApplicableBudgetPoolByContext } = require("../services/budgetPool");
const { issueDocumentNumber } = require("../services/documentSequence");
const {
buildWorkflowStepsFromApprovalRule,
resolveActionableStep,
@@ -90,12 +92,6 @@ function ensureApplicantOrAdmin(request, reimbursement) {
}
}
function formatFormNumber(sequence, timezone) {
const datePart = compactDateString(timezone);
const serial = String(sequence.current_number).padStart(sequence.number_length, "0");
return `${sequence.prefix}${sequence.separator}${datePart}${sequence.separator}${serial}`;
}
function parseWithdrawBody(body) {
const bodySchema = z.object({
comment: z.string().trim().min(1).max(500).optional(),
@@ -350,14 +346,9 @@ async function loadApprovalRuleForAmount(tx, totalAmount) {
}
async function resolveApplicableBudgetPool(tx, reimbursement) {
return tx.budgetPool.findFirst({
where: {
status: "active",
OR: [{ department_id: reimbursement.department_id }, { department_id: null }],
period_start: { lte: reimbursement.reimbursement_date },
period_end: { gte: reimbursement.reimbursement_date },
},
orderBy: [{ department_id: "desc" }, { created_at: "asc" }],
return resolveApplicableBudgetPoolByContext(tx, {
departmentId: reimbursement.department_id,
effectiveDate: reimbursement.reimbursement_date,
});
}
@@ -1204,7 +1195,7 @@ async function reimbursementRoutes(fastify) {
await fastify.prisma.$transaction(async (tx) => {
const reimbursementRows = await tx.$queryRaw`
SELECT id, owner_id, submitter_id, department_id, status, form_number, total_amount
SELECT id, owner_id, submitter_id, department_id, reimbursement_date, status, form_number, total_amount
FROM "reimbursement_forms"
WHERE id = ${reimbursementId}::uuid
FOR UPDATE
@@ -1371,31 +1362,13 @@ async function reimbursementRoutes(fastify) {
let formNumber = reimbursement.form_number;
if (!formNumber) {
const sequence = await tx.documentSequence.upsert({
where: { document_type: "reimbursement" },
update: {
current_number: { increment: 1 },
updated_by: request.employee.id,
},
create: {
document_type: "reimbursement",
prefix: "BX",
date_format: "YYYYMMDD",
separator: "-",
number_length: 4,
reset_period: "none",
current_number: 1,
updated_by: request.employee.id,
},
select: {
prefix: true,
separator: true,
number_length: true,
current_number: true,
},
const issued = await issueDocumentNumber(tx, {
documentType: "reimbursement",
actorId: request.employee.id,
timeZone: fastify.config.appTimezone,
});
formNumber = formatFormNumber(sequence, fastify.config.appTimezone);
formNumber = issued.documentNumber;
}
await tx.reimbursementForm.update({
server/src/routes/workflow.js
+127 -26
查看文件
@@ -335,6 +335,77 @@ async function loadReimbursementNotifyContext(tx, reimbursementId) {
});
}
function getWorkflowEntityMeta(entityType, entityRecord, entityId) {
const normalizedEntityType = entityType === "procurement" ? "purchase_request" : entityType;
if (normalizedEntityType === "reimbursement") {
return {
label: "报销单",
reference: entityRecord?.form_number ?? entityId,
targetType: "reimbursement_form",
detailPath: `/reimbursements/${entityId}`,
};
}
if (normalizedEntityType === "leave") {
return {
label: "请假单",
reference: entityId,
targetType: "leave_request",
detailPath: "/leave-requests",
};
}
if (normalizedEntityType === "purchase_request") {
return {
label: "采购申请",
reference: entityRecord?.request_no ?? entityId,
targetType: "purchase_request",
detailPath: "/purchase-requests",
};
}
return {
label: "审批单",
reference: entityId,
targetType: normalizedEntityType,
detailPath: `/workflow/tasks/${entityId}`,
};
}
function buildPendingTaskCopy(entityMeta, { transfer = false } = {}) {
return {
title: `【待办】${entityMeta.label} ${entityMeta.reference} ${transfer ? "转审待处理" : "待审批"}`,
body: transfer
? `${entityMeta.label} ${entityMeta.reference} 已转审给你，请及时处理。`
: `${entityMeta.label} ${entityMeta.reference} 已流转到你，请及时处理。`,
};
}
function buildApprovedCopy(entityMeta) {
return {
title: `【已批准】${entityMeta.label} ${entityMeta.reference}`,
body:
entityMeta.targetType === "reimbursement_form"
? `${entityMeta.label} ${entityMeta.reference} 已审批通过，等待财务付款。`
: `${entityMeta.label} ${entityMeta.reference} 已审批通过。`,
};
}
function buildRejectedCopy(entityMeta, comment) {
return {
title: `【已驳回】${entityMeta.label} ${entityMeta.reference}`,
body: `${entityMeta.label} ${entityMeta.reference} 已被驳回：${comment}`,
};
}
function buildReturnedCopy(entityMeta, comment) {
return {
title: `【已退回】${entityMeta.label} ${entityMeta.reference}`,
body: `${entityMeta.label} ${entityMeta.reference} 已退回：${comment}`,
};
}
async function createSkipHistoryRecords(tx, workflowInstanceId, actorId, ownerId, skippedSteps) {
for (const skipped of skippedSteps) {
await tx.workflowHistory.create({
@@ -892,6 +963,12 @@ async function workflowRoutes(fastify) {
tx,
workflowInstance.entity_id,
);
const entityMeta = getWorkflowEntityMeta(
workflowInstance.entity_type,
reimbursement,
workflowInstance.entity_id,
);
const pendingCopy = buildPendingTaskCopy(entityMeta);
const recipients = await resolveRecipientsForAssignee(tx, {
assigneeId: actionable.assigneeId,
assigneeRole: actionable.assigneeRole,
@@ -900,8 +977,8 @@ async function workflowRoutes(fastify) {
await createNotifications(tx, {
recipientEmployeeIds: recipients,
type: "workflow.task_assigned",
title: `【待办】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 待审批`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已流转到你，请及时处理。`,
title: pendingCopy.title,
body: pendingCopy.body,
targetType: "workflow_task",
targetId: nextTask.id,
});
@@ -909,8 +986,8 @@ async function workflowRoutes(fastify) {
emailTasks.push({
type: "workflow.task_assigned",
recipientEmployeeIds: recipients,
subject: `【待办】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 待审批`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已流转到你，请及时处理。`,
subject: pendingCopy.title,
body: pendingCopy.body,
targetPath: `/workflow/tasks/${nextTask.id}`,
});
} catch (error) {
@@ -1013,6 +1090,12 @@ async function workflowRoutes(fastify) {
if (workflowInstance.entity_type === "reimbursement") {
try {
const reimbursement = await loadReimbursementNotifyContext(tx, workflowInstance.entity_id);
const entityMeta = getWorkflowEntityMeta(
workflowInstance.entity_type,
reimbursement,
workflowInstance.entity_id,
);
const approvedCopy = buildApprovedCopy(entityMeta);
const recipients = Array.from(
new Set([reimbursement?.owner_id, reimbursement?.submitter_id].filter(Boolean)),
);
@@ -1020,18 +1103,18 @@ async function workflowRoutes(fastify) {
await createNotifications(tx, {
recipientEmployeeIds: recipients,
type: "reimbursement.approved",
title: `【已批准】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id}`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已审批通过，等待财务付款。`,
targetType: "reimbursement_form",
title: approvedCopy.title,
body: approvedCopy.body,
targetType: entityMeta.targetType,
targetId: workflowInstance.entity_id,
});
emailTasks.push({
type: "reimbursement.approved",
recipientEmployeeIds: recipients,
subject: `【已批准】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id}`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已审批通过，等待财务付款。`,
targetPath: `/reimbursements/${workflowInstance.entity_id}`,
subject: approvedCopy.title,
body: approvedCopy.body,
targetPath: entityMeta.detailPath,
});
} catch (error) {
fastify.log.error(
@@ -1179,6 +1262,12 @@ async function workflowRoutes(fastify) {
if (workflowInstance.entity_type === "reimbursement") {
try {
const reimbursement = await loadReimbursementNotifyContext(tx, workflowInstance.entity_id);
const entityMeta = getWorkflowEntityMeta(
workflowInstance.entity_type,
reimbursement,
workflowInstance.entity_id,
);
const rejectedCopy = buildRejectedCopy(entityMeta, comment);
const recipients = Array.from(
new Set([reimbursement?.owner_id, reimbursement?.submitter_id].filter(Boolean)),
);
@@ -1186,18 +1275,18 @@ async function workflowRoutes(fastify) {
await createNotifications(tx, {
recipientEmployeeIds: recipients,
type: "reimbursement.rejected",
title: `【已驳回】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id}`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已被驳回：${comment}`,
targetType: "reimbursement_form",
title: rejectedCopy.title,
body: rejectedCopy.body,
targetType: entityMeta.targetType,
targetId: workflowInstance.entity_id,
});
emailTasks.push({
type: "reimbursement.rejected",
recipientEmployeeIds: recipients,
subject: `【已驳回】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id}`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已被驳回：${comment}`,
targetPath: `/reimbursements/${workflowInstance.entity_id}`,
subject: rejectedCopy.title,
body: rejectedCopy.body,
targetPath: entityMeta.detailPath,
});
} catch (error) {
fastify.log.error(
@@ -1344,6 +1433,12 @@ async function workflowRoutes(fastify) {
if (workflowInstance.entity_type === "reimbursement") {
try {
const reimbursement = await loadReimbursementNotifyContext(tx, workflowInstance.entity_id);
const entityMeta = getWorkflowEntityMeta(
workflowInstance.entity_type,
reimbursement,
workflowInstance.entity_id,
);
const returnedCopy = buildReturnedCopy(entityMeta, comment);
const recipients = Array.from(
new Set([reimbursement?.owner_id, reimbursement?.submitter_id].filter(Boolean)),
);
@@ -1351,18 +1446,18 @@ async function workflowRoutes(fastify) {
await createNotifications(tx, {
recipientEmployeeIds: recipients,
type: "reimbursement.returned",
title: `【已退回】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id}`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已退回：${comment}`,
targetType: "reimbursement_form",
title: returnedCopy.title,
body: returnedCopy.body,
targetType: entityMeta.targetType,
targetId: workflowInstance.entity_id,
});
emailTasks.push({
type: "reimbursement.returned",
recipientEmployeeIds: recipients,
subject: `【已退回】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id}`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已退回：${comment}`,
targetPath: `/reimbursements/${workflowInstance.entity_id}`,
subject: returnedCopy.title,
body: returnedCopy.body,
targetPath: entityMeta.detailPath,
});
} catch (error) {
fastify.log.error(
@@ -1475,11 +1570,17 @@ async function workflowRoutes(fastify) {
try {
const reimbursement = await loadReimbursementNotifyContext(tx, workflowInstance.entity_id);
const entityMeta = getWorkflowEntityMeta(
workflowInstance.entity_type,
reimbursement,
workflowInstance.entity_id,
);
const pendingCopy = buildPendingTaskCopy(entityMeta, { transfer: true });
await createNotifications(tx, {
recipientEmployeeIds: [toApproverId],
type: "workflow.task_assigned",
title: `【待办】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 转审待处理`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已转审给你，请及时处理。`,
title: pendingCopy.title,
body: pendingCopy.body,
targetType: "workflow_task",
targetId: taskId,
});
@@ -1487,8 +1588,8 @@ async function workflowRoutes(fastify) {
emailTasks.push({
type: "workflow.task_assigned",
recipientEmployeeIds: [toApproverId],
subject: `【待办】报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 转审待处理`,
body: `报销单 ${reimbursement?.form_number ?? workflowInstance.entity_id} 已转审给你，请及时处理。`,
subject: pendingCopy.title,
body: pendingCopy.body,
targetPath: `/workflow/tasks/${taskId}`,
});
} catch (error) {
server/src/services/budgetPool.js
+175
查看文件
@@ -0,0 +1,175 @@
const { AppError } = require("../utils/AppError");
const BUDGET_SCOPE_TYPES = Object.freeze({
global: "global",
departmentLegacy: "department_legacy",
costCenterScoped: "cost_center_scoped",
});
const BUDGET_SCOPE_PRIORITY = [
BUDGET_SCOPE_TYPES.costCenterScoped,
BUDGET_SCOPE_TYPES.departmentLegacy,
BUDGET_SCOPE_TYPES.global,
];
function buildValidationError(details, statusCode = 400) {
return new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode,
details,
});
}
function resolveBudgetScope({ departmentId = null, legalEntityId = null, costCenterId = null } = {}) {
const hasDepartment = Boolean(departmentId);
const hasLegalEntity = Boolean(legalEntityId);
const hasCostCenter = Boolean(costCenterId);
if (hasCostCenter && !hasLegalEntity) {
throw buildValidationError({ costCenterId: "legalEntityId_required" });
}
if (hasDepartment && (hasLegalEntity || hasCostCenter)) {
throw buildValidationError({ scope: "mixed_dimensions_not_allowed" }, 409);
}
if (hasLegalEntity && !hasCostCenter) {
throw buildValidationError({ costCenterId: "required_with_legalEntityId" });
}
if (hasLegalEntity && hasCostCenter) {
return {
scopeType: BUDGET_SCOPE_TYPES.costCenterScoped,
departmentId: null,
legalEntityId,
costCenterId,
};
}
if (hasDepartment) {
return {
scopeType: BUDGET_SCOPE_TYPES.departmentLegacy,
departmentId,
legalEntityId: null,
costCenterId: null,
};
}
return {
scopeType: BUDGET_SCOPE_TYPES.global,
departmentId: null,
legalEntityId: null,
costCenterId: null,
};
}
function resolveBudgetScopeType(record) {
const hasDepartment = Boolean(record?.department_id);
const hasLegalEntity = Boolean(record?.legal_entity_id);
const hasCostCenter = Boolean(record?.cost_center_id);
if (hasLegalEntity && hasCostCenter && !hasDepartment) {
return BUDGET_SCOPE_TYPES.costCenterScoped;
}
if (hasDepartment && !hasLegalEntity && !hasCostCenter) {
return BUDGET_SCOPE_TYPES.departmentLegacy;
}
if (!hasDepartment && !hasLegalEntity && !hasCostCenter) {
return BUDGET_SCOPE_TYPES.global;
}
return "invalid";
}
function matchesBudgetPoolContext(record, context) {
const scopeType = resolveBudgetScopeType(record);
if (scopeType === BUDGET_SCOPE_TYPES.costCenterScoped) {
return (
Boolean(context.legalEntityId) &&
Boolean(context.costCenterId) &&
record.legal_entity_id === context.legalEntityId &&
record.cost_center_id === context.costCenterId
);
}
if (scopeType === BUDGET_SCOPE_TYPES.departmentLegacy) {
return Boolean(context.departmentId) && record.department_id === context.departmentId;
}
if (scopeType === BUDGET_SCOPE_TYPES.global) {
return true;
}
return false;
}
function normalizeBudgetContext({ departmentId = null, legalEntityId = null, costCenterId = null } = {}) {
if (costCenterId && !legalEntityId) {
throw buildValidationError({ costCenterId: "legalEntityId_required" });
}
return {
departmentId,
legalEntityId,
costCenterId,
};
}
function selectBudgetPoolCandidate(records, context = {}) {
const normalizedContext = normalizeBudgetContext(context);
for (const scopeType of BUDGET_SCOPE_PRIORITY) {
const matches = (records ?? []).filter(
(record) => resolveBudgetScopeType(record) === scopeType && matchesBudgetPoolContext(record, normalizedContext),
);
if (matches.length === 1) {
return matches[0];
}
if (matches.length > 1) {
if (scopeType === BUDGET_SCOPE_TYPES.costCenterScoped) {
throw buildValidationError({ budget: "budget_pool_ambiguous", scopeType }, 409);
}
return matches[0];
}
}
return null;
}
async function resolveApplicableBudgetPoolByContext(
tx,
{ departmentId = null, legalEntityId = null, costCenterId = null, effectiveDate },
) {
if (!(effectiveDate instanceof Date) || Number.isNaN(effectiveDate.getTime())) {
throw buildValidationError({ effectiveDate: "invalid_date" });
}
const records = await tx.budgetPool.findMany({
where: {
status: "active",
archived_at: null,
period_start: { lte: effectiveDate },
period_end: { gte: effectiveDate },
},
orderBy: [{ created_at: "asc" }, { code: "asc" }],
});
return selectBudgetPoolCandidate(records, {
departmentId,
legalEntityId,
costCenterId,
});
}
module.exports = {
BUDGET_SCOPE_TYPES,
resolveBudgetScope,
resolveBudgetScopeType,
selectBudgetPoolCandidate,
resolveApplicableBudgetPoolByContext,
};
server/src/services/documentSequence.js
+341
查看文件
@@ -0,0 +1,341 @@
const { AppError } = require("../utils/AppError");
const { compactDateString } = require("../utils/date");
const DOCUMENT_TYPE_ALIASES = {
expense: "reimbursement",
};
const DOCUMENT_TYPE_CONFIG = {
reimbursement: {
defaultCategoryCode: "reimbursement_general",
preferLegacySequence: true,
fallback: {
prefix: "BX",
dateFormat: "YYYYMMDD",
separator: "-",
numberLength: 4,
resetPeriod: "none",
},
},
leave: {
defaultCategoryCode: "leave_request",
preferLegacySequence: false,
fallback: {
prefix: "JQ",
dateFormat: "YYYYMMDD",
separator: "-",
numberLength: 4,
resetPeriod: "yearly",
},
},
purchase_request: {
defaultCategoryCode: "purchase_general",
preferLegacySequence: false,
fallback: {
prefix: "CG",
dateFormat: "YYYYMMDD",
separator: "-",
numberLength: 4,
resetPeriod: "yearly",
},
},
asset_card: {
defaultCategoryCode: "asset_it",
preferLegacySequence: false,
fallback: {
prefix: "ZC",
dateFormat: "YYYYMMDD",
separator: "-",
numberLength: 4,
resetPeriod: "yearly",
},
},
general: {
defaultCategoryCode: "general_record",
preferLegacySequence: false,
fallback: {
prefix: "GEN",
dateFormat: "YYYYMMDD",
separator: "-",
numberLength: 4,
resetPeriod: "yearly",
},
},
};
function buildValidationError(details, statusCode = 400) {
return new AppError({
code: "VALID_001",
message: "参数校验失败",
statusCode,
details,
});
}
function normalizeDocumentType(documentType) {
const rawValue = String(documentType ?? "").trim().toLowerCase();
const normalized = DOCUMENT_TYPE_ALIASES[rawValue] ?? rawValue;
if (!DOCUMENT_TYPE_CONFIG[normalized]) {
throw buildValidationError({ documentType: "unsupported_document_type" }, 409);
}
return normalized;
}
function mapSequenceRecord(record) {
if (!record) {
return null;
}
return {
documentType: record.document_type,
prefix: record.prefix,
dateFormat: record.date_format,
separator: record.separator,
numberLength: record.number_length,
resetPeriod: record.reset_period,
currentNumber: record.current_number,
lastResetDate: record.last_reset_date?.toISOString?.()?.slice(0, 10) ?? null,
updatedAt: record.updated_at?.toISOString?.() ?? null,
updatedBy: record.updated_by ?? null,
};
}
function buildConfigFromFallback(documentType) {
const fallback = DOCUMENT_TYPE_CONFIG[documentType].fallback;
return {
exists: false,
source: "fallback",
documentType,
documentCategoryCode: null,
currentNumber: 0,
lastResetDate: null,
updatedAt: null,
updatedBy: null,
...fallback,
};
}
function buildConfigFromCategory(documentType, category, sequenceRecord) {
const fallback = DOCUMENT_TYPE_CONFIG[documentType].fallback;
const mappedSequence = mapSequenceRecord(sequenceRecord);
return {
exists: Boolean(sequenceRecord),
source: "document_category",
documentType,
documentCategoryCode: category.code,
prefix: category.sequence_prefix,
dateFormat: mappedSequence?.dateFormat ?? fallback.dateFormat,
separator: mappedSequence?.separator ?? fallback.separator,
numberLength: category.number_length,
resetPeriod: category.reset_period,
currentNumber: mappedSequence?.currentNumber ?? 0,
lastResetDate: mappedSequence?.lastResetDate ?? null,
updatedAt: mappedSequence?.updatedAt ?? null,
updatedBy: mappedSequence?.updatedBy ?? null,
};
}
async function findDocumentCategory(prisma, { documentType, documentCategoryCode }) {
const normalizedDocumentType = normalizeDocumentType(documentType);
const defaultCategoryCode = DOCUMENT_TYPE_CONFIG[normalizedDocumentType].defaultCategoryCode;
if (documentCategoryCode) {
const category = await prisma.documentCategory.findUnique({
where: { code: documentCategoryCode },
select: {
code: true,
entity_type: true,
sequence_prefix: true,
number_length: true,
reset_period: true,
enabled: true,
archived_at: true,
},
});
if (!category) {
throw buildValidationError({ documentCategoryCode: "not_found" }, 409);
}
if (category.entity_type !== normalizedDocumentType) {
throw buildValidationError({ documentCategoryCode: "entity_type_mismatch" }, 409);
}
if (!category.enabled || category.archived_at) {
throw buildValidationError({ documentCategoryCode: "disabled_or_archived" }, 409);
}
return category;
}
if (defaultCategoryCode) {
const defaultCategory = await prisma.documentCategory.findUnique({
where: { code: defaultCategoryCode },
select: {
code: true,
entity_type: true,
sequence_prefix: true,
number_length: true,
reset_period: true,
enabled: true,
archived_at: true,
},
});
if (
defaultCategory &&
defaultCategory.entity_type === normalizedDocumentType &&
defaultCategory.enabled &&
!defaultCategory.archived_at
) {
return defaultCategory;
}
}
return prisma.documentCategory.findFirst({
where: {
entity_type: normalizedDocumentType,
enabled: true,
archived_at: null,
},
orderBy: [{ created_at: "asc" }, { code: "asc" }],
select: {
code: true,
entity_type: true,
sequence_prefix: true,
number_length: true,
reset_period: true,
enabled: true,
archived_at: true,
},
});
}
async function resolveDocumentSequenceConfig(prisma, { documentType, documentCategoryCode = null } = {}) {
const normalizedDocumentType = normalizeDocumentType(documentType);
const documentTypeConfig = DOCUMENT_TYPE_CONFIG[normalizedDocumentType];
const sequenceRecord = await prisma.documentSequence.findUnique({
where: { document_type: normalizedDocumentType },
select: {
document_type: true,
prefix: true,
date_format: true,
separator: true,
number_length: true,
reset_period: true,
current_number: true,
last_reset_date: true,
updated_at: true,
updated_by: true,
},
});
if (documentTypeConfig.preferLegacySequence && !documentCategoryCode && sequenceRecord) {
return {
exists: true,
source: "document_sequence",
documentCategoryCode: null,
...mapSequenceRecord(sequenceRecord),
};
}
const category = await findDocumentCategory(prisma, {
documentType: normalizedDocumentType,
documentCategoryCode,
});
if (category) {
return buildConfigFromCategory(normalizedDocumentType, category, sequenceRecord);
}
if (sequenceRecord) {
return {
exists: true,
source: "document_sequence",
documentCategoryCode: null,
...mapSequenceRecord(sequenceRecord),
};
}
return buildConfigFromFallback(normalizedDocumentType);
}
function formatDocumentNumber(sequenceConfig, timeZone) {
const datePart = compactDateString(timeZone);
const serial = String(sequenceConfig.current_number).padStart(sequenceConfig.number_length, "0");
return `${sequenceConfig.prefix}${sequenceConfig.separator}${datePart}${sequenceConfig.separator}${serial}`;
}
async function issueDocumentNumber(
tx,
{ documentType, documentCategoryCode = null, actorId = null, timeZone = "Asia/Shanghai" } = {},
) {
const normalizedDocumentType = normalizeDocumentType(documentType);
const config = await resolveDocumentSequenceConfig(tx, {
documentType: normalizedDocumentType,
documentCategoryCode,
});
const sequenceRecord = await tx.documentSequence.upsert({
where: { document_type: normalizedDocumentType },
update: {
prefix: config.prefix,
date_format: config.dateFormat,
separator: config.separator,
number_length: config.numberLength,
reset_period: config.resetPeriod,
current_number: { increment: 1 },
updated_by: actorId,
},
create: {
document_type: normalizedDocumentType,
prefix: config.prefix,
date_format: config.dateFormat,
separator: config.separator,
number_length: config.numberLength,
reset_period: config.resetPeriod,
current_number: 1,
updated_by: actorId,
},
select: {
document_type: true,
prefix: true,
date_format: true,
separator: true,
number_length: true,
reset_period: true,
current_number: true,
last_reset_date: true,
updated_at: true,
updated_by: true,
},
});
const mappedSequence = mapSequenceRecord(sequenceRecord);
return {
documentNumber: formatDocumentNumber(
{
prefix: mappedSequence.prefix,
separator: mappedSequence.separator,
number_length: mappedSequence.numberLength,
current_number: mappedSequence.currentNumber,
},
timeZone,
),
sequence: mappedSequence,
config: {
...config,
currentNumber: mappedSequence.currentNumber,
updatedAt: mappedSequence.updatedAt,
updatedBy: mappedSequence.updatedBy,
},
};
}
module.exports = {
normalizeDocumentType,
resolveDocumentSequenceConfig,
issueDocumentNumber,
};