admin
2020-04-21 0b57cfd62e842b309d03467b96a331c673ecad7c
fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java
@@ -55,6 +55,67 @@
         userInviteValidNumMapper.insertSelective(inviteValid);
      }
   }
   /**
    *  直接粉丝 -1
    * @param uid
    */
   @Override
   @Transactional(rollbackFor = Exception.class)
   public void reduceValidNumFirst(Long uid, Long  workerId) {
      UserInviteValidRecord record = userInviteValidRecordMapper.getByUidAndWorkerId(uid, workerId,
            UserInviteValidRecord.TYPE_ONE);
      if (record == null) {
         return;
      }
      UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);
      if (inviteValid != null) {
         int num = 0;
         if (inviteValid.getNumFirst() > 0) {
            num = inviteValid.getNumFirst() - 1;
         }
         inviteValid.setId(uid);
         inviteValid.setNumFirst(num);
         inviteValid.setUpdateTime(new Date());
         userInviteValidNumMapper.updateByPrimaryKeySelective(inviteValid);
      }
      // 删除有效记录
      userInviteValidRecordMapper.deleteByPrimaryKey(record.getId());
   }
   /**
    *  直接粉丝 -1
    * @param uid
    */
   @Override
   @Transactional(rollbackFor = Exception.class)
   public void reduceValidNumSecond(Long uid, Long workerId) {
      UserInviteValidRecord record = userInviteValidRecordMapper.getByUidAndWorkerId(uid, workerId,
            UserInviteValidRecord.TYPE_TWO);
      if (record == null) {
         return;
      }
      UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);
      if (inviteValid != null) {
         int num = 0;
         if (inviteValid.getNumFirst() > 0) {
            num = inviteValid.getNumSecond() - 1;
         }
         inviteValid.setId(uid);
         inviteValid.setNumSecond(num);
         inviteValid.setUpdateTime(new Date());
         userInviteValidNumMapper.updateByPrimaryKeySelective(inviteValid);
      }
      // 删除有效记录
      userInviteValidRecordMapper.deleteByPrimaryKey(record.getId());
   }
   /**
    *  间接粉丝 +1
@@ -106,7 +167,7 @@
         }
         
         Long bossId = threeSale.getBoss().getId();
         String uniqueKey = StringUtil.Md5(bossId + "#" + uid + "#" + UserInviteValidRecord.TYPE_ONE);
         String uniqueKey = StringUtil.Md5(uid + "#" + UserInviteValidRecord.TYPE_ONE);
         UserInviteValidRecord record = userInviteValidRecordMapper.selectByUniqueKey(uniqueKey);
         if (record == null) {
            record = new UserInviteValidRecord();
@@ -126,10 +187,9 @@
         if (threeSaleSuper == null) {
            return;
         }
         // 间接关系
         Long bossIdSuper = threeSaleSuper.getBoss().getId();
         String uniqueKeySuper = StringUtil.Md5(bossIdSuper + "#" + uid + "#" + UserInviteValidRecord.TYPE_TWO);
         String uniqueKeySuper = StringUtil.Md5(uid + "#" + UserInviteValidRecord.TYPE_TWO);
         UserInviteValidRecord recordSuper = userInviteValidRecordMapper.selectByUniqueKey(uniqueKeySuper);
         if (recordSuper == null) {
            recordSuper = new UserInviteValidRecord();