diff --git a/pom.xml b/pom.xml
index 208f604b..552c3631 100644
--- a/pom.xml
+++ b/pom.xml
@@ -241,6 +241,19 @@
mybatis-plus-boot-starter
3.4.0
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/research-admin/src/main/java/com/research/web/controller/client/session/SessionController.java b/research-admin/src/main/java/com/research/web/controller/client/session/SessionController.java
new file mode 100644
index 00000000..d82b4e88
--- /dev/null
+++ b/research-admin/src/main/java/com/research/web/controller/client/session/SessionController.java
@@ -0,0 +1,77 @@
+package com.research.web.controller.client.session;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.research.common.core.domain.BaseDto;
+import com.research.common.core.domain.JsonResponse;
+import com.research.system.domain.dto.SessionDto;
+import com.research.system.domain.vo.SessionVo;
+import com.research.system.service.SessionService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import liquibase.pro.packaged.J;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @Author zzc
+ * @Package com.research.web.controller.client.session
+ * @Date 2025/11/24 14:39
+ * @description:
+ */
+@RestController
+@RequestMapping("/session")
+@Api(tags = "消息相关")
+@Slf4j
+public class SessionController {
+
+ @Resource
+ private SessionService sessionService;
+
+ @ApiOperation(value = "查询通讯录")
+ @RequestMapping(value = "/queryTxl", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+ public JsonResponse> queryTxl(@ApiParam @Validated @RequestBody BaseDto dto) {
+ if (dto.getPageNum() > 0) {
+ PageHelper.startPage(dto.getPageNum(), dto.getPageSize());
+ }
+ return JsonResponse.ok(new PageInfo<>(sessionService.queryTxl(dto.getParam())));
+ }
+
+ @ApiOperation(value = "根据会话ID查询聊天记录")
+ @RequestMapping(value = "/queryLog", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+ public JsonResponse queryLog(@ApiParam @Validated @RequestBody BaseDto dto) {
+ return JsonResponse.ok(sessionService.queryLog(dto));
+ }
+
+ @ApiOperation(value = "发送消息")
+ @RequestMapping(value = "/send", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+ public JsonResponse send(@ApiParam @Validated @RequestBody SessionDto.SendMessage dto) {
+ return JsonResponse.ok(sessionService.send(dto));
+ }
+
+ @ApiOperation(value = "添加会话")
+ @RequestMapping(value = "/addSession", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+ public JsonResponse addSession(@ApiParam @Validated @RequestBody SessionDto.CreateSession dto) {
+ return JsonResponse.ok(sessionService.addSession(dto));
+ }
+
+ @ApiOperation(value = "删除会话")
+ @RequestMapping(value = "/delSession", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+ public JsonResponse delSession(@ApiParam @Validated @RequestBody SessionDto.Delete dto) {
+ return JsonResponse.ok(sessionService.delSession(dto));
+ }
+
+ @ApiOperation(value = "删除聊天记录")
+ @RequestMapping(value = "/delLog", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+ public JsonResponse delLog(@ApiParam @Validated @RequestBody SessionDto.Delete dto) {
+ return JsonResponse.ok(sessionService.delLog(dto));
+ }
+}
diff --git a/research-generator/src/main/resources/mbg.xml b/research-generator/src/main/resources/mbg.xml
index 3ed65a94..45e048a4 100644
--- a/research-generator/src/main/resources/mbg.xml
+++ b/research-generator/src/main/resources/mbg.xml
@@ -84,11 +84,17 @@
-
+
-
+
+
+
+
+
+
+