rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

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

@@ -41,6 +41,7 @@
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetService;

import com.yeshi.fanli.service.inter.shop.BanLiShopOrderPayService;

import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService;

import com.yeshi.fanli.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

@@ -73,15 +74,15 @@


   @Resource

   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;

	


   @Resource

   private ConfigService configService;

	


   @Resource

   private AdminUserService adminUserService;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Transactional(rollbackFor = Exception.class)

   @Override

@@ -132,7 +133,7 @@
      }

   }



   @Transactional(rollbackFor=Exception.class)

   @Transactional(rollbackFor = Exception.class)

   @Override

   public void payOrderByMoney(Long orderId, BigDecimal money) throws BanLiShopOrderException {

      BanLiShopOrder order = banLiShopOrderService.selectByPrimaryKeyForUpdate(orderId);

@@ -176,7 +177,7 @@
    */

   private void paySuccess(BanLiShopOrder order) {

      ThreadUtil.run(new Runnable() {

			


         @Override

         public void run() {

            long[] targetUids = new long[] { 3L, 4L };

@@ -191,11 +192,10 @@
            }

         }

      });

		
		


   }



   @Transactional(rollbackFor=Exception.class)

   @Transactional(rollbackFor = Exception.class)

   @Override

   public void refund(Long orderId) throws BanLiShopOrderException {

      // 订单退款

@@ -244,8 +244,7 @@
               BanLiShopOrderMQMsg msg = new BanLiShopOrderMQMsg(order.getId(), order.getUid());

               Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,

                     OrderTopicTagEnum.banLiShopOrderRefund, msg);

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

               SendResult result = producer.send(message);

               SendResult result = rocketMQManager.sendNormalMsg(message, 1000 * 60 * 5L,null);

               if (result == null) {

                  throw new BanLiShopOrderException(8, "消息发送失败");

               }

@@ -392,4 +391,48 @@
      }

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void invalidOrderByOrderId(Long orderId, String stateDesc) throws BanLiShopOrderException {



      BanLiShopOrder order = banLiShopOrderService.selectByPrimaryKeyForUpdate(orderId);

      if (order == null)

         return;

      // 退款

      if (order.getState() == BanLiShopOrder.STATE_NO_PAY) {// 状态还是未支付

         // 退款红包

         if (order.getHongBaoPaymentState() != null

               && order.getHongBaoPaymentState() == BanLiShopOrder.PAY_STATE_PAID) {

            BanLiShopGoods goods = banLiShopGoodsService.selectByPrimaryKey(order.getGoods().getId());

            BanLiShopGoodsClass goodsClass = banLiShopGoodsClassService

                  .selectByPrimaryKey(goods.getGoodsClass().getId());

            BanLiShopGoodsSets set = banLiShopGoodsSetService.selectByPrimaryKey(order.getGoodsSet().getId());

            // 红包退款

            RedPackDetail detail = null;

            try {

               detail = RedPackDetailFactory.createShopOrderDrawBack(orderId, order.getUid(), goodsClass.getName(),

                     set.getName(), order.getHongBaoPayment());

            } catch (RedPackDetailException e) {

               e.printStackTrace();

            }



            if (detail == null)

               throw new BanLiShopOrderException(4, "红包详情失败");

            try {

               redPackBalanceService.addRedPack(order.getUid(), order.getHongBaoPayment(), detail);

            } catch (RedPackBalanceException e) {

               throw new BanLiShopOrderException(5, "红包退款失败");

            }



            BanLiShopOrder update = new BanLiShopOrder(order.getId());

            update.setHongBaoPaymentState(BanLiShopOrder.PAY_STATE_REFUND);

            update.setUpdateTime(new Date());

            banLiShopOrderService.udpateSelectiveByPrimaryKey(update);

         }



         banLiShopOrderService.invalidOrderByOrderId(orderId, stateDesc);

      }



   }



}