zgty/zt-dsc
9
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(iwork): 添加工作流创建操作中operatorUserId字段验证

Browse Source 
- 在createWorkflow方法中添加operatorUserId必填字段检查
- 在createGenericWorkflow方法中添加operatorUserId必填字段检查
- 当operatorUserId为空时抛出IWORK_SEAL_REQUIRED_FIELD_MISSING异常
- 优化createGenericWorkflow中operatorUserId参数传递逻辑
This commit is contained in:
wuzongyong
2026-01-29 15:26:25 +08:00
parent 947e1cc891
commit 2af0f178dc
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/integration/iwork/impl/IWorkIntegrationServiceImpl.java
View File

@@ -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