From 243d5d39d24ce24b0a6614672b44d1f831249b04 Mon Sep 17 00:00:00 2001 From: ccsens_zhengzhichuan Date: Tue, 25 Nov 2025 13:45:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8E=A5=E5=8F=A3=E5=AE=8C?= =?UTF-8?q?=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 13 + .../client/session/SessionController.java | 77 ++ research-generator/src/main/resources/mbg.xml | 10 +- .../research/system/domain/dto/GroupDto.java | 2 +- .../domain/dto/ResResearchIntegrityDto.java | 1 + .../system/domain/dto/SessionDto.java | 66 ++ .../system/domain/po/ChatContactList.java | 116 +++ .../domain/po/ChatContactListExample.java | 810 +++++++++++++++ .../domain/po/ChatMessageReadStatus.java | 139 +++ .../po/ChatMessageReadStatusExample.java | 881 ++++++++++++++++ .../system/domain/po/ChatSessionMembers.java | 139 +++ .../domain/po/ChatSessionMembersExample.java | 891 ++++++++++++++++ .../system/domain/po/ChatSessionMessages.java | 150 +++ .../domain/po/ChatSessionMessagesExample.java | 961 ++++++++++++++++++ .../system/domain/po/ChatSessions.java | 139 +++ .../system/domain/po/ChatSessionsExample.java | 901 ++++++++++++++++ .../research/system/domain/vo/GroupVO.java | 2 +- .../domain/vo/ResResearchIntegrityVo.java | 1 + .../research/system/domain/vo/SessionVo.java | 87 ++ .../system/persist/dao/SessionDao.java | 23 + .../persist/mapper/ChatContactListMapper.java | 20 + .../mapper/ChatMessageReadStatusMapper.java | 28 + .../mapper/ChatSessionMembersMapper.java | 28 + .../mapper/ChatSessionMessagesMapper.java | 28 + .../persist/mapper/ChatSessionsMapper.java | 28 + .../system/service/SessionService.java | 29 + .../service/impl/KtsGroupServiceImpl.java | 1 + .../service/impl/SessionServiceImpl.java | 173 ++++ .../main/resources/mapper/dao/KtsGroupDao.xml | 2 +- .../mapper/dao/ResResearchIntegrityDao.xml | 1 + .../main/resources/mapper/dao/SessionDao.xml | 94 ++ .../mapper/system/ChatContactListMapper.xml | 215 ++++ .../system/ChatMessageReadStatusMapper.xml | 300 ++++++ .../system/ChatSessionMembersMapper.xml | 300 ++++++ .../system/ChatSessionMessagesMapper.xml | 317 ++++++ .../mapper/system/ChatSessionsMapper.xml | 300 ++++++ 36 files changed, 7268 insertions(+), 5 deletions(-) create mode 100644 research-admin/src/main/java/com/research/web/controller/client/session/SessionController.java create mode 100644 research-system/src/main/java/com/research/system/domain/dto/SessionDto.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatContactList.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatContactListExample.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatMessageReadStatus.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatMessageReadStatusExample.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatSessionMembers.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatSessionMembersExample.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatSessionMessages.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatSessionMessagesExample.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatSessions.java create mode 100644 research-system/src/main/java/com/research/system/domain/po/ChatSessionsExample.java create mode 100644 research-system/src/main/java/com/research/system/domain/vo/SessionVo.java create mode 100644 research-system/src/main/java/com/research/system/persist/dao/SessionDao.java create mode 100644 research-system/src/main/java/com/research/system/persist/mapper/ChatContactListMapper.java create mode 100644 research-system/src/main/java/com/research/system/persist/mapper/ChatMessageReadStatusMapper.java create mode 100644 research-system/src/main/java/com/research/system/persist/mapper/ChatSessionMembersMapper.java create mode 100644 research-system/src/main/java/com/research/system/persist/mapper/ChatSessionMessagesMapper.java create mode 100644 research-system/src/main/java/com/research/system/persist/mapper/ChatSessionsMapper.java create mode 100644 research-system/src/main/java/com/research/system/service/SessionService.java create mode 100644 research-system/src/main/java/com/research/system/service/impl/SessionServiceImpl.java create mode 100644 research-system/src/main/resources/mapper/dao/SessionDao.xml create mode 100644 research-system/src/main/resources/mapper/system/ChatContactListMapper.xml create mode 100644 research-system/src/main/resources/mapper/system/ChatMessageReadStatusMapper.xml create mode 100644 research-system/src/main/resources/mapper/system/ChatSessionMembersMapper.xml create mode 100644 research-system/src/main/resources/mapper/system/ChatSessionMessagesMapper.xml create mode 100644 research-system/src/main/resources/mapper/system/ChatSessionsMapper.xml 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 @@ - + -
+ +
+
+
+
+
+