feat：企微标签打标签改为消息队列

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

@@ -484,12 +484,12 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
             }
 
             JSONObject jsonObject = new JSONObject();
-            jsonObject.put("corpid",wxEnterprise.getCorpid());
+            jsonObject.put("corpid", wxEnterprise.getCorpid());
             jsonObject.put("suiteId", wxSuiteid);
-            jsonObject.put("wxUserId",wxUserId);
-            jsonObject.put("externalUserId",externalUserId);
-            jsonObject.put("needSetTags",StringUtils.join(needSetTags,","));
-            jsonObject.put("needDelTags",StringUtils.join(needDelTags,","));
+            jsonObject.put("wxUserId", wxUserId);
+            jsonObject.put("externalUserId", externalUserId);
+            jsonObject.put("needSetTags", StringUtils.join(needSetTags, ","));
+            jsonObject.put("needDelTags", StringUtils.join(needDelTags, ","));
             GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
             try {
                 clientInstance.sendMessage("qywxMarkTagMq", jsonObject.toJSONString());
@@ -570,14 +570,14 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
         }
         Map<String, Set<String>> externalTagMap = getExternalTagMap(externalUseridInfo, wxEnterpriseId);
         if (MapUtils.isEmpty(externalTagMap)) {
-            logger.info("该用户没有不存在好友关系，获取不到关联导购打的标签，：externalUseridInfo:{}",externalUseridInfo);
+            logger.info("该用户没有不存在好友关系，获取不到关联导购打的标签，：externalUseridInfo:{}", externalUseridInfo);
             resp.setMessage("该用户没有不存在好友关系，获取不到关联导购打的标签");
             return resp;
         }
         //当前操作用户企业打的标签
         Set<String> staffChangeTagKeys = externalTagMap.get(wxUserId);
         if (CollectionUtils.isEmpty(staffChangeTagKeys)) {
-            logger.info("该用户没有不存在好友关系，获取不到关联导购打的标签,wxUserId:{}",wxUserId);
+            logger.info("该用户没有不存在好友关系，获取不到关联导购打的标签,wxUserId:{}", wxUserId);
             resp.setMessage("该用户没有不存在好友关系，获取不到关联导购打的标签");
             return resp;
         }
@@ -586,7 +586,7 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
         //获取该外部联系人的所有会员
         List<TabHaobanExternalClerkRelated> clerkRelateds = externalClerkRelatedService.listExternalByExternalUserid(wxEnterpriseId, externalUserId);
         if (CollectionUtils.isEmpty(clerkRelateds)) {
-            logger.info("该用户没关联对应的好友：{}",externalUserId);
+            logger.info("该用户没关联对应的好友：{}", externalUserId);
             resp.setMessage("该用户没关联对应的好友");
             return resp;
         }
@@ -932,8 +932,7 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
         String externalUserId = jsonObject.getString("externalUserId");
         String needSetTags = jsonObject.getString("needSetTags");
         String needDelTags = jsonObject.getString("needDelTags");
-        String key = "HAOBAN:QYWX:TAG:"+wxUserId+externalUserId;
-        //重试5次
+        String key = "HAOBAN:QYWX:TAG:" + wxUserId + externalUserId;
         Integer currentTimes = Convert.toInt(RedisUtil.getCache(key), 0);
         if (currentTimes > MAX_TIMES) {
             logger.error("企微打标签超过最大次数，key：{}", key);
@@ -945,7 +944,7 @@ public class QywxTagApiServiceImpl implements QywxTagApiService {
             logger.info("权限不对，重试三次:{},{}", wxUserId, externalUserId);
             GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
             try {
-                clientInstance.sendMessage("qywxMarkTagMq", jsonObject.toJSONString(),30);
+                clientInstance.sendMessage("qywxMarkTagMq", jsonObject.toJSONString(), 30);
             } catch (Exception e) {
                 logger.info("企微标签同步qywxMarkTagMq发送失败：{}", e.getMessage(), e);
             }