mianbin/ops-pro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

日志修改

Browse Source
This commit is contained in:
even 2025-05-26 20:04:50 +08:00
parent e16d90d3c4
commit 02447a79a4
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/manager/impl/MemoryLogManager.java
View File

@ -9,6 +9,7 @@ import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletRequest;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
import java.io.IOException;
@ -47,8 +48,9 @@ public class MemoryLogManager implements LoggerManager {
log.info("当前请求ip：{}",ipAddr);
log.info("当前用户id：{}",loginUserId);
log.info("当前taskId：{}",loginUserId);
List<SseEmitter> taskIdSSEList = taskIdSSEMap.getOrDefault(taskId, new ArrayList<>(1));
List<SseEmitter> taskIdSSEList = taskIdSSEMap.computeIfAbsent(taskId, k->new ArrayList<>(1));
taskIdSSEList.add(emitter);
return emitter;
}
@ -88,6 +90,16 @@ public class MemoryLogManager implements LoggerManager {
}
}
logCache.append(logContent);
List<SseEmitter> sseEmitters = taskIdSSEMap.get(taskId);
if (!CollectionUtils.isEmpty(sseEmitters)) {
for (SseEmitter sseEmitter : sseEmitters) {
try {
sseEmitter.send(logContent);
} catch (IOException e) {
log.error("",e);
}
}
}
}
@Override