From 35eba8a7575806ca47e435702a56b0a13f7bed0b Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Sat, 15 May 2021 13:28:47 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/yunding/service/Impl/XchProfitServiceImpl.java | 16 ++++++++++++++++ 1 files changed, 16 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/XchProfitServiceImpl.java b/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/XchProfitServiceImpl.java index 3b8ef4d..3dc38f1 100644 --- a/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/XchProfitServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/XchProfitServiceImpl.java @@ -4,6 +4,7 @@ import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; +import com.xcong.excoin.common.contants.AppContants; import com.xcong.excoin.modules.coin.dao.MemberAccountMoneyChangeDao; import com.xcong.excoin.modules.member.dao.MemberDao; import com.xcong.excoin.modules.member.dao.MemberWalletCoinDao; @@ -18,6 +19,7 @@ import com.xcong.excoin.modules.yunding.entity.YdOrderEntity; import com.xcong.excoin.modules.yunding.entity.YdProductEntity; import com.xcong.excoin.modules.yunding.service.XchProfitService; +import com.xcong.excoin.netty.common.Contans; import com.xcong.excoin.rabbit.producer.YunDingProducter; import com.xcong.excoin.utils.LogRecordUtils; import lombok.extern.slf4j.Slf4j; @@ -183,6 +185,7 @@ ydOrderDao.updateById(updateOrder); } + // 合伙人分红 List<MemberEntity> partners = memberDao.selectPartnerMemberList(); YdBasicSettingEntity setting = ydBasicSettingDao.selectById(1L); if (CollUtil.isNotEmpty(partners)) { @@ -197,6 +200,19 @@ } } + if(!AppContants.SYSTEM_REFERER.equals(memberEntity.getRefererId())) { + // 直推返利 + MemberEntity parentNode = memberDao.selectMemberInfoByInviteId(memberEntity.getRefererId()); + if (parentNode != null) { + BigDecimal parentAmount = order.getAmount().multiply(setting.getParentRatio()); + + String conent = "直推USDT返利"; + LogRecordUtils.insertMemberAccountMoneyChangeWithId(parentNode.getId(), conent, parentAmount, "USDT", 1, 10, order.getId()); + MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(parentNode.getId(), "USDT"); + + memberWalletCoinDao.updateBlockBalance(walletCoin.getId(), parentAmount, BigDecimal.ZERO, 0); + } + } } private Map<Long, BigDecimal> buildReturnRatioObj(List<MemberEntity> agents, int type) { -- Gitblit v1.9.1