会员查询社群接口

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

@@ -12,6 +12,7 @@ import java.util.stream.Collectors;
 
 import com.gic.enterprise.api.dto.StoreDTO;
 import com.gic.enterprise.api.service.StoreService;
+import com.gic.haoban.manage.api.dto.chat.GroupChatUserNoticeDTO;
 import com.gic.haoban.manage.service.dao.mapper.WxEnterpriseMapper;
 import com.gic.haoban.manage.service.service.*;
 import com.gic.haoban.manage.service.service.chat.GroupChatActivityInviteLogService;
@@ -185,6 +186,10 @@ public class GroupChatServiceImpl implements GroupChatService {
             logger.info("群查不到,wxChatid={}", wxChatId);
             return;
         }
+        List<TabGroupChatUser> list = this.groupChatUserMapper.listAllChatUser(wxEnterpriseId,groupChat.getGroupChatId()) ;
+        for(TabGroupChatUser user : list) {
+            this.notice(user.getEnterpriseId(),user.getMemberId(),0);
+        }
         this.groupChatMapper.updateChatStatus(groupChat.getGroupChatId(), 4);
         // 更新群数量
         this.updateOwnerCount(groupChat.getStaffId());
@@ -780,6 +785,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                     TabGroupChatUser user = nowUserMap.get(userId);
                     if (null != user && user.getUserType() == 3) {
                         ++quitMemberCount;
+                        this.notice(enterpriseId,user.getMemberId(),0);
                     }
                 }
             }
@@ -972,6 +978,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                 logger.info("匹配群客户,unionid");
                 user.setMemberId(member.getMemberId());
                 user.setUserType(3);
+                this.notice(enterpriseId,member.getMemberId(),1) ;
             }
         } else if (StringUtils.isNotBlank(externalUserId)) {
             TabHaobanExternalClerkRelated related = this.externalClerkRelatedMapper
@@ -980,6 +987,7 @@ public class GroupChatServiceImpl implements GroupChatService {
                 logger.info("匹配群客户,externalUserId");
                 user.setMemberId(related.getMemberId());
                 user.setUserType(3);
+                this.notice(enterpriseId,related.getMemberId(),1) ;
                 TabGroupChat group = this.groupChatMapper.selectById(groupChatId) ;
                 if(null != group) {
                     this.externalMemberService.updateMemberGrowth(related.getEnterpriseId(),related.getMemberId(), GrowthRuleEnum.ADD_HAOBAN_GROUP.getRuleCode(), "群信息",group.getName() + "(" + groupChatId + ")");
@@ -998,11 +1006,31 @@ public class GroupChatServiceImpl implements GroupChatService {
             Set<Long> groupChatIdList = list.stream().map(dto -> dto.getGroupChatId()).collect(Collectors.toSet());
             groupChatIdList.forEach(groupChatId -> {
                 logger.info("群加会员数={}", groupChatId);
+                this.notice(enterpriseId,memberId,1) ;
                 this.groupChatMapper.addMemberCount(groupChatId);
             });
         }
     }
 
+
+    public void notice(String enterpriseId,String memberId , int addOrQuit) {
+        logger.info("会员群发退群通知={}",memberId,addOrQuit);
+        if(StringUtils.isBlank(enterpriseId) || StringUtils.isBlank(memberId)) {
+            return;
+        }
+        JSONObject json  = new JSONObject() ;
+        GroupChatUserNoticeDTO dto = new GroupChatUserNoticeDTO() ;
+        dto.setEnterpriseId(enterpriseId);
+        dto.setMemberId(memberId);
+        dto.setAddOrQuit(addOrQuit);
+        try {
+            mqClient.sendMessage("qywxAddGroupChatEvent", json.toJSONString());
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+
     private String getWxEnterpriesId(String corpid) {
         TabHaobanWxEnterprise wxEnterprise = this.wxEnterpriseService.getEnterpriseBycorpId(corpid);
         if (wxEnterprise == null) {