feature: 埋点数据

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/pojo/bo/content/message/InteractRecordMessageBO.java

@@ -86,4 +86,6 @@ public class InteractRecordMessageBO implements Serializable {
      * @see com.gic.haoban.manage.api.enums.content.ShareBizType
      */
     private Integer bizType;
+
+    private String appKey;
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/content/adaptor/MessageConvertHelper.java

@@ -31,6 +31,10 @@ public class MessageConvertHelper {
             return null;
         }
         InteractRecordMessageBO interactRecordMessageBO = new InteractRecordMessageBO();
+
+        String appKey = jsonObject.getString("app_key");
+        interactRecordMessageBO.setAppKey(appKey);
+
         String enterpriseId = jsonObject.getString("merch_id");
         interactRecordMessageBO.setEnterpriseId(enterpriseId);
 

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.ctrip.framework.apollo.Config;
+import com.ctrip.framework.apollo.ConfigService;
 import com.gic.dubbo.entity.ProviderLocalTag;
 import com.gic.haoban.manage.api.enums.content.MaterialInteractRecordEventType;
 import com.gic.haoban.manage.service.pojo.bo.content.message.InteractRecordMessageBO;
@@ -44,11 +46,20 @@ public class InteractRecordMessageListener implements MessageListener<String, St
         String value = consumerRecord.value();
         log.info("【InteractRecordMessageListener】处理埋点事件 {}", value);
 
+
+
         InteractRecordMessageBO recordMessageBO = messageConvertHelper.convertMessageBo(value);
         if (recordMessageBO == null) {
             log.info("互动记录解析异常 {}", value);
             return;
         }
+        // 过滤环境
+        Config config = ConfigService.getAppConfig();
+        String envKey = config.getProperty("bury.point.env.app.key", "");
+        if (!StringUtils.equalsIgnoreCase(envKey, recordMessageBO.getAppKey())) {
+            log.info("埋点数据环境正确 config.env: {}, appKey: {}", envKey, recordMessageBO.getAppKey());
+            return;
+        }
         if (recordMessageBO.getEventType() == null || !dealEventType.contains(recordMessageBO.getEventType())) {
             log.info("埋点事件类型非相关类型 {}", recordMessageBO.getEventType());
             return;