团队列表

KKSU

2024-01-04 66e80ddd501b68cdbb7426d92707d9417c828703

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

@@ -87,6 +87,7 @@
    private final MallProductSellRecordMapper mallProductSellRecordMapper;

    private final ICommonService commonService;
    private final MallMemberAmountMapper mallMemberAmountMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -351,22 +352,25 @@
                orderInfo.setPayTime(new Date());
                orderInfo.setPayResult("1");
                this.baseMapper.updateById(orderInfo);
                MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(member.getId());
                mallMemberAmount.setGsd(mallMemberAmount.getGsd().subtract(orderInfo.getAmount()));
                mallMemberAmountMapper.updateGsdById(mallMemberAmount);

                commonService.changeWallet(orderInfo.getId(), FlowTypeEnum.BALANCE.getValue());
//                commonService.changeWallet(orderInfo.getId(), FlowTypeEnum.BALANCE.getValue());
                /**
                 * 插入一条待处理记录
                 * mq处理之后，更新状态
                 */
                MallMqRecord mallMqRecord = new MallMqRecord();
                mallMqRecord.setOrderId(orderInfo.getId());
                mallMqRecord.setState(2);
                mallMqRecord.setRetryTimes(2);
                mallMqRecord.setCreateTime(orderInfo.getPayTime());
                mallMqRecordMapper.insert(mallMqRecord);
                //发送补贴消息
                agentProducer.sendPerkMoneyMsg(orderInfo.getId());
                //发送代理自动升级消息
                agentProducer.sendAutoLevelUpMsg(member.getId());
//                MallMqRecord mallMqRecord = new MallMqRecord();
//                mallMqRecord.setOrderId(orderInfo.getId());
//                mallMqRecord.setState(2);
//                mallMqRecord.setRetryTimes(2);
//                mallMqRecord.setCreateTime(orderInfo.getPayTime());
//                mallMqRecordMapper.insert(mallMqRecord);
//                //发送补贴消息
//                agentProducer.sendPerkMoneyMsg(orderInfo.getId());
//                //发送代理自动升级消息
//                agentProducer.sendAutoLevelUpMsg(member.getId());
                break;
            case "4":
                if (orderInfo.getOrderType() != 2) {