配置文件修改

admin

2019-11-23 51a4ff5d777028d52a19c314a99f796334cb7b51

 fanli/src/main/java/com/yeshi/fanli/service/impl/shop/BanLiShopOrderServiceImpl.java

@@ -47,6 +47,7 @@
import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.factory.RedPackDetailFactory;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

import com.yeshi.fanli.util.rocketmq.MQTopicName;

import com.yeshi.fanli.util.shop.BanLiShopOrderUtil;

import com.yeshi.fanli.util.wx.BanLiShopWXPayUtil;

@@ -170,8 +171,8 @@


   private void sendPlaceOrderMsg(Long orderId, Long uid) {



      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.banLiShopOrderDelay.name(),

            new Gson().toJson(new BanLiShopOrderMQMsg(orderId, uid)).getBytes());

      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.banLiShopOrderDelay,

            new BanLiShopOrderMQMsg(orderId, uid));

      msg.setKey(orderId + "");

      long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 10);// 10分钟后通知

      msg.setStartDeliverTime(delayTime);

@@ -341,8 +342,8 @@
               if (isS)// 支付成功，重新发送支付成功消息

               {

                  BanLiShopOrderMQMsg msg = new BanLiShopOrderMQMsg(order.getId(), order.getUid());

                  Message message = new Message(MQTopicName.TOPIC_ORDER.name(),

                        OrderTopicTagEnum.banLiShopOrderPaid.name(), new Gson().toJson(msg).getBytes());

                  Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,

                        OrderTopicTagEnum.banLiShopOrderPaid,msg);

                  producer.send(message);

                  return;

               }

@@ -373,8 +374,8 @@
      if (order.getState() != BanLiShopOrder.STATE_PAID)

         throw new BanLiShopOrderException(1, "订单未处于待审核状态");



      Message message = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.banLiShopOrderRefund.name(),

            new Gson().toJson(new BanLiShopOrderMQMsg(order.getId(), order.getUid())).getBytes());

      Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.banLiShopOrderRefund,

         new BanLiShopOrderMQMsg(order.getId(), order.getUid()));

      try {

         orderTransactionProducer.send(message, new LocalTransactionExecuter() {

            @Override