diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/integration/iwork/impl/IWorkIntegrationServiceImpl.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/integration/iwork/impl/IWorkIntegrationServiceImpl.java index fcf0bd56..d184dd7e 100644 --- a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/integration/iwork/impl/IWorkIntegrationServiceImpl.java +++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/integration/iwork/impl/IWorkIntegrationServiceImpl.java @@ -140,6 +140,11 @@ public class IWorkIntegrationServiceImpl implements IWorkIntegrationService { @Override public IWorkOperationRespVO createWorkflow(IWorkWorkflowCreateReqVO reqVO) { + // 检查是否传输了operatorId + String reqVOOperatorUserId = reqVO.getOperatorUserId(); + if (!StringUtils.hasText(reqVOOperatorUserId)) { + throw ServiceExceptionUtil.exception(IWORK_SEAL_REQUIRED_FIELD_MISSING, "operatorUserId"); + } assertConfigured(); String appId = resolveAppId(); ClientKeyPair clientKeyPair = resolveClientKeyPair(appId, Boolean.TRUE.equals(reqVO.getForceRefreshToken())); @@ -163,10 +168,16 @@ public class IWorkIntegrationServiceImpl implements IWorkIntegrationService { @Override public IWorkOperationRespVO createGenericWorkflow(IWorkGenericWorkflowCreateReqVO reqVO) { + // 检查是否传输了operatorId + String reqVOOperatorUserId = reqVO.getOperatorUserId(); + if (!StringUtils.hasText(reqVOOperatorUserId)) { + throw ServiceExceptionUtil.exception(IWORK_SEAL_REQUIRED_FIELD_MISSING, "operatorUserId"); + } + assertConfigured(); String appId = resolveAppId(); ClientKeyPair clientKeyPair = resolveClientKeyPair(appId, Boolean.TRUE.equals(reqVO.getForceRefreshToken())); - String operatorUserId = resolveOperatorUserId(reqVO.getOperatorUserId()); + String operatorUserId = resolveOperatorUserId(reqVOOperatorUserId); IWorkSession session = createSession(appId, clientKeyPair, operatorUserId, Boolean.TRUE.equals(reqVO.getForceRefreshToken())); // 构建透传参数,将 workflowId 加入 payload