feat(REQ-3647) - 兼容日志中存在 personId 为 system 的情况

This commit is contained in:
wangli 2025-06-25 16:37:49 +08:00
parent 090b9caf97
commit 6a3b2f2d3c

View File

@ -234,7 +234,7 @@ public abstract class AbstractBpmnTaskAssigneeSelector implements BpmnTaskAssign
}
List<Long> personIds = assigners.stream()
.map(BpmnTaskDelegateAssigner::getPersonId)
.filter(e -> Objects.nonNull(e) && StringUtils.hasText(e) && !Objects.equals("null", e))
.filter(e -> Objects.nonNull(e) && StringUtils.hasText(e) && !Objects.equals("null", e) && !Objects.equals("system", e))
.map(Long::parseLong)
.distinct().collect(Collectors.toList());
if (CollectionUtils.isEmpty(personIds)) {
@ -244,7 +244,7 @@ public abstract class AbstractBpmnTaskAssigneeSelector implements BpmnTaskAssign
"根据 PersonId 查询自然人档案", "cn.axzo.karma.client.feign.FlowSupportApi.listPersons", refreshProperties, context, personIds)
.stream().collect(Collectors.toMap(PersonProfileResp::getId, Function.identity(), (s, t) -> s));
assigners.forEach(assigner -> {
if (!StringUtils.hasText(assigner.getPersonId()) || Objects.equals("null", assigner.getPersonId())) {
if (!StringUtils.hasText(assigner.getPersonId()) || Objects.equals("null", assigner.getPersonId()) || Objects.equals("system", assigner.getPersonId())) {
return;
}
long personId = Long.parseLong(Optional.ofNullable(assigner.getPersonId()).orElse("-1"));