Commit 7385ca57 by Future

解散群逻辑添加

parent 57f0ea87
...@@ -20,10 +20,10 @@ import com.wecloud.im.enums.MutedEnum; ...@@ -20,10 +20,10 @@ import com.wecloud.im.enums.MutedEnum;
import com.wecloud.im.mapper.ImConversationMapper; import com.wecloud.im.mapper.ImConversationMapper;
import com.wecloud.im.param.DisbandConversationParam; import com.wecloud.im.param.DisbandConversationParam;
import com.wecloud.im.param.ImClientSimpleDto; import com.wecloud.im.param.ImClientSimpleDto;
import com.wecloud.im.param.ListConversationMembersParam;
import com.wecloud.im.param.ImConversationPageParam; import com.wecloud.im.param.ImConversationPageParam;
import com.wecloud.im.param.ImConversationQueryParam; import com.wecloud.im.param.ImConversationQueryParam;
import com.wecloud.im.param.ImConversationQueryVo; import com.wecloud.im.param.ImConversationQueryVo;
import com.wecloud.im.param.ListConversationMembersParam;
import com.wecloud.im.param.MutedGroupParam; import com.wecloud.im.param.MutedGroupParam;
import com.wecloud.im.param.SetAdminsParam; import com.wecloud.im.param.SetAdminsParam;
import com.wecloud.im.param.TransferOwnerParam; import com.wecloud.im.param.TransferOwnerParam;
...@@ -38,9 +38,9 @@ import com.wecloud.im.service.ImClientService; ...@@ -38,9 +38,9 @@ import com.wecloud.im.service.ImClientService;
import com.wecloud.im.service.ImConversationMembersService; import com.wecloud.im.service.ImConversationMembersService;
import com.wecloud.im.service.ImConversationService; import com.wecloud.im.service.ImConversationService;
import com.wecloud.im.service.ImMessageService; import com.wecloud.im.service.ImMessageService;
import com.wecloud.im.vo.ConversationMemberVo;
import com.wecloud.im.vo.ConversationVo; import com.wecloud.im.vo.ConversationVo;
import com.wecloud.im.vo.ImConversationCreateVo; import com.wecloud.im.vo.ImConversationCreateVo;
import com.wecloud.im.vo.ConversationMemberVo;
import com.wecloud.im.vo.OfflineMsgDto; import com.wecloud.im.vo.OfflineMsgDto;
import com.wecloud.im.ws.enums.MsgTypeEnum; import com.wecloud.im.ws.enums.MsgTypeEnum;
import com.wecloud.im.ws.enums.WsResponseCmdEnum; import com.wecloud.im.ws.enums.WsResponseCmdEnum;
...@@ -510,7 +510,6 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -510,7 +510,6 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
return ApiResult.ok(); return ApiResult.ok();
} }
@Transactional(rollbackFor = Exception.class)
@Override @Override
public void disband(DisbandConversationParam param) { public void disband(DisbandConversationParam param) {
ImClient currentClient = imClientService.getCurrentClient(); ImClient currentClient = imClientService.getCurrentClient();
...@@ -533,8 +532,6 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -533,8 +532,6 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
if (membersList.isEmpty()) { if (membersList.isEmpty()) {
throw new BusinessException("群聊成员列表为空"); throw new BusinessException("群聊成员列表为空");
} }
// 删除会话
imConversationService.removeById(param.getConversationId());
// 删除所有成员 // 删除所有成员
imConversationMembersService.deleteByConversationId(param.getConversationId()); imConversationMembersService.deleteByConversationId(param.getConversationId());
for (ImConversationMembers member : membersList) { for (ImConversationMembers member : membersList) {
...@@ -739,6 +736,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -739,6 +736,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
/** /**
* 设置管理员 * 设置管理员
*
* @param param * @param param
* @return * @return
*/ */
...@@ -767,6 +765,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -767,6 +765,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
/** /**
* 群禁言 * 群禁言
*
* @param param * @param param
* @return * @return
*/ */
...@@ -813,6 +812,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap ...@@ -813,6 +812,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
/** /**
* 判断当前操作人是否为指定角色成员 * 判断当前操作人是否为指定角色成员
*
* @param currentClientId * @param currentClientId
* @param conversationId * @param conversationId
* @return * @return
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment