Commit fb65ba3a by 王祖波

获取eventType对象修改

parent f550a5bd
...@@ -44,9 +44,6 @@ public class InteractRecordMessageListener implements MessageListener<String, St ...@@ -44,9 +44,6 @@ public class InteractRecordMessageListener implements MessageListener<String, St
ProviderLocalTag providerLocalTag = ProviderLocalTag.tag.get(); ProviderLocalTag providerLocalTag = ProviderLocalTag.tag.get();
providerLocalTag.traceId = UUID.randomUUID().toString(); providerLocalTag.traceId = UUID.randomUUID().toString();
String value = consumerRecord.value(); String value = consumerRecord.value();
log.info("【InteractRecordMessageListener】处理埋点事件 {}", value);
InteractRecordMessageBO recordMessageBO = messageConvertHelper.convertMessageBo(value); InteractRecordMessageBO recordMessageBO = messageConvertHelper.convertMessageBo(value);
if (recordMessageBO == null) { if (recordMessageBO == null) {
......
...@@ -139,7 +139,7 @@ public class InteractRecordMessageService { ...@@ -139,7 +139,7 @@ public class InteractRecordMessageService {
// 组装扩展信息 // 组装扩展信息
if (MaterialInteractRecordEventType.VISIT_PRODUCT.getCode() if (MaterialInteractRecordEventType.VISIT_PRODUCT.getCode()
.equals(interactRecordBO.getEventType()) .equals(interactRecordBO.getEventType())
|| MaterialInteractRecordEventType.ADD_SHOPPING_CART.getCode().equals(interactRecordBO.getEventType())) { || MaterialInteractRecordEventType.ADD_SHOPPING_CART.getCode().equals(interactRecordMessageBO.getEventType())) {
if (MaterialInteractRecordEventType.ADD_SHOPPING_CART.getCode().equals(interactRecordBO.getEventType()) if (MaterialInteractRecordEventType.ADD_SHOPPING_CART.getCode().equals(interactRecordBO.getEventType())
&& !MaterialInteractRecordEventType.ADD_SHOPPING_CART.getCode().equals(oldEventType)) { && !MaterialInteractRecordEventType.ADD_SHOPPING_CART.getCode().equals(oldEventType)) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment