sxc/Vetti-Service-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TTS 返回语音优化

Browse Source
This commit is contained in:
wangxiangshun
2025-10-19 19:29:41 +08:00
parent 3f96c2e2f1
commit 9febb08b4f
1 changed files with 18 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
vetti-common/src/main/java/com/vetti/common/ai/gpt/OpenAiStreamClient.java
View File

@@ -104,6 +104,7 @@ public class OpenAiStreamClient {
String data = line.substring(6).trim(); String data = line.substring(6).trim();
// 检查是否为结束标记 // 检查是否为结束标记
if (data.equals("[DONE]")) { if (data.equals("[DONE]")) {
listener.onMessage(bufferStr.toString());
listener.onComplete(); listener.onComplete();
break; break;
} }
@@ -116,22 +117,23 @@ public class OpenAiStreamClient {
.getJSONObject("delta") .getJSONObject("delta")
.getStr("content"); .getStr("content");
// if (content != null && !content.isEmpty()) { if (content != null && !content.isEmpty()) {
// if(punctuationSet.contains(content)){ if(punctuationSet.contains(content)){
// //说明有标点啦,直接返回 //说明有标点啦,直接返回
// bufferStr.append(content); bufferStr.append(content);
// listener.onMessage(bufferStr.toString()); listener.onMessage(bufferStr.toString());
// }else{ bufferStr.replace(0, bufferStr.length(), "");
// //加入缓冲区 // bufferStr = new StringBuffer();
// if(StrUtil.isEmpty(bufferStr.toString())){ }else{
// bufferStr.append(content); //加入缓冲区
// }else { if(StrUtil.isEmpty(bufferStr.toString())){
// bufferStr.append(" ").append(content); bufferStr.append(content);
// } }else {
// } bufferStr.append(" ").append(content);
// }
// } }
listener.onMessage(content); }
// listener.onMessage(content);
} catch (Exception e) { } catch (Exception e) {
listener.onError(new IOException("Parse error: " + e.getMessage())); listener.onError(new IOException("Parse error: " + e.getMessage()));
} }