From d83bbb9b951f93fae06b5832757e978e635190b1 Mon Sep 17 00:00:00 2001 From: zhengweilin Date: Sun, 9 Mar 2025 18:29:49 +0800 Subject: [PATCH] =?UTF-8?q?fix(sj=5F1.4.0-beta2):=201=E3=80=81=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D=E5=B7=A5=E4=BD=9C=E6=B5=81=E5=8E=BB=E9=87=8D=E5=91=8A?= =?UTF-8?q?=E8=AD=A6=E5=BC=82=E5=B8=B8=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../snailjob/server/common/alarm/AbstractWorkflowAlarm.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/alarm/AbstractWorkflowAlarm.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/alarm/AbstractWorkflowAlarm.java index 83a45711c..b9c168037 100644 --- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/alarm/AbstractWorkflowAlarm.java +++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/alarm/AbstractWorkflowAlarm.java @@ -2,6 +2,7 @@ package com.aizuda.snailjob.server.common.alarm; import cn.hutool.core.util.StrUtil; import com.aizuda.snailjob.common.core.util.JsonUtil; +import com.aizuda.snailjob.common.core.util.StreamUtils; import com.aizuda.snailjob.server.common.convert.AlarmInfoConverter; import com.aizuda.snailjob.server.common.dto.WorkflowAlarmInfo; import com.aizuda.snailjob.template.datasource.persistence.dataobject.WorkflowBatchResponseDO; @@ -32,8 +33,8 @@ public abstract class AbstractWorkflowAlarm extends Map> workflowAlarmInfoMap = new HashMap<>(); workflowAlarmInfoList.forEach(i -> notifyScene.add(i.getNotifyScene())); - Map workflowAlarmInfoGroupMap = workflowAlarmInfoList.stream().collect(Collectors.toMap(i -> i.getId(), Function.identity())); - + Map workflowAlarmInfoGroupMap = StreamUtils.toIdentityMap(workflowAlarmInfoList, WorkflowAlarmInfo::getId); + // 查询数据库 List workflowBatchResponseDOList = workflowTaskBatchMapper.selectWorkflowBatchList( new QueryWrapper() .in("batch.id", workflowAlarmInfoList.stream().map(i -> i.getId()).collect(Collectors.toSet()))