Commit b5eb4e55 authored by 李超鹏's avatar 李超鹏

修改

parent fe28535e
Pipeline #7458 failed with stages
...@@ -60,17 +60,17 @@ public class KnowledgeService { ...@@ -60,17 +60,17 @@ public class KnowledgeService {
request.setQuery(text); request.setQuery(text);
request.setStream(true); request.setStream(true);
Multi<ChatAIResponse> chatStream = knowLedgeChat.chatStream(request); Multi<ChatAIResponse> chatStream = knowLedgeChat.chatStream(request);
StringBuilder answers = new StringBuilder(); StringBuilder answers = new StringBuilder(), docs = new StringBuilder();
return chatStream return chatStream
.onItem().invoke(item -> item.setQuestionId(question.getId())) .onItem().invoke(item -> item.setQuestionId(question.getId()))
.onItem().invoke(item -> { .onItem().invoke(item -> {
answers.append(StringUtil.isNullOrEmpty(item.getAnswer()) ? "" : item.getAnswer()); answers.append(StringUtil.isNullOrEmpty(item.getAnswer()) ? "" : item.getAnswer());
if (Objects.nonNull(item.getDocs())) { if (Objects.nonNull(item.getDocs())) {
answers.append("\n").append(String.join(";", item.getDocs())); docs.append(String.join(";", item.getDocs()));
} }
}) })
.onCompletion().invoke(() -> { .onCompletion().invoke(() -> {
questionMapper.updateById(question.setAnswers(answers.toString())); questionMapper.updateById(question.setAnswers(answers.toString()).setDocs(docs.toString()));
}); });
} }
return Multi.createFrom().item(new ChatAIResponse()); return Multi.createFrom().item(new ChatAIResponse());
......
...@@ -21,11 +21,12 @@ public class Question { ...@@ -21,11 +21,12 @@ public class Question {
private String question; private String question;
@TableField("answers") @TableField("answers")
private String answers; private String answers;
@TableField("docs")
private String docs;
@TableField("correct") @TableField("correct")
private Integer correct; private Integer correct;
@TableField("create_time") @TableField("create_time")
private LocalDateTime createTime; private LocalDateTime createTime;
@TableField("delete_flag") @TableField("delete_flag")
private Integer deleteFlag; private Integer deleteFlag;
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment