赠送积分更新状态

xiaoyong931011

2023-08-21 f0dbcbe3f79900a3f6cacea04893697b9187946a

 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java

@@ -294,6 +294,7 @@
        String payResultStr = "";
        String wxResultStr = "";
        String amountActualMsg = "0";
        StringBuffer stringBuffer = new StringBuffer();
        switch (payOrderDto.getType()) {
            case "1":
                BrandWCPayRequestData brandWCPayRequestData = null;
@@ -321,6 +322,11 @@
                        orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue(),"余额支付",2);

                amountActualMsg = orderInfo.getAmount().toString();

                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());
                break;
            case "3":
                /**
@@ -376,6 +382,11 @@
                    mallMoneyFlowService.addMoneyFlow(member.getId(), scoreActual.negate(),
                            MoneyFlowTypeEnum.SCORE_PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue(),"积分支付",2);
                }

                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());
                break;
            case "4":
                MallRollPerk mallRollPerk = mallRollPerkMapper.selectById(payOrderDto.getRollId());
@@ -395,6 +406,11 @@
                orderInfo.setPayMethod("兑换券支付");
                orderInfo.setPayTime(new Date());
                orderInfo.setPayResult("1");

                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());

                mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.ROLL_PAY.getValue(),
                        orderInfo.getOrderNo(),  FlowTypeEnum.PRIZE_SCORE.getValue());
@@ -429,6 +445,11 @@
                orderInfo.setPayMethod("余额加微信");
                orderInfo.setAmount(amountThree);
                amountActualMsg = amountThree.toString();

                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());
                break;
            /**
             *  积分加余额
@@ -465,6 +486,11 @@
                mallMoneyFlowService.addMoneyFlow(member.getId(), amountActualOne.negate(), MoneyFlowTypeEnum.PAY.getValue(),
                        orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue(),"余额支付",2);
                amountActualMsg = amountActualOne.toString();

                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());

                orderInfo.setPayMethod("积分加余额");
                mallMoneyFlowService.addMoneyFlow(member.getId(), scoreOne.negate(),
@@ -505,6 +531,12 @@
                payResultStr = brandWCPayRequestDataTwo.getPrepay_id();
                orderInfo.setPayMethod("积分加微信");
                amountActualMsg = amountActualTwo.toString();


                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());
                break;
            default:
                throw new FebsException("请选择正确的支付方式");
@@ -518,11 +550,11 @@
        String takeCode = ShareCodeUtil.toSerialCode(orderInfo.getId());
        orderInfo.setTakeCode(takeCode);
        this.baseMapper.updateById(orderInfo);
        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append(orderInfo.getId().toString());
        stringBuffer.append("@");
        stringBuffer.append(amountActualMsg);
        agentProducer.sendOrderGetMsg(stringBuffer.toString());
//        StringBuffer stringBuffer = new StringBuffer();
//        stringBuffer.append(orderInfo.getId().toString());
//        stringBuffer.append("@");
//        stringBuffer.append(amountActualMsg);
//        agentProducer.sendOrderGetMsg(stringBuffer.toString());
        agentProducer.sendRollSendMsg(orderInfo.getId());

//        OrderStateDto orderStateDto = new OrderStateDto();
@@ -624,7 +656,8 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void confirmOrder(Long id) {
        MallMember member = LoginUserUtil.getLoginUser();
        Long memberId = LoginUserUtil.getLoginUser().getId();
        MallMember member = mallMemberMapper.selectById(memberId);
        MallOrderInfo orderInfo = this.baseMapper.selectOrderByMemberIdAndId(member.getId(), id);
        if (orderInfo == null || AppContants.DEL_FLAG_Y == orderInfo.getDelFlag()) {
            throw new FebsException("订单不存在");
@@ -647,34 +680,61 @@
        orderInfo.setReceivingTime(new Date());
        this.baseMapper.updateById(orderInfo);

        //生成一条团长提成记录
//        Long orderInfoId = orderInfo.getId();
//        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfoId);
//        if(CollUtil.isNotEmpty(mallOrderItemList)){
//
//            MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(orderInfo.getTakeUniqueCode());
//            Integer profitSwitch = mallTeamLeader.getProfitSwitch()==null?2:mallTeamLeader.getProfitSwitch();
//            BigDecimal bonusPercent =new BigDecimal(mallTeamLeader.getBonusPercent()==null?"0":mallTeamLeader.getBonusPercent());
//
//            if(1 == profitSwitch){
//                for(MallOrderItem mallOrderItem : mallOrderItemList){
//                    Integer state = mallOrderItem.getState() == null ? 1 : mallOrderItem.getState();
//                    if(1 == state){
//                        MallLeaderAchieve mallLeaderAchieve = new MallLeaderAchieve();
//                        mallLeaderAchieve.setMemberId(orderInfo.getMemberId());
//                        mallLeaderAchieve.setOrderNo(orderInfo.getOrderNo());
//                        mallLeaderAchieve.setOrderItemId(mallOrderItem.getId());
//                        BigDecimal itemAmount = mallOrderItem.getAmount();
//                        mallLeaderAchieve.setAmount(itemAmount);
//                        BigDecimal bigDecimal = bonusPercent.multiply(itemAmount).setScale(2, BigDecimal.ROUND_DOWN);
//                        mallLeaderAchieve.setProfitAmount(bigDecimal);
//                        mallLeaderAchieve.setUniqueCode(orderInfo.getTakeUniqueCode());
//                        mallLeaderAchieve.setState(MallLeaderAchieve.STATE_ONE);
//                        mallLeaderAchieveMapper.insert(mallLeaderAchieve);
//                    }
//                }
//            }
//        }
        //是否返利
        if(ObjectUtil.isNotEmpty(member.getReferrerId())){
            String referrerId = member.getReferrerId();
            MallMember mallMemberParent = memberMapper.selectInfoByInviteId(referrerId);
            Long parentId = mallMemberParent.getId();
            String orderNo = orderInfo.getOrderNo();
            MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectOneByOrderNoAndMemberIdAndRtMemberId(orderNo, parentId, member.getId());
            if(ObjectUtil.isNotEmpty(mallMoneyFlow)){
                mallMoneyFlow.setStatus(2);
                mallMoneyFlow.setIsReturn(1);
                mallMoneyFlowMapper.updateById(mallMoneyFlow);
                memberWalletService.add(mallMoneyFlow.getAmount(), parentId, "balance");
            }

            if(ObjectUtil.isNotEmpty(mallMemberParent.getReferrerId())){
                String referrerIdUp = mallMemberParent.getReferrerId();
                MallMember mallMemberParentUp = memberMapper.selectInfoByInviteId(referrerIdUp);
                Long parentIdUp = mallMemberParentUp.getId();
                MallMoneyFlow mallMoneyFlowUp = mallMoneyFlowMapper.selectOneByOrderNoAndMemberIdAndRtMemberId(orderNo, parentIdUp, parentId);
                if(ObjectUtil.isNotEmpty(mallMoneyFlowUp)){
                    mallMoneyFlowUp.setStatus(2);
                    mallMoneyFlowUp.setIsReturn(1);
                    mallMoneyFlowMapper.updateById(mallMoneyFlowUp);
                    memberWalletService.add(mallMoneyFlow.getAmount(), parentIdUp, "balance");
                }
            }
        }
        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfo.getId());
        if(CollUtil.isNotEmpty(mallOrderItemList)){
            for(MallOrderItem mallOrderItem : mallOrderItemList){
                Long goodsId = mallOrderItem.getGoodsId();
                MallGoods mallGoods = mallGoodsMapper.selectById(goodsId);
                if(ObjectUtil.isEmpty(mallGoods)){
                    break;
                }
                //是否送券 1:是 2:否
                BigDecimal levelTwoPrice = mallGoods.getLevelTwoPrice();
                if(BigDecimal.ONE.compareTo(levelTwoPrice) == 0){
                    MallRollPerk mallRollPerk = new MallRollPerk();
                    mallRollPerk.setMemberId(member.getId());
                    mallRollPerk.setState(1);
                    mallRollPerk.setRollId(mallGoods.getLevelThreePrice().longValue());
                    mallRollPerkMapper.insert(mallRollPerk);
                }
                //赠送积分
                BigDecimal levelOnePrice = mallGoods.getLevelOnePrice();
                if(BigDecimal.ZERO.compareTo(levelOnePrice) <= 0){
                    memberWalletService.add(levelOnePrice, member.getId(), "score");

                    mallMoneyFlowService.addMoneyFlow(member.getId(), levelOnePrice, MoneyFlowTypeEnum.STATIC_BONUS.getValue(),
                            orderInfo.getOrderNo(),  FlowTypeEnum.SCORE.getValue(),"赠送积分",2);
                }
            }
        }

    }

    @Override