Commit ed5ae704 by 徐高华

并发控制

parent d783cefa
......@@ -482,7 +482,7 @@ public class GroupChatServiceImpl implements GroupChatService {
if (CollectionUtils.isEmpty(staffList)) {
break;
}
logger.info("查询staff表第{}页,共{}条", pageNum + 1, staffList.size());
logger.info("查询staff表第{}页,共{}条,{}", pageNum + 1, staffList.size(), wxEnterpriseId);
List<String> userIdList = null;
if (qwDTO.needOpenUserIdDk()) {
userIdList = staffList.stream().filter(dto -> StringUtils.isNotBlank(dto.getWxOpenUseId()))
......@@ -565,6 +565,8 @@ public class GroupChatServiceImpl implements GroupChatService {
chat.setQuitCount(0);
chat.setQuitMemberCount(0);
this.groupChatMapper.insert(chat);
} else {
groupChatId = groupChat.getGroupChatId();
}
RedisUtil.unlock(lockKey);
} catch (Exception e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment