add feature import by excel vendor & hospital

package-lock.json

@@ -30,6 +30,7 @@
         "pg": "^8.16.2",
         "qs": "^6.14.0",
         "sharp": "^0.34.3",
+        "xlsx": "^0.18.5",
         "zod": "^4.0.5"
       },
       "devDependencies": {
@@ -42,6 +43,7 @@
         "@types/multer": "^2.0.0",
         "@types/node": "^24.0.14",
         "@types/sharp": "^0.31.1",
+        "@types/xlsx": "^0.0.35",
         "nodemon": "^3.1.10",
         "prisma": "^6.10.1",
         "ts-node": "^10.9.2",
@@ -878,6 +880,13 @@
         "@types/node": "*"
       }
     },
+    "node_modules/@types/xlsx": {
+      "version": "0.0.35",
+      "resolved": "https://registry.npmjs.org/@types/xlsx/-/xlsx-0.0.35.tgz",
+      "integrity": "sha512-s0x3DYHZzOkxtjqOk/Nv1ezGzpbN7I8WX+lzlV/nFfTDOv7x4d8ZwGHcnaiB8UCx89omPsftQhS5II3jeWePxQ==",
+      "dev": true,
+      "license": "MIT"
+    },
     "node_modules/@types/yauzl": {
       "version": "2.10.3",
       "resolved": "https://registry.npmjs.org/@types/yauzl/-/yauzl-2.10.3.tgz",
@@ -927,6 +936,15 @@
         "node": ">=0.4.0"
       }
     },
+    "node_modules/adler-32": {
+      "version": "1.3.1",
+      "resolved": "https://registry.npmjs.org/adler-32/-/adler-32-1.3.1.tgz",
+      "integrity": "sha512-ynZ4w/nUUv5rrsR8UUGoe1VC9hZj6V5hU9Qw1HlMDJGEJw5S7TfTErWTjMys6M7vr0YWcPqs3qAr4ss0nDfP+A==",
+      "license": "Apache-2.0",
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/agent-base": {
       "version": "7.1.3",
       "resolved": "https://registry.npmjs.org/agent-base/-/agent-base-7.1.3.tgz",
@@ -1177,6 +1195,19 @@
         "url": "https://github.com/sponsors/ljharb"
       }
     },
+    "node_modules/cfb": {
+      "version": "1.2.2",
+      "resolved": "https://registry.npmjs.org/cfb/-/cfb-1.2.2.tgz",
+      "integrity": "sha512-KfdUZsSOw19/ObEWasvBP/Ac4reZvAGauZhs6S/gqNhXhI7cKwvlH7ulj+dOEYnca4bm4SGo8C1bTAQvnTjgQA==",
+      "license": "Apache-2.0",
+      "dependencies": {
+        "adler-32": "~1.3.0",
+        "crc-32": "~1.2.0"
+      },
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/chokidar": {
       "version": "3.6.0",
       "resolved": "https://registry.npmjs.org/chokidar/-/chokidar-3.6.0.tgz",
@@ -1225,6 +1256,15 @@
         "node": ">=20"
       }
     },
+    "node_modules/codepage": {
+      "version": "1.15.0",
+      "resolved": "https://registry.npmjs.org/codepage/-/codepage-1.15.0.tgz",
+      "integrity": "sha512-3g6NUTPd/YtuuGrhMnOMRjFc+LJw/bnMp3+0r/Wcz3IXUuCosKRJvMphm5+Q+bvTVGcJJuRvVLuYba+WojaFaA==",
+      "license": "Apache-2.0",
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/color": {
       "version": "4.2.3",
       "resolved": "https://registry.npmjs.org/color/-/color-4.2.3.tgz",
@@ -1359,6 +1399,18 @@
         "node": ">= 0.10"
       }
     },
+    "node_modules/crc-32": {
+      "version": "1.2.2",
+      "resolved": "https://registry.npmjs.org/crc-32/-/crc-32-1.2.2.tgz",
+      "integrity": "sha512-ROmzCKrTnOwybPcJApAA6WBWij23HVfGVNKqqrZpuyZOHqK2CwHSvpGuyt/UNNvaIjEd8X5IFGp4Mh+Ie1IHJQ==",
+      "license": "Apache-2.0",
+      "bin": {
+        "crc32": "bin/crc32.njs"
+      },
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/create-require": {
       "version": "1.1.1",
       "resolved": "https://registry.npmjs.org/create-require/-/create-require-1.1.1.tgz",
@@ -1843,6 +1895,15 @@
         "node": ">= 0.6"
       }
     },
+    "node_modules/frac": {
+      "version": "1.1.2",
+      "resolved": "https://registry.npmjs.org/frac/-/frac-1.1.2.tgz",
+      "integrity": "sha512-w/XBfkibaTl3YDqASwfDUqkna4Z2p9cFSr1aHDt0WoMTECnRfBOv2WArlZILlqgWlmdIlALXGpM2AOhEk5W3IA==",
+      "license": "Apache-2.0",
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/fresh": {
       "version": "2.0.0",
       "resolved": "https://registry.npmjs.org/fresh/-/fresh-2.0.0.tgz",
@@ -3336,6 +3397,18 @@
       "license": "BSD-3-Clause",
       "optional": true
     },
+    "node_modules/ssf": {
+      "version": "0.11.2",
+      "resolved": "https://registry.npmjs.org/ssf/-/ssf-0.11.2.tgz",
+      "integrity": "sha512-+idbmIXoYET47hH+d7dfm2epdOMUDjqcB4648sTZ+t2JwoyBFL/insLfB/racrDmsKB3diwsDA696pZMieAC5g==",
+      "license": "Apache-2.0",
+      "dependencies": {
+        "frac": "~1.1.2"
+      },
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/statuses": {
       "version": "2.0.2",
       "resolved": "https://registry.npmjs.org/statuses/-/statuses-2.0.2.tgz",
@@ -3573,12 +3646,51 @@
         "node": ">= 0.8"
       }
     },
+    "node_modules/wmf": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/wmf/-/wmf-1.0.2.tgz",
+      "integrity": "sha512-/p9K7bEh0Dj6WbXg4JG0xvLQmIadrner1bi45VMJTfnbVHsc7yIajZyoSoK60/dtVBs12Fm6WkUI5/3WAVsNMw==",
+      "license": "Apache-2.0",
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
+    "node_modules/word": {
+      "version": "0.3.0",
+      "resolved": "https://registry.npmjs.org/word/-/word-0.3.0.tgz",
+      "integrity": "sha512-OELeY0Q61OXpdUfTp+oweA/vtLVg5VDOXh+3he3PNzLGG/y0oylSOC1xRVj0+l4vQ3tj/bB1HVHv1ocXkQceFA==",
+      "license": "Apache-2.0",
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/wrappy": {
       "version": "1.0.2",
       "resolved": "https://registry.npmjs.org/wrappy/-/wrappy-1.0.2.tgz",
       "integrity": "sha512-l4Sp/DRseor9wL6EvV2+TuQn63dMkPjZ/sp9XkghTEbV9KlPS1xUsZ3u7/IQO4wxtcFB4bgpQPRcR3QCvezPcQ==",
       "license": "ISC"
     },
+    "node_modules/xlsx": {
+      "version": "0.18.5",
+      "resolved": "https://registry.npmjs.org/xlsx/-/xlsx-0.18.5.tgz",
+      "integrity": "sha512-dmg3LCjBPHZnQp5/F/+nnTa+miPJxUXB6vtk42YjBBKayDNagxGEeIdWApkYPOf3Z3pm3k62Knjzp7lMeTEtFQ==",
+      "license": "Apache-2.0",
+      "dependencies": {
+        "adler-32": "~1.3.0",
+        "cfb": "~1.2.1",
+        "codepage": "~1.15.0",
+        "crc-32": "~1.2.1",
+        "ssf": "~0.11.2",
+        "wmf": "~1.0.1",
+        "word": "~0.3.0"
+      },
+      "bin": {
+        "xlsx": "bin/xlsx.njs"
+      },
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
     "node_modules/xtend": {
       "version": "4.0.2",
       "resolved": "https://registry.npmjs.org/xtend/-/xtend-4.0.2.tgz",

package.json

@@ -35,6 +35,7 @@
     "pg": "^8.16.2",
     "qs": "^6.14.0",
     "sharp": "^0.34.3",
+    "xlsx": "^0.18.5",
     "zod": "^4.0.5"
   },
   "devDependencies": {
@@ -47,6 +48,7 @@
     "@types/multer": "^2.0.0",
     "@types/node": "^24.0.14",
     "@types/sharp": "^0.31.1",
+    "@types/xlsx": "^0.0.35",
     "nodemon": "^3.1.10",
     "prisma": "^6.10.1",
     "ts-node": "^10.9.2",

prisma/migrations/20250828033126_add_field_email_in_hospital/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "hospitals" ADD COLUMN     "email" TEXT;

prisma/schema.prisma

@@ -108,6 +108,7 @@ model Hospital {
   // simrs_type           String?
   contact              String?
   image                String?
+  email                String?
   progress_status      ProgressStatus
   note                 String?
   created_by           String

src/controllers/admin/HospitalController.ts

@@ -6,6 +6,7 @@ import { PaginationParam } from '../../utils/PaginationParams';
 import { errorResponse, messageSuccessResponse } from '../../utils/Response';
 import { validateStoreHospitalRequest, validateUpdateHospitalRequest } from '../../validators/admin/hospital/HospitalValidators';
 import { CustomRequest } from '../../types/token/CustomRequest';
+import { HttpException } from '../../utils/HttpException';
 
 export const getAllHospital = async (req: Request, res: Response): Promise<Response> => {
     try {
@@ -80,4 +81,16 @@ export const deleteHospital = async (req: Request, res: Response): Promise<Respo
     } catch (err) {
         return errorResponse(res, err);
     }
+};
+
+export const importHospital = async (req: Request, res: Response): Promise<Response> => {
+    try {
+        if (!req.file) {
+            throw new HttpException("No file uploaded", 400);
+        }
+        await HospitalService.importHospitalService(req.file, req as CustomRequest);
+        return messageSuccessResponse(res, "Success import hospital", 201);
+    } catch (err) {
+        return errorResponse(res, err);
+    }
 };

src/controllers/admin/VendorController.ts

@@ -6,6 +6,7 @@ import { PaginationParam } from '../../utils/PaginationParams';
 import { errorResponse, messageSuccessResponse } from '../../utils/Response';
 import { validateStoreVendorRequest, validateUpdateVendorRequest } from '../../validators/admin/vendor/VendorValidators';
 import { CustomRequest } from '../../types/token/CustomRequest';
+import { HttpException } from '../../utils/HttpException';
 
 export const getAllVendor = async (req: Request, res: Response): Promise<Response> => {
     try {
@@ -61,65 +62,14 @@ export const deleteVendor = async (req: Request, res: Response): Promise<Respons
     }
 };
 
-
-// const { VendorCollection } = require('../../resources/admin/vendor/VendorCollection.js');
-// const { VendorResource } = require('../../resources/admin/vendor/VendorResource.js');
-// const vendorService = require('../../services/admin/VendorService.js');
-// const { PaginationParam } = require('../../utils/PaginationParams.js');
-// const { errorResponse, messageSuccessResponse } = require('../../utils/Response.js');
-// const { validateStoreVendorRequest, validateUpdateVendorRequest } = require('../../validators/admin/vendor/VendorValidators.js');
-
-// exports.getAllVendor = async (req, res) => {
-//     try {
-//         const { page, limit, search, sortBy, orderBy } = PaginationParam(req);
-
-//         const { vendors, total } = await vendorService.getAllVendorService({
-//             page, limit, search, sortBy, orderBy
-//         });
-
-//         return VendorCollection({ req, res, data: vendors, total, page, limit, message: 'Vendor data successfully retrieved' });
-//     } catch (err) {
-//         return errorResponse(res, err);
-//     }
-// };
-
-// exports.showVendor = async (req, res) => {
-//     try {
-//         const id = req.params.id;
-//         const { vendor } = await vendorService.showVendorService(id);
-//         return VendorResource(res, vendor, 'Success show vendor');
-//     } catch (err) {
-//         return errorResponse(res, err);
-//     }
-// };
-
-// exports.storeVendor = async (req, res) => {
-//     try {
-//         const validatedData = validateStoreVendorRequest(req.body);
-//         await vendorService.storeVendorService(validatedData, req);
-//         return messageSuccessResponse(res, 'Success added vendor', 201);
-//     } catch (err) {
-//         return errorResponse(res, err);
-//     }
-// }
-
-// exports.updateVendor = async (req, res) => {
-//     try {
-//         const id = req.params.id;
-//         const validatedData = validateUpdateVendorRequest(req.body);
-//         await vendorService.updateVendorService(validatedData, id, req);
-//         return messageSuccessResponse(res, 'Success update vendor');
-//     } catch (err) {
-//         return errorResponse(res, err);
-//     }
-// }
-
-// exports.deleteVendor = async (req, res) => {
-//     try {
-//         const id = req.params.id;
-//         await vendorService.deleteVendorService(id, req);
-//         return messageSuccessResponse(res, 'Success delete vendor');
-//     } catch (err) {
-//         return errorResponse(res, err);
-//     }
-// };
+export const importVendor = async (req: Request, res: Response): Promise<Response> => {
+    try {
+        if (!req.file) {
+            throw new HttpException("No file uploaded", 400);
+        }
+        await VendorService.importVendorService(req.file, req as CustomRequest);
+        return messageSuccessResponse(res, "Success import vendor", 201);
+    } catch (err) {
+        return errorResponse(res, err);
+    }
+};

src/repository/admin/HospitalRepository.ts

@@ -1,5 +1,5 @@
 import prisma from '../../prisma/PrismaClient';
-import { Prisma } from '@prisma/client';
+import { Hospital, Prisma } from '@prisma/client';
 
 interface FindAllParams {
     skip: number;
@@ -26,6 +26,7 @@ const HospitalRepository = {
                 address: true,
                 // simrs_type: true,
                 contact: true,
+                email: true,
                 image: true,
                 progress_status: true,
                 note: true,
@@ -87,6 +88,7 @@ const HospitalRepository = {
                 address: true,
                 // simrs_type: true,
                 contact: true,
+                email: true,
                 image: true,
                 progress_status: true,
                 note: true,
@@ -138,163 +140,17 @@ const HospitalRepository = {
             data,
         });
     },
-};
-
-export default HospitalRepository;
-
-
-// const prisma = require('../../prisma/PrismaClient.js');
-
-// const HospitalRepository = {
-//     findAll: async ({ skip, take, where, orderBy }) => {
-//         const hospitalsRaw = await prisma.hospital.findMany({
-//             where,
-//             skip,
-//             take,
-//             orderBy,
-//             select: {
-//                 id: true,
-//                 name: true,
-//                 hospital_code: true,
-//                 type: true,
-//                 ownership: true,
-//                 province: { select: { id: true, name: true } },
-//                 city: { select: { id: true, name: true } },
-//                 address: true,
-//                 // simrs_type: true,
-//                 contact: true,
-//                 image: true,
-//                 progress_status: true,
-//                 note: true,
-//                 latitude: true,
-//                 longitude: true,
-//                 gmaps_url: true,
-//                 created_by: true,
-//                 createdAt: true,
-//                 updatedAt: true,
-//                 user: { select: { id: true, fullname: true } },
-//                 vendor_experiences: {
-//                     where: {
-//                         status: "active",
-//                         deletedAt: null
-//                     },
-//                     select: {
-//                         vendor: {
-//                             select: {
-//                                 id: true,
-//                                 name: true,
-//                                 name_pt: true,
-//                                 strengths: true,
-//                                 weaknesses: true,
-//                                 website: true,
-//                             }
-//                         }
-//                     }
-//                 }
-//             }
-//         });
-
-//         return hospitalsRaw.map(hospital => {
-//             const { vendor_experiences, ...rest } = hospital;
-//             return {
-//                 ...rest,
-//                 vendor: vendor_experiences?.[0]?.vendor || null
-//             };
-//         });
-//     },
-
-//     countAll: async (where) => {
-//         return prisma.hospital.count({ where });
-//     },
-
-//     findById: async (id) => {
-//         const hospitalRaw = await prisma.hospital.findFirst({
-//             where: {
-//                 id,
-//                 deletedAt: null
-//             },
-//             select: {
-//                 id: true,
-//                 name: true,
-//                 hospital_code: true,
-//                 type: true,
-//                 ownership: true,
-//                 province: { select: { id: true, name: true } },
-//                 city: { select: { id: true, name: true } },
-//                 address: true,
-//                 // simrs_type: true,
-//                 contact: true,
-//                 image: true,
-//                 progress_status: true,
-//                 note: true,
-//                 latitude: true,
-//                 longitude: true,
-//                 gmaps_url: true,
-//                 created_by: true,
-//                 createdAt: true,
-//                 updatedAt: true,
-//                 user: { select: { id: true, fullname: true } },
-//                 vendor_experiences: {
-//                     where: {
-//                         status: "active",
-//                         deletedAt: null
-//                     },
-//                     take: 1,
-//                     select: {
-//                         vendor: {
-//                             select: {
-//                                 id: true,
-//                                 name: true,
-//                                 name_pt: true,
-//                                 strengths: true,
-//                                 weaknesses: true,
-//                                 website: true,
-//                             }
-//                         }
-//                     }
-//                 }
-//             }
-//         });
-
-//         if (!hospitalRaw) return null;
 
-//         const { vendor_experiences, ...rest } = hospitalRaw;
-//         return {
-//             ...rest,
-//             vendor: vendor_experiences?.[0]?.vendor || null
-//         };
-//     },
 
-//     create: async (data) => {
-//         return prisma.hospital.create({ data });
-//     },
-
-//     // update: async (id, data) => {
-//     //     return prisma.hospital.update({
-//     //         where: { id },
-//     //         data: {
-//     //             name: data.name,
-//     //             hospital_code: data.hospital_code,
-//     //             type: data.type,
-//     //             ownership: data.ownership,
-//     //             province: { connect: { id: data.province_id } },
-//     //             city: { connect: { id: data.city_id } },
-//     //             address: data.address,
-//     //             // simrs_type: data.simrs_type,
-//     //             contact: data.contact,
-//     //             note: data.note,
-//     //             image: data.image,
-//     //             progress_status: data.progress_status,
-//     //         }
-//     //     });
-//     // },
-
-//     update: async (id, data) => {
-//         return prisma.hospital.update({
-//             where: { id },
-//             data
-//         });
-//     },
-// };
+    findByName: async (name: string, hospital_code: string): Promise<Hospital | null> => {
+        return prisma.hospital.findFirst({
+            where: {
+                name,
+                hospital_code,
+                deletedAt: null,
+            },
+        });
+    },
+};
 
-// module.exports = HospitalRepository;
+export default HospitalRepository;

src/repository/admin/VendorRepository.ts

@@ -1,6 +1,6 @@
 import prisma from '../../prisma/PrismaClient';
 import { now } from '../../utils/TimeLocal';
-import { Prisma } from '@prisma/client';
+import { Prisma, Vendor } from '@prisma/client';
 
 type FindAllOptions = {
     skip?: number;
@@ -122,126 +122,16 @@ const VendorRepository = {
 
         return vendor;
     },
-};
-
-export default VendorRepository;
-
-
-// const prisma = require('../../prisma/PrismaClient.js');
-// const timeLocal = require('../../utils/TimeLocal.js');
-
-// const VendorRepository = {
-//     findAll: async ({ skip, take, where, orderBy }) => {
-//         const vendors = await prisma.vendor.findMany({
-//             where,
-//             skip,
-//             take,
-//             orderBy,
-//             select: {
-//                 id: true,
-//                 name: true,
-//                 name_pt: true,
-//                 strengths: true,
-//                 weaknesses: true,
-//                 website: true,
-//                 user: { select: { id: true, fullname: true } },
-//                 _count: {
-//                     select: {
-//                         vendor_experiences: {
-//                             where: {
-//                                 deletedAt: null
-//                             }
-//                         }
-//                     }
-//                 },
-//                 createdAt: true,
-//                 updatedAt: true,
-//             },
-//         });
-
-//         const formattedVendors = vendors.map(v => {
-//             const { _count, ...rest } = v;
-//             return {
-//                 ...rest,
-//                 count_hospitals: _count.vendor_experiences,
-//             };
-//         });
-
-//         return formattedVendors;
-//     },
-
-//     countAll: async (where) => {
-//         return prisma.vendor.count({ where });
-//     },
-
-//     findById: async (id) => {
-//         const vendor = await prisma.vendor.findFirst({
-//             where: {
-//                 id,
-//                 deletedAt: null
-//             },
-//             select: {
-//                 id: true,
-//                 name: true,
-//                 name_pt: true,
-//                 strengths: true,
-//                 weaknesses: true,
-//                 website: true,
-//                 user: { select: { id: true, fullname: true } },
-//                 _count: {
-//                     select: {
-//                         vendor_experiences: {
-//                             where: {
-//                                 deletedAt: null
-//                             }
-//                         }
-//                     }
-//                 },
-//                 createdAt: true,
-//                 updatedAt: true,
-//             },
-//         });
-
-//         const { _count, ...rest } = vendor;
-//         return {
-//             ...rest,
-//             count_hospitals: _count.vendor_experiences
-//         };
-//     },
 
-//     create: async (data) => {
-//         return prisma.vendor.create({ data });
-//     },
-
-//     update: async (id, data) => {
-//         return prisma.vendor.update({
-//             where: { id },
-//             data
-//         });
-//     },
-
-//     delete: async (id) => {
-//         // delete vendor
-//         const vendor = await prisma.vendor.update({
-//             where: { id },
-//             data: {
-//                 deletedAt: timeLocal.now().toDate()
-//             }
-//         });
-
-//         // Unlink vendor_id di vendor_histories
-//         await prisma.vendorExperience.updateMany({
-//             where: {
-//                 vendor_id: id,
-//                 deletedAt: null
-//             },
-//             data: {
-//                 vendor_id: null
-//             }
-//         });
-
-//         return vendor;
-//     },
-// };
+    findByName: async (name: string, name_pt: string): Promise<Vendor | null> => {
+        return prisma.vendor.findFirst({
+            where: {
+                name,
+                name_pt,
+                deletedAt: null,
+            },
+        });
+    },
+};
 
-// module.exports = VendorRepository;
+export default VendorRepository;

src/routes/admin/HospitalRoute.ts

@@ -17,6 +17,8 @@ router.get('/:id', [keycloak.protect(), extractToken, checkRoles(["admin"])], Ho
 router.patch('/:id', [keycloak.protect(), extractToken, checkRoles(["admin"])], upload.single('image'), HospitalController.updateHospital);
 router.delete('/:id', [keycloak.protect(), extractToken, checkRoles(["admin"])], HospitalController.deleteHospital);
 
+router.post('/import', [keycloak.protect(), extractToken, checkRoles(['admin'])], upload.single("file"), HospitalController.importHospital);
+
 // Vendor Experience
 router.get('/:id/vendor-experience', [keycloak.protect(), extractToken, checkRoles(["admin"])], VendorExperienceController.getAllVendorExperience);
 router.post('/:id/vendor-experience', [keycloak.protect(), extractToken, checkRoles(["admin"])], VendorExperienceController.storeVendorExperience);

src/routes/admin/VendorRoute.ts

@@ -3,6 +3,7 @@ import * as VendorController from '../../controllers/admin/VendorController';
 import keycloak from '../../middleware/Keycloak';
 import { extractToken } from '../../middleware/ExtractToken';
 import checkRoles from '../../middleware/CheckRoles';
+import upload from '../../middleware/UploadImage';
 
 const router: Router = express.Router();
 
@@ -12,4 +13,6 @@ router.get('/:id', [keycloak.protect(), extractToken, checkRoles(['admin', 'sale
 router.patch('/:id', [keycloak.protect(), extractToken, checkRoles(['admin', 'sales'])], VendorController.updateVendor);
 router.delete('/:id', [keycloak.protect(), extractToken, checkRoles(['admin'])], VendorController.deleteVendor);
 
+router.post('/import', [keycloak.protect(), extractToken, checkRoles(['admin'])], upload.single("file"), VendorController.importVendor);
+
 export default router;

src/services/admin/HospitalService.ts

@@ -12,7 +12,9 @@ import { HospitalRequestDTO } from '../../types/admin/hospital/HospitalDTO';
 import path from 'path';
 import fs from 'fs/promises';
 import sharp from 'sharp';
+import * as XLSX from "xlsx";
 import { storeCategoryLinkService, updateCategoryLinkService } from './CategoryLinkService';
+import { validateStoreHospitalRequest } from '../../validators/admin/hospital/HospitalValidators';
 
 interface PaginationParams {
     page: number;
@@ -151,6 +153,7 @@ export const storeHospitalService = async (validateData: HospitalRequestDTO, req
         ownership: validateData.ownership,
         address: validateData.address,
         contact: validateData.contact,
+        email: validateData.email,
         image: imagePath,
         latitude,
         longitude,
@@ -278,6 +281,7 @@ export const updateHospitalService = async (validateData: Partial<HospitalReques
         ...(validateData.ownership && { ownership: validateData.ownership }),
         ...(validateData.address && { address: validateData.address }),
         ...(validateData.contact && { contact: validateData.contact }),
+        ...(validateData.email && { email: validateData.email }),
         ...(validateData.note !== undefined && { note: validateData.note }),
         ...(validateData.progress_status && { progress_status: validateData.progress_status }),
         ...(imagePath && { image: imagePath }),
@@ -319,236 +323,102 @@ export const deleteHospitalService = async (id: string, req: CustomRequest) => {
     await deleteLog(req, data);
 };
 
-// const HospitalRepository = require('../../repository/admin/HospitalRepository.js');
-// const HttpException = require('../../utils/HttpException.js');
-// const { SearchFilter } = require('../../utils/SearchFilter.js');
-// const timeLocal = require('../../utils/TimeLocal.js');
-// const { createLog, updateLog, deleteLog } = require('../../utils/LogActivity.js');
-// const ProvinceRepository = require('../../repository/admin/ProvinceRepository.js');
-// const CityRepository = require('../../repository/admin/CityRepository.js');
-// const { BASE_URL } = require('../../../config/config.js');
-// const prisma = require('../../prisma/PrismaClient.js');
-// const { formatISOWithoutTimezone } = require('../../utils/FormatDate.js');
-
-// exports.getAllHospitalService = async ({ page, limit, search, sortBy, orderBy, province, city, type, ownership, progress_status }) => {
-//     const skip = (page - 1) * limit;
-
-//     const where = {
-//         ...SearchFilter(search, ['name', 'province.id', 'city.id', 'type', 'ownership', 'simrs_type']),
-//         ...(province ? { province_id: province } : {}),
-//         ...(city ? { city_id: city } : {}),
-//         ...(type ? { type: type } : {}),
-//         ...(ownership ? { ownership: ownership } : {}),
-//         ...(progress_status ? { progress_status: progress_status } : {}),
-//         deletedAt: null
-//     };
-
-//     const [hospitals, total] = await Promise.all([
-//         HospitalRepository.findAll({ skip, take: limit, where, orderBy: { [sortBy]: orderBy } }),
-//         HospitalRepository.countAll(where)
-//     ]);
-
-//     return { hospitals, total };
-// };
-
-// exports.showHospitalService = async (id) => {
-//     const hospital = await HospitalRepository.findById(id);
-//     if (!hospital) {
-//         throw new HttpException("Data hospital not found", 404);
-//     }
-
-//     return hospital;
-// };
-
-// exports.storeHospitalService = async (validateData, req) => {
-//     const creatorId = req.tokenData.sub;
-//     const province = await ProvinceRepository.findById(validateData.province_id);
-//     if (!province) {
-//         throw new HttpException('Province not found', 404);
-//     }
-
-//     const city = await CityRepository.findById(validateData.city_id);
-//     if (!city) {
-//         throw new HttpException('City not found', 404);
-//     }
-
-//     if (!req.file) {
-//         throw new HttpException({ image: ['image file is required'] }, 422);
-//     }
-
-//     const existingHospital = await prisma.hospital.findFirst({
-//         where: {
-//             name: validateData.name,
-//             city_id: validateData.city_id,
-//             deletedAt: null
-//         }
-//     });
-
-//     if (existingHospital) {
-//         throw new HttpException('Hospital with same name in this city already exists', 400);
-//     }
-
-//     const imagePath = req.file ? `/storage/img/${req.file.filename}` : null;
-
-//     let latitude = validateData.latitude ?? null;
-//     let longitude = validateData.longitude ?? null;
-//     let gmapsUrl = validateData.gmaps_url ?? null;
-
-//     if (gmapsUrl) {
-//         if (gmapsUrl.includes("www.google.com/maps")) {
-//             const regex = /@(-?\d+\.\d+),(-?\d+\.\d+)/;
-//             const match = gmapsUrl.match(regex);
-
-//             if (match) {
-//                 latitude = parseFloat(match[1]);
-//                 longitude = parseFloat(match[2]);
-//             } else {
-//                 throw new HttpException("Unable to extract coordinates from gmaps_url", 400);
-//             }
-
-//         } else if (gmapsUrl.includes("maps.app.goo.gl")) {
-//             latitude = null;
-//             longitude = null;
-
-//         } else {
-//             // URL disediakan tapi bukan dari domain yang valid
-//             throw new HttpException("gmaps_url must be a valid Google Maps URL", 400);
-//         }
-//     } else if (latitude !== null && longitude !== null) {
-//         gmapsUrl = null;
-//     } else {
-//         throw new HttpException("Either gmaps_url or coordinates must be provided", 400);
-//     }
-
-//     const payload = {
-//         ...validateData,
-//         image: imagePath,
-//         progress_status: "cari_data",
-//         // simrs_type: "-",
-//         created_by: creatorId,
-//         latitude,
-//         longitude,
-//         gmaps_url: gmapsUrl,
-//     };
-
-//     const data = await HospitalRepository.create(payload);
-//     await createLog(req, data);
-// };
+export const importHospitalService = async (file: Express.Multer.File, req: CustomRequest) => {
+    const creatorId = req.tokenData.sub;
 
-// const validProgressStatuses = ['cari_data', 'dihubungi', 'negosiasi', 'follow_up', 'mou', 'onboarded', 'tidak_berminat'];
+    const workbook = XLSX.read(file.buffer, { type: "buffer" });
+    const sheetName = workbook.SheetNames[0];
+    const sheet = workbook.Sheets[sheetName];
+    const rows: string[] = XLSX.utils.sheet_to_json(sheet);
+
+    for (const row of rows) {
+        const validatedData = validateStoreHospitalRequest(row);
+
+        // Cek provinsi
+        const province = await ProvinceRepository.findById(validatedData.province_id!);
+        if (!province) throw new HttpException('Province not found', 404);
+
+        // Cek kota
+        const city = await CityRepository.findById(validatedData.city_id!);
+        if (!city) throw new HttpException('City not found', 404);
 
-// exports.updateHospitalService = async (validateData, id, req) => {
-//     const hospital = await HospitalRepository.findById(id);
-//     if (!hospital) {
-//         throw new HttpException("Hospital data not found", 404);
-//     }
-
-//     if (validateData.province_id) {
-//         const province = await ProvinceRepository.findById(validateData.province_id);
-//         if (!province) {
-//             throw new HttpException('Province not found', 404);
-//         }
-//     }
-
-//     if (validateData.city_id) {
-//         const city = await CityRepository.findById(validateData.city_id);
-//         if (!city) {
-//             throw new HttpException('City not found', 404);
-//         }
-//     }
-
-//     if (validateData.progress_status && !validProgressStatuses.includes(validateData.progress_status)) {
-//         throw new HttpException(
-//             `Invalid progress_status. Allowed values are: ${validProgressStatuses.join(', ')}`,
-//             422
-//         );
-//     }
-
-//     if (validateData.name && validateData.city_id) {
-//         const existingHospital = await prisma.hospital.findFirst({
-//             where: {
-//                 name: validateData.name,
-//                 city_id: validateData.city_id,
-//                 deletedAt: null,
-//                 NOT: { id }
-//             }
-//         });
-
-//         if (existingHospital) {
-//             throw new HttpException('Hospital with same name in this city already exists', 400);
-//         }
-//     }
-
-//     // Jika ada file baru, replace image
-//     let imagePath = hospital.image; // pakai yang lama
-//     if (req.file) {
-//         imagePath = `/storage/img/${req.file.filename}`; // path relatif
-//     }
-
-
-//     // Handle koordinat dan gmaps_url
-//     let latitude = hospital.latitude;
-//     let longitude = hospital.longitude;
-//     let gmapsUrl = hospital.gmaps_url;
-
-//     if (
-//         validateData.latitude !== undefined &&
-//         validateData.longitude !== undefined &&
-//         validateData.latitude !== null &&
-//         validateData.longitude !== null
-//     ) {
-//         // Jika diberikan lat long langsung
-//         latitude = validateData.latitude;
-//         longitude = validateData.longitude;
-//         gmapsUrl = validateData.gmaps_url || gmapsUrl;
-//     } else if (
-//         validateData.gmaps_url &&
-//         typeof validateData.gmaps_url === "string" &&
-//         validateData.gmaps_url.trim() !== ""
-//     ) {
-//         gmapsUrl = validateData.gmaps_url;
-
-//         if (gmapsUrl.includes("www.google.com/maps")) {
-//             const regex = /@(-?\d+\.\d+),(-?\d+\.\d+)/;
-//             const match = gmapsUrl.match(regex);
-//             if (match) {
-//                 latitude = parseFloat(match[1]);
-//                 longitude = parseFloat(match[2]);
-//             } else {
-//                 throw new HttpException("Unable to extract coordinates from gmaps_url", 400);
-//             }
-//         } else if (gmapsUrl.includes("maps.app.goo.gl")) {
-//             // Tidak bisa ambil koordinat langsung
-//             latitude = null;
-//             longitude = null;
-//         } else {
-//             throw new HttpException("gmaps_url must be a valid Google Maps URL", 400);
-//         }
-//     }
-
-//     const payload = {
-//         ...validateData,
-//         image: imagePath,
-//         // created_by: req.user.id,
-//         latitude,
-//         longitude,
-//         gmaps_url: gmapsUrl,
-//     };
-
-//     const data = await HospitalRepository.update(id, payload);
-//     await updateLog(req, data);
-// };
-
-// exports.deleteHospitalService = async (id, req) => {
-//     const hospital = await HospitalRepository.findById(id);
-
-//     if (!hospital) {
-//         throw new HttpException('Hospital not found', 404);
-//     }
-
-//     const data = await HospitalRepository.update(id, {
-//         deletedAt: timeLocal.now().toDate()
-//     });
-
-//     await deleteLog(req, data);
-// };
+        // Cek duplikat hospital (berdasarkan nama + city)
+        const existingHospital = await prisma.hospital.findFirst({
+            where: {
+                name: validatedData.name,
+                city_id: validatedData.city_id,
+                contact: validatedData.contact,
+                deletedAt: null
+            }
+        });
+        if (existingHospital) {
+            throw new HttpException(`Hospital ${validatedData.name} in this city already exists`, 400);
+        }
+
+        // Atur imagePath (karena import via file excel biasanya tidak ada gambar)
+        let imagePath: string | null = null;
+
+        // Ambil lat-long dari gmaps_url kalau ada
+        let { latitude, longitude, gmaps_url: gmapsUrl } = validatedData;
+        if (gmapsUrl) {
+            if (gmapsUrl.includes("www.google.com/maps")) {
+                const regex = /@(-?\d+\.\d+),(-?\d+\.\d+)/;
+                const match = gmapsUrl.match(regex);
+                if (match) {
+                    latitude = parseFloat(match[1]);
+                    longitude = parseFloat(match[2]);
+                } else {
+                    throw new HttpException("Unable to extract coordinates from gmaps_url", 400);
+                }
+            } else if (gmapsUrl.includes("maps.app.goo.gl")) {
+                latitude = null;
+                longitude = null;
+            } else {
+                throw new HttpException("gmaps_url must be a valid Google Maps URL", 400);
+            }
+        } else if (latitude !== null && longitude !== null) {
+            gmapsUrl = null;
+        } else {
+            throw new HttpException("Either gmaps_url or coordinates must be provided", 400);
+        }
+
+        const payload: Prisma.HospitalCreateInput = {
+            name: validatedData.name!,
+            hospital_code: validatedData.hospital_code,
+            type: validatedData.type,
+            ownership: validatedData.ownership,
+            address: validatedData.address,
+            contact: validatedData.contact,
+            email: validatedData.email,
+            image: imagePath,
+            latitude,
+            longitude,
+            gmaps_url: gmapsUrl,
+            progress_status: ProgressStatus.cari_data,
+            note: validatedData.note ?? '',
+            province: {
+                connect: { id: validatedData.province_id! },
+            },
+            city: {
+                connect: { id: validatedData.city_id! },
+            },
+            user: {
+                connect: { id: creatorId },
+            },
+        };
+
+        const data = await HospitalRepository.create(payload);
+
+        // tags kategori kalau ada
+        if (validatedData.tags?.length) {
+            await storeCategoryLinkService(
+                validatedData.tags,
+                'hospital_notes',
+                data.id,
+                req
+            );
+        }
+
+        await createLog(req, data);
+    }
+};

src/services/admin/VendorService.ts

@@ -7,7 +7,9 @@ import { Request } from 'express';
 import { Prisma } from '@prisma/client';
 import { VendorRequestDTO } from '../../types/admin/vendor/VendorDTO';
 import { CustomRequest } from '../../types/token/CustomRequest';
+import * as XLSX from "xlsx";
 import { storeCategoryLinkService, updateCategoryLinkService } from './CategoryLinkService';
+import { validateStoreVendorRequest } from '../../validators/admin/vendor/VendorValidators';
 
 interface PaginationParams {
     page: number;
@@ -158,103 +160,41 @@ export const deleteVendorService = async (id: string, req: CustomRequest) => {
     await deleteLog(req, data);
 };
 
-// const VendorRepository = require('../../repository/admin/VendorRepository.js');
-// const HttpException = require('../../utils/HttpException.js');
-// const prisma = require('../../prisma/PrismaClient.js');
-// const { SearchFilter } = require('../../utils/SearchFilter.js');
-// const timeLocal = require('../../utils/TimeLocal.js');
-// const { createLog, updateLog, deleteLog } = require('../../utils/LogActivity.js');
-// const { formatISOWithoutTimezone } = require('../../utils/FormatDate.js');
-// const { getUserNameById } = require('../../utils/CheckUserKeycloak.js');
-
-// exports.getAllVendorService = async ({ page, limit, search, sortBy, orderBy }) => {
-//     const skip = (page - 1) * limit;
-
-//     const where = {
-//         ...SearchFilter(search, ['name', 'name_pt']),
-//         deletedAt: null
-//     };
-
-//     const [vendors, total] = await Promise.all([
-//         VendorRepository.findAll({ skip, take: limit, where, orderBy: { [sortBy]: orderBy } }),
-//         VendorRepository.countAll(where)
-//     ]);
-
-//     return { vendors, total };
-// };
-
-// exports.showVendorService = async (id) => {
-//     const vendor = await VendorRepository.findById(id);
-//     if (!vendor) {
-//         throw new HttpException("Data vendor not found", 404);
-//     }
-
-//     // const userName = await getUserNameById(vendor.created_by);
-
-//     return { vendor };
-// };
-
-// exports.storeVendorService = async (validateData, req) => {
-//     const creatorId = req.tokenData.sub;
-
-//     const name_vendor = await prisma.vendor.findFirst({
-//         where: {
-//             name: validateData.name,
-//             deletedAt: null
-//         }
-//     });
-
-//     if (name_vendor) {
-//         throw new HttpException("Vendor name must be unique", 400);
-//     }
-
-//     const payload = {
-//         ...validateData,
-//         created_by: creatorId
-//     };
-
-//     const data = await VendorRepository.create(payload);
-//     await createLog(req, data);
-// };
-
-// exports.updateVendorService = async (validateData, id, req) => {
-//     // const creatorId = req.user.id;
-
-//     const vendor = await VendorRepository.findById(id);
-//     if (!vendor) {
-//         throw new HttpException("Data vendor not found", 404);
-//     }
-
-//     if (validateData.name && validateData.name !== vendor.name) {
-//         const name_vendor = await prisma.vendor.findFirst({
-//             where: {
-//                 name: validateData.name,
-//                 deletedAt: null
-//             }
-//         });
-
-//         if (name_vendor) {
-//             throw new HttpException("Vendor name must be unique", 400);
-//         }
-//     }
-
-//     const payload = {
-//         ...validateData,
-//         // created_by: creatorId
-//     };
-
-//     const data = await VendorRepository.update(id, payload);
-//     await updateLog(req, data);
-// };
-
-// exports.deleteVendorService = async (id, req) => {
-//     const vendor = await VendorRepository.findById(id);
-
-//     if (!vendor) {
-//         throw new HttpException('Vendor not found', 404);
-//     }
-
-//     const data = await VendorRepository.delete(id);
-
-//     await deleteLog(req, data);
-// };
+export const importVendorService = async (file: Express.Multer.File, req: CustomRequest) => {
+    const workbook = XLSX.read(file.buffer, { type: "buffer" });
+    const sheetName = workbook.SheetNames[0];
+    const sheet = workbook.Sheets[sheetName];
+    const rows: string[] = XLSX.utils.sheet_to_json(sheet);
+
+    for (const row of rows) {
+        const validatedData = validateStoreVendorRequest(row);
+
+        const existingVendor = await VendorRepository.findByName(validatedData.name, validatedData.name_pt);
+        if (existingVendor) {
+            throw new HttpException(`Vendor ${validatedData.name} already exists`, 400);
+        }
+
+        const payload: Prisma.VendorCreateInput = {
+            ...validatedData,
+            user: {
+                connect: {
+                    id: req.tokenData.sub,
+                },
+            },
+            strengths: validatedData.strengths?.note,
+            weaknesses: validatedData.weaknesses?.note,
+        };
+
+        const data = await VendorRepository.create(payload);
+
+        // category links
+        if (validatedData.strengths?.tags?.length) {
+            await storeCategoryLinkService(validatedData.strengths.tags, "vendor_strength_notes", data.id, req);
+        }
+        if (validatedData.weaknesses?.tags?.length) {
+            await storeCategoryLinkService(validatedData.weaknesses.tags, "vendor_weaknesses_notes", data.id, req);
+        }
+
+        await createLog(req, data);
+    }
+};

src/types/admin/hospital/HospitalDTO.ts

@@ -9,6 +9,7 @@ export interface HospitalRequestDTO {
     city_id?: string;
     address?: string | null;
     contact?: string | null;
+    email?: string | null;
     gmaps_url?: string | null;
     latitude?: number | null;
     longitude?: number | null;
@@ -34,6 +35,7 @@ export interface HospitalDTO {
     address: string | null;
     contact: string | null;
     image: string | null;
+    email: string | null;
     progress_status: ProgressStatus;
     note: string | null;
     note_tags?: string[];

src/validators/admin/hospital/HospitalValidators.ts

@@ -6,27 +6,23 @@ export const storeHospitalSchema = Joi.object({
     name: Joi.string().trim().required().messages({
         'string.empty': 'name is required',
     }),
-    hospital_code: Joi.string().trim().required().messages({
-        'string.empty': 'hospital code is required',
-    }),
+    hospital_code: Joi.alternatives().try(Joi.string().trim(), Joi.number()).required()
+        .messages({ 'any.required': 'hospital code is required' })
+        .custom((value) => String(value).trim()),
     type: Joi.string().trim().required().messages({
         'string.empty': 'type is required',
     }),
-    ownership: Joi.string().trim().required().messages({
-        'string.empty': 'ownership is required',
-    }),
+    ownership: Joi.string().trim().optional(),
     province_id: Joi.string().trim().required().messages({
         'string.empty': 'province id is required',
     }),
     city_id: Joi.string().trim().required().messages({
         'string.empty': 'city id is required',
     }),
-    address: Joi.string().trim().required().messages({
-        'string.empty': 'address is required',
-    }),
-    contact: Joi.string().trim().required().messages({
-        'string.empty': 'contact is required',
-    }),
+    address: Joi.string().trim().optional(),
+    // contact: Joi.string().trim().optional(),
+    contact: Joi.alternatives().try(Joi.string().trim(), Joi.number()).optional().custom((value) => String(value).trim()),
+    email: Joi.string().trim().optional(),
     note: Joi.string().allow('', null),
     tags: Joi.array().items(Joi.string()).optional().default([]),
     gmaps_url: Joi.string().trim().optional().allow(null, ''),
@@ -44,6 +40,7 @@ export const updateHospitalSchema = Joi.object({
     city_id: Joi.string().trim().optional(),
     address: Joi.string().trim().optional(),
     contact: Joi.string().trim().optional(),
+    email: Joi.string().trim().optional(),
     note: Joi.string().allow('', null),
     tags: Joi.array().items(Joi.string()).optional().default([]),
     image: Joi.any().optional().allow(null, ''),

src/validators/admin/vendor/VendorValidators.ts

@@ -9,15 +9,7 @@ const vendorSchema = Joi.object<VendorRequestDTO>({
     name_pt: Joi.string().trim().required().messages({
         'string.empty': 'Vendor name pt is required',
     }),
-    // strengths: Joi.string().trim().required().messages({
-    //     'string.empty': 'Vendor strengths is required',
-    // }),
-    // weaknesses: Joi.string().trim().required().messages({
-    //     'string.empty': 'Vendor weaknesses is required',
-    // }),
-    website: Joi.string().trim().required().messages({
-        'string.empty': 'Vendor website is required',
-    }),
+    website: Joi.string().trim().optional(),
     strengths: Joi.object({
         note: Joi.string().allow('', null),
         tags: Joi.array().items(Joi.string()).optional().default([]),
@@ -36,12 +28,6 @@ const updateVendorSchema = Joi.object<Partial<VendorRequestDTO>>({
     name_pt: Joi.string().trim().optional().messages({
         'string.empty': 'Vendor name_pt is required',
     }),
-    // strengths: Joi.string().trim().optional().messages({
-    //     'string.empty': 'Vendor strengths is required',
-    // }),
-    // weaknesses: Joi.string().trim().optional().messages({
-    //     'string.empty': 'Vendor weaknesses is required',
-    // }),
     website: Joi.string().trim().optional().messages({
         'string.empty': 'Vendor website is required',
     }),