chat

src/main/java/com/sxtvs/open/api/chat/service/impl/KimiChatServiceImpl.java

@@ -87,7 +87,19 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
     }
 
     private void stream2db(String resp, Long groupId){
-        KimiStreamResponse kimiResponse =  JSON.parseObject(resp, KimiStreamResponse.class);
+
+        KimiStreamResponse kimiResponse ;
+        try{
+            kimiResponse =  JSON.parseObject(resp, KimiStreamResponse.class);
+        }catch (Exception e){
+            log.error("解析失败 -- ",resp);
+            return;
+        }
+        if(kimiResponse == null){
+            log.error("解析失败 -- ",resp);
+            return;
+        }
+        if(kimiResponse.getChoices() == null || kimiResponse.getChoices().size() == 0){
         if (kimiResponse == null || kimiResponse.getChoices() == null || kimiResponse.getChoices().isEmpty()){
             return;
         }