|
@@ -64,13 +64,6 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
|
|
|
@Resource
|
|
|
private SSEService sseService;
|
|
|
|
|
|
- private HttpHeaders getHeader(){
|
|
|
- HttpHeaders headers = new HttpHeaders();
|
|
|
- //headers.setContentType(MediaType.APPLICATION_JSON);
|
|
|
- headers.set("Authorization", "Bearer " + token);
|
|
|
- return headers;
|
|
|
- }
|
|
|
-
|
|
|
public void chatCompletions(KimiRequest kimiRequest, Long groupId) {
|
|
|
|
|
|
HttpClient client = HttpClient.newBuilder().build();
|
|
@@ -117,6 +110,7 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
|
|
|
}
|
|
|
|
|
|
}).join();
|
|
|
+ log.info( "--结束--" );
|
|
|
sseService.complate(groupId);
|
|
|
}
|
|
|
|