删除好友事件

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/MemberUnionidRelatedApiServiceImpl.java

@@ -1077,6 +1077,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
             log.info("查询TabHaobanWxEnterprise为空：{}", corpId);
             return;
         }
+        this.deleteToEvent(wxEnterprise.getWxEnterpriseId(),dto.getExternalUserid()) ;
         String wxEnterpriseId = wxEnterprise.getWxEnterpriseId();
         dto.setWxEnterpriseId(wxEnterpriseId);
         TabHaobanStaff staff = this.staffMapper.selectByUserIdAndEnterpriseId(wxUserId, wxEnterpriseId);
@@ -1089,6 +1090,28 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
         externalClerkRelatedService.delByUserIdAndExternalUserId(dto);
     }
 
+
+    private void deleteToEvent(String wxEnterpriseId, String externalUserId) {
+        GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+        try {
+            JSONObject msgBody = new JSONObject();
+            msgBody.put("wxEnterpriseId", wxEnterpriseId);
+            msgBody.put("externalUserId", externalUserId);
+            String event = "deleteQwExternalUserEvent";
+            String topic = "member";
+            SubscribeMessageDTO subscribeMessageDTO = new SubscribeMessageDTO();
+            subscribeMessageDTO.setEvent(event);
+            subscribeMessageDTO.setTopic(topic);
+            subscribeMessageDTO.setMsgBody(msgBody.toJSONString());
+            String msg =  JSONObject.toJSONString(subscribeMessageDTO) ;
+            log.info("删除外部联系人事件={}",msg);
+            clientInstance.sendMessage("deleteQwExternalUserEvent",msg);
+        } catch (Exception e) {
+            log.info("删除外部联系：{}", e.getMessage(), e);
+        }
+    }
+
+
     private void editMemberUnionidRelatedProcess(MemberUnionidRelatedDTO dto, String wxUserId) {
         log.info("修改标签/会员信息回调：{}", JSONObject.toJSONString(dto));
         TabHaobanWxEnterprise wxEnterprise = wxEnterpriseService.getEnterpriseBycorpId(dto.getCorpid());