gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix(sj_1.4.0-beta2):

Browse Source 
1、修复工作流去重告警异常问题
This commit is contained in:
zhengweilin 2025-03-09 18:29:49 +08:00
parent 758c2eeada
commit d83bbb9b95
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/alarm/AbstractWorkflowAlarm.java
View File

@ -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<E extends ApplicationEvent> extends
Map<Long, List<WorkflowAlarmInfo>> workflowAlarmInfoMap = new HashMap<>();
workflowAlarmInfoList.forEach(i -> notifyScene.add(i.getNotifyScene()));
Map<Long, WorkflowAlarmInfo> workflowAlarmInfoGroupMap = workflowAlarmInfoList.stream().collect(Collectors.toMap(i -> i.getId(), Function.identity()));
Map<Long, WorkflowAlarmInfo> workflowAlarmInfoGroupMap = StreamUtils.toIdentityMap(workflowAlarmInfoList, WorkflowAlarmInfo::getId);
// 查询数据库
List<WorkflowBatchResponseDO> workflowBatchResponseDOList = workflowTaskBatchMapper.selectWorkflowBatchList(
new QueryWrapper<WorkflowTaskBatch>()
.in("batch.id", workflowAlarmInfoList.stream().map(i -> i.getId()).collect(Collectors.toSet()))