toolchaintechnologycenter/spdm-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改：hpc代码优化,mock用户和租户id

Browse Source
This commit is contained in:
yangyang01000846
2026-01-14 19:50:59 +08:00
parent 8c986a335b
commit f1e34c06fd
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
flowable/src/main/java/com/sdm/flowable/delegate/handler/HpcHandler.java
View File

@@ -77,7 +77,7 @@ public class HpcHandler implements ExecutionHandler<Map<String, Object>,HPCExecu
}
CoreLogger.info("beforeNodeId:{},currentNodeId:{},masterFileRegularStr:{},inputFilesRegularStr:{}",beforeNodeId,currentNodeId,masterFileRegularStr,inputFilesRegularStr);
// 初始化用户/租户信息
initUserInfo(execution);
initUserInfo(execution,params);
// params 取只是测试使用
String processDefinitionId = (execution==null||StringUtils.isBlank(execution.getProcessDefinitionId()))?
params.get("processDefinitionId").toString():execution.getProcessDefinitionId();
@@ -136,17 +136,17 @@ public class HpcHandler implements ExecutionHandler<Map<String, Object>,HPCExecu
messageFeignClient.sendMessage(req);
}
private void initUserInfo(DelegateExecution execution) {
private void initUserInfo(DelegateExecution execution,Map<String, Object> params) {
// 获取当前流程实例参数
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();
tenantId=Objects.isNull(params.get("tenantId")) ? null : (Long) params.get("tenantId");
}
if(Objects.isNull(userId)){
tenantId=ThreadLocalContext.getUserId();
userId=Objects.isNull(params.get("userId")) ? null : (Long) params.get("userId");
}
ThreadLocalContext.setUserId(userId);
ThreadLocalContext.setUserName(userName);