| | |
|---|
| | | this.baseMapper.updateById(orderInfo); |
|---|
| | | |
|---|
| | | 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.sendOrderReturn(orderInfo.getId()); |
|---|
| | | //发送代理自动升级消息 |
|---|
| | | agentProducer.sendAutoLevelUpMsg(member.getId()); |
|---|
| | | break; |
|---|
