From e6667c792be898c41cda7d850dda02a403ef79c2 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Thu, 06 Apr 2023 10:35:20 +0800 Subject: [PATCH] 关于积分凭证 --- src/test/java/cc/mrbird/febs/ProfitTest.java | 54 ++++++++++++++++++++++++++++++++++-------------------- 1 files changed, 34 insertions(+), 20 deletions(-) diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java index 178b4e6..0ad3247 100644 --- a/src/test/java/cc/mrbird/febs/ProfitTest.java +++ b/src/test/java/cc/mrbird/febs/ProfitTest.java @@ -9,11 +9,13 @@ 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.IApiMallOrderInfoService; 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 cc.mrbird.febs.rabbit.producter.AgentProducer; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; @@ -43,32 +45,44 @@ private IMemberProfitService memberProfitService; @Autowired + private IApiMallOrderInfoService iApiMallOrderInfoService; + + @Autowired private MallMemberMapper memberMapper; + + @Autowired + private AgentProducer agentProducer; @Test public void dynamicProfit() { -// agentService.perkMoneyConsumer(Long.parseLong("571")); - List<MallMember> mallMemberTeamPerk = new ArrayList<>(); - MallMember mallMember = memberMapper.selectById(233L); - List<String> ids = StrUtil.split(mallMember.getReferrerIds(), ','); - List<MallMember> mallMembers = memberMapper.selectByInviteIds(ids); - Map<String, List<MallMember>> collect = mallMembers.stream().collect(Collectors.groupingBy(MallMember::getLevel)); - Set<String> set = collect.keySet(); // 得到所有key的集合 - for (String key : set) { - List<MallMember> value = collect.get(key); - System.out.println(key + " " + value); - mallMemberTeamPerk.add(value.get(0)); - - System.out.println(value.get(0).getName()); - - } - List<Long> mallMemberStarIds = mallMemberTeamPerk.stream().map(MallMember::getId).collect(Collectors.toList()); - - System.out.println(mallMemberStarIds); + agentService.perkMoneyConsumer(Long.parseLong("712")); +// memberProfitService.dynamicProfit(Long.parseLong("709")); +// memberProfitService.scoreRecordReleaseJob(); +// memberProfitService.achieveReleaseJob(); +// agentProducer.sendPerkMoneyMsg(679L); +// agentService.perkMoneyConsumer(665L); +// memberProfitService.teamEqualsPerkJob(null); +// List<MallMember> mallMemberTeamPerk = new ArrayList<>(); +// MallMember mallMember = memberMapper.selectById(233L); +// List<String> ids = StrUtil.split(mallMember.getReferrerIds(), ','); +// List<MallMember> mallMembers = memberMapper.selectByInviteIds(ids); +// Map<String, List<MallMember>> collect = mallMembers.stream().collect(Collectors.groupingBy(MallMember::getLevel)); +// Set<String> set = collect.keySet(); // 得到所有key的集合 +// for (String key : set) { +// List<MallMember> value = collect.get(key); +// System.out.println(key + " " + value); +// mallMemberTeamPerk.add(value.get(0)); +// +// System.out.println(value.get(0).getName()); +// +// } +// List<Long> mallMemberStarIds = mallMemberTeamPerk.stream().map(MallMember::getId).collect(Collectors.toList()); +// +// System.out.println(mallMemberStarIds); } @Test public void agentProfit() { - memberProfitService.agentProfit(null); + iApiMallOrderInfoService.changeWallet(665L); } @@ -79,7 +93,7 @@ @Test public void thankfulProfit() { - memberProfitService.thankfulProfit(new Date()); + memberProfitService.mqPerkRetryJob(); } @Test -- Gitblit v1.9.1