diff --git a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/qms/listener/QmsExecutionListener.java b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/qms/listener/QmsExecutionListener.java index 4d732e4..3b9ea74 100644 --- a/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/qms/listener/QmsExecutionListener.java +++ b/zt-module-bpm/zt-module-bpm-server/src/main/java/com/zt/plat/module/bpm/service/qms/listener/QmsExecutionListener.java @@ -8,6 +8,8 @@ import com.zt.plat.module.qms.enums.ErrorCodeConstants; import com.zt.plat.module.qms.enums.QmsBpmConstant; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; +import org.flowable.bpmn.model.FieldExtension; +import org.flowable.bpmn.model.FlowableListener; import org.flowable.engine.RuntimeService; import org.flowable.engine.delegate.DelegateExecution; import org.flowable.engine.delegate.JavaDelegate; @@ -15,6 +17,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; +import java.util.List; import java.util.Map; import static com.zt.plat.framework.common.exception.util.ServiceExceptionUtil.exception0; @@ -39,9 +42,11 @@ public class QmsExecutionListener implements JavaDelegate { JSONObject jsonObject = new JSONObject(variables); String insId = execution.getProcessInstanceId(); String businessKey = execution.getProcessInstanceBusinessKey(); - + FlowableListener listener = execution.getCurrentFlowableListener(); + List fieldExtensions = listener.getFieldExtensions(); //节点执行监听里配置的扩展字段 String currentActivityId = execution.getCurrentActivityId(); jsonObject.put(QmsBpmConstant.BPM_CALLBACK_ACTIVITY_ID, currentActivityId); + jsonObject.put(QmsBpmConstant.BPM_FIELD_EXTENSIONS, fieldExtensions); QmsBpmDTO qmsBpmDTO = new QmsBpmDTO(insId, businessKey, jsonObject, ""); Map v = runtimeService.getVariables(execution.getProcessInstanceId()); // Object status = runtimeService.getVariable(execution.getProcessInstanceId(), WfProcessConstant.TASK_VARIABLE_PROCESS_TERMINATE);