红包表明修改

yujian

2019-11-05 a980ade25b3dc1a7da482e37113f2935a2719c0b

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

@@ -9,22 +9,33 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.aliyun.openservices.ons.api.Message;

import com.aliyun.openservices.ons.api.Producer;

import com.aliyun.openservices.ons.api.SendResult;

import com.google.gson.Gson;

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.entity.mq.MQUnSendInfo;

import com.yeshi.fanli.entity.redpack.RedPackDetail;

import com.yeshi.fanli.entity.shop.BanLiShopGoods;

import com.yeshi.fanli.entity.shop.BanLiShopGoodsClass;

import com.yeshi.fanli.entity.shop.BanLiShopGoodsSets;

import com.yeshi.fanli.entity.shop.BanLiShopOrder;

import com.yeshi.fanli.exception.mq.MQUnSendInfoException;

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.mq.MQUnSendInfoService;

import com.yeshi.fanli.service.inter.redpack.RedPackBalanceService;

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

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

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

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.shop.BanLiShopUtil;

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

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



@Service

public class BanLiShopOrderServiceImpl implements BanLiShopOrderService {

@@ -43,6 +54,12 @@


   @Resource

   private RedPackBalanceService redPackBalanceService;



   @Resource(name = "producer")

   private Producer producer;



   @Resource

   private MQUnSendInfoService mqUnSendInfoService;



   @Transactional

   @Override

@@ -89,12 +106,40 @@
      banLiShopOrderMapper.insertSelective(order);



      // 添加订单号

      String orderNo = BanLiShopUtil.createOrderNo(order.getId());

      String orderNo = BanLiShopOrderUtil.createOrderNo(order.getId());

      // 更新订单号

      BanLiShopOrder update = new BanLiShopOrder();

      update.setId(order.getId());

      update.setOrderNo(orderNo);

      banLiShopOrderMapper.updateByPrimaryKeySelective(update);



      // 订单添加成功 ,延时通知后续

      sendPlaceOrderMsg(order.getId(), order.getUid());

   }



   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());

      msg.setKey(orderId + "");

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

      msg.setStartDeliverTime(delayTime);

      SendResult sendResult = producer.send(msg);

      if (sendResult == null) {

         MQUnSendInfo info = new MQUnSendInfo();

         info.setBody(new String(msg.getBody()));

         if (msg.getStartDeliverTime() > 0)

            info.setDeliverTime(new Date(msg.getStartDeliverTime()));

         info.setKey(msg.getKey());

         info.setTag(msg.getTag());

         info.setTopic(msg.getTopic());

         try {

            mqUnSendInfoService.addMQUnSendInfo(info);

         } catch (MQUnSendInfoException e) {

            e.printStackTrace();

         }

      }



   }



   @Override

@@ -150,13 +195,43 @@
      update.setHongBaoPaymentState(BanLiShopOrder.PAY_STATE_PAID);

      // 判断其他待支付项是否已经支付

      update.setUpdateTime(new Date());

      if (order.getState() == BanLiShopOrder.PAY_STATE_NOPAY)

         if ((order.getBalancePaymentState() == null

               || order.getBalancePaymentState() == BanLiShopOrder.PAY_STATE_PAID)

               && (order.getMoneyPaymentState() == null

                     || order.getMoneyPaymentState() == BanLiShopOrder.PAY_STATE_PAID))// 其他待支付项已经支付

            update.setState(BanLiShopOrder.PAY_STATE_PAID);

      order.setHongBaoPaymentState(update.getHongBaoPaymentState());

      update.setState(getOrderPayState(order));

      banLiShopOrderMapper.updateByPrimaryKeySelective(update);

   }



   private int getOrderPayState(BanLiShopOrder order) {

      int needPayCount = 0;

      int paidCount = 0;

      // 获取订单付款状态

      if (order.getHongBaoPayment() != null) {

         needPayCount++;

         if (order.getHongBaoPaymentState() != null

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

            paidCount++;

      }



      if (order.getBalancePayment() != null) {

         needPayCount++;

         if (order.getBalancePaymentState() != null

               && order.getBalancePaymentState() == BanLiShopOrder.PAY_STATE_PAID)

            paidCount++;

      }



      if (order.getMoneyPayment() != null) {

         needPayCount++;

         if (order.getMoneyPaymentState() != null && order.getMoneyPaymentState() == BanLiShopOrder.PAY_STATE_PAID)

            paidCount++;

      }



      if (needPayCount == paidCount)

         return BanLiShopOrder.STATE_PAID;

      else {

         if (paidCount == 0)

            return BanLiShopOrder.STATE_NO_PAY;

         else

            return BanLiShopOrder.STATE_PART_PAY;

      }

   }



   @Override

@@ -181,12 +256,8 @@
      update.setMoneyPaymentState(BanLiShopOrder.PAY_STATE_PAID);

      // 判断其他待支付项是否已经支付

      update.setUpdateTime(new Date());

      if (order.getState() == BanLiShopOrder.PAY_STATE_NOPAY)

         if ((order.getBalancePaymentState() == null

               || order.getBalancePaymentState() == BanLiShopOrder.PAY_STATE_PAID)

               && (order.getHongBaoPaymentState() == null

                     || order.getHongBaoPaymentState() == BanLiShopOrder.PAY_STATE_PAID))// 其他待支付项已经支付

            update.setState(BanLiShopOrder.PAY_STATE_PAID);

      order.setMoneyPaymentState(update.getMoneyPaymentState());

      update.setState(getOrderPayState(order));

      banLiShopOrderMapper.updateByPrimaryKeySelective(update);

   }



@@ -195,4 +266,41 @@
      return banLiShopOrderMapper.selectByPrimaryKeyForUpdate(id);

   }



   @Override

   public void invalidOrderByOrderId(Long id, String desc) {

      // 判断订单是否存在

      BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKeyForUpdate(id);

      if (order == null)

         return;



      // 判断是否处于未付款

      if (order.getState() == BanLiShopOrder.STATE_NO_PAY) {

         BanLiShopOrder update = new BanLiShopOrder();

         update.setId(id);

         update.setStateDesc(desc);

         update.setState(BanLiShopOrder.STATE_INVALID);

         update.setUpdateTime(new Date());

         banLiShopOrderMapper.updateByPrimaryKeySelective(update);

      }

   }



   @Transactional

   @Override

   public void rejectOrder(Long id, String msg) throws BanLiShopOrderException {

      // 判断订单是否处于付款状态

      BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKeyForUpdate(id);

      if (order == null)

         throw new BanLiShopOrderException(1, "订单不存在");



      if (order.getState() != BanLiShopOrder.STATE_PAID)

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



      // TODO 订单退款

      BanLiShopOrder update = new BanLiShopOrder();

      update.setState(BanLiShopOrder.STATE_REJECT);

      update.setStateDesc(msg);

      update.setUpdateTime(new Date());

      banLiShopOrderMapper.updateByPrimaryKeySelective(update);

   }



}