yujian
2019-09-03 2ddf5b8a1290123e2d1c05bcc851ec35cd217afc
fanli/src/main/java/com/yeshi/fanli/service/impl/msg/UserOrderMsgNotificationServiceImpl.java
@@ -7,10 +7,14 @@
import org.springframework.stereotype.Service;
import com.yeshi.fanli.dto.push.PushContentDTO;
import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail;
import com.yeshi.fanli.entity.config.push.PushMsgFactory;
import com.yeshi.fanli.exception.msg.MsgOrderDetailException;
import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.service.inter.msg.MsgOrderDetailService;
import com.yeshi.fanli.service.inter.msg.UserOrderMsgNotificationService;
import com.yeshi.fanli.service.inter.push.PushService;
import com.yeshi.fanli.util.factory.msg.MsgOrderDetailFactory;
@Service
@@ -19,25 +23,38 @@
   @Resource
   private MsgOrderDetailService msgOrderDetailService;
   @Override
   public void orderFanLiStatistic(Long uid, String orderId, BigDecimal payMoney, BigDecimal money, int goodsCount,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createFanLiOrder(uid, orderId, goodsCount, orderState, payMoney,
            money, null);
      try {
   @Resource
   private PushService pushService;
   @Override
   public void orderFanLiStatistic(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,
         int goodsCount, int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createFanLiOrder(uid, orderId, orderType, goodsCount, orderState,
            payMoney, money, null);
      try {
         msgOrderDetailService.addMsgOrderDetail(detail,
               (payMoney == null || payMoney.compareTo(new BigDecimal(0)) <= 0) ? false : true);
      } catch (MsgOrderDetailException e) {
         e.printStackTrace();
      }
      if (payMoney != null && payMoney.compareTo(new BigDecimal(0)) > 0) {
         PushContentDTO dto = PushMsgFactory.createFanLiOrderStatisticed(orderType, orderId, money);
         try {
            pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
         } catch (NumberFormatException e) {
            e.printStackTrace();
         } catch (PushException e) {
            e.printStackTrace();
         }
      }
   }
   @Override
   public void orderFanLiStateChanged(Long uid, String orderId, BigDecimal payMoney, BigDecimal money,
   public void orderFanLiStateChanged(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createFanLiOrder(uid, orderId, 0, orderState, payMoney, money,
            null);
      MsgOrderDetail detail = MsgOrderDetailFactory.createFanLiOrder(uid, orderId, orderType, 0, orderState, payMoney,
            money, null);
      // 暂时不推送
      try {
         msgOrderDetailService.updateMsgOrderDetail(detail, false);
@@ -48,10 +65,10 @@
   }
   @Override
   public void orderShareStatistic(Long uid, String orderId, BigDecimal payMoney, BigDecimal money, int goodsCount,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createShareOrder(uid, orderId, goodsCount, orderState, payMoney,
            money, null);
   public void orderShareStatistic(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,
         int goodsCount, int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createShareOrder(uid, orderId, orderType, goodsCount, orderState,
            payMoney, money, null);
      try {
         msgOrderDetailService.addMsgOrderDetail(detail,
               (payMoney == null || payMoney.compareTo(new BigDecimal(0)) <= 0) ? false : true);
@@ -59,46 +76,64 @@
         e.printStackTrace();
      }
   }
   @Override
   public void orderShareStateChanged(Long uid, String orderId, BigDecimal payMoney, BigDecimal money,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createShareOrder(uid, orderId, 0, orderState, payMoney, money,
            null);
      // 暂时不推送
      PushContentDTO dto = PushMsgFactory.createFanLiOrderStatisticed(orderType, orderId, money);
      try {
         msgOrderDetailService.updateMsgOrderDetail(detail, false);
      } catch (MsgOrderDetailException e) {
         pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
      } catch (NumberFormatException e) {
         e.printStackTrace();
      } catch (PushException e) {
         e.printStackTrace();
      }
   }
   @Override
   public void orderInviteStatistic(Long uid, String orderId, BigDecimal payMoney, BigDecimal money, int goodsCount,
   public void orderShareStateChanged(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, goodsCount, orderState, payMoney,
      MsgOrderDetail detail = MsgOrderDetailFactory.createShareOrder(uid, orderId, orderType, 0, orderState, payMoney,
            money, null);
      // 暂时不推送
      // try {
      // msgOrderDetailService.updateMsgOrderDetail(detail, false);
      // } catch (MsgOrderDetailException e) {
      // e.printStackTrace();
      // }
   }
   @Override
   public void orderInviteStatistic(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,
         int goodsCount, int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, orderType, goodsCount, orderState,
            payMoney, money, null);
      try {
         msgOrderDetailService.addMsgOrderDetail(detail,
               (money == null || money.compareTo(new BigDecimal(0)) <= 0) ? false : true);
      } catch (MsgOrderDetailException e) {
         e.printStackTrace();
      }
      PushContentDTO dto = PushMsgFactory.createInviteOrderStatisticed(orderType, orderId, money);
      try {
         pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
      } catch (NumberFormatException e) {
         e.printStackTrace();
      } catch (PushException e) {
         e.printStackTrace();
      }
   }
   @Override
   public void orderInviteStateChanged(Long uid, String orderId, BigDecimal payMoney, BigDecimal money,
   public void orderInviteStateChanged(Long uid, String orderId, int orderType, BigDecimal payMoney, BigDecimal money,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, 0, orderState, payMoney, money,
            null);
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, orderType, 0, orderState,
            payMoney, money, null);
      // 暂时不推送
      try {
         msgOrderDetailService.updateMsgOrderDetail(detail, false);
      } catch (MsgOrderDetailException e) {
         e.printStackTrace();
      }
      // try {
      // msgOrderDetailService.updateMsgOrderDetail(detail, false);
      // } catch (MsgOrderDetailException e) {
      // e.printStackTrace();
      // }
   }
@@ -110,29 +145,39 @@
   }
   @Override
   public void orderShareFirstLevelStatistic(Long uid, String orderId, BigDecimal payMoney, BigDecimal money,
         int goodsCount, int orderState, String sourceUserName) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, goodsCount, orderState, payMoney,
            money, String.format("由一级队员【%s】分享", getShortName(sourceUserName)));
   public void orderShareFirstLevelStatistic(Long uid, String orderId, int orderType, BigDecimal payMoney,
         BigDecimal money, int goodsCount, int orderState, String sourceUserName) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, orderType, goodsCount, orderState,
            payMoney, money, String.format("由一级队员【%s】分享", getShortName(sourceUserName)));
      try {
         msgOrderDetailService.addMsgOrderDetail(detail,
               (money == null || money.compareTo(new BigDecimal(0)) <= 0) ? false : true);
      } catch (MsgOrderDetailException e) {
         e.printStackTrace();
      }
      PushContentDTO dto = PushMsgFactory.createInviteOrderStatisticed(orderType, orderId, money);
      try {
         pushService.pushZNX(uid, dto.getTitle(), dto.getContent(), null, null);
      } catch (NumberFormatException e) {
         e.printStackTrace();
      } catch (PushException e) {
         e.printStackTrace();
      }
   }
   @Override
   public void orderShareFirstLevelStateChanged(Long uid, String orderId, BigDecimal payMoney, BigDecimal money,
         int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, 0, orderState, payMoney, money,
            null);
   public void orderShareFirstLevelStateChanged(Long uid, String orderId, int orderType, BigDecimal payMoney,
         BigDecimal money, int orderState) {
      MsgOrderDetail detail = MsgOrderDetailFactory.createInviteOrder(uid, orderId, orderType, 0, orderState,
            payMoney, money, null);
      // 暂时不推送
      try {
         msgOrderDetailService.updateMsgOrderDetail(detail, false);
      } catch (MsgOrderDetailException e) {
         e.printStackTrace();
      }
      // try {
      // msgOrderDetailService.updateMsgOrderDetail(detail, false);
      // } catch (MsgOrderDetailException e) {
      // e.printStackTrace();
      // }
   }
   @Override