blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-12-31 c5947256b22f2283214258827f61af09966cf490 
 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java


@@ -15,6 +15,7 @@


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.rabbit.producter.AgentProducer;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.ObjectUtil;


@@ -46,6 +47,7 @@


    private final RunVipMapper runVipMapper;


    private final IApiMallMemberWalletService walletService;


    private final IApiMallMemberService mallMemberService;


    private final AgentProducer agentProducer;




    @Override


    @Transactional(rollbackFor = Exception.class)


@@ -282,6 +284,12 @@


        Long memberId = mallCharge.getMemberId();


        String vipCode = mallCharge.getVipCode();


        mallMemberMapper.updateVipLevelTimeAndLevel(memberId,DateUtil.date(),vipCode);




        agentProducer.sendNodeUpMsg(memberId);


    }




    @Override


    public void nodeUpMsg(Long memberId) {


        DataDictionaryCustom directCntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(


                RunVipDataDictionaryEnum.NODE_DIRECT_CNT.getType(),


                RunVipDataDictionaryEnum.NODE_DIRECT_CNT.getCode());