|
@@ -924,7 +924,7 @@ public class ImGroupServiceImpl extends BaseServiceImpl<String, ImGroup> impleme
|
|
} catch (ParseException e) {
|
|
} catch (ParseException e) {
|
|
throw new BizException("时间区间参数错误,格式为:yyyy-MM-dd");
|
|
throw new BizException("时间区间参数错误,格式为:yyyy-MM-dd");
|
|
}
|
|
}
|
|
- Lists.partition(rows,20).parallelStream().forEach(this::groupTransfer);
|
|
|
|
|
|
+ Lists.partition(rows,10).parallelStream().forEach(this::groupTransfer);
|
|
importImGroupCount += rows.size();
|
|
importImGroupCount += rows.size();
|
|
log.info("------------------------------- import im group --------------------------------------------");
|
|
log.info("------------------------------- import im group --------------------------------------------");
|
|
log.info("import im group success count:{}/{}", importImGroupCount, total);
|
|
log.info("import im group success count:{}/{}", importImGroupCount, total);
|