add 成功建立连接时间

nb-im/src/main/java/com/nb/im/controller/ImRooMsgController.java → nb-im/src/main/java/com/nb/im/controller/ImRoomMsgController.java

@@ -1,12 +1,16 @@
 package com.nb.im.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.nb.core.result.R;
-import com.nb.im.service.LocalImMsgReadService;
+import com.nb.im.entity.ImMsgEntity;
 import com.nb.im.service.LocalImMsgService;
+import com.nb.im.service.dto.ImRoomMsgQuery;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.AllArgsConstructor;
+import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 /**
@@ -20,23 +24,15 @@ import org.springframework.web.bind.annotation.RestController;
 @AllArgsConstructor
 @RequestMapping("/im/msg")
 @Api(tags = "聊天室消息")
-public class ImRooMsgController  {
+public class ImRoomMsgController  {
     private final LocalImMsgService chatRoomMsgService;
-    private final LocalImMsgReadService msgReadService;
-
-    @PostMapping("/offline/no_page")
-    @ApiOperation("读取离线消息")
-    public R offlineMsg(){
-        //todo
-        return null;
-    }
-
-
 
 
-    @PostMapping("")
-    @ApiOperation("获取漫游消息")
-    public R list(){
-        return R.success();
+    @PostMapping("/roam")
+    @ApiOperation("获取漫游消息（默认获取最新500条数据）")
+    public R list(@RequestBody@Validated ImRoomMsgQuery query){
+        return R.success(chatRoomMsgService.list(new QueryWrapper<ImMsgEntity>()
+                .lambda()
+                .eq(ImMsgEntity::getRoomId,query.getRoomId())));
     }
- }
+}

nb-im/src/main/java/com/nb/im/service/LocalImRoomService.java

@@ -27,7 +27,7 @@ import java.util.Map;
 /**
  * @author lifang
  * @version 1.0.0
- * @ClassName LocalChatRoomSerice.java
+ * @ClassName LocalImRoomService.java
  * @Description TODO
  * @createTime 2022年08月16日 09:30:00
  */

nb-im/src/main/java/com/nb/im/service/dto/ImRoomDto.java

@@ -20,7 +20,7 @@ import javax.validation.constraints.NotNull;
  * @createTime 2022年08月16日 16:35:00
  */
 @Data
-@ApiModel("聊天室查询")
+@ApiModel("聊天室")
 public class ImRoomDto {
     @ApiModelProperty(value = "医生id",required = true)
     @NotNull(message = "医生id不能为空")

nb-im/src/main/java/com/nb/im/service/dto/ImRoomMsgQuery.java

@@ -0,0 +1,23 @@
+package com.nb.im.service.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+
+/**
+ * @author lifang
+ * @version 1.0.0
+ * @ClassName ImRoomMsgQuery.java
+ * @Description TODO
+ * @createTime 2022年08月29日 09:50:00
+ */
+@Data
+@ApiModel("聊天室信息查询")
+public class ImRoomMsgQuery {
+    @ApiModelProperty(value = "聊天室id",required = true)
+    @NotNull(message = "聊天室id不能为空")
+    private String roomId;
+
+}