blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-12-06 52764805246423419ef8d0c076238f94bc6ed65c 
 src/main/java/cc/mrbird/febs/mall/quartz/OrderSettlementJob.java


@@ -1,11 +1,8 @@


package cc.mrbird.febs.mall.quartz;




import cc.mrbird.febs.common.enumerates.AgentLevelEnum;


import cc.mrbird.febs.common.enumerates.DataDictionaryEnum;


import cc.mrbird.febs.common.enumerates.FlowTypeEnum;


import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;


import cc.mrbird.febs.common.utils.MallUtils;


import cc.mrbird.febs.mall.entity.*;


import cc.mrbird.febs.mall.entity.DataDictionaryCustom;


import cc.mrbird.febs.mall.entity.MallOrderInfo;


import cc.mrbird.febs.mall.mapper.*;


import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;


import cc.mrbird.febs.mall.service.IMallAchieveService;


@@ -13,20 +10,15 @@


import cc.mrbird.febs.mall.service.IMemberProfitService;


import cc.mrbird.febs.rabbit.producter.AgentProducer;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.date.DateTime;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.ObjectUtil;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;


import org.springframework.scheduling.annotation.Scheduled;


import org.springframework.stereotype.Component;




import java.math.BigDecimal;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




/**


 * @author wzy


@@ -150,7 +142,9 @@


            mallOrderInfoMapper.updateOrderConfirmStatus(DateUtil.date(),DateUtil.offsetDay(new Date(), -value));




            orderInfos.forEach(item -> {


                agentProducer.sendGetScoreMsg(item.getId());


                if(item.getOrderType() == 1){


                    agentProducer.sendGetScoreMsg(item.getId());


                }


            });


        }


    }