fix：加好友改为消息队列

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

@@ -220,12 +220,11 @@ public interface MemberUnionidRelatedApiService {
 
     /**
      * 关注公共号-会员回调好办关联好友（通过公共号二维码带参数）
-     *
-     * @param memberUnionidWechatAccountQDTO 成员unionid qdto微信帐户
-     * @return {@link ServiceResponse<Boolean> }
+     * "routerName"：addMemberUnionidWechatAccountByClerkMq
+     * @param res res
      * @author mozhu
-     * @date 2022-01-22 17:06:24
+     * @date 2022-02-21 14:56:25
      */
-    ServiceResponse addMemberUnionidWechatAccountByClerk(MemberUnionidWechatAccountQDTO memberUnionidWechatAccountQDTO);
+    void addMemberUnionidWechatAccountByClerk(String res);
 
 }

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

@@ -537,7 +537,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
             String sceneStr = "QWHY_" + relationKey + "_" + clerkId;
             //30天失效
             QRcodeDTO qRcodePic = imageService.getQRcodePic(enterpriseId, sceneStr, 2592000);
-            log.info("参数的公众号二维码返回：{}",JSON.toJSONString(qRcodePic));
+            log.info("参数的公众号二维码返回：{}", JSON.toJSONString(qRcodePic));
             if (qRcodePic != null) {
                 String downloadUrl = qRcodePic.getPicUploadResDTO().downloadUrl;
                 String[] arr = downloadUrl.split("/");
@@ -550,7 +550,7 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
                 }
             }
         } else if (friendSettingType.equals(FriendSettingTypeEnum.TEXT_AND_MINI_PROGRAM.getCode())) {
-            log.info("发送小程序：wxEnterpriseId:{},sendApp:{}", wxEnterpriseId,sendApp);
+            log.info("发送小程序：wxEnterpriseId:{},sendApp:{}", wxEnterpriseId, sendApp);
             //发送小程序
             if (sendApp) {
                 TabMiniprogramSetting miniprogramSetting = miniprogramSettingService.getMiniprogramSetting(wxEnterpriseId, enterpriseId);
@@ -1756,6 +1756,10 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
     @Override
     public void addMemberUnionidWechatAccount(String res) {
         log.info("通过查询unionid关联导购对外联系人id接口,res:{}", res);
+        if (StringUtils.isBlank(res)) {
+            log.info("通过查询unionid关联导购对外联系人id接口为空");
+            return;
+        }
         MemberUnionidWechatAccountQDTO memberUnionidWechatAccountQDTO = JSON.parseObject(res, MemberUnionidWechatAccountQDTO.class);
         String enterpriseId = memberUnionidWechatAccountQDTO.getEnterpriseId();
         String unionid = memberUnionidWechatAccountQDTO.getUnionid();
@@ -1818,31 +1822,36 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
     }
 
     @Override
-    public ServiceResponse addMemberUnionidWechatAccountByClerk(MemberUnionidWechatAccountQDTO memberUnionidWechatAccountQDTO) {
-        log.info("关注公共号-会员回调好办关联好友请求参数：{}", JSON.toJSONString(memberUnionidWechatAccountQDTO));
+    public void addMemberUnionidWechatAccountByClerk(String res) {
+        log.info("关注公共号-会员回调好办关联好友请求参数：{}", res);
+        if (StringUtils.isBlank(res)) {
+            log.info("关注公共号-会员回调好办关联好友请求参数为空");
+            return;
+        }
+        MemberUnionidWechatAccountQDTO memberUnionidWechatAccountQDTO = JSON.parseObject(res, MemberUnionidWechatAccountQDTO.class);
         String enterpriseId = memberUnionidWechatAccountQDTO.getEnterpriseId();
         String unionid = memberUnionidWechatAccountQDTO.getUnionid();
         String openId = memberUnionidWechatAccountQDTO.getOpenId();
         String memberId = memberUnionidWechatAccountQDTO.getMemberId();
         String sceneStr = memberUnionidWechatAccountQDTO.getSceneStr();
-        ServiceResponse serviceResponse = new ServiceResponse();
         if (StringUtils.isAnyBlank(enterpriseId, unionid, openId, memberId, sceneStr)) {
             log.error("关注公共号-会员回调好办关联好友，有参数为空:enterpriseId:{},unionid:{},openId:{},memberId:{},sceneStr:{}", enterpriseId, unionid, openId, memberId, sceneStr);
-            serviceResponse.setCode(0);
-            serviceResponse.setMessage("参数为空");
-            return serviceResponse;
+            return;
         }
         String[] s = sceneStr.split("_");
         String relationKey = s[1];
         TabHaobanExternalClerkRelated externalClerkRelated = externalClerkRelatedMapper.getByRelationKey(relationKey);
         if (externalClerkRelated == null) {
-            log.error("关注公共号-会员回调好办关联好友,未查询到,relationKey：{}",relationKey);
-            serviceResponse.setCode(0);
-            serviceResponse.setMessage("未查询到好友关系");
-            return serviceResponse;
+            log.error("关注公共号-会员回调好办关联好友,未查询到,relationKey：{}", relationKey);
+            GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+            try {
+                clientInstance.sendMessage("addMemberUnionidWechatAccountByClerkMq", res,5);
+            } catch (Exception e) {
+                log.info("发送消息异常：{}", e.getMessage());
+            }
+            return;
         }
         externalClerkRelatedApiService.bindMemberIdExternalById(externalClerkRelated.getExternalClerkRelatedId(), enterpriseId, memberId, unionid);
-        return serviceResponse;
     }
 
     /**