wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - 调整 API 调用的日志打印

Browse Source
This commit is contained in:
wangli 2024-02-21 10:59:42 +08:00
parent 32ba169348
commit a7afc9524b
6 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/AbstractBpmnTaskAssigneeSelector.java
View File

@ -71,7 +71,8 @@ public abstract class AbstractBpmnTaskAssigneeSelector implements BpmnTaskAssign
return Collections.emptyList();
}
protected final <T> T parseApiResult(Supplier<ApiResult<T>> supplier, String operatorDesc, Object... param) {
protected final <T> T parseApiResult(Supplier<ApiResult<T>> supplier, String operatorDesc,
String extInfo, Object... param) {
StopWatch stopWatch = new StopWatch(operatorDesc);
log.info("{}-Param: {}", operatorDesc, JSONUtil.toJsonStr(param));
stopWatch.start();
@ -81,7 +82,7 @@ public abstract class AbstractBpmnTaskAssigneeSelector implements BpmnTaskAssign
Assert.notNull(result, "服务调用异常");
// 200自定义处理
if (HttpStatus.HTTP_OK != result.getCode()) {
throw new WorkflowEngineException(CALC_TASK_ASSIGNEE_ERROR, "[API:]" + result.getMsg());
throw new WorkflowEngineException(CALC_TASK_ASSIGNEE_ERROR, "[API:" + extInfo + "]" + result.getMsg());
}
return result.getData();
}

3
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/BasedIdentityTaskAssigneeSelector.java
View File

@ -62,7 +62,8 @@ public class BasedIdentityTaskAssigneeSelector extends AbstractBpmnTaskAssigneeS
List<FlowTaskAssignerResp> flowTaskAssigners =
parseApiResult(() -> flowSupportApi.listTaskAssignerByIdentity(req),
"审批节点: " + userTask.getId() + ", 通过身份查询审批人", req);
"审批节点: " + userTask.getId() + ", 通过身份查询审批人",
"cn.axzo.karma.client.feign.FlowSupportApi.listTaskAssignerByIdentity", req);
if (CollUtil.isEmpty(flowTaskAssigners)) {
return super.invokeService(userTask, execution, scopeDto);

3
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/BasedInitiatorLeaderTaskAssigneeSelector.java
View File

@ -71,7 +71,8 @@ public class BasedInitiatorLeaderTaskAssigneeSelector extends AbstractBpmnTaskAs
List<FlowTaskAssigner> flowTaskAssigners =
parseApiResult(() -> organizationalNodeUserApi.listFlowTaskAssigner(req),
"审批节点: " + userTask.getId() + ", 通过发起人主管查询审批人", req);
"审批节点: " + userTask.getId() + ", 通过发起人主管查询审批人",
"cn.axzo.maokai.api.client.OrganizationalNodeUserApi.listFlowTaskAssigner", req);
if (CollUtil.isEmpty(flowTaskAssigners)) {
return super.invokeService(userTask, execution, scopeDto);

3
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/BasedPositionTaskAssigneeSelector.java
View File

@ -59,7 +59,8 @@ public class BasedPositionTaskAssigneeSelector extends AbstractBpmnTaskAssigneeS
List<FlowTaskAssigner> flowTaskAssigners =
parseApiResult(() -> organizationalNodeUserApi.listFlowTaskAssigner(req),
"审批节点: " + userTask.getId() + ", 通过岗位查询审批人", req);
"审批节点: " + userTask.getId() + ", 通过岗位查询审批人",
"cn.axzo.maokai.api.client.OrganizationalNodeUserApi.listFlowTaskAssigner", req);
if (CollUtil.isEmpty(flowTaskAssigners)) {
return super.invokeService(userTask, execution, scopeDto);

3
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/BasedRoleTaskAssigneeSelector.java
View File

@ -64,7 +64,8 @@ public class BasedRoleTaskAssigneeSelector extends AbstractBpmnTaskAssigneeSelec
.collect(Collectors.toList()))
.build();
List<SaasRoleUserDTO> flowTaskAssigners = parseApiResult(() -> tyrSaasRoleUserApi.roleUserList(param),
"审批节点: " + userTask.getId() + ", 通过角色查询审批人", param)
"审批节点: " + userTask.getId() + ", 通过角色查询审批人",
"cn.axzo.tyr.client.feign.TyrSaasRoleUserApi.roleUserList", param)
.stream().filter(f -> workspaceIdSet.contains(f.getWorkspaceId()))
.collect(Collectors.toList());

3
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/TransferToAdminTaskAssigneeSelector.java
View File

@ -65,7 +65,8 @@ public class TransferToAdminTaskAssigneeSelector extends AbstractBpmnTaskAssigne
ListFlowTaskAssignerReq req = builder.build();
List<FlowTaskAssignerResp> flowTaskAssigners =
parseApiResult(() -> flowSupportApi.listTaskAssignerAdmin(req),
"审批节点: " + userTask.getId() + ", 通过管理员查询审批人", req);
"审批节点: " + userTask.getId() + ", 通过管理员查询审批人",
"cn.axzo.karma.client.feign.FlowSupportApi.listTaskAssignerAdmin", req);
if (CollUtil.isEmpty(flowTaskAssigners)) {
return super.invokeService(userTask, execution, scopeDto);