package jnpf.flowable.service;
|
|
import com.baomidou.dynamic.datasource.tx.TransactionContext;
|
import jnpf.flowable.mapper.DmsLifecycleNativeFormMapper;
|
import jnpf.onlinedev.VisualdevOnlineApi;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.support.TransactionSynchronizationManager;
|
|
/** DMS lifecycle only; native controller still owns validation, persistence and audit. */
|
@Component
|
public class DmsLifecycleNativeFormAdapter {
|
private final DmsLifecycleNativeFormMapper mapper;
|
private final ObjectProvider<VisualdevOnlineApi> nativeForms;
|
private final boolean enabled;
|
|
public DmsLifecycleNativeFormAdapter(DmsLifecycleNativeFormMapper mapper,
|
@Qualifier("visualdevForFlowController") ObjectProvider<VisualdevOnlineApi> nativeForms,
|
@Value("${dms.business-occupancy.enabled:false}") boolean enabled) {
|
this.mapper = mapper;
|
this.nativeForms = nativeForms;
|
this.enabled = enabled;
|
}
|
|
/** Same selection for write AND immediate readback; never silently fall back on protected writes. */
|
public VisualdevOnlineApi select(String formId, VisualdevOnlineApi ordinary, boolean writing) {
|
if (!enabled || formId == null || formId.isBlank()) return ordinary;
|
NativeForm form = mapper.publishedLifecycleForm(formId);
|
if (form == null) return ordinary;
|
boolean dynamic = TransactionContext.getXID() != null;
|
// Outside submission/approval transactions a normal detail read retains its existing route.
|
if (!writing && !dynamic) return ordinary;
|
if (!dynamic || TransactionSynchronizationManager.isActualTransactionActive())
|
throw new IllegalStateException("DMS 生命周期保存必须使用原生动态事务，不能混用事务管理器");
|
if (!Integer.valueOf(1).equals(form.getType())
|
|| (form.getDbLinkId() != null && !form.getDbLinkId().isBlank()
|
&& !"0".equals(form.getDbLinkId())))
|
throw new IllegalStateException("DMS 生命周期事务适配仅支持默认数据源原生在线表单");
|
VisualdevOnlineApi local = nativeForms.getIfAvailable();
|
if (local == null) throw new IllegalStateException("DMS 生命周期事务适配需要平台聚合部署的原生表单服务");
|
return local;
|
}
|
|
public boolean protects(String formId) {
|
return enabled && formId != null && mapper.publishedLifecycleForm(formId) != null;
|
}
|
|
/** Only DMS failures are tagged for the existing engine compensation branch. */
|
public <T> T invoke(String formId, VisualdevOnlineApi ordinary, boolean writing,
|
java.util.function.Function<VisualdevOnlineApi,T> action) {
|
if ((!writing && TransactionContext.getXID()==null) || !protects(formId)) return action.apply(ordinary);
|
try {
|
T result=action.apply(select(formId,ordinary,writing));
|
if(result==null) throw new IllegalStateException("DMS 原生表单调用未返回结果");
|
if(result instanceof jnpf.base.ActionResult<?> response && response.getCode()!=200)
|
throw new IllegalStateException(response.getMsg());
|
return result;
|
}
|
catch (RuntimeException failure) { throw new NativeFailure(failure); }
|
}
|
public static final class NativeFailure extends RuntimeException {
|
public NativeFailure(Throwable cause) { super(cause.getMessage(),cause); }
|
}
|
|
public static class NativeForm {
|
private String mainTable;
|
private String formData;
|
public String getMainTable() { return mainTable; }
|
public void setMainTable(String value) { mainTable = value; }
|
public String getFormData() { return formData; }
|
public void setFormData(String value) { formData = value; }
|
private Integer type;
|
private String dbLinkId;
|
public Integer getType() { return type; }
|
public void setType(Integer value) { type = value; }
|
public String getDbLinkId() { return dbLinkId; }
|
public void setDbLinkId(String value) { dbLinkId = value; }
|
}
|
}
|
