suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

鲜丰门店下培训人员拉取

Browse Source
This commit is contained in:
wangxiaopeng
2024-05-10 16:01:20 +08:00
parent 666793b334
commit d5eb2b9def
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/XfsgTrainingPersonSyncListener.java
View File

@@ -12,6 +12,7 @@ import com.cool.store.dto.ehr.StaffBaseInfoDTO;
import com.cool.store.dto.ehr.SyncXfsgTrainingPersonInfoDTO; import com.cool.store.dto.ehr.SyncXfsgTrainingPersonInfoDTO;
import com.cool.store.entity.ShopInfoDO; import com.cool.store.entity.ShopInfoDO;
import com.cool.store.entity.TempUserDetailDO; import com.cool.store.entity.TempUserDetailDO;
import com.cool.store.enums.RocketMqTagEnum;
import com.cool.store.enums.UserRoleEnum; import com.cool.store.enums.UserRoleEnum;
import com.cool.store.service.XfsgEhrService; import com.cool.store.service.XfsgEhrService;
import com.cool.store.utils.RedisUtilPool; 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); boolean lock = redisUtilPool.setNxExpire(lockKey, message.getMsgID(), CommonConstants.NORMAL_LOCK_TIMES);
if(lock){ if(lock){
try { try {
syncXfsgTrainingPerson(text); switch (RocketMqTagEnum.getByTag(message.getTag())){
case SYNC_TRAINING_PERSON:
syncXfsgTrainingPerson(text);
break;
}
}catch (Exception e){ }catch (Exception e){
log.error("XfsgTrainingPersonSyncListener consume error",e); log.error("XfsgTrainingPersonSyncListener consume error",e);
return Action.ReconsumeLater; return Action.ReconsumeLater;