订阅消息调整

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/dto/MemberUnionidWechatAccountQDTO.java

@@ -30,6 +30,16 @@ public class MemberUnionidWechatAccountQDTO implements Serializable {
      */
     private String sceneStr;
 
+    private boolean eventFlag = false ;
+
+    public boolean isEventFlag() {
+        return eventFlag;
+    }
+
+    public void setEventFlag(boolean eventFlag) {
+        this.eventFlag = eventFlag;
+    }
+
     public String getEnterpriseId() {
         return enterpriseId;
     }

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

@@ -26,5 +26,7 @@ public interface HaobanCommonMQApiService {
     public void memberEventMerge(String params) ;
     // 会员注销
     public void memberEventDel(String params) ;
+    // 会员扫码关注
+    public void memberEventWechat(String params) ;
 
 }

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

@@ -2,9 +2,12 @@ package com.gic.haoban.manage.service.service.out.impl;
 
 import java.util.Map;
 
+import com.gic.commons.util.StringUtil;
+import com.gic.haoban.manage.api.dto.MemberUnionidWechatAccountQDTO;
 import com.gic.haoban.manage.api.service.ExternalClerkRelatedApiService;
 import com.gic.haoban.manage.service.util.EventUtils;
 import com.gic.member.api.dto.MemberInfoChangeNotifyDTO;
+import com.gic.member.api.dto.event.wechat.WeChatOfficialAccountEventParam;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -167,4 +170,38 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
         String enterpriseId = json.getString("enterpriseId") ;
         this.externalClerkRelatedApiService.delByMemberIdAndEnterpriseIdEvent(memberId, enterpriseId, null, 0);
     }
+
+    @Override
+    public void memberEventWechat(String params) {
+        if(!EventUtils.isOpenEvent()) {
+            return ;
+        }
+        log.info("会员扫码关注事件={}",params);
+        WeChatOfficialAccountEventParam json = JSONObject.parseObject(params,WeChatOfficialAccountEventParam.class) ;
+        String memberId = json.getMemberId() ;
+        String unionid = null ;
+        if (StringUtil.isBlankVerifyMinusOne(memberId) || StringUtil.isBlankVerifyMinusOne(unionid)) {
+            log.warn("memberId、unionid为空，不通知");
+            return;
+        }
+        String enterpriseId = json.getEnterpriseId() ;
+        String openId = json.getOpenId() ;
+        String qrcodeParam = json.getQrCode() ;
+        try {
+            MemberUnionidWechatAccountQDTO dto = new MemberUnionidWechatAccountQDTO();
+            dto.setEnterpriseId(enterpriseId);
+            dto.setUnionid(unionid);
+            dto.setOpenId(openId);
+            dto.setSceneStr(qrcodeParam);
+            dto.setMemberId(memberId);
+            dto.setEventFlag(true);
+            if (qrcodeParam != null && qrcodeParam.startsWith("QWHY")) {
+                GICMQClientUtil.getClientInstance().sendMessage("addMemberUnionidWechatAccountByClerkMq", JSON.toJSONString(dto));
+            } else {
+                GICMQClientUtil.getClientInstance().sendMessage("addMemberUnionidWechatAccountMq", JSON.toJSONString(dto));
+            }
+        } catch (Exception e) {
+            log.error("通知好办失败", e);
+        }
+    }
 }

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

@@ -11,6 +11,7 @@ import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
+import com.gic.haoban.manage.service.util.EventUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
@@ -1640,6 +1641,16 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
             return;
         }
         MemberUnionidWechatAccountQDTO memberUnionidWechatAccountQDTO = JSON.parseObject(res, MemberUnionidWechatAccountQDTO.class);
+        boolean eventFlag = memberUnionidWechatAccountQDTO.isEventFlag() ;
+        if(EventUtils.isOpenEvent()) {
+            if(!eventFlag) {
+                return ;
+            }
+        }else {
+            if(eventFlag) {
+                return ;
+            }
+        }
         String enterpriseId = memberUnionidWechatAccountQDTO.getEnterpriseId();
         String unionid = memberUnionidWechatAccountQDTO.getUnionid();
         String openId = memberUnionidWechatAccountQDTO.getOpenId();
@@ -1717,6 +1728,16 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
             return;
         }
         MemberUnionidWechatAccountQDTO memberUnionidWechatAccountQDTO = JSON.parseObject(res, MemberUnionidWechatAccountQDTO.class);
+        boolean eventFlag = memberUnionidWechatAccountQDTO.isEventFlag() ;
+        if(EventUtils.isOpenEvent()) {
+            if(!eventFlag) {
+                return ;
+            }
+        }else {
+            if(eventFlag) {
+                return ;
+            }
+        }
         String enterpriseId = memberUnionidWechatAccountQDTO.getEnterpriseId();
         String unionid = memberUnionidWechatAccountQDTO.getUnionid();
         String openId = memberUnionidWechatAccountQDTO.getOpenId();