同步

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

@@ -71,27 +71,24 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             }else {
                 List<String> clerkIds=new ArrayList<>();
                 clerkIds.add(syncPojo.getClerkId());
-                StaffClerkRelationDTO bindRelationDTO = staffClerkRelationService.getOneBindCodeNoStatus(syncPojo.getEnterpriseId(), syncPojo.getClerkCode());
-                if (bindRelationDTO == null) {
-                    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)) {
-                    logger.info("更新关联信息:{}",syncPojo.getClerkId());
+
+                StaffClerkRelationDTO clerkRelationDTO = staffClerkRelationService.getByClerkId(syncPojo.getClerkId());
+                if (clerkRelationDTO != null) {
+
+                    logger.info("更新关联信息1:{}",syncPojo.getClerkId());
                     staffClerkRelationService.updateByClerkId(relationDTO);
-                }else {
-                    logger.info("走新增逻辑:{}",syncPojo.getClerkId());
-                    //走新增逻辑
-                    moveOrAddClerk(syncPojo,bindRelationDTO);
+                    return;
                 }
+                StaffClerkRelationDTO bindRelationDTO = staffClerkRelationService.getOneBindCodeNoStatus(syncPojo.getEnterpriseId(), syncPojo.getClerkCode());
+                if (null == clerkRelationDTO) {
+                    logger.info("没有关联导购，不需要操作:{}", syncPojo.getClerkId());
+
+                    return;
+                }
+
+                logger.info("走新增逻辑:{}",syncPojo.getClerkId());
+                //走新增逻辑
+                moveOrAddClerk(syncPojo,bindRelationDTO);
             }
         }
     }