| | |
| | | orderInfo.setPayTradeNo(params.get("transaction_id")); |
| | | orderInfoMapper.updateById(orderInfo); |
| | | |
| | | commonService.changeWallet(orderInfo.getId(), FlowTypeEnum.BALANCE.getValue()); |
| | | commonService.changeWallet(orderInfo.getId(), FlowTypeEnum.WECHAT.getValue()); |
| | | |
| | | /** |
| | | * 插入一条待处理记录 |
| | |
| | | mallMqRecord.setState(2); |
| | | mallMqRecord.setRetryTimes(2); |
| | | mallMqRecordMapper.insert(mallMqRecord); |
| | | //发送补贴消息 |
| | | agentProducer.sendPerkMoneyMsg(orderInfo.getId()); |
| | | //发送代理自动升级消息 |
| | | agentProducer.sendAutoLevelUpMsg(orderInfo.getMemberId()); |
| | | } |
| | | } |