| | |
|---|
| | |
|
|---|
| | | UserSystemCouponUseMQMsg mqMsg = new UserSystemCouponUseMQMsg(userSystemCoupon.getId(), order.getOrderId(),
|
|---|
| | | sourceType, systemCoupon.getType().name());
|
|---|
| | | // 事务消息
|
|---|
| | | |
|---|
| | | if (Constant.IS_TEST) {
|
|---|
| | | useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
|
|---|
| | | } else { // 事务消息
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.useSystemCoupon, mqMsg);
|
|---|
| | | try {
|
|---|
| | | SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional(rollbackFor=Exception.class)
|
|---|
| | | public void useRewardCouponCore(UserSystemCoupon userSystemCoupon, BigDecimal money, BigDecimal hongBao, Long uid,
|
|---|
