package jnpf.dmsService;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

/** Recovery consumes proven native terminal states; never expires a lease by age. */
@Service
@Slf4j
@RequiredArgsConstructor
public class DmsBusinessOccupancyTerminationJob {
    private final DmsBusinessLifecycleGuard guard;
    @Scheduled(cron="${dms.business-occupancy.termination-cron:0 * * * * ?}")
    public void releaseEndedApplications() {
        String after=null;
        for(int page=0;page<100;page++) {
            var rows=guard.terminationCandidates(after,100);
            for(var row:rows) try { guard.releaseEnded(row); }
            catch(RuntimeException error) { log.error("DMS terminal occupancy release failed tenant={} receipt={}",row.getTenantId(),row.getId(),error); }
            if(rows.size()<100) return;
            after=rows.get(rows.size()-1).getId();
        }
    }
}