|
@@ -137,7 +137,8 @@ public class BigModelServiceImpl implements IBigModelService
|
|
|
json.put("data",symbolData);
|
|
json.put("data",symbolData);
|
|
|
log.info("智谱返回信息:" + json);
|
|
log.info("智谱返回信息:" + json);
|
|
|
symbolData = "";
|
|
symbolData = "";
|
|
|
- threadPoolTaskExecutor.execute(() -> send(sseEmitter,json));
|
|
|
|
|
|
|
+ send(sseEmitter,json);
|
|
|
|
|
+// threadPoolTaskExecutor.execute(() -> send(sseEmitter,json));
|
|
|
}
|
|
}
|
|
|
} else {
|
|
} else {
|
|
|
JSONObject json = new JSONObject();
|
|
JSONObject json = new JSONObject();
|
|
@@ -145,7 +146,8 @@ public class BigModelServiceImpl implements IBigModelService
|
|
|
json.put("event", type);
|
|
json.put("event", type);
|
|
|
json.put("data", newData);
|
|
json.put("data", newData);
|
|
|
log.info("智谱返回信息:" + json);
|
|
log.info("智谱返回信息:" + json);
|
|
|
- threadPoolTaskExecutor.execute(() -> send(sseEmitter,json));
|
|
|
|
|
|
|
+ send(sseEmitter,json);
|
|
|
|
|
+// threadPoolTaskExecutor.execute(() -> send(sseEmitter,json));
|
|
|
}
|
|
}
|
|
|
//sseEmitter.send(json);
|
|
//sseEmitter.send(json);
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|