《多轮AI智能对话系统》整体实现-第04节：历史会话与健康检查功能的设计与实现

/**
 * 清除某个用户的消息
 */
void clearMessage(String userId);

/**
 * 获取某个用户的历史消息
 */
List<AIMessage> getMessage(String userId);

/**
 * 获取某个用户对话历史的大小
 */
long getMessageSize(String userId);

@Override
public void clearMessage(String userId) {
	try {
		aiChatContextService.clearContextMessage(userId);
		log.info("清空历史对话成功, 用户ID:{}", userId);
	} catch (Exception e) {
		log.error("清空用户对话历史失败，用户ID: {}, 错误信息: {}", userId, e.getMessage());
	}
}

@Override
public List<AIMessage> getMessage(String userId) {
	try {
		List<AIMessage> history = aiChatContextService.getContextMessage(userId);
		log.info("获取历史会话列表，用户ID: {}, 历史会话消息数量: {}", userId, history.size());
		return history;
	} catch (Exception e) {
		log.error("获取历史会话列表失败，用户ID: {}, 错误信息: {}", userId, e.getMessage());
		return Collections.emptyList();
	}
}

@Override
public long getMessageSize(String userId) {
	try {
		return aiChatContextService.getContextMessageSize(userId);
	} catch (Exception e) {
		log.error("获取历史对话的大小失败，用户ID: {}, 错误: {}", userId, e.getMessage());
		return 0;
	}
}

/**
 * 获取历史对话消息
 */
@GetMapping("/history/{userId}")
public ResponseEntity<List<AIMessage>> getMessage(@PathVariable String userId) {
	try {
		log.info("获取历史对话消息，用户ID: {}", userId);

		List<AIMessage> history = aiChatService.getMessage(userId);
		return ResponseEntity.ok(history);

	} catch (Exception e) {
		log.error("获取历史对话消息: {}", e.getMessage());
		return ResponseEntity.internalServerError().build();
	}
}

/**
 * 清空历史对话消息
 */
@DeleteMapping("/history/{userId}")
public ResponseEntity<Map<String, String>> clearMessage(@PathVariable String userId) {
	try {
		log.info("清空历史对话消息，用户ID: {}", userId);

		aiChatService.clearMessage(userId);
		return ResponseEntity.ok(Map.of(AIConstants.MESSAGE, "对话历史已清除"));

	} catch (Exception e) {
		log.error("清空历史对话消息失败: {}", e.getMessage());
		return ResponseEntity.internalServerError()
				.body(Map.of("error", "清空历史对话消息失败：" + e.getMessage()));
	}
}

/**
 * 获取历史统计信息
 */
@GetMapping("/stats/{userId}")
public ResponseEntity<Map<String, Object>> getStats(@PathVariable String userId) {
	try {
		log.info("获取历史统计信息，用户ID: {}", userId);

		long historySize = aiChatService.getMessageSize(userId);
		return ResponseEntity.ok(Map.of(
				AIConstants.USERID, userId,
				AIConstants.HISTORY_SIZE, historySize,
				AIConstants.TIMESTAMP, System.currentTimeMillis()
		));

	} catch (Exception e) {
		log.error("获取历史统计信息失败: {}", e.getMessage(), e);
		return ResponseEntity.internalServerError().build();
	}
}

/**
 * 健康检查接口
 */
@GetMapping("/health")
public ResponseEntity<Map<String, String>> health() {
	return ResponseEntity.ok(Map.of(
			AIConstants.STATUS, AIConstants.STATUS_UP,
			AIConstants.SERVICE, "SpringAI DeepSeek Chat",
			AIConstants.TIMESTAMP, String.valueOf(System.currentTimeMillis())
	));
}