|
|
@@ -57,7 +57,9 @@ public class UserAccountServiceImpl implements IUserAccountService {
|
|
|
@Override
|
|
|
public Boolean doUserAccount(UserAccountBo bo) {
|
|
|
UserAccount entity = MapstructUtils.convert(bo, UserAccount.class);
|
|
|
- UserAccountVo vo = baseMapper.selectVoById(bo.getUserId());
|
|
|
+ log.info("传入账户数据:{}",bo);
|
|
|
+ UserAccountVo vo = TenantHelper.ignore(() -> baseMapper.selectVoById(bo.getUserId()));
|
|
|
+ log.info("查询账户数据:{}",vo);
|
|
|
int rows;
|
|
|
if(ObjectUtil.isEmpty(vo)){
|
|
|
// 当前没有一卡通账户,先增加账户信息
|
|
|
@@ -82,7 +84,7 @@ public class UserAccountServiceImpl implements IUserAccountService {
|
|
|
}
|
|
|
} else{
|
|
|
// 已有账户,更新
|
|
|
- rows = baseMapper.updateById(entity);
|
|
|
+ rows = TenantHelper.ignore(() -> baseMapper.updateById(entity));
|
|
|
if(rows != 1){
|
|
|
return false;
|
|
|
}
|
|
|
@@ -90,7 +92,7 @@ public class UserAccountServiceImpl implements IUserAccountService {
|
|
|
// 如果卡类或有效期变了,需要同步更新主卡的卡类与有效期
|
|
|
}
|
|
|
}
|
|
|
- vo = baseMapper.selectVoById(bo.getUserId());
|
|
|
+ vo = TenantHelper.ignore(() -> baseMapper.selectVoById(bo.getUserId()));
|
|
|
kafkaNormalProducer.sendKafkaMessage(KafkaTopicConstants.SYNC_DATA_TOPIC, EventTypeConstants.ACCOUNT, EventSenderEnum.BACKSTAGE.code(), vo);
|
|
|
return true;
|
|
|
}
|