| | |
|---|
| | |
|
|---|
| | | UserSystemCouponUseMQMsg mqMsg = new UserSystemCouponUseMQMsg(userSystemCoupon.getId(), order.getOrderId(),
|
|---|
| | | sourceType, systemCoupon.getType().name());
|
|---|
| | | // 事务消息
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.useSystemCoupon, mqMsg);
|
|---|
| | | try {
|
|---|
| | | SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
| | | @Override
|
|---|
| | | public TransactionStatus execute(Message arg0, Object arg1) {
|
|---|
| | | try {
|
|---|
| | | useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | |
|---|
| | | 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() {
|
|---|
| | | @Override
|
|---|
| | | public TransactionStatus execute(Message arg0, Object arg1) {
|
|---|
| | | try {
|
|---|
| | | useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }, null);
|
|---|
| | | System.out.println(result);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | throw e;
|
|---|
| | | }, null);
|
|---|
| | | System.out.println(result);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | throw e;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
