|
|
@@ -1,11 +1,14 @@
|
|
|
package org.dromara.talk.service.impl;
|
|
|
|
|
|
import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
import java.util.Map;
|
|
|
+import java.util.function.Consumer;
|
|
|
|
|
|
import cn.hutool.json.JSONObject;
|
|
|
import okhttp3.*;
|
|
|
import org.dromara.talk.config.DifyConfig;
|
|
|
+import org.dromara.talk.domain.vo.TalkAgentVo;
|
|
|
import org.dromara.talk.service.IDifyService;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
@@ -25,10 +28,10 @@ public class DifyServiceImpl implements IDifyService {
|
|
|
|
|
|
@Override
|
|
|
public void callWorkflowStream(String userMessage, String agentGender,
|
|
|
- java.util.List<java.util.Map<String, String>> ttsVcnList,
|
|
|
- org.dromara.talk.domain.vo.TalkAgentVo agentConfig,
|
|
|
+ List<Map<String, String>> ttsVcnList,
|
|
|
+ TalkAgentVo agentConfig,
|
|
|
Long userId, String conversationId, String customerPhone, String source,
|
|
|
- java.util.function.Consumer<String> onTextChunk,
|
|
|
+ Consumer<String> onTextChunk,
|
|
|
IDifyService.SentenceCallback onSentence) {
|
|
|
try {
|
|
|
log.info("流式调用 Dify 工作流 - userId: {}, conversationId: {}", userId, conversationId);
|