订阅消息调整

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

@@ -180,6 +180,8 @@ public interface ExternalClerkRelatedApiService {
     // 0 删除会员 1合并会员 2会员换绑
     void delByMemberIdAndEnterpriseId(String memberId, String enterpriseId, String mergeMemberId, int type);
 
+    void delByMemberIdAndEnterpriseIdEvent(String memberId, String enterpriseId, String mergeMemberId, int type);
+
     /**
      * 导购和会员是否好友关系，true是好友
      *

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

@@ -20,4 +20,11 @@ public interface HaobanCommonMQApiService {
     
     public void welcomeMQ(String params) ;
 
+    // 会员换绑
+    public void memberEventChange(String params) ;
+    // 会员合并
+    public void memberEventMerge(String params) ;
+    // 会员注销
+    public void memberEventDel(String params) ;
+
 }

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

@@ -35,6 +35,7 @@ import com.gic.haoban.manage.service.pojo.QywxTagSyncInfoPojo;
 import com.gic.haoban.manage.service.service.ExternalClerkRelatedService;
 import com.gic.haoban.manage.service.service.WxEnterpriseService;
 import com.gic.haoban.manage.service.service.hm.WxUserAddLogService;
+import com.gic.haoban.manage.service.util.EventUtils;
 import com.gic.member.api.dto.MemberDTO;
 import com.gic.member.api.dto.MemberSourceDetailDTO;
 import com.gic.member.api.dto.MemberSourceShowDTO;
@@ -404,8 +405,15 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
         return tabHaobanExternalClerkRelatedMapper.listStoreIdByMemberId(memberId , addCreateTime);
     }
 
-    @Override
     public void delByMemberIdAndEnterpriseId(String memberId, String enterpriseId, String mergeMemberId, int type) {
+        if(EventUtils.isOpenEvent()) {
+            return ;
+        }
+        this.delByMemberIdAndEnterpriseIdEvent(memberId,enterpriseId,mergeMemberId,type);
+    }
+
+    @Override
+    public void delByMemberIdAndEnterpriseIdEvent(String memberId, String enterpriseId, String mergeMemberId, int type) {
        // 0 删除会员 1合并会员 2会员换绑
        if(type==0) {
            log.info("删除会员,memberId：{}", memberId);
@@ -445,7 +453,7 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
            }
        }
     }
-    
+
     @Override
     public void delByMemberIdAndEnterpriseId(String memberId, String enterpriseId, String mergeMemberId) {
         log.info("删除会员或者合并会员,memberId:{},enterpriseId:{},mergeMemberId:{}", memberId, enterpriseId, mergeMemberId);

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

@@ -2,6 +2,9 @@ package com.gic.haoban.manage.service.service.out.impl;
 
 import java.util.Map;
 
+import com.gic.haoban.manage.api.service.ExternalClerkRelatedApiService;
+import com.gic.haoban.manage.service.util.EventUtils;
+import com.gic.member.api.dto.MemberInfoChangeNotifyDTO;
 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 ExternalClerkRelatedApiService externalClerkRelatedApiService ;
 
     @Override
     public void putCommonMessage(CommonMQDTO dto) {
@@ -106,4 +111,60 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     public void welcomeMQ(String params) {
         this.welcomeSendService.sendWelcome(params);
     }
+
+    @Override
+    public void memberEventChange(String params) {
+        if(!EventUtils.isOpenEvent()) {
+            return ;
+        }
+        log.info("会员换绑事件={}",params);
+        JSONObject json = JSONObject.parseObject(params) ;
+        String memberId = json.getString("memberId") ;
+        String enterpriseId = json.getString("enterpriseId") ;
+        String changeBindMemberId = json.getString("changeBindMemberId") ;
+        this.externalClerkRelatedApiService.delByMemberIdAndEnterpriseIdEvent(memberId,enterpriseId,changeBindMemberId,2);
+    }
+
+    @Override
+    public void memberEventMerge(String params) {
+        if(!EventUtils.isOpenEvent()) {
+            return ;
+        }
+        log.info("会员合并事件={}",params);
+        JSONObject json = JSONObject.parseObject(params) ;
+        String memberId = json.getString("memberId") ;
+        String enterpriseId = json.getString("enterpriseId") ;
+        JSONObject delMemberObj = json.getJSONObject("delMember") ;
+        if(null == delMemberObj) {
+            log.info("删除会员为空,不处理");
+            return ;
+        }
+        String delMemberId = delMemberObj.getString("memberId") ;
+        this.externalClerkRelatedApiService.delByMemberIdAndEnterpriseIdEvent(delMemberId, enterpriseId, memberId, 1);
+
+        // 内容中台
+        MemberInfoChangeNotifyDTO dto = new MemberInfoChangeNotifyDTO();
+        dto.setMemberId(delMemberId);
+        dto.setMergeMemberId(memberId);
+        dto.setEnterpriseId(enterpriseId);
+        dto.setOpt(2);
+        try {
+            GICMQClientUtil.getClientInstance().sendMessage("memberIdChangeNotify", JSON.toJSONString(dto));
+        } catch (Exception ex) {
+            throw new RuntimeException(ex);
+        }
+
+    }
+
+    @Override
+    public void memberEventDel(String params) {
+        if(!EventUtils.isOpenEvent()) {
+            return ;
+        }
+        log.info("会员注销事件={}",params);
+        JSONObject json = JSONObject.parseObject(params) ;
+        String memberId = json.getString("memberId") ;
+        String enterpriseId = json.getString("enterpriseId") ;
+        this.externalClerkRelatedApiService.delByMemberIdAndEnterpriseIdEvent(memberId, enterpriseId, null, 0);
+    }
 }

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

+package com.gic.haoban.manage.service.util;
+
+import com.gic.redis.data.util.RedisUtil;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+public class EventUtils {
+
+    private static Logger log = LogManager.getLogger(EventUtils.class);
+
+    public static boolean isOpenEvent() {
+        Object o = RedisUtil.getCache("open-marketing-member-event") ;
+        if(null == o) {
+            log.info("未开启事件-好办");
+            return false ;
+        }
+        log.info("开启事件-好办");
+        return true ;
+    }
+
+}