Merge branch 'fixbug_0818'

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

@@ -36,6 +36,16 @@ public interface HmQrcodeApiService {
      */
     ServiceResponse addList(HmQrcodeQDTO hmQrcodeQDTO);
 
+
+    /**
+     * 添加好友
+     * addHmQrcodeMq
+     * @param param 参数
+     * @author mozhu
+     * @date 2022-08-16 17:03:19
+     */
+    void addHmQrcode(String param);
+
     /**
      * 更新
      *

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

@@ -7,6 +7,7 @@ import com.gic.clerk.api.dto.ClerkDTO;
 import com.gic.clerk.api.service.ClerkService;
 import com.gic.clerk.api.service.RightService;
 import com.gic.commons.util.EntityUtil;
+import com.gic.commons.util.GICMQClientUtil;
 import com.gic.commons.util.UniqueIdUtils;
 import com.gic.enterprise.api.dto.StoreDTO;
 import com.gic.enterprise.api.service.StoreService;
@@ -45,6 +46,7 @@ import com.gic.log.record.util.GicLogRecordOptTypeEnum;
 import com.gic.member.tag.api.dto.MemberTagDTO;
 import com.gic.member.tag.api.dto.MemberTagItemDTO;
 import com.gic.member.tag.api.service.MemberTagApiService;
+import com.gic.mq.sdk.GicMQClient;
 import com.gic.redis.data.util.RedisUtil;
 import com.gic.wechat.api.dto.qywx.response.QywxResponseDTO;
 import com.gic.wechat.api.dto.qywx.welcome.QywxExternalcontactDTO;
@@ -227,7 +229,14 @@ public class HmQrcodeApiServiceImpl implements HmQrcodeApiService {
         for (String clerkId : clerkIdList) {
             hmQrcodeQDTO.setClerkIdList(Collections.singletonList(clerkId));
             hmQrcodeQDTO.setName("");
-            add(hmQrcodeQDTO);
+
+            GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+            try {
+                logger.info("发送消息到addHmQrcodeMq，{}", clerkId);
+                clientInstance.sendMessage("addHmQrcodeMq", JSON.toJSONString(hmQrcodeQDTO));
+            } catch (Exception e) {
+                logger.info("发送消息到addHmQrcodeMq报错",e);
+            }
         }
 
         setLoggerContext(enterpriseId, wxEnterpriseId, hmQrcodeQDTO.getWebLoginDTO());
@@ -241,6 +250,16 @@ public class HmQrcodeApiServiceImpl implements HmQrcodeApiService {
         return ServiceResponse.success();
     }
 
+    @Override
+    public void addHmQrcode(String param) {
+        if (StringUtils.isBlank(param)) {
+            logger.info("批量新增活码为空");
+            return;
+        }
+        HmQrcodeQDTO hmQrcodeQDTO = JSON.toJavaObject(JSON.parseObject(param), HmQrcodeQDTO.class);
+        add(hmQrcodeQDTO);
+    }
+
     /**
      * 设置日志记录器上下文
      * 日志