diff --git a/src/employees/employees.module.ts b/src/employees/employees.module.ts index 16f3d39c0777b2b6ccb76a75e5280d17fc434d40..152ad76b7c8f1582c1229590a8b80ff82ef2c629 100644 --- a/src/employees/employees.module.ts +++ b/src/employees/employees.module.ts @@ -1,8 +1,11 @@ import { Module } from '@nestjs/common'; +import { TypeOrmModule } from '@nestjs/typeorm'; // ✅ เพิ่ม import { EmployeesService } from './employees.service'; import { EmployeesController } from './employees.controller'; +import { Employee } from './entities/employee.entity'; // ✅ เพิ่ม @Module({ + imports: [TypeOrmModule.forFeature([Employee])], // ✅ เพิ่ม controllers: [EmployeesController], providers: [EmployeesService], }) diff --git a/src/employees/employees.service.ts b/src/employees/employees.service.ts index 8d9e02e4d46d3a352c5b686cbefe9f9e296af1d7..e0f0db8a26f54606162238008e83700f1d9db588 100644 --- a/src/employees/employees.service.ts +++ b/src/employees/employees.service.ts @@ -1,26 +1,41 @@ import { Injectable } from '@nestjs/common'; +import { InjectRepository } from '@nestjs/typeorm'; +import { Repository } from 'typeorm'; import { CreateEmployeeDto } from './dto/create-employee.dto'; import { UpdateEmployeeDto } from './dto/update-employee.dto'; +import { Employee } from './entities/employee.entity'; @Injectable() export class EmployeesService { + constructor( + @InjectRepository(Employee) + private readonly employeeRepository: Repository<Employee>, + ) {} + + // ✅ ใช้งานจริง create(createEmployeeDto: CreateEmployeeDto) { - return 'This action adds a new employee'; + const newEmployee = this.employeeRepository.create(createEmployeeDto); + return this.employeeRepository.save(newEmployee); } + // ✅ ดึงพนักงานทั้งหมดจาก DB findAll() { - return `This action returns all employees`; + return this.employeeRepository.find(); } + // ✅ ดึงพนักงานตาม ID findOne(id: number) { - return `This action returns a #${id} employee`; + return this.employeeRepository.findOneBy({ EmployeeID: id }); } - update(id: number, updateEmployeeDto: UpdateEmployeeDto) { - return `This action updates a #${id} employee`; + // ✅ อัปเดตพนักงาน + async update(id: number, updateEmployeeDto: UpdateEmployeeDto) { + await this.employeeRepository.update(id, updateEmployeeDto); + return this.findOne(id); } + // ✅ ลบพนักงาน remove(id: number) { - return `This action removes a #${id} employee`; + return this.employeeRepository.delete(id); } }