wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3345: 同步群成员时进行物理删除

Browse Source
This commit is contained in:
yanglin 2025-02-07 15:47:18 +08:00
parent 134b8e2d50
commit a5845bc106
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
im-center-server/src/main/java/cn/axzo/im/dao/mapper/GroupMapperMapper.java
View File

@ -2,9 +2,15 @@ package cn.axzo.im.dao.mapper;
import cn.axzo.im.entity.GroupMember; import cn.axzo.im.entity.GroupMember;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Param;
/** /**
* @author yanglin * @author yanglin
*/ */
public interface GroupMapperMapper extends BaseMapper<GroupMember> { public interface GroupMapperMapper extends BaseMapper<GroupMember> {
@Delete("DELETE FROM im_group_member WHERE tid = #{tid}")
void deleteAccounts(@Param("tid") Long tid);
} }

4
im-center-server/src/main/java/cn/axzo/im/dao/repository/GroupMemberDao.java
View File

@ -21,9 +21,7 @@ import static java.util.stream.Collectors.toSet;
public class GroupMemberDao extends ServiceImpl<GroupMapperMapper, GroupMember> { public class GroupMemberDao extends ServiceImpl<GroupMapperMapper, GroupMember> {
public void deleteAccounts(Long tid) { public void deleteAccounts(Long tid) {
lambdaUpdate() getBaseMapper().deleteAccounts(tid);
.eq(GroupMember::getTid, tid)
.remove();
} }
public Set<PersonAccountAttribute> getGroupPersons(Long tid) { public Set<PersonAccountAttribute> getGroupPersons(Long tid) {