admin
2020-04-02 b9b613a285ebe0da27ca7dd2c3434c8c917abb74
fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPInfoServiceImpl.java
@@ -13,14 +13,11 @@
import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPInfoMapper;
import com.yeshi.fanli.dto.msg.MsgAccountVipDTO;
import com.yeshi.fanli.dto.msg.MsgOtherVIPDTO;
import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail;
import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail.MsgTypeAccountTypeEnum;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.bus.user.ThreeSale;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.bus.user.UserInviteSeparate;
import com.yeshi.fanli.entity.bus.user.UserInviteValidNum;
import com.yeshi.fanli.entity.bus.user.UserSystemCoupon;
import com.yeshi.fanli.entity.bus.user.vip.UserVIPInfo;
@@ -45,7 +42,6 @@
import com.yeshi.fanli.service.inter.user.vip.UserVipConfigService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
@Service
public class UserVIPInfoServiceImpl implements UserVIPInfoService {
@@ -166,71 +162,17 @@
      return userVIPInfoMapper.countQuery(key, state);
   }
   @Override
   @Transactional(rollbackFor = Exception.class)
   public void inviteSeparate(Long workerId, Long bossId) {
      if (workerId == null || bossId == null)
         return;
      // 查询记录
      UserInviteSeparate userInviteSeparate = userInviteSeparateService.selectByWorkerIdAndBossId(workerId, bossId);
      if (userInviteSeparate == null)
         return;
      // 是否存在邀请关系
      ThreeSale threeSale = threeSaleSerivce.getMyBoss(workerId);
      if (threeSale == null)
         return;
      Long bossIdExist = threeSale.getBoss().getId();
      if (bossIdExist == null || bossId.longValue() != bossIdExist.longValue())
         return;
      // 上级会员情况
      boolean separate = false;
      UserVIPInfo userVIPInfo = userVIPInfoMapper.selectByPrimaryKey(bossId);
      if (userVIPInfo != null && userVIPInfo.getState() != null
            && userVIPInfo.getState() == UserVIPInfo.STATE_SUCCESS) {
         if (userInviteSeparate.getEndTime().getTime() < userVIPInfo.getSuccessTime().getTime()) {
            separate = true; // 结束时间已经超过
         }
      } else {
         separate = true; // 上级非会员
      }
      if (!separate) {
         // 未脱离
         userInviteSeparateService.updateStateByWorkerIdAndBossId(workerId, bossId,
               UserInviteSeparate.STATE_INVALID);
      } else {
         // 脱离关系
         userInviteSeparateService.updateStateByWorkerIdAndBossId(workerId, bossId,
               UserInviteSeparate.STATE_SUCCESS);
         // 脱离邀请关系
         threeSaleSerivce.inviteSeparate(workerId, bossId);
         int limitDays = Integer.parseInt(userVipConfigService.getValueByKey("invite_separate_limit_days"));
         // 消息
         UserInfo userInfo = userInfoService.selectByPKey(workerId);
         MsgOtherVIPDTO msgboss = new MsgOtherVIPDTO();
         msgboss.setContent1(userInfo.getNickName() + workerId + "于"
               + TimeUtil.formatDateDot(userInviteSeparate.getCreateTime()) + "成功升级成为超级会员 ");
         msgboss.setContent2("很遗憾,你未能在" + limitDays + "天升级为超级会员 ");
         msgboss.setContent3("已与其脱离邀请关系");
         userOtherMsgNotificationService.teamSplitCallBoss(bossId, "如有疑问请联系我的-人工客服", msgboss);
      }
   }
   @Transactional(rollbackFor = Exception.class)
   @Override
   public void applyVIP(Long uid) throws UserVIPInfoException {
      UserVIPPreInfo latestProcess = userVIPPreInfoService.getLatestProcessInfo(uid);
      if (latestProcess == null || latestProcess.getProcess() != UserVIPPreInfo.PROCESS_2) {
         throw new UserVIPInfoException(1, "该用户还不是高级会员");
         throw new UserVIPInfoException(1, "请先升级为高级会员");
      }
      if (!verifyVip(uid))
         throw new UserVIPInfoException(1, "系统验证:不满足升级条件");
         throw new UserVIPInfoException(1, "不满足升级条件");
      UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKeyForUpdate(uid);
      if (userInfo == null) {