2.1需求

yujian

2020-05-09 7e7db2fa55a9a3af46d4fd8ede0dee147f101d64

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPInfoServiceImpl.java

@@ -16,26 +16,23 @@
import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPInfoMapper;

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

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

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

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

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

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

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

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

import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;

import com.yeshi.fanli.entity.bus.user.vip.UserLevelUpgradedNotify;

import com.yeshi.fanli.entity.bus.user.vip.UserVIPInfo;

import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;

import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;

import com.yeshi.fanli.entity.common.Config;

import com.yeshi.fanli.entity.system.ConfigKeyEnum;

import com.yeshi.fanli.exception.user.vip.UserVIPInfoException;

import com.yeshi.fanli.exception.user.vip.UserVIPPreInfoException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;

import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;

import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;

import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.service.inter.user.integral.IntegralDetailService;

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

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

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

import com.yeshi.fanli.service.inter.user.msg.UserAccountMsgNotificationService;

import com.yeshi.fanli.service.inter.user.vip.UserLevelUpgradedNotifyService;

@@ -45,6 +42,7 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.email.MailSenderUtil;

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

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



@@ -58,9 +56,6 @@
   private UserInfoService userInfoService;



   @Resource

   private UserInfoExtraService userInfoExtraService;



   @Resource

   private UserVipConfigService userVipConfigService;



   @Lazy

@@ -68,44 +63,28 @@
   private HongBaoV2CountService hongBaoV2CountService;



   @Resource

   private IntegralDetailService integralDetailService;



   @Resource

   private BanLiShopOrderService banLiShopOrderService;



   @Resource

   private UserOtherMsgNotificationService userOtherMsgNotificationService;



   @Resource

   private ThreeSaleSerivce threeSaleSerivce;



   @Resource

   private UserInviteSeparateService userInviteSeparateService;



   @Resource

   private ConfigService configService;



   @Lazy

   @Resource

   private UserSystemCouponService userSystemCouponService;



   @Resource

   private UserVIPPreInfoService userVIPPreInfoService;



   @Resource

   private UserAccountMsgNotificationService userAccountMsgNotificationService;

	


   @Resource

   private UserInviteValidNumService userInviteValidNumService;

	


   @Resource

   private UserLevelUpgradedNotifyService userLevelUpgradedNotifyService;

	
	


   @Resource

   private UserInviteMsgNotificationService userInviteMsgNotificationService;



   @Resource(name = "producer")

   private Producer producer;

	
	


   @Resource

   private ConfigService configService;



   @Override

   @Transactional(rollbackFor = Exception.class)

@@ -122,7 +101,6 @@
      info.setCreateTime(new Date());

      userVIPInfoMapper.insert(info);

   }





   @Override

   public boolean isVIP(Long uid) {

@@ -165,7 +143,6 @@
      return map;

   }





   @Override

   public List<UserVIPInfo> listQuery(int page, int count, String key, Integer state) {

      return userVIPInfoMapper.listQuery((page - 1) * count, count, key, state);

@@ -176,7 +153,6 @@
      return userVIPInfoMapper.countQuery(key, state);

   }





   @Transactional(rollbackFor = Exception.class)

   @Override

   public void applyVIP(Long uid) throws UserVIPInfoException {

@@ -185,7 +161,8 @@
         throw new UserVIPInfoException(1, "请先升级为高级会员");

      }



      if (!verifyVip(uid))

      int verifyResult = verifyVip(uid);

      if (verifyResult <= 0)

         throw new UserVIPInfoException(1, "不满足升级条件");



      UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKeyForUpdate(uid);

@@ -204,6 +181,22 @@
      info.setState(UserVIPInfo.STATE_VERIFING);

      info.setUpdateTime(new Date());

      userVIPInfoMapper.updateByPrimaryKeySelective(info);

      // 发送邮件通知

      try {

         Config config = configService.getConfig(ConfigKeyEnum.extractCodeEmailFrom.getKey());

         String[] sts = config.getValue().split(",");

         String account = sts[0];

         String pwd = sts[1];



         String msg = String.format("用户ID:%s 申请超级会员", uid + "");

         String email = userVipConfigService.getValueByKey("apply_vip_email");

         String[] emails = email.split(",");

         for (String e : emails) {

            MailSenderUtil.sendEmail(e, account, pwd, msg, msg);

         }

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

   }



   @Transactional(rollbackFor = Exception.class)

@@ -222,13 +215,10 @@
         throw new UserVIPInfoException(1, "该用户还不是高级会员");

      }



      if (!verifyVip(uid))

         throw new UserVIPInfoException(1, "系统验证：不满足升级条件");

      int verifyVipResult = verifyVip(uid);



      // 额外信息

      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);

      if (userInfoExtra == null)

         throw new UserVIPInfoException(1, "用户信息不存在");

      if (verifyVipResult <= 0)

         throw new UserVIPInfoException(1, "系统验证：不满足升级条件");



      Date upgradeTime = new Date();

      // 通过超级会员

@@ -239,6 +229,18 @@
      info.setUpdateTime(upgradeTime);

      userVIPInfoMapper.updateByPrimaryKeySelective(info);



      UserVIPPreInfo preInfo = new UserVIPPreInfo();

      preInfo.setCreateTime(new Date());

      preInfo.setProcess(UserLevelEnum.superVIP.getLevel());

      preInfo.setSourceType(verifyVipResult);

      preInfo.setUid(uid);



      try {

         userVIPPreInfoService.addUserVIPPreInfo(preInfo);

      } catch (UserVIPPreInfoException e1) {

         throw new UserVIPInfoException(100, "升级失败");

      }



      // 升级弹框提示

      UserLevelUpgradedNotify notify = new UserLevelUpgradedNotify();

      notify.setUid(uid);

@@ -247,38 +249,32 @@
      notify.setValid(true);

      notify.setCreateTime(new Date());

      userLevelUpgradedNotifyService.addUserLevelUpgradedNotify(notify);

		
      try {

         // 赠送免单券

         String giveCoupon = userVipConfigService.getValueByKey("vip_pre_10_gift_givefree_coupon");

         if (!StringUtil.isNullOrEmpty(giveCoupon)) {

            int num = Integer.parseInt(giveCoupon);

            userSystemCouponService.freeCouponWin(uid, CouponTypeEnum.freeCouponGive,

                  UserSystemCoupon.SOURCE_SYSTEM_PUSH, num, true);

         }

      } catch (Exception e) {

         throw new UserVIPInfoException(1, "券赠送失败");

      }

		


      try {

         // 升级消息

         UserVIPPreInfo pre1 = userVIPPreInfoService.getVipByProcess(uid, UserVIPPreInfo.PROCESS_2);

         userAccountMsgNotificationService.vipUpgradeSuccess(uid, TimeUtil.getDayDifferenceCount(pre1.getCreateTime(), new Date()));

			
         // 升级提醒上级

         userVIPPreInfoService.remindBoss(uid, "超级会员", getPassItem(uid), upgradeTime, false);

         userAccountMsgNotificationService.vipUpgradeSuccess(uid,

               TimeUtil.getDayDifferenceCount(pre1.getCreateTime(), new Date()));



         // 直接粉丝升级提醒

         ThreeSale threeSale = threeSaleSerivce.getMyBoss(uid);

         if (threeSale != null) {

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

            UserInfo userInfo = userInfoService.selectByPKey(uid);

            userInviteMsgNotificationService.fansUpgrade(bossId, "超级会员", userInfo.getNickName(), getPassItem(uid),

                  upgradeTime);

         }

      } catch (Exception e) {

         e.printStackTrace();

      }

		


      if (!Constant.IS_TEST) {

         UserLevelChangedMQMsg msg = new UserLevelChangedMQMsg(uid, UserLevelEnum.highVIP,UserLevelEnum.superVIP, new Date());

         UserLevelChangedMQMsg msg = new UserLevelChangedMQMsg(uid, UserLevelEnum.highVIP, UserLevelEnum.superVIP,

               new Date());

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userLevelChanged, msg);

         producer.send(message);

      }

   }





   /**

    * 验证是否符合VIP

@@ -286,13 +282,8 @@
    * @return

    */

   private String getPassItem(Long uid) {

      // 自购订单

      long doneZiGou = hongBaoV2CountService.counOrderByUidAndOrderType(uid, Constant.VIP_ORDER_PAY,

            HongBaoV2.TYPE_ZIGOU);

      // 分享订单

      long doneShare = hongBaoV2CountService.counOrderByUidAndOrderType(uid, Constant.VIP_ORDER_PAY,

            HongBaoV2.TYPE_SHARE_GOODS);

		
      // 自购 + 分享订单

      long doneOrder = hongBaoV2CountService.countMyDirectOrderByCashArrival(uid, Constant.VIP_ORDER_PAY);

      // 有效粉丝

      int doneFirst = 0;

      int doneSecond = 0;

@@ -302,55 +293,45 @@
         doneSecond = userInviteValidNum.getNumSecond() == null ? 0 : userInviteValidNum.getNumSecond();

      }



      long limitZiGou = 0;

      String zigou = userVipConfigService.getValueByKey("vip_pre_10_zigou_order_count");

      long limitOrder = 0;

      String zigou = userVipConfigService.getValueByKey("vip_pre_10_order_count");

      if (!StringUtil.isNullOrEmpty(zigou)) {

         limitZiGou = Long.parseLong(zigou);

         limitOrder = Long.parseLong(zigou);

      }

		
      long limitShare = 0;

      String share = userVipConfigService.getValueByKey("vip_pre_10_share_order_count");

      if (!StringUtil.isNullOrEmpty(share)) {

         limitShare = Long.parseLong(share);

      }

		


      long limitFirst = 0;

      String first = userVipConfigService.getValueByKey("vip_pre_10_first_level_team_count");

      if (!StringUtil.isNullOrEmpty(first)) {

         limitFirst = Long.parseLong(first);

      }

		


      long limitSecond = 0;

      String second = userVipConfigService.getValueByKey("vip_pre_10_second_level_team_count");

      if (!StringUtil.isNullOrEmpty(second)) {

         limitSecond = Long.parseLong(second);

      }

		


      String item = "";

      if (doneZiGou >= limitZiGou) {

         item = "返利订单";

      } else if (doneShare >= limitShare) {

         item = "分享订单";

      if (doneOrder >= limitOrder) {

         item = "返利+分享订单";

      } else if (doneFirst >= limitFirst && doneSecond >= limitSecond) {

         item = "邀请粉丝";

         item = "直接+间接粉丝";

      }

      return item;

   }

	
	


   /**

    * 验证是否符合VIP

    *  验证是否符合VIP

    * @Title: verifyVip

    * @Description: 
    * @param uid

    * @return

    * @return 0-不符合  1-订单  2-团队

    * int 返回类型

    * @throws

    */

   private boolean verifyVip(Long uid) {

      // 自购订单

      long doneZiGou = hongBaoV2CountService.counOrderByUidAndOrderType(uid, Constant.VIP_ORDER_PAY,

            HongBaoV2.TYPE_ZIGOU);

      // 分享订单

      long doneShare = hongBaoV2CountService.counOrderByUidAndOrderType(uid, Constant.VIP_ORDER_PAY,

            HongBaoV2.TYPE_SHARE_GOODS);

		
   private int verifyVip(Long uid) {

      // 自购 + 分享订单

      long doneOrder = hongBaoV2CountService.countMyDirectOrderByCashArrival(uid, Constant.VIP_ORDER_PAY);

      // 有效粉丝

      int doneFirst = 0;

      int doneSecond = 0;

@@ -359,35 +340,32 @@
         doneFirst = userInviteValidNum.getNumFirst() == null ? 0 : userInviteValidNum.getNumFirst();

         doneSecond = userInviteValidNum.getNumSecond() == null ? 0 : userInviteValidNum.getNumSecond();

      }



      long limitZiGou = 0;

      String zigou = userVipConfigService.getValueByKey("vip_pre_10_zigou_order_count");

      long limitOrder = 0;

      String zigou = userVipConfigService.getValueByKey("vip_pre_10_order_count");

      if (!StringUtil.isNullOrEmpty(zigou)) {

         limitZiGou = Long.parseLong(zigou);

         limitOrder = Long.parseLong(zigou);

      }

		
      long limitShare = 0;

      String share = userVipConfigService.getValueByKey("vip_pre_10_share_order_count");

      if (!StringUtil.isNullOrEmpty(share)) {

         limitShare = Long.parseLong(share);

      }

		


      long limitFirst = 0;

      String first = userVipConfigService.getValueByKey("vip_pre_10_first_level_team_count");

      if (!StringUtil.isNullOrEmpty(first)) {

         limitFirst = Long.parseLong(first);

      }

		


      long limitSecond = 0;

      String second = userVipConfigService.getValueByKey("vip_pre_10_second_level_team_count");

      if (!StringUtil.isNullOrEmpty(second)) {

         limitSecond = Long.parseLong(second);

      }

		
      if (doneZiGou >= limitZiGou || doneShare >= limitShare || (doneFirst >= limitFirst && doneSecond >= limitSecond)) {

         return true;



      if (doneOrder >= limitOrder) {

         return UserVIPPreInfo.SOURCE_TYPE_ORDER;

      }

      return false;



      if ((doneFirst >= limitFirst && doneSecond >= limitSecond))



         return UserVIPPreInfo.SOURCE_TYPE_TEAM;

      return 0;

   }



   @Transactional(rollbackFor = Exception.class)

@@ -405,10 +383,15 @@
      info.setId(userInfo.getId());

      info.setState(UserVIPInfo.STATE_INVALID);

      info.setUpdateTime(new Date());

      info.setBeiZhu(reason);

      userVIPInfoMapper.updateByPrimaryKeySelective(info);



      // 消息

      userAccountMsgNotificationService.vipUpgradeFail(uid, reason);

   }



   @Override

   public void deleteByPrimaryKey(Long id) {

      userVIPInfoMapper.deleteByPrimaryKey(id);

   }



}