pom.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/yb/controller/AiController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/yb/entity/ResponseEntity.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/yb/util/OkHttpUtil.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/resources/application.yml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
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> 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 ; } 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 ; } 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 @@ // å建请æ±ï¼Requestï¼ if( parentId != null ) fastgpt_kl = fastgpt_kl+"ï¼parentId="+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()); 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