Browse Source

群迁移

liujc 1 year ago
parent
commit
fe73907568

+ 13 - 2
cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/ImGroupServiceImpl.java

@@ -1302,14 +1302,25 @@ public class ImGroupServiceImpl extends ServiceImpl<ImGroupDao, ImGroup> impleme
         String defaultHeard = sysConfigService.findConfigValue(SysConfigConstant.DEFAULT_HEARD);
         for (ImGroup imGroup : records) {
 
-            log.info("群迁移开始:{}", imGroup.getId());
+            log.info("群销毁开始:{}", imGroup.getId());
             // 先删除群组
             try {
                 // 解散群
                 imPluginContext.getPluginService().groupDismiss(imGroup.getId(), new ArrayList<>());
             } catch (Exception e) {
-                log.error(String.format("群迁移删除群聊失败:%s", e.getMessage()),e);
+                log.error(String.format("群迁移删除群聊失败:%s", e.getMessage()), e);
             }
+        }
+        for (ImGroup imGroup : records) {
+
+            log.info("群迁移开始:{}", imGroup.getId());
+//            // 先删除群组
+//            try {
+//                // 解散群
+//                imPluginContext.getPluginService().groupDismiss(imGroup.getId(), new ArrayList<>());
+//            } catch (Exception e) {
+//                log.error(String.format("群迁移删除群聊失败:%s", e.getMessage()),e);
+//            }
 
             List<ImGroupMember> memberList = imGroupMemberService.lambdaQuery()
                     .eq(ImGroupMember::getGroupId, imGroup.getId())