Merge branch 'master_xgh_加好友队列调整' into 'master'

Master xgh 加好友队列调整

See merge request !950

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

@@ -382,16 +382,32 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
         DealQywxExternalUserPojo dealQywxExternalUserPojo = new DealQywxExternalUserPojo();
         dealQywxExternalUserPojo.setType(DealQywxExternalUserPojo.DealType.add.getType());
         dealQywxExternalUserPojo.setData(dto);
-
+        
         GicMQClient instance = GICMQClientUtil.getClientInstance();
+        String mqName = "dealQywxExternalUserMq" ;
+        if(this.mqCheck(dto)) {
+            mqName = "dealQywxExternalUserMq2";
+        }
         try {
-            instance.sendMessage("dealQywxExternalUserMq", JSONObject.toJSONString(dealQywxExternalUserPojo));
+            instance.sendMessage(mqName, JSONObject.toJSONString(dealQywxExternalUserPojo));
         } catch (Exception e) {
             log.info("异步处理异常：{}", e);
         }
         return null;
     }
-
+    
+    private boolean mqCheck(QwFrientNoticeDTO dto) {
+        boolean flag = false ;
+        Object obj = RedisUtil.getCache("dealQywxExternalUserMq2") ;
+        if(null != obj) {
+            String str = obj.toString() ;
+            String corpid = dto.getCorpid() ;
+            if(StringUtils.isNotBlank(corpid) && str.contains(corpid)) {
+                flag = true ;
+            }
+        }
+        return flag ;
+    }
 
     @Override
     public String addMemberUnionidRelatedNew(MemberUnionidRelatedDTO dto, String wxUserId) {