同步绑定流程

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

@@ -66,21 +66,22 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             relationDTO.setClerkCode(syncPojo.getClerkCode());
             //非正常状态 删除
             if (!syncPojo.getStatus().equals(1)) {
+                logger.info("删除操作:{}",syncPojo.getClerkId());
                 staffClerkRelationService.delBind(syncPojo.getClerkId());
             }else {
                 List<String> clerkIds=new ArrayList<>();
                 clerkIds.add(syncPojo.getClerkId());
                 StaffClerkRelationDTO bindRelationDTO = staffClerkRelationService.getOneBindCodeNoStatus(syncPojo.getEnterpriseId(), syncPojo.getClerkCode());
                 if (bindRelationDTO == null) {
-                    logger.info("没有关联导购，不需要操作");
+                    logger.info("没有关联导购，不需要操作:{}",syncPojo.getClerkId());
                     return;
                 }
                 if (bindRelationDTO.getStatusFlag().equals(StatusEnum.NORMAL.getValue())
                         &&syncPojo.getOldStatus().equals(1)) {
-                    logger.info("更新关联信息");
+                    logger.info("更新关联信息:{}",syncPojo.getClerkId());
                     staffClerkRelationService.updateByClerkId(relationDTO);
                 }else {
-                    logger.info("走新增逻辑");
+                    logger.info("走新增逻辑:{}",syncPojo.getClerkId());
                     //走新增逻辑
                     moveOrAddClerk(syncPojo,bindRelationDTO);
                 }