Compare commits
No commits in common. "0724f442e6925f99ea9f6fd8fa9ef8510aa658f3" and "5061f4f140e494be30e62d9174871f87fd7e0136" have entirely different histories.
0724f442e6
...
5061f4f140
@ -10,8 +10,39 @@ import org.slf4j.LoggerFactory;
|
|||||||
|
|
||||||
@SpringBootApplication
|
@SpringBootApplication
|
||||||
public class GoeingPrintServerApplication {
|
public class GoeingPrintServerApplication {
|
||||||
public static void main(String[] args) {
|
|
||||||
SpringApplication.run(GoeingPrintServerApplication.class, args);
|
private static final Logger log = LoggerFactory.getLogger(GoeingPrintServerApplication.class);
|
||||||
|
|
||||||
|
public static void main(String[] args) {
|
||||||
|
// 检查是否在macOS系统上运行
|
||||||
|
String osName = System.getProperty("os.name").toLowerCase();
|
||||||
|
boolean isMacOS = osName.contains("mac");
|
||||||
|
|
||||||
|
// 检查是否已经设置了java.awt.headless系统属性
|
||||||
|
String headlessProperty = System.getProperty("java.awt.headless");
|
||||||
|
|
||||||
|
// 如果是macOS并且没有明确设置headless属性,可能需要特殊处理
|
||||||
|
if (isMacOS && headlessProperty == null) {
|
||||||
|
log.info("在macOS系统上运行,检查是否需要启用无头模式");
|
||||||
|
|
||||||
|
// 检查是否支持图形界面
|
||||||
|
if (GraphicsEnvironment.isHeadless()) {
|
||||||
|
log.warn("检测到系统不支持图形界面,自动启用无头模式");
|
||||||
|
System.setProperty("java.awt.headless", "true");
|
||||||
|
System.setProperty("app.headless.mode", "true");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
ConfigurableApplicationContext context = SpringApplication.run(GoeingPrintServerApplication.class, args);
|
||||||
|
|
||||||
|
// 从配置中读取是否强制使用无头模式
|
||||||
|
Environment env = context.getEnvironment();
|
||||||
|
boolean forceHeadless = Boolean.parseBoolean(env.getProperty("app.force.headless", "false"));
|
||||||
|
|
||||||
|
if (forceHeadless) {
|
||||||
|
log.info("根据配置强制启用无头模式");
|
||||||
|
System.setProperty("java.awt.headless", "true");
|
||||||
|
System.setProperty("app.headless.mode", "true");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -35,10 +35,7 @@ public class PrintController implements PrintService {
|
|||||||
@Autowired
|
@Autowired
|
||||||
private PrintServerConfig config;
|
private PrintServerConfig config;
|
||||||
|
|
||||||
@Autowired
|
private final String rootPath = "pdfTemp";
|
||||||
private com.goeing.printserver.main.sse.PrinterClient printerClient;
|
|
||||||
|
|
||||||
private final String rootPath = System.getProperty("java.io.tmpdir") + File.separator + "goeingprint" + File.separator + "pdfTemp";
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取所有可用打印机列表
|
* 获取所有可用打印机列表
|
||||||
@ -197,65 +194,6 @@ public class PrintController implements PrintService {
|
|||||||
return settings;
|
return settings;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取打印机连接状态
|
|
||||||
*
|
|
||||||
* @return 包含各种连接状态的详细信息
|
|
||||||
*/
|
|
||||||
@GetMapping("printers/status")
|
|
||||||
public Map<String, Object> getPrintersStatus() {
|
|
||||||
Map<String, Object> status = new HashMap<>();
|
|
||||||
|
|
||||||
// Java后端服务状态
|
|
||||||
Map<String, Object> backendStatus = new HashMap<>();
|
|
||||||
backendStatus.put("status", "connected");
|
|
||||||
backendStatus.put("uptime", getUptime());
|
|
||||||
backendStatus.put("timestamp", System.currentTimeMillis());
|
|
||||||
status.put("backend", backendStatus);
|
|
||||||
|
|
||||||
// WebSocket连接状态
|
|
||||||
Map<String, Object> websocketStatus = new HashMap<>();
|
|
||||||
boolean isWebSocketConnected = printerClient.isConnected();
|
|
||||||
websocketStatus.put("status", isWebSocketConnected ? "connected" : "disconnected");
|
|
||||||
websocketStatus.put("url", config.getWebsocketUrl());
|
|
||||||
websocketStatus.put("printerId", config.getPrinterId());
|
|
||||||
if (isWebSocketConnected) {
|
|
||||||
websocketStatus.put("connectionUrl", printerClient.getCurrentConnectionUrl());
|
|
||||||
}
|
|
||||||
websocketStatus.put("timestamp", System.currentTimeMillis());
|
|
||||||
status.put("websocket", websocketStatus);
|
|
||||||
|
|
||||||
// 本地打印机状态
|
|
||||||
Map<String, Object> printersStatus = new HashMap<>();
|
|
||||||
javax.print.PrintService[] printServices = PrinterJob.lookupPrintServices();
|
|
||||||
List<Map<String, Object>> printerList = Arrays.stream(printServices)
|
|
||||||
.map(service -> {
|
|
||||||
Map<String, Object> printer = new HashMap<>();
|
|
||||||
printer.put("name", service.getName());
|
|
||||||
printer.put("status", "available"); // 简化处理,假设所有检测到的打印机都可用
|
|
||||||
printer.put("isDefault", service.getName().equals(config.getDefaultPrinter()));
|
|
||||||
return printer;
|
|
||||||
})
|
|
||||||
.sorted((a, b) -> ((String) a.get("name")).compareTo((String) b.get("name")))
|
|
||||||
.collect(Collectors.toList());
|
|
||||||
|
|
||||||
printersStatus.put("count", printerList.size());
|
|
||||||
printersStatus.put("printers", printerList);
|
|
||||||
printersStatus.put("defaultPrinter", config.getDefaultPrinter());
|
|
||||||
printersStatus.put("timestamp", System.currentTimeMillis());
|
|
||||||
status.put("localPrinters", printersStatus);
|
|
||||||
|
|
||||||
// 打印队列状态
|
|
||||||
Map<String, Object> queueStatus = new HashMap<>();
|
|
||||||
queueStatus.put("queueSize", printQueueService.getQueueSize());
|
|
||||||
queueStatus.put("maxQueueSize", printQueueService.getMaxQueueSize());
|
|
||||||
queueStatus.put("currentTask", printQueueService.getCurrentTaskInfo());
|
|
||||||
queueStatus.put("timestamp", System.currentTimeMillis());
|
|
||||||
status.put("queue", queueStatus);
|
|
||||||
|
|
||||||
return status;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 保存系统设置
|
* 保存系统设置
|
||||||
*
|
*
|
||||||
@ -265,76 +203,18 @@ public class PrintController implements PrintService {
|
|||||||
@PostMapping("settings")
|
@PostMapping("settings")
|
||||||
public Map<String, String> saveSystemSettings(@RequestBody Map<String, Object> settings) {
|
public Map<String, String> saveSystemSettings(@RequestBody Map<String, Object> settings) {
|
||||||
try {
|
try {
|
||||||
boolean needReconnect = false;
|
|
||||||
|
|
||||||
// 更新最大队列大小
|
// 更新最大队列大小
|
||||||
if (settings.containsKey("maxQueueSize")) {
|
if (settings.containsKey("maxQueueSize")) {
|
||||||
int maxQueueSize = (Integer) settings.get("maxQueueSize");
|
int maxQueueSize = (Integer) settings.get("maxQueueSize");
|
||||||
printQueueService.setMaxQueueSize(maxQueueSize);
|
printQueueService.setMaxQueueSize(maxQueueSize);
|
||||||
config.setMaxQueueSize(maxQueueSize);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 更新默认打印机
|
|
||||||
if (settings.containsKey("defaultPrinter")) {
|
|
||||||
String defaultPrinter = (String) settings.get("defaultPrinter");
|
|
||||||
config.setDefaultPrinter(defaultPrinter);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 更新通知设置
|
|
||||||
if (settings.containsKey("enableNotifications")) {
|
|
||||||
boolean enableNotifications = (Boolean) settings.get("enableNotifications");
|
|
||||||
config.setEnableNotifications(enableNotifications);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 更新自动启动设置
|
|
||||||
if (settings.containsKey("autoStart")) {
|
|
||||||
boolean autoStart = (Boolean) settings.get("autoStart");
|
|
||||||
config.setAutoStart(autoStart);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 更新WebSocket URL(需要重连)
|
|
||||||
if (settings.containsKey("websocketUrl")) {
|
|
||||||
String websocketUrl = (String) settings.get("websocketUrl");
|
|
||||||
if (!websocketUrl.equals(config.getWebsocketUrl())) {
|
|
||||||
config.setWebsocketUrl(websocketUrl);
|
|
||||||
needReconnect = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 更新打印机ID(需要重连)
|
|
||||||
if (settings.containsKey("printerId")) {
|
|
||||||
String printerId = (String) settings.get("printerId");
|
|
||||||
if (!printerId.equals(config.getPrinterId())) {
|
|
||||||
config.setPrinterId(printerId);
|
|
||||||
needReconnect = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 更新API Key(需要重连)
|
|
||||||
if (settings.containsKey("apiKey")) {
|
|
||||||
String apiKey = (String) settings.get("apiKey");
|
|
||||||
if (!apiKey.equals(config.getApiKey())) {
|
|
||||||
config.setApiKey(apiKey);
|
|
||||||
needReconnect = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 保存配置到文件
|
|
||||||
config.saveConfig();
|
|
||||||
|
|
||||||
// 如果WebSocket相关配置发生变化,触发重连
|
|
||||||
if (needReconnect) {
|
|
||||||
log.info("WebSocket配置已更改,正在重新连接...");
|
|
||||||
printerClient.reconnect();
|
|
||||||
} else {
|
|
||||||
log.info("WebSocket配置未更改,无需重连");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 这里可以添加其他设置的保存逻辑
|
||||||
log.info("系统设置已保存: {}", settings);
|
log.info("系统设置已保存: {}", settings);
|
||||||
|
|
||||||
Map<String, String> result = new HashMap<>();
|
Map<String, String> result = new HashMap<>();
|
||||||
result.put("status", "success");
|
result.put("status", "success");
|
||||||
result.put("message", "设置保存成功" + (needReconnect ? ",WebSocket正在重新连接" : ""));
|
result.put("message", "设置保存成功");
|
||||||
return result;
|
return result;
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("保存系统设置失败", e);
|
log.error("保存系统设置失败", e);
|
||||||
@ -345,7 +225,37 @@ public class PrintController implements PrintService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取系统日志
|
||||||
|
*
|
||||||
|
* @return 系统日志列表
|
||||||
|
*/
|
||||||
|
@GetMapping("logs")
|
||||||
|
public List<Map<String, Object>> getSystemLogs() {
|
||||||
|
// 这里返回模拟的日志数据,实际项目中可以集成日志框架
|
||||||
|
List<Map<String, Object>> logs = new ArrayList<>();
|
||||||
|
|
||||||
|
Map<String, Object> log1 = new HashMap<>();
|
||||||
|
log1.put("level", "info");
|
||||||
|
log1.put("time", LocalDateTime.now().minusHours(1).toString());
|
||||||
|
log1.put("message", "打印服务启动成功");
|
||||||
|
logs.add(log1);
|
||||||
|
|
||||||
|
Map<String, Object> log2 = new HashMap<>();
|
||||||
|
log2.put("level", "info");
|
||||||
|
log2.put("time", LocalDateTime.now().minusMinutes(30).toString());
|
||||||
|
log2.put("message", "连接到打印机: " + (config.getDefaultPrinter() != null ? config.getDefaultPrinter() : "默认打印机"));
|
||||||
|
logs.add(log2);
|
||||||
|
|
||||||
|
Map<String, Object> log3 = new HashMap<>();
|
||||||
|
log3.put("level", "info");
|
||||||
|
log3.put("time", LocalDateTime.now().minusMinutes(10).toString());
|
||||||
|
log3.put("message", "当前队列大小: " + printQueueService.getQueueSize());
|
||||||
|
logs.add(log3);
|
||||||
|
|
||||||
|
return logs;
|
||||||
|
}
|
||||||
|
|
||||||
@PostMapping("print")
|
@PostMapping("print")
|
||||||
public String print(@RequestBody PrintRequest request) {
|
public String print(@RequestBody PrintRequest request) {
|
||||||
// 记录请求信息
|
// 记录请求信息
|
||||||
@ -394,7 +304,7 @@ public class PrintController implements PrintService {
|
|||||||
log.info("正在从以下地址下载文件: {}", fileUrl);
|
log.info("正在从以下地址下载文件: {}", fileUrl);
|
||||||
HttpUtil.downloadFile(fileUrl, filePath);
|
HttpUtil.downloadFile(fileUrl, filePath);
|
||||||
|
|
||||||
log.info("文件下载地址为:{}",filePath);
|
log.info("文件下载地址为:",filePath);
|
||||||
|
|
||||||
if (!pdfFile.exists() || pdfFile.length() == 0) {
|
if (!pdfFile.exists() || pdfFile.length() == 0) {
|
||||||
throw new RuntimeException("Downloaded file is empty or does not exist");
|
throw new RuntimeException("Downloaded file is empty or does not exist");
|
||||||
|
|||||||
@ -1,32 +0,0 @@
|
|||||||
// LogbackConfig.java
|
|
||||||
package com.goeing.printserver.main.config;
|
|
||||||
|
|
||||||
import ch.qos.logback.classic.LoggerContext;
|
|
||||||
import ch.qos.logback.classic.Logger;
|
|
||||||
import com.goeing.printserver.main.utils.MemoryLogAppender;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
|
|
||||||
import jakarta.annotation.PostConstruct;
|
|
||||||
|
|
||||||
@Configuration
|
|
||||||
public class LogbackConfig {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private MemoryLogAppender memoryLogAppender;
|
|
||||||
|
|
||||||
@PostConstruct
|
|
||||||
public void registerAppender() {
|
|
||||||
LoggerContext context = (LoggerContext) LoggerFactory.getILoggerFactory();
|
|
||||||
|
|
||||||
// // 添加 appender 到 root logger
|
|
||||||
Logger rootLogger = context.getLogger(org.slf4j.Logger.ROOT_LOGGER_NAME);
|
|
||||||
rootLogger.addAppender(memoryLogAppender);
|
|
||||||
memoryLogAppender.start();
|
|
||||||
|
|
||||||
// 可选:也加到你的包 logger
|
|
||||||
// Logger appLogger = context.getLogger("com.goeing.printserver");
|
|
||||||
// appLogger.addAppender(memoryLogAppender);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -78,7 +78,7 @@ public class PrintServerConfig {
|
|||||||
printerId = properties.getProperty("printerId", DEFAULT_PRINTER_ID);
|
printerId = properties.getProperty("printerId", DEFAULT_PRINTER_ID);
|
||||||
apiKey = properties.getProperty("apiKey", DEFAULT_API_KEY);
|
apiKey = properties.getProperty("apiKey", DEFAULT_API_KEY);
|
||||||
|
|
||||||
log.info("配置已加载: {}, WebSocket URL: {}, PrinterId: {}", configFile.getAbsolutePath(), websocketUrl, printerId);
|
log.info("配置已加载: {}", configFile.getAbsolutePath());
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
log.error("加载配置文件失败", e);
|
log.error("加载配置文件失败", e);
|
||||||
// 使用默认值
|
// 使用默认值
|
||||||
@ -101,10 +101,7 @@ public class PrintServerConfig {
|
|||||||
*/
|
*/
|
||||||
public void saveConfig() {
|
public void saveConfig() {
|
||||||
try {
|
try {
|
||||||
// 确保目录存在
|
// 更新属性
|
||||||
configFile.getParentFile().mkdirs();
|
|
||||||
|
|
||||||
// 设置配置值
|
|
||||||
properties.setProperty("defaultPrinter", defaultPrinter);
|
properties.setProperty("defaultPrinter", defaultPrinter);
|
||||||
properties.setProperty("maxQueueSize", String.valueOf(maxQueueSize));
|
properties.setProperty("maxQueueSize", String.valueOf(maxQueueSize));
|
||||||
properties.setProperty("enableNotifications", String.valueOf(enableNotifications));
|
properties.setProperty("enableNotifications", String.valueOf(enableNotifications));
|
||||||
@ -116,10 +113,9 @@ public class PrintServerConfig {
|
|||||||
|
|
||||||
// 保存到文件
|
// 保存到文件
|
||||||
try (FileOutputStream fos = new FileOutputStream(configFile)) {
|
try (FileOutputStream fos = new FileOutputStream(configFile)) {
|
||||||
properties.store(fos, "Print Server Configuration");
|
properties.store(fos, "Goeing Print Server Configuration");
|
||||||
|
log.info("配置已保存: {}", configFile.getAbsolutePath());
|
||||||
}
|
}
|
||||||
|
|
||||||
log.info("配置已保存: {}, WebSocket URL: {}, PrinterId: {}", configFile.getAbsolutePath(), websocketUrl, printerId);
|
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
log.error("保存配置文件失败", e);
|
log.error("保存配置文件失败", e);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,74 +0,0 @@
|
|||||||
package com.goeing.printserver.main.controller;
|
|
||||||
|
|
||||||
import com.goeing.printserver.main.utils.MemoryLogAppender;
|
|
||||||
import com.goeing.printserver.main.utils.MemoryLogStorage;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.web.bind.annotation.*;
|
|
||||||
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日志控制器,提供日志相关的 API 接口
|
|
||||||
*/
|
|
||||||
@RestController
|
|
||||||
@RequestMapping("/api/logs")
|
|
||||||
@Slf4j
|
|
||||||
public class LogController {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private MemoryLogStorage memoryLogStorage;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取系统日志
|
|
||||||
* @param limit 限制数量,默认100
|
|
||||||
* @param level 日志级别过滤,默认ALL
|
|
||||||
* @return 日志列表
|
|
||||||
*/
|
|
||||||
@GetMapping
|
|
||||||
public Map<String, Object> getLogs(
|
|
||||||
@RequestParam(defaultValue = "100") int limit,
|
|
||||||
@RequestParam(defaultValue = "ALL") String level) {
|
|
||||||
|
|
||||||
Map<String, Object> result = new HashMap<>();
|
|
||||||
|
|
||||||
try {
|
|
||||||
List<MemoryLogAppender.LogEntry> logs = memoryLogStorage.getLogs(limit, level);
|
|
||||||
result.put("success", true);
|
|
||||||
result.put("logs", logs);
|
|
||||||
result.put("total", logs.size());
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("获取日志失败", e);
|
|
||||||
result.put("success", false);
|
|
||||||
result.put("message", "获取日志失败: " + e.getMessage());
|
|
||||||
result.put("logs", List.of());
|
|
||||||
result.put("total", 0);
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清空系统日志
|
|
||||||
* @return 操作结果
|
|
||||||
*/
|
|
||||||
@DeleteMapping
|
|
||||||
public Map<String, Object> clearLogs() {
|
|
||||||
Map<String, Object> result = new HashMap<>();
|
|
||||||
|
|
||||||
try {
|
|
||||||
memoryLogStorage.clearLogs();
|
|
||||||
result.put("success", true);
|
|
||||||
result.put("message", "日志已清空");
|
|
||||||
log.info("系统日志已被清空");
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("清空日志失败", e);
|
|
||||||
result.put("success", false);
|
|
||||||
result.put("message", "清空日志失败: " + e.getMessage());
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -151,9 +151,6 @@ public class PrinterClient implements ApplicationRunner {
|
|||||||
String printerId = config.getPrinterId();
|
String printerId = config.getPrinterId();
|
||||||
String apiKey = config.getApiKey();
|
String apiKey = config.getApiKey();
|
||||||
|
|
||||||
// 添加调试日志
|
|
||||||
log.info("当前配置 - WebSocket URL: {}, PrinterId: {}, ApiKey: {}", serverUri, printerId, apiKey);
|
|
||||||
|
|
||||||
String tempUrl = serverUri+"?printerId="+printerId+"&apiKey="+apiKey;
|
String tempUrl = serverUri+"?printerId="+printerId+"&apiKey="+apiKey;
|
||||||
|
|
||||||
isConnecting = true;
|
isConnecting = true;
|
||||||
|
|||||||
@ -1,68 +0,0 @@
|
|||||||
package com.goeing.printserver.main.utils;
|
|
||||||
|
|
||||||
import ch.qos.logback.classic.spi.ILoggingEvent;
|
|
||||||
import ch.qos.logback.core.AppenderBase;
|
|
||||||
import cn.hutool.extra.spring.SpringUtil;
|
|
||||||
import lombok.Getter;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
import java.time.format.DateTimeFormatter;
|
|
||||||
import java.util.*;
|
|
||||||
import java.util.concurrent.ConcurrentLinkedQueue;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 内存日志追加器,用于缓存日志到内存中
|
|
||||||
*/
|
|
||||||
@Component
|
|
||||||
public class MemoryLogAppender extends AppenderBase<ILoggingEvent> {
|
|
||||||
@Autowired
|
|
||||||
private MemoryLogStorage memoryLogStorage; // ✅ Spring 注入,全局唯一
|
|
||||||
|
|
||||||
private static final DateTimeFormatter FORMATTER =
|
|
||||||
DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void start() {
|
|
||||||
System.out.println("✅ MemoryLogAppender started with context: " + context);
|
|
||||||
super.start(); // 必须调用
|
|
||||||
}
|
|
||||||
@Override
|
|
||||||
protected void append(ILoggingEvent event) {
|
|
||||||
if (!isStarted()) return;
|
|
||||||
|
|
||||||
// 排除日志接口的请求日志,避免循环记录
|
|
||||||
String message = event.getFormattedMessage();
|
|
||||||
if (message != null) {
|
|
||||||
if (message.contains("/api/logs")||message.contains("LogController")) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
LogEntry logEntry = new LogEntry(
|
|
||||||
LocalDateTime.now().format(FORMATTER),
|
|
||||||
event.getLevel().toString(),
|
|
||||||
event.getLoggerName(),
|
|
||||||
event.getFormattedMessage()
|
|
||||||
);
|
|
||||||
memoryLogStorage.addLog(logEntry); // 写入共享存储
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 日志条目类
|
|
||||||
*/
|
|
||||||
@Getter
|
|
||||||
public static class LogEntry {
|
|
||||||
private final String timestamp;
|
|
||||||
private final String level;
|
|
||||||
private final String logger;
|
|
||||||
private final String message;
|
|
||||||
|
|
||||||
public LogEntry(String timestamp, String level, String logger, String message) {
|
|
||||||
this.timestamp = timestamp;
|
|
||||||
this.level = level;
|
|
||||||
this.logger = logger;
|
|
||||||
this.message = message;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,57 +0,0 @@
|
|||||||
package com.goeing.printserver.main.utils;
|
|
||||||
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import java.util.*;
|
|
||||||
import java.util.concurrent.ConcurrentLinkedQueue;
|
|
||||||
|
|
||||||
@Component
|
|
||||||
public class MemoryLogStorage {
|
|
||||||
|
|
||||||
private final Queue<MemoryLogAppender.LogEntry> logs = new ConcurrentLinkedQueue<>();
|
|
||||||
private static final int MAX_LOGS = 2000;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 添加日志条目,并控制最大数量
|
|
||||||
*/
|
|
||||||
public void addLog(MemoryLogAppender.LogEntry logEntry) {
|
|
||||||
logs.offer(logEntry);
|
|
||||||
// 保持最多 MAX_LOGS 条
|
|
||||||
while (logs.size() > MAX_LOGS) {
|
|
||||||
logs.poll();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取日志列表(支持过滤和分页)
|
|
||||||
*/
|
|
||||||
public List<MemoryLogAppender.LogEntry> getLogs(int limit, String level) {
|
|
||||||
List<MemoryLogAppender.LogEntry> result = new ArrayList<>();
|
|
||||||
for (MemoryLogAppender.LogEntry log : logs) {
|
|
||||||
if (level == null || "ALL".equals(level) || level.equals(log.getLevel())) {
|
|
||||||
result.add(log);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// 最新的在前
|
|
||||||
result.sort((a, b) -> b.getTimestamp().compareTo(a.getTimestamp()));
|
|
||||||
// 限制数量
|
|
||||||
if (limit > 0 && result.size() > limit) {
|
|
||||||
return result.subList(0, limit);
|
|
||||||
}
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清空所有日志
|
|
||||||
*/
|
|
||||||
public void clearLogs() {
|
|
||||||
logs.clear();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 获取当前日志数量(用于监控)
|
|
||||||
*/
|
|
||||||
public int size() {
|
|
||||||
return logs.size();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -254,8 +254,8 @@ public class PdfPrinter {
|
|||||||
PrintRequestAttributeSet aset = new HashPrintRequestAttributeSet();
|
PrintRequestAttributeSet aset = new HashPrintRequestAttributeSet();
|
||||||
|
|
||||||
// 设置纸张大小
|
// 设置纸张大小
|
||||||
// String size = option.getSize() != null ? option.getSize() : "Letter";
|
String size = option.getSize() != null ? option.getSize() : "Letter";
|
||||||
// aset.add(PAPER_SIZES.getOrDefault(size, MediaSizeName.NA_LETTER));
|
aset.add(PAPER_SIZES.getOrDefault(size, MediaSizeName.NA_LETTER));
|
||||||
|
|
||||||
// 设置颜色模式
|
// 设置颜色模式
|
||||||
setColorMode(aset, option.getColor());
|
setColorMode(aset, option.getColor());
|
||||||
@ -280,7 +280,7 @@ public class PdfPrinter {
|
|||||||
* @return PDF页面方向
|
* @return PDF页面方向
|
||||||
*/
|
*/
|
||||||
private static Orientation getPdfOrientation(String orientationStr) {
|
private static Orientation getPdfOrientation(String orientationStr) {
|
||||||
if ("ORI_LANDSCAPE".equalsIgnoreCase(orientationStr)) {
|
if (orientationStr != null && "ORI_LANDSCAPE".equalsIgnoreCase(orientationStr)) {
|
||||||
return Orientation.LANDSCAPE;
|
return Orientation.LANDSCAPE;
|
||||||
}
|
}
|
||||||
return Orientation.PORTRAIT; // 默认为纵向
|
return Orientation.PORTRAIT; // 默认为纵向
|
||||||
@ -293,14 +293,7 @@ public class PdfPrinter {
|
|||||||
* @param color 颜色模式字符串
|
* @param color 颜色模式字符串
|
||||||
*/
|
*/
|
||||||
private static void setColorMode(PrintRequestAttributeSet aset, String color) {
|
private static void setColorMode(PrintRequestAttributeSet aset, String color) {
|
||||||
if (color == null) {
|
if (color != null && ("Full Color".equalsIgnoreCase(color) || "Cover Letter Color Only".equalsIgnoreCase(color))) {
|
||||||
aset.add(Chromaticity.MONOCHROME);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
String c = color.trim().toLowerCase();
|
|
||||||
|
|
||||||
if (c.equals("color") || c.equals("full color") || c.equals("cover letter color only")) {
|
|
||||||
aset.add(Chromaticity.COLOR);
|
aset.add(Chromaticity.COLOR);
|
||||||
} else {
|
} else {
|
||||||
aset.add(Chromaticity.MONOCHROME);
|
aset.add(Chromaticity.MONOCHROME);
|
||||||
|
|||||||
@ -10,6 +10,7 @@ spring.main.allow-circular-references=true
|
|||||||
|
|
||||||
# 在macOS系统上,如果遇到HeadlessException,可以设置为true强制使用无头模式
|
# 在macOS系统上,如果遇到HeadlessException,可以设置为true强制使用无头模式
|
||||||
# 或者在启动时添加JVM参数:-Djava.awt.headless=true
|
# 或者在启动时添加JVM参数:-Djava.awt.headless=true
|
||||||
|
app.force.headless=false
|
||||||
|
|
||||||
# 日志配置
|
# 日志配置
|
||||||
# 设置打印机状态面板和设置面板的日志级别为WARN,减少日志输出
|
# 设置打印机状态面板和设置面板的日志级别为WARN,减少日志输出
|
||||||
|
|||||||
@ -1,54 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<configuration>
|
|
||||||
<!-- 控制台输出 -->
|
|
||||||
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
|
|
||||||
<encoder>
|
|
||||||
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
|
|
||||||
</encoder>
|
|
||||||
</appender>
|
|
||||||
|
|
||||||
<!-- 内存日志追加器 -->
|
|
||||||
<!-- <appender name="MEMORY" class="com.goeing.printserver.main.utils.MemoryLogAppender">-->
|
|
||||||
<!-- <!– 内存追加器不需要额外配置 –>-->
|
|
||||||
<!-- </appender>-->
|
|
||||||
|
|
||||||
<!-- 文件输出 -->
|
|
||||||
<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
|
|
||||||
<file>${java.io.tmpdir}/goeingprint/logs/application.log</file>
|
|
||||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
|
|
||||||
<fileNamePattern>${java.io.tmpdir}/goeingprint/logs/application.%d{yyyy-MM-dd}.%i.log</fileNamePattern>
|
|
||||||
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
|
|
||||||
<maxFileSize>10MB</maxFileSize>
|
|
||||||
</timeBasedFileNamingAndTriggeringPolicy>
|
|
||||||
<maxHistory>30</maxHistory>
|
|
||||||
</rollingPolicy>
|
|
||||||
<encoder>
|
|
||||||
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
|
|
||||||
</encoder>
|
|
||||||
</appender>
|
|
||||||
|
|
||||||
<!-- 根日志级别 -->
|
|
||||||
<root level="INFO">
|
|
||||||
<appender-ref ref="CONSOLE" />
|
|
||||||
<!-- <appender-ref ref="MEMORY" />-->
|
|
||||||
<appender-ref ref="FILE" />
|
|
||||||
</root>
|
|
||||||
|
|
||||||
<!-- 特定包的日志级别 -->
|
|
||||||
<logger name="com.goeing.printserver" level="DEBUG" additivity="false">
|
|
||||||
<appender-ref ref="CONSOLE" />
|
|
||||||
<!-- <appender-ref ref="MEMORY" />-->
|
|
||||||
<appender-ref ref="FILE" />
|
|
||||||
</logger>
|
|
||||||
|
|
||||||
<!-- Spring Boot 相关日志 -->
|
|
||||||
<logger name="org.springframework" level="INFO" />
|
|
||||||
<logger name="org.springframework.web" level="DEBUG" />
|
|
||||||
|
|
||||||
<!-- Hibernate 相关日志 -->
|
|
||||||
<logger name="org.hibernate" level="WARN" />
|
|
||||||
|
|
||||||
<!-- 网络相关日志 -->
|
|
||||||
<logger name="org.apache.http" level="WARN" />
|
|
||||||
<logger name="httpclient" level="WARN" />
|
|
||||||
</configuration>
|
|
||||||
Loading…
Reference in New Issue
Block a user