diff --git a/flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java b/flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java index 42d8b0ca..286565d8 100644 --- a/flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java +++ b/flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java @@ -72,6 +72,9 @@ public class HpcHandler implements ExecutionHandler,HPCExecu String currentNodeId =execution.getCurrentActivityId(); String masterFileRegularStr = config.getMasterFileRegularStr(); String inputFilesRegularStr = config.getInputFilesRegularStr(); + if(StringUtils.isBlank(masterFileRegularStr)){ + throw new RuntimeException("Hpc任务执行失败,主求解文件规则不能是空"); + } CoreLogger.info("beforeNodeId:{},currentNodeId:{},masterFileRegularStr:{},inputFilesRegularStr:{}",beforeNodeId,currentNodeId,masterFileRegularStr,inputFilesRegularStr); // 初始化用户/租户信息 initUserInfo(execution); @@ -138,6 +141,13 @@ public class HpcHandler implements ExecutionHandler,HPCExecu Long userId = (Long) execution.getVariable("userId"); String userName = (String) execution.getVariable("userName"); Long tenantId = (Long) execution.getVariable("tenantId"); + log.info("Hpc流程发起,用户id:{},租户id:{}",userId,tenantId); + if(Objects.isNull(tenantId)){ + tenantId=ThreadLocalContext.getTenantId(); + } + if(Objects.isNull(userId)){ + tenantId=ThreadLocalContext.getUserId(); + } ThreadLocalContext.setUserId(userId); ThreadLocalContext.setUserName(userName); ThreadLocalContext.setTenantId(tenantId); diff --git a/pbs/src/main/java/com/sdm/pbs/service/impl/PbsServiceDecorator.java b/pbs/src/main/java/com/sdm/pbs/service/impl/PbsServiceDecorator.java index 007f4a01..6833dcc3 100644 --- a/pbs/src/main/java/com/sdm/pbs/service/impl/PbsServiceDecorator.java +++ b/pbs/src/main/java/com/sdm/pbs/service/impl/PbsServiceDecorator.java @@ -153,7 +153,7 @@ public class PbsServiceDecorator implements IPbsServiceDecorator { if (response.isSuccess() && StringUtils.isNotEmpty(response.getData())) { jobId = response.getData(); } - if(StringUtils.isNotEmpty(jobId)){ + if(StringUtils.isBlank(jobId)){ log.error("Hpc执行失败返回结果:{}",JSONObject.toJSONString(response)); throw new RuntimeException("Hpc执行失败,返回jobId空"); }