added employee current details crud and services

Author: TejasNair9977

models/employee/empCurrentDetail.js

@@ -1,6 +1,6 @@
 import connector from "#models/databaseUtil";
 
-const employeeCurrentEmployementSchema = {
+const employeeCurrentEmploymentSchema = {
   uid: { type: String, require: true },
   date_of_joining: { type: Date, required: true },
   department_name: { type: String, required: true },
@@ -11,7 +11,64 @@ const employeeCurrentEmployementSchema = {
 };
 
 // eslint-disable-next-line  no-unused-vars
-const employeeCurrentEmployement = connector.model(
-  "Employee current Employement",
-  employeeCurrentEmployementSchema,
+const EmployeeCurrentEmployment = connector.model(
+  "EmployeeCurrentEmployement",
+  employeeCurrentEmploymentSchema,
 );
+
+async function create(employeeCurrentEmploymentData) {
+  const {
+    uid,
+    dateOfJoining,
+    departmentName,
+    designation,
+    jobStatus,
+    jobProfile,
+    currentCtc,
+  } = employeeCurrentEmploymentData;
+
+  const empCurEmp = new EmployeeCurrentEmployment({
+    uid,
+    dateOfJoining,
+    departmentName,
+    designation,
+    jobStatus,
+    jobProfile,
+    currentCtc,
+  });
+
+  const empCurrentEmploymentDoc = await empCurEmp.save();
+  return empCurrentEmploymentDoc;
+}
+
+async function read(filter, limit = 0, page = 1) {
+  const empCurrentEmploymentDoc = await EmployeeCurrentEmployment.find(filter)
+    .limit(limit)
+    .skip((page - 1) * limit)
+    .exec();
+  const count = await EmployeeCurrentEmployment.count();
+  const totalPages = Math.ceil(count / limit);
+  return { totalPages, data: empCurrentEmploymentDoc };
+}
+
+async function update(filter, updateObject, options = { multi: true }) {
+  const updateResult = await EmployeeCurrentEmployment.updateMany(
+    filter,
+    { $set: updateObject },
+    options,
+  );
+  return updateResult.acknowledged;
+}
+
+async function remove(filter) {
+  const deleteResult =
+    await EmployeeCurrentEmployment.deleteMany(filter).exec();
+  return deleteResult.acknowledged;
+}
+
+export default {
+  create,
+  read,
+  update,
+  remove,
+};

services/employee/empCurrentDetail.js

@@ -0,0 +1,50 @@
+import databaseError from "#error/database";
+import EmployeeCurrent from "#models/employee/empPersonal";
+
+export async function addNewEmployeeCurrent(
+  uid,
+  dateOfJoining,
+  departmentName,
+  designation,
+  jobStatus,
+  jobProfile,
+  currentCtc,
+) {
+  const newEmployeeCurrent = await EmployeeCurrent.create({
+    uid,
+    dateOfJoining,
+    departmentName,
+    designation,
+    jobStatus,
+    jobProfile,
+    currentCtc,
+  });
+  if (newEmployeeCurrent.uid === uid) {
+    return newEmployeeCurrent;
+  }
+  throw new databaseError.DataEntryError("Add EmployeeCurrent");
+}
+
+export async function getEmployeeCurrent(filter, limit, page) {
+  const employeeCurrent = await EmployeeCurrent.read(filter, limit, page);
+  if (employeeCurrent) {
+    return employeeCurrent;
+  }
+  throw new databaseError.DataNotFoundError("EmployeeCurrent");
+}
+
+export async function deleteEmployeeCurrentById(EmployeeCurrentId) {
+  const deleted = await EmployeeCurrent.remove({ _id: EmployeeCurrentId });
+  if (deleted) {
+    return deleted;
+  }
+  throw new databaseError.DataDeleteError("EmployeeCurrent");
+}
+
+export async function updateEmployeeCurrentById(id, data) {
+  const updated = await EmployeeCurrent.update({ _id: id }, data);
+  if (updated) {
+    return updated;
+  }
+  throw new databaseError.DataEntryError("EmployeeCurrent");
+}