| | |
|---|
| | | doPDDOrderJob();// 拼多多订单处理
|
|---|
| | | doImportantTaoBaoGoodsUpdateJob();// 淘宝重要商品的信息更新
|
|---|
| | | doHongBaoRecieveIntegralGetJob();// 返利到账，金币增加
|
|---|
| | | // doPlaceOrderIntegralJob();// 下单赠送金币任务
|
|---|
| | | // doPlaceOrderIntegralJob();// 下单赠送金币任务
|
|---|
| | | doDouYinDeviceActiveJob();// 抖音设备激活广告监测
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | |
|---|
| | | 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())) {
|
|---|
| | | // 统计订单下的用户所获得的返利金额
|
|---|
| | | 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);
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | } 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);
|
|---|
| | | // 获取上两级数据
|
|---|
| | | 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);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | 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);
|
|---|
| | | } 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);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
