package jnpf.dmsService;
|
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.dmsMapper.DmsApprovedBatchMapper;
|
import jnpf.dmsMapper.DmsApprovedDisableMapper;
|
import jnpf.dmsEntity.storage.approval.DmsDisableRequest;
|
import org.springframework.beans.factory.annotation.Value;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
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
|
@ConditionalOnProperty(name = "dms.approved-files.effective-job.enabled", havingValue = "true", matchIfMissing = true)
|
public class DmsApprovedFileEffectiveJob {
|
private static final int DISCOVERY_PAGE_SIZE = 100;
|
private final DmsApprovedBatchMapper receipts;
|
private final DmsApprovedFileRetryService retry;
|
private final DmsApprovedDisableMapper disables;
|
private final DmsApprovedDisableService disableService;
|
@Value("${dms.approved-disable.enabled:false}") private boolean disableEnabled;
|
|
@Value("${dms.approved-files.retry-backoff-enabled:true}")
|
private boolean retryBackoffEnabled = true;
|
|
@Scheduled(cron = "${dms.approved-files.effective-job.cron:0 * * * * ?}")
|
@AuditLog(action = "DMS_APPROVED_FILES_DUE", bizCodeExpr = "''", recordSuccess = false)
|
public void activateDue() {
|
receipts.discover();
|
if (disableEnabled) {
|
discoverDisables();
|
}
|
for (jnpf.dmsEntity.storage.approval.DmsApprovedBatch receipt : receipts.retryCandidates(disableEnabled, retryBackoffEnabled)) {
|
try { retry.process(receipt); }
|
catch (RuntimeException error) {
|
log.error("批准文件本次处理失败，后续按登记进度自动重试 tenant={} batch={}", receipt.getTenantId(), receipt.getId(), error);
|
}
|
}
|
}
|
|
private void discoverDisables() {
|
DmsDisableRequest after = null;
|
while (true) {
|
List<DmsDisableRequest> page = disables.approvedApplications(after, DISCOVERY_PAGE_SIZE);
|
for (DmsDisableRequest source : page) {
|
try { disableService.enqueue(source.getTenantId(), source.getFlowId(), source.getTaskId(), source.getOperation()); }
|
catch (RuntimeException error) {
|
log.error("停用申请接收失败 tenant={} task={} application={}",
|
source.getTenantId(), source.getTaskId(), source.getApplicationId(), error);
|
}
|
}
|
if (page.size() < DISCOVERY_PAGE_SIZE) return;
|
// Advance past failures too. OFFSET would skip rows as successful enqueues leave the query.
|
after = page.get(page.size() - 1);
|
}
|
}
|
}
|
