From d5eb2b9def62ccd5782e38abeb3d856d6af68278 Mon Sep 17 00:00:00 2001 From: wangxiaopeng <807933401@qq.com> Date: Fri, 10 May 2024 16:01:20 +0800 Subject: [PATCH] =?UTF-8?q?=E9=B2=9C=E4=B8=B0=E9=97=A8=E5=BA=97=E4=B8=8B?= =?UTF-8?q?=E5=9F=B9=E8=AE=AD=E4=BA=BA=E5=91=98=E6=8B=89=E5=8F=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../consumer/listener/XfsgTrainingPersonSyncListener.java | 7 ++++++- 1 file changed, 6 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 53e9a1c89..856f76b69 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 @@ -12,6 +12,7 @@ import com.cool.store.dto.ehr.StaffBaseInfoDTO; import com.cool.store.dto.ehr.SyncXfsgTrainingPersonInfoDTO; import com.cool.store.entity.ShopInfoDO; import com.cool.store.entity.TempUserDetailDO; +import com.cool.store.enums.RocketMqTagEnum; import com.cool.store.enums.UserRoleEnum; import com.cool.store.service.XfsgEhrService; import com.cool.store.utils.RedisUtilPool; @@ -56,7 +57,11 @@ public class XfsgTrainingPersonSyncListener implements MessageListener { boolean lock = redisUtilPool.setNxExpire(lockKey, message.getMsgID(), CommonConstants.NORMAL_LOCK_TIMES); if(lock){ try { - syncXfsgTrainingPerson(text); + switch (RocketMqTagEnum.getByTag(message.getTag())){ + case SYNC_TRAINING_PERSON: + syncXfsgTrainingPerson(text); + break; + } }catch (Exception e){ log.error("XfsgTrainingPersonSyncListener consume error",e); return Action.ReconsumeLater;