package jnpf.dmsBusinessOccupancy;
|
|
import org.mybatis.spring.SqlSessionTemplate;
|
import java.util.List;
|
import java.util.Objects;
|
|
/** Number lock precedes document/resource locks. Does not change any original expiry condition. */
|
public final class BusinessFileExpiryGate {
|
private final BusinessOccupancyTransactions transactions;
|
private final BusinessFileOccupancyCoordinator coordinator;
|
public BusinessFileExpiryGate(SqlSessionTemplate sessions) {
|
transactions = new BusinessOccupancyTransactions(sessions);
|
coordinator = new BusinessFileOccupancyCoordinator(sessions);
|
}
|
|
/** False means WAIT, never EXPIRED. Caller rereads deadline and executes in this transaction. */
|
public boolean tryEnter(String tenantId, String centerVersionId) {
|
Objects.requireNonNull(centerVersionId);
|
return transactions.execute(mapper -> {
|
List<BusinessFileTarget> before = mapper.expiryTargets(tenantId, centerVersionId);
|
if (before.isEmpty() && !mapper.hasCurrentBusinessReference(tenantId, centerVersionId)) {
|
// A CREATE can be center-effective before its resource projection commits.
|
// With no occupancy this still enters the original center/historical path.
|
String number=mapper.centerFileNumber(tenantId,centerVersionId);
|
if(number==null) return true;
|
if(!coordinator.tryEnterExpiry(tenantId,List.of(number))) return false;
|
return Objects.equals(number,mapper.centerFileNumber(tenantId,centerVersionId))
|
&& !mapper.hasCurrentBusinessReference(tenantId,centerVersionId);
|
}
|
if (before.size() != 1)
|
throw new IllegalStateException("到期文件当前业务映射异常，需核查映射");
|
BusinessFileTarget target = before.get(0);
|
if (!coordinator.tryEnterExpiry(tenantId, List.of(target.getFileNumber()))) return false;
|
// Discovery gives only the lock key; a mapping change must not redirect the expiry.
|
List<BusinessFileTarget> after = mapper.expiryTargets(tenantId, centerVersionId);
|
return before.equals(after);
|
});
|
}
|
}
|
