) requestData.getOrDefault("inputs", new HashMap<>());
- // 从requestData中获取用户相关信息并添加到inputs中（如果存在且不为null）
- Object userId = requestData.get("user_id");
- if (userId != null) {
- inputs.put("user_id", userId.toString());
- }
+ inputs.put("user_id", currentUsername);
Object userName = requestData.get("user_name");
if (userName != null) {
@@ -192,7 +196,7 @@ public class AiChatController extends BaseController {
String jsonBody = mapper.writeValueAsString(bodyMap);
// 创建请求体对象
- RequestBody body = RequestBody.create( MediaType.get("application/json; charset=utf-8"),jsonBody);
+ RequestBody body = RequestBody.create(MediaType.get("application/json; charset=utf-8"), jsonBody);
// 构建HTTP请求
Request httpRequest = new Request.Builder()
@@ -370,10 +374,10 @@ public class AiChatController extends BaseController {
try {
// 参数校验和限制
int limitValue = Math.min(Math.max(Integer.parseInt(limit), 1), 100);
-
+
// 构建请求URL
String url = "http://47.112.118.149:8100/v1/app/feedbacks?page=" + page + "&limit=" + limitValue;
-
+
// 构建请求
Request request = new Request.Builder()
.url(url)
@@ -414,7 +418,7 @@ public class AiChatController extends BaseController {
userMap.put("email", userNode.has("email") ? userNode.get("email").asText() : null);
feedbackItem.put("from_end_user", userMap);
}
-
+
// 提取消息内容
if (feedbackNode.has("message")) {
JsonNode messageNode = feedbackNode.get("message");
@@ -425,7 +429,7 @@ public class AiChatController extends BaseController {
messageMap.put("created_at", messageNode.has("created_at") ? messageNode.get("created_at").asLong() : null);
feedbackItem.put("message", messageMap);
}
-
+
feedbackList.add(feedbackItem);
}
}
@@ -438,7 +442,7 @@ public class AiChatController extends BaseController {
if (errorBody != null) {
String errorBodyString = errorBody.string();
errorMsg += " - 响应体: " + errorBodyString;
-
+
// 尝试解析响应体中的错误信息
try {
JsonNode errorNode = mapper.readTree(errorBodyString);
@@ -460,39 +464,59 @@ public class AiChatController extends BaseController {
}
}
+/* @GetMapping("/history")
+ public AjaxResult getHistoryMessagesToAdmin(@RequestParam String user,
+ @RequestParam(required = false) String firstId,
+ @RequestParam(defaultValue = "20") int limit) {
+ //调用查询会话
+ String conversation_id = conversations(user);
+ }*/
+
/**
* 获取会话历史消息的端点
*
* 该方法接收客户端发送的请求，获取指定会话的历史消息记录。
*
+ *
+ * //@param conversation_id 会话ID
*
- * @param conversationId 会话ID
- * @param user 用户标识符
- * @param firstId 当前页第一条聊天记录的ID，默认null
- * @param limit 一次请求返回多少条记录，默认20条
+ * @param firstId 当前页第一条聊天记录的ID，默认null
+ * @param limit 一次请求返回多少条记录，默认20条
* @return AjaxResult 返回会话历史消息的结果
*/
@GetMapping("/history")
public AjaxResult getHistoryMessages(
- @RequestParam(required = false) String conversationId,
- @RequestParam String user,
+ //@RequestParam(required = false) String conversation_id,
@RequestParam(required = false) String firstId,
@RequestParam(defaultValue = "20") int limit) {
try {
+ /* // 获取当前用户
+ String currentUsername = SecurityUtils.getLoginUser().getUsername();
+ // 获取会话列表的id
+ String conversation_id = conversations(currentUsername);
+ if(conversation_id == null){
+ return error("没有会话");
+ }*/
+
+
// 验证conversationId是否为空
- if (conversationId == null || conversationId.trim().isEmpty()) {
- return error("会话ID不能为空");
- }
+ /*if (conversation_id == null || conversation_id.trim().isEmpty()) {
+ return error("会话ID不能为空后端");
+ }*/
+ String conversation_id = "8fb04ac4-ac9f-470b-9ac4-fee1ebec6412";
+ String currentUsername = SecurityUtils.getLoginUser().getUsername();
+ System.out.println(currentUsername);
+ System.out.println(conversation_id);
// 构建请求参数
HttpUrl.Builder urlBuilder = HttpUrl.parse(DIFY_API_HISTORY_URL).newBuilder();
- urlBuilder.addQueryParameter("conversation_id", conversationId);
- urlBuilder.addQueryParameter("user", user);
+ urlBuilder.addQueryParameter("conversation_id", conversation_id);
+ urlBuilder.addQueryParameter("user", currentUsername);
if (firstId != null) {
urlBuilder.addQueryParameter("first_id", firstId);
}
urlBuilder.addQueryParameter("limit", String.valueOf(limit));
-
+ System.out.println(currentUsername);
// 构建HTTP请求
Request request = new Request.Builder()
.url(urlBuilder.build())
@@ -537,14 +561,20 @@ public class AiChatController extends BaseController {
* @param sortBy 排序字段，默认 -updated_at (按更新时间倒序排列)
* @return AjaxResult 返回会话列表的结果
*/
- @GetMapping("/conversations")
- public AjaxResult getConversations(
+ /*@GetMapping("/getConversationsToUser")
+ public AjaxResult getConversationsToUser(
@RequestParam String user,
@RequestParam(required = false) String lastId,
@RequestParam(defaultValue = "20") int limit,
@RequestParam(defaultValue = "-updated_at") String sortBy) {
try {
- // 参数校验
+ // 获取当前用户
+ String currentUsername = SecurityUtils.getLoginUser().getUsername();
+ // 获取会话列表的id
+ String conversation_id = conversations(currentUsername);
+
+ return AjaxResult.success(conversation_id);*/
+ /*// 参数校验
if (user == null || user.trim().isEmpty()) {
return error("用户标识不能为空");
}
@@ -606,13 +636,216 @@ public class AiChatController extends BaseController {
result.put("data", data);
return success(result);
- }
- } catch (IOException e) {
+ }*/
+/* } catch (IOException e) {
return error("获取会话列表失败: " + e.getMessage());
}
+ }*/
+
+
+ // 权限标识为辅导员
+ @GetMapping("/getMessagesToAdmin")
+ public AjaxResult getMessagesToAdmin(@RequestParam String user,
+ @RequestParam(required = false) String lastId,
+ @RequestParam(defaultValue = "20") int limit,
+ @RequestParam(defaultValue = "-updated_at") String sortBy) {
+ try {
+ List conversations = getConversations(user);
+ if (conversations == null || conversations.isEmpty()) {
+ return AjaxResult.error("暂无会话记录");
+ }
+ String conversation_id = conversations.get(0).getId();
+ System.out.println(conversation_id);
+ return success(getConversationHistoryMessages(conversation_id, user, null, 20));
+ } catch (IOException e) {
+ return AjaxResult.error("网络请求失败，请稍后重试",error());
+ }
}
- /**
+ // 权限标识为学生
+ @GetMapping("/getMessagesToUser")
+ public AjaxResult getMessagesToUser(@RequestParam(required = false) String lastId,
+ @RequestParam(defaultValue = "20") int limit,
+ @RequestParam(defaultValue = "-updated_at") String sortBy) {
+ try {
+ String user = SecurityUtils.getLoginUser().getUsername();
+ List conversations = getConversations(user);
+ if (conversations == null || conversations.isEmpty()) {
+ return AjaxResult.error("暂无会话记录");
+ }
+ String conversation_id = conversations.get(0).getId();
+ return success(getConversationHistoryMessages(conversation_id, user, null, 20));
+ } catch (IOException e) {
+ return AjaxResult.error("网络请求失败，请稍后重试");
+ }
+ }
+
+
+ /*
+ * 获取会话列表
+ * */
+ public List getConversations(String user, String lastId, int limit, String sortBy) throws IOException {
+ // 构建带查询参数的 URL
+ HttpUrl.Builder urlBuilder = HttpUrl.parse(DIFY_CONVERSATIONS_URL).newBuilder();
+ urlBuilder.addQueryParameter("user", user);
+ if (lastId != null && !lastId.trim().isEmpty()) {
+ urlBuilder.addQueryParameter("last_id", lastId);
+ }
+ urlBuilder.addQueryParameter("limit", String.valueOf(limit));
+ urlBuilder.addQueryParameter("sort_by", sortBy);
+
+ // 构建请求
+ Request request = new Request.Builder()
+ .url(urlBuilder.build())
+ .addHeader("Authorization", "Bearer " + DIFY_API_KEY)
+ .get()
+ .build();
+
+ // 执行请求
+ try (Response response = client.newCall(request).execute()) {
+ if (!response.isSuccessful()) {
+ throw new IOException("Dify API 请求失败: " + response.code() + " " + response.message());
+ }
+
+ // 读取响应体
+ String responseBodyString = response.body().string();
+ JsonNode rootNode = mapper.readTree(responseBodyString);
+
+ // 提取 data 数组
+ JsonNode dataArray = rootNode.path("data");
+ List conversations = new ArrayList<>();
+
+ if (dataArray.isArray()) {
+ for (JsonNode node : dataArray) {
+ ConversationDTO dto = new ConversationDTO();
+ dto.setId(node.path("id").asText(null));
+ dto.setName(node.path("name").asText(null));
+ dto.setIntroduction(node.path("introduction").asText(null));
+
+ // 处理时间戳（假设接口返回的是 Unix 时间戳，单位：秒）
+ long createdAt = node.path("created_at").asLong(0L);
+ long updatedAt = node.path("updated_at").asLong(0L);
+
+ dto.setCreated_at(createdAt > 0 ? new Date(createdAt * 1000) : null);
+ dto.setUpdated_at(updatedAt > 0 ? new Date(updatedAt * 1000) : null);
+
+ conversations.add(dto);
+ }
+ }
+
+ return conversations;
+ }
+ }
+
+ public List getConversations(String user) throws IOException {
+ return getConversations(user, null, 0, null);
+ }
+
+ public List getConversations(String user, String lastId) throws IOException {
+ return getConversations(user, lastId, 0, null);
+ }
+
+ public List getConversations(String user, Integer limit, String sortBy) throws IOException {
+ return getConversations(user, null, limit, sortBy);
+ }
+
+
+ //获取历史消息
+ private Map getConversationHistoryMessages(
+ String conversationId,
+ String user,
+ String firstId,
+ Integer limit) throws ServiceException {
+
+ // 参数校验
+ if (conversationId == null || conversationId.trim().isEmpty()) {
+ throw new IllegalArgumentException("conversationId 不能为空");
+ }
+ if (user == null || user.trim().isEmpty()) {
+ throw new IllegalArgumentException("user 不能为空");
+ }
+
+ conversationId = conversationId.trim();
+ user = user.trim();
+ int finalLimit = limit != null && limit > 0 ? Math.min(limit, 100) : 20;
+
+ // 构建请求 URL
+ HttpUrl.Builder urlBuilder = HttpUrl.parse(DIFY_API_HISTORY_URL).newBuilder();
+ urlBuilder.addQueryParameter("conversation_id", conversationId);
+ urlBuilder.addQueryParameter("user", user);
+ if (firstId != null && !firstId.trim().isEmpty()) {
+ urlBuilder.addQueryParameter("first_id", firstId.trim());
+ }
+ urlBuilder.addQueryParameter("limit", String.valueOf(finalLimit));
+
+ Request request = new Request.Builder()
+ .url(urlBuilder.build())
+ .addHeader("Authorization", "Bearer " + DIFY_API_KEY)
+ .addHeader("Accept", "application/json")
+ .get()
+ .build();
+
+ try (Response response = client.newCall(request).execute()) {
+
+ if (!response.isSuccessful()) {
+ String body = response.body() != null ? response.body().string() : "No body";
+ String msg = String.format("HTTP %d %s - %s", response.code(), response.message(), body);
+ throw new ServiceException("请求失败");
+ }
+
+ ResponseBody responseBody = response.body();
+ if (responseBody == null) {
+ return emptyResult(finalLimit);
+ }
+
+ String responseBodyString = responseBody.string();
+ JsonNode rootNode;
+ try {
+ rootNode = mapper.readTree(responseBodyString);
+ } catch (JsonProcessingException e) {
+ throw new ServiceException("响应数据格式错误");
+ }
+
+ // 提取 data 数组
+ List> data = new ArrayList<>();
+ JsonNode dataArray = rootNode.get("data");
+ if (dataArray != null && dataArray.isArray()) {
+ data = mapper.convertValue(dataArray, new TypeReference>>() {
+ });
+ }
+
+ // 提取 has_more
+ boolean hasMore = rootNode.path("has_more").asBoolean(false);
+
+ // ✅ 直接构建前端需要的返回结构
+ Map result = new HashMap<>();
+ result.put("data", data);
+ result.put("has_more", hasMore);
+ result.put("limit", finalLimit);
+
+ return result; // 直接返回，调用方直接丢给前端
+
+ } catch (IOException e) {
+ throw new ServiceException("网络请求失败: " + e.getMessage());
+ }
+ }
+
+ // 辅助方法：返回空结果
+ private Map emptyResult(int limit) {
+ Map result = new HashMap<>();
+ result.put("data", new ArrayList<>());
+ result.put("has_more", false);
+ result.put("limit", limit);
+ return result;
+ }
+
+
+
+
+
+
+ /*
+ *//**
* 文件上传接口
*
* 上传文件并在发送消息时使用，可实现图文多模态理解。支持应用程序所支持的所有格式。
@@ -622,7 +855,7 @@ public class AiChatController extends BaseController {
* @param file 要上传的文件
* @param user 用户标识，用于定义终端用户的身份
* @return 包含文件信息的统一响应结果
- */
+ *//*
@PostMapping("/files/upload")
public AjaxResult uploadFile(@RequestParam("file") MultipartFile file,
@RequestParam("user") String user) {
@@ -670,5 +903,5 @@ public class AiChatController extends BaseController {
} catch (Exception e) {
return AjaxResult.error("文件上传异常: " + e.getMessage());
}
- }
+ }*/
}
diff --git a/srs-teacher/src/main/java/com/srs/teacher/domain/dto/ConversationDTO.java b/srs-teacher/src/main/java/com/srs/teacher/domain/dto/ConversationDTO.java
new file mode 100644
index 0000000..a741143
--- /dev/null
+++ b/srs-teacher/src/main/java/com/srs/teacher/domain/dto/ConversationDTO.java
@@ -0,0 +1,53 @@
+package com.srs.teacher.domain.dto;
+
+import java.util.Date;
+
+public class ConversationDTO {
+ private String id; // 会话 ID
+ private String name; // 会话名称，默认由大语言模型生成。
+ private String introduction; // 开场白
+ private Date created_at; // 创建时间
+ private Date updated_at; // 更新时间
+
+ // Getters and Setters for the properties
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public String getIntroduction() {
+ return introduction;
+ }
+
+ public void setIntroduction(String introduction) {
+ this.introduction = introduction;
+ }
+
+ public Date getCreated_at() {
+ return created_at;
+ }
+
+ public void setCreated_at(Date created_at) {
+ this.created_at = created_at;
+ }
+
+ public Date getUpdated_at() {
+ return updated_at;
+ }
+
+ public void setUpdated_at(Date updated_at) {
+ this.updated_at = updated_at;
+ }
+}
+
From eedfa17d182feb01b1b33c77dd2063a544d81ad2 Mon Sep 17 00:00:00 2001
From: firefly <1633489380@qq.com>
Date: Tue, 12 Aug 2025 17:38:53 +0800
Subject: [PATCH 6/9] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=BA=86=E4=B8=80?=
=?UTF-8?q?=E4=BA=9B=E6=8A=A5=E9=94=99=E4=BF=A1=E6=81=AF=E7=9A=84=E6=89=93?=
=?UTF-8?q?=E5=8D=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../controller/aitutor/AiChatController.java | 279 ++++++------------
1 file changed, 88 insertions(+), 191 deletions(-)
diff --git a/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java b/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
index 917e8fa..4f9b5f4 100644
--- a/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
+++ b/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
@@ -7,7 +7,6 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import com.srs.common.core.controller.BaseController;
// OkHttp 显式导入
-import com.srs.common.core.domain.model.LoginUser;
import com.srs.common.exception.ServiceException;
import com.srs.common.utils.SecurityUtils;
import com.srs.teacher.domain.dto.ConversationDTO;
@@ -18,14 +17,13 @@ import com.srs.common.core.domain.AjaxResult; // ✅ RuoYi 的返回结果类
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
+import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
import java.io.BufferedReader;
import java.io.IOException;
-import java.net.SocketTimeoutException;
import java.time.Duration;
import java.util.*;
import java.util.concurrent.CompletableFuture;
@@ -464,201 +462,46 @@ public class AiChatController extends BaseController {
}
}
-/* @GetMapping("/history")
- public AjaxResult getHistoryMessagesToAdmin(@RequestParam String user,
- @RequestParam(required = false) String firstId,
- @RequestParam(defaultValue = "20") int limit) {
- //调用查询会话
- String conversation_id = conversations(user);
- }*/
-
- /**
- * 获取会话历史消息的端点
- *
- * 该方法接收客户端发送的请求，获取指定会话的历史消息记录。
- *
- *
- * //@param conversation_id 会话ID
- *
- * @param firstId 当前页第一条聊天记录的ID，默认null
- * @param limit 一次请求返回多少条记录，默认20条
- * @return AjaxResult 返回会话历史消息的结果
- */
- @GetMapping("/history")
- public AjaxResult getHistoryMessages(
- //@RequestParam(required = false) String conversation_id,
- @RequestParam(required = false) String firstId,
- @RequestParam(defaultValue = "20") int limit) {
- try {
- /* // 获取当前用户
- String currentUsername = SecurityUtils.getLoginUser().getUsername();
- // 获取会话列表的id
- String conversation_id = conversations(currentUsername);
- if(conversation_id == null){
- return error("没有会话");
- }*/
-
-
- // 验证conversationId是否为空
- /*if (conversation_id == null || conversation_id.trim().isEmpty()) {
- return error("会话ID不能为空后端");
- }*/
- String conversation_id = "8fb04ac4-ac9f-470b-9ac4-fee1ebec6412";
- String currentUsername = SecurityUtils.getLoginUser().getUsername();
- System.out.println(currentUsername);
- System.out.println(conversation_id);
-
- // 构建请求参数
- HttpUrl.Builder urlBuilder = HttpUrl.parse(DIFY_API_HISTORY_URL).newBuilder();
- urlBuilder.addQueryParameter("conversation_id", conversation_id);
- urlBuilder.addQueryParameter("user", currentUsername);
- if (firstId != null) {
- urlBuilder.addQueryParameter("first_id", firstId);
- }
- urlBuilder.addQueryParameter("limit", String.valueOf(limit));
- System.out.println(currentUsername);
- // 构建HTTP请求
- Request request = new Request.Builder()
- .url(urlBuilder.build())
- .addHeader("Authorization", "Bearer " + DIFY_API_KEY)
- .get()
- .build();
-
- // 执行HTTP请求
- try (Response response = client.newCall(request).execute()) {
- // 检查响应是否成功
- if (!response.isSuccessful()) {
- return error("Dify 请求失败: " + response.code() + " " + response.message());
- }
-
- // 解析JSON响应
- JsonNode rootNode = mapper.readTree(response.body().string());
- boolean hasMore = rootNode.path("has_more").asBoolean(false);
- List> data = mapper.convertValue(rootNode.path("data"), List.class);
-
- // 构建返回结果
- Map result = new HashMap<>();
- result.put("limit", limit);
- result.put("has_more", hasMore);
- result.put("data", data);
-
- return success(result);
- }
- } catch (IOException e) {
- return error("获取会话历史消息失败: " + e.getMessage());
- }
- }
-
- /**
- * 获取会话列表
- *
- * 该方法用于获取当前用户的会话列表，默认返回最近的 20 条。
- *
- *
- * @param user 用户标识符，由开发者定义规则，需保证用户标识在应用内唯一
- * @param lastId 当前页最后一条记录的 ID，默认 null
- * @param limit 一次请求返回多少条记录，默认 20 条，最大 100 条，最小 1 条
- * @param sortBy 排序字段，默认 -updated_at (按更新时间倒序排列)
- * @return AjaxResult 返回会话列表的结果
- */
- /*@GetMapping("/getConversationsToUser")
- public AjaxResult getConversationsToUser(
- @RequestParam String user,
- @RequestParam(required = false) String lastId,
- @RequestParam(defaultValue = "20") int limit,
- @RequestParam(defaultValue = "-updated_at") String sortBy) {
- try {
- // 获取当前用户
- String currentUsername = SecurityUtils.getLoginUser().getUsername();
- // 获取会话列表的id
- String conversation_id = conversations(currentUsername);
-
- return AjaxResult.success(conversation_id);*/
- /*// 参数校验
- if (user == null || user.trim().isEmpty()) {
- return error("用户标识不能为空");
- }
-
- // 限制limit的范围在1-100之间
- if (limit < 1 || limit > 100) {
- return error("limit参数必须在1到100之间");
- }
-
- // 构建请求参数
- HttpUrl.Builder urlBuilder = HttpUrl.parse(DIFY_CONVERSATIONS_URL).newBuilder();
- urlBuilder.addQueryParameter("user", user);
- if (lastId != null) {
- urlBuilder.addQueryParameter("last_id", lastId);
- }
- urlBuilder.addQueryParameter("limit", String.valueOf(limit));
- urlBuilder.addQueryParameter("sort_by", sortBy);
-
- // 构建HTTP请求
- Request request = new Request.Builder()
- .url(urlBuilder.build())
- .addHeader("Authorization", "Bearer " + DIFY_API_KEY)
- .get()
- .build();
-
- // 执行HTTP请求
- try (Response response = client.newCall(request).execute()) {
- // 检查响应是否成功
- if (!response.isSuccessful()) {
- return error("Dify 请求失败: " + response.code() + " " + response.message());
- }
-
- // 解析JSON响应
- JsonNode rootNode = mapper.readTree(response.body().string());
- int resLimit = rootNode.path("limit").asInt();
- boolean hasMore = rootNode.path("has_more").asBoolean(false);
- List> data = new ArrayList<>();
-
- // 解析会话列表数据
- JsonNode dataArray = rootNode.path("data");
- if (dataArray.isArray()) {
- for (JsonNode conversationNode : dataArray) {
- Map conversation = new HashMap<>();
- conversation.put("id", conversationNode.path("id").asText());
- conversation.put("name", conversationNode.path("name").asText());
- conversation.put("inputs", mapper.convertValue(conversationNode.path("inputs"), Map.class));
- conversation.put("status", conversationNode.path("status").asText());
- conversation.put("introduction", conversationNode.path("introduction").asText());
- conversation.put("created_at", conversationNode.path("created_at").asLong());
- conversation.put("updated_at", conversationNode.path("updated_at").asLong());
- data.add(conversation);
- }
- }
-
- // 构建返回结果
- Map result = new HashMap<>();
- result.put("limit", resLimit);
- result.put("has_more", hasMore);
- result.put("data", data);
-
- return success(result);
- }*/
-/* } catch (IOException e) {
- return error("获取会话列表失败: " + e.getMessage());
- }
- }*/
-
-
// 权限标识为辅导员
@GetMapping("/getMessagesToAdmin")
public AjaxResult getMessagesToAdmin(@RequestParam String user,
@RequestParam(required = false) String lastId,
@RequestParam(defaultValue = "20") int limit,
@RequestParam(defaultValue = "-updated_at") String sortBy) {
+ System.out.println("进入getMessagesToAdmin方法");
+ System.out.println("参数 user: " + user);
+ System.out.println("参数 lastId: " + lastId);
+ System.out.println("参数 limit: " + limit);
+ System.out.println("参数 sortBy: " + sortBy);
+
try {
+ System.out.println("开始调用getConversations方法");
List conversations = getConversations(user);
+ System.out.println("getConversations方法调用完成，结果: " + (conversations != null ? conversations.size() : "null"));
+
if (conversations == null || conversations.isEmpty()) {
+ System.out.println("会话列表为空");
return AjaxResult.error("暂无会话记录");
}
+
String conversation_id = conversations.get(0).getId();
- System.out.println(conversation_id);
- return success(getConversationHistoryMessages(conversation_id, user, null, 20));
+ System.out.println("获取到的会话ID: " + conversation_id);
+
+ System.out.println("开始调用getConversationHistoryMessages方法");
+ Map result = getConversationHistoryMessages(conversation_id, user, null, 20);
+ System.out.println("getConversationHistoryMessages方法调用完成");
+
+ AjaxResult successResult = success(result);
+ System.out.println("返回成功结果");
+ return successResult;
} catch (IOException e) {
- return AjaxResult.error("网络请求失败，请稍后重试",error());
+ System.out.println("捕获到IOException: " + e.getMessage());
+ e.printStackTrace();
+ return AjaxResult.error("网络请求失败，请稍后重试");
+ } catch (Exception e) {
+ System.out.println("捕获到其他异常: " + e.getMessage());
+ e.printStackTrace();
+ return AjaxResult.error("请求处理失败: " + e.getMessage());
}
}
@@ -667,16 +510,43 @@ public class AiChatController extends BaseController {
public AjaxResult getMessagesToUser(@RequestParam(required = false) String lastId,
@RequestParam(defaultValue = "20") int limit,
@RequestParam(defaultValue = "-updated_at") String sortBy) {
+ System.out.println("进入getMessagesToUser方法");
+ System.out.println("参数 lastId: " + lastId);
+ System.out.println("参数 limit: " + limit);
+ System.out.println("参数 sortBy: " + sortBy);
+
try {
+ System.out.println("开始获取当前登录用户");
String user = SecurityUtils.getLoginUser().getUsername();
+ System.out.println("当前登录用户: " + user);
+
+ System.out.println("开始调用getConversations方法");
List conversations = getConversations(user);
+ System.out.println("getConversations方法调用完成，结果: " + (conversations != null ? conversations.size() : "null"));
+
if (conversations == null || conversations.isEmpty()) {
+ System.out.println("会话列表为空");
return AjaxResult.error("暂无会话记录");
}
+
String conversation_id = conversations.get(0).getId();
- return success(getConversationHistoryMessages(conversation_id, user, null, 20));
+ System.out.println("获取到的会话ID: " + conversation_id);
+
+ System.out.println("开始调用getConversationHistoryMessages方法");
+ Map result = getConversationHistoryMessages(conversation_id, user, null, 20);
+ System.out.println("getConversationHistoryMessages方法调用完成");
+
+ AjaxResult successResult = success(result);
+ System.out.println("返回成功结果");
+ return successResult;
} catch (IOException e) {
+ System.out.println("捕获到IOException: " + e.getMessage());
+ e.printStackTrace();
return AjaxResult.error("网络请求失败，请稍后重试");
+ } catch (Exception e) {
+ System.out.println("捕获到其他异常: " + e.getMessage());
+ e.printStackTrace();
+ return AjaxResult.error("请求处理失败: " + e.getMessage());
}
}
@@ -701,14 +571,19 @@ public class AiChatController extends BaseController {
.get()
.build();
+ System.out.println("准备发送HTTP请求到: " + urlBuilder.build().toString());
+
// 执行请求
try (Response response = client.newCall(request).execute()) {
+ System.out.println("收到HTTP响应，状态码: " + response.code());
if (!response.isSuccessful()) {
+ System.out.println("HTTP请求失败: " + response.code() + " " + response.message());
throw new IOException("Dify API 请求失败: " + response.code() + " " + response.message());
}
// 读取响应体
String responseBodyString = response.body().string();
+ System.out.println("响应体内容: " + responseBodyString);
JsonNode rootNode = mapper.readTree(responseBodyString);
// 提取 data 数组
@@ -716,6 +591,7 @@ public class AiChatController extends BaseController {
List conversations = new ArrayList<>();
if (dataArray.isArray()) {
+ System.out.println("解析到 " + dataArray.size() + " 个会话");
for (JsonNode node : dataArray) {
ConversationDTO dto = new ConversationDTO();
dto.setId(node.path("id").asText(null));
@@ -733,12 +609,14 @@ public class AiChatController extends BaseController {
}
}
+ System.out.println("getConversations方法执行完成，返回 " + conversations.size() + " 个会话");
+
return conversations;
}
}
public List getConversations(String user) throws IOException {
- return getConversations(user, null, 0, null);
+ return getConversations(user, null, 1, "-updated_at");
}
public List getConversations(String user, String lastId) throws IOException {
@@ -757,11 +635,19 @@ public class AiChatController extends BaseController {
String firstId,
Integer limit) throws ServiceException {
+ System.out.println("进入getConversationHistoryMessages方法");
+ System.out.println("参数 conversationId: " + conversationId);
+ System.out.println("参数 user: " + user);
+ System.out.println("参数 firstId: " + firstId);
+ System.out.println("参数 limit: " + limit);
+
// 参数校验
if (conversationId == null || conversationId.trim().isEmpty()) {
+ System.out.println("conversationId 参数为空");
throw new IllegalArgumentException("conversationId 不能为空");
}
if (user == null || user.trim().isEmpty()) {
+ System.out.println("user 参数为空");
throw new IllegalArgumentException("user 不能为空");
}
@@ -785,24 +671,31 @@ public class AiChatController extends BaseController {
.get()
.build();
+ System.out.println("准备发送HTTP请求到: " + urlBuilder.build().toString());
+
try (Response response = client.newCall(request).execute()) {
+ System.out.println("收到HTTP响应，状态码: " + response.code());
if (!response.isSuccessful()) {
String body = response.body() != null ? response.body().string() : "No body";
+ System.out.println("HTTP请求失败，响应体: " + body);
String msg = String.format("HTTP %d %s - %s", response.code(), response.message(), body);
throw new ServiceException("请求失败");
}
ResponseBody responseBody = response.body();
if (responseBody == null) {
+ System.out.println("响应体为空");
return emptyResult(finalLimit);
}
String responseBodyString = responseBody.string();
+ System.out.println("响应体内容: " + responseBodyString);
JsonNode rootNode;
try {
rootNode = mapper.readTree(responseBodyString);
} catch (JsonProcessingException e) {
+ System.out.println("响应数据格式错误: " + e.getMessage());
throw new ServiceException("响应数据格式错误");
}
@@ -810,12 +703,14 @@ public class AiChatController extends BaseController {
List> data = new ArrayList<>();
JsonNode dataArray = rootNode.get("data");
if (dataArray != null && dataArray.isArray()) {
+ System.out.println("解析到 " + dataArray.size() + " 条消息");
data = mapper.convertValue(dataArray, new TypeReference>>() {
});
}
// 提取 has_more
boolean hasMore = rootNode.path("has_more").asBoolean(false);
+ System.out.println("has_more: " + hasMore);
// ✅ 直接构建前端需要的返回结构
Map result = new HashMap<>();
@@ -823,9 +718,12 @@ public class AiChatController extends BaseController {
result.put("has_more", hasMore);
result.put("limit", finalLimit);
+ System.out.println("getConversationHistoryMessages方法执行完成");
+
return result; // 直接返回，调用方直接丢给前端
} catch (IOException e) {
+ System.out.println("网络请求失败: " + e.getMessage());
throw new ServiceException("网络请求失败: " + e.getMessage());
}
}
@@ -844,8 +742,7 @@ public class AiChatController extends BaseController {
- /*
- *//**
+ /**
* 文件上传接口
*
* 上传文件并在发送消息时使用，可实现图文多模态理解。支持应用程序所支持的所有格式。
@@ -855,7 +752,7 @@ public class AiChatController extends BaseController {
* @param file 要上传的文件
* @param user 用户标识，用于定义终端用户的身份
* @return 包含文件信息的统一响应结果
- *//*
+ */
@PostMapping("/files/upload")
public AjaxResult uploadFile(@RequestParam("file") MultipartFile file,
@RequestParam("user") String user) {
@@ -903,5 +800,5 @@ public class AiChatController extends BaseController {
} catch (Exception e) {
return AjaxResult.error("文件上传异常: " + e.getMessage());
}
- }*/
+ }
}
From 06976f5ef0087a7fa9a3e3e14f04d5b6e140a140 Mon Sep 17 00:00:00 2001
From: firefly <1633489380@qq.com>
Date: Wed, 13 Aug 2025 16:50:43 +0800
Subject: [PATCH 7/9] =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E4=BA=86=E4=B8=80?=
=?UTF-8?q?=E4=B8=AA=E5=AD=A6=E5=8F=B7=E5=AF=B9=E5=BA=94=E4=B8=80=E6=9D=A1?=
=?UTF-8?q?=E5=AF=B9=E8=AF=9Did?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../controller/aitutor/AiChatController.java | 87 +++++--------------
1 file changed, 20 insertions(+), 67 deletions(-)
diff --git a/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java b/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
index 4f9b5f4..a040f79 100644
--- a/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
+++ b/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
@@ -160,8 +160,21 @@ public class AiChatController extends BaseController {
bodyMap.put("user", currentUsername); // 用户标识
bodyMap.put("response_mode", "streaming"); // 设置为流式响应模式
- // 如果存在对话ID，则添加到请求参数中
- if (requestData.containsKey("conversation_id")) {
+ // 如果请求中没有提供conversation_id，则尝试获取或创建一个
+ if (!requestData.containsKey("conversation_id") || requestData.get("conversation_id") == null) {
+ try {
+ List conversations = getConversations(currentUsername, null, 1, "-updated_at");
+ if (conversations != null && !conversations.isEmpty()) {
+ // 使用已有的会话ID
+ bodyMap.put("conversation_id", conversations.get(0).getId());
+ }
+ // 如果没有会话，Dify会自动创建一个新的会话
+ } catch (Exception e) {
+ System.out.println("获取用户会话时出错: " + e.getMessage());
+ // 继续执行，让Dify自动创建新会话
+ }
+ } else {
+ // 如果存在对话ID，则添加到请求参数中
bodyMap.put("conversation_id", requestData.get("conversation_id"));
}
@@ -465,41 +478,26 @@ public class AiChatController extends BaseController {
// 权限标识为辅导员
@GetMapping("/getMessagesToAdmin")
public AjaxResult getMessagesToAdmin(@RequestParam String user,
- @RequestParam(required = false) String lastId,
+ @RequestParam(required = false) String firstId,
@RequestParam(defaultValue = "20") int limit,
@RequestParam(defaultValue = "-updated_at") String sortBy) {
- System.out.println("进入getMessagesToAdmin方法");
- System.out.println("参数 user: " + user);
- System.out.println("参数 lastId: " + lastId);
- System.out.println("参数 limit: " + limit);
- System.out.println("参数 sortBy: " + sortBy);
try {
- System.out.println("开始调用getConversations方法");
List conversations = getConversations(user);
- System.out.println("getConversations方法调用完成，结果: " + (conversations != null ? conversations.size() : "null"));
if (conversations == null || conversations.isEmpty()) {
- System.out.println("会话列表为空");
return AjaxResult.error("暂无会话记录");
}
String conversation_id = conversations.get(0).getId();
- System.out.println("获取到的会话ID: " + conversation_id);
-
- System.out.println("开始调用getConversationHistoryMessages方法");
- Map result = getConversationHistoryMessages(conversation_id, user, null, 20);
- System.out.println("getConversationHistoryMessages方法调用完成");
+ Map result = getConversationHistoryMessages(conversation_id, user, firstId, limit);
AjaxResult successResult = success(result);
- System.out.println("返回成功结果");
return successResult;
} catch (IOException e) {
- System.out.println("捕获到IOException: " + e.getMessage());
e.printStackTrace();
return AjaxResult.error("网络请求失败，请稍后重试");
} catch (Exception e) {
- System.out.println("捕获到其他异常: " + e.getMessage());
e.printStackTrace();
return AjaxResult.error("请求处理失败: " + e.getMessage());
}
@@ -507,44 +505,27 @@ public class AiChatController extends BaseController {
// 权限标识为学生
@GetMapping("/getMessagesToUser")
- public AjaxResult getMessagesToUser(@RequestParam(required = false) String lastId,
+ public AjaxResult getMessagesToUser(@RequestParam(required = false) String firstId,
@RequestParam(defaultValue = "20") int limit,
@RequestParam(defaultValue = "-updated_at") String sortBy) {
- System.out.println("进入getMessagesToUser方法");
- System.out.println("参数 lastId: " + lastId);
- System.out.println("参数 limit: " + limit);
- System.out.println("参数 sortBy: " + sortBy);
try {
- System.out.println("开始获取当前登录用户");
String user = SecurityUtils.getLoginUser().getUsername();
- System.out.println("当前登录用户: " + user);
-
- System.out.println("开始调用getConversations方法");
List conversations = getConversations(user);
- System.out.println("getConversations方法调用完成，结果: " + (conversations != null ? conversations.size() : "null"));
if (conversations == null || conversations.isEmpty()) {
- System.out.println("会话列表为空");
return AjaxResult.error("暂无会话记录");
}
String conversation_id = conversations.get(0).getId();
- System.out.println("获取到的会话ID: " + conversation_id);
-
- System.out.println("开始调用getConversationHistoryMessages方法");
- Map result = getConversationHistoryMessages(conversation_id, user, null, 20);
- System.out.println("getConversationHistoryMessages方法调用完成");
+ Map result = getConversationHistoryMessages(conversation_id, user, firstId, limit);
AjaxResult successResult = success(result);
- System.out.println("返回成功结果");
return successResult;
} catch (IOException e) {
- System.out.println("捕获到IOException: " + e.getMessage());
e.printStackTrace();
return AjaxResult.error("网络请求失败，请稍后重试");
} catch (Exception e) {
- System.out.println("捕获到其他异常: " + e.getMessage());
e.printStackTrace();
return AjaxResult.error("请求处理失败: " + e.getMessage());
}
@@ -571,19 +552,15 @@ public class AiChatController extends BaseController {
.get()
.build();
- System.out.println("准备发送HTTP请求到: " + urlBuilder.build().toString());
-
// 执行请求
try (Response response = client.newCall(request).execute()) {
- System.out.println("收到HTTP响应，状态码: " + response.code());
if (!response.isSuccessful()) {
- System.out.println("HTTP请求失败: " + response.code() + " " + response.message());
throw new IOException("Dify API 请求失败: " + response.code() + " " + response.message());
}
// 读取响应体
String responseBodyString = response.body().string();
- System.out.println("响应体内容: " + responseBodyString);
+ System.out.println("Raw Response: " + responseBodyString); // 打印原始数据
JsonNode rootNode = mapper.readTree(responseBodyString);
// 提取 data 数组
@@ -591,7 +568,6 @@ public class AiChatController extends BaseController {
List conversations = new ArrayList<>();
if (dataArray.isArray()) {
- System.out.println("解析到 " + dataArray.size() + " 个会话");
for (JsonNode node : dataArray) {
ConversationDTO dto = new ConversationDTO();
dto.setId(node.path("id").asText(null));
@@ -609,8 +585,6 @@ public class AiChatController extends BaseController {
}
}
- System.out.println("getConversations方法执行完成，返回 " + conversations.size() + " 个会话");
-
return conversations;
}
}
@@ -635,19 +609,11 @@ public class AiChatController extends BaseController {
String firstId,
Integer limit) throws ServiceException {
- System.out.println("进入getConversationHistoryMessages方法");
- System.out.println("参数 conversationId: " + conversationId);
- System.out.println("参数 user: " + user);
- System.out.println("参数 firstId: " + firstId);
- System.out.println("参数 limit: " + limit);
-
// 参数校验
if (conversationId == null || conversationId.trim().isEmpty()) {
- System.out.println("conversationId 参数为空");
throw new IllegalArgumentException("conversationId 不能为空");
}
if (user == null || user.trim().isEmpty()) {
- System.out.println("user 参数为空");
throw new IllegalArgumentException("user 不能为空");
}
@@ -671,31 +637,24 @@ public class AiChatController extends BaseController {
.get()
.build();
- System.out.println("准备发送HTTP请求到: " + urlBuilder.build().toString());
-
try (Response response = client.newCall(request).execute()) {
- System.out.println("收到HTTP响应，状态码: " + response.code());
if (!response.isSuccessful()) {
String body = response.body() != null ? response.body().string() : "No body";
- System.out.println("HTTP请求失败，响应体: " + body);
String msg = String.format("HTTP %d %s - %s", response.code(), response.message(), body);
throw new ServiceException("请求失败");
}
ResponseBody responseBody = response.body();
if (responseBody == null) {
- System.out.println("响应体为空");
return emptyResult(finalLimit);
}
String responseBodyString = responseBody.string();
- System.out.println("响应体内容: " + responseBodyString);
JsonNode rootNode;
try {
rootNode = mapper.readTree(responseBodyString);
} catch (JsonProcessingException e) {
- System.out.println("响应数据格式错误: " + e.getMessage());
throw new ServiceException("响应数据格式错误");
}
@@ -703,27 +662,21 @@ public class AiChatController extends BaseController {
List> data = new ArrayList<>();
JsonNode dataArray = rootNode.get("data");
if (dataArray != null && dataArray.isArray()) {
- System.out.println("解析到 " + dataArray.size() + " 条消息");
data = mapper.convertValue(dataArray, new TypeReference>>() {
});
}
// 提取 has_more
boolean hasMore = rootNode.path("has_more").asBoolean(false);
- System.out.println("has_more: " + hasMore);
// ✅ 直接构建前端需要的返回结构
Map result = new HashMap<>();
result.put("data", data);
result.put("has_more", hasMore);
result.put("limit", finalLimit);
-
- System.out.println("getConversationHistoryMessages方法执行完成");
-
return result; // 直接返回，调用方直接丢给前端
} catch (IOException e) {
- System.out.println("网络请求失败: " + e.getMessage());
throw new ServiceException("网络请求失败: " + e.getMessage());
}
}
From 68fb516019b6167ba1f32781c015c5e3b0ddd7c9 Mon Sep 17 00:00:00 2001
From: firefly <1633489380@qq.com>
Date: Thu, 14 Aug 2025 11:28:19 +0800
Subject: [PATCH 8/9] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BA=86=E9=83=A8?=
=?UTF-8?q?=E5=88=86=E4=BB=A3=E7=A0=81=E7=BB=93=E6=9E=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../controller/aitutor/AiChatController.java | 92 ++++++++-----------
1 file changed, 39 insertions(+), 53 deletions(-)
diff --git a/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java b/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
index a040f79..5f5ea23 100644
--- a/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
+++ b/srs-admin/src/main/java/com/srs/web/controller/aitutor/AiChatController.java
@@ -16,6 +16,7 @@ import okhttp3.*;
import com.srs.common.core.domain.AjaxResult; // ✅ RuoYi 的返回结果类
import okhttp3.RequestBody;
import okhttp3.ResponseBody;
+import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
@@ -38,41 +39,49 @@ import java.util.concurrent.CompletableFuture;
@RestController
@RequestMapping("/aitutor/aichat")
public class AiChatController extends BaseController {
- /**
- * Dify API的URL地址
- * 用于发送聊天消息请求到Dify服务
- */
-
- private static final String DIFY_API_URL = "http://47.112.118.149:8100/v1/chat-messages";
- //private static final String DIFY_API_URL = "http://localhost:8080/v1/chat-messages";
-
- /**
- * Dify反馈API的基础URL
- * 用于提交消息反馈（点赞、点踩等）
- */
- private static final String DIFY_FEEDBACK_BASE_URL = "http://47.112.118.149:8100/v1/messages";
- //private static final String DIFY_FEEDBACK_BASE_URL = "http://localhost:8080/v1/messages";
-
- private static final String DIFY_API_HISTORY_URL = "http://47.112.118.149:8100/v1/messages";
- //private static final String DIFY_API_HISTORY_URL = "http://localhost:8080/v1/messages";
-
- /**
- * Dify会话API的基础URL
- * 用于获取会话列表
- */
- private static final String DIFY_CONVERSATIONS_URL = "http://47.112.118.149:8100/v1/conversations";
- //private static final String DIFY_CONVERSATIONS_URL = "http://localhost:8080/v1/conversations";
-
- //文件上传
- private static final String DIFY_FILES_URL = "http://47.112.118.149:8100/v1/files/upload";
/**
* Dify API的访问密钥
* 用于身份验证，授权访问Dify服务
*/
private static final String DIFY_API_KEY = "app-2wjqcYI9n6igHTVHdH8qXlnh";
- //private static final String DIFY_API_KEY = "app-";
+ /**
+ * Dify API的URL地址
+ * 用于发送聊天消息请求到Dify服务
+ */
+
+ private static final String DIFY_API_URL = "http://47.112.118.149:8100/v1/chat-messages";
+
+ /**
+ * Dify反馈API的基础URL
+ * 用于提交消息反馈（点赞、点踩等）
+ */
+ private static final String DIFY_FEEDBACK_BASE_URL = "http://47.112.118.149:8100/v1/messages";
+
+ /**
+ * Dify获取反馈API的基础URL
+ * 用于获取消息反馈（点赞、点踩等）
+ */
+ private static final String DIFY_API_FEEDBACK_URL = "http://47.112.118.149:8100/v1/app/feedbacks?page=";
+
+ /**
+ * Dify消息历史记录API的基础URL
+ * 用于获取消息历史记录
+ */
+ private static final String DIFY_API_HISTORY_URL = "http://47.112.118.149:8100/v1/messages";
+
+ /**
+ * Dify会话API的基础URL
+ * 用于获取会话列表
+ */
+ private static final String DIFY_CONVERSATIONS_URL = "http://47.112.118.149:8100/v1/conversations";
+
+ /**
+ * Dify文件上传API的URL地址
+ * 用于上传文件到Dify服务，支持图文多模态理解
+ */
+ private static final String DIFY_FILES_URL = "http://47.112.118.149:8100/v1/files/upload";
/**
* HTTP客户端实例
@@ -386,12 +395,9 @@ public class AiChatController extends BaseController {
// 参数校验和限制
int limitValue = Math.min(Math.max(Integer.parseInt(limit), 1), 100);
- // 构建请求URL
- String url = "http://47.112.118.149:8100/v1/app/feedbacks?page=" + page + "&limit=" + limitValue;
-
// 构建请求
Request request = new Request.Builder()
- .url(url)
+ .url(DIFY_API_FEEDBACK_URL + page + "&limit=" + limitValue)
.addHeader("Authorization", "Bearer " + DIFY_API_KEY)
.addHeader("Content-Type", "application/json")
.get()
@@ -420,27 +426,6 @@ public class AiChatController extends BaseController {
feedbackItem.put("app_id", feedbackNode.has("app_id") ? feedbackNode.get("app_id").asText() : null);
feedbackItem.put("conversation_id", feedbackNode.has("conversation_id") ? feedbackNode.get("conversation_id").asText() : null);
- // 提取用户信息
- if (feedbackNode.has("from_end_user")) {
- JsonNode userNode = feedbackNode.get("from_end_user");
- Map userMap = new HashMap<>();
- userMap.put("id", userNode.has("id") ? userNode.get("id").asText() : null);
- userMap.put("name", userNode.has("name") ? userNode.get("name").asText() : null);
- userMap.put("email", userNode.has("email") ? userNode.get("email").asText() : null);
- feedbackItem.put("from_end_user", userMap);
- }
-
- // 提取消息内容
- if (feedbackNode.has("message")) {
- JsonNode messageNode = feedbackNode.get("message");
- Map messageMap = new HashMap<>();
- messageMap.put("id", messageNode.has("id") ? messageNode.get("id").asText() : null);
- messageMap.put("query", messageNode.has("query") ? messageNode.get("query").asText() : null);
- messageMap.put("answer", messageNode.has("answer") ? messageNode.get("answer").asText() : null);
- messageMap.put("created_at", messageNode.has("created_at") ? messageNode.get("created_at").asLong() : null);
- feedbackItem.put("message", messageMap);
- }
-
feedbackList.add(feedbackItem);
}
}
@@ -476,6 +461,7 @@ public class AiChatController extends BaseController {
}
// 权限标识为辅导员
+ @PreAuthorize("@ss.hasPermi('cph:teacher:list')")
@GetMapping("/getMessagesToAdmin")
public AjaxResult getMessagesToAdmin(@RequestParam String user,
@RequestParam(required = false) String firstId,
From 496b76d6cd2994a6d957f5ab953ce0922183cf91 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=9F=A5=E6=97=A0=E6=B6=AF?= <2637171921@qq.com>
Date: Thu, 14 Aug 2025 15:02:03 +0800
Subject: [PATCH 9/9] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=8A=A0Dify=E7=9B=B8?=
=?UTF-8?q?=E5=85=B3=E6=8E=A5=E5=8F=A3WeChatMentalAlertController=E7=94=A8?=
=?UTF-8?q?=E4=BA=8E=E6=8E=A5=E6=94=B6=E4=BF=A1=E6=81=AF=E8=B0=83=E7=94=A8?=
=?UTF-8?q?=E4=BC=81=E4=B8=9A=E5=BE=AE=E4=BF=A1=E5=8F=91=E9=80=81=E6=B6=88?=
=?UTF-8?q?=E6=81=AF=E7=BB=99=E9=93=BA=E5=AF=BC=E5=91=98=EF=BC=8C=E6=96=B0?=
=?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=AF=B9=E6=9C=89=E5=BF=83=E7=90=86=E9=97=AE?=
=?UTF-8?q?=E9=A2=98=E5=AD=A6=E7=94=9F=E7=9A=84=E6=95=B0=E6=8D=AE=E5=BA=93?=
=?UTF-8?q?=E8=A1=A8=E5=AD=98=E5=82=A8student=5Fmental=5Frating=EF=BC=8C?=
=?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=8A=A0=E5=AF=B9student=5Fmental=5Frating?=
=?UTF-8?q?=E8=A1=A8=E7=9A=84=E6=89=80=E6=9C=89=E6=9F=A5=E8=AF=A2=E5=92=8C?=
=?UTF-8?q?=E5=AD=A6=E5=8F=B7=E7=B2=BE=E5=87=86=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../common/WeChatMentalAlertController.java | 129 ++++++++++++++++++
.../system/domain/StudentMentalRating.java | 49 +++++++
.../mapper/StudentMentalRatingMapper.java | 32 +++++
.../system/StudentMentalRatingMapper.xml | 46 +++++++
4 files changed, 256 insertions(+)
create mode 100644 srs-admin/src/main/java/com/srs/web/controller/common/WeChatMentalAlertController.java
create mode 100644 srs-system/src/main/java/com/srs/system/domain/StudentMentalRating.java
create mode 100644 srs-system/src/main/java/com/srs/system/mapper/StudentMentalRatingMapper.java
create mode 100644 srs-system/src/main/resources/mapper/system/StudentMentalRatingMapper.xml
diff --git a/srs-admin/src/main/java/com/srs/web/controller/common/WeChatMentalAlertController.java b/srs-admin/src/main/java/com/srs/web/controller/common/WeChatMentalAlertController.java
new file mode 100644
index 0000000..9aa2976
--- /dev/null
+++ b/srs-admin/src/main/java/com/srs/web/controller/common/WeChatMentalAlertController.java
@@ -0,0 +1,129 @@
+package com.srs.web.controller.common;
+
+import com.srs.common.core.controller.BaseController;
+import com.srs.common.core.domain.AjaxResult;
+import com.srs.common.core.domain.entity.SysUser;
+import com.srs.common.core.domain.model.LoginUser;
+import com.srs.common.utils.WeChatUtil;
+import com.srs.framework.web.service.TokenService;
+import com.srs.system.domain.StudentMentalRating;
+import com.srs.system.mapper.StudentMentalRatingMapper;
+import com.srs.system.mapper.SysUserMapper;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * Dify心理问题发送企业微信 知无涯
+ */
+@Slf4j
+@RestController
+@RequestMapping("/api/wechat")
+public class WeChatMentalAlertController extends BaseController {
+
+ @Autowired
+ private SysUserMapper sysUserMapper;
+
+ @Autowired
+ private WeChatUtil weChatUtil;
+
+ @Autowired
+ private TokenService tokenService;
+ @Autowired
+ private StudentMentalRatingMapper studentMentalRatingMapper;
+
+ /**
+ * 处理心理预警通知请求
+ */
+ @PostMapping("/mentalAlert")
+ public AjaxResult handleMentalAlert(@RequestBody MentalAlertRequest request,
+ HttpServletRequest httpRequest) {
+
+ // 校验 token 是否有效
+ LoginUser loginUser = tokenService.getLoginUser(httpRequest);
+ if (loginUser == null) {
+ return AjaxResult.error("Token无效或已过期");
+ }
+
+ // 查询辅导员信息
+ SysUser teacher = sysUserMapper.selectTeacherByStuNo(request.getUserId());
+ if (teacher == null || !StringUtils.hasText(teacher.getUserName())) {
+ log.error("辅导员信息不完整，学号: {}", request.getUserId());
+ return AjaxResult.error("未分配辅导员或信息不完整");
+ }
+ /* 保存学生心理问题评级 */
+ StudentMentalRating record = new StudentMentalRating();
+ record.setStudentId(request.getUserId());
+ record.setRating(request.getRating());
+ studentMentalRatingMapper.insert(record);
+
+ // 构建并发送消息
+ try {
+ String content = buildContent(request, teacher);
+ weChatUtil.sendTextMessage(teacher.getUserName(), content);
+ return AjaxResult.success("消息已发送至辅导员");
+ } catch (Exception e) {
+ log.error("发送企业微信失败", e);
+ return AjaxResult.error("发送失败: " + e.getMessage());
+ }
+ }
+
+ /**
+ * 构建企业微信消息内容
+ */
+ private String buildContent(MentalAlertRequest request, SysUser teacher) {
+ String teacherName = StringUtils.hasText(teacher.getNickName())
+ ? teacher.getNickName()
+ : teacher.getUserName();
+ return String.format(
+ "【心理预警通知】\n" +
+ "辅导员：%s（%s）\n" +
+ "学生姓名：%s\n" +
+ "学号：%s\n" +
+ "问题描述：%s\n" +
+ "AI建议：%s\n" +
+ "心理问题评级：%s",
+ teacherName,
+ teacher.getUserName(),
+ request.getUserName(),
+ request.getUserId(),
+ request.getStudentQuestion(),
+ request.getAiAnswer(),
+ request.getRating()
+ );
+ }
+
+
+ @Data
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class MentalAlertRequest {
+ private String userId; // 学生学号
+ private String userName; // 学生姓名
+ private String studentQuestion; // 学生提问内容
+ private String aiAnswer; // AI回复内容
+ private String rating; // 心理问题评级
+ }
+
+ /**
+ * 获取全部学生心理评级记录
+ */
+ @GetMapping("/rating/all")
+ public AjaxResult allRatings() {
+ return AjaxResult.success(studentMentalRatingMapper.selectAll());
+ }
+
+ /**
+ * 根据学号获取全部记录
+ */
+ @GetMapping("/rating/{stuNo}")
+ public AjaxResult listByStuNo(@PathVariable String stuNo) {
+ return AjaxResult.success(studentMentalRatingMapper.selectByStuNo(stuNo));
+ }
+}
\ No newline at end of file
diff --git a/srs-system/src/main/java/com/srs/system/domain/StudentMentalRating.java b/srs-system/src/main/java/com/srs/system/domain/StudentMentalRating.java
new file mode 100644
index 0000000..b26f57d
--- /dev/null
+++ b/srs-system/src/main/java/com/srs/system/domain/StudentMentalRating.java
@@ -0,0 +1,49 @@
+package com.srs.system.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.srs.common.core.domain.BaseEntity;
+
+import java.util.Date;
+
+/**
+ * 学生心理问题评级表 知无涯
+ */
+public class StudentMentalRating extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+ private Long id;
+ private String studentId;
+ private String rating;
+
+
+ public Long getId() {
+ return id;
+ }
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ public String getStudentId() {
+ return studentId;
+ }
+
+ public void setStudentId(String studentId) {
+ this.studentId = studentId;
+ }
+
+ public String getRating() {
+ return rating;
+ }
+
+ public void setRating(String rating) {
+ this.rating = rating;
+ }
+
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+ private Date createdTime;
+
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+ private Date updatedTime;
+}
\ No newline at end of file
diff --git a/srs-system/src/main/java/com/srs/system/mapper/StudentMentalRatingMapper.java b/srs-system/src/main/java/com/srs/system/mapper/StudentMentalRatingMapper.java
new file mode 100644
index 0000000..bcc0f32
--- /dev/null
+++ b/srs-system/src/main/java/com/srs/system/mapper/StudentMentalRatingMapper.java
@@ -0,0 +1,32 @@
+package com.srs.system.mapper;
+
+import com.srs.system.domain.StudentMentalRating;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface StudentMentalRatingMapper {
+
+ /**
+ * 按学号查询 知无涯
+ */
+ StudentMentalRating selectByStudentId(String studentId);
+
+ /**
+ * 插入
+ */
+ int insert(StudentMentalRating record);
+
+ /**
+ * 按学号更新评级
+ */
+ int updateRatingByStudentId(StudentMentalRating record);
+
+ /** 全部记录 */
+ List selectAll();
+
+ /** 单学号全部记录 */
+ List selectByStuNo(@Param("stuNo") String stuNo);
+
+}
+
diff --git a/srs-system/src/main/resources/mapper/system/StudentMentalRatingMapper.xml b/srs-system/src/main/resources/mapper/system/StudentMentalRatingMapper.xml
new file mode 100644
index 0000000..88cd1e5
--- /dev/null
+++ b/srs-system/src/main/resources/mapper/system/StudentMentalRatingMapper.xml
@@ -0,0 +1,46 @@
+
+
+
+
+
+
+
+ INSERT INTO student_mental_rating(student_id, rating)
+ VALUES (#{studentId}, #{rating})
+
+
+
+ UPDATE student_mental_rating
+ SET rating = #{rating}
+ WHERE student_id = #{studentId}
+
+
+
+
+
+
+
+
\ No newline at end of file