过滤状态为0导购

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

@@ -120,7 +120,10 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             staffClerkRelationService.delBind(syncPojo.getClerkId(), "-1", ChannelCodeEnum.SYNC_UNBIND.getCode());
         } else if (gicRecordType.equals(GicRecordType.INSERT)) {
             StaffClerkRelationDTO relationDTO = staffClerkRelationService.getOneBindCodeNoStatus(syncPojo.getEnterpriseId(), syncPojo.getClerkCode());
-            moveOrAddClerk(syncPojo, relationDTO);
+            if (syncPojo.getStatus() != 0) {
+                // 过滤掉状态为0的同步导购数据
+                moveOrAddClerk(syncPojo, relationDTO);
+            }
         } else if (gicRecordType.equals(GicRecordType.UPDATE)) {
             StaffClerkRelationDTO relationDTO = new StaffClerkRelationDTO();
             relationDTO.setClerkId(syncPojo.getClerkId());