|
@@ -42,6 +42,7 @@ public class ChannelMoneyLogServiceImpl extends ServiceImpl<ChannelMoneyLogMappe
|
|
|
Channel channel = channelService.getById(moneyLog.getChannelId());
|
|
|
|
|
|
boolean income = checkIncome(moneyLog.getType());
|
|
|
+ int logMoney = moneyLog.getLogMoney();
|
|
|
int money = 0;
|
|
|
if (!income) {
|
|
|
//根据收支方向,将金额转负,方便统一计算
|
|
@@ -62,9 +63,9 @@ public class ChannelMoneyLogServiceImpl extends ServiceImpl<ChannelMoneyLogMappe
|
|
|
}
|
|
|
LogUtil.info(logger, "channelId:{0}, money:{1}", new Object[]{channel.getChannelId() , channel.getMoney()});
|
|
|
|
|
|
- //1、更新商户余额表
|
|
|
+ //1、更新渠道余额表
|
|
|
boolean rtn = channelService.update(new LambdaUpdateWrapper<Channel>().set(Channel::getMoney, money)
|
|
|
- .set(ChannelMoneyEnum.WITHDRAW == moneyLog.getType() || ChannelMoneyEnum.WITHDRAW_FEE == moneyLog.getType(), Channel::getFrozenMoney, channel.getFrozenMoney() + moneyLog.getLogMoney())
|
|
|
+ .set(ChannelMoneyEnum.WITHDRAW == moneyLog.getType() || ChannelMoneyEnum.WITHDRAW_FEE == moneyLog.getType(), Channel::getFrozenMoney, channel.getFrozenMoney() + logMoney)
|
|
|
.eq(Channel::getChannelId, channel.getChannelId()).eq(Channel::getMoney, channel.getMoney()));
|
|
|
Assert.isTrue(rtn, "渠道余额更新失败,channelId:" + channel.getChannelId());
|
|
|
|