根据userId 伪登录

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

@@ -73,8 +73,15 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
                 clerkIds.add(syncPojo.getClerkId());
                 StaffClerkRelationDTO bindRelationDTO = staffClerkRelationService.getOneBindCodeNoStatus(syncPojo.getEnterpriseId(), syncPojo.getClerkCode());
                 if (bindRelationDTO == null) {
-                    logger.info("没有关联导购，不需要操作:{}",syncPojo.getClerkId());
-                    return;
+                    StaffClerkRelationDTO clerkRelationDTO = staffClerkRelationService.getByClerkId(syncPojo.getClerkId());
+                    if (null == clerkRelationDTO) {
+                        logger.info("没有关联导购，不需要操作:{}", syncPojo.getClerkId());
+
+                        return;
+                    }else{
+                        logger.info("更新关联信息1:{}",syncPojo.getClerkId());
+                        staffClerkRelationService.updateByClerkId(relationDTO);
+                    }
                 }
                 if (bindRelationDTO.getStatusFlag().equals(StatusEnum.NORMAL.getValue())
                         &&syncPojo.getOldStatus().equals(1)) {