聊天室长连接请求

core/src/main/java/com/wecloud/im/action/ConversationAction.java

 package com.wecloud.im.action;
 
-import io.geekidea.springbootplus.framework.common.api.ApiCode;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.commons.collections4.CollectionUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-import org.springframework.validation.annotation.Validated;
-
 import com.alibaba.fastjson.JSON;
 import com.wecloud.dispatch.annotation.ActionMapping;
 import com.wecloud.im.param.DisbandConversationParam;
+import com.wecloud.im.param.ExitChatRoomParam;
 import com.wecloud.im.param.ImConversationQueryParam;
+import com.wecloud.im.param.IntoChatRoomParam;
 import com.wecloud.im.param.MutedGroupMemberParam;
 import com.wecloud.im.param.MutedGroupParam;
 import com.wecloud.im.param.SetAdminsParam;
@@ -32,6 +20,19 @@ import com.wecloud.im.service.ImConversationService;
 import com.wecloud.im.vo.ConversationVo;
 import com.wecloud.im.vo.ImConversationCreateVo;
 import com.wecloud.im.ws.model.WsResponse;
+import io.geekidea.springbootplus.framework.common.api.ApiCode;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 
 /**
  *
@@ -228,4 +229,28 @@ public class ConversationAction {
         imConversationService.updateDisplayConversation(data);
         return WsResponse.ok();
     }
+
+    /**
+     * 用户进入聊天室
+     */
+    @ActionMapping("/intoChatRoom")
+    @ApiOperation(value = "用户进入聊天室", notes = "用户进入聊天室")
+    public WsResponse<Boolean> intoChatRoom(@RequestBody IntoChatRoomParam data) {
+        log.info("用户进入聊天室入参 {}", JSON.toJSONString(data));
+        return WsResponse.ok(imConversationService.intoChatRoom(data));
+    }
+
+
+    /**
+     * 用户退出聊天室
+     */
+    @ActionMapping("/exitRoom")
+    @ApiOperation(value = "用户退出聊天室", notes = "用户退出聊天室")
+    public WsResponse<Boolean> exitRoom(@RequestBody ExitChatRoomParam data) {
+        log.info("用户退出聊天室入参 {}", JSON.toJSONString(data));
+        return WsResponse.ok(imConversationService.exitRoom(data));
+    }
+
+
+
 }

core/src/main/java/com/wecloud/im/controller/ImConversationController.java

 package com.wecloud.im.controller;
 
+import com.wecloud.im.param.ExitChatRoomParam;
 import com.wecloud.im.param.IntoChatRoomParam;
 import io.geekidea.springbootplus.framework.common.api.ApiCode;
 import io.geekidea.springbootplus.framework.common.api.ApiResult;
@@ -219,5 +220,16 @@ public class ImConversationController extends BaseController {
     }
 
 
+    /**
+     * 用户退出聊天室
+     */
+    @PostMapping("/exitRoom")
+    @ApiOperation(value = "用户退出聊天室", notes = "用户退出聊天室")
+    public ApiResult<Boolean> exitRoom(@RequestBody ExitChatRoomParam param) {
+        log.info("用户退出聊天室入参 {}", JSON.toJSONString(param));
+        return ApiResult.ok(imConversationService.exitRoom(param));
+    }
+
+
 }