命令规范

im-platform/src/main/java/com/bx/implatform/controller/FriendController.java

@@ -3,7 +3,7 @@ package com.bx.implatform.controller;
 import com.bx.implatform.entity.Friend;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IFriendService;
+import com.bx.implatform.service.FriendService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.vo.FriendVO;
 import io.swagger.v3.oas.annotations.Operation;
@@ -22,7 +22,7 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class FriendController {
 
-    private final IFriendService friendService;
+    private final FriendService friendService;
 
     @GetMapping("/list")
     @Operation(summary = "好友列表", description = "获取好友列表")

im-platform/src/main/java/com/bx/implatform/controller/GroupController.java

@@ -2,7 +2,7 @@ package com.bx.implatform.controller;
 
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IGroupService;
+import com.bx.implatform.service.GroupService;
 import com.bx.implatform.vo.GroupInviteVO;
 import com.bx.implatform.vo.GroupMemberVO;
 import com.bx.implatform.vo.GroupVO;
@@ -21,7 +21,7 @@ import java.util.List;
 @RequiredArgsConstructor
 public class GroupController {
 
-    private final IGroupService groupService;
+    private final GroupService groupService;
 
     @Operation(summary = "创建群聊", description = "创建群聊")
     @PostMapping("/create")

im-platform/src/main/java/com/bx/implatform/controller/GroupMessageController.java

@@ -3,7 +3,7 @@ package com.bx.implatform.controller;
 import com.bx.implatform.dto.GroupMessageDTO;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IGroupMessageService;
+import com.bx.implatform.service.GroupMessageService;
 import com.bx.implatform.vo.GroupMessageVO;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -20,7 +20,7 @@ import java.util.List;
 @RequiredArgsConstructor
 public class GroupMessageController {
 
-    private final IGroupMessageService groupMessageService;
+    private final GroupMessageService groupMessageService;
 
     @PostMapping("/send")
     @Operation(summary = "发送群聊消息", description = "发送群聊消息")

im-platform/src/main/java/com/bx/implatform/controller/LoginController.java

@@ -5,7 +5,7 @@ import com.bx.implatform.dto.ModifyPwdDTO;
 import com.bx.implatform.dto.RegisterDTO;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IUserService;
+import com.bx.implatform.service.UserService;
 import com.bx.implatform.vo.LoginVO;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -18,7 +18,7 @@ import org.springframework.web.bind.annotation.*;
 @RequiredArgsConstructor
 public class LoginController {
 
-    private final IUserService userService;
+    private final UserService userService;
 
     @PostMapping("/login")
     @Operation(summary = "用户登陆", description = "用户登陆")

im-platform/src/main/java/com/bx/implatform/controller/PrivateMessageController.java

@@ -3,7 +3,7 @@ package com.bx.implatform.controller;
 import com.bx.implatform.dto.PrivateMessageDTO;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IPrivateMessageService;
+import com.bx.implatform.service.PrivateMessageService;
 import com.bx.implatform.vo.PrivateMessageVO;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -20,7 +20,7 @@ import java.util.List;
 @RequiredArgsConstructor
 public class PrivateMessageController {
 
-    private final IPrivateMessageService privateMessageService;
+    private final PrivateMessageService privateMessageService;
 
     @PostMapping("/send")
     @Operation(summary = "发送消息", description = "发送私聊消息")

im-platform/src/main/java/com/bx/implatform/controller/UserController.java

@@ -3,7 +3,7 @@ package com.bx.implatform.controller;
 import com.bx.implatform.entity.User;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IUserService;
+import com.bx.implatform.service.UserService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.util.BeanUtils;
@@ -24,7 +24,7 @@ import java.util.List;
 @RequiredArgsConstructor
 public class UserController {
 
-    private final IUserService userService;
+    private final UserService userService;
 
     @GetMapping("/terminal/online")
     @Operation(summary = "判断用户哪个终端在线", description = "返回在线的用户id的终端集合")

im-platform/src/main/java/com/bx/implatform/controller/WebrtcGroupController.java

@@ -3,7 +3,7 @@ package com.bx.implatform.controller;
 import com.bx.implatform.dto.*;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IWebrtcGroupService;
+import com.bx.implatform.service.WebrtcGroupService;
 import com.bx.implatform.vo.WebrtcGroupInfoVO;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -22,7 +22,7 @@ import org.springframework.web.bind.annotation.*;
 @RequiredArgsConstructor
 public class WebrtcGroupController {
 
-    private final IWebrtcGroupService webrtcGroupService;
+    private final WebrtcGroupService webrtcGroupService;
 
     @Operation(summary = "发起群视频通话")
     @PostMapping("/setup")

im-platform/src/main/java/com/bx/implatform/controller/WebrtcPrivateController.java

@@ -3,7 +3,7 @@ package com.bx.implatform.controller;
 import com.bx.implatform.annotation.OnlineCheck;
 import com.bx.implatform.result.Result;
 import com.bx.implatform.result.ResultUtils;
-import com.bx.implatform.service.IWebrtcPrivateService;
+import com.bx.implatform.service.WebrtcPrivateService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
@@ -15,7 +15,7 @@ import org.springframework.web.bind.annotation.*;
 @RequiredArgsConstructor
 public class WebrtcPrivateController {
 
-    private final IWebrtcPrivateService webrtcPrivateService;
+    private final WebrtcPrivateService webrtcPrivateService;
 
     @OnlineCheck
     @Operation(summary = "呼叫视频通话")

im-platform/src/main/java/com/bx/implatform/listener/PrivateMessageListener.java

@@ -9,7 +9,7 @@ import com.bx.imcommon.enums.IMSendCode;
 import com.bx.imcommon.model.IMSendResult;
 import com.bx.implatform.entity.PrivateMessage;
 import com.bx.implatform.enums.MessageStatus;
-import com.bx.implatform.service.IPrivateMessageService;
+import com.bx.implatform.service.PrivateMessageService;
 import com.bx.implatform.vo.PrivateMessageVO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,7 +24,7 @@ import java.util.Set;
 public class PrivateMessageListener implements MessageListener<PrivateMessageVO> {
     @Lazy
     @Autowired
-    private IPrivateMessageService privateMessageService;
+    private PrivateMessageService privateMessageService;
     @Override
     public void process(List<IMSendResult<PrivateMessageVO>> results) {
         Set<Long> messageIds = new HashSet<>();

im-platform/src/main/java/com/bx/implatform/service/IFriendService.java → im-platform/src/main/java/com/bx/implatform/service/FriendService.java

@@ -6,7 +6,7 @@ import com.bx.implatform.vo.FriendVO;
 
 import java.util.List;
 
-public interface IFriendService extends IService<Friend> {
+public interface FriendService extends IService<Friend> {
 
     /**
      * 判断用户2是否用户1的好友

im-platform/src/main/java/com/bx/implatform/service/IGroupMemberService.java → im-platform/src/main/java/com/bx/implatform/service/GroupMemberService.java

@@ -5,7 +5,7 @@ import com.bx.implatform.entity.GroupMember;
 
 import java.util.List;
 
-public interface IGroupMemberService extends IService<GroupMember> {
+public interface GroupMemberService extends IService<GroupMember> {
 
     /**
      * 根据群聊id和用户id查询群聊成员

im-platform/src/main/java/com/bx/implatform/service/IGroupMessageService.java → im-platform/src/main/java/com/bx/implatform/service/GroupMessageService.java

@@ -7,7 +7,7 @@ import com.bx.implatform.vo.GroupMessageVO;
 
 import java.util.List;
 
-public interface IGroupMessageService extends IService<GroupMessage> {
+public interface GroupMessageService extends IService<GroupMessage> {
 
     /**
      * 发送群聊消息(高并发接口，查询mysql接口都要进行缓存)

im-platform/src/main/java/com/bx/implatform/service/IGroupService.java → im-platform/src/main/java/com/bx/implatform/service/GroupService.java

@@ -8,7 +8,7 @@ import com.bx.implatform.vo.GroupVO;
 
 import java.util.List;
 
-public interface IGroupService extends IService<Group> {
+public interface GroupService extends IService<Group> {
 
     /**
      * 创建新群聊

im-platform/src/main/java/com/bx/implatform/service/IPrivateMessageService.java → im-platform/src/main/java/com/bx/implatform/service/PrivateMessageService.java

@@ -7,7 +7,7 @@ import com.bx.implatform.vo.PrivateMessageVO;
 
 import java.util.List;
 
-public interface IPrivateMessageService extends IService<PrivateMessage> {
+public interface PrivateMessageService extends IService<PrivateMessage> {
 
     /**
      * 发送私聊消息(高并发接口，查询mysql接口都要进行缓存)

im-platform/src/main/java/com/bx/implatform/service/IUserService.java → im-platform/src/main/java/com/bx/implatform/service/UserService.java

@@ -11,7 +11,7 @@ import com.bx.implatform.vo.UserVO;
 
 import java.util.List;
 
-public interface IUserService extends IService<User> {
+public interface UserService extends IService<User> {
 
     /**
      * 用户登录

im-platform/src/main/java/com/bx/implatform/service/IWebrtcGroupService.java → im-platform/src/main/java/com/bx/implatform/service/WebrtcGroupService.java

@@ -3,7 +3,7 @@ package com.bx.implatform.service;
 import com.bx.implatform.dto.*;
 import com.bx.implatform.vo.WebrtcGroupInfoVO;
 
-public interface IWebrtcGroupService {
+public interface WebrtcGroupService {
 
     /**
      * 发起通话

im-platform/src/main/java/com/bx/implatform/service/IWebrtcPrivateService.java → im-platform/src/main/java/com/bx/implatform/service/WebrtcPrivateService.java

@@ -5,7 +5,7 @@ package com.bx.implatform.service;
  *
  * @author
  */
-public interface IWebrtcPrivateService {
+public interface WebrtcPrivateService {
 
     void call(Long uid, String mode,String offer);
 

im-platform/src/main/java/com/bx/implatform/service/impl/FriendServiceImpl.java

@@ -7,11 +7,10 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.bx.implatform.contant.RedisKey;
 import com.bx.implatform.entity.Friend;
 import com.bx.implatform.entity.User;
-import com.bx.implatform.enums.ResultCode;
 import com.bx.implatform.exception.GlobalException;
 import com.bx.implatform.mapper.FriendMapper;
 import com.bx.implatform.mapper.UserMapper;
-import com.bx.implatform.service.IFriendService;
+import com.bx.implatform.service.FriendService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.vo.FriendVO;
@@ -31,7 +30,7 @@ import java.util.Objects;
 @Service
 @RequiredArgsConstructor
 @CacheConfig(cacheNames = RedisKey.IM_CACHE_FRIEND)
-public class FriendServiceImpl extends ServiceImpl<FriendMapper, Friend> implements IFriendService {
+public class FriendServiceImpl extends ServiceImpl<FriendMapper, Friend> implements FriendService {
 
     private final UserMapper userMapper;
 

im-platform/src/main/java/com/bx/implatform/service/impl/GroupMemberServiceImpl.java

@@ -9,7 +9,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.bx.implatform.contant.RedisKey;
 import com.bx.implatform.entity.GroupMember;
 import com.bx.implatform.mapper.GroupMemberMapper;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
 import com.bx.implatform.util.DateTimeUtils;
 import org.springframework.cache.annotation.CacheConfig;
 import org.springframework.cache.annotation.CacheEvict;
@@ -22,7 +22,7 @@ import java.util.stream.Collectors;
 
 @Service
 @CacheConfig(cacheNames = RedisKey.IM_CACHE_GROUP_MEMBER_ID)
-public class GroupMemberServiceImpl extends ServiceImpl<GroupMemberMapper, GroupMember> implements IGroupMemberService {
+public class GroupMemberServiceImpl extends ServiceImpl<GroupMemberMapper, GroupMember> implements GroupMemberService {
     @CacheEvict(key = "#member.getGroupId()")
     @Override
     public boolean save(GroupMember member) {

im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java

@@ -23,9 +23,9 @@ import com.bx.implatform.enums.MessageStatus;
 import com.bx.implatform.enums.MessageType;
 import com.bx.implatform.exception.GlobalException;
 import com.bx.implatform.mapper.GroupMessageMapper;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
-import com.bx.implatform.service.IGroupMessageService;
+import com.bx.implatform.service.GroupMessageService;
-import com.bx.implatform.service.IGroupService;
+import com.bx.implatform.service.GroupService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.util.BeanUtils;
@@ -46,9 +46,10 @@ import java.util.stream.Collectors;
 @Slf4j
 @Service
 @RequiredArgsConstructor
-public class GroupMessageServiceImpl extends ServiceImpl<GroupMessageMapper, GroupMessage> implements IGroupMessageService {
+public class GroupMessageServiceImpl extends ServiceImpl<GroupMessageMapper, GroupMessage> implements
-    private final IGroupService groupService;
+    GroupMessageService {
-    private final IGroupMemberService groupMemberService;
+    private final GroupService groupService;
+    private final GroupMemberService groupMemberService;
     private final RedisTemplate<String, Object> redisTemplate;
     private final IMClient imClient;
     private final SensitiveFilterUtil sensitiveFilterUtil;

im-platform/src/main/java/com/bx/implatform/service/impl/GroupServiceImpl.java

@@ -17,10 +17,10 @@ import com.bx.implatform.enums.MessageType;
 import com.bx.implatform.exception.GlobalException;
 import com.bx.implatform.mapper.GroupMapper;
 import com.bx.implatform.mapper.GroupMessageMapper;
-import com.bx.implatform.service.IFriendService;
+import com.bx.implatform.service.FriendService;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
-import com.bx.implatform.service.IGroupService;
+import com.bx.implatform.service.GroupService;
-import com.bx.implatform.service.IUserService;
+import com.bx.implatform.service.UserService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.util.BeanUtils;
@@ -45,11 +45,11 @@ import java.util.stream.Collectors;
 @Service
 @RequiredArgsConstructor
 @CacheConfig(cacheNames = RedisKey.IM_CACHE_GROUP)
-public class GroupServiceImpl extends ServiceImpl<GroupMapper, Group> implements IGroupService {
+public class GroupServiceImpl extends ServiceImpl<GroupMapper, Group> implements GroupService {
-    private final IUserService userService;
+    private final UserService userService;
-    private final IGroupMemberService groupMemberService;
+    private final GroupMemberService groupMemberService;
     private final GroupMessageMapper groupMessageMapper;
-    private final IFriendService friendsService;
+    private final FriendService friendsService;
     private final IMClient imClient;
     private final RedisTemplate<String, Object> redisTemplate;
 

im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java

@@ -16,11 +16,10 @@ import com.bx.implatform.entity.Friend;
 import com.bx.implatform.entity.PrivateMessage;
 import com.bx.implatform.enums.MessageStatus;
 import com.bx.implatform.enums.MessageType;
-import com.bx.implatform.enums.ResultCode;
 import com.bx.implatform.exception.GlobalException;
 import com.bx.implatform.mapper.PrivateMessageMapper;
-import com.bx.implatform.service.IFriendService;
+import com.bx.implatform.service.FriendService;
-import com.bx.implatform.service.IPrivateMessageService;
+import com.bx.implatform.service.PrivateMessageService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.util.BeanUtils;
@@ -38,9 +37,10 @@ import java.util.stream.Collectors;
 @Slf4j
 @Service
 @RequiredArgsConstructor
-public class PrivateMessageServiceImpl extends ServiceImpl<PrivateMessageMapper, PrivateMessage> implements IPrivateMessageService {
+public class PrivateMessageServiceImpl extends ServiceImpl<PrivateMessageMapper, PrivateMessage> implements
+    PrivateMessageService {
 
-    private final IFriendService friendService;
+    private final FriendService friendService;
     private final IMClient imClient;
     private final SensitiveFilterUtil sensitiveFilterUtil;
 

im-platform/src/main/java/com/bx/implatform/service/impl/UserServiceImpl.java

@@ -18,9 +18,9 @@ import com.bx.implatform.entity.User;
 import com.bx.implatform.enums.ResultCode;
 import com.bx.implatform.exception.GlobalException;
 import com.bx.implatform.mapper.UserMapper;
-import com.bx.implatform.service.IFriendService;
+import com.bx.implatform.service.FriendService;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
-import com.bx.implatform.service.IUserService;
+import com.bx.implatform.service.UserService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.util.BeanUtils;
@@ -39,11 +39,11 @@ import java.util.stream.Collectors;
 @Slf4j
 @Service
 @RequiredArgsConstructor
-public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {
+public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
 
     private final PasswordEncoder passwordEncoder;
-    private final IGroupMemberService groupMemberService;
+    private final GroupMemberService groupMemberService;
-    private final IFriendService friendService;
+    private final FriendService friendService;
     private final JwtProperties jwtProperties;
     private final IMClient imClient;
 

im-platform/src/main/java/com/bx/implatform/service/impl/WebrtcGroupServiceImpl.java

@@ -15,10 +15,10 @@ import com.bx.implatform.entity.GroupMessage;
 import com.bx.implatform.enums.MessageStatus;
 import com.bx.implatform.enums.MessageType;
 import com.bx.implatform.exception.GlobalException;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
-import com.bx.implatform.service.IGroupMessageService;
+import com.bx.implatform.service.GroupMessageService;
-import com.bx.implatform.service.IGroupService;
+import com.bx.implatform.service.GroupService;
-import com.bx.implatform.service.IWebrtcGroupService;
+import com.bx.implatform.service.WebrtcGroupService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.session.WebrtcGroupSession;
@@ -47,10 +47,10 @@ import java.util.stream.Collectors;
 @Slf4j
 @Service
 @RequiredArgsConstructor
-public class WebrtcGroupServiceImpl implements IWebrtcGroupService {
+public class WebrtcGroupServiceImpl implements WebrtcGroupService {
-    private final IGroupService groupService;
+    private final GroupService groupService;
-    private final IGroupMemberService groupMemberService;
+    private final GroupMemberService groupMemberService;
-    private final IGroupMessageService groupMessageService;
+    private final GroupMessageService groupMessageService;
     private final RedisTemplate<String, Object> redisTemplate;
     private final IMClient imClient;
     private final UserStateUtils userStateUtils;

im-platform/src/main/java/com/bx/implatform/service/impl/WebrtcPrivateServiceImpl.java

@@ -9,8 +9,8 @@ import com.bx.implatform.enums.MessageStatus;
 import com.bx.implatform.enums.MessageType;
 import com.bx.implatform.enums.WebrtcMode;
 import com.bx.implatform.exception.GlobalException;
-import com.bx.implatform.service.IPrivateMessageService;
+import com.bx.implatform.service.PrivateMessageService;
-import com.bx.implatform.service.IWebrtcPrivateService;
+import com.bx.implatform.service.WebrtcPrivateService;
 import com.bx.implatform.session.SessionContext;
 import com.bx.implatform.session.UserSession;
 import com.bx.implatform.session.WebrtcPrivateSession;
@@ -30,11 +30,11 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Service
 @RequiredArgsConstructor
-public class WebrtcPrivateServiceImpl implements IWebrtcPrivateService {
+public class WebrtcPrivateServiceImpl implements WebrtcPrivateService {
 
     private final IMClient imClient;
     private final RedisTemplate<String, Object> redisTemplate;
-    private final IPrivateMessageService privateMessageService;
+    private final PrivateMessageService privateMessageService;
     private final UserStateUtils userStateUtils;
 
     @Override

im-platform/src/main/java/com/bx/implatform/task/GroupBannedConsumerTask.java

@@ -1,34 +1,25 @@
 package com.bx.implatform.task;
 
-import cn.hutool.core.util.StrUtil;
 import com.bx.imclient.IMClient;
 import com.bx.imcommon.enums.IMTerminalType;
 import com.bx.imcommon.model.IMGroupMessage;
-import com.bx.imcommon.model.IMSystemMessage;
 import com.bx.imcommon.model.IMUserInfo;
 import com.bx.imcommon.mq.RedisMQConsumer;
 import com.bx.imcommon.mq.RedisMQListener;
 import com.bx.implatform.contant.Constant;
 import com.bx.implatform.contant.RedisKey;
 import com.bx.implatform.dto.GroupBanDTO;
-import com.bx.implatform.dto.UserBanDTO;
-import com.bx.implatform.entity.Group;
 import com.bx.implatform.entity.GroupMessage;
 import com.bx.implatform.enums.MessageStatus;
 import com.bx.implatform.enums.MessageType;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
-import com.bx.implatform.service.IGroupMessageService;
+import com.bx.implatform.service.GroupMessageService;
-import com.bx.implatform.service.IGroupService;
 import com.bx.implatform.util.BeanUtils;
 import com.bx.implatform.vo.GroupMessageVO;
-import com.bx.implatform.vo.SystemMessageVO;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.logging.log4j.util.Strings;
-import org.springframework.boot.context.properties.source.ConfigurationPropertyState;
 import org.springframework.stereotype.Component;
 
-import java.util.Collections;
 import java.util.Date;
 import java.util.List;
 
@@ -45,9 +36,9 @@ public class GroupBannedConsumerTask extends RedisMQConsumer<GroupBanDTO> {
 
     private final IMClient imClient;
 
-    private final IGroupMessageService groupMessageService;
+    private final GroupMessageService groupMessageService;
 
-    private final IGroupMemberService groupMemberService;
+    private final GroupMemberService groupMemberService;
 
     @Override
     public void onMessage(GroupBanDTO dto) {

im-platform/src/main/java/com/bx/implatform/task/GroupUnbanConsumerTask.java

@@ -1,6 +1,5 @@
 package com.bx.implatform.task;
 
-import cn.hutool.core.util.StrUtil;
 import com.bx.imclient.IMClient;
 import com.bx.imcommon.enums.IMTerminalType;
 import com.bx.imcommon.model.IMGroupMessage;
@@ -9,13 +8,12 @@ import com.bx.imcommon.mq.RedisMQConsumer;
 import com.bx.imcommon.mq.RedisMQListener;
 import com.bx.implatform.contant.Constant;
 import com.bx.implatform.contant.RedisKey;
-import com.bx.implatform.dto.GroupBanDTO;
 import com.bx.implatform.dto.GroupUnbanDTO;
 import com.bx.implatform.entity.GroupMessage;
 import com.bx.implatform.enums.MessageStatus;
 import com.bx.implatform.enums.MessageType;
-import com.bx.implatform.service.IGroupMemberService;
+import com.bx.implatform.service.GroupMemberService;
-import com.bx.implatform.service.IGroupMessageService;
+import com.bx.implatform.service.GroupMessageService;
 import com.bx.implatform.util.BeanUtils;
 import com.bx.implatform.vo.GroupMessageVO;
 import lombok.RequiredArgsConstructor;
@@ -38,9 +36,9 @@ public class GroupUnbanConsumerTask extends RedisMQConsumer<GroupUnbanDTO> {
 
     private final IMClient imClient;
 
-    private final IGroupMessageService groupMessageService;
+    private final GroupMessageService groupMessageService;
 
-    private final IGroupMemberService groupMemberService;
+    private final GroupMemberService groupMemberService;
 
     @Override
     public void onMessage(GroupUnbanDTO dto) {