帮助中心 + 新人红包统计

yujian

2019-12-26 012232edc4dac15517c69c2af3934f901e818b7c

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

@@ -60,6 +60,7 @@
import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.cmq.HongBaoRecieveCMQManager;

import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;

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

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

import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil;



@@ -113,7 +114,7 @@
   @Resource

   private HongBaoV2SettleTempService hongBaoV2SettleTempService;



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void inviteSettleTB(Long uid) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

@@ -154,9 +155,9 @@


      // 邀请赚到账事务消息

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_INVITE, uid,

            sourceType, null, null, new Date());

      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiActual.name(),

            new Gson().toJson(mqMsg).getBytes());

            sourceType, null, null, new Date(), 0);



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

      String taskKey = getTaskKey(uid);

      msg.setKey(taskKey);

      // 添加事务消息

@@ -175,9 +176,10 @@
      } catch (Exception e) {

         LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));

      }

      System.out.println(new Gson().toJson(mqMsg));

   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void inviteSettleJD(Long uid) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

@@ -218,8 +220,8 @@


      // 邀请赚到账事务消息

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_INVITE, uid,

            sourceType, null, null, new Date());

      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiActual.name(), new Gson().toJson(mqMsg).getBytes());

            sourceType, null, null, new Date(), 0);

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

      String taskKey = getTaskKey(uid);

      msg.setKey(taskKey);

      // 添加事务消息

@@ -236,7 +238,7 @@
      }

   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void inviteSettlePDD(Long uid) throws OrderMoneySettleException {

      // 查询UID的一二级邀请赚

@@ -277,8 +279,8 @@


      // 邀请赚到账事务消息

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_INVITE, uid,

            sourceType, null, null, new Date());

      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiActual.name(), new Gson().toJson(mqMsg).getBytes());

            sourceType, null, null, new Date(), 0);

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

      String taskKey = getTaskKey(uid);

      msg.setKey(taskKey);

      // 添加事务消息

@@ -295,7 +297,7 @@
      }

   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void shareSettleTB(Long uid) throws OrderMoneySettleException {

      /**

@@ -317,9 +319,9 @@
            hongBaoList.addAll(tempHongBaoList);

      }



      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid,

            sourceType, null, null, new Date());

      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(),OrderTopicTagEnum.orderFanLiActual.name(), new Gson().toJson(mqMsg).getBytes());

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid, sourceType,

            null, null, new Date(), 0);

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

      String taskKey = getTaskKey(uid);

      msg.setKey(taskKey);

      // 添加事务消息

@@ -340,7 +342,7 @@
      }

   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void shareSettleJD(Long uid) throws OrderMoneySettleException {

      /**

@@ -362,9 +364,9 @@
            hongBaoList.addAll(tempHongBaoList);

      }



      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid,

            sourceType, null, null, new Date());

      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiActual.name(), new Gson().toJson(mqMsg).getBytes());

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid, sourceType,

            null, null, new Date(), 0);

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

      String taskKey = getTaskKey(uid);

      msg.setKey(taskKey);

      // 添加事务消息

@@ -381,7 +383,7 @@
      }

   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void shareSettlePDD(Long uid) throws OrderMoneySettleException {

      /**

@@ -403,9 +405,9 @@
            hongBaoList.addAll(tempHongBaoList);

      }



      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid,

            sourceType, null, null, new Date());

      Message msg = new Message(MQTopicName.TOPIC_ORDER.name(), OrderTopicTagEnum.orderFanLiActual.name(), new Gson().toJson(mqMsg).getBytes());

      OrderMoneyRecievedMQMsg mqMsg = new OrderMoneyRecievedMQMsg(OrderMoneyRecievedMQMsg.TYPE_SHARE, uid, sourceType,

            null, null, new Date(), 0);

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

      String taskKey = getTaskKey(uid);

      msg.setKey(taskKey);

      // 添加事务消息

@@ -422,7 +424,7 @@
      }

   }



   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void ziGouSettle(String orderId, int sourceType, String taskKey) throws OrderMoneySettleException {

      // 查询同一订单号的红包

@@ -574,7 +576,7 @@
      return hongBao;

   }



   @Transactional

   @Transactional(rollbackFor = Exception.class)

   private void fanliInviteTB(List<HongBaoV2> hongBaoList, Long uid, String key) throws TaoBaoWeiQuanException {

      List<Long> hbIdList = new ArrayList<>();

      BigDecimal invitemoney = new BigDecimal(0);

@@ -627,9 +629,9 @@
            Date minDate = new Date(TimeUtil

                  .convertToTimeTemp(ca.get(Calendar.YEAR) + "-" + (ca.get(Calendar.MONTH) + 1), "yyyy-M"));

            long validCount = hongBaoV2Mapper.countInviteOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_JS,

                  minDate, maxDate);

                  minDate, maxDate, Constant.SOURCE_TYPE_TAOBAO);

            long weiQuanCount = hongBaoV2Mapper.countInviteOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_WQ,

                  minDate, maxDate);

                  minDate, maxDate, Constant.SOURCE_TYPE_TAOBAO);



            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInvite(uid, Constant.SOURCE_TYPE_TAOBAO,

                  (int) validCount, (int) weiQuanCount, invitemoney, new Date());

@@ -713,9 +715,9 @@
            Date minDate = new Date(TimeUtil

                  .convertToTimeTemp(ca.get(Calendar.YEAR) + "-" + (ca.get(Calendar.MONTH) + 1), "yyyy-M"));

            long validCount = hongBaoV2Mapper.countInviteOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_JS,

                  minDate, maxDate);

                  minDate, maxDate, sourceType);

            long weiQuanCount = hongBaoV2Mapper.countInviteOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_WQ,

                  minDate, maxDate);

                  minDate, maxDate, sourceType);



            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInvite(uid, sourceType, (int) validCount,

                  (int) weiQuanCount, invitemoney, new Date());

@@ -811,9 +813,9 @@
            Date minDate = new Date(TimeUtil

                  .convertToTimeTemp(ca.get(Calendar.YEAR) + "-" + (ca.get(Calendar.MONTH) + 1), "yyyy-M"));

            long validCount = hongBaoV2Mapper.countShareOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_JS,

                  minDate, maxDate);

                  minDate, maxDate, Constant.SOURCE_TYPE_TAOBAO);

            long weiQuanCount = hongBaoV2Mapper.countShareOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_WQ,

                  minDate, maxDate);

                  minDate, maxDate, Constant.SOURCE_TYPE_TAOBAO);



            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, Constant.SOURCE_TYPE_TAOBAO,

                  (int) validCount, (int) weiQuanCount, sharemoney, new Date());

@@ -909,12 +911,12 @@
            Date minDate = new Date(TimeUtil

                  .convertToTimeTemp(ca.get(Calendar.YEAR) + "-" + (ca.get(Calendar.MONTH) + 1), "yyyy-M"));

            long validCount = hongBaoV2Mapper.countShareOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_JS,

                  minDate, maxDate);

                  minDate, maxDate, sourceType);

            long weiQuanCount = hongBaoV2Mapper.countShareOrderCountByUidAndSettleTime(uid, CommonOrder.STATE_WQ,

                  minDate, maxDate);

                  minDate, maxDate, sourceType);



            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, Constant.SOURCE_TYPE_TAOBAO,

                  (int) validCount, (int) weiQuanCount, sharemoney, new Date());

            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, sourceType, (int) validCount,

                  (int) weiQuanCount, sharemoney, new Date());

            // 添加资金

            userMoneyService.addUserMoney(uid, sharemoney, userMoneyDetail);



@@ -954,7 +956,7 @@
    * @param orderId

    * @param sourceType

    */

   @Transactional

   @Transactional(rollbackFor=Exception.class)

   @Override

   public void inviteSubsidySettle(Long uid, String taskKey) throws OrderMoneySettleException {

      // 查询key