订单搜索引擎增量更新

admin

2020-01-07 6fdcc0c26dd33e87a024a69ed635d9aedb59cad6

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java

@@ -253,7 +253,7 @@
      return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin());

   }



   @Transactional(rollbackFor=Exception.class)

   @Transactional(rollbackFor = Exception.class)

   public boolean addDetail(Long uid, IntegralTaskRecord record) throws IntegralTaskRecordException {

      Long uid2 = record.getUid();

      if (uid2 == null || uid.longValue() != uid2.longValue())

@@ -351,7 +351,7 @@
      return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime);

   }



   @Transactional(rollbackFor=Exception.class)

   @Transactional(rollbackFor = Exception.class)

   @Override

   public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {

      if (record == null)

@@ -370,15 +370,6 @@
      // 设置有效期

      record.setEndTime(DateUtil.plusDayDate(Constant.GOLD_COIN_VALID_DAYS, date));

      integralTaskRecordMapper.insertSelective(record);

		
//      long count = integralTaskRecordMapper.getTotalGoldCoinByUid(record.getUid());

//      if (count >= 200) {// 大于200发送消息

//         IntegralTaskMQMsg msg = new IntegralTaskMQMsg(record.getUid(), count, new Date());

//         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.integralTaskFinish,

//               msg);

//         producer.send(message);

//      }



      return record;

   }



@@ -507,8 +498,11 @@
         msgOther.setSource("首笔分享订单，系统奖励金币 ");

         msgOther.setExplain("首笔分享订单得到的奖金不足0.01元时奖励 ");

      } else {

         msgOther.setSource(level + "级队员首次下单，系统奖励金币 ");

         msgOther.setExplain("仅新邀请队员首下单你得到的奖金不足0.01元时奖励 ");

         if (level.equalsIgnoreCase("一") || level.equalsIgnoreCase("1"))

            msgOther.setSource("直接粉丝首次下单，系统奖励金币 ");

         else

            msgOther.setSource("间接粉丝首次下单，系统奖励金币 ");

         msgOther.setExplain("仅新邀请粉丝首下单你得到的奖金不足0.01元时奖励 ");

      }

      userOtherMsgNotificationService.firstOrderRewardMsg(uid, null, msgOther);

   }