fix(billing): 统一计费代理类BillingChatServiceProxy

This commit is contained in:
Administrator
2025-09-04 16:41:14 +08:00
parent 4a8d21a742
commit 2b5fd810a4

View File

@@ -18,6 +18,7 @@ import java.util.function.Consumer;
/**
* 统一计费代理类
* 自动处理所有ChatService的AI回复保存和计费逻辑
*
*/
@Slf4j
@RequiredArgsConstructor
@@ -31,12 +32,12 @@ public class BillingChatServiceProxy implements IChatService {
// 🔥 在AI回复开始前检查余额是否充足
if (!chatCostService.checkBalanceSufficient(chatRequest)) {
String errorMsg = "余额不足无法使用AI服务请充值后再试";
log.warn("余额不足阻止AI回复用户ID: {}, 模型: {}",
log.warn("余额不足阻止AI回复用户ID: {}, 模型: {}",
chatRequest.getUserId(), chatRequest.getModel());
throw new RuntimeException(errorMsg);
}
log.debug("余额检查通过开始AI回复用户ID: {}, 模型: {}",
log.debug("余额检查通过开始AI回复用户ID: {}, 模型: {}",
chatRequest.getUserId(), chatRequest.getModel());
// 创建增强的SseEmitter自动收集AI回复