拆分队列

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/HaobanCommonMQApiService.java

@@ -2,6 +2,8 @@ package com.gic.haoban.manage.api.service;
 
 import com.gic.haoban.manage.api.dto.CommonMQDTO;
 
+import java.util.List;
+
 /**
  * 
 * @ClassName: HaobanCommonMQApiService
@@ -20,4 +22,8 @@ public interface HaobanCommonMQApiService {
     
     public void welcomeMQ(String params) ;
 
+    public void putToNoticeMemberMQ(String enterpriseId, List<String> memberIdList) ;
+
+    public void noticeMemberMQ(String params) ;
+
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/StaffClerkRelationService.java

@@ -16,6 +16,8 @@ public interface StaffClerkRelationService {
   
     boolean delBind(String clerkId, String optStaffId, int channelCode , String newClerkId , String wxEnterpriseId);
 
+    void delMemberQywxFlag(String enterpriseId, List<String> memberIds) ;
+
     /**
      * 解绑-删除绑定（门店级别）
      *

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

@@ -89,8 +89,6 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
     private MemberApiService memberApiService;
     @Autowired
     private ClerkService clerkService;
-    @Autowired
-    private RightService rightService;
 
     @Override
     public List<StaffClerkRelationDTO> listBindCode(String wxEnterpriseId, String enterpriseId, Set<String> clerkCodeList) {
@@ -209,7 +207,8 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
             //删除 并设置主门店
             clerkMainStoreRelatedService.delMainStore(staffId, storeId, wxEnterpriseId);
             //推入日志
-            delMemberQywxFlag(enterpriseId, memberIds); 
+            // delMemberQywxFlag(enterpriseId, memberIds);
+            this.haobanCommonMQApiService.putToNoticeMemberMQ(enterpriseId,memberIds);
         }
         if(needFlush) {
             logger.info("解绑自动刷新好友,staffId={}",staffId);
@@ -222,7 +221,7 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
     }
 
 
-    private void delMemberQywxFlag(String enterpriseId, List<String> memberIds) {
+    public void delMemberQywxFlag(String enterpriseId, List<String> memberIds) {
         for (String memberId : memberIds) {
             //解绑通知会员
             int count = externalClerkRelatedService.getCountByMemberId(memberId);
@@ -267,7 +266,8 @@ public class StaffClerkRelationServiceImpl implements StaffClerkRelationService
             String enterpriseId = staffClerkRelation.getEnterpriseId();
             //删除好友通知会员
             List<String> memberIds = externalClerkRelatedService.getByStoreIdAndStaffId(staffClerkRelation.getStoreId(), staffClerkRelation.getStaffId());
-            delMemberQywxFlag(enterpriseId, memberIds);
+            // delMemberQywxFlag(enterpriseId, memberIds);
+            this.haobanCommonMQApiService.putToNoticeMemberMQ(enterpriseId,memberIds);
         }
 
         List<String> need = needUnbind.stream().map(tab -> tab.getStaffClerkRelationId()).collect(Collectors.toList());

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

 package com.gic.haoban.manage.service.service.out.impl;
 
+import java.util.List;
 import java.util.Map;
 
+import com.alibaba.fastjson.JSONArray;
+import com.gic.haoban.manage.service.service.StaffClerkRelationService;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -35,6 +38,8 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     private WelcomeSendService welcomeSendService;
     @Autowired
     private MemberOpenCardBusinessService memberOpenCardBusinessService ;
+    @Autowired
+    private StaffClerkRelationService staffClerkRelationService ;
 
     @Override
     public void putCommonMessage(CommonMQDTO dto) {
@@ -106,4 +111,24 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     public void welcomeMQ(String params) {
         this.welcomeSendService.sendWelcome(params);
     }
+
+    @Override
+    public void noticeMemberMQ(String params) {
+        JSONObject json = JSONObject.parseObject(params) ;
+        String enterpriseId = json.getString("enterpriseId") ;
+        List<String> memberIdList = JSONArray.parseArray(json.getString("memberIdList"),String.class) ;
+        this.staffClerkRelationService.delMemberQywxFlag(enterpriseId,memberIdList) ;
+    }
+
+    @Override
+    public void putToNoticeMemberMQ(String enterpriseId, List<String> memberIdList) {
+        JSONObject json = new JSONObject() ;
+        json.put("enterpriseId",enterpriseId) ;
+        json.put("memberIdList",memberIdList) ;
+        try {
+            mqClient.sendMessage("haobanNoticeMemberMQ", json.toJSONString());
+        } catch (Exception e) {
+            log.error("发送MQ异常");
+        }
+    }
 }