vip 消息

yujian

2020-04-02 0ec22dcf4fd9c4496e6f681e7fab89f56c6e4e8a

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteValidNumServiceImpl.java

@@ -5,8 +5,8 @@


import javax.annotation.Resource;



import org.springframework.context.annotation.Lazy;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.yeshi.fanli.dao.mybatis.user.UserInviteValidNumMapper;

import com.yeshi.fanli.dao.mybatis.user.UserInviteValidRecordMapper;

@@ -14,7 +14,6 @@
import com.yeshi.fanli.entity.bus.user.UserInviteValidNum;

import com.yeshi.fanli.entity.bus.user.UserInviteValidRecord;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService;

import com.yeshi.fanli.util.Constant;

@@ -42,12 +41,14 @@
    *  直接粉丝 +1

    * @param uid

    */

   @Transactional(rollbackFor = Exception.class)

   private void addNumFirst(Long uid) {

      UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);

      if (inviteValid != null) {

         userInviteValidNumMapper.addNumFirst(uid, 1);

      } else {

         inviteValid = new UserInviteValidNum();

         inviteValid.setId(uid);

         inviteValid.setNumFirst(1);

         inviteValid.setNumSecond(0);

         inviteValid.setUpdateTime(new Date());

@@ -59,12 +60,14 @@
    *  间接粉丝 +1

    * @param uid

    */

   @Transactional(rollbackFor = Exception.class)

   private void addNumSecond(Long uid) {

      UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);

      if (inviteValid != null) {

         userInviteValidNumMapper.addNumSecond(uid, 1);

      } else {

         inviteValid = new UserInviteValidNum();

         inviteValid.setId(uid);

         inviteValid.setNumFirst(0);

         inviteValid.setNumSecond(1);

         inviteValid.setUpdateTime(new Date());

@@ -73,6 +76,7 @@
   }

   

   @Override

   @Transactional(rollbackFor = Exception.class)

   public void addValidTeamNum(Long uid, BigDecimal payment, Date payDate) {

      if (uid == null || payment == null || payDate == null) {

         return;

@@ -123,13 +127,14 @@
            return;

         }

         

         // 间接关系

         Long bossIdSuper = threeSaleSuper.getBoss().getId();

         String uniqueKeySuper = StringUtil.Md5(bossIdSuper + "#" + bossId + "#" + UserInviteValidRecord.TYPE_TWO);

         String uniqueKeySuper = StringUtil.Md5(bossIdSuper + "#" + uid + "#" + UserInviteValidRecord.TYPE_TWO);

         UserInviteValidRecord recordSuper = userInviteValidRecordMapper.selectByUniqueKey(uniqueKeySuper);

         if (recordSuper == null) {

            recordSuper = new UserInviteValidRecord();

            recordSuper.setUid(bossIdSuper);

            recordSuper.setWorkerId(bossId);

            recordSuper.setWorkerId(uid);

            recordSuper.setType(UserInviteValidRecord.TYPE_TWO);

            recordSuper.setUniqueKey(uniqueKeySuper);

            recordSuper.setCreateTime(new Date());

@@ -142,15 +147,5 @@
         LogHelper.error(e);

      }

   }

	
	
	
	
	
	
	
	
	
	
    

}