Commit 9bb10523664a293db17d6c4d16b62d52600ba1ee
1 parent
0f986bcc
【代码评审】商城:消息获取改为游标查询
Showing
2 changed files
with
5 additions
and
5 deletions
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/controller/admin/kefu/vo/message/KeFuMessageListReqVO.java
| @@ -9,7 +9,7 @@ import java.time.LocalDateTime; | @@ -9,7 +9,7 @@ import java.time.LocalDateTime; | ||
| 9 | 9 | ||
| 10 | import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; | 10 | import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; |
| 11 | 11 | ||
| 12 | -@Schema(description = "管理后台 - 客服消息 Request VO") | 12 | +@Schema(description = "管理后台 - 客服消息列表 Request VO") |
| 13 | @Data | 13 | @Data |
| 14 | public class KeFuMessageListReqVO { | 14 | public class KeFuMessageListReqVO { |
| 15 | 15 |
yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/dal/mysql/kefu/KeFuMessageMapper.java
| @@ -21,10 +21,10 @@ public interface KeFuMessageMapper extends BaseMapperX<KeFuMessageDO> { | @@ -21,10 +21,10 @@ public interface KeFuMessageMapper extends BaseMapperX<KeFuMessageDO> { | ||
| 21 | 21 | ||
| 22 | /** | 22 | /** |
| 23 | * 获得消息列表 | 23 | * 获得消息列表 |
| 24 | - * 第一次查询时不带时间,默认查询最新的十条消息 | ||
| 25 | - * 第二次查询带时间查询历史消息 | 24 | + * 1. 第一次查询时,不带时间,默认查询最新的十条消息 |
| 25 | + * 2. 第二次查询时,带时间,查询历史消息 | ||
| 26 | * | 26 | * |
| 27 | - * @param reqVO 请求 | 27 | + * @param reqVO 列表请求 |
| 28 | * @return 消息列表 | 28 | * @return 消息列表 |
| 29 | */ | 29 | */ |
| 30 | default List<KeFuMessageDO> selectList(KeFuMessageListReqVO reqVO) { | 30 | default List<KeFuMessageDO> selectList(KeFuMessageListReqVO reqVO) { |
| @@ -32,7 +32,7 @@ public interface KeFuMessageMapper extends BaseMapperX<KeFuMessageDO> { | @@ -32,7 +32,7 @@ public interface KeFuMessageMapper extends BaseMapperX<KeFuMessageDO> { | ||
| 32 | .eqIfPresent(KeFuMessageDO::getConversationId, reqVO.getConversationId()) | 32 | .eqIfPresent(KeFuMessageDO::getConversationId, reqVO.getConversationId()) |
| 33 | .ltIfPresent(KeFuMessageDO::getCreateTime, reqVO.getCreateTime()) | 33 | .ltIfPresent(KeFuMessageDO::getCreateTime, reqVO.getCreateTime()) |
| 34 | .orderByDesc(KeFuMessageDO::getCreateTime) | 34 | .orderByDesc(KeFuMessageDO::getCreateTime) |
| 35 | - .last("limit 10")); | 35 | + .last("limit 10")); // TODO @puhui999:使用 limitN 哈。然后 10 通过 reqVO 传递。 |
| 36 | } | 36 | } |
| 37 | 37 | ||
| 38 | default List<KeFuMessageDO> selectListByConversationIdAndUserTypeAndReadStatus(Long conversationId, Integer userType, | 38 | default List<KeFuMessageDO> selectListByConversationIdAndUserTypeAndReadStatus(Long conversationId, Integer userType, |