package jnpf.dmsService.expiry;

import jnpf.dmsEntity.storage.expiry.DmsFileExpiryItem;
import jnpf.dmsMapper.DmsFileExpiryMapper;
import jnpf.dmsService.search.DmsSearchProperties;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import java.util.List;

@Slf4j
@Service
@EnableScheduling
@RequiredArgsConstructor
public class DmsFileExpiryJob {
    private final DmsFileExpiryProperties properties;
    private final DmsFileExpiryMapper mapper;
    private final DmsFileExpiryExecutor executor;
    private final DmsFileExpirySearchCleanup cleanup;
    private final DmsSearchProperties search;
    @Scheduled(cron = "${dms.expiry.cron:0 * * * * ?}")
    @jnpf.audit.sdk.annotation.AuditLog(action = "DMS_FILE_EXPIRY_SCAN", bizCodeExpr = "''", recordSuccess = false)
    public Result run() {
        int limit = Math.max(1, Math.min(1000, properties.getBatchSize()));
        int scanned = 0, applied = 0, skipped = 0, failed = 0;
        long oldestLagSeconds = 0;
        DmsFileExpiryItem after = null;
        for (int page = 0; page < Math.max(1, properties.getMaxPages()); page++) {
            List<DmsFileExpiryItem> items = mapper.candidates(after, limit);
            for (DmsFileExpiryItem item : items) {
                scanned++;
                oldestLagSeconds = Math.max(oldestLagSeconds,
                        Math.max(0, (System.currentTimeMillis() - item.getEffectiveTo().getTime()) / 1000));
                try {
                    if (executor.process(item)) applied++; else skipped++;
                } catch (RuntimeException error) {
                    failed++;
                    log.error("DMS expiry failed; retry next scan tenant={} version={}", item.getTenantId(), item.getFileVersionId(), error);
                }
            }
            if (items.size() < limit) break;
            after = items.get(items.size() - 1); // Advance over failures; a poison row cannot starve this scan.
        }
        log.info("DMS expiry scanned={} applied={} skipped={} failed={} oldestLagSeconds={}",
                scanned, applied, skipped, failed, oldestLagSeconds);
        if (search.isEnabled()) {
            for (DmsFileExpiryItem item : mapper.cleanupCandidates(limit)) {
                try { cleanup.process(item); }
                catch (RuntimeException error) {
                    log.error("DMS expiry cleanup retry tenant={} version={}", item.getTenantId(), item.getFileVersionId(), error);
                }
            }
        }
        return new Result(scanned, applied, skipped, failed, oldestLagSeconds);
    }

    @Getter
    public static final class Result {
        private final int scanned;
        private final int applied;
        private final int skipped;
        private final int failed;
        private final long oldestLagSeconds;

        public Result(int scanned, int applied, int skipped, int failed,
                      long oldestLagSeconds) {
            this.scanned = scanned;
            this.applied = applied;
            this.skipped = skipped;
            this.failed = failed;
            this.oldestLagSeconds = oldestLagSeconds;
        }
    }
}