分享订单到账消息调整

yujian

2020-04-16 a1cc60298bd8b9cbddb29ad7c5e8e59ea1ee790c

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

@@ -6,6 +6,7 @@
import javax.annotation.Resource;



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;

@@ -30,7 +31,6 @@
   private ThreeSaleSerivce threeSaleSerivce;

   

   

	
   @Override

   public UserInviteValidNum selectByPrimaryKey(Long id) {

      return userInviteValidNumMapper.selectByPrimaryKey(id);

@@ -41,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());

@@ -58,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());

@@ -72,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;

@@ -121,14 +126,14 @@
         if (threeSaleSuper == null) {

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

@@ -141,15 +146,5 @@
         LogHelper.error(e);

      }

   }

	
	
	
	
	
	
	
	
	
	
    

}