diff --git a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/XfsgTrainingPersonSyncListener.java b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/XfsgTrainingPersonSyncListener.java index 3343ba1fb..d7bd611fa 100644 --- a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/XfsgTrainingPersonSyncListener.java +++ b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/XfsgTrainingPersonSyncListener.java @@ -107,7 +107,8 @@ public class XfsgTrainingPersonSyncListener implements MessageListener { TempUserDetailDO tempUserDetailDO = fillTempUserDetailDO(shopInfoDO, staffBaseInfoDTO); tempUserDetailDAO.insertSelective(tempUserDetailDO); } - }else if(checkTempUserDetailDO != null && checkTempUserDetailDO.getShopId() == 0L){ + }else if(checkTempUserDetailDO != null && + (checkTempUserDetailDO.getShopId() == 0L || checkTempUserDetailDO.getShopId() != shopInfoDO.getId())){ // 已录入,但是没有店铺id checkTempUserDetailDO.setLineId(shopInfoDO.getLineId()); checkTempUserDetailDO.setShopId(shopInfoDO.getId());