Commit 836154a1 by fudahua

日志

parent 4b6d391b
......@@ -90,7 +90,6 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
StaffClerkRelationDTO clerkRelationDTO = staffClerkRelationService.getByClerkId(syncPojo.getClerkId());
if (clerkRelationDTO != null) {
logger.info("更新关联信息1:{}",syncPojo.getClerkId());
staffClerkRelationService.updateByClerkId(relationDTO);
return;
......@@ -98,10 +97,8 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
StaffClerkRelationDTO bindRelationDTO = staffClerkRelationService.getOneBindCodeNoStatus(syncPojo.getEnterpriseId(), syncPojo.getClerkCode());
if (null == bindRelationDTO) {
logger.info("没有关联导购,不需要操作:{}", syncPojo.getClerkId());
return;
}
logger.info("走新增逻辑:{}",syncPojo.getClerkId());
//走新增逻辑
moveOrAddClerk(syncPojo,bindRelationDTO);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment