红包

yujian

2019-11-04 01407e36f8a1d46e065cdcfe14629540dbd6b921

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java

@@ -391,10 +391,29 @@
            return;

      }



      // 查询该订单之前是否有到账

      List<HongBaoOrder> list = hongBaoOrderMapper.listByOrderIdAndSourceType(

            hongBaoOrder.getCommonOrder().getOrderNo(), hongBaoOrder.getCommonOrder().getSourceType());

      List<Long> hongBaoIdList = new ArrayList<>();

      if (list != null) {

         for (HongBaoOrder ho : list) {

            hongBaoIdList.add(ho.getHongBaoV2().getId());

         }

      }



      List<HongBaoV2> allHongBaoList = hongBaoV2Mapper.listByIds(hongBaoIdList);

      boolean first = true;

      for (HongBaoV2 v2 : allHongBaoList)

         if (v2.getState() == HongBaoV2.STATE_YILINGQU) {

            first = false;

            break;

         }



      // 自购到账事务消息

      OrderMoneyRecievedMQMsgDTO mqMsg = new OrderMoneyRecievedMQMsgDTO(OrderMoneyRecievedMQMsgDTO.TYPE_ZIGOU,

            mainUser.getId(), hongBaoOrder.getCommonOrder().getSourceType(),

            hongBaoOrder.getCommonOrder().getOrderNo(), null, new Date());

      mqMsg.setOrderFirst(first);

      Message msg = new Message(MQTopicName.TOPIC_FANLI.name(), "actual", new Gson().toJson(mqMsg).getBytes());

      String key = mainUser.getId() + "-" + UUID.randomUUID().toString();

      msg.setKey(key);

@@ -503,7 +522,7 @@
      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }

      if(1>0)

      if (1 > 0)

         return;



      try {

@@ -1182,7 +1201,7 @@
      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(),

            String.format(MQTagConstant.TAG_ORDER_STATISTIC_PREFIX + "%s-%s", sourceType, hongBaoType),

            new Gson().toJson(mqMsg).getBytes());

      SendResult result=   orderTransactionProducer.send(msg, new LocalTransactionExecuter() {

      SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {

         @Override

         public TransactionStatus execute(Message arg0, Object arg1) {

            int resultCode = 0;

@@ -1196,10 +1215,10 @@
               }

            }

            return TransactionStatus.CommitTransaction;

//            if (resultCode != 0)

//               return TransactionStatus.CommitTransaction;

//            else

//               return TransactionStatus.RollbackTransaction;

            // if (resultCode != 0)

            // return TransactionStatus.CommitTransaction;

            // else

            // return TransactionStatus.RollbackTransaction;

         }

      }, null);

      System.out.println(result);