Changes between Version 6 and Version 7 of AdvancedApplicationDesign

Timestamp:

08/20/24 19:57:32 (5 weeks ago)

Author:

216049

Comment:

--

AdvancedApplicationDesign

@@ -219 +219 @@
 
 [[Image(total-income.png)]]
+
+== Интегритет
+
+=== Тригери
+
+{{{#!sql
+
+create or replace function check_expiry_date() returns trigger
+as
+    $$
+    begin
+        if exists(
+            select 1
+            from vozenje v
+            where v.patnik_id = new.patnik_id and v.end_date is null
+        ) then
+            update vozenje set end_date = now(), status = 'FINISHED' where id in (select v.id
+                                                                                  from vozenje v
+                                                                                  where v.patnik_id = new.patnik_id and v.end_date is null);
+        end if;
+
+        if exists(
+            select 1
+            from bilet
+            where id = new.bilet_id and datum_aktivacija is null
+        ) then
+            update bilet set datum_aktivacija = now(), status = 'ACTIVE' where id = new.bilet_id;
+        end if;
+
+        if exists(
+            select 1
+            from bilet b
+            join tipbilet tb on b.tip_id = tb.id
+            where b.id = new.bilet_id and ((b.datum_aktivacija + (tb.trajnost || ' milliseconds')::interval) < now())
+        ) then
+            update bilet set status = 'EXPIRED' where id = new.bilet_id;
+            end if;
+
+        if exists(
+            select 1
+            from bilet b
+                     join tipbilet tb on b.tip_id = tb.id
+            where b.id = new.bilet_id and ((b.datum_aktivacija + (tb.trajnost || ' milliseconds')::interval) < now())
+        ) then
+            RAISE exception 'Ticket is expired';
+        end if;
+        return new;
+    end;
+    $$ language plpgsql;
+
+create or replace trigger check_validity_of_ticket
+    before insert on vozenje
+    for each row
+    execute function check_expiry_date();
+
+
+}}}
+
+=== Трансакции
+
+{{{#!java
+
+@Transactional
+    fun refreshAverageTimeDiffs() {
+        val sql = "REFRESH MATERIALIZED VIEW CONCURRENTLY avg_time_diffs;"
+        jdbcTemplate.execute(sql)
+    }
+
+    @Transactional
+    fun refreshCommutesByHour() {
+        val sql = "refresh materialized view concurrently most_busy_part_of_the_day;"
+        jdbcTemplate.execute(sql)
+    }
+
+    @Transactional
+    fun refreshFinesPerLine() {
+        val sql = "refresh materialized view concurrently kazna_po_linija;"
+        jdbcTemplate.execute(sql)
+    }
+    
+    @Transactional
+    fun refreshTotalIncome() {
+        val sql = "refresh materialized view concurrently total_income;"
+        jdbcTemplate.execute(sql)
+    }
+
+}}}
+
+{{{#!java 
+@Transactional
+    fun createFine(request: FineRequest): FineResponse {
+        val kontrola = kontrolaRepository.findByIdOrNull(request.kontrolaId) ?: throw NotFoundException("Kontrola")
+        val now = Timestamp.valueOf(LocalDateTime.now())
+        val kazna =
+            kaznaRepository.save(
+                Kazna(
+                    dateCreated = now,
+                    id = 0L,
+                    kondukter = authService.getConductor(),
+                    datePayed =
+                        if (request.plateno) {
+                            now
+                        } else {
+                            null
+                        },
+                    iznos = request.iznos,
+                    dokument = request.dokument,
+                    kontrola = kontrola,
+                    plateno = request.plateno,
+                ),
+            )
+
+        if (request.patnikId != null) {
+            val korisnik = korisnikRepository.findByIdOrNull(request.patnikId!!) ?: throw NotFoundException("Korisnik")
+            val patnik = patnikRepository.findByKorisnik(korisnik) ?: throw NotFoundException("Patnik")
+            val kzr =
+                kaznaZaRegistriranRepository.save(
+                    KaznaZaRegistriran(
+                        patnik = patnik,
+                        id = 0L,
+                        kazna = kazna,
+                    ),
+                )
+            return kzr.let { dtoMapper.toFineResponse(kazna = kazna, kzr = kzr, kzn = null) }
+        }
+
+        if (request.adresa != null && request.ime != null && request.telefon != null) {
+            val kzn =
+                kaznaZaNeregistriranRepository.save(
+                    KaznaZaNeregistriran(
+                        id = 0L,
+                        kazna = kazna,
+                        ime = request.ime!!,
+                        telefon = request.telefon!!,
+                        adresa = request.adresa!!,
+                    ),
+                )
+
+            return kzn.let { dtoMapper.toFineResponse(kazna = kazna, kzn = kzn, kzr = null) }
+        }
+        return dtoMapper.toFineResponse(kazna = kazna, kzr = null, kzn = null)
+    }
+}}}
+
+
+{{{#!java
+
+@Transactional
+    fun start(request: StartCommuteRequest): CommuteResponse {
+        if (!this.authService.hasAuthority(RoleEnum.ROLE_PASSENGER)) throw UnauthorizedAccessException("Unauthorised role")
+        val korisnik = this.authService.getAuthenticatedUser()
+        val patnik = patnikRepository.findByKorisnik(korisnik) ?: throw NotFoundException("Korisnik")
+
+        var bilet = biletRepository.findByIdAndPatnik(request.ticketId, patnik) ?: throw NotFoundException("Bilet")
+
+        val instancaNaLinija =
+            instancaNaLinijaRepository.findByIdOrNull(request.routeInstanceId) ?: throw NotFoundException("RouteInstanceId")
+        val postojka = postojkaRepository.findByIdOrNull(request.stationId) ?: throw NotFoundException("StationId")
+
+        val postojkaNaLinijaStart =
+            postojkaNaLinijaRepository.findByLinijaAndPostojkaAndPravec(instancaNaLinija.linija, postojka, instancaNaLinija.pravec)
+                ?: throw NotFoundException("Station not found")
+
+        if (bilet.status == BiletEnum.INACTIVE) {
+            bilet.status = BiletEnum.ACTIVE
+            bilet.datumAktivacija = Timestamp.valueOf(LocalDateTime.now())
+            bilet = biletRepository.save(bilet)
+        }
+
+        val vozenje =
+            Vozenje(
+                id = 0L,
+                startDate = Timestamp.valueOf(LocalDateTime.now()),
+                endDate = null,
+                status = VozenjeStatus.ACTIVE,
+                patnik = patnik,
+                postojkaNaLinijaStart = postojkaNaLinijaStart,
+                instancaNaLinija = instancaNaLinija,
+                bilet = bilet,
+            )
+        return vozenjeRepository.save(vozenje).let { dtoMapper.toCommuteResponse(it) }
+    }
+
+}}}