清理多余引用

Administrator

2018-11-29 ebb3551170b255defc25fe93bbf6eb1e84cd321d

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

@@ -26,6 +26,7 @@
import com.yeshi.fanli.dao.mybatis.order.OrderItemMapper;

import com.yeshi.fanli.dao.mybatis.order.OrderMapper;

import com.yeshi.fanli.dao.mybatis.share.PidUserMapper;

import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;

import com.yeshi.fanli.entity.bus.user.AccountDetails;

import com.yeshi.fanli.entity.bus.user.HongBao;

import com.yeshi.fanli.entity.bus.user.HongBaoExtra;

@@ -45,6 +46,7 @@
import com.yeshi.fanli.exception.TaoBaoWeiQuanException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

import com.yeshi.fanli.service.inter.order.LostOrderService;

import com.yeshi.fanli.service.inter.order.OrderItemServcie;

import com.yeshi.fanli.service.inter.order.OrderProcessService;

import com.yeshi.fanli.service.inter.order.OrderService;

@@ -128,6 +130,12 @@
   @Resource

   private RedisManager redisManager;



   @Resource

   private LostOrderService lostOrderService;



   @Resource

   private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper;



   @Override

   public void processOrder(Map<String, List<TaoBaoOrder>> orders) {

      List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

@@ -163,6 +171,7 @@


   /**

    * 利用redis的原子性将订单号锁住，不让其他处理

    * 
    * @param orderId

    */

   private void redisLockOrder(String orderId) {

@@ -172,6 +181,7 @@


   /**

    * 订单解锁

    * 
    * @param orderId

    */

   private void redisUnlockOrder(String orderId) {

@@ -181,6 +191,7 @@


   /**

    * 订单是否被锁住了

    * 
    * @param orderId

    * @return

    */

@@ -202,12 +213,16 @@
         try {

            String orderId = its.next();

            // 处理红包与子红包

//            if (isRedisLockOrder(orderId))

//               continue;

//            redisLockOrder(orderId);

            // if (isRedisLockOrder(orderId))

            // continue;

            // redisLockOrder(orderId);

            processShopingFanliOrder(orderId, orders.get(orderId));

//            redisUnlockOrder(orderId);

            // redisUnlockOrder(orderId);

            // 出错了就不处理该订单了，需要定期检查



            // 更改丢失订单的状态

            lostOrderService.processSuceess(orderId);



         } catch (HongBaoException e1) {

            e1.printStackTrace();

         } catch (OrderItemException e2) {

@@ -383,8 +398,13 @@
         } else// 计算订单的总金额

         {

            BigDecimal money = new BigDecimal(0);

            for (TaoBaoOrder o : orderList)

               money = money.add(o.getPayment());

            for (TaoBaoOrder o : orderList) {

               if (o.getOrderState().equalsIgnoreCase("订单结算"))

                  money = money.add(o.getSettlement());

               else {

                  money = money.add(o.getPayment());

               }

            }

            updateOrder.setMoney(money);

            String thirdState = null;

            for (TaoBaoOrder o : orderList)

@@ -438,6 +458,16 @@
   public void fanli(HongBao hb) throws TaoBaoWeiQuanException {

      // 查询最新的红包数据

      hb = hongBaoMapper.selectByPrimaryKeyForUpdate(hb.getId());

      // 维权中的不返利

      List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper

            .selectListByOrderIdAndState(hb.getOrderId(), "维权创建");

      if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)

         return;



      taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper.selectListByOrderIdAndState(hb.getOrderId(), "等待处理");

      if (taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)

         return;



      long currentTimeMillis = System.currentTimeMillis();

      if (hb.getState() != HongBao.STATE_SHIXIAO) {

         // 设置为已返利

@@ -505,9 +535,9 @@


      List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(order.getOrderId());

      if (orderList != null && orderList.size() > 0 & !StringUtil.isNullOrEmpty(orderList.get(0).getSettlementTime()))

         order.setJieSuanTime(orderList.get(0).getSettlementTime());

      if (TimeUtil.convertToTimeTemp(order.getJieSuanTime(), "yyyy-MM-dd HH:mm:ss") >= TimeUtil

            .convertToTimeTemp("2018-08-05", "yyyy-MM-dd")) {

         order.setJieSuanTime(

               new Date(TimeUtil.convertToTimeTemp(orderList.get(0).getSettlementTime(), "yyyy-MM-dd HH:mm:ss")));

      if (order.getJieSuanTime().getTime() >= TimeUtil.convertToTimeTemp("2018-08-05", "yyyy-MM-dd")) {

         return;

      }

      try {

@@ -543,17 +573,37 @@
      }

   }



   private HongBao filterWeiQuanINGHongBao(HongBao hongBao) {



      List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList = taoBaoWeiQuanOrderMapper

            .selectListByOrderIdAndState(hongBao.getOrderId(), "维权创建");



      List<TaoBaoWeiQuanOrder> taoBaoWeiQuanList1 = taoBaoWeiQuanOrderMapper

            .selectListByOrderIdAndState(hongBao.getOrderId(), "等待处理");

      if ((taoBaoWeiQuanList != null && taoBaoWeiQuanList.size() > 0)

            || (taoBaoWeiQuanList1 != null && taoBaoWeiQuanList1.size() > 0)) {

         return null;

      }

      return hongBao;

   }



   @Override

   @Transactional

   public void fanliInvaiteAndShare(Long uid) throws TaoBaoWeiQuanException {

      /**

       * 处理邀请赚订单

       */

      // 查询UID的邀请赚订单

      List<HongBao> hongBaoList = hongBaoMapper.selectCanBalanceHongBaoByChildHongBaoAndUid(uid);

      BigDecimal money = new BigDecimal(0);



      BigDecimal money = new BigDecimal(0);

      // 需要判断退款的订单号

      Set<String> drawBackOrders = new HashSet<String>();



      for (HongBao hongBao : hongBaoList) {

         hongBao = filterWeiQuanINGHongBao(hongBao);

         if (hongBao == null)

            continue;

			
         hongBao = hongBaoMapper.selectByPrimaryKeyForUpdate(hongBao.getId());

         if (hongBao.getState() == HongBao.STATE_BUKELINGQU || hongBao.getState() == HongBao.STATE_KELINGQU) {

            money = money.add(hongBao.getMoney());

@@ -578,10 +628,17 @@
         }

      }



      /**

       * 处理顶级分享赚

       */



      // 查询UID的分享赚订单

      List<PidOrder> pidOrderList = pidOrderMapper.getCanBalanceListByUid(uid);

      for (PidOrder pidOrder : pidOrderList) {

         HongBao hongBao = hongBaoMapper.selectByPrimaryKeyForUpdate(pidOrder.getHongBao().getId());

         hongBao = filterWeiQuanINGHongBao(hongBao);

         if (hongBao == null)

            continue;

         if (hongBao.getState() == HongBao.STATE_BUKELINGQU || hongBao.getState() == HongBao.STATE_KELINGQU) {

            money = money.add(hongBao.getMoney());

            HongBao updateHongBao = new HongBao();

@@ -602,10 +659,15 @@
         }

      }



      /**

       * 处理一级二级分享赚

       */



      List<HongBao> totalHongBaoList = new ArrayList<>();

      // 查询UID的二级或者三级分享赚订单

      // TODO 暂时查询10000条数据，后面再做分页

      List<HongBao> hbList = hongBaoMapper.selectCanBalanceHongBaoByTypeAndUid(HongBao.TYPE_SHARE_YIJI, uid, 10000);



      if (hbList != null && hbList.size() > 0)

         totalHongBaoList.addAll(hbList);



@@ -613,8 +675,12 @@
      if (hbList != null && hbList.size() > 0)

         totalHongBaoList.addAll(hbList);





      for (HongBao hb : totalHongBaoList) {

         if (hb.getState() == HongBao.STATE_BUKELINGQU || hb.getState() == HongBao.STATE_KELINGQU) {

            hb = filterWeiQuanINGHongBao(hb);

            if (hb == null)

               continue;

            money = money.add(hb.getMoney());

            HongBao updateHongBao = new HongBao();

            updateHongBao.setId(hb.getId());

@@ -626,6 +692,10 @@
         }

      }



      /**

       * 增加用户资金记录

       */



      if (money.compareTo(new BigDecimal(0)) > 0) {

         userInfoMapper.addHongBaoByUid(uid, money);

         // 添加记录