Parcourir la source

新增技淘百问处理

anderx il y a 2 ans
Parent
commit
9ed28bb5b9
1 fichiers modifiés avec 6 ajouts et 3 suppressions
  1. 6 3
      src/main/java/com/goafanti/common/utils/BaiduChatUtils.java

+ 6 - 3
src/main/java/com/goafanti/common/utils/BaiduChatUtils.java

@@ -119,18 +119,21 @@ public class BaiduChatUtils {
                     res.sseEmitter.send(data);
                 }
             }
-            SseMap.sseEmitterMap.remove(inputSendChat.getUserId());
             res.sseEmitter.complete();
             reader.close();
         } catch (MalformedURLException e) {
             e.printStackTrace();
+            sendJitaoBaiWen(inputSendChat.getUserId(),"data:{\"error_code\":\"2\",\"error_msg\":\"域名解析异常\"}");
         } catch (ProtocolException e) {
             e.printStackTrace();
         }
+        SseMap.sseEmitterMap.remove(inputSendChat.getUserId());
     }
 
-
-
+    private void sendJitaoBaiWen(String userId, String s) throws IOException {
+        SseResult res =  SseMap.sseEmitterMap.get(userId);
+        res.sseEmitter.send(s);
+    }
 
 
     private String  getRedisBaiduAccessToken() {