AccessionInvNameServiceImpl.java
/*
* Copyright 2026 Global Crop Diversity Trust
* Licensed under the Apache License, Version 2.0
* See LICENSE file in project root folder or http://www.apache.org/licenses/LICENSE-2.0
*/
package org.gringlobal.service.impl;
import org.gringlobal.custom.elasticsearch.SearchException;
import org.gringlobal.model.AccessionInvName;
import org.gringlobal.model.community.SecurityAction;
import org.gringlobal.persistence.AccessionInvNameRepository;
import org.gringlobal.persistence.InventoryRepository;
import org.gringlobal.service.AccessionInvNameService;
import org.gringlobal.service.filter.AccessionInvNameFilter;
import org.gringlobal.service.filter.InventoryFilter;
import org.gringlobal.service.filter.SiteFilter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.security.access.prepost.PostAuthorize;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
/**
* @author Maxym Borodenko
*/
@Service
@Transactional(readOnly = true)
@Validated
@Slf4j
public class AccessionInvNameServiceImpl extends FilteredCRUDService2Impl<AccessionInvName, AccessionInvNameFilter, AccessionInvNameRepository> implements AccessionInvNameService {
@Autowired
private InventoryRepository inventoryRepository;
@Override
protected AccessionInvNameFilter adjustFilter(AccessionInvNameFilter filter) {
var siteIds = ggceSec.getSiteIds(SecurityAction.PassportData.name(), "READ");
if (siteIds != null) {
log.debug("Forcing Site IDs: {}", siteIds);
var siteFilter = new AccessionInvNameFilter();
siteFilter.inventory(new InventoryFilter().includeSystem(null));
siteFilter.inventory.site(new SiteFilter());
siteFilter.inventory.site.id(siteIds);
siteFilter.AND = filter;
return siteFilter;
} else {
// No change
return filter;
}
}
@Override
@Transactional
@PostAuthorize("@ggceSec.actionAllowed('PassportData', 'WRITE', returnObject.inventory.site)")
public AccessionInvName create(AccessionInvName source) {
return _lazyLoad(createFast(source));
}
@Override
@Transactional
@PostAuthorize("@ggceSec.actionAllowed('PassportData', 'WRITE', returnObject.inventory.site)")
public AccessionInvName createFast(AccessionInvName source) {
assert(source.getId() == null);
log.debug("Create AccessionInvName. Input data {}", source);
source.setInventory(inventoryRepository.getReferenceById(source.getInventory().getId()));
AccessionInvName saved = repository.save(source);
return saved;
}
@Override
@Transactional
@PreAuthorize("@ggceSec.actionAllowed('PassportData', 'WRITE', #target.inventory.site)")
public AccessionInvName update(AccessionInvName input, AccessionInvName target) {
return _lazyLoad(updateFast(input, target));
}
@Override
@Transactional
@PreAuthorize("@ggceSec.actionAllowed('PassportData', 'WRITE', #target.inventory.site)")
public AccessionInvName updateFast(AccessionInvName updated, AccessionInvName target) {
log.debug("Update AccessionInvName. Input data {}", updated);
target.apply(updated);
return repository.save(target);
}
@Override
@Transactional
@PreAuthorize("@ggceSec.actionAllowed('PassportData', 'WRITE', #entity.inventory.site)")
public AccessionInvName remove(AccessionInvName entity) {
return super.remove(entity);
}
@Override
@PostAuthorize("@ggceSec.actionAllowed('PassportData', 'READ', returnObject.inventory.site)")
public AccessionInvName get(long id) {
return super.get(id);
}
@Override
@PostAuthorize("@ggceSec.actionAllowed('PassportData', 'READ', returnObject.inventory.site)")
public AccessionInvName get(AccessionInvName source) {
return super.get(source);
}
@Override
public Page<AccessionInvName> list(AccessionInvNameFilter filter, Pageable page) throws SearchException {
return super.list(AccessionInvName.class, filter, page);
}
}