| | |
| | | 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
|
| | |
| | | }
|
| | |
|
| | | 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();
|
| | |
| | | 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();
|