fix: surface active beds on elder records

This commit is contained in:
2026-07-02 17:43:00 -07:00
parent 9480030391
commit c181e6fbdd
5 changed files with 135 additions and 53 deletions

View File

@@ -202,6 +202,8 @@ export async function getOrdersWithItems(params: {
- `POST /api/admissions`: admit an elder or transfer an active elder to a new available bed. - `POST /api/admissions`: admit an elder or transfer an active elder to a new available bed.
- `PATCH /api/admissions/[id]`: discharge an active admission and release its bed. - `PATCH /api/admissions/[id]`: discharge an active admission and release its bed.
- `GET /api/elders`: list elders with current active bed labels joined from `admissions -> beds -> rooms`.
- `readData()`: compatibility read model must expose the same active bed labels on `Elder.room`, `Elder.bed`, and `Elder.bedId`.
- Mutations use `getDatabase().transaction(async (transaction) => ...)`. - Mutations use `getDatabase().transaction(async (transaction) => ...)`.
### 3. Contracts ### 3. Contracts
@@ -223,8 +225,10 @@ export async function getOrdersWithItems(params: {
### 5. Good/Base/Bad Cases ### 5. Good/Base/Bad Cases
- Good: return a typed mutation result from inside the transaction, then convert it to `jsonFailure` or `jsonSuccess` outside the transaction. - Good: return a typed mutation result from inside the transaction, then convert it to `jsonFailure` or `jsonSuccess` outside the transaction.
- Good: display elder bed fields as read-only data derived from the active admission; bed assignment actions live in the bed/admission workspace.
- Base: read-only admission lists may use the temporary `readData()` compatibility model while the domain helper layer is being extracted. - Base: read-only admission lists may use the temporary `readData()` compatibility model while the domain helper layer is being extracted.
- Bad: throw ordinary `Error` for business conflicts such as occupied beds, because it loses the structured status/reason contract. - Bad: throw ordinary `Error` for business conflicts such as occupied beds, because it loses the structured status/reason contract.
- Bad: allow free-text room/bed edits on the elder form when those strings are not persisted relationship data.
### 6. Tests Required ### 6. Tests Required

View File

@@ -119,7 +119,7 @@ export async function DELETE(_request: Request, context: RouteContext): Promise<
const activeAdmissions = await transaction const activeAdmissions = await transaction
.select() .select()
.from(admissions) .from(admissions)
.where(and(eq(admissions.elderId, id), eq(admissions.status, "active"))); .where(and(eq(admissions.elderId, id), eq(admissions.organizationId, organizationId), eq(admissions.status, "active")));
await Promise.all( await Promise.all(
activeAdmissions.map((admission) => activeAdmissions.map((admission) =>
@@ -131,7 +131,10 @@ export async function DELETE(_request: Request, context: RouteContext): Promise<
); );
await Promise.all( await Promise.all(
activeAdmissions.map((admission) => activeAdmissions.map((admission) =>
transaction.update(beds).set({ status: "available", updatedAt: new Date() }).where(eq(beds.id, admission.bedId)), transaction
.update(beds)
.set({ status: "available", updatedAt: new Date() })
.where(and(eq(beds.id, admission.bedId), eq(beds.organizationId, organizationId))),
), ),
); );

View File

@@ -6,11 +6,30 @@ import { jsonFailure, jsonSuccess, readJsonBody } from "@/modules/core/server/ap
import { recordAuditLog } from "@/modules/core/server/audit"; import { recordAuditLog } from "@/modules/core/server/audit";
import { requirePermission } from "@/modules/core/server/auth"; import { requirePermission } from "@/modules/core/server/auth";
import { getDatabase } from "@/modules/core/server/db"; import { getDatabase } from "@/modules/core/server/db";
import { admissions, beds, elders } from "@/modules/core/server/schema"; import { admissions, beds, elders, rooms } from "@/modules/core/server/schema";
import { validateElderInput } from "@/modules/elders/types"; import { validateElderInput } from "@/modules/elders/types";
import type { Elder } from "@/modules/elders/types"; import type { Elder } from "@/modules/elders/types";
function toElder(row: typeof elders.$inferSelect, bedLabel?: { room: string; bed: string; bedId: string }): Elder { type ElderRow = typeof elders.$inferSelect;
type BedLabel = {
room: string;
bed: string;
bedId: string;
};
type ElderCreateResult =
| {
success: true;
elder: ElderRow;
bedLabel?: BedLabel;
}
| {
success: false;
reason: string;
status: number;
};
function toElder(row: ElderRow, bedLabel?: BedLabel): Elder {
return { return {
id: row.id, id: row.id,
organizationId: row.organizationId, organizationId: row.organizationId,
@@ -46,13 +65,36 @@ export async function GET(): Promise<Response> {
} }
const database = getDatabase(); const database = getDatabase();
const rows = await database const [rows, activeAdmissionRows] = await Promise.all([
.select() database
.from(elders) .select()
.where(eq(elders.organizationId, organizationId)) .from(elders)
.orderBy(desc(elders.createdAt)); .where(eq(elders.organizationId, organizationId))
.orderBy(desc(elders.createdAt)),
database
.select({
elderId: admissions.elderId,
bedId: admissions.bedId,
bedCode: beds.code,
roomName: rooms.name,
})
.from(admissions)
.innerJoin(beds, eq(beds.id, admissions.bedId))
.innerJoin(rooms, eq(rooms.id, beds.roomId))
.where(and(eq(admissions.organizationId, organizationId), eq(admissions.status, "active"))),
]);
const bedLabelByElderId = new Map(
activeAdmissionRows.map((row) => [
row.elderId,
{
room: row.roomName,
bed: row.bedCode,
bedId: row.bedId,
},
]),
);
return jsonSuccess("老人档案已加载", { elders: rows.map((row) => toElder(row)) }); return jsonSuccess("老人档案已加载", { elders: rows.map((row) => toElder(row, bedLabelByElderId.get(row.id))) });
} }
export async function POST(request: Request): Promise<Response> { export async function POST(request: Request): Promise<Response> {
@@ -76,7 +118,7 @@ export async function POST(request: Request): Promise<Response> {
} }
const database = getDatabase(); const database = getDatabase();
const created = await database.transaction(async (transaction) => { const created = await database.transaction(async (transaction): Promise<ElderCreateResult> => {
const elderId = randomUUID(); const elderId = randomUUID();
const elderRows = await transaction const elderRows = await transaction
.insert(elders) .insert(elders)
@@ -87,7 +129,7 @@ export async function POST(request: Request): Promise<Response> {
gender: input.data.gender, gender: input.data.gender,
age: input.data.age, age: input.data.age,
careLevel: input.data.careLevel, careLevel: input.data.careLevel,
status: input.data.status, status: input.data.bedId ? "active" : input.data.status,
primaryContact: input.data.primaryContact, primaryContact: input.data.primaryContact,
phone: input.data.phone, phone: input.data.phone,
medicalNotes: input.data.medicalNotes, medicalNotes: input.data.medicalNotes,
@@ -95,21 +137,22 @@ export async function POST(request: Request): Promise<Response> {
.returning(); .returning();
const elder = elderRows[0]; const elder = elderRows[0];
if (!elder) { if (!elder) {
throw new Error("老人档案创建失败"); return { success: false, reason: "老人档案创建失败", status: 500 };
} }
if (input.data.bedId) { if (input.data.bedId) {
const bedRows = await transaction const bedRows = await transaction
.select() .select({ bed: beds, roomName: rooms.name })
.from(beds) .from(beds)
.innerJoin(rooms, eq(rooms.id, beds.roomId))
.where(and(eq(beds.id, input.data.bedId), eq(beds.organizationId, organizationId))) .where(and(eq(beds.id, input.data.bedId), eq(beds.organizationId, organizationId)))
.limit(1); .limit(1);
const bed = bedRows[0]; const bedRow = bedRows[0];
if (!bed) { if (!bedRow) {
throw new Error("床位不存在"); return { success: false, reason: "床位不存在", status: 404 };
} }
if (bed.status !== "available") { if (bedRow.bed.status !== "available") {
throw new Error("床位不可分配"); return { success: false, reason: "床位不可分配", status: 409 };
} }
await transaction await transaction
@@ -117,17 +160,34 @@ export async function POST(request: Request): Promise<Response> {
.values({ .values({
organizationId, organizationId,
elderId: elder.id, elderId: elder.id,
bedId: bed.id, bedId: bedRow.bed.id,
status: "active", status: "active",
notes: "新增档案时办理入住", notes: "新增档案时办理入住",
}); });
await transaction.update(beds).set({ status: "occupied", updatedAt: new Date() }).where(eq(beds.id, bed.id)); await transaction
.update(beds)
.set({ status: "occupied", updatedAt: new Date() })
.where(and(eq(beds.id, bedRow.bed.id), eq(beds.organizationId, organizationId)));
return {
success: true,
elder,
bedLabel: {
room: bedRow.roomName,
bed: bedRow.bed.code,
bedId: bedRow.bed.id,
},
};
} }
return elder; return { success: true, elder };
}); });
const elder = toElder(created); if (!created.success) {
return jsonFailure(created.reason, created.status);
}
const elder = toElder(created.elder, created.bedLabel);
await recordAuditLog({ await recordAuditLog({
actor: auth.context.account, actor: auth.context.account,
organizationId, organizationId,

View File

@@ -113,6 +113,19 @@ export async function readData(): Promise<AppData> {
]); ]);
const roleById = new Map(membershipRows.map((row) => [row.membership.id, row.role])); const roleById = new Map(membershipRows.map((row) => [row.membership.id, row.role]));
const activeAdmissionByElderId = new Map<string, { room: string; bed: string; bedId: string }>();
for (const row of admissionRows) {
if (row.admission.status !== "active") {
continue;
}
activeAdmissionByElderId.set(row.admission.elderId, {
room: row.roomName,
bed: row.bedCode,
bedId: row.admission.bedId,
});
}
const bedCounts = new Map<string, { total: number; occupied: number }>(); const bedCounts = new Map<string, { total: number; occupied: number }>();
for (const row of bedRows) { for (const row of bedRows) {
const current = bedCounts.get(row.bed.roomId) ?? { total: 0, occupied: 0 }; const current = bedCounts.get(row.bed.roomId) ?? { total: 0, occupied: 0 };
@@ -209,22 +222,26 @@ export async function readData(): Promise<AppData> {
expiresAt: iso(row.expiresAt), expiresAt: iso(row.expiresAt),
})); }));
const eldersData: Elder[] = elderRows.map((row) => ({ const eldersData: Elder[] = elderRows.map((row) => {
id: row.id, const activeAdmission = activeAdmissionByElderId.get(row.id);
organizationId: row.organizationId, return {
name: row.name, id: row.id,
gender: row.gender, organizationId: row.organizationId,
age: row.age, name: row.name,
careLevel: row.careLevel, gender: row.gender,
room: "", age: row.age,
bed: "", careLevel: row.careLevel,
status: row.status, room: activeAdmission?.room ?? "",
primaryContact: row.primaryContact, bed: activeAdmission?.bed ?? "",
phone: row.phone, bedId: activeAdmission?.bedId,
medicalNotes: row.medicalNotes, status: row.status,
createdAt: iso(row.createdAt), primaryContact: row.primaryContact,
updatedAt: iso(row.updatedAt), phone: row.phone,
})); medicalNotes: row.medicalNotes,
createdAt: iso(row.createdAt),
updatedAt: iso(row.updatedAt),
};
});
const roomsData: Room[] = roomRows.map((row) => { const roomsData: Room[] = roomRows.map((row) => {
const counts = bedCounts.get(row.id) ?? { total: 0, occupied: 0 }; const counts = bedCounts.get(row.id) ?? { total: 0, occupied: 0 };

View File

@@ -56,6 +56,10 @@ function formatDateTime(value: string): string {
return new Date(value).toLocaleString("zh-CN"); return new Date(value).toLocaleString("zh-CN");
} }
function formatBedLabel(elder: Pick<Elder, "room" | "bed">): string {
return elder.room && elder.bed ? `${elder.room}-${elder.bed}` : "-";
}
function getRiskLabel(elder: Elder): { label: string; variant: "danger" | "warning" | "success" } { function getRiskLabel(elder: Elder): { label: string; variant: "danger" | "warning" | "success" } {
if (elder.careLevel === "intensive") { if (elder.careLevel === "intensive") {
return { label: "红色重点", variant: "danger" }; return { label: "红色重点", variant: "danger" };
@@ -136,6 +140,7 @@ export function EldersClient({ initialElders, permissions }: EldersClientProps):
const safePage = Math.min(page, pageCount); const safePage = Math.min(page, pageCount);
const pageStart = (safePage - 1) * PAGE_SIZE; const pageStart = (safePage - 1) * PAGE_SIZE;
const visibleElders = filteredElders.slice(pageStart, pageStart + PAGE_SIZE); const visibleElders = filteredElders.slice(pageStart, pageStart + PAGE_SIZE);
const editingElder = editingId ? elders.find((elder) => elder.id === editingId) : undefined;
function updateField<K extends keyof ElderInput>(key: K, value: ElderInput[K]): void { function updateField<K extends keyof ElderInput>(key: K, value: ElderInput[K]): void {
setForm((current) => ({ ...current, [key]: value })); setForm((current) => ({ ...current, [key]: value }));
@@ -359,9 +364,7 @@ export function EldersClient({ initialElders, permissions }: EldersClientProps):
</p> </p>
</Table.Cell> </Table.Cell>
<Table.Cell className="px-4 py-3">{CARE_LEVEL_LABELS[elder.careLevel]}</Table.Cell> <Table.Cell className="px-4 py-3">{CARE_LEVEL_LABELS[elder.careLevel]}</Table.Cell>
<Table.Cell className="px-4 py-3 text-muted-foreground"> <Table.Cell className="px-4 py-3 text-muted-foreground">{formatBedLabel(elder)}</Table.Cell>
{elder.room}-{elder.bed}
</Table.Cell>
<Table.Cell className="px-4 py-3 text-muted-foreground"> <Table.Cell className="px-4 py-3 text-muted-foreground">
{elder.primaryContact} / {elder.phone} {elder.primaryContact} / {elder.phone}
</Table.Cell> </Table.Cell>
@@ -490,16 +493,11 @@ export function EldersClient({ initialElders, permissions }: EldersClientProps):
/> />
</div> </div>
</div> </div>
<div className="grid gap-3 sm:grid-cols-2"> {isEditing ? (
<label className="grid gap-1.5 text-sm font-medium"> <div className="rounded-md border bg-secondary/30 px-3 py-2 text-sm">
{editingElder ? formatBedLabel(editingElder) : "-"}
<Input value={form.room} onChange={(event) => updateField("room", event.target.value)} /> </div>
</label> ) : null}
<label className="grid gap-1.5 text-sm font-medium">
<Input value={form.bed} onChange={(event) => updateField("bed", event.target.value)} />
</label>
</div>
<label className="grid gap-1.5 text-sm font-medium"> <label className="grid gap-1.5 text-sm font-medium">
<Input value={form.primaryContact} onChange={(event) => updateField("primaryContact", event.target.value)} /> <Input value={form.primaryContact} onChange={(event) => updateField("primaryContact", event.target.value)} />
@@ -543,7 +541,7 @@ export function EldersClient({ initialElders, permissions }: EldersClientProps):
<div className="flex flex-col gap-4"> <div className="flex flex-col gap-4">
{deleteTarget ? ( {deleteTarget ? (
<div className="rounded-md border border-red-200 bg-red-50 p-3 text-sm text-red-700"> <div className="rounded-md border border-red-200 bg-red-50 p-3 text-sm text-red-700">
{deleteTarget.name}{deleteTarget.room}-{deleteTarget.bed} {deleteTarget.name}{formatBedLabel(deleteTarget)}
{formatDateTime(deleteTarget.updatedAt)} {formatDateTime(deleteTarget.updatedAt)}
</div> </div>
) : null} ) : null}