多系统兼容优化

admin

2020-07-04 9d35ba657fa5e3add766405d76e3ff8c4dcd4ad4

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/msg/UserOrderMsgNotificationServiceImpl.java

@@ -5,6 +5,8 @@


import javax.annotation.Resource;



import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



@@ -28,6 +30,9 @@
   @Resource

   private PushService pushService;

   

    @Resource

    private UserInfoService userInfoService;





   @Override

   public void orderFanLiStatistic(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,

@@ -37,10 +42,12 @@
      // 保存消息明细消息

      addOrderStatistics(uid, orderId, orderType, Constant.TYPE_REBATE, goodsCount, payMoney, money, downTime, null, needNotify);

      

        SystemEnum system = userInfoService.getUserSystem(uid);



      if (needNotify) {

         PushContentDTO dto = PushMsgFactory.createFanLiOrderStatisticed(orderType, orderId, money);

         try {

            pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);

                pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null, system);

         } catch (NumberFormatException e) {

            e.printStackTrace();

         } catch (PushException e) {

@@ -58,10 +65,11 @@
      // 保存消息明细消息

      addOrderStatistics(uid, orderId, orderType, Constant.TYPE_SHAER, goodsCount, payMoney, money, downTime, null, needNotify);

      

        SystemEnum system = userInfoService.getUserSystem(uid);



      PushContentDTO dto = PushMsgFactory.createShareOrderStatisticed(orderType, orderId, money);

      try {

         pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);

            pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null, system);

      } catch (NumberFormatException e) {

         e.printStackTrace();

      } catch (PushException e) {

@@ -86,12 +94,14 @@
         return;

      }

      

        SystemEnum system = userInfoService.getUserSystem(uid);



      // 保存消息明细消息

      addOrderStatistics(uid, orderId, orderType, Constant.TYPE_INVITE, goodsCount, payMoney, totalMoney, downTime, null, true);



      PushContentDTO dto = PushMsgFactory.createInviteOrderStatisticed(orderType, orderId, money);

      try {

         pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);

            pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null, system);

      } catch (NumberFormatException e) {

         e.printStackTrace();

      } catch (PushException e) {

@@ -101,6 +111,7 @@
   

   /**

    * 创建订单被统计消息

     *

    * @param uid

    * @param orderId 订单号

    * @param source  订单来源：淘宝、京东、天猫

@@ -123,7 +134,6 @@
         e.printStackTrace();

      }

   }







   @Override