赠送积分更新状态

xiaoyong931011

2023-08-21 f0dbcbe3f79900a3f6cacea04893697b9187946a

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

@@ -13,10 +13,7 @@
import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.mapper.*;
import cc.mrbird.febs.mall.service.*;
import cc.mrbird.febs.mall.vo.ApiLeaderListVo;
import cc.mrbird.febs.mall.vo.OrderDetailVo;
import cc.mrbird.febs.mall.vo.OrderListVo;
import cc.mrbird.febs.mall.vo.OrderRefundVo;
import cc.mrbird.febs.mall.vo.*;
import cc.mrbird.febs.pay.model.BrandWCPayRequestData;
import cc.mrbird.febs.pay.model.OrderStateDto;
import cc.mrbird.febs.pay.service.IPayService;
@@ -84,6 +81,7 @@
    private final MallElectronicFenceMapper mallElectronicFenceMapper;
    private final MallMemberWalletMapper mallMemberWalletMapper;
    private final MallRollPerkMapper mallRollPerkMapper;
    private final MallMoneyFlowMapper mallMoneyFlowMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -111,7 +109,7 @@
        orderInfo.setStatus(OrderStatusEnum.WAIT_PAY.getValue());
        orderInfo.setRemark(addOrderDto.getRemark());
        orderInfo.setOrderType(addOrderDto.getOrderType());
        orderInfo.setDeliveryType(2);
        orderInfo.setDeliveryType(addOrderDto.getDeliveryType());
        if (CollUtil.isEmpty(addOrderDto.getItems())) {
            throw new FebsException("参数错误");
        }
@@ -296,6 +294,7 @@
        String payResultStr = "";
        String wxResultStr = "";
        String amountActualMsg = "0";
        StringBuffer stringBuffer = new StringBuffer();
        switch (payOrderDto.getType()) {
            case "1":
                BrandWCPayRequestData brandWCPayRequestData = null;
@@ -323,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":
                /**
@@ -378,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());
@@ -389,6 +398,7 @@
                    throw new FebsException("兑换券已使用");
                }
                mallRollPerk.setState(2);
                mallRollPerk.setUpdateTime(DateUtil.date());
                mallRollPerkMapper.updateById(mallRollPerk);
                payResultStr = orderInfo.getOrderNo();

@@ -397,25 +407,154 @@
                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());
                break;
            /**
             *  余额加微信
             */
            case "2,1":
                MallMemberWallet mallMemberWalletThree = mallMemberWalletMapper.selectWalletByMemberId(member.getId());
                BigDecimal balanceThree = mallMemberWalletThree.getBalance();
                BigDecimal amountThree = orderInfo.getAmount();

//                int reduceThree = memberWalletService.reduce(balanceThree, member.getId(), "balance");
//                if (reduceThree == 2) {
//                    throw new FebsException("余额不足");
//                }
//                mallMoneyFlowService.addMoneyFlow(member.getId(), balanceThree.negate(), MoneyFlowTypeEnum.PAY.getValue(),
//                        orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue(),"余额支付",2);

                //实际支付余额
                BigDecimal amountActualThree = amountThree.subtract(balanceThree).setScale(2, BigDecimal.ROUND_DOWN);
                orderInfo.setAmount(amountActualThree);

                BrandWCPayRequestData brandWCPayRequestDataThree = null;
                try {
                    brandWCPayRequestDataThree = iXcxPayService.startPayment(orderInfo);
                } catch (Exception e) {
                    throw new FebsException("支付失败");
                }
                wxResultStr = JSONUtil.toJsonStr(brandWCPayRequestDataThree);
                payResultStr = brandWCPayRequestDataThree.getPrepay_id();
                orderInfo.setPayMethod("余额加微信");
                orderInfo.setAmount(amountThree);
                amountActualMsg = amountThree.toString();

                stringBuffer.append(orderInfo.getId().toString());
                stringBuffer.append("@");
                stringBuffer.append(amountActualMsg);
                agentProducer.sendOrderGetMsg(stringBuffer.toString());
                break;
            /**
             *  积分加余额
             */
            case "3,2":
                /**
                 * 获取用户的当前积分
                 */
                MallMemberWallet mallMemberWalletNOne = mallMemberWalletMapper.selectWalletByMemberId(member.getId());
                BigDecimal scoreOne = mallMemberWalletNOne.getScore();
                BigDecimal amountOne = orderInfo.getAmount();
                //积分兑换比例
                DataDictionaryCustom scoreChangeOneDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                        DataDictionaryEnum.SCORE_CHANGE.getType(),
                        DataDictionaryEnum.SCORE_CHANGE.getCode()
                );
                BigDecimal scoreChangeOne = StrUtil.isEmpty(scoreChangeOneDic.getValue()) ? new BigDecimal("1") : new BigDecimal(scoreChangeOneDic.getValue());
                int reduceOne = memberWalletService.reduce(scoreOne, member.getId(), "score");
                if (reduceOne == 2) {
                    throw new FebsException("积分余额不足");
                }
                BigDecimal scoreToAmountOne = scoreOne.divide(scoreChangeOne, 2, BigDecimal.ROUND_DOWN);
                //实际支付余额
                BigDecimal amountActualOne = amountOne.subtract(scoreToAmountOne).setScale(2, BigDecimal.ROUND_DOWN);
                int balanceOne = memberWalletService.reduce(amountActualOne, member.getId(), "balance");
                if (balanceOne == 2) {
                    throw new FebsException("余额不足");
                }
                orderInfo.setPayOrderNo(orderInfo.getOrderNo());
                orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
                orderInfo.setPayTime(new Date());
                orderInfo.setPayResult("1");
                orderInfo.setDeliveryState(OrderDeliveryStateEnum.DELIVERY_WAIT.getValue());
                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(),
                        MoneyFlowTypeEnum.SCORE_PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue(),"积分支付",2);
                break;
            /**
             *  积分加微信
             */
            case "3,1":
                MallMemberWallet mallMemberWalletNTwo = mallMemberWalletMapper.selectWalletByMemberId(member.getId());
                BigDecimal scoreTwo = mallMemberWalletNTwo.getScore();
                BigDecimal amountTwo = orderInfo.getAmount();
                //积分兑换比例
                DataDictionaryCustom scoreChangeTwoDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                        DataDictionaryEnum.SCORE_CHANGE.getType(),
                        DataDictionaryEnum.SCORE_CHANGE.getCode()
                );
                BigDecimal scoreChangeTwo = StrUtil.isEmpty(scoreChangeTwoDic.getValue()) ? new BigDecimal("1") : new BigDecimal(scoreChangeTwoDic.getValue());
                int reduceTwo = memberWalletService.reduce(scoreTwo, member.getId(), "score");
                if (reduceTwo == 2) {
                    throw new FebsException("积分余额不足");
                }
                mallMoneyFlowService.addMoneyFlow(member.getId(), scoreTwo.negate(),
                        MoneyFlowTypeEnum.SCORE_PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue(),"积分支付",2);

                BigDecimal scoreToAmountTwo = scoreTwo.divide(scoreChangeTwo, 2, BigDecimal.ROUND_DOWN);
                //实际支付余额
                BigDecimal amountActualTwo = amountTwo.subtract(scoreToAmountTwo).setScale(2, BigDecimal.ROUND_DOWN);
                orderInfo.setAmount(amountActualTwo);

                BrandWCPayRequestData brandWCPayRequestDataTwo = null;
                try {
                    brandWCPayRequestDataTwo = iXcxPayService.startPayment(orderInfo);
                } catch (Exception e) {
                    throw new FebsException("支付失败");
                }
                wxResultStr = JSONUtil.toJsonStr(brandWCPayRequestDataTwo);
                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("请选择正确的支付方式");

        }
        if(ObjectUtil.isNotEmpty(payOrderDto.getUseTime())){
            orderInfo.setUseTime(payOrderDto.getUseTime());
            orderInfo.setUseTime(DateUtil.parseDate(payOrderDto.getUseTime()));
        }

        //订单支付成功产生一个提货码
        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();
@@ -508,13 +647,17 @@
            long remainTime = DateUtil.between(new Date(), endTime, DateUnit.SECOND, false);
            orderDetailVo.setRemainTime(remainTime);
        }
        String orderNo = orderInfo.getOrderNo();
        List<MoneyFlowVo> moneyFlowVos = mallMoneyFlowMapper.selectMoneyFlowByOrderNo(orderNo,orderInfo.getMemberId());
        orderDetailVo.setMoneyFlowVos(moneyFlowVos);
        return orderDetailVo;
    }

    @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("订单不存在");
@@ -537,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