package jnpf.dmsService;
|
|
import jnpf.dmsEntity.center.DmsCenterDisableCommand;
|
import jnpf.base.ActionResult;
|
import jnpf.dmsEntity.storage.approval.DmsApprovedBatch;
|
import jnpf.dmsEntity.storage.approval.DmsDisableRequest;
|
import jnpf.dmsMapper.DmsApprovedDisableMapper;
|
import jnpf.exception.DataException;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
/** Processes due items using the shared batch lease; owns no retry queue or scheduler. */
|
@Service
|
@RequiredArgsConstructor
|
public class DmsApprovedDisableProcessor {
|
private final DmsApprovedDisableMapper mapper;
|
private final DmsApprovedDisableService service;
|
private final DmsApprovedDisableClient files;
|
@Value("${dms.approved-disable.enabled:false}") private boolean enabled;
|
|
public static boolean supports(String auditType) {
|
return "chexiao_shenqing".equals(auditType) || "shixiao_shenqing".equals(auditType);
|
}
|
|
public boolean isEnabled() { return enabled; }
|
|
public void process(DmsApprovedBatch batch) {
|
if (!enabled || !supports(batch.getAuditType()) || batch.getLeaseToken() == null)
|
throw new DataException("停用处理未启用或统一任务租约缺失");
|
RuntimeException failure = null;
|
for (DmsDisableRequest row : mapper.dueItems(batch.getTenantId(), batch.getId())) {
|
try { processItem(batch, row); }
|
catch (RuntimeException error) {
|
if (failure == null) failure = error;
|
else failure.addSuppressed(error);
|
}
|
}
|
// A completed row must not be replayed because a different row failed or is future-dated.
|
try { service.refreshProgress(batch); }
|
catch (RuntimeException error) {
|
if (failure == null) failure = error;
|
else failure.addSuppressed(error);
|
}
|
if (failure != null) throw failure;
|
}
|
|
private void processItem(DmsApprovedBatch batch, DmsDisableRequest row) {
|
DmsCenterDisableCommand form = new DmsCenterDisableCommand();
|
form.setTenantId(batch.getTenantId()); form.setRequestId(row.getId());
|
form.setMainDocumentId(row.getDocumentId()); form.setExpectedMainVersionId(row.getFileVersionId());
|
form.setReason(row.getOperation()); form.setActorId(row.getActorId()); form.setEffectiveAt(row.getScheduledAt());
|
form.setLeaseToken(batch.getLeaseToken());
|
ActionResult<Void> response = files.disable(form);
|
if (response == null || !Integer.valueOf(200).equals(response.getCode()))
|
throw new DataException(response == null ? "文件失效未返回执行结果" : response.getMsg());
|
}
|
}
|
