admin
2019-11-16 a6f34b99ee20e528b766c8ed5a61bd9c5aa0e7ae
fanli/src/main/java/com/yeshi/fanli/service/impl/shop/BanLiShopOrderServiceImpl.java
@@ -23,6 +23,8 @@
import com.yeshi.fanli.dao.mybatis.shop.BanLiShopOrderMapper;
import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;
import com.yeshi.fanli.dto.mq.order.body.BanLiShopOrderMQMsg;
import com.yeshi.fanli.dto.msg.MsgRedPackUseContentDTO;
import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail.MsgTypeMoneyTypeEnum;
import com.yeshi.fanli.entity.mq.MQUnSendInfo;
import com.yeshi.fanli.entity.redpack.RedPackDetail;
import com.yeshi.fanli.entity.shop.BanLiShopGoods;
@@ -35,6 +37,7 @@
import com.yeshi.fanli.exception.redpack.RedPackBalanceException;
import com.yeshi.fanli.exception.redpack.RedPackDetailException;
import com.yeshi.fanli.exception.shop.BanLiShopOrderException;
import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;
import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;
import com.yeshi.fanli.service.inter.redpack.RedPackBalanceService;
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsClassService;
@@ -83,6 +86,9 @@
   @Resource(name = "transactionManager")
   private DataSourceTransactionManager transactionManager;
   @Resource
   private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
   @Transactional
   @Override
@@ -395,6 +401,15 @@
         update.setUpdateTime(new Date());
         update.setRejectTime(new Date());
         banLiShopOrderMapper.updateByPrimaryKeySelective(update);
         // 消息发送
         MsgRedPackUseContentDTO dto = new MsgRedPackUseContentDTO();
         dto.setGoodsSetName(order.getOrderGoods().getSetName());
         dto.setHongBao(order.getHongBaoPayment());
         dto.setMoney(order.getMoneyPayment());
         dto.setReason(msg);
         dto.setTime(new Date());
         userMoneyMsgNotificationService.redPackMsg(order.getUid(), MsgTypeMoneyTypeEnum.redPackUseFail,
               new Gson().toJson(dto), null);
         transactionManager.commit(transactionStatus);
      } catch (Exception e) {
         transactionManager.rollback(transactionStatus);