49 lines
1.8 KiB
Java
49 lines
1.8 KiB
Java
package ru.soune.nocopy.handler;
|
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import lombok.AllArgsConstructor;
|
|
import org.springframework.stereotype.Component;
|
|
import ru.soune.nocopy.dto.BaseRequest;
|
|
import ru.soune.nocopy.dto.BaseResponse;
|
|
import ru.soune.nocopy.dto.MessageCode;
|
|
import ru.soune.nocopy.dto.statistic.TariffStatisticFullResponse;
|
|
import ru.soune.nocopy.dto.statistic.TariffStatisticRequest;
|
|
import ru.soune.nocopy.dto.statistic.TariffStatisticResponse;
|
|
import ru.soune.nocopy.repository.TariffInfoRepository;
|
|
|
|
import java.util.List;
|
|
|
|
@Component
|
|
@AllArgsConstructor
|
|
public class StatisticTariffInfoFileHandler implements RequestHandler {
|
|
|
|
private ObjectMapper objectMapper;
|
|
|
|
private TariffInfoRepository tariffInfoRepository;
|
|
|
|
@Override
|
|
public BaseResponse handle(BaseRequest request) throws Exception {
|
|
TariffStatisticRequest tariffRequest =
|
|
objectMapper.convertValue(request.getMessageBody(), TariffStatisticRequest.class);
|
|
|
|
boolean activeOnly = tariffRequest.getActiveOnly() != null ? tariffRequest.getActiveOnly() : true;
|
|
List<Object[]> results = tariffInfoRepository.getTariffStatisticsNative(activeOnly);
|
|
|
|
List<TariffStatisticResponse> tariffs = results.stream()
|
|
.map(row -> new TariffStatisticResponse(
|
|
(String) row[0],
|
|
((Number) row[1]).longValue(),
|
|
((Number) row[2]).doubleValue()
|
|
))
|
|
.toList();
|
|
|
|
TariffStatisticFullResponse statistics = new TariffStatisticFullResponse(tariffs);
|
|
|
|
return new BaseResponse(
|
|
request.getMsgId(),
|
|
MessageCode.SUCCESS.getCode(),
|
|
MessageCode.SUCCESS.getDescription(),
|
|
statistics);
|
|
}
|
|
}
|