Compare commits
No commits in common. "510325d7af483c5334609d8274827d2e198cac21" and "b3906155eceb67fa7fabab99de78d451c7a2273e" have entirely different histories.
510325d7af
...
b3906155ec
@ -22,7 +22,7 @@ Web service for obtaining the price of a product given a date, the product id an
|
||||
```
|
||||
mvn clean spring-boot:run -Dspring-boot.run.profiles=local
|
||||
```
|
||||
3. Service should be ready to receive requests at http://localhost:8080/price, with OpenAPI docs available at http://localhost:8080/swagger-ui/index.html
|
||||
3. Service should be ready to receive requests at http://localhost:8080/price with OpenAPI docs available at http://localhost:8080/swagger-ui/index.html
|
||||
|
||||
## Running Tests
|
||||
|
||||
|
||||
@ -11,7 +11,7 @@
|
||||
<parent>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>web-price</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
<relativePath>../pom.xml</relativePath>
|
||||
</parent>
|
||||
|
||||
@ -19,7 +19,7 @@
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>domain</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
|
||||
@ -2,10 +2,9 @@ package com.techivw.webprice.application.ports.out;
|
||||
|
||||
import com.techivw.webprice.domain.Price;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
|
||||
public interface PriceRepositoryPort {
|
||||
|
||||
List<Price> findPricesByProductIdAndBrandIdAndDateTimeBetween(Long productId, Long brandId, LocalDateTime dateTime);
|
||||
List<Price> findPricesByProductIdAndBrandId(Long productId, Long brandId);
|
||||
}
|
||||
|
||||
@ -21,12 +21,14 @@ public class PriceService implements PriceServicePort {
|
||||
@Override
|
||||
public Price getPriceWithHighestPriorityByDateTimeAndProductIdAndBrandId(LocalDateTime dateTime, Long productId, Long brandId) {
|
||||
|
||||
List<Price> prices = priceRepositoryPort.findPricesByProductIdAndBrandIdAndDateTimeBetween(productId, brandId, dateTime);
|
||||
List<Price> prices = priceRepositoryPort.findPricesByProductIdAndBrandId(productId, brandId);
|
||||
|
||||
return prices.stream()
|
||||
.max(Comparator.comparing(Price::getPriority))
|
||||
.orElseThrow(() -> new NotFoundException(
|
||||
String.format("Price for product %d of brand %d not found for date %s",
|
||||
productId, brandId, dateTime)));
|
||||
Optional<Price> maxPriorityPrice = prices.stream()
|
||||
.filter(price -> !dateTime.isBefore(price.getStartDate()) && !dateTime.isAfter(price.getEndDate()))
|
||||
.max(Comparator.comparing(Price::getPriority));
|
||||
|
||||
return maxPriorityPrice.orElseThrow(() ->
|
||||
new NotFoundException(String.format(
|
||||
"Price for product %d of brand %d not found for date %s", productId, brandId, dateTime)));
|
||||
}
|
||||
}
|
||||
|
||||
@ -29,7 +29,7 @@ class PriceServiceTest {
|
||||
|
||||
private PriceServicePort priceService;
|
||||
|
||||
private final LocalDateTime TEST_DATE = LocalDateTime.parse("2020-06-14T16:00:00");
|
||||
private final LocalDateTime TEST_DATE = LocalDateTime.parse("2023-01-01T12:00:00");
|
||||
private final Long TEST_PRODUCT_ID = 35455L;
|
||||
private final Long TEST_BRAND_ID = 1L;
|
||||
|
||||
@ -44,8 +44,8 @@ class PriceServiceTest {
|
||||
Price highPriorityPrice = createPrice(2);
|
||||
List<Price> prices = Arrays.asList(lowPriorityPrice, highPriorityPrice);
|
||||
|
||||
when(priceRepositoryPort.findPricesByProductIdAndBrandIdAndDateTimeBetween(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID), eq(TEST_DATE)))
|
||||
when(priceRepositoryPort.findPricesByProductIdAndBrandId(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID)))
|
||||
.thenReturn(prices);
|
||||
|
||||
Price result = priceService.getPriceWithHighestPriorityByDateTimeAndProductIdAndBrandId(
|
||||
@ -57,8 +57,8 @@ class PriceServiceTest {
|
||||
|
||||
@Test
|
||||
void shouldThrowNotFoundExceptionWhenPriceListIsEmpty() {
|
||||
when(priceRepositoryPort.findPricesByProductIdAndBrandIdAndDateTimeBetween(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID), eq(TEST_DATE)))
|
||||
when(priceRepositoryPort.findPricesByProductIdAndBrandId(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID)))
|
||||
.thenReturn(Collections.emptyList());
|
||||
|
||||
assertThrows(NotFoundException.class, () ->
|
||||
@ -66,6 +66,28 @@ class PriceServiceTest {
|
||||
TEST_DATE, TEST_PRODUCT_ID, TEST_BRAND_ID));
|
||||
}
|
||||
|
||||
@Test
|
||||
void shouldThrowNotFoundExceptionWhenNoPriceInDateRange() {
|
||||
Price price = Price.builder()
|
||||
.brandId(TEST_BRAND_ID)
|
||||
.productId(TEST_PRODUCT_ID)
|
||||
.startDate(TEST_DATE.plusDays(1))
|
||||
.endDate(TEST_DATE.plusDays(2))
|
||||
.priceList(1L)
|
||||
.price(BigDecimal.valueOf(35.50))
|
||||
.priority(1)
|
||||
.currency("EUR")
|
||||
.build();
|
||||
|
||||
when(priceRepositoryPort.findPricesByProductIdAndBrandId(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID)))
|
||||
.thenReturn(Collections.singletonList(price));
|
||||
|
||||
assertThrows(NotFoundException.class, () ->
|
||||
priceService.getPriceWithHighestPriorityByDateTimeAndProductIdAndBrandId(
|
||||
TEST_DATE, TEST_PRODUCT_ID, TEST_BRAND_ID));
|
||||
}
|
||||
|
||||
private Price createPrice(int priority) {
|
||||
return Price.builder()
|
||||
.brandId(TEST_BRAND_ID)
|
||||
@ -78,4 +100,4 @@ class PriceServiceTest {
|
||||
.currency("EUR")
|
||||
.build();
|
||||
}
|
||||
}
|
||||
}
|
||||
10
boot/pom.xml
10
boot/pom.xml
@ -7,7 +7,7 @@
|
||||
<parent>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>web-price</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
<relativePath>../pom.xml</relativePath>
|
||||
</parent>
|
||||
|
||||
@ -20,22 +20,22 @@
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>domain</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>application</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>rest-api</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>sql-repository</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
|
||||
@ -11,6 +11,6 @@
|
||||
<parent>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>web-price</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</parent>
|
||||
</project>
|
||||
|
||||
@ -7,7 +7,7 @@
|
||||
<parent>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>web-price</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
<relativePath>../../../pom.xml</relativePath>
|
||||
</parent>
|
||||
|
||||
@ -19,12 +19,12 @@
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>domain</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>application</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
|
||||
@ -39,7 +39,7 @@ public class PriceControllerAdapter {
|
||||
@ApiResponse(responseCode = "400", description = "Invalid request parameters")
|
||||
@ApiResponse(responseCode = "404", description = "Price information not found for the given parameters")
|
||||
public ResponseEntity<PriceResponse> getPrice(
|
||||
@Parameter(description = "Date and time for price lookup (ISO format)", example = "2020-06-14T16:00:00")
|
||||
@Parameter(description = "Date and time for price lookup (ISO format)", example = "2025-04-30T12:00:00")
|
||||
@RequestParam(name = "dateTime") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime dateTime,
|
||||
@Parameter(description = "Product ID", example = "35455")
|
||||
@RequestParam(name = "productId") Long productId,
|
||||
|
||||
@ -11,7 +11,7 @@
|
||||
<parent>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>web-price</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
<relativePath>../../../pom.xml</relativePath>
|
||||
</parent>
|
||||
|
||||
@ -19,12 +19,12 @@
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>domain</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.techivw</groupId>
|
||||
<artifactId>application</artifactId>
|
||||
<version>2.0-RELEASE</version>
|
||||
<version>1.1-RELEASE</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.flywaydb</groupId>
|
||||
|
||||
@ -2,19 +2,12 @@ package com.techivw.webprice.infrastructure.repositories;
|
||||
|
||||
import com.techivw.webprice.infrastructure.repositories.model.PriceEntity;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
public interface PriceEntityJPARepository extends JpaRepository<PriceEntity, Long> {
|
||||
|
||||
@Query("SELECT p FROM PriceEntity p WHERE " +
|
||||
"p.productId = :productId " +
|
||||
"AND p.brandId = :brandId " +
|
||||
"AND :dateTime BETWEEN p.startDate AND p.endDate")
|
||||
List<PriceEntity> findPricesByProductIdAndBrandIdAndBetweenDateTime(
|
||||
Long productId, Long brandId, LocalDateTime dateTime);
|
||||
List<PriceEntity> findPricesByProductIdAndBrandId(Long productId, Long brandId);
|
||||
}
|
||||
|
||||
@ -8,7 +8,6 @@ import com.techivw.webprice.infrastructure.repositories.model.PriceEntity;
|
||||
import lombok.AllArgsConstructor;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.List;
|
||||
|
||||
@Service
|
||||
@ -18,9 +17,9 @@ public class PriceRepositoryAdapter implements PriceRepositoryPort {
|
||||
private final PriceEntityJPARepository repository;
|
||||
|
||||
@Override
|
||||
public List<Price> findPricesByProductIdAndBrandIdAndDateTimeBetween(Long productId, Long brandId, LocalDateTime dateTime) {
|
||||
public List<Price> findPricesByProductIdAndBrandId(Long productId, Long brandId) {
|
||||
|
||||
List<PriceEntity> priceEntityList = repository.findPricesByProductIdAndBrandIdAndBetweenDateTime(productId, brandId, dateTime);
|
||||
List<PriceEntity> priceEntityList = repository.findPricesByProductIdAndBrandId(productId, brandId);
|
||||
|
||||
return PriceEntityMapper.toPriceList(priceEntityList);
|
||||
}
|
||||
|
||||
@ -43,24 +43,24 @@ class PriceRepositoryAdapterTest {
|
||||
createPriceEntity(2)
|
||||
);
|
||||
|
||||
when(repository.findPricesByProductIdAndBrandIdAndBetweenDateTime(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID), eq(TEST_DATE)))
|
||||
when(repository.findPricesByProductIdAndBrandId(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID)))
|
||||
.thenReturn(priceEntities);
|
||||
|
||||
List<Price> result = adapter.findPricesByProductIdAndBrandIdAndDateTimeBetween(
|
||||
TEST_PRODUCT_ID, TEST_BRAND_ID, TEST_DATE);
|
||||
List<Price> result = adapter.findPricesByProductIdAndBrandId(
|
||||
TEST_PRODUCT_ID, TEST_BRAND_ID);
|
||||
|
||||
assertEquals(2, result.size());
|
||||
}
|
||||
|
||||
@Test
|
||||
void shouldReturnEmptyListWhenNoPriceEntitiesExist() {
|
||||
when(repository.findPricesByProductIdAndBrandIdAndBetweenDateTime(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID), eq(TEST_DATE)))
|
||||
when(repository.findPricesByProductIdAndBrandId(
|
||||
eq(TEST_PRODUCT_ID), eq(TEST_BRAND_ID)))
|
||||
.thenReturn(Collections.emptyList());
|
||||
|
||||
List<Price> result = adapter.findPricesByProductIdAndBrandIdAndDateTimeBetween(
|
||||
TEST_PRODUCT_ID, TEST_BRAND_ID, TEST_DATE);
|
||||
List<Price> result = adapter.findPricesByProductIdAndBrandId(
|
||||
TEST_PRODUCT_ID, TEST_BRAND_ID);
|
||||
|
||||
assertTrue(result.isEmpty());
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user