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;