feat: finish VisitService and VisitServiceImpl

src/main/java/com/example/nto/service/TerminalService.java

@@ -0,0 +1,5 @@
+package com.example.nto.service;
+
+public interface TerminalService {
+
+}

src/main/java/com/example/nto/service/VisitService.java

@@ -0,0 +1,21 @@
+package com.example.nto.service;
+
+import com.example.nto.dto.entity.VisitDTO;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+public interface VisitService {
+    List<VisitDTO> getAll();
+    List<VisitDTO> getAllVisitByEmployee(long employeeId);
+    List<VisitDTO> getAllVisitByPeriod(LocalDateTime start, LocalDateTime stop);
+    List<VisitDTO> getAllFinished(boolean isFinished);
+
+    VisitDTO getById(long visitId);
+    VisitDTO open(long employeeId, long startTerminalId, String passageName);
+    void exit(long employeeId, long endTerminalId);
+
+    // update не нужен он не будет использоваться :)
+
+    void delete(long visitId);
+}

src/main/java/com/example/nto/service/impl/TerminalServiceImpl.java

@@ -0,0 +1,6 @@
+package com.example.nto.service.impl;
+
+import com.example.nto.service.TerminalService;
+
+public class TerminalServiceImpl implements TerminalService {
+}

src/main/java/com/example/nto/service/impl/VisitServiceImpl.java

@@ -0,0 +1,125 @@
+package com.example.nto.service.impl;
+
+import com.example.nto.aspect.annotation.LogExample;
+import com.example.nto.domain.entity.Employee;
+import com.example.nto.domain.entity.Passage;
+import com.example.nto.domain.entity.Terminal;
+import com.example.nto.domain.entity.Visit;
+import com.example.nto.domain.exception.ResourceNotFoundException;
+import com.example.nto.dto.entity.VisitDTO;
+import com.example.nto.dto.mappers.VisitMapper;
+import com.example.nto.repository.EmployeeRepository;
+import com.example.nto.repository.PassageRepository;
+import com.example.nto.repository.TerminalRepository;
+import com.example.nto.repository.VisitRepository;
+import com.example.nto.service.VisitService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class VisitServiceImpl implements VisitService {
+    private final EmployeeRepository employeeRepository;
+    private final VisitRepository visitRepository;
+    private final TerminalRepository terminalRepository;
+    private final PassageRepository passageRepository;
+
+    @Override
+    @LogExample
+    public List<VisitDTO> getAll() {
+        return visitRepository.findAll().stream().map(VisitMapper::convertToDTO).collect(Collectors.toList());
+    }
+
+    @Override
+    @LogExample
+    public List<VisitDTO> getAllVisitByEmployee(long employeeId) {
+        return visitRepository.findAll().stream()
+                .filter(visit -> checkEmployeeVisit(visit, employeeId))
+                .map(VisitMapper::convertToDTO).collect(Collectors.toList());
+    }
+
+    @Override
+    @LogExample
+    public List<VisitDTO> getAllVisitByPeriod(LocalDateTime start, LocalDateTime stop) {
+        // todo: Доделать если останется время
+        return List.of();
+    }
+
+    @Override
+    @LogExample
+    public List<VisitDTO> getAllFinished(boolean isFinished) {
+        return visitRepository.findAll().stream()
+                .filter(visit -> checkFinishVisit(visit, isFinished))
+                .map(VisitMapper::convertToDTO).collect(Collectors.toList());
+    }
+
+    @Override
+    @LogExample
+    public VisitDTO getById(long visitId) {
+        return visitRepository.findById(visitId).map(VisitMapper::convertToDTO)
+                .orElseThrow(() -> new ResourceNotFoundException("Посещение с id (" + visitId + ") не найден!"));
+    }
+
+    @Override
+    @LogExample
+    public void delete(long visitId) {
+        visitRepository.findById(visitId).orElseThrow(() -> new ResourceNotFoundException("Посещение с id (" + visitId + ") не найден!"));
+        visitRepository.deleteById(visitId);
+    }
+
+    @Override
+    @LogExample
+    public VisitDTO open(long employeeId, long startTerminalId, String passageName) {
+        Employee employee = employeeRepository.findById(employeeId)
+                .orElseThrow(() -> new ResourceNotFoundException("Работник с id (" + employeeId + ") не найден!"));
+        Terminal terminal = terminalRepository.findById(startTerminalId)
+                .orElseThrow(() -> new ResourceNotFoundException("Терминал с id (" + startTerminalId + ") не найден!"));
+        Passage passage = passageRepository.findByPassageName(passageName)
+                .orElseThrow(() -> new ResourceNotFoundException("Тип входа с названием (" + passageName + ") не найден!"));
+
+        Visit visit = new Visit();
+
+        visit.setEmployee(employee);
+        visit.setStartVisit(LocalDateTime.now());
+        visit.setFinished(false);
+        visit.setStartTerminal(terminal);
+        visit.setPassage(passage);
+
+        return VisitMapper.convertToDTO(visitRepository.save(visit));
+    }
+
+    @Override
+    @LogExample
+    public void exit(long employeeId, long endTerminalId) {
+        Employee employee = employeeRepository.findById(employeeId)
+                .orElseThrow(() -> new ResourceNotFoundException("Работник с id (" + employeeId + ") не найден!"));
+        Terminal terminal = terminalRepository.findById(endTerminalId)
+                .orElseThrow(() -> new ResourceNotFoundException("Терминал с id (" + endTerminalId + ") не найден!"));
+        Visit activeVisit = getActiveVisit(employee);
+
+        activeVisit.setStartVisit(LocalDateTime.now());
+        activeVisit.setFinished(true);
+        activeVisit.setEndTerminal(terminal);
+
+        visitRepository.save(activeVisit);
+    }
+
+    private static boolean checkEmployeeVisit(Visit visit, long employeeId) {
+        return visit.getEmployee().getId() == employeeId;
+    }
+
+    private static boolean checkFinishVisit(Visit visit, boolean isFinished) {
+        return visit.isFinished() == isFinished;
+    }
+
+    private static Visit getActiveVisit(Employee employee) {
+        List<Visit> visits = employee.getVisits().stream().filter(Visit::isFinished).collect(Collectors.toList());
+
+        if (visits.size() == 1) return visits.get(0);
+        else throw new IllegalStateException("Пользователь не может находится в суперпозиции");
+    }
+}