群聊

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupMemberServiceImpl.java

@@ -85,6 +85,7 @@ public class ImGroupMemberServiceImpl extends ServiceImpl<ImGroupMemberDao, ImGr
         return new ArrayList<>();
     }
 
+    @Override
     @Transactional(rollbackFor = Exception.class)
     public void join(List<GroupMember> groupMemberList,String imGroupId) throws Exception {
         GroupMember[] groupMembers = groupMemberList.toArray(new GroupMember[groupMemberList.size()]);
@@ -115,8 +116,15 @@ public class ImGroupMemberServiceImpl extends ServiceImpl<ImGroupMemberDao, ImGr
         imGroupMember.setNickname(basicUserInfo.getUsername());
         imGroupMember.setAvatar(basicUserInfo.getAvatar());
         imGroupMember.setUpdateTime(new Date());
-        baseMapper.updateById(imGroupMember);
+        this.startTransactional(()->{
+            baseMapper.updateById(imGroupMember);
+        });
         return imGroupMember;
     }
+
+    @Transactional(rollbackFor = Exception.class)
+    public void startTransactional(Runnable runnable){
+        runnable.run();
+    }
 }