From 432256e9c67bb5cfab2e7df3971fdb5c50301647 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Tue, 17 Jan 2023 20:35:06 +0800 Subject: [PATCH] 20221227 充值归集 --- src/test/java/cc/mrbird/febs/ProfitTest.java | 82 +++++++++++++++++++++++++++++++---------- 1 files changed, 62 insertions(+), 20 deletions(-) diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java index 05c3c10..b81747b 100644 --- a/src/test/java/cc/mrbird/febs/ProfitTest.java +++ b/src/test/java/cc/mrbird/febs/ProfitTest.java @@ -32,8 +32,11 @@ import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; +import org.web3j.crypto.Credentials; +import org.web3j.crypto.WalletUtils; import javax.annotation.Resource; +import java.io.File; import java.math.BigDecimal; import java.math.BigInteger; import java.text.DecimalFormat; @@ -104,8 +107,35 @@ private DataDictionaryCustomMapper dataDictionaryCustomMapper; @Test + public void tetstgetPrikey(){ + Map<String, String> wallet = new HashMap<String, String>(); + try { + String walletPassword = "secr3t"; + // 文件路径 + String walletDirectory = "E:\\address"; + String walletName = "UTC--2023-01-13T08-03-47.600000000Z--aec294ac13f0a64c57a7b9ddb3aee5e791cff06a.json"; + +// String walletName = WalletUtils.generateNewWalletFile(walletPassword, new File(walletDirectory)); +// System.out.println("wallet location: " + walletDirectory + "/" + walletName); + Credentials credentials = WalletUtils.loadCredentials(walletPassword, walletDirectory + "/" + walletName); + String accountAddress = credentials.getAddress(); + String privateKey = credentials.getEcKeyPair().getPrivateKey().toString(16); + // 钱包地址 + wallet.put("address", accountAddress); + // 钱包私钥 + wallet.put("privateKey", privateKey); + System.out.println(accountAddress); + System.out.println(privateKey); + // 产生的钱包文件地址 + wallet.put("walletLocation", walletDirectory + "/" + walletName); + } catch (Exception e) { + e.printStackTrace(); + } + } + + @Test public void directorProfitTest() { - Long directRewardId = 607L; + Long directRewardId = 701L; MallOrderInfo orderInfo = mallOrderInfoMapper.selectById(directRewardId); if(ObjectUtil.isEmpty(orderInfo)){ return; @@ -151,29 +181,32 @@ * 2、返利对象:下单人的直推上级 10%,直推的直推 5% * 3、金额:补贴金额乘以分享奖励的比例 */ + if(StrUtil.isEmpty(mallMember.getReferrerId())){ + return; + } //下单人的直推上级 MallMember mallMemberOne = memberMapper.selectInfoByInviteId(mallMember.getReferrerId()); //生成直推返利的流水记录 if(ObjectUtil.isNotEmpty(mallMemberOne)){ - DataDictionaryCustom rewardPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.REWARD_PERCENT.getType(), - DataDictionaryEnum.REWARD_PERCENT.getCode() - ); - BigDecimal rewardPercent = new BigDecimal(rewardPercentDic.getValue()).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN); - BigDecimal directRewardAmount = subsidyAmount.multiply(rewardPercent).setScale(4, BigDecimal.ROUND_DOWN); - - Long marketSubsidyFlowId = mallMoneyFlowService.addMoneyFlow( - mallMember.getId(), - orderInfo.getOrderNo(), - directRewardAmount, - MallMoneyFlowTypeEnum.DIRECT_REWARD.getCode(), - MallMoneyFlow.STATUS_SUCCESS, - MallMoneyFlow.IS_RETURN_Y, - mallMemberOne.getId(), - FlowTypeEnum.BALANCE.getValue(), - MallMoneyFlowTypeEnum.DIRECT_REWARD.getName() - ); - memberWalletService.addBalance(directRewardAmount,mallMemberOne.getId()); +// DataDictionaryCustom rewardPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( +// DataDictionaryEnum.REWARD_PERCENT.getType(), +// DataDictionaryEnum.REWARD_PERCENT.getCode() +// ); +// BigDecimal rewardPercent = new BigDecimal(rewardPercentDic.getValue()).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN); +// BigDecimal directRewardAmount = subsidyAmount.multiply(rewardPercent).setScale(4, BigDecimal.ROUND_DOWN); +// +// Long marketSubsidyFlowId = mallMoneyFlowService.addMoneyFlow( +// mallMember.getId(), +// orderInfo.getOrderNo(), +// directRewardAmount, +// MallMoneyFlowTypeEnum.DIRECT_REWARD.getCode(), +// MallMoneyFlow.STATUS_SUCCESS, +// MallMoneyFlow.IS_RETURN_Y, +// mallMemberOne.getId(), +// FlowTypeEnum.BALANCE.getValue(), +// MallMoneyFlowTypeEnum.DIRECT_REWARD.getName() +// ); +// memberWalletService.addBalance(directRewardAmount,mallMemberOne.getId()); DataDictionaryCustom shareOneDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.LEVEL_ONE.getType(), DataDictionaryEnum.LEVEL_ONE.getCode() @@ -193,6 +226,10 @@ MallMoneyFlowTypeEnum.SHARE_REWARD_ONE.getName() ); memberWalletService.addBalance(shareOneAmount,mallMemberOne.getId()); + } + + if(StrUtil.isEmpty(mallMemberOne.getReferrerId())){ + return; } //下单人的直推上级的直推 MallMember mallMemberTwo = memberMapper.selectInfoByInviteId(mallMemberOne.getReferrerId()); @@ -219,6 +256,11 @@ /** * 团队管理补贴 */ + + + if(StrUtil.isEmpty(mallMember.getReferrerIds())){ + return; + } //下单人所有的上级 String referrerIds = mallMember.getReferrerIds(); List<String> refererIdList = StrUtil.split(referrerIds, ",", -1, true, true); -- Gitblit v1.9.1