From 1fc5510367dcf321ac85e50e31c9dcdaaf5cd09e Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Wed, 21 Dec 2022 11:56:27 +0800 Subject: [PATCH] 20221221 --- src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java | 87 +++++++++++++++++++++---------------------- 1 files changed, 43 insertions(+), 44 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java index 87984f8..a5edbb4 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java @@ -9,6 +9,7 @@ import cc.mrbird.febs.mall.mapper.MallMoneyFlowMapper; import cc.mrbird.febs.mall.service.IApiMallMemberService; import cc.mrbird.febs.mall.service.IApiMallMemberWalletService; +import cc.mrbird.febs.mall.service.IMemberProfitService; import cc.mrbird.febs.mall.service.impl.CommonService; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateTime; @@ -33,55 +34,53 @@ @Component public class ProfitJob { - @Autowired - private MallMoneyFlowMapper moneyFlowMapper; - - @Autowired - private MallMemberMapper memberMapper; - - @Autowired - private IApiMallMemberWalletService memberWalletService; - - @Autowired - private IApiMallMemberService memberService; - - @Scheduled(cron = "0 1 0 * * ?") - @Transactional(rollbackFor = Exception.class) - public void profitJob() { - log.info("推荐人返利执行"); -// DateTime yesterday = DateUtil.yesterday(); -// List<MallMoneyFlow> flows = moneyFlowMapper.selectMoneyFlowProfitByDate(yesterday); +// @Autowired +// private IMemberProfitService memberProfitService; // -// if (CollUtil.isEmpty(flows)) { -// return; -// } +// /** +// * 代理分红 +// */ +// @Scheduled(cron = "0 30 0 * * ?") +// public void profitJob() { +// memberProfitService.agentProfit(null); +// } // -// for (MallMoneyFlow flow : flows) { -// MallMember member = memberMapper.selectById(flow.getMemberId()); +// @Scheduled(cron = "0 30 1 * * ?") +// public void storeAndDirectorJob() { +// memberProfitService.storeAndDirectorProfit(null); +// } // -// List<MallMember> child = memberMapper.selectByIdAndNoLevel(member.getInviteId(), AgentLevelEnum.ZERO_LEVEL.name()); -// if (CollUtil.isEmpty(child)) { -// continue; -// } -// int size = child.size(); -// BigDecimal needReturn = flow.getAmount().multiply(BigDecimal.valueOf(0.1)); +// /** +// * 感恩奖 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void thankfulJob() { +// memberProfitService.thankfulProfit(null); +// } // -// String orderNo = MallUtils.getOrderNum("R"); -// String remarkFormat = "{}, 用户:{}, 利润分红: {}"; // -// BigDecimal returnMoney = needReturn.divide(BigDecimal.valueOf(size), 2, RoundingMode.DOWN); -// for (MallMember mallMember : child) { -// memberWalletService.addBalance(returnMoney, mallMember.getId()); +// /** +// * 静态分红 +// */ +//// @Scheduled(cron = "0 0 0 * * ?") +//// public void staticProfitJob() { +//// memberProfitService.staticProfit(null); +//// } // -// String remark = StrUtil.format(remarkFormat, DateUtil.format(yesterday, "yyyy-MM-dd"), member.getName(), returnMoney); -// memberService.addMoneyFlow(mallMember.getId(), returnMoney, MoneyFlowTypeEnum.PARENT_BONUS.getValue(), orderNo, null, remark, member.getId(), null); -// } +// /** +// * 排名奖 每月1号 +// */ +// @Scheduled(cron = "0 30 0 1 * ?") +// public void rankJob() { +// memberProfitService.rankProfit(); +// } // -// String remark = StrUtil.format(remarkFormat, DateUtil.format(yesterday, "yyyy-MM-dd"), member.getName(), needReturn); -// memberService.addMoneyFlow(member.getId(), needReturn.negate(), MoneyFlowTypeEnum.PARENT_BONUS.getValue(), orderNo, null, remark, null, null); -// memberWalletService.reduceBalance(needReturn, member.getId()); -// -// moneyFlowMapper.updateIsReturnByMemberId(MallMoneyFlow.IS_RETURN_Y, flow.getMemberId()); -// } - } +// /** +// * 积分池,所有消费拿出10%放到积分池,然后按1%每天释放加权平分 +// */ +// @Scheduled(cron = "0 0 2 * * ?") +//// @Scheduled(cron = "0 0/5 * * * ? ") +// public void scorePool() { +// memberProfitService.scorePool(); +// } } -- Gitblit v1.9.1