提交 3a01ea67 authored 作者: liuhaiquan's avatar liuhaiquan

修改货主充值获取货主编码错误的问题

上级 1736d644
...@@ -299,8 +299,12 @@ public class OwnerAccountServiceImpl implements OwnerAccountService { ...@@ -299,8 +299,12 @@ public class OwnerAccountServiceImpl implements OwnerAccountService {
//给对应账户增加金额 //给对应账户增加金额
BigDecimal topUpBalance = ownerTopUp.getTopUpBalance(); BigDecimal topUpBalance = ownerTopUp.getTopUpBalance();
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
Long ownerUserNo;
String ownerUserName;
while (true) { while (true) {
OwnerAccount account = ownerAccountDao.getAccountByOwnerUserNoAndAccountType(ownerTopUp.getOwnerUserNo(), param.getAccountType()); OwnerAccount account = ownerAccountDao.getAccountByOwnerUserNoAndAccountType(ownerTopUp.getOwnerUserNo(), param.getAccountType());
ownerUserNo = account.getOwnerUserNo();
ownerUserName = account.getOwnerUserName();
OwnerAccount update = new OwnerAccount(); OwnerAccount update = new OwnerAccount();
update.setAccountBalance(topUpBalance); update.setAccountBalance(topUpBalance);
update.setUsableBalance(topUpBalance); update.setUsableBalance(topUpBalance);
...@@ -333,12 +337,12 @@ public class OwnerAccountServiceImpl implements OwnerAccountService { ...@@ -333,12 +337,12 @@ public class OwnerAccountServiceImpl implements OwnerAccountService {
break; break;
} }
} }
OwnerInfoFeignVO ownerInfo = ownerInfoService.getOwnerInfo(loginUserInfo.getUserNo()); OwnerInfoFeignVO ownerInfo = ownerInfoService.getOwnerInfo(ownerUserNo);
//充值成功并且当前货主是冻结方式是自动冻结,则触发自动冻结的mq监听 //充值成功并且当前货主是冻结方式是自动冻结,则触发自动冻结的mq监听
if(Objects.equals(ownerInfo.getFreezeSetting(), FreezeSettingEnum.AUTO.getCode())){ if(Objects.equals(ownerInfo.getFreezeSetting(), FreezeSettingEnum.AUTO.getCode())){
log.info("货主编码:{},货主姓名:{},充值成功金额:{},发送自动冻结的mq消息",loginUserInfo.getUserNo(),loginUserInfo.getUserName(),topUpBalance); log.info("货主编码:{},货主姓名:{},充值成功金额:{},发送自动冻结的mq消息",ownerUserNo,ownerUserName,topUpBalance);
FreezeTriggerMqParam mq = new FreezeTriggerMqParam(); FreezeTriggerMqParam mq = new FreezeTriggerMqParam();
mq.setUserNo(loginUserInfo.getUserNo()); mq.setUserNo(ownerUserNo);
Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(mq)).getBytes()).build(); Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(mq)).getBytes()).build();
//设置延时5秒处理,防止事务未提交 //设置延时5秒处理,防止事务未提交
message.getMessageProperties().setExpiration("5000"); message.getMessageProperties().setExpiration("5000");
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论