package cc.mrbird.febs.mall.quartz; import cc.mrbird.febs.common.enumerates.AgentLevelEnum; import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum; import cc.mrbird.febs.common.utils.MallUtils; import cc.mrbird.febs.mall.entity.MallMember; 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.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; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.Date; import java.util.List; /** * @author wzy * @date 2021-09-28 **/ @Slf4j @Component public class ProfitJob { @Autowired private IMemberProfitService memberProfitService; /** * 代理分红 */ // @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 0 1 * * ?") // public void thankfulJob() { // memberProfitService.thankfulProfit(null); // } /** * 代理商补贴 */ @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 * * * ?") public void mqPerkRetryJob() { memberProfitService.mqPerkRetryJob(); } /** * 静态分红 */ // @Scheduled(cron = "0 0 0 * * ?") // public void staticProfitJob() { // memberProfitService.staticProfit(null); // } /** * 排名奖 每月1号 */ // @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(); // } }