修改配置

fs-service/src/main/java/com/fs/ad/service/impl/AdHtmlClickLogServiceImpl.java

@@ -355,6 +355,9 @@ public class AdHtmlClickLogServiceImpl extends ServiceImpl<AdHtmlClickLogMapper,
         if(type == 2){
             return AD_LOG_KEY + vid + ":" + type + ":" + clickType.getIqiyiType();
         }
+        if(type == 3){
+            return AD_LOG_KEY + vid + ":" + type + ":" + clickType.getDyType();
+        }
         throw new BaseException("错误类型");
     }
 

fs-service/src/main/java/com/fs/qw/service/impl/QwExternalContactServiceImpl.java

@@ -1644,13 +1644,14 @@ public class QwExternalContactServiceImpl extends ServiceImpl<QwExternalContactM
         qwExternalContact.setExternalUserId(externalUserID); // 设置外部联系人ID
         qwExternalContact.setCorpId(corpId);
         qwExternalContact.setCreateTime(new Date());
-
-        try {
-            AdUploadVo vo = AdUploadVo.builder().state(state).type(AdUploadType.ADD_WX).build();
-            logger.info("上传mq:{}", vo);
-            rocketMQTemplate.syncSend("ad-upload", JSON.toJSONString(vo));
-        }catch (Exception e){
-            logger.error("广告回调上传",e);
+        if(StringUtils.isNotEmpty(state)){
+            try {
+                AdUploadVo vo = AdUploadVo.builder().state(state).type(AdUploadType.ADD_WX).build();
+                logger.info("上传mq:{}", vo);
+                rocketMQTemplate.syncSend("ad-upload", JSON.toJSONString(vo));
+            }catch (Exception e){
+                logger.error("广告回调上传",e);
+            }
         }
         try {
             new Thread(() -> {

fs-service/src/main/resources/application-druid-hdt.yml

@@ -147,7 +147,6 @@ rocketmq:
         access-key: default
         secret-key: aZS4z!88dNndKTfhITzTpTxRrVUShtH3
     consumer:
-        topic: ad-upload
-        group: ad-group
+        group: common-group
         access-key: default
         secret-key: aZS4z!88dNndKTfhITzTpTxRrVUShtH3