|
@@ -1064,7 +1064,11 @@ public class ImGroupServiceImpl extends BaseServiceImpl<String, ImGroup> impleme
|
|
|
return data;
|
|
|
}).collect(Collectors.toList());
|
|
|
importGroupMember.setMemberList(members);
|
|
|
- imPluginContext.getPluginService().importGroupMember(importGroupMember);
|
|
|
+ List<List<MessageWrapper.ImportGroupMemberData>> partition = Lists.partition(members, 88);
|
|
|
+ for (List<MessageWrapper.ImportGroupMemberData> importGroupMemberData : partition) {
|
|
|
+ importGroupMember.setMemberList(importGroupMemberData);
|
|
|
+ imPluginContext.getPluginService().importGroupMember(importGroupMember);
|
|
|
+ }
|
|
|
imGroupDao.updateImportStatusSuccess(imGroup.getId());
|
|
|
} catch (Exception e) {
|
|
|
log.error(String.format("群迁移失败,失败群组:%s", JSON.toJSONString(imGroup)));
|