From 2dab9941cb60285cbeff62d69a975a4c2eec9d11 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 09 Oct 2023 15:13:27 +0800
Subject: [PATCH] redbagprod

---
 src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java |   60 ++++++++++--------------------------------------------------
 1 files changed, 10 insertions(+), 50 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..34290df 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,14 @@
 @Component
 public class ProfitJob {
 
-    @Autowired
-    private MallMoneyFlowMapper moneyFlowMapper;
+//    @Autowired
+//    private IMemberProfitService memberProfitService;
 
-    @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);
-//
-//        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());
-//        }
-    }
+    /**
+     * 代理分红
+     */
+//    @Scheduled(cron = "0 30 0 * * ?")
+//    public void profitJob() {
+//        memberProfitService.agentProfit(null);
+//    }
 }

--
Gitblit v1.9.1