| | |
|---|
| | | private HongBaoOrderMapper hongBaoOrderMapper;
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | @Transactional(rollbackFor=Exception.class)
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void fanli(HongBaoV2 hb1) throws TaoBaoWeiQuanException {
|
|---|
| | | // 查询最新的红包数据
|
|---|
| | | hb1 = hongBaoV2Mapper.selectByPrimaryKeyForUpdate(hb1.getId());
|
|---|
| | |
|---|
| | | String key = mainUser.getId() + "-" + UUID.randomUUID().toString();
|
|---|
| | | msg.setKey(key);
|
|---|
| | | try {
|
|---|
| | | orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
| | | @Override
|
|---|
| | | public TransactionStatus execute(Message arg0, Object arg1) {
|
|---|
| | | try {
|
|---|
| | | orderMoneySettleService.ziGouSettle(hongBaoOrder.getCommonOrder().getOrderNo(),
|
|---|
| | | hongBaoOrder.getCommonOrder().getSourceType(), key);
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | if (!Constant.IS_TEST)
|
|---|
| | | orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
|
|---|
| | | @Override
|
|---|
| | | public TransactionStatus execute(Message arg0, Object arg1) {
|
|---|
| | | try {
|
|---|
| | | orderMoneySettleService.ziGouSettle(hongBaoOrder.getCommonOrder().getOrderNo(),
|
|---|
| | | hongBaoOrder.getCommonOrder().getSourceType(), key);
|
|---|
| | | return TransactionStatus.CommitTransaction;
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | return TransactionStatus.RollbackTransaction;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }, null);
|
|---|
| | | else{
|
|---|
| | | try {
|
|---|
| | | orderMoneySettleService.ziGouSettle(hongBaoOrder.getCommonOrder().getOrderNo(),
|
|---|
| | | hongBaoOrder.getCommonOrder().getSourceType(), key);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | | }, null);
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
|
|---|
| | | }
|
|---|
| | |
|---|
| | | } catch (UserAccountException e) {
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | if (resultCode == 1) {// 只发送新增消息
|
|---|
| | | OrderMQMsg mqMsg = new OrderMQMsg(orderId, sourceType, uid, OrderMQMsg.HANDLE_TYPE_ADD,
|
|---|
| | | isCommonOrderValid(coList), 0, new Date());
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderStatistic, mqMsg);
|
|---|
| | | producer.send(msg);
|
|---|
| | | }
|
|---|
| | | if (!Constant.IS_TEST)
|
|---|
| | | if (resultCode == 1) {// 只发送新增消息
|
|---|
| | | OrderMQMsg mqMsg = new OrderMQMsg(orderId, sourceType, uid, OrderMQMsg.HANDLE_TYPE_ADD,
|
|---|
| | | isCommonOrderValid(coList), 0, new Date());
|
|---|
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderStatistic, mqMsg);
|
|---|
| | | producer.send(msg);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
