Merge branch 'feature/社群' into 'developer'

Feature/社群

See merge request !839

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatServiceImpl.java

@@ -127,7 +127,7 @@ public class GroupChatServiceImpl implements GroupChatService {
     // 每次拉取成员数
     private int pageSize = 100;
     // 每次拉取群数
-    private int limit = 1;
+    private int limit = 1000;
     // 群下线成员数
     private int offNum = 200;
 
@@ -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) {
@@ -632,7 +634,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                 chat.setOriginalStaffId(oldStaffId);
                 this.groupChatMapper.update(chat);
                 if (StringUtils.isBlank(chat.getWxChatIdDk())) {
-                    this.updateWxChatIdDk(wxEnterpriseId, staff.getStaffId());
+                    //this.updateWxChatIdDk(wxEnterpriseId, staff.getStaffId());
                 }
                 this.saveOwner(wxEnterpriseId, staff.getStaffId());
                 RedisUtil.unlock(lockKey);