From 37add75366d13ed10fcb8e2db890cbccd7555cb7 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Mon, 15 Jan 2024 11:28:44 +0800 Subject: [PATCH] 修改联系人。异步更新所有用户的上下级关系 --- src/test/java/cc/mrbird/febs/ProfitTest.java | 233 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 227 insertions(+), 6 deletions(-) diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java index a457ea4..6b0c7ef 100644 --- a/src/test/java/cc/mrbird/febs/ProfitTest.java +++ b/src/test/java/cc/mrbird/febs/ProfitTest.java @@ -1,11 +1,33 @@ package cc.mrbird.febs; +import cc.mrbird.febs.common.entity.FebsResponse; +import cc.mrbird.febs.common.utils.MallUtils; +import cc.mrbird.febs.mall.entity.MallMember; +import cc.mrbird.febs.mall.entity.MallOrderItem; +import cc.mrbird.febs.mall.mapper.MallMemberMapper; +import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper; +import cc.mrbird.febs.mall.mapper.MallOrderItemMapper; +import cc.mrbird.febs.mall.quartz.OrderSettlementJob; import cc.mrbird.febs.mall.service.IAgentService; +import cc.mrbird.febs.mall.service.IApiMallMemberWalletService; +import cc.mrbird.febs.mall.service.IMallAchieveService; import cc.mrbird.febs.mall.service.IMemberProfitService; +import cc.mrbird.febs.pay.model.*; +import cc.mrbird.febs.pay.service.UnipayService; import cc.mrbird.febs.rabbit.consumer.AgentConsumer; +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; + +import java.math.BigDecimal; +import java.text.DecimalFormat; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; /** * @author wzy @@ -14,17 +36,216 @@ @SpringBootTest public class ProfitTest { - @Autowired - private AgentConsumer agentConsumer; - +// @Autowired +// private AgentConsumer agentConsumer; +// @Autowired private IAgentService agentService; + @Autowired + private MallMemberMapper mallMemberMapper; +// +// @Autowired +// private IMemberProfitService memberProfitService; +// + @Autowired - private IMemberProfitService memberProfitService; - + private IApiMallMemberWalletService walletService; @Test public void dynamicProfit() { - memberProfitService.dynamicProfit(45L); + List<MallMember> mallMembers = mallMemberMapper.selectList(null); + if(CollUtil.isEmpty(mallMembers)){ + return; + } + for(MallMember mallMember : mallMembers){ + boolean flag = false; + String parentId = mallMember.getReferrerId(); + if (StrUtil.isBlank(parentId)) { + flag = true; + } + String ids = ""; + while (!flag) { + if (StrUtil.isBlank(ids)) { + ids += parentId; + } else { + ids += ("," + parentId); + } + MallMember parentMember = mallMemberMapper.selectInfoByInviteId(parentId); + if (parentMember == null) { + break; + } + parentId = parentMember.getReferrerId(); + if (StrUtil.isBlank(parentMember.getReferrerId())) { + flag = true; + } + } + + if (StrUtil.isNotBlank(ids)) { + mallMember.setReferrerIds(ids); + } + mallMemberMapper.updateById(mallMember); + } + + +// walletService.add(new BigDecimal(2000), 1L, "equityLimit");//减少权益积分 +// agentService.returnMoneyToAgent(3323L); +// agentService.autoUpAgentLevel(640L); } +// @Test +// public void agentProfit() { +// memberProfitService.agentProfit(null); +// } +// +// +//// @Test +//// public void staticProfit() { +//// memberProfitService.staticProfit(new Date()); +//// } +// +// @Test +// public void thankfulProfit() { +// memberProfitService.thankfulProfit(new Date()); +// } +// +// @Test +// public void rankProfit() { +// memberProfitService.rankProfit(); +// } +// +// @Autowired +// private MallOrderInfoMapper mallOrderInfoMapper; +// +// @Test +// public void directorProfitTest() { +// memberProfitService.storeAndDirectorProfit(new Date()); +// } +// +// @Autowired +// private MallOrderItemMapper mallOrderItemMapper; +// +// @Autowired +// private IMallAchieveService mallAchieveService; +// +// @Test +// public void achieveTest() { +// List<MallOrderItem> items = mallOrderItemMapper.selectList(null); +// for (MallOrderItem item : items) { +// mallAchieveService.add(item.getId()); +// } +// } +// +// @Test +// public void paramTest() { +// Map<String, Integer> map = new HashMap<>(); +// BigDecimal amount = new BigDecimal("100"); +// map.put("amount", 1); +// changeAmount(map); +// System.out.println(map.get("amount")); +// } +// +// public void changeAmount(Map<String, Integer> amount) { +// amount.put("amount", 2); +// } +// +// @Test +// public void scorePool(){ +// memberProfitService.scorePool(); +// } +// +// @Test +// public void staticProfit(){ +// memberProfitService.staticProfit(null); +// } +// +// @Autowired +// private OrderSettlementJob orderSettlementJob; +// +// @Test +// public void orderSettlementJobTest() { +//// orderSettlementJob.normalGoodsSettlementJob(); +// +// mallAchieveService.add(83L); +// } +// +// +// @Autowired +// private UnipayService unipayService; +// @Test +// public void unipay(){ +// UnipayDto unipayDto = new UnipayDto(); +// unipayDto.setAmount(new BigDecimal("0.01")); +// unipayDto.setFrpCode("ALIPAY_H5"); +// unipayDto.setTradeMerchantNo("777180800385820"); +//// unipayDto.setFrpCode("WEIXIN_APP3"); +// unipayDto.setOrderNo("2022082316415386395"); +// unipayDto.setProductName("洗护套装"); +// unipayService.unipay(unipayDto); +// } +// @Test +// public void getAgreeMentPaySms(){ +// AgreeMentPaySmsDto agreeMentPaySmsDto = new AgreeMentPaySmsDto(); +// agreeMentPaySmsDto.setOrderNo("2022082617305930328"); +// +// BigDecimal value = new BigDecimal("0.1").setScale(2, BigDecimal.ROUND_DOWN); +// DecimalFormat decimalFormat = new DecimalFormat("0.00#"); +// String strVal = decimalFormat.format(value); +// agreeMentPaySmsDto.setOrderAmount(new BigDecimal(strVal)); +// agreeMentPaySmsDto.setName("肖永"); +// agreeMentPaySmsDto.setCreatedTime(DateUtil.now()); +// agreeMentPaySmsDto.setIdType("1"); +// agreeMentPaySmsDto.setIdCardNum("430321199310113713"); +// agreeMentPaySmsDto.setBankNo("6222031901002389639"); +// agreeMentPaySmsDto.setPhone("15274802129"); +// String agreeMentPaySms = unipayService.getAgreeMentPaySms(agreeMentPaySmsDto); +// if("JS000000".equals(agreeMentPaySms)){ +// System.out.println("获取成功"); +// }else{ +// System.out.println(agreeMentPaySms); +// } +// } +// +// @Test +// public void agreementSign(){ +// AgreementSignDto agreementSignDto = new AgreementSignDto(); +// agreementSignDto.setOrderNo("2022082614465345250"); +// agreementSignDto.setSmsCode("841243"); +// unipayService.agreementSign(agreementSignDto); +// } +// +// @Test +// public void agreementPay(){ +// AgreementPayDto agreementPayDto = new AgreementPayDto(); +// agreementPayDto.setOrderNo("2022082614465345250"); +// +// BigDecimal value = new BigDecimal("0.1").setScale(2, BigDecimal.ROUND_DOWN); +// DecimalFormat decimalFormat = new DecimalFormat("0.00#"); +// String strVal = decimalFormat.format(value); +// agreementPayDto.setOrderAmount(new BigDecimal(strVal)); +// agreementPayDto.setOrderTime(DateUtil.now()); +// agreementPayDto.setOrderDesc("测试"); +// agreementPayDto.setBankNo("6222031901002389639"); +// unipayService.agreementPay(agreementPayDto); +// } +// +// @Test +// public void singlePay(){ +// /** +// * 调用汇聚代付 +// */ +// String orderNo = MallUtils.getOrderNum("W"); +// SinglePayDto singlePayDto = new SinglePayDto(); +// singlePayDto.setMerchantOrderNo(orderNo); +// singlePayDto.setReceiverAccountNoEncBankNo("6222031903210023839639"); +// singlePayDto.setReceiverAccountNoEncName("肖永"); +// singlePayDto.setReceiverAccountType("201"); +// BigDecimal paidAmount = new BigDecimal(1.00); +// singlePayDto.setPaidAmount(paidAmount); +// singlePayDto.setCurrency("201"); +// singlePayDto.setIsChecked("202"); +// singlePayDto.setPaidDesc("用户提现"); +// singlePayDto.setPaidUse("202"); +// String singlePayRep = unipayService.singlePay(singlePayDto); +// +// System.out.println(singlePayRep); +// } } -- Gitblit v1.9.1