package jnpf.dmsService.expiry;
|
|
import jnpf.dmsEntity.storage.expiry.DmsFileExpiryItem;
|
import jnpf.dmsEntity.storage.form.DmsFileLifecycleUpdateForm;
|
import jnpf.dmsMapper.DmsFileExpiryMapper;
|
import jnpf.dmsService.DmsFileLifecycleService;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DmsFileExpiryExecutor {
|
private final DmsFileExpiryMapper mapper;
|
private final DmsFileLifecycleService lifecycle;
|
private final jnpf.dmsService.DmsBusinessLifecycleGuard businessOccupancy;
|
|
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
|
public boolean process(DmsFileExpiryItem candidate) {
|
if (!businessOccupancy.tryEnterExpiry(candidate.getTenantId(), candidate.getFileVersionId())) return false;
|
if (mapper.tryLockDocument(candidate.getTenantId(), candidate.getDocumentId()) == null) return false;
|
DmsFileExpiryItem current = mapper.dueState(candidate.getTenantId(), candidate.getFileVersionId());
|
if (current == null) return false; // Extended or superseded since discovery.
|
DmsFileLifecycleUpdateForm form = new DmsFileLifecycleUpdateForm();
|
form.setTenantId(current.getTenantId());
|
form.setFileVersionId(current.getFileVersionId());
|
form.setLifecycleStatus("EXPIRED");
|
form.setEffectiveFrom(current.getEffectiveFrom());
|
form.setEffectiveTo(current.getEffectiveTo());
|
lifecycle.updateExpired(form, "dms-expiry-job");
|
return true;
|
}
|
}
|
