From 571493a441390dc68c6d81a644bf33398e0c656a Mon Sep 17 00:00:00 2001 From: wangxiaopeng <807933401@qq.com> Date: Mon, 13 May 2024 10:06:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E5=9F=B9=E8=AE=AD=E4=BA=BA?= =?UTF-8?q?=E5=91=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mq/consumer/listener/XfsgTrainingPersonSyncListener.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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());