修改

ai-api/src/main/java/api/controller/ai/AIController.java

@@ -7,10 +7,11 @@ import api.service.ai.AssistantsService;
 import api.service.ai.IZhiPuService;
 import api.service.ai.QiFanService;
 import api.service.ai.XingHuoService;
-import api.util.annotation.Log;
-import api.util.enums.BusinessType;
+import api.util.helper.HttpHelper;
+import api.util.helper.StringHelper;
 import com.alibaba.dashscope.exception.InputRequiredException;
 import com.alibaba.dashscope.exception.NoApiKeyException;
+import com.alibaba.fastjson2.JSON;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +24,9 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.Objects;
 
 
@@ -40,34 +43,27 @@ public class AIController extends BaseController {
     private QiFanService qiFanService;
     @Autowired
     private XingHuoService xingHuoService;
+
     @ApiOperation("智谱问答同步调用")
-    @Log(title = "智谱问答同步调用",businessType = BusinessType.QUERY)
     @GetMapping("/getInvoke")
-    public AjaxResult getInvoke (String question) {
+    public AjaxResult getInvoke(String question) {
         String result = zhiPuService.Invoke(question);
         return Success(result);
     }
+
     @ApiOperation("sse调用")
-    @Log(title = "sse调用",businessType = BusinessType.QUERY)
-    @PostMapping(value = "/getSseInvoke" ,produces = MediaType.TEXT_EVENT_STREAM_VALUE)
-    public  SseEmitter getSseInvoke(@RequestBody List<AIInput> Input,String type,
-                                    HttpServletRequest request, HttpServletResponse response)
+    @PostMapping(value = "/getSseInvoke", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter getSseInvoke(@RequestBody List<AIInput> Input, String type,
+                                   HttpServletRequest request, HttpServletResponse response)
             throws ServletException, IOException, NoApiKeyException, InputRequiredException, InterruptedException {
-        if (Objects.equals(type, "ZhiPu"))
-        {
-            return zhiPuService.sseInvoke(Input,request,response);
-        }
-        else if (Objects.equals(type, "TongYi"))
-        {
-            return   assistantsService.streamCallWithMessage(Input,request,response);
-        }
-        else if (Objects.equals(type, "QianFan"))
-        {
-            return  qiFanService.sseInvoke(Input,request,response);
-        }
-        else if (Objects.equals(type, "XingHuo"))
-        {
-            return  xingHuoService.sseInvoke(Input,response);
+        if (Objects.equals(type, "ZhiPu")) {
+            return zhiPuService.sseInvoke(Input, request, response);
+        } else if (Objects.equals(type, "TongYi")) {
+            return assistantsService.streamCallWithMessage(Input, request, response);
+        } else if (Objects.equals(type, "QianFan")) {
+            return qiFanService.sseInvoke(Input, request, response);
+        } else if (Objects.equals(type, "XingHuo")) {
+            return xingHuoService.sseInvoke(Input, response);
         }
         return null;
     }