no-copy/src/main/java/ru/soune/nocopy/handler/ViolationHandler.java

package ru.soune.nocopy.handler;

import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.Page;
import org.springframework.stereotype.Component;
import ru.soune.nocopy.dto.BaseRequest;
import ru.soune.nocopy.dto.BaseResponse;
import ru.soune.nocopy.dto.violation.ViolationRequest;
import ru.soune.nocopy.dto.violation.ViolationResponse;
import ru.soune.nocopy.entity.file.FileEntity;
import ru.soune.nocopy.entity.violation.Violation;
import ru.soune.nocopy.repository.FileEntityRepository;
import ru.soune.nocopy.service.violation.ViolationService;

import java.io.FileNotFoundException;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.time.format.DateTimeParseException;
import java.util.List;
import java.util.Map;

@Component
@Slf4j
@RequiredArgsConstructor
public class ViolationHandler implements RequestHandler {
    private final ObjectMapper objectMapper;

    private final ViolationService violationService;

    private final FileEntityRepository fileRepository;

    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

    @Override
    public BaseResponse handle(BaseRequest request) throws Exception {
        ViolationRequest violationRequest = objectMapper.convertValue(request.getMessageBody(), ViolationRequest.class);

        validateRequest(violationRequest);
        //TODO add response
        FileEntity file = fileRepository.findById(violationRequest.getFileId())
                .orElseThrow(() -> new FileNotFoundException("File not found with id: " + violationRequest.getFileId()));

        LocalDateTime startDate = null;
        LocalDateTime endDate = null;

        if (violationRequest.getStartDate() != null && violationRequest.getEndDate() != null) {
            startDate = parseDate(violationRequest.getStartDate());
            endDate = parseDate(violationRequest.getEndDate());
        }

        if ("group".equalsIgnoreCase(violationRequest.getAction())) {
            Map<String, Long> groupedData = violationService.getGroupedViolations(
                    file,
                    violationRequest.getGroupBy(),
                    violationRequest.getStatus(),
                    startDate,
                    endDate
            );

            return BaseResponse.builder()
                    .msgId(request.getMsgId())
                    .messageBody(groupedData)
                    .build();
        } else {
            Page<Violation> violationPage;

            if (startDate != null && endDate != null) {
                violationPage = violationService.getViolationsByFileAndDateRange(
                        file, startDate, endDate,
                        violationRequest.getPage(), violationRequest.getSize(), violationRequest.getSortDirection()
                );
            } else if (violationRequest.getStatus() != null && !violationRequest.getStatus().isEmpty()) {
                violationPage = violationService.getViolationsByFileAndStatus(
                        file, violationRequest.getStatus(),
                        violationRequest.getPage(), violationRequest.getSize(), violationRequest.getSortDirection()
                );
            } else {
                violationPage = violationService.getViolationsByFile(
                        file,
                        violationRequest.getPage(), violationRequest.getSize(), violationRequest.getSortDirection()
                );
            }

            List<ViolationResponse.ViolationDto> violationDtos = violationPage.getContent()
                    .stream()
                    .map(ViolationResponse.ViolationDto::fromEntity)
                    .toList();

            ViolationResponse response = ViolationResponse.builder()
                    .violations(violationDtos)
                    .totalElements(violationPage.getTotalElements())
                    .totalPages(violationPage.getTotalPages())
                    .currentPage(violationPage.getNumber())
                    .pageSize(violationPage.getSize())
                    .hasNext(violationPage.hasNext())
                    .hasPrevious(violationPage.hasPrevious())
                    .build();

            return BaseResponse.builder()
                    .msgId(request.getMsgId())
                    .messageBody(response)
                    .build();
        }
    }

    //TODO add response exception
    private void validateRequest(ViolationRequest request) {
        if (request.getFileId() == null) {
            return;
        }

        if (request.getPage() < 0) {
            request.setPage(0);
        }

        if (request.getSize() <= 0 || request.getSize() > 100) {
            request.setSize(10);
        }

        if (!request.getSortDirection().equalsIgnoreCase("asc") &&
                !request.getSortDirection().equalsIgnoreCase("desc")) {
            request.setSortDirection("desc");
        }
    }

    //TODO add response exception
    private LocalDateTime parseDate(String dateStr) {
        try {
            return LocalDateTime.parse(dateStr, DATE_FORMATTER);
        } catch (DateTimeParseException e) {
            log.error(e.getMessage());
            return null;
        }
    }
}