Skip to content

phsl / api

Go to a project
Commit eac0c7e2 by Jony.L
Options

智谱多轮对话 conversationId不能为空

parent de9fb195
Showing with 4 additions and 0 deletions
computility-module-external/src/main/java/com/luhu/computility/module/external/controller/openapi/service/OpenApiServiceImpl.java
package com.luhu.computility.module.external.controller.openapi.service; package com.luhu.computility.module.external.controller.openapi.service;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONArray; import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject; import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
...@@ -639,6 +640,9 @@ public class OpenApiServiceImpl implements OpenApiService { ...@@ -639,6 +640,9 @@ public class OpenApiServiceImpl implements OpenApiService {
@Override @Override
public SseEmitter zhipuMultiStreamChat(ZhipuConversationReqDTO zhipuConversationReqDTO) { public SseEmitter zhipuMultiStreamChat(ZhipuConversationReqDTO zhipuConversationReqDTO) {
if(ObjectUtil.isEmpty(zhipuConversationReqDTO.getConversationId().trim())){
throw new ServiceException("多轮对话接口中conversationId不能为空！");
}
SseEmitter emitter = new SseEmitter(Long.MAX_VALUE); SseEmitter emitter = new SseEmitter(Long.MAX_VALUE);
ExecutorService executorService = Executors.newSingleThreadExecutor(); ExecutorService executorService = Executors.newSingleThreadExecutor();
executorService.submit(() -> { executorService.submit(() -> {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment