导购为空不处理

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

@@ -15,6 +15,7 @@ import org.springframework.kafka.listener.MessageListener;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 import java.util.UUID;
 
 /**
@@ -62,6 +63,11 @@ public class InteractRecordMessageListener implements MessageListener<String, St
             return;
         }
         dataConvert(recordMessageBO);
+        String clerkId = recordMessageBO.getClerkId();
+        if (StringUtils.isBlank(clerkId) || Objects.equals(clerkId, "-1")) {
+            log.info("导购为空不处理:{}", clerkId);
+            return;
+        }
         interactRecordMessageService.dealRecord(recordMessageBO);
     }