diff --git a/iot-common/iot-third/src/main/java/com/qiuguo/iot/third/nlp/AliYunXingChen.java b/iot-common/iot-third/src/main/java/com/qiuguo/iot/third/nlp/AliYunXingChen.java index c7698b9..f0c877d 100644 --- a/iot-common/iot-third/src/main/java/com/qiuguo/iot/third/nlp/AliYunXingChen.java +++ b/iot-common/iot-third/src/main/java/com/qiuguo/iot/third/nlp/AliYunXingChen.java @@ -87,6 +87,7 @@ public class AliYunXingChen { response.blockingForEach(m -> { String v = m.getChoices().get(0).getMessages().get(0).getContent().replaceAll(recordMessage.getMsg(), ""); onNext.sendMessage(v); + recordMessage.setMsg(m.getChoices().get(0).getMessages().get(0).getContent()); if("stop".equals(m.getChoices().get(0).getStopReason())){ // @@ -94,6 +95,7 @@ public class AliYunXingChen { .role(m.getChoices().get(0).getMessages().get(0).getRole()) .content(m.getChoices().get(0).getMessages().get(0).getContent()) .build(); + qwenReplyResponse.setResut(message1.getContent()); addMessage(message1); onNext.finish(); }