资金明细接口增加筛选

admin

2019-11-26 ea022e84777312b730257dfcf2a33e865c8e07b7

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java

@@ -419,10 +419,9 @@
      // 自购到账事务消息

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_ZIGOU,

            mainUser.getId(), hongBaoOrder.getCommonOrder().getSourceType(),

            hongBaoOrder.getCommonOrder().getOrderNo(), null, new Date(),0);

            hongBaoOrder.getCommonOrder().getOrderNo(), null, new Date(), 0);

      mqMsg.setOrderFirst(first);

      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual,

            mqMsg);

      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiActual, mqMsg);

      String key = mainUser.getId() + "-" + UUID.randomUUID().toString();

      msg.setKey(key);

      try {

@@ -506,8 +505,10 @@
      List<Long> inviteAndShareUids = hongBaoV2Mapper.listUidCanBanlanceShareAndInvite(1000);

      Set<Long> uidSets = new HashSet<>();

      if (inviteAndShareUids != null)

         for (Long uid : inviteAndShareUids)

            uidSets.add(uid);

         for (Long uid : inviteAndShareUids) {

            if (userInfoMapper.selectAvailableByPrimaryKey(uid) != null)

               uidSets.add(uid);

         }

      // 根据用户ID

      Iterator<Long> its = uidSets.iterator();

      while (its.hasNext()) {

@@ -530,15 +531,13 @@
      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }

      if (1 > 0)

         return;



      //

      try {

         orderMoneySettleService.inviteSettleJD(uid);

      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }



      //

      try {

         orderMoneySettleService.inviteSettlePDD(uid);

      } catch (OrderMoneySettleException e) {

@@ -557,7 +556,7 @@
      } catch (OrderMoneySettleException e) {

         e.printStackTrace();

      }



      //

      try {

         orderMoneySettleService.shareSettlePDD(uid);

      } catch (OrderMoneySettleException e) {

@@ -1220,9 +1219,8 @@
      }

      if (resultCode == 1) {// 只发送新增消息

         OrderMQMsg mqMsg = new OrderMQMsg(orderId, sourceType, uid, OrderMQMsg.HANDLE_TYPE_ADD,

               isCommonOrderValid(coList),0,new Date());

         Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderStatistic,

               mqMsg);

               isCommonOrderValid(coList), 0, new Date());

         Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderStatistic, mqMsg);

         producer.send(msg);

      }

   }