|
|
@@ -87,6 +87,11 @@ public class KxsTotalDebtServiceImpl extends ServiceImpl<KxsTotalDebtMapper, Kxs
|
|
|
@Override
|
|
|
@DSTransactional(rollbackFor = Exception.class)
|
|
|
public void deductPartnerAmount(KxsTotalDebt kxsTotalDebt) {
|
|
|
+ //执行之前先查询一次
|
|
|
+ KxsTotalDebt totalDebt = baseMapper.selectById(kxsTotalDebt.getId());
|
|
|
+ if(totalDebt.getTotalDebt().compareTo(BigDecimal.ZERO) <= 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
//查询该创客合伙人/盟主是否有客提现余额,如果大于0则扣除
|
|
|
KxsPartner kxsPartner = kxsPartnerMapper.selectOne(Wrappers.<KxsPartner>lambdaQuery().eq(KxsPartner::getUserId, kxsTotalDebt.getUserId()));
|
|
|
if(kxsPartner == null){
|
|
|
@@ -137,6 +142,11 @@ public class KxsTotalDebtServiceImpl extends ServiceImpl<KxsTotalDebtMapper, Kxs
|
|
|
@Override
|
|
|
@DSTransactional(rollbackFor = Exception.class)
|
|
|
public void deductLeaderAmount(KxsTotalDebt kxsTotalDebt) {
|
|
|
+
|
|
|
+ KxsTotalDebt totalDebt = baseMapper.selectById(kxsTotalDebt.getId());
|
|
|
+ if(totalDebt.getTotalDebt().compareTo(BigDecimal.ZERO) <= 0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
//查询该创客合伙人/盟主是否有客提现余额,如果大于0则扣除
|
|
|
KxsLeader kxsLeader = kxsLeaderMapper.selectOne(Wrappers.<KxsLeader>lambdaQuery().eq(KxsLeader::getUserId, kxsTotalDebt.getUserId()));
|
|
|
if(kxsLeader == null){
|