| | |
|---|
| | | private final DataDictionaryCustomMapper dataDictionaryCustomMapper; |
|---|
| | | private final MallAchieveRecordMapper mallAchieveRecordMapper; |
|---|
| | | private final MallMemberWalletMapper mallMemberWalletMapper; |
|---|
| | | private final MallMqRecordMapper mallMqRecordMapper; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | |
|---|
| | | orderInfo.setPayResult("1"); |
|---|
| | | |
|---|
| | | changeWallet(orderInfo.getId()); |
|---|
| | | /** |
|---|
| | | * 插入一条待处理记录 |
|---|
| | | * mq处理之后，更新状态 |
|---|
| | | */ |
|---|
| | | MallMqRecord mallMqRecord = new MallMqRecord(); |
|---|
| | | mallMqRecord.setOrderId(orderInfo.getId()); |
|---|
| | | mallMqRecord.setState(2); |
|---|
| | | mallMqRecord.setRetryTimes(2); |
|---|
| | | mallMqRecordMapper.insert(mallMqRecord); |
|---|
| | | //发送补贴消息 |
|---|
| | | agentProducer.sendPerkMoneyMsg(orderInfo.getId()); |
|---|
| | | //发送代理自动升级消息 |
|---|
