package jnpf.flowable.service;
|
|
import jnpf.exception.DataException;
|
import jnpf.flowable.model.filepermission.WorkflowFileCheckpoint;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.stereotype.Service;
|
import java.util.Map;
|
import java.util.function.Consumer;
|
|
@Service
|
@RequiredArgsConstructor
|
public class WorkflowFileCheckpointSupport {
|
private final FilePermissionSnapshotService snapshots;
|
private final ObjectProvider<WorkflowFileCheckpoint> checkpoint;
|
|
public boolean enabled(String taskId) { return snapshots.find(taskId) != null; }
|
|
public void save(String taskId, String formId, Map<String, Object> data, Consumer<Map<String, Object>> continuation) {
|
save(taskId, formId, null, data, continuation);
|
}
|
|
public void save(String taskId, String formId, String operatorId, Map<String, Object> data,
|
Consumer<Map<String, Object>> continuation) {
|
if (snapshots.find(taskId) == null) { continuation.accept(data); return; }
|
WorkflowFileCheckpoint service = checkpoint.getIfAvailable();
|
if (service == null) throw new DataException("当前部署尚未接入流程共享附件保存，不能继续节点操作");
|
service.save(taskId, formId, operatorId, data, continuation);
|
}
|
}
|
