traceId

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/KafkaMessageServiceImpl.java

@@ -5,6 +5,7 @@ import com.gic.binlog.base.entity.GicField;
 import com.gic.binlog.base.entity.GicRecord;
 import com.gic.binlog.base.entity.enums.GicRecordType;
 import com.gic.commons.util.EntityUtil;
+import com.gic.dubbo.entity.ProviderLocalTag;
 import com.gic.haoban.contacts.manage.api.enums.StatusEnum;
 import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
 import com.gic.haoban.manage.service.pojo.BinlogBasePojo;
@@ -39,6 +40,9 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
 
     @Override
     public void onMessage(ConsumerRecord<String, GicRecord> record) {
+        ProviderLocalTag providerLocalTag = ProviderLocalTag.tag.get();
+        providerLocalTag.traceId = UUID.randomUUID().toString();
+
         logger.info("message：{}", JSONObject.toJSONString(record.value()));
         if(record.value()==null){
             logger.info("数据为空");