205 lines
9.1 KiB
Java
205 lines
9.1 KiB
Java
package fr.titionfire.ffsaf.domain.service;
|
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
|
import fr.titionfire.ffsaf.data.model.ClubModel;
|
|
import fr.titionfire.ffsaf.data.repository.ClubRepository;
|
|
import fr.titionfire.ffsaf.data.repository.CombRepository;
|
|
import fr.titionfire.ffsaf.net2.ServerCustom;
|
|
import fr.titionfire.ffsaf.net2.data.SimpleClubModel;
|
|
import fr.titionfire.ffsaf.net2.request.SReqClub;
|
|
import fr.titionfire.ffsaf.rest.data.SimpleClubList;
|
|
import fr.titionfire.ffsaf.rest.from.FullClubForm;
|
|
import fr.titionfire.ffsaf.utils.Contact;
|
|
import fr.titionfire.ffsaf.utils.PageResult;
|
|
import fr.titionfire.ffsaf.utils.RoleAsso;
|
|
import fr.titionfire.ffsaf.utils.Utils;
|
|
import io.quarkus.hibernate.reactive.panache.Panache;
|
|
import io.quarkus.hibernate.reactive.panache.PanacheQuery;
|
|
import io.quarkus.hibernate.reactive.panache.common.WithSession;
|
|
import io.quarkus.panache.common.Page;
|
|
import io.quarkus.panache.common.Sort;
|
|
import io.quarkus.vertx.VertxContextSupport;
|
|
import io.smallrye.mutiny.Uni;
|
|
import io.smallrye.mutiny.unchecked.Unchecked;
|
|
import jakarta.enterprise.context.ApplicationScoped;
|
|
import jakarta.inject.Inject;
|
|
import jakarta.ws.rs.BadRequestException;
|
|
import org.eclipse.microprofile.config.inject.ConfigProperty;
|
|
import org.hibernate.reactive.mutiny.Mutiny;
|
|
|
|
import java.util.Collection;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
|
|
import static fr.titionfire.ffsaf.net2.Client_Thread.MAPPER;
|
|
|
|
@WithSession
|
|
@ApplicationScoped
|
|
public class ClubService {
|
|
|
|
@Inject
|
|
ClubRepository repository;
|
|
|
|
@Inject
|
|
ServerCustom serverCustom;
|
|
|
|
@Inject
|
|
CombRepository combRepository;
|
|
|
|
@Inject
|
|
KeycloakService keycloakService;
|
|
|
|
@ConfigProperty(name = "upload_dir")
|
|
String media;
|
|
|
|
public SimpleClubModel findByIdOptionalClub(long id) throws Throwable {
|
|
return VertxContextSupport.subscribeAndAwait(
|
|
() -> Panache.withTransaction(() -> repository.findById(id).map(SimpleClubModel::fromModel)));
|
|
}
|
|
|
|
public Collection<SimpleClubModel> findAllClub() throws Throwable {
|
|
return VertxContextSupport.subscribeAndAwait(() -> Panache.withTransaction(
|
|
() -> repository.findAll().list()
|
|
.map(clubModels -> clubModels.stream().map(SimpleClubModel::fromModel).toList())));
|
|
}
|
|
|
|
public Uni<List<ClubModel>> getAll() {
|
|
return repository.listAll();
|
|
}
|
|
|
|
public Uni<?> setClubId(Long id, String id1) {
|
|
return repository.findById(id).chain(clubModel -> {
|
|
clubModel.setClubId(id1);
|
|
return Panache.withTransaction(() -> repository.persist(clubModel));
|
|
});
|
|
}
|
|
|
|
public Uni<PageResult<SimpleClubList>> search(Integer limit, int page, String search, String country) {
|
|
if (search == null)
|
|
search = "";
|
|
search = search + "%";
|
|
|
|
PanacheQuery<ClubModel> query;
|
|
|
|
if (country == null || country.isBlank())
|
|
query = repository.find("name LIKE ?1",
|
|
Sort.ascending("name"), search).page(Page.ofSize(limit));
|
|
else
|
|
query = repository.find("name LIKE ?1 AND country LIKE ?2",
|
|
Sort.ascending("name"), search, country + "%").page(Page.ofSize(limit));
|
|
return getPageResult(query, limit, page);
|
|
}
|
|
|
|
private Uni<PageResult<SimpleClubList>> getPageResult(PanacheQuery<ClubModel> query, int limit, int page) {
|
|
return Uni.createFrom().item(new PageResult<SimpleClubList>())
|
|
.invoke(result -> result.setPage(page))
|
|
.invoke(result -> result.setPage_size(limit))
|
|
.call(result -> query.count().invoke(result::setResult_count))
|
|
.call(result -> query.pageCount()
|
|
.invoke(Unchecked.consumer(pages -> {
|
|
if (page > pages) throw new BadRequestException();
|
|
}))
|
|
.invoke(result::setPage_count))
|
|
.call(result -> query.page(Page.of(page, limit)).list()
|
|
.map(membreModels -> membreModels.stream().map(SimpleClubList::fromModel).toList())
|
|
.invoke(result::setResult));
|
|
}
|
|
|
|
public Uni<ClubModel> getById(long id) {
|
|
return repository.findById(id).call(m -> Mutiny.fetch(m.getContact()));
|
|
}
|
|
|
|
public Uni<ClubModel> getByClubId(String clubId) {
|
|
return repository.find("clubId", clubId).firstResult();
|
|
}
|
|
|
|
public Uni<String> update(long id, FullClubForm input) {
|
|
return repository.findById(id).call(m -> Mutiny.fetch(m.getContact()))
|
|
.onItem().transformToUni(Unchecked.function(m -> {
|
|
TypeReference<HashMap<Contact, String>> typeRef = new TypeReference<>() {
|
|
};
|
|
|
|
m.setName(input.getName());
|
|
m.setCountry(input.getCountry());
|
|
m.setInternational(input.isInternational());
|
|
|
|
if (!input.isInternational()) {
|
|
m.setTraining_location(input.getTraining_location());
|
|
m.setTraining_day_time(input.getTraining_day_time());
|
|
m.setContact_intern(input.getContact_intern());
|
|
m.setRNA(input.getRna());
|
|
if (input.getSiret() != null && !input.getSiret().isBlank())
|
|
m.setSIRET(Long.parseLong(input.getSiret()));
|
|
m.setAddress(input.getAddress());
|
|
|
|
try {
|
|
m.setContact(MAPPER.readValue(input.getContact(), typeRef));
|
|
} catch (JsonProcessingException e) {
|
|
throw new BadRequestException();
|
|
}
|
|
}
|
|
return Panache.withTransaction(() -> repository.persist(m));
|
|
}))
|
|
.invoke(membreModel -> SReqClub.sendIfNeed(serverCustom.clients,
|
|
SimpleClubModel.fromModel(membreModel)))
|
|
.map(__ -> "OK");
|
|
}
|
|
|
|
public Uni<Long> add(FullClubForm input) {
|
|
TypeReference<HashMap<Contact, String>> typeRef = new TypeReference<>() {
|
|
};
|
|
|
|
return Uni.createFrom().nullItem()
|
|
.chain(() -> {
|
|
ClubModel clubModel = new ClubModel();
|
|
|
|
clubModel.setName(input.getName());
|
|
clubModel.setCountry(input.getCountry());
|
|
clubModel.setInternational(input.isInternational());
|
|
clubModel.setNo_affiliation(null);
|
|
if (!input.isInternational()) {
|
|
clubModel.setTraining_location(input.getTraining_location());
|
|
clubModel.setTraining_day_time(input.getTraining_day_time());
|
|
clubModel.setContact_intern(input.getContact_intern());
|
|
clubModel.setRNA(input.getRna());
|
|
if (input.getSiret() != null && !input.getSiret().isBlank())
|
|
clubModel.setSIRET(Long.parseLong(input.getSiret()));
|
|
clubModel.setAddress(input.getAddress());
|
|
|
|
try {
|
|
clubModel.setContact(MAPPER.readValue(input.getContact(), typeRef));
|
|
} catch (JsonProcessingException ignored) {
|
|
}
|
|
}
|
|
|
|
return Panache.withTransaction(() -> repository.persist(clubModel));
|
|
})
|
|
.call(clubModel -> keycloakService.getGroupFromClub(clubModel)) // create group in keycloak
|
|
.invoke(clubModel -> SReqClub.sendAddIfNeed(serverCustom.clients, SimpleClubModel.fromModel(clubModel)))
|
|
.map(ClubModel::getId);
|
|
}
|
|
|
|
public Uni<?> delete(long id) {
|
|
return repository.findById(id)
|
|
.chain(club -> combRepository.list("club = ?1", club)
|
|
.map(combModels -> combModels.stream().peek(combModel -> {
|
|
combModel.setClub(null);
|
|
combModel.setRole(RoleAsso.MEMBRE);
|
|
}).toList())
|
|
.call(list -> (list.isEmpty()) ? Uni.createFrom().voidItem() :
|
|
Uni.join().all(list.stream().filter(m -> m.getUserId() != null)
|
|
.map(m -> keycloakService.clearUser(m.getUserId())).toList())
|
|
.andCollectFailures())
|
|
.chain(list -> Panache.withTransaction(() -> combRepository.persist(list)))
|
|
.map(o -> club)
|
|
)
|
|
.call(clubModel -> (clubModel.getClubId() == null) ? Uni.createFrom()
|
|
.voidItem() : keycloakService.removeClubGroup(clubModel.getClubId()))
|
|
.invoke(membreModel -> SReqClub.sendRmIfNeed(serverCustom.clients, id))
|
|
.chain(clubModel -> Panache.withTransaction(() -> repository.delete(clubModel)))
|
|
.call(__ -> Utils.deleteMedia(id, media, "ppClub"))
|
|
.call(__ -> Utils.deleteMedia(id, media, "clubStatus"));
|
|
}
|
|
}
|