{alert.label}
- {alert.propertyType} • {alert.marketType}
+ {alert.propertyType === 'HOUSE' ? 'Dom' : 'Mieszkanie'} • {alert.market && alert.market.length > 0 ? alert.market : 'Wtórny i pierwotny'}
Z alertow NIE wychodza zadne e-maile - swiadoma decyzja, zeby nie generowac ruchu pocztowego.
+ */ +@Entity +@Table(name = "price_alerts") +public class PriceAlert { + + public enum Kind { + /** Cena jednego ogloszenia - powiadamiamy przy kazdej zmianie. */ + LISTING, + /** Srednia cena za m2 w miescie - powiadamiamy przy zmianie od progu w gore lub w dol. */ + LOCATION + } + + @Id + @GeneratedValue(strategy = GenerationType.IDENTITY) + private Long id; + + @Column(name = "user_email", nullable = false, length = 180) + private String userEmail; + + @Enumerated(EnumType.STRING) + @Column(nullable = false, length = 20) + private Kind kind; + + /** Etykieta pokazywana uzytkownikowi: tytul ogloszenia albo nazwa lokalizacji. */ + @Column(nullable = false, length = 200) + private String label; + + // --- alert ogloszenia --- + + @Column(name = "listing_id") + private Long listingId; + + // --- alert lokalizacji --- + + @Column(length = 120) + private String city; + + /** Wojewodztwo - tylko do wyswietlenia, nie filtruje ogloszen. */ + @Column(length = 60) + private String region; + + @Enumerated(EnumType.STRING) + @Column(name = "property_type", length = 20) + private PropertyType propertyType; + + /** "", "Wtórny" albo "Pierwotny" - puste znaczy oba rynki. */ + @Column(length = 20) + private String market; + + /** Ostatnia zmierzona wartosc: cena ogloszenia albo srednia za m2. Null = jeszcze nie mierzono. */ + @Column(name = "last_value") + private Long lastValue; + + @Column(name = "last_checked_at") + private Instant lastCheckedAt; + + @Column(name = "notifications_enabled", nullable = false) + private boolean notificationsEnabled = true; + + @Column(name = "created_at", nullable = false) + private Instant createdAt = Instant.now(); + + public Long getId() { + return id; + } + + public String getUserEmail() { + return userEmail; + } + + public void setUserEmail(String userEmail) { + this.userEmail = userEmail; + } + + public Kind getKind() { + return kind; + } + + public void setKind(Kind kind) { + this.kind = kind; + } + + public String getLabel() { + return label; + } + + public void setLabel(String label) { + this.label = label; + } + + public Long getListingId() { + return listingId; + } + + public void setListingId(Long listingId) { + this.listingId = listingId; + } + + public String getCity() { + return city; + } + + public void setCity(String city) { + this.city = city; + } + + public String getRegion() { + return region; + } + + public void setRegion(String region) { + this.region = region; + } + + public PropertyType getPropertyType() { + return propertyType; + } + + public void setPropertyType(PropertyType propertyType) { + this.propertyType = propertyType; + } + + public String getMarket() { + return market; + } + + public void setMarket(String market) { + this.market = market; + } + + public Long getLastValue() { + return lastValue; + } + + public void setLastValue(Long lastValue) { + this.lastValue = lastValue; + } + + public Instant getLastCheckedAt() { + return lastCheckedAt; + } + + public void setLastCheckedAt(Instant lastCheckedAt) { + this.lastCheckedAt = lastCheckedAt; + } + + public boolean isNotificationsEnabled() { + return notificationsEnabled; + } + + public void setNotificationsEnabled(boolean notificationsEnabled) { + this.notificationsEnabled = notificationsEnabled; + } + + public Instant getCreatedAt() { + return createdAt; + } +} diff --git a/backend/src/main/java/pl/polskalokalnie/pricealert/PriceAlertChecker.java b/backend/src/main/java/pl/polskalokalnie/pricealert/PriceAlertChecker.java new file mode 100644 index 0000000..3d16612 --- /dev/null +++ b/backend/src/main/java/pl/polskalokalnie/pricealert/PriceAlertChecker.java @@ -0,0 +1,45 @@ +package pl.polskalokalnie.pricealert; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +/** + * Codzienny przeglad alertow cenowych - o 03:00, czyli po nocnym zapisie srednich cen (02:30), + * zeby porownywac swieze dane. Raz dziennie to swiadomy wybor: uzytkownik dostaje najwyzej + * jedno powiadomienie na alert dziennie, bez zasypywania listy. + */ +@Component +public class PriceAlertChecker { + + private static final Logger log = LoggerFactory.getLogger(PriceAlertChecker.class); + + private final PriceAlertService priceAlertService; + + public PriceAlertChecker(PriceAlertService priceAlertService) { + this.priceAlertService = priceAlertService; + } + + @Scheduled(cron = "0 0 3 * * *") + public void checkDaily() { + run(); + } + + /** Przy starcie aplikacji - dzieki temu pierwszy pomiar powstaje od razu po zalozeniu alertu. */ + @Scheduled(initialDelay = 90_000, fixedDelay = Long.MAX_VALUE) + public void checkOnStartup() { + run(); + } + + private void run() { + try { + int notified = priceAlertService.checkAll(); + if (notified > 0) { + log.info("Alerty cenowe: wyslano {} powiadomien", notified); + } + } catch (RuntimeException ex) { + log.warn("Alerty cenowe: przeglad nie powiodl sie: {}", ex.getMessage()); + } + } +} diff --git a/backend/src/main/java/pl/polskalokalnie/pricealert/PriceAlertController.java b/backend/src/main/java/pl/polskalokalnie/pricealert/PriceAlertController.java new file mode 100644 index 0000000..d272e6c --- /dev/null +++ b/backend/src/main/java/pl/polskalokalnie/pricealert/PriceAlertController.java @@ -0,0 +1,60 @@ +package pl.polskalokalnie.pricealert; + +import java.util.List; +import org.springframework.http.ResponseEntity; +import org.springframework.security.core.Authentication; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; +import pl.polskalokalnie.pricealert.PriceAlertDtos.PriceAlertEventResponse; +import pl.polskalokalnie.pricealert.PriceAlertDtos.PriceAlertRequest; +import pl.polskalokalnie.pricealert.PriceAlertDtos.PriceAlertResponse; + +/** Alerty cenowe zalogowanego uzytkownika. Powiadomienia trafiaja tylko na liste w serwisie. */ +@RestController +@RequestMapping("/api/price-alerts") +public class PriceAlertController { + + private final PriceAlertService priceAlertService; + + public PriceAlertController(PriceAlertService priceAlertService) { + this.priceAlertService = priceAlertService; + } + + @GetMapping + public ListZmiany wykrywa serwer raz dziennie, a wynik trafia wylacznie na liste powiadomien + * uzytkownika (dzwonek). Zadnych e-maili - decyzja wlasciciela serwisu, zeby nie generowac + * ruchu pocztowego.
+ */ +@Service +public class PriceAlertService { + + private static final Logger log = LoggerFactory.getLogger(PriceAlertService.class); + + /** + * Prog dla alertow lokalizacji. Srednia rusza sie przy kazdym nowym ogloszeniu, wiec bez + * progu powiadomienia bylyby szumem. Cena pojedynczego ogloszenia progu nie ma - tam kazda + * zmiana jest dla obserwujacego istotna. + */ + static final double LOCATION_MIN_CHANGE_PCT = 2.0; + + private final PriceAlertRepository alertRepository; + private final PriceAlertEventRepository eventRepository; + private final ListingRepository listingRepository; + private final PriceSnapshotService snapshotService; + private final NotificationService notificationService; + + public PriceAlertService(PriceAlertRepository alertRepository, + PriceAlertEventRepository eventRepository, + ListingRepository listingRepository, + PriceSnapshotService snapshotService, + NotificationService notificationService) { + this.alertRepository = alertRepository; + this.eventRepository = eventRepository; + this.listingRepository = listingRepository; + this.snapshotService = snapshotService; + this.notificationService = notificationService; + } + + @Transactional(readOnly = true) + public ListŚledź zmiany cen mieszkań i bądź na bieżąco. Otrzymuj powiadomienia, gdy ceny spadną lub wzrosną.
+Śledź zmiany cen mieszkań i bądź na bieżąco. Powiadomienie o zmianie znajdziesz na swojej liście powiadomień - nie wysyłamy maili.