From dfa9dac181eb8fb6a95e32df299cbbc822455e29 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Tue, 29 Aug 2023 16:58:38 +0800 Subject: [PATCH] jufu商城 --- src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java | 116 ++++++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 93 insertions(+), 23 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 be03796..9700659 100644 --- a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java +++ b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java @@ -7,6 +7,7 @@ import cc.mrbird.febs.mall.entity.MallMoneyFlow; import cc.mrbird.febs.mall.mapper.MallMemberMapper; import cc.mrbird.febs.mall.mapper.MallMoneyFlowMapper; +import cc.mrbird.febs.mall.service.IAgentService; import cc.mrbird.febs.mall.service.IApiMallMemberService; import cc.mrbird.febs.mall.service.IApiMallMemberWalletService; import cc.mrbird.febs.mall.service.IMemberProfitService; @@ -36,42 +37,111 @@ @Autowired private IMemberProfitService memberProfitService; + @Autowired + private IAgentService agentService; /** * 代理分红 */ - @Scheduled(cron = "0 30 0 * * ?") - public void profitJob() { - memberProfitService.agentProfit(null); - } +// @Scheduled(cron = "0 30 0 * * ?") +// public void profitJob() { +// memberProfitService.agentProfit(null); +// } - @Scheduled(cron = "0 30 1 * * ?") - public void storeAndDirectorJob() { - memberProfitService.storeAndDirectorProfit(null); - } +// @Scheduled(cron = "0 30 1 * * ?") +// public void storeAndDirectorJob() { +// memberProfitService.storeAndDirectorProfit(null); +// } - /** - * 感恩奖 - */ - @Scheduled(cron = "0 0 1 * * ?") - public void thankfulJob() { - memberProfitService.thankfulProfit(null); - } +// /** +// * 线下服务中心补贴 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void thankfulJob() { +// memberProfitService.thankfulProfit(null); +// } + +// /** +// * 代理商补贴 TODO 需要去掉注释 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void agentPerkJob() { +// memberProfitService.agentPerkJob(null); +// } +// +// /** +// * 线下服务中心补贴 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void offLinePerkJob() { +// memberProfitService.offLinePerkJob(null); +// } +// +// /** +// * 平级奖励补贴 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void teamEqualsPerkJob() { +// memberProfitService.teamEqualsPerkJob(null); +// } +// +// /** +// * 补贴消息--重试 +// * 一个小时运行一次 +// */ +// @Scheduled(cron = "0 0/5 * * * ?") +// public void mqPerkRetryJob() { +// memberProfitService.mqPerkRetryJob(); +// } +// /** +// * 联创、合伙人的每日绿色凭证释放 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void scoreRecordReleaseJob() { +// memberProfitService.scoreRecordReleaseJob(); +// } +// +// /** +// * 业绩产生凭证 +// */ +// @Scheduled(cron = "0 0 1 * * ?") +// public void achieveReleaseJob() { +// memberProfitService.achieveReleaseJob(); +// } +// +// /** +// * 代理星级补贴 +// */ +// @Scheduled(cron = "0 0 0 * * ?") +// public void perkAgentAchieveJob() { +// agentService.perkAgent(); +// } + + /** * 静态分红 */ - @Scheduled(cron = "0 0 0 * * ?") - public void staticProfitJob() { - memberProfitService.staticProfit(null); - } +// @Scheduled(cron = "0 0 0 * * ?") +// public void staticProfitJob() { +// memberProfitService.staticProfit(null); +// } /** * 排名奖 每月1号 */ - @Scheduled(cron = "0 30 0 1 * ?") - public void rankJob() { - memberProfitService.rankProfit(); - } +// @Scheduled(cron = "0 30 0 1 * ?") +// public void rankJob() { +// memberProfitService.rankProfit(); +// } + + /** + * 积分池,所有消费拿出10%放到积分池,然后按1%每天释放加权平分 + */ +// @Scheduled(cron = "0 0 2 * * ?") +// @Scheduled(cron = "0 0/5 * * * ? ") +// public void scorePool() { +// memberProfitService.scorePool(); +// } } -- Gitblit v1.9.1