feat: masse licence validation

src/main/java/fr/titionfire/ffsaf/domain/service/LicenceService.java

@@ -20,6 +20,7 @@ import org.hibernate.reactive.mutiny.Mutiny;
 
 import java.util.List;
 import java.util.function.Consumer;
+import java.util.function.Function;
 
 @WithSession
 @ApplicationScoped
@@ -34,6 +35,9 @@ public class LicenceService {
     @Inject
     SequenceRepository sequenceRepository;
 
+    @Inject
+    KeycloakService keycloakService;
+
     public Uni<List<LicenceModel>> getLicence(long id, Consumer<MembreModel> checkPerm) {
         return combRepository.findById(id).invoke(checkPerm)
                 .chain(combRepository -> Mutiny.fetch(combRepository.getLicences()));
@@ -48,6 +52,23 @@ public class LicenceService {
                 .chain(membres -> repository.find("saison = ?1 AND membre IN ?2", Utils.getSaison(), membres).list());
     }
 
+    public Uni<?> valideLicences(List<Long> ids) {
+        Uni<String> uni = Uni.createFrom().nullItem();
+
+        for (Long id : ids) {
+            uni = uni.chain(__ -> repository.find("membre.id = ?1 AND saison = ?2", id, Utils.getSaison()).firstResult()
+                            .chain(model -> {
+                                model.setValidate(true);
+                                return Panache.withTransaction(() -> repository.persist(model)
+                                        .call(m -> Mutiny.fetch(m.getMembre())
+                                                .call(genLicenceNumberAndAccountIfNeed())
+                                        ));
+                            }))
+                    .map(__ -> "OK");
+        }
+        return uni;
+    }
+
     public Uni<LicenceModel> setLicence(long id, LicenceForm form) {
         if (form.getId() == -1) {
             return combRepository.findById(id).chain(membreModel -> {
@@ -58,10 +79,8 @@ public class LicenceService {
                 model.setCertificate(form.getCertificate());
                 model.setValidate(form.isValidate());
                 return Panache.withTransaction(() -> repository.persist(model)
-                        .call(m -> (m.isValidate() && membreModel.getLicence() <= 0) ?
-                                sequenceRepository.getNextValueInTransaction(SequenceType.Licence)
-                                        .invoke(i -> membreModel.setLicence(Math.toIntExact(i)))
-                                        .chain(() -> combRepository.persist(membreModel))
+                        .call(m -> m.isValidate() ? Uni.createFrom().item(membreModel)
+                                .call(genLicenceNumberAndAccountIfNeed())
                                 : Uni.createFrom().nullItem()
                         ));
             });
@@ -71,17 +90,24 @@ public class LicenceService {
                 model.setValidate(form.isValidate());
                 return Panache.withTransaction(() -> repository.persist(model)
                         .call(m -> m.isValidate() ? Mutiny.fetch(m.getMembre())
-                                .call(membreModel -> (membreModel.getLicence() <= 0) ?
-                                        sequenceRepository.getNextValueInTransaction(SequenceType.Licence)
-                                                .invoke(i -> membreModel.setLicence(Math.toIntExact(i)))
-                                                .chain(() -> combRepository.persist(membreModel))
-                                        : Uni.createFrom().nullItem())
+                                .call(genLicenceNumberAndAccountIfNeed())
                                 : Uni.createFrom().nullItem()
                         ));
             });
         }
     }
 
+    private Function<MembreModel, Uni<?>> genLicenceNumberAndAccountIfNeed() {
+        return membreModel -> ((membreModel.getLicence() <= 0) ?
+                sequenceRepository.getNextValueInTransaction(SequenceType.Licence)
+                        .invoke(i -> membreModel.setLicence(Math.toIntExact(i)))
+                        .chain(() -> combRepository.persist(membreModel))
+                : Uni.createFrom().nullItem())
+                .call(__ -> (membreModel.getUserId() == null) ?
+                        keycloakService.initCompte(membreModel.getId())
+                        : Uni.createFrom().nullItem());
+    }
+
     public Uni<?> deleteLicence(long id) {
         return Panache.withTransaction(() -> repository.deleteById(id));
     }

src/main/java/fr/titionfire/ffsaf/rest/LicenceEndpoints.java

@@ -13,6 +13,7 @@ import jakarta.inject.Inject;
 import jakarta.ws.rs.*;
 import jakarta.ws.rs.core.MediaType;
 import org.eclipse.microprofile.openapi.annotations.Operation;
+import org.eclipse.microprofile.openapi.annotations.parameters.Parameter;
 import org.eclipse.microprofile.openapi.annotations.responses.APIResponse;
 import org.eclipse.microprofile.openapi.annotations.responses.APIResponses;
 
@@ -97,6 +98,22 @@ public class LicenceEndpoints {
         return licenceService.setLicence(id, form).map(SimpleLicence::fromModel);
     }
 
+
+    @POST
+    @Path("validate")
+    @RolesAllowed("federation_admin")
+    @Produces(MediaType.APPLICATION_JSON)
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Operation(summary = "Validation licence", description = "Valide en masse les licence de l'année en cours (pour les administrateurs)")
+    @APIResponses(value = {
+            @APIResponse(responseCode = "200", description = "Les licences ont été mise à jour avec succès"),
+            @APIResponse(responseCode = "403", description = "Accès refusé"),
+            @APIResponse(responseCode = "500", description = "Erreur interne du serveur")
+    })
+    public Uni<?> valideLicences(@Parameter(description = "Id des membre a valider") List<Long> ids) {
+        return licenceService.valideLicences(ids);
+    }
+
     @DELETE
     @Path("{id}")
     @RolesAllowed("federation_admin")