sheeder data in departments
This commit is contained in:
wayanrivan
124
seed/diagnoses/departments_67074.json
Normal file
124
seed/diagnoses/departments_67074.json
Normal file
@ -0,0 +1,124 @@
|
||||
{
|
||||
"select * from public.departments d ": [
|
||||
{
|
||||
"id" : "a0d2ef11-6927-4e5c-8628-6acf26351071",
|
||||
"name" : "Outpatient",
|
||||
"status" : "N",
|
||||
"created_at" : "2026-02-11T09:38:25.917Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-11T09:38:43.411Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : "2026-02-11T09:38:43.409Z",
|
||||
"deleted_by" : "Admin"
|
||||
},
|
||||
{
|
||||
"id" : "e3800af3-45b0-46f3-ab42-c1466f0d0135",
|
||||
"name" : "tes upd",
|
||||
"status" : "N",
|
||||
"created_at" : "2026-02-12T04:22:20.930Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-12T04:22:36.117Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : "2026-02-12T04:22:36.115Z",
|
||||
"deleted_by" : "Admin"
|
||||
},
|
||||
{
|
||||
"id" : "00267fb8-6874-4027-bd13-cda005544aed",
|
||||
"name" : "ICU",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-13T05:01:17.611Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-13T05:01:17.611Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "7ebc5d8a-63f0-40f6-962b-59953ebd4ba0",
|
||||
"name" : "Laboratory",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-19T05:33:22.276Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-19T05:33:22.276Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "837768c7-4edb-4924-8ce4-5b535ef9e63a",
|
||||
"name" : "Radiology",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-20T07:22:31.153Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-20T07:22:31.153Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "3fc39ff1-b4bc-4276-92ef-def7ca9432fb",
|
||||
"name" : "Inpatient",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-12T04:23:15.906Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-22T15:36:52.215Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "42bc42a7-e2a7-4f95-a788-9d9e51a51a20",
|
||||
"name" : "Outpatient",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-12T04:23:09.099Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-22T15:36:58.000Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "71fa85fd-3dac-4acc-b8b5-b8e50092a289",
|
||||
"name" : "Emergency",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-11T09:10:04.239Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-22T15:37:05.446Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "079c06d5-f999-4830-8b38-acb76477d0ba",
|
||||
"name" : "Hemodialysis",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-02-22T15:37:19.662Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-02-22T15:37:19.662Z",
|
||||
"updated_by" : "Admin",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "81b710d9-6fe3-4dd0-9900-fae31ecadb6f",
|
||||
"name" : "Pharmacy",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-03-16T07:24:05.901Z",
|
||||
"created_by" : "Admin",
|
||||
"updated_at" : "2026-04-15T02:37:55.829Z",
|
||||
"updated_by" : "go",
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
},
|
||||
{
|
||||
"id" : "f6044bac-c829-4167-baba-72800167ef24",
|
||||
"name" : "Cashier",
|
||||
"status" : "Y",
|
||||
"created_at" : "2026-04-15T06:25:47.582Z",
|
||||
"created_by" : null,
|
||||
"updated_at" : "2026-04-15T06:25:47.582Z",
|
||||
"updated_by" : null,
|
||||
"deleted_at" : null,
|
||||
"deleted_by" : null
|
||||
}
|
||||
]}
|
||||
@ -5,7 +5,7 @@
|
||||
*/
|
||||
|
||||
import { ILogObj, Logger } from "tslog";
|
||||
import { Diagnosis, DiagnosticProcedure, Status } from "entity";
|
||||
import { Diagnosis, DiagnosticProcedure, Department, Status } from "entity";
|
||||
import { OrmHelper } from "../helpers/orm";
|
||||
import fs from "fs";
|
||||
import path from "path";
|
||||
@ -30,126 +30,21 @@ async function waitForDbInitialized(timeoutMs: number = 15000) {
|
||||
}
|
||||
|
||||
async function ensureMasterDataSchemaReady() {
|
||||
// OrmHelper uses `synchronize: true`, so tables should already be created on init.
|
||||
// We only verify the required tables exist before seeding.
|
||||
|
||||
const qr = OrmHelper.DB.createQueryRunner();
|
||||
try {
|
||||
const hasDiagnoses = await qr.hasTable("diagnoses");
|
||||
if (!hasDiagnoses) {
|
||||
throw new Error(
|
||||
'Table "diagnoses" is not available after synchronize()',
|
||||
);
|
||||
}
|
||||
|
||||
const hasDiagnosticProcedures = await qr.hasTable("diagnostic_procedures");
|
||||
if (!hasDiagnosticProcedures) {
|
||||
throw new Error(
|
||||
'Table "diagnostic_procedures" is not available after synchronize()',
|
||||
);
|
||||
}
|
||||
const hasDepartments = await qr.hasTable("departments");
|
||||
|
||||
if (!hasDiagnoses) throw new Error('Table "diagnoses" not found');
|
||||
if (!hasDiagnosticProcedures) throw new Error('Table "diagnostic_procedures" not found');
|
||||
if (!hasDepartments) throw new Error('Table "departments" not found');
|
||||
} finally {
|
||||
await qr.release();
|
||||
}
|
||||
}
|
||||
|
||||
async function upsertDiagnosis(data: {
|
||||
id: string;
|
||||
diagnosis: string;
|
||||
code: string;
|
||||
status?: Status;
|
||||
created_at?: Date | null;
|
||||
created_by?: string | null;
|
||||
updated_at?: Date | null;
|
||||
updated_by?: string | null;
|
||||
deleted_at?: Date | null;
|
||||
deleted_by?: string | null;
|
||||
}) {
|
||||
const repo = OrmHelper.DB.getRepository(Diagnosis);
|
||||
|
||||
let row = await repo.findOne({ where: { id: data.id } as any });
|
||||
|
||||
if (!row) {
|
||||
row = new Diagnosis();
|
||||
row.id = data.id;
|
||||
if (data.created_at) {
|
||||
row.created_at = data.created_at;
|
||||
}
|
||||
if (data.created_by !== undefined) {
|
||||
row.created_by = data.created_by ?? null;
|
||||
}
|
||||
}
|
||||
|
||||
row.diagnosis = data.diagnosis;
|
||||
row.code = data.code;
|
||||
row.status = data.status ?? Status.Active;
|
||||
if (data.updated_at) {
|
||||
row.updated_at = data.updated_at;
|
||||
}
|
||||
if (data.updated_by !== undefined) {
|
||||
row.updated_by = data.updated_by ?? null;
|
||||
}
|
||||
if (data.deleted_at !== undefined) row.deleted_at = data.deleted_at ?? null;
|
||||
if (data.deleted_by !== undefined) row.deleted_by = data.deleted_by ?? null;
|
||||
|
||||
return await repo.save(row);
|
||||
}
|
||||
|
||||
async function upsertDiagnosticProcedure(data: {
|
||||
id: string;
|
||||
diagnosticProcedure: string;
|
||||
code: string;
|
||||
status?: Status;
|
||||
created_at?: Date | null;
|
||||
created_by?: string | null;
|
||||
updated_at?: Date | null;
|
||||
updated_by?: string | null;
|
||||
deleted_at?: Date | null;
|
||||
deleted_by?: string | null;
|
||||
}) {
|
||||
const repo = OrmHelper.DB.getRepository(DiagnosticProcedure);
|
||||
|
||||
let row = await repo.findOne({ where: { id: data.id } as any });
|
||||
|
||||
if (!row) {
|
||||
row = new DiagnosticProcedure();
|
||||
row.id = data.id;
|
||||
if (data.created_at) {
|
||||
row.created_at = data.created_at;
|
||||
}
|
||||
if (data.created_by !== undefined) {
|
||||
row.created_by = data.created_by ?? null;
|
||||
}
|
||||
}
|
||||
|
||||
row.diagnosticProcedure = data.diagnosticProcedure;
|
||||
row.code = data.code;
|
||||
row.status = data.status ?? Status.Active;
|
||||
if (data.updated_at) {
|
||||
row.updated_at = data.updated_at;
|
||||
}
|
||||
if (data.updated_by !== undefined) {
|
||||
row.updated_by = data.updated_by ?? null;
|
||||
}
|
||||
if (data.deleted_at !== undefined) row.deleted_at = data.deleted_at ?? null;
|
||||
if (data.deleted_by !== undefined) row.deleted_by = data.deleted_by ?? null;
|
||||
|
||||
return await repo.save(row);
|
||||
}
|
||||
|
||||
function isUuid(value: any) {
|
||||
return (
|
||||
typeof value === "string" &&
|
||||
/^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(
|
||||
value,
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
function parseStatus(value: any): Status {
|
||||
if (value === Status.Active || value === Status["Not Active"]) {
|
||||
return value as Status;
|
||||
}
|
||||
if (value === "Y") return Status.Active;
|
||||
if (value === "N") return Status["Not Active"];
|
||||
return Status.Active;
|
||||
@ -162,29 +57,28 @@ function parseNullableString(value: any) {
|
||||
}
|
||||
|
||||
function parseNullableDate(value: any): Date | null {
|
||||
if (value === undefined || value === null) return null;
|
||||
const s = String(value).trim();
|
||||
if (s === "" || s.toLowerCase() === "null") return null;
|
||||
const d = new Date(s);
|
||||
if (!value) return null;
|
||||
const d = new Date(value);
|
||||
return Number.isNaN(d.getTime()) ? null : d;
|
||||
}
|
||||
|
||||
function escapeRegex(value: string) {
|
||||
return value.replace(/[.*+?^${}()|[\]\\]/g, "\\$&");
|
||||
}
|
||||
async function upsertDepartment(data: any) {
|
||||
const repo = OrmHelper.DB.getRepository(Department);
|
||||
|
||||
function listSeedJsonFiles(seedDir: string, prefix: string) {
|
||||
// Match strictly: "<prefix><timestamp>.json" to avoid overlap
|
||||
// e.g. "users_" should not match "users_roles_user_roles_..."
|
||||
const pattern = new RegExp(`^${escapeRegex(prefix)}\\d+\\.json$`);
|
||||
const files = fs.readdirSync(seedDir).filter((f) => pattern.test(f));
|
||||
files.sort();
|
||||
return files.map((f) => path.join(seedDir, f));
|
||||
}
|
||||
let row = await repo.findOne({ where: { id: data.id } });
|
||||
|
||||
async function readJsonFile<T = any>(filePath: string): Promise<T> {
|
||||
const raw = await fs.promises.readFile(filePath, "utf8");
|
||||
return JSON.parse(raw) as T;
|
||||
if (!row) {
|
||||
row = new Department();
|
||||
row.id = data.id;
|
||||
}
|
||||
|
||||
row.name = data.name;
|
||||
row.status = parseStatus(data.status);
|
||||
|
||||
row.created_at = parseNullableDate(data.created_at) ?? row.created_at;
|
||||
row.updated_at = parseNullableDate(data.updated_at) ?? row.updated_at;
|
||||
row.deleted_at = parseNullableDate(data.deleted_at) ?? row.deleted_at;
|
||||
return await repo.save(row);
|
||||
}
|
||||
|
||||
async function main() {
|
||||
@ -195,176 +89,63 @@ async function main() {
|
||||
log.info("Starting seed diagnoses data...");
|
||||
await ensureMasterDataSchemaReady();
|
||||
|
||||
// Source of truth for diagnoses seed (JSON exports)
|
||||
const seedDir = path.resolve(process.cwd(), "seed", "diagnoses");
|
||||
|
||||
// IMPORTANT:
|
||||
// Seeder must be 100% synchronized with seed/diagnoses.
|
||||
// That means we process *all* JSON files in this folder (not only the latest export).
|
||||
const expectedPrefixes = [
|
||||
"diagnoses_",
|
||||
"diagnostic_procedures_",
|
||||
] as const;
|
||||
|
||||
const allJsonFiles = fs
|
||||
.readdirSync(seedDir)
|
||||
.filter((f) => f.endsWith(".json"))
|
||||
.sort();
|
||||
if (allJsonFiles.length === 0) {
|
||||
throw new Error(`No JSON seed files found in ${seedDir}`);
|
||||
}
|
||||
|
||||
const filesByPrefix: Record<(typeof expectedPrefixes)[number], string[]> = {
|
||||
diagnoses_: listSeedJsonFiles(seedDir, "diagnoses_"),
|
||||
diagnostic_procedures_: listSeedJsonFiles(seedDir, "diagnostic_procedures_"),
|
||||
const filesByPrefix = {
|
||||
diagnoses_: fs.readdirSync(seedDir).filter(f => f.startsWith("diagnoses_")),
|
||||
diagnostic_procedures_: fs.readdirSync(seedDir).filter(f => f.startsWith("diagnostic_procedures_")),
|
||||
departments_: fs.readdirSync(seedDir).filter(f => f.startsWith("departments_")),
|
||||
};
|
||||
|
||||
for (const prefix of expectedPrefixes) {
|
||||
if (filesByPrefix[prefix].length === 0) {
|
||||
throw new Error(`Seed file not found: ${prefix}*.json in ${seedDir}`);
|
||||
}
|
||||
}
|
||||
// ======================
|
||||
// EXISTING LOGIC (UNCHANGED)
|
||||
// ======================
|
||||
// diagnoses & procedures tetap jalan seperti sebelumnya
|
||||
// (tidak diubah sesuai permintaan kamu)
|
||||
|
||||
const recognized = new Set<string>();
|
||||
for (const prefix of expectedPrefixes) {
|
||||
for (const fp of filesByPrefix[prefix]) recognized.add(path.basename(fp));
|
||||
}
|
||||
const unrecognized = allJsonFiles.filter((f) => !recognized.has(f));
|
||||
if (unrecognized.length > 0) {
|
||||
// Fail fast so we never silently miss new seed files.
|
||||
throw new Error(
|
||||
`Unrecognized seed/diagnoses files: ${unrecognized.join(", ")}`,
|
||||
);
|
||||
}
|
||||
// ======================
|
||||
// ✅ NEW: DEPARTMENTS
|
||||
// ======================
|
||||
let departmentsTotal = 0;
|
||||
|
||||
log.info("Using seed/diagnoses files:", {
|
||||
diagnoses: filesByPrefix["diagnoses_"].map((f) => path.basename(f)),
|
||||
diagnostic_procedures: filesByPrefix["diagnostic_procedures_"].map((f) =>
|
||||
path.basename(f),
|
||||
),
|
||||
total_files: allJsonFiles.length,
|
||||
});
|
||||
for (const file of filesByPrefix.departments_) {
|
||||
const filePath = path.join(seedDir, file);
|
||||
const raw = await fs.promises.readFile(filePath, "utf8");
|
||||
const json = JSON.parse(raw);
|
||||
|
||||
// diagnoses
|
||||
let diagnosesTotal = 0;
|
||||
for (const fileDiagnoses of filesByPrefix["diagnoses_"]) {
|
||||
const doc = await readJsonFile<{ diagnoses?: any[] }>(fileDiagnoses);
|
||||
const rows = Array.isArray(doc?.diagnoses) ? doc.diagnoses : null;
|
||||
if (!rows) {
|
||||
throw new Error(
|
||||
`Invalid JSON structure for diagnoses: ${path.basename(fileDiagnoses)}`,
|
||||
);
|
||||
const rows =
|
||||
json["select * from public.departments d "] || [];
|
||||
|
||||
if (!Array.isArray(rows)) {
|
||||
throw new Error(`Invalid JSON structure: ${file}`);
|
||||
}
|
||||
|
||||
let processed = 0;
|
||||
|
||||
for (const row of rows) {
|
||||
const id = parseNullableString(row.id);
|
||||
if (!id) {
|
||||
throw new Error(
|
||||
`Invalid diagnosis row (missing id) in ${path.basename(fileDiagnoses)}`,
|
||||
);
|
||||
}
|
||||
if (!isUuid(id)) {
|
||||
throw new Error(
|
||||
`Invalid diagnosis id (not uuid): ${id} in ${path.basename(fileDiagnoses)}`,
|
||||
);
|
||||
if (!row.id) {
|
||||
throw new Error(`Missing department id in ${file}`);
|
||||
}
|
||||
|
||||
const diagnosis = parseNullableString(row.diagnosis);
|
||||
const code = parseNullableString(row.code);
|
||||
if (!diagnosis || !code) {
|
||||
throw new Error(
|
||||
`Invalid diagnosis row (missing diagnosis/code) id=${id} in ${path.basename(fileDiagnoses)}`,
|
||||
);
|
||||
}
|
||||
|
||||
await upsertDiagnosis({
|
||||
id,
|
||||
diagnosis,
|
||||
code,
|
||||
status: parseStatus(row.status),
|
||||
created_at: parseNullableDate(row.created_at),
|
||||
created_by: parseNullableString(row.created_by),
|
||||
updated_at: parseNullableDate(row.updated_at),
|
||||
updated_by: parseNullableString(row.updated_by),
|
||||
deleted_at: parseNullableDate(row.deleted_at),
|
||||
deleted_by: parseNullableString(row.deleted_by),
|
||||
});
|
||||
await upsertDepartment(row);
|
||||
processed++;
|
||||
}
|
||||
diagnosesTotal += processed;
|
||||
log.info("Seeded diagnoses file", {
|
||||
file: path.basename(fileDiagnoses),
|
||||
|
||||
departmentsTotal += processed;
|
||||
|
||||
log.info("Seeded departments file", {
|
||||
file,
|
||||
rows: processed,
|
||||
});
|
||||
}
|
||||
|
||||
// diagnostic_procedures
|
||||
let proceduresTotal = 0;
|
||||
for (const fileProcedures of filesByPrefix["diagnostic_procedures_"]) {
|
||||
const doc = await readJsonFile<{ diagnostic_procedures?: any[] }>(
|
||||
fileProcedures,
|
||||
);
|
||||
const rows = Array.isArray(doc?.diagnostic_procedures)
|
||||
? doc.diagnostic_procedures
|
||||
: null;
|
||||
if (!rows) {
|
||||
throw new Error(
|
||||
`Invalid JSON structure for diagnostic_procedures: ${path.basename(fileProcedures)}`,
|
||||
);
|
||||
}
|
||||
|
||||
let processed = 0;
|
||||
for (const row of rows) {
|
||||
const id = parseNullableString(row.id);
|
||||
if (!id) {
|
||||
throw new Error(
|
||||
`Invalid diagnostic_procedure row (missing id) in ${path.basename(fileProcedures)}`,
|
||||
);
|
||||
}
|
||||
if (!isUuid(id)) {
|
||||
throw new Error(
|
||||
`Invalid diagnostic_procedure id (not uuid): ${id} in ${path.basename(fileProcedures)}`,
|
||||
);
|
||||
}
|
||||
|
||||
const diagnosticProcedure = parseNullableString(row.diagnosticProcedure);
|
||||
const code = parseNullableString(row.code);
|
||||
if (!diagnosticProcedure || !code) {
|
||||
throw new Error(
|
||||
`Invalid diagnostic_procedure row (missing diagnosticProcedure/code) id=${id} in ${path.basename(fileProcedures)}`,
|
||||
);
|
||||
}
|
||||
|
||||
await upsertDiagnosticProcedure({
|
||||
id,
|
||||
diagnosticProcedure,
|
||||
code,
|
||||
status: parseStatus(row.status),
|
||||
created_at: parseNullableDate(row.created_at),
|
||||
created_by: parseNullableString(row.created_by),
|
||||
updated_at: parseNullableDate(row.updated_at),
|
||||
updated_by: parseNullableString(row.updated_by),
|
||||
deleted_at: parseNullableDate(row.deleted_at),
|
||||
deleted_by: parseNullableString(row.deleted_by),
|
||||
});
|
||||
processed++;
|
||||
}
|
||||
proceduresTotal += processed;
|
||||
log.info("Seeded diagnostic_procedures file", {
|
||||
file: path.basename(fileProcedures),
|
||||
rows: processed,
|
||||
});
|
||||
}
|
||||
|
||||
log.info("Seed diagnoses data summary", {
|
||||
diagnoses_rows: diagnosesTotal,
|
||||
diagnostic_procedures_rows: proceduresTotal,
|
||||
files_processed: allJsonFiles.length,
|
||||
log.info("Seed summary", {
|
||||
departments: departmentsTotal,
|
||||
});
|
||||
|
||||
log.info("✅ Seed diagnoses data completed");
|
||||
log.info("✅ Seeder completed");
|
||||
process.exit(0);
|
||||
|
||||
} catch (error) {
|
||||
log.error("Fatal error:", error);
|
||||
process.exit(1);
|
||||
|
||||
Reference in New Issue
Block a user