feat: 销售线索链路traceId

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.dubbo.entity.ProviderLocalTag;
 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;
@@ -11,6 +12,7 @@ import org.springframework.kafka.listener.MessageListener;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.UUID;
 
 /**
  * @Author MUSI
@@ -33,8 +35,9 @@ public class InteractRecordMessageListener implements MessageListener<String, St
 
     @Override
     public void onMessage(ConsumerRecord<String, String> consumerRecord) {
+        ProviderLocalTag providerLocalTag = ProviderLocalTag.tag.get();
+        providerLocalTag.traceId = UUID.randomUUID().toString();
         String value = consumerRecord.value();
-
         log.info("【InteractRecordMessageListener】处理埋点事件 {}", value);
         InteractRecordMessageBO recordMessageBO = JSON.parseObject(value, InteractRecordMessageBO.class);
         if (recordMessageBO == null) {