加入任务

admin

2019-09-06 2012b3b5db3c6b06535a68f775bcc81b16151b90

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

@@ -36,6 +36,7 @@
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;

@@ -123,6 +124,9 @@


   @Resource

   private HongBaoOrderService hongBaoOrderService;



   @Resource

   private IntegralTaskRecordService integralTaskRecordService;



   private static boolean isInited = false;



@@ -779,11 +783,12 @@
               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());

                        List<CommonOrder> list = commonOrderService

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

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

                     if (list != null)

                        for (CommonOrder commonOrder : list) {

@@ -793,8 +798,8 @@
                              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()));

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

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

                              // 查询上级

                              List<HongBaoV2> children = hongBaoV2Service

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

@@ -803,7 +808,8 @@
                                    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()));

                                       hongBaoMoney.put(uid,

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

                                 }

                              }

                           }

@@ -813,7 +819,9 @@
                           order.getUserInfo().getId())) {// 有效的首单

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

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

                           // TODO 分享奖金是0

                              // 分享奖金是0

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

                                    null);

                        }



                        // 获取上两级数据

@@ -821,7 +829,9 @@
                        if (boss != null) {// 判断上级的红包

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

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

                              // TODO 补偿资金

                                 // 补偿金币

                                 integralTaskRecordService.firstSharerOrderRewardBoss(boss.getId(),

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

                           }

                        }



@@ -830,7 +840,9 @@
                        if (boss != null) {// 判断上级的红包

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

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

                              // TODO 补偿资金1级

                                 // 补偿金币1级

                                 integralTaskRecordService.firstRebateOrderRewardBoss(boss.getId(),

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

                           }

                        }



@@ -838,10 +850,17 @@
                        if (boss != null) {// 判断上级的红包

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

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

                              // TODO 补偿资金2级

                                 // 补偿金币2级

                                 integralTaskRecordService.firstRebateOrderRewardBossSuper(boss.getId(),

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

                           }

                        }

                     }

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

                              key);

                     } catch (Exception e) {

                        LogHelper.errorDetailInfo(e);

                     }

                  }



               }