feat(stat): add stats page

2025-02-09 15:48:29 +01:00
parent 0769e5ae9d
commit e2e50ae3db
9 changed files with 667 additions and 9 deletions
--- a/src/main/java/fr/titionfire/ffsaf/domain/service/StatsService.java
+++ b/src/main/java/fr/titionfire/ffsaf/domain/service/StatsService.java
@@ -0,0 +1,71 @@
+package fr.titionfire.ffsaf.domain.service;
+
+import fr.titionfire.ffsaf.data.repository.LicenceRepository;
+import fr.titionfire.ffsaf.rest.data.LicenceStats;
+import fr.titionfire.ffsaf.utils.Categorie;
+import fr.titionfire.ffsaf.utils.Genre;
+import fr.titionfire.ffsaf.utils.Utils;
+import io.quarkus.hibernate.reactive.panache.common.WithSession;
+import io.smallrye.mutiny.Multi;
+import io.smallrye.mutiny.Uni;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+import org.hibernate.reactive.mutiny.Mutiny;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+@WithSession
+@ApplicationScoped
+public class StatsService {
+
+    @Inject
+    LicenceRepository licenceRepository;
+
+    public Uni<LicenceStats> getStats() {
+        ConcurrentHashMap<Categorie, Integer> categories = new ConcurrentHashMap<>();
+        LicenceStats stats = new LicenceStats();
+        int currentSaison = Utils.getSaison();
+
+        //noinspection ReactiveStreamsUnusedPublisher
+        return licenceRepository.listAll()
+                .onItem().transformToMulti(licences -> Multi.createFrom().iterable(licences))
+                .call(licence -> Mutiny.fetch(licence.getMembre()))
+                .invoke(licence -> {
+                    if (!stats.getLicences().containsKey(licence.getSaison()))
+                        stats.getLicences().put(licence.getSaison(), new LicenceStats.YearStats());
+
+                    LicenceStats.YearStats yearStats = stats.getLicences().get(licence.getSaison());
+
+                    System.out.println("stats: " + licence.getMembre().getFname());
+                    if (licence.isValidate()) {
+                        if (licence.getMembre().getGenre() == Genre.H)
+                            yearStats.addH();
+                        else if (licence.getMembre().getGenre() == Genre.F)
+                            yearStats.addF();
+                        else
+                            yearStats.addNa();
+
+                        if (licence.getSaison() == currentSaison && licence.getMembre().getCategorie() != null) {
+                            categories.put(licence.getMembre().getCategorie(),
+                                    categories.getOrDefault(licence.getMembre().getCategorie(), 0) + 1);
+                        }
+                    } else {
+                        yearStats.addNotValid();
+                    }
+
+                })
+                .collect().asList()
+                .map(__ -> {
+                    for (Categorie c : Categorie.values()) {
+                        LicenceStats.CategoriesStats o = new LicenceStats.CategoriesStats();
+
+                        o.setName(c.getName());
+                        o.setCount(categories.getOrDefault(c, 0));
+
+                        stats.getCategories().add(o);
+                    }
+
+                    return stats;
+                });
+    }
+}