From 3f1ea1e3240f045412189619d7e4021d5f26a4f2 Mon Sep 17 00:00:00 2001
From: leutu <leutu@qq.com>
Date: 星期一, 24 六月 2024 14:14:17 +0800
Subject: [PATCH] apikey更新

---
 src/main/java/com/yb/util/OkHttpUtil.java         |   30 ++++++++++----
 src/main/java/com/yb/controller/AiController.java |   12 ++++-
 pom.xml                                           |   18 +++++++++
 src/main/java/com/yb/entity/ResponseEntity.java   |    9 ++++
 src/main/resources/application.yml                |    3 +
 5 files changed, 59 insertions(+), 13 deletions(-)

diff --git a/pom.xml b/pom.xml
index 8d85da5..a26600e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,6 +66,24 @@
             <artifactId>springdoc-openapi-starter-webmvc-api</artifactId>
             <version>2.1.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.26</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.26</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.26</version>
+            <scope>provided</scope>
+        </dependency>
 
 
     </dependencies>
diff --git a/src/main/java/com/yb/controller/AiController.java b/src/main/java/com/yb/controller/AiController.java
index dbd9b3b..8694787 100644
--- a/src/main/java/com/yb/controller/AiController.java
+++ b/src/main/java/com/yb/controller/AiController.java
@@ -3,6 +3,7 @@
 
 import com.alibaba.fastjson.JSON;
 import com.yb.util.OkHttpUtil;
+import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 
@@ -38,11 +39,13 @@
 
 
     @GetMapping("/chat")
+    @Operation(summary = "澶фā鍨嬪璇�")
     public String chat(@RequestParam(value = "message",defaultValue = "Hi") String message){
         return chatModel.call("璇风敤涓枃鍥炵瓟濡備笅闂,濡傛灉鏈夊湴鍚嶅嚭鐜帮紝鍥炲埌鍐呭鍖呮嫭缁忕含搴﹀苟浣跨敤json杩斿洖,"+message);
     }
 
     @GetMapping("/intent")
+    @Operation(summary = "鎰忓浘璇锋眰")
     public String intent(@RequestParam(value = "message",defaultValue = "Hi") String message){
         String json = okHttpUtil.getMessage(intent+"="+message);
         Map<String,String> hashMap = new HashMap<>() ;
@@ -67,6 +70,7 @@
     }
 
     @GetMapping("/mix")
+    @Operation(summary = "鎰忓浘涓庡ぇ妯″瀷璇锋眰")
     public String mix(@RequestParam(value = "message",defaultValue = "Hi") String message){
         String json = okHttpUtil.postFastgpt(message);
         System.out.println(message);
@@ -91,7 +95,8 @@
     }
 
     @GetMapping("/fastgpt")
-    public String fastgpt(@RequestParam(value = "message",defaultValue = "Hi") String message){
+    @Operation(summary = "鐭ヨ瘑搴撴煡璇�")
+    public String fastgpt(@RequestParam(value = "message",defaultValue = "涓夌淮瀹炴櫙") String message){
 
         okHttpUtil.requesFast(message);
         String json = okHttpUtil.requesFast(message);
@@ -100,10 +105,11 @@
     }
 
     @GetMapping("/fastgpt_list")
-    public String fastgpt_list(String parentId){
+    @Operation(summary = "鐭ヨ瘑搴撳垪琛�")
+    public String fastgpt_list(){
 
 
-        String json = okHttpUtil.requesFast_kl(parentId);
+        String json = okHttpUtil.requesFast_kl();
 
         return  json ;
     }
diff --git a/src/main/java/com/yb/entity/ResponseEntity.java b/src/main/java/com/yb/entity/ResponseEntity.java
new file mode 100644
index 0000000..39bb774
--- /dev/null
+++ b/src/main/java/com/yb/entity/ResponseEntity.java
@@ -0,0 +1,9 @@
+package com.yb.entity;
+
+import lombok.Data;
+
+@Data
+public class ResponseEntity {
+    private String[] eveent;
+    private String[] data ;
+}
diff --git a/src/main/java/com/yb/util/OkHttpUtil.java b/src/main/java/com/yb/util/OkHttpUtil.java
index 94d050e..fcdf3ee 100644
--- a/src/main/java/com/yb/util/OkHttpUtil.java
+++ b/src/main/java/com/yb/util/OkHttpUtil.java
@@ -1,6 +1,8 @@
 package com.yb.util;
 
 import com.alibaba.fastjson.JSON;
+import com.google.gson.Gson;
+import com.yb.entity.ResponseEntity;
 import okhttp3.*;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
@@ -79,11 +81,12 @@
     }
 
     public String requesFast(String message){
-        OkHttpClient client = new OkHttpClient();
+        System.out.println("fastgpt:"+message) ;
+       OkHttpClient client = new OkHttpClient();
         Response response = null ;
         // 鍒涘缓璇锋眰澶达紙Headers锛�
         okhttp3.Headers headers = new okhttp3.Headers.Builder()
-                .add("Authorization", "Bearer fastgpt-rML09d7nyx8Bn2Al3UipZia3Q8FNuXdekU1nyMlgCfHNwS8NN1giSPNZ1y6Wmt")
+                .add("Authorization", "Bearer "+apikey)
                 .build();
 
         /*
@@ -105,7 +108,7 @@
         // 鏋勫缓璇锋眰浣擄紙RequestBody锛夛紝杩欓噷浣跨敤鐨勬槸瀛楃涓茬被鍨嬬殑璇锋眰鏁版嵁
 
         HashMap<String,Object> hashMap = new HashMap<>() ;
-        hashMap.put("chatId",""+Math.random()*100000);
+        hashMap.put("chatId","1111");
         hashMap.put("stream","false");
         hashMap.put("detail","false");
         List<HashMap<String,String>> list = new ArrayList<>();
@@ -130,7 +133,15 @@
             if (response.isSuccessful()) {
                 //System.out.println("Success: " + response.body().string());
                 String rep = response.body().string();
-                return rep ;
+                if( rep.indexOf("flowResponses") > 0) {
+                    int index = rep.indexOf("flowResponses");
+                    int index_s = rep.indexOf("data", index);
+                    String data = rep.substring(index_s + 5);
+                    System.out.println(data);
+                    return data;
+                }else{
+                    return rep ;
+                }
             } else {
                 System.out.println("Error: " + response.code() + " " + response.message());
             }
@@ -139,15 +150,15 @@
         }
 
 
-         return response != null?response.body().toString():"null" ;
+         return null ;
     }
 
-    public String requesFast_kl(String parentId){
+    public String requesFast_kl(){
         OkHttpClient client = new OkHttpClient();
         Response response = null ;
         // 鍒涘缓璇锋眰澶达紙Headers锛�
         okhttp3.Headers headers = new okhttp3.Headers.Builder()
-                .add("Authorization", "Bearer fastgpt-rML09d7nyx8Bn2Al3UipZia3Q8FNuXdekU1nyMlgCfHNwS8NN1giSPNZ1y6Wmt")
+                .add("Authorization", "Bearer "+apikey)
                 .build();
 
         /*
@@ -159,7 +170,7 @@
 
 
         // 鍒涘缓璇锋眰锛圧equest锛�
-        if( parentId != null ) fastgpt_kl = fastgpt_kl+"锛焢arentId="+parentId;
+
         okhttp3.Request.Builder builder = new okhttp3.Request.Builder()
                 .url(fastgpt_kl)
                 .headers(headers) ;
@@ -171,7 +182,8 @@
             response = client.newCall(request).execute();
             if (response.isSuccessful()) {
                 //System.out.println("Success: " + response.body().string());
-                String rep = response.body().string();
+                String rep = response.body().toString();
+
                 return rep ;
             } else {
                 System.out.println("Error: " + response.code() + " " + response.message());
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 0247aeb..868a393 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -13,7 +13,8 @@
         model: qwen:1.8b
   intent: http://106.120.22.26:5367/intention?message
   fastgpt:
-    apikey: fastgpt-rML09d7nyx8Bn2Al3UipZia3Q8FNuXdekU1nyMlgCfHNwS8NN1giSPNZ1y6Wmt
+    appid:  6673bfa1d14da0cede023f28
+    apikey: fastgpt-dPcuRIABVdEdnQ5cGI1iL5uIIClxMZ4SYO79hrqs2OKXlh3IUU7jFF
     url: http://192.168.11.28/api/v1/chat/completions
     kc: http://192.168.11.28/api/core/dataset/create
     kl: http://192.168.11.28/api/core/dataset/list

--
Gitblit v1.9.3