From 7e6bbd05a75b07cb0717812d0b51aad128361012 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 19 May 2022 18:43:42 +0800 Subject: [PATCH] fix some problem --- src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java | 71 ++++++++++++++++++----------------- 1 files changed, 36 insertions(+), 35 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 4d7a98b..87984f8 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java @@ -45,42 +45,43 @@ @Autowired private IApiMallMemberService memberService; - @Scheduled(cron = "0 0 1 * * ?") + @Scheduled(cron = "0 1 0 * * ?") @Transactional(rollbackFor = Exception.class) public void profitJob() { - DateTime yesterday = DateUtil.yesterday(); - List<MallMoneyFlow> flows = moneyFlowMapper.selectMoneyFlowProfitByDate(yesterday); - - if (CollUtil.isEmpty(flows)) { - return; - } - - for (MallMoneyFlow flow : flows) { - MallMember member = memberMapper.selectById(flow.getMemberId()); - - 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)); - - 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()); - - 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); - } - - 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()); - } + log.info("推荐人返利执行"); +// DateTime yesterday = DateUtil.yesterday(); +// List<MallMoneyFlow> flows = moneyFlowMapper.selectMoneyFlowProfitByDate(yesterday); +// +// if (CollUtil.isEmpty(flows)) { +// return; +// } +// +// for (MallMoneyFlow flow : flows) { +// MallMember member = memberMapper.selectById(flow.getMemberId()); +// +// 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)); +// +// 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()); +// +// 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); +// } +// +// 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()); +// } } } -- Gitblit v1.9.1