Merge remote-tracking branch 'origin/div' into 2.1.2

admin

2020-05-20 98b1a0affd69bbe63223c21fdd2c404e8bedfccb

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

@@ -10,8 +10,12 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.aliyun.openservices.ons.api.Message;

import com.aliyun.openservices.ons.api.Producer;

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

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

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.BeComeValidUserMQMsg;

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

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

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

@@ -23,6 +27,8 @@
import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



@Service

public class UserInviteValidNumServiceImpl implements UserInviteValidNumService {

@@ -31,26 +37,26 @@


   @Resource

   private UserInviteValidRecordMapper userInviteValidRecordMapper;

	


   @Lazy

   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

	


   @Lazy

   @Resource

   private UserInfoService userInfoService;

	


   @Lazy

   @Resource

   private CommonOrderService commonOrderService;

	
	
	


   @Resource(name = "producer")

   private Producer producer;



   @Override

   public UserInviteValidNum selectByPrimaryKey(Long id) {

      return userInviteValidNumMapper.selectByPrimaryKey(id);

   }

	


   /**

    *  直接粉丝 +1

@@ -70,20 +76,20 @@
         userInviteValidNumMapper.insertSelective(inviteValid);

      }

   }

	


   /**

    *  直接粉丝 -1

    * @param uid

    */

   @Override

   @Transactional(rollbackFor = Exception.class)

   public void reduceValidNumFirst(Long uid, Long  workerId) {

   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;

@@ -95,11 +101,11 @@
         inviteValid.setUpdateTime(new Date());

         userInviteValidNumMapper.updateByPrimaryKeySelective(inviteValid);

      }

		


      // 删除有效记录

      userInviteValidRecordMapper.deleteByPrimaryKey(record.getId());

   }

	


   /**

    *  直接粉丝 -1

    * @param uid

@@ -112,7 +118,7 @@
      if (record == null) {

         return;

      }

		


      UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);

      if (inviteValid != null) {

         int num = 0;

@@ -124,13 +130,10 @@
         inviteValid.setUpdateTime(new Date());

         userInviteValidNumMapper.updateByPrimaryKeySelective(inviteValid);

      }

		


      // 删除有效记录

      userInviteValidRecordMapper.deleteByPrimaryKey(record.getId());

   }

	
	
	


   /**

    *  间接粉丝 +1

@@ -150,37 +153,37 @@
         userInviteValidNumMapper.insertSelective(inviteValid);

      }

   }

	


   @Override

   @Transactional(rollbackFor = Exception.class)

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

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

         return;

      }

		


      try {

         // 付款金额小于1

         if (payment.compareTo(Constant.VIP_ORDER_PAY) < 0) {

            return;

         }

			


         // 是否上级

         ThreeSale threeSale = threeSaleSerivce.getMyBoss(uid);

         if (threeSale == null) {

            return;

         }

			


         // 队员关系有效时间

         Long succeedTime = threeSale.getSucceedTime();

         if (succeedTime == null) {

            succeedTime = threeSale.getCreateTime();

         }

			


         // 下单时间在生产关系之前

         if (payDate.getTime() <= succeedTime.longValue()) {

            return;

         }

			


         Long bossId = threeSale.getBoss().getId();

         String uniqueKey = StringUtil.Md5(uid + "#" + UserInviteValidRecord.TYPE_ONE);

         UserInviteValidRecord record = userInviteValidRecordMapper.selectByUniqueKey(uniqueKey);

@@ -192,11 +195,19 @@
            record.setUniqueKey(uniqueKey);

            record.setCreateTime(new Date());

            userInviteValidRecordMapper.insertSelective(record);

				


            // 更新上级的直接粉丝数量

            addNumFirst(bossId);

         }

			


         // 发送成为有效粉丝的消息

         if (!Constant.IS_TEST) {

            BeComeValidUserMQMsg msg = new BeComeValidUserMQMsg(uid, new Date());

            Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.becomeValidUser,

                  msg);

            producer.send(message);

         }



         // 是否上上级

         ThreeSale threeSaleSuper = threeSaleSerivce.getMyBoss(bossId);

         if (threeSaleSuper == null) {

@@ -214,7 +225,7 @@
            recordSuper.setUniqueKey(uniqueKeySuper);

            recordSuper.setCreateTime(new Date());

            userInviteValidRecordMapper.insertSelective(recordSuper);

				


            // 更新上上级的间接粉丝数量

            addNumSecond(bossIdSuper);

         }

@@ -222,8 +233,7 @@
         LogHelper.error(e);

      }

   }

	
	


   @Override

   public void syncInfoAgain(Long workerId) {

      // 更新上级

@@ -231,17 +241,17 @@
      if (threeSale == null) {

         return;

      }

		


      Long uid = threeSale.getBoss().getId();

      UserInfo userInfo = userInfoService.selectByPKey(uid);

      if (userInfo == null || userInfo.getState() != UserInfo.STATE_NORMAL) {

         return;

      }

		


      int countTeam1 = 0;

      List<ThreeSale> listFirstTeam = threeSaleSerivce.listFirstTeam(0, Integer.MAX_VALUE, uid);

      if (listFirstTeam != null && listFirstTeam.size() > 0) {

         for (ThreeSale firstTeam: listFirstTeam) {

         for (ThreeSale firstTeam : listFirstTeam) {

            if (firstTeam.getWorker() == null || firstTeam.getWorker().getId() == null) {

               continue;

            }

@@ -249,12 +259,12 @@
            String uniqueKey = StringUtil.Md5(wid + "#" + UserInviteValidRecord.TYPE_ONE);

            UserInviteValidRecord record = userInviteValidRecordMapper.selectByUniqueKey(uniqueKey);

            if (record != null) {

               countTeam1 ++;

               countTeam1++;

            } else {

               long countValid = commonOrderService.countOrderByUidAndSettled(wid, Constant.VIP_ORDER_PAY);

               if (countValid > 0) {

                  countTeam1 ++;

						
                  countTeam1++;



                  record = new UserInviteValidRecord();

                  record.setUid(uid);

                  record.setWorkerId(wid);

@@ -266,12 +276,13 @@
            }

         }

      }

		


      UserInviteValidNum inviteValid = userInviteValidNumMapper.selectForUpdate(uid);

      if (inviteValid != null) {

         UserInviteValidNum updateObj = new UserInviteValidNum();

         updateObj.setId(uid);

         updateObj.setNumFirst(countTeam1);;

         updateObj.setNumFirst(countTeam1);

         ;

         userInviteValidNumMapper.updateByPrimaryKeySelective(updateObj);

      } else {

         inviteValid = new UserInviteValidNum();

@@ -281,23 +292,23 @@
         inviteValid.setUpdateTime(new Date());

         userInviteValidNumMapper.insertSelective(inviteValid);

      }

		


      // 更新上上级信息

      ThreeSale superThreeSale = threeSaleSerivce.getByWorkerId(uid);

      if (superThreeSale == null) {

         return;

      }

		


      Long superUid = superThreeSale.getBoss().getId();

      UserInfo superUserInfo = userInfoService.selectByPKey(superUid);

      if (superUserInfo == null || superUserInfo.getState() != UserInfo.STATE_NORMAL) {

         return;

      }

		


      int countTeam2 = 0;

      List<ThreeSale> listSecondTeam = threeSaleSerivce.listSecondTeam(0,  Integer.MAX_VALUE, superUid);

      List<ThreeSale> listSecondTeam = threeSaleSerivce.listSecondTeam(0, Integer.MAX_VALUE, superUid);

      if (listSecondTeam != null && listSecondTeam.size() > 0) {

         for (ThreeSale team: listSecondTeam) {

         for (ThreeSale team : listSecondTeam) {

            if (team.getWorker() == null || team.getWorker().getId() == null) {

               continue;

            }

@@ -305,12 +316,12 @@
            String uniqueKeySuper = StringUtil.Md5(wid + "#" + UserInviteValidRecord.TYPE_TWO);

            UserInviteValidRecord recordSuper = userInviteValidRecordMapper.selectByUniqueKey(uniqueKeySuper);

            if (recordSuper != null) {

               countTeam2 ++;

               countTeam2++;

            } else {

               long countValid = commonOrderService.countOrderByUidAndSettled(wid, Constant.VIP_ORDER_PAY);

               if (countValid > 0) {

                  countTeam2 ++;

						
                  countTeam2++;



                  recordSuper = new UserInviteValidRecord();

                  recordSuper.setUid(superUid);

                  recordSuper.setWorkerId(wid);

@@ -322,7 +333,7 @@
            }

         }

      }

		


      UserInviteValidNum inviteValid2 = userInviteValidNumMapper.selectForUpdate(superUid);

      if (inviteValid2 != null) {

         UserInviteValidNum updateObj = new UserInviteValidNum();

@@ -338,5 +349,5 @@
         userInviteValidNumMapper.insertSelective(inviteValid2);

      }

   }

	


}