feat: 分享日志log

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/message/InteractRecordMessageListener.java

 package com.gic.haoban.manage.service.service.content.message;
 
 import com.alibaba.fastjson.JSON;
+import com.gic.haoban.manage.api.enums.content.MaterialInteractRecordEventType;
 import com.gic.haoban.manage.service.pojo.bo.content.message.InteractRecordMessageBO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.listener.MessageListener;
-import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @Author MUSI
@@ -20,6 +23,13 @@ public class InteractRecordMessageListener implements MessageListener<String, St
     @Autowired
     InteractRecordMessageService interactRecordMessageService;
 
+    private static final List<Integer> dealEventType = new ArrayList<>();
+
+    static {
+        dealEventType.add(MaterialInteractRecordEventType.VISIT_PRODUCT.getCode());
+        dealEventType.add(MaterialInteractRecordEventType.VISIT_MATERIAL.getCode());
+    }
+
     @Override
     public void onMessage(ConsumerRecord<String, String> consumerRecord) {
         String value = consumerRecord.value();
@@ -30,6 +40,10 @@ public class InteractRecordMessageListener implements MessageListener<String, St
             log.info("互动记录解析异常 {}", value);
             return;
         }
+        if (recordMessageBO.getEventType() == null || !dealEventType.contains(recordMessageBO.getEventType())) {
+            log.info("素材埋点事件类型非 素材相关类型 {}", recordMessageBO.getEventType());
+            return;
+        }
         interactRecordMessageService.dealRecord(recordMessageBO);
     }
 }

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

@@ -50,6 +50,7 @@ public class MaterialShareLogApiServiceImpl implements MaterialShareLogApiServic
             sharePYQ.setShareLogId(logId);
             triggerCustomerDetailLog.setSharePYQ(sharePYQ);
             try{
+                log.info("分享朋友圈日志 MQ {}", JSON.toJSONString(triggerCustomerDetailLog));
                 GICMQClientUtil.getClientInstance().sendMessage(SHARE_MATERIAL_DETAIL_LOG, JSON.toJSONString(triggerCustomerDetailLog));
             }catch (Exception ex){
                 log.warn("客户分享素材 触达日志MQ异常 {}", JSON.toJSONString(triggerCustomerDetailLog), ex);