加入任务

admin

2019-09-06 2012b3b5db3c6b06535a68f775bcc81b16151b90

 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java

@@ -20,22 +20,29 @@
import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;

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

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

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

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

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

import com.yeshi.fanli.entity.jd.JDOrder;

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

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

import com.yeshi.fanli.entity.pdd.PDDOrder;

import com.yeshi.fanli.entity.push.PushQueueRecord;

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

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

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

import com.yeshi.fanli.exception.TaoBaoWeiQuanException;

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

import com.yeshi.fanli.log.LogHelper;

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

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

import com.yeshi.fanli.service.inter.integral.IntegralGetService;

import com.yeshi.fanli.service.inter.integral.IntegralTaskRecordService;

import com.yeshi.fanli.service.inter.jd.JDOrderService;

import com.yeshi.fanli.service.inter.lable.BoutiqueAutoRuleService;

import com.yeshi.fanli.service.inter.lable.LabelService;

import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;

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

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

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

import com.yeshi.fanli.service.inter.pdd.PDDOrderService;

import com.yeshi.fanli.service.inter.push.IOSPushService;

@@ -47,6 +54,7 @@
import com.yeshi.fanli.util.cmq.HongBaoRecieveCMQManager;

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

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

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

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

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

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

@@ -111,6 +119,15 @@
   @Resource

   private IntegralGetService integralGetService;



   @Resource

   private CommonOrderService commonOrderService;



   @Resource

   private HongBaoOrderService hongBaoOrderService;



   @Resource

   private IntegralTaskRecordService integralTaskRecordService;



   private static boolean isInited = false;



   public void onApplicationEvent(ContextRefreshedEvent arg0) {

@@ -146,6 +163,7 @@
         doPDDOrderJob();// 拼多多订单处理

         doImportantTaoBaoGoodsUpdateJob();// 淘宝重要商品的信息更新

         doHongBaoRecieveIntegralGetJob();// 返利到账，金币增加

         doPlaceOrderIntegralJob();// 下单赠送金币任务

      }



   }

@@ -743,7 +761,136 @@
            }

         }

      });

   }



   private boolean isFirstValidOrder(String orderId, int sourceType, Long uid) {

      CommonOrder commonOrder = commonOrderService.selectLatestValidByUid(uid);

      if (commonOrder != null && commonOrder.getOrderNo().equalsIgnoreCase(orderId)

            && sourceType == commonOrder.getSourceType())

         return true;

      else

         return false;

   }



   // 下单获取金币任务

   public void doPlaceOrderIntegralJob() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               Map<String, Order> map = PlaceOrderCMQManager.getInstance()

                     .consumeQueueMsg(PlaceOrderCMQManager.QUEUE_INTEGRAL, 16);

               if (map != null) {

                  // 是否是首单

                  for (Iterator<String> its = map.keySet().iterator(); its.hasNext();) {

                     try {

                        String key = its.next();

                        Order order = map.get(key);

                        // 统计订单下的用户所获得的返利金额

                        List<CommonOrder> list = commonOrderService

                              .listBySourceTypeAndOrderId(order.getOrderType(), order.getOrderId());

                        Map<Long, BigDecimal> hongBaoMoney = new HashMap<>();

                        if (list != null)

                           for (CommonOrder commonOrder : list) {

                              HongBaoOrder hongBaoOrder = hongBaoOrderService

                                    .selectDetailByCommonOrderId(commonOrder.getId());

                              if (hongBaoOrder != null && hongBaoOrder.getHongBaoV2() != null) {

                                 Long mainUid = hongBaoOrder.getHongBaoV2().getUserInfo().getId();

                                 if (hongBaoMoney.get(mainUid) == null)

                                    hongBaoMoney.put(mainUid, new BigDecimal(0));

                                 hongBaoMoney.put(mainUid, hongBaoMoney.get(mainUid)

                                       .add(hongBaoOrder.getHongBaoV2().getMoney()));

                                 // 查询上级

                                 List<HongBaoV2> children = hongBaoV2Service

                                       .listChildrenById(hongBaoOrder.getHongBaoV2().getId());

                                 if (children != null) {

                                    for (HongBaoV2 hongBao : children) {

                                       Long uid = hongBao.getUserInfo().getId();

                                       if (hongBaoMoney.get(uid) == null)

                                          hongBaoMoney.put(uid, new BigDecimal(0));

                                       hongBaoMoney.put(uid,

                                             hongBaoMoney.get(uid).add(hongBao.getMoney()));

                                    }

                                 }

                              }

                           }



                        if (isFirstValidOrder(order.getOrderId(), order.getOrderType(),

                              order.getUserInfo().getId())) {// 有效的首单

                           if (hongBaoMoney.get(order.getUserInfo().getId()) == null || hongBaoMoney

                                 .get(order.getUserInfo().getId()).compareTo(new BigDecimal("0")) <= 0) {

                              // 分享奖金是0

                              integralTaskRecordService.firstShareOrderReward(order.getUserInfo().getId(),

                                    null);

                           }



                           // 获取上两级数据

                           UserInfo boss = threeSaleSerivce.getBoss(order.getUserInfo().getId());

                           if (boss != null) {// 判断上级的红包

                              if (hongBaoMoney.get(boss.getId()) == null

                                    || hongBaoMoney.get(boss.getId()).compareTo(new BigDecimal("0")) <= 0) {

                                 // 补偿金币

                                 integralTaskRecordService.firstSharerOrderRewardBoss(boss.getId(),

                                       order.getUserInfo().getId(), null);

                              }

                           }



                        } else {// 自购订单

                           UserInfo boss = threeSaleSerivce.getBoss(order.getUserInfo().getId());

                           if (boss != null) {// 判断上级的红包

                              if (hongBaoMoney.get(boss.getId()) == null

                                    || hongBaoMoney.get(boss.getId()).compareTo(new BigDecimal("0")) <= 0) {

                                 // 补偿金币1级

                                 integralTaskRecordService.firstRebateOrderRewardBoss(boss.getId(),

                                       order.getUserInfo().getId(), null);

                              }

                           }



                           boss = threeSaleSerivce.getBoss(boss.getId());

                           if (boss != null) {// 判断上级的红包

                              if (hongBaoMoney.get(boss.getId()) == null

                                    || hongBaoMoney.get(boss.getId()).compareTo(new BigDecimal("0")) <= 0) {

                                 // 补偿金币2级

                                 integralTaskRecordService.firstRebateOrderRewardBossSuper(boss.getId(),

                                       order.getUserInfo().getId(), null);

                              }

                           }

                        }

                        PlaceOrderCMQManager.getInstance().deleteQueueMsg(PlaceOrderCMQManager.QUEUE_INTEGRAL,

                              key);

                     } catch (Exception e) {

                        LogHelper.errorDetailInfo(e);

                     }

                  }



               }

            }

         }

      });

   }



   // 抖音广告监控

   public void doPlaceOrderAdJob() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               Map<String, Order> map = PlaceOrderCMQManager.getInstance()

                     .consumeQueueMsg(PlaceOrderCMQManager.QUEUE_AD, 16);

               if (map != null) {

                  // 是否是首单

                  for (Iterator<String> its = map.keySet().iterator(); its.hasNext();) {

                     String key = its.next();

                     Order order = map.get(key);

                     if (isFirstValidOrder(order.getOrderId(), order.getOrderType(),

                           order.getUserInfo().getId())) {// 有效的首单

                        // TODO 抖音的数据回调

                     }

                  }

               }

            }

         }

      });

   }



}