订单接口筛选统计数据调整

yujian

2019-01-04 38fffe4319f408b5dc1da23d30512e90b0f4feac

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

@@ -13,6 +13,7 @@
import javax.annotation.Resource;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Propagation;

import org.springframework.transaction.annotation.Transactional;



import com.yeshi.fanli.dao.mybatis.AccountDetailsMapper;

@@ -23,6 +24,7 @@
import com.yeshi.fanli.dao.mybatis.ThreeSaleGiftMapper;

import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

import com.yeshi.fanli.dao.mybatis.hongbao.HongBaoMapper;

import com.yeshi.fanli.dao.mybatis.money.UserMoneyDetailMapper;

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

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

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

@@ -30,10 +32,13 @@
import com.yeshi.fanli.entity.bus.user.AccountDetails;

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

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

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

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

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

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

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

import com.yeshi.fanli.entity.money.UserMoneyDetail;

import com.yeshi.fanli.entity.order.CommonOrder;

import com.yeshi.fanli.entity.taobao.PidOrder;

import com.yeshi.fanli.entity.taobao.PidUser;

import com.yeshi.fanli.entity.taobao.TaoBaoOrder;

@@ -44,10 +49,14 @@
import com.yeshi.fanli.exception.ObjectStateException;

import com.yeshi.fanli.exception.OrderItemException;

import com.yeshi.fanli.exception.TaoBaoWeiQuanException;

import com.yeshi.fanli.exception.money.UserMoneyDetailException;

import com.yeshi.fanli.exception.order.CommonOrderException;

import com.yeshi.fanli.log.LogHelper;

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

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

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

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

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

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

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

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

@@ -64,6 +73,7 @@
import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

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

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

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



@Service

@@ -144,6 +154,9 @@
   @Resource

   private AccountDetailsHongBaoMapService accountDetailsHongBaoMapService;



   @Resource

   private UserMoneyDetailMapper userMoneyDetailMapper;



   @Override

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

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

@@ -151,7 +164,8 @@
      // 分离出返利订单与分享赚订单

      Iterator<String> its = orders.keySet().iterator();

      Map<String, List<TaoBaoOrder>> fanliOrderMap = new HashMap<>();

      Map<String, List<PidOrder>> shareOrderMap = new HashMap<>();

      Map<String, List<PidOrder>> sharePidOrderMap = new HashMap<>();

      Map<String, List<TaoBaoOrder>> shareOrderMap = new HashMap<>();

      while (its.hasNext()) {

         String orderId = its.next();

         if (orders.get(orderId) != null && orders.get(orderId).size() > 0) {

@@ -160,11 +174,12 @@
                  list.get(0).getSourceMediaId(), list.get(0).getAdPositionId());

            PidUser pidUser = pidUserMapper.selectByPid(pid);

            if (pidUser != null && pidUser.getType() == PidUser.TYPE_SHARE_GOODS) {// 商品分享订单

               List<PidOrder> pidOrderList = new ArrayList<>();

               for (TaoBaoOrder order : list) {

                  pidOrderList.add(TaoBaoOrderUtil.convertToPidOrder(order));

               }

               shareOrderMap.put(orderId, pidOrderList);

               // List<PidOrder> pidOrderList = new ArrayList<>();

               // for (TaoBaoOrder order : list) {

               // pidOrderList.add(TaoBaoOrderUtil.convertToPidOrder(order));

               // }

               // sharePidOrderMap.put(orderId, pidOrderList);

               shareOrderMap.put(orderId, list);

            } else {// 普通返利订单

               fanliOrderMap.put(orderId, list);

            }

@@ -212,19 +227,20 @@
         return false;

   }



   @Transactional

   @Override

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

      // 查询在Order中是否存在该订单号

      Iterator<String> its = orders.keySet().iterator();

      String tempOrderId = "";

      while (its.hasNext()) {

         try {

            String orderId = its.next();

            tempOrderId = orderId;

            // 处理红包与子红包

            // if (isRedisLockOrder(orderId))

            // continue;

            // redisLockOrder(orderId);

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

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

            // redisUnlockOrder(orderId);

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



@@ -236,15 +252,27 @@
         } catch (OrderItemException e2) {

            e2.printStackTrace();

         } catch (Exception e) {



            e.printStackTrace();

            try {

               LogHelper.errorDetailInfo(e, null, tempOrderId);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

      }

   }



   @Transactional

   @Override

   public void processShareGoodsOrder(Map<String, List<PidOrder>> orders) {

      pidOrderService.addPidOrderFromTaoBao(orders);

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

      // pidOrderService.addPidOrderFromTaoBao(orders);

      if (orders != null) {

         Iterator<String> its = orders.keySet().iterator();

         while (its.hasNext()) {

            String orderId = its.next();

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

         }

      }

   }



   /**

@@ -509,6 +537,20 @@
                  AccountDetailsFactory.FANLI, orderItem, null, hb.getUserInfo());

            accountDetailsMapper.insertSelective(accountDetails);



            // 插入新版资金明细

            try {

               UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createFanLi(hb.getUserInfo().getId(),

                     hb.getOrderId(), 1, hb.getId(), hb.getMoney());

               userMoneyDetail.setId(accountDetails.getId());

               userMoneyDetailMapper.insert(userMoneyDetail);

            } catch (UserMoneyDetailException e1) {

               try {

                  LogHelper.errorDetailInfo(e1);

               } catch (Exception e2) {

                  e2.printStackTrace();

               }

            }



            // 添加资金明细与红包的映射关系

            accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(hb.getId(), accountDetails.getId());



@@ -609,7 +651,7 @@


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



      BigDecimal money = new BigDecimal(0);

      BigDecimal invitemoney = new BigDecimal(0);

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

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

      for (HongBao hongBao : hongBaoList) {

@@ -619,7 +661,7 @@


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

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

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

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

            HongBao updateHongBao = new HongBao();

            updateHongBao.setId(hongBao.getId());

            updateHongBao.setGetTime(System.currentTimeMillis());

@@ -644,9 +686,84 @@
      }



      /**

       * 处理顶级分享赚

       * 处理一级二级分享赚(属于邀请赚类型)

       */



      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);



      hbList = hongBaoMapper.selectCanBalanceHongBaoByTypeAndUid(HongBao.TYPE_SHARE_ERJI, uid, 10000);

      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;

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

            HongBao updateHongBao = new HongBao();

            updateHongBao.setId(hb.getId());

            updateHongBao.setGetTime(System.currentTimeMillis());

            updateHongBao.setState(HongBao.STATE_YILINGQU);

            hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);

            // 添加到红包返利记录集合

            hbIdList.add(hb.getId());

            if (!StringUtil.isNullOrEmpty(hb.getOrderId()))

               drawBackOrders.add(hb.getOrderId());

         }

      }



      // 邀请赚到账

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

         userInfoMapper.addHongBaoByUid(uid, invitemoney);

         // 添加记录

         AccountDetails accountDetails = AccountDetailsFactory.create("+" + invitemoney,

               AccountDetailsFactory.TICHENG, null, null, new UserInfo(uid));

         accountDetailsMapper.insertSelective(accountDetails);



         // 添加新版详情记录

         try {

            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createInvite(uid, 0, 0, 0, invitemoney,

                  new Date());

            userMoneyDetail.setId(accountDetails.getId());

            userMoneyDetailMapper.insert(userMoneyDetail);

         } catch (UserMoneyDetailException e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }



         // 记录返利红包与资金详情的对应关系



         // 添加到红包返利记录集合

         accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(hbIdList, accountDetails.getId());



         // 发送推送

         try {

            // 提成到账消息通知

            userNotificationService.tiChengInviteRecieved(uid, invitemoney);

         } catch (Exception e) {

            e.printStackTrace();

         }

         for (String orderId : drawBackOrders)

            taoBaoWeiQuanDrawBackService.doWeiQuanInvite(orderId);

      }



      hbIdList.clear();

      drawBackOrders.clear();



      /**

       * 处理分享赚

       */

      BigDecimal sharemoney = new BigDecimal(0);

      // 查询UID的分享赚订单

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

      for (PidOrder pidOrder : pidOrderList) {

@@ -655,7 +772,7 @@
         if (hongBao == null)

            continue;

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

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

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

            HongBao updateHongBao = new HongBao();

            updateHongBao.setId(hongBao.getId());

            updateHongBao.setGetTime(System.currentTimeMillis());

@@ -677,49 +794,29 @@
      }



      /**

       * 处理一级二级分享赚

       * 分享赚到账

       */



      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);



      hbList = hongBaoMapper.selectCanBalanceHongBaoByTypeAndUid(HongBao.TYPE_SHARE_ERJI, uid, 10000);

      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());

            updateHongBao.setGetTime(System.currentTimeMillis());

            updateHongBao.setState(HongBao.STATE_YILINGQU);

            hongBaoMapper.updateByPrimaryKeySelective(updateHongBao);

            // 添加到红包返利记录集合

            hbIdList.add(hb.getId());

            if (!StringUtil.isNullOrEmpty(hb.getOrderId()))

               drawBackOrders.add(hb.getOrderId());

         }

      }



      /**

       * 增加用户资金记录

       */



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

         userInfoMapper.addHongBaoByUid(uid, money);

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

         userInfoMapper.addHongBaoByUid(uid, sharemoney);

         // 添加记录

         AccountDetails accountDetails = AccountDetailsFactory.create("+" + money, AccountDetailsFactory.TICHENG,

               null, null, new UserInfo(uid));

         AccountDetails accountDetails = AccountDetailsFactory.create("+" + sharemoney,

               AccountDetailsFactory.SHARE_GOODS, null, null, new UserInfo(uid));

         accountDetailsMapper.insertSelective(accountDetails);



         // 添加新版详情记录

         try {

            UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createShare(uid, 0, 0, 0, sharemoney,

                  new Date());

            userMoneyDetail.setId(accountDetails.getId());

            userMoneyDetailMapper.insert(userMoneyDetail);

         } catch (UserMoneyDetailException e) {

            try {

               LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

               e1.printStackTrace();

            }

         }

         // 记录返利红包与资金详情的对应关系



         // 添加到红包返利记录集合

@@ -728,13 +825,128 @@
         // 发送推送

         try {

            // 提成到账消息通知

            userNotificationService.tiChengRecieved(uid, money);

            userNotificationService.tiChengShareRecieved(uid, sharemoney);

         } catch (Exception e) {

            e.printStackTrace();

         }

         for (String orderId : drawBackOrders)

            taoBaoWeiQuanDrawBackService.doWeiQuanShare(orderId);

      }



   }



   @Resource

   private CommonOrderService commonOrderService;



   @Resource

   private HongBaoV2Service hongBaoV2Service;



   @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)

   @Override

   public void processShopingFanliOrderNew(String orderId, List<TaoBaoOrder> orderList)

         throws HongBaoException, OrderItemException {

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



      if (orderList != null && orderList.size() > 0) {

         String pid = String.format("mm_%s_%s_%s", configList.get(0).getAccountId(),

               orderList.get(0).getSourceMediaId(), orderList.get(0).getAdPositionId());



         Order oldOrder = orderMapper.selectOrderByOrderId(orderId);

         // 原来不存在订单

         Long uid = null;

         if (oldOrder == null) {

            PidUser pidUser = pidUserMapper.selectByPid(pid);

            if (pidUser != null) {

               uid = pidUser.getUid();



               // 插入到Order中

               // 添加到订单中去

               Order order = new Order();

               order.setBeizhu("PID返利订单");

               order.setCreatetime(System.currentTimeMillis());

               order.setOrderId(orderId);

               order.setOrderType(1);

               order.setState(Order.STATE_YIZHIFU);

               order.setUserInfo(new UserInfo(uid));

               order.setVersion(2);

               // 加入到订单表

               orderMapper.insertSelective(order);

               oldOrder = order;

            }

         } else {

            uid = oldOrder.getUserInfo().getId();



         }

         // 尚未找到和PID对应的用户

         if (uid == null)

            return;



         // 计算订单总额度

         Order updateOrder = new Order();

         updateOrder.setId(oldOrder.getId());

         BigDecimal money = new BigDecimal(0);

         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)

            if (!o.getOrderState().equalsIgnoreCase("订单失效")) {

               thirdState = o.getOrderState();

               break;

            }

         updateOrder.setThirdState(thirdState);

         updateOrder.setThirdCreateTime(

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

         orderMapper.updateByPrimaryKeySelective(updateOrder);



         // 用第一个子订单锁定用户

         for (TaoBaoOrder taoBaoOrder : orderList) {

            try {

               CommonOrder commonOrder = commonOrderService.addTaoBaoOrder(taoBaoOrder, uid);

               hongBaoV2Service.addHongBao(commonOrder, HongBaoV2.TYPE_ZIGOU);

            } catch (CommonOrderException e) {

               e.printStackTrace();

            } catch (HongBaoException e1) {

               e1.printStackTrace();

            }

         }

      }

   }



   @Override

   public void processShareGoodsOrderNew(String orderId, List<TaoBaoOrder> orderList) {

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

      if (orderList != null && orderList.size() > 0) {

         String pid = String.format("mm_%s_%s_%s", configList.get(0).getAccountId(),

               orderList.get(0).getSourceMediaId(), orderList.get(0).getAdPositionId());

         // 原来不存在订单

         Long uid = null;

         PidUser pidUser = pidUserMapper.selectByPid(pid);

         if (pidUser != null)

            uid = pidUser.getUid();



         // 尚未找到和PID对应的用户

         if (uid == null)

            return;



         // 用第一个子订单锁定用户

         for (TaoBaoOrder taoBaoOrder : orderList) {

            try {

               CommonOrder commonOrder = commonOrderService.addTaoBaoOrder(taoBaoOrder, uid);

               hongBaoV2Service.addHongBao(commonOrder, HongBaoV2.TYPE_SHARE_GOODS);

            } catch (CommonOrderException e) {

               e.printStackTrace();

            } catch (HongBaoException e1) {

               e1.printStackTrace();

            }

         }

      }



   }



}