|
|
@@ -8,6 +8,7 @@ import cn.reghao.devops.mgr.ops.builder.tool.repo.CommitInfo;
|
|
|
import cn.reghao.devops.mgr.ops.docker.model.po.DockerRegistry;
|
|
|
import lombok.Getter;
|
|
|
import lombok.Setter;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
|
import java.io.BufferedWriter;
|
|
|
import java.io.File;
|
|
|
@@ -22,6 +23,7 @@ import java.util.Queue;
|
|
|
* @author reghao
|
|
|
* @date 2026-02-26 15:22:24
|
|
|
*/
|
|
|
+@Slf4j
|
|
|
@Setter
|
|
|
@Getter
|
|
|
public class PipelineContext implements AutoCloseable {
|
|
|
@@ -95,15 +97,14 @@ public class PipelineContext implements AutoCloseable {
|
|
|
message);
|
|
|
|
|
|
// 1. 输出到控制台 (方便宿主观察)
|
|
|
- System.out.println("[" + appId + "_" + buildId + "] " + message);
|
|
|
-
|
|
|
+ //log.info("[" + appId + "_" + buildId + "] " + message);
|
|
|
// 2. 写入文件 (持久化)
|
|
|
try {
|
|
|
writer.write(formattedMsg);
|
|
|
writer.newLine();
|
|
|
writer.flush(); // 实时刷盘,防止崩溃时丢失日志
|
|
|
} catch (IOException e) {
|
|
|
- System.err.println("无法写入日志文件: " + e.getMessage());
|
|
|
+ log.error("无法写入日志文件: {}", e.getMessage());
|
|
|
}
|
|
|
|
|
|
// 3. 更新内存摘要 (用于任务结束后存入 MySQL)
|