订单统计/订单到账消息通知修改

admin

2019-11-07 f3bcea3e6e9c8e93123487ec2ee0b33176bd8697

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

@@ -10,6 +10,7 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.transaction.support.DefaultTransactionDefinition;

import org.yeshi.utils.exception.WXOrderException;



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

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

@@ -45,6 +46,7 @@
import com.yeshi.fanli.util.factory.RedPackDetailFactory;

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

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

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



@Service

public class BanLiShopOrderServiceImpl implements BanLiShopOrderService {

@@ -151,6 +153,7 @@
      orderGoods.setSetName(set.getName());

      orderGoods.setState(set.getState());

      orderGoods.setZkPrice(set.getZkPrice());

      orderGoods.setPicture(goods.getSquarePicture());

      banLiShopOrderGoodsMapper.insertSelective(orderGoods);

      return orderGoods;

   }

@@ -319,6 +322,28 @@


      // 判断是否处于未付款

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

         /**

          * 查询是否已经微信支付

          */

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

            try {

               boolean isS = BanLiShopWXPayUtil.isPaySuccess(order.getOrderNo());

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

                  producer.send(message);

                  return;

               }



            } catch (WXOrderException e) {

               e.printStackTrace();

            } catch (Exception e) {



            }

         }



         BanLiShopOrder update = new BanLiShopOrder();

         update.setId(id);

         update.setStateDesc(desc);

@@ -422,4 +447,9 @@
      return order;

   }



   @Override

   public BanLiShopOrder selectByOrderNo(String orderNo) {

      return banLiShopOrderMapper.selectByOrderNo(orderNo);

   }



}