history update position

src/services/PositionService.ts

@@ -0,0 +1,216 @@
+import { AppDataSource } from "../database/data-source";
+import { EmployeePosMaster } from "../entities/EmployeePosMaster";
+import { EmployeeTempPosMaster } from "../entities/EmployeeTempPosMaster";
+import { PosMaster } from "../entities/PosMaster";
+import { PosMasterEmployeeHistory } from "../entities/PosMasterEmployeeHistory";
+import { PosMasterEmployeeTempHistory } from "../entities/PosMasterEmployeeTempHistory";
+import { PosMasterHistory } from "../entities/PosMasterHistory";
+import { RequestWithUser } from "../middlewares/user";
+
+export async function CreatePosMasterHistoryOfficer(
+  posMasterId: string,
+  request: RequestWithUser | null,
+): Promise<boolean> {
+  try {
+    await AppDataSource.transaction(async (manager) => {
+      const repoPosmaster = manager.getRepository(PosMaster);
+      const repoHistory = manager.getRepository(PosMasterHistory);
+
+      const pm = await repoPosmaster.findOne({
+        where: { id: posMasterId },
+        relations: [
+          "positions",
+          "positions.posLevel",
+          "positions.posType",
+          "positions.posExecutive",
+          "orgRoot",
+          "orgChild1",
+          "orgChild2",
+          "orgChild3",
+          "orgChild4",
+          "current_holder",
+        ],
+      });
+
+      if (!pm) return false;
+      if (!pm.ancestorDNA) return false;
+      const _null: any = null;
+      const h = new PosMasterHistory();
+      const selectedPosition =
+        pm.positions.length > 0
+          ? pm.positions.find((p) => p.positionIsSelected === true) ?? null
+          : null;
+      h.ancestorDNA = pm.ancestorDNA;
+      h.prefix = pm.current_holder?.prefix || _null;
+      h.firstName = pm.current_holder?.firstName || _null;
+      h.lastName = pm.current_holder?.lastName || _null;
+      h.posMasterNoPrefix = pm.posMasterNoPrefix ?? _null;
+      h.posMasterNo = pm.posMasterNo ?? _null;
+      h.posMasterNoSuffix = pm.posMasterNoSuffix ?? _null;
+      h.position = selectedPosition?.positionName ?? _null;
+      h.posType = selectedPosition?.posType?.posTypeName ?? _null;
+      h.posLevel = selectedPosition?.posLevel?.posLevelName ?? _null;
+      h.posExecutive = selectedPosition?.posExecutive?.posExecutiveName ?? _null;
+      h.shortName =
+        [
+          pm.orgChild4?.orgChild4ShortName,
+          pm.orgChild3?.orgChild3ShortName,
+          pm.orgChild2?.orgChild2ShortName,
+          pm.orgChild1?.orgChild1ShortName,
+          pm.orgRoot?.orgRootShortName,
+        ].find((s) => typeof s === "string" && s.trim().length > 0) ?? _null;
+      const userId = request?.user?.sub ?? "";
+      const userName = request?.user?.name ?? "system";
+      h.createdUserId = userId;
+      h.createdFullName = userName;
+      h.lastUpdateUserId = userId;
+      h.lastUpdateFullName = userName;
+      h.createdAt = new Date();
+      h.lastUpdatedAt = new Date();
+      await repoHistory.save(h);
+    });
+
+    return true;
+  } catch (err) {
+    console.error("CreatePosMasterHistoryOfficer transaction error:", err);
+    return false;
+  }
+}
+
+export async function CreatePosMasterHistoryEmployee(
+  posMasterId: string,
+  request: RequestWithUser | null,
+): Promise<boolean> {
+  try {
+    await AppDataSource.transaction(async (manager) => {
+      const repoPosmaster = manager.getRepository(EmployeePosMaster);
+      const repoHistory = manager.getRepository(PosMasterEmployeeHistory);
+
+      const pm = await repoPosmaster.findOne({
+        where: { id: posMasterId },
+        relations: [
+          "positions",
+          "positions.posLevel",
+          "positions.posType",
+          "positions.posExecutive",
+          "orgRoot",
+          "orgChild1",
+          "orgChild2",
+          "orgChild3",
+          "orgChild4",
+          "current_holder",
+        ],
+      });
+
+      if (!pm) return false;
+      if (!pm.ancestorDNA) return false;
+      const _null: any = null;
+      const h = new PosMasterEmployeeHistory();
+      const selectedPosition =
+        pm.positions.length > 0
+          ? pm.positions.find((p) => p.positionIsSelected === true) ?? null
+          : null;
+      h.ancestorDNA = pm.ancestorDNA;
+      h.prefix = pm.current_holder?.prefix || _null;
+      h.firstName = pm.current_holder?.firstName || _null;
+      h.lastName = pm.current_holder?.lastName || _null;
+      h.posMasterNoPrefix = pm.posMasterNoPrefix ?? _null;
+      h.posMasterNo = pm.posMasterNo ?? _null;
+      h.posMasterNoSuffix = pm.posMasterNoSuffix ?? _null;
+      h.position = selectedPosition?.positionName ?? _null;
+      h.posType = selectedPosition?.posType?.posTypeName ?? _null;
+      h.posLevel = selectedPosition?.posLevel?.posLevelName ?? _null;
+      h.shortName =
+        [
+          pm.orgChild4?.orgChild4ShortName,
+          pm.orgChild3?.orgChild3ShortName,
+          pm.orgChild2?.orgChild2ShortName,
+          pm.orgChild1?.orgChild1ShortName,
+          pm.orgRoot?.orgRootShortName,
+        ].find((s) => typeof s === "string" && s.trim().length > 0) ?? _null;
+      const userId = request?.user?.sub ?? "";
+      const userName = request?.user?.name ?? "system";
+      h.createdUserId = userId;
+      h.createdFullName = userName;
+      h.lastUpdateUserId = userId;
+      h.lastUpdateFullName = userName;
+      h.createdAt = new Date();
+      h.lastUpdatedAt = new Date();
+      await repoHistory.save(h);
+    });
+
+    return true;
+  } catch (err) {
+    console.error("CreatePosMasterHistoryEmployee transaction error:", err);
+    return false;
+  }
+}
+
+export async function CreatePosMasterHistoryEmployeeTemp(
+  posMasterId: string,
+  request: RequestWithUser | null,
+): Promise<boolean> {
+  try {
+    await AppDataSource.transaction(async (manager) => {
+      const repoPosmaster = manager.getRepository(EmployeeTempPosMaster);
+      const repoHistory = manager.getRepository(PosMasterEmployeeTempHistory);
+
+      const pm = await repoPosmaster.findOne({
+        where: { id: posMasterId },
+        relations: [
+          "positions",
+          "positions.posLevel",
+          "positions.posType",
+          "positions.posExecutive",
+          "orgRoot",
+          "orgChild1",
+          "orgChild2",
+          "orgChild3",
+          "orgChild4",
+          "current_holder",
+        ],
+      });
+
+      if (!pm) return false;
+      if (!pm.ancestorDNA) return false;
+      const _null: any = null;
+      const h = new PosMasterEmployeeTempHistory();
+      const selectedPosition =
+        pm.positions.length > 0
+          ? pm.positions.find((p) => p.positionIsSelected === true) ?? null
+          : null;
+      h.ancestorDNA = pm.ancestorDNA;
+      h.prefix = pm.current_holder?.prefix || _null;
+      h.firstName = pm.current_holder?.firstName || _null;
+      h.lastName = pm.current_holder?.lastName || _null;
+      h.posMasterNoPrefix = pm.posMasterNoPrefix ?? _null;
+      h.posMasterNo = pm.posMasterNo ?? _null;
+      h.posMasterNoSuffix = pm.posMasterNoSuffix ?? _null;
+      h.position = selectedPosition?.positionName ?? _null;
+      h.posType = selectedPosition?.posType?.posTypeName ?? _null;
+      h.posLevel = selectedPosition?.posLevel?.posLevelName ?? _null;
+      h.shortName =
+        [
+          pm.orgChild4?.orgChild4ShortName,
+          pm.orgChild3?.orgChild3ShortName,
+          pm.orgChild2?.orgChild2ShortName,
+          pm.orgChild1?.orgChild1ShortName,
+          pm.orgRoot?.orgRootShortName,
+        ].find((s) => typeof s === "string" && s.trim().length > 0) ?? _null;
+      const userId = request?.user?.sub ?? "";
+      const userName = request?.user?.name ?? "system";
+      h.createdUserId = userId;
+      h.createdFullName = userName;
+      h.lastUpdateUserId = userId;
+      h.lastUpdateFullName = userName;
+      h.createdAt = new Date();
+      h.lastUpdatedAt = new Date();
+      await repoHistory.save(h);
+    });
+
+    return true;
+  } catch (err) {
+    console.error("CreatePosMasterHistoryEmployeeTemp transaction error:", err);
+    return false;
+  }
+}

src/services/rabbitmq.ts

@@ -5,14 +5,12 @@ import { chunkArray, commandTypePath } from "../interfaces/utils";
 import CallAPI from "../interfaces/call-api";
 import HttpError from "../interfaces/http-error";
 import HttpStatusCode from "../interfaces/http-status";
-import { RequestWithUser } from "../middlewares/user";
 import { PosMaster } from "../entities/PosMaster";
 import { Profile } from "../entities/Profile";
 import { EmployeePosMaster } from "../entities/EmployeePosMaster";
 import { EmployeeTempPosMaster } from "../entities/EmployeeTempPosMaster";
 import { ProfileEmployee } from "../entities/ProfileEmployee";
 import { OrgRevision } from "../entities/OrgRevision";
-import { request } from "http";
 import { EmployeePosition } from "../entities/EmployeePosition";
 import { OrgChild1 } from "../entities/OrgChild1";
 import { OrgChild2 } from "../entities/OrgChild2";
@@ -25,6 +23,7 @@ import { In, Not } from "typeorm";
 import { PosMasterAct } from "../entities/PosMasterAct";
 import { PermissionOrg } from "../entities/PermissionOrg";
 import { sendWebSocket } from "./webSocket";
+import { CreatePosMasterHistoryOfficer } from "./PositionService";
 
 export let sendToQueue: (payload: any) => void;
 export let sendToQueueOrg: (payload: any) => void;
@@ -580,6 +579,7 @@ async function handler_org(msg: amqp.ConsumeMessage): Promise<boolean> {
       item.lastUpdateFullName = lastUpdateFullName;
       item.lastUpdatedAt = lastUpdatedAt;
       await repoPosmaster.save(item).catch((e) => console.log(e));
+      await CreatePosMasterHistoryOfficer(item.id, null);
     }
     if (orgRevisionPublish != null && orgRevisionDraft != null) {
       //new main revision