帮助中心

yujian

2019-12-19 626d711cb15896055c13fe344eb7fcc824589715

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

@@ -40,6 +40,7 @@
import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.charge.FuLuChargeApiUtil;

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.wx.BanLiShopWXPayUtil;



@@ -69,7 +70,7 @@
   @Resource(name = "producer")

   private Producer producer;



   @Transactional

   @Transactional(rollbackFor = Exception.class)

   @Override

   public void payOrderByHongBao(Long orderId) throws BanLiShopOrderException, RedPackBalanceException {

      BanLiShopOrder order = banLiShopOrderService.selectByPrimaryKeyForUpdate(orderId);

@@ -210,8 +211,8 @@
               order.setMoneyPaymentState(BanLiShopOrder.PAY_STATE_REFUNDING);

               // 发送退款消息

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

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

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

               Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,

                     OrderTopicTagEnum.banLiShopOrderRefund, msg);

               message.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60 * 5L);// 延时24小时通知检测微信退款状态

               SendResult result = producer.send(message);

               if (result == null) {

@@ -286,7 +287,7 @@
      }

   }



   @Transactional

   @Transactional(rollbackFor = Exception.class)

   @Override

   public void charge(Long orderId) throws BanLiShopOrderException {

      BanLiShopOrder order = banLiShopOrderService.selectByPrimaryKey(orderId);