Added salary method for specific personnel

Author: cevheri

salary-service/src/main/java/com/cevher/ms/salary/domain/Salary.java

@@ -0,0 +1,28 @@
+package com.cevher.ms.salary.domain;
+
+import lombok.*;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.time.LocalDate;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+@ToString
+@EqualsAndHashCode
+@Entity
+@Table(name = "salary")
+public class Salary implements Serializable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+    private LocalDate salaryDate;
+    private Long personId;
+    private Double amount;
+    private LocalDate createdAt;
+    private String createdBy;
+}

salary-service/src/main/java/com/cevher/ms/salary/dto/SalaryDto.java

@@ -0,0 +1,30 @@
+package com.cevher.ms.salary.dto;
+
+import lombok.*;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.time.chrono.ChronoLocalDate;
+import java.time.format.DateTimeFormatter;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+@ToString
+@EqualsAndHashCode
+public class SalaryDto {
+    private Long id;
+    private LocalDate salaryDate;
+    private Integer salaryTerm;
+    private Long personId;
+    private Double amount;
+
+    public Integer getSalaryTerm() {
+        return Integer.parseInt(salaryDate.format(DateTimeFormatter.ofPattern("yyyyMM")));
+    }
+}

salary-service/src/main/java/com/cevher/ms/salary/exception/AlreadySalaryException.java

@@ -0,0 +1,7 @@
+package com.cevher.ms.salary.exception;
+
+public class AlreadySalaryException extends RuntimeException {
+    public AlreadySalaryException(String current_salary_found) {
+        super(current_salary_found);
+    }
+}

salary-service/src/main/java/com/cevher/ms/salary/repository/SalaryRepository.java

@@ -0,0 +1,17 @@
+package com.cevher.ms.salary.repository;
+
+import com.cevher.ms.salary.domain.Salary;
+import com.cevher.ms.salary.dto.SalaryDto;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.time.LocalDate;
+import java.util.Optional;
+
+
+public interface SalaryRepository
+        extends JpaRepository<Salary, Long> {
+    Page<Salary> findAllByPersonId(Long personId, Pageable pageable);
+    Optional<Salary> findByPersonIdAndSalaryDate(Long personId, LocalDate salaryDate);
+}

salary-service/src/main/java/com/cevher/ms/salary/rest/SalaryResource.java

@@ -0,0 +1,42 @@
+package com.cevher.ms.salary.rest;
+
+import com.cevher.ms.salary.dto.SalaryDto;
+import com.cevher.ms.salary.service.SalaryService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.tomcat.jni.Local;
+import org.springframework.data.domain.Pageable;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDate;
+import java.util.List;
+
+@RestController
+@Slf4j
+@RequiredArgsConstructor
+@RequestMapping("/")
+public class SalaryResource {
+    private final SalaryService salaryService;
+
+
+    public ResponseEntity<List<SalaryDto>> getAllSalaryByPersonId(Long personId, Pageable pageable) {
+        var sal = salaryService.findAllByPersonId(personId, pageable);
+        return ResponseEntity.ok().body(sal.getContent());
+    }
+
+    public void deleteSalary(Long personId, LocalDate salaryDate) {
+
+    }
+
+    @PostMapping("addSalary/{personId}/{salary}")
+    public void addSalary(@PathVariable("personId") long personId,
+                          @PathVariable("salary") double salary) {
+        salaryService.addSalary(personId, salary);
+    }
+
+    public void addSalaryWithDate(Long person, Double salary, LocalDate salaryDate) {
+
+    }
+
+}

salary-service/src/main/java/com/cevher/ms/salary/service/SalaryService.java

@@ -0,0 +1,56 @@
+package com.cevher.ms.salary.service;
+
+import com.cevher.ms.salary.domain.Salary;
+import com.cevher.ms.salary.dto.SalaryDto;
+import com.cevher.ms.salary.exception.AlreadySalaryException;
+import com.cevher.ms.salary.repository.SalaryRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.util.List;
+
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class SalaryService {
+    private final SalaryRepository salaryRepository;
+
+    public Page<SalaryDto> findAllByPersonId(Long personId, Pageable pageable) {
+        return salaryRepository.findAllByPersonId(personId, pageable)
+                .map(s -> SalaryDto.builder()
+                        .id(s.getId())
+                        .personId(s.getPersonId())
+                        .salaryDate(s.getSalaryDate())
+                        .amount(s.getAmount())
+                        .build());
+
+
+    }
+
+    private void checkSalaryByPerson(Long personId, LocalDate salaryDate) {
+        salaryRepository
+                .findByPersonIdAndSalaryDate(personId, salaryDate)
+                .ifPresent(x -> {
+                    throw new AlreadySalaryException("Current Salary Found");
+                });
+    }
+
+    public void addSalary(Long personId, Double personSalary) {
+
+        checkSalaryByPerson(personId, LocalDate.now());
+
+        Salary salary = Salary.builder()
+                .personId(personId)
+                .createdAt(LocalDate.now())
+                .createdBy("system")
+                .amount(personSalary)
+                .salaryDate(LocalDate.now())
+                .build();
+        salaryRepository.save(salary);
+    }
+}