package com.yeshi.fanli.service.impl.user.vip;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.DateUtil;
|
|
import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPInfoMapper;
|
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
|
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.exception.user.vip.UserVIPInfoException;
|
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.UserInviteValidNumService;
|
import com.yeshi.fanli.service.inter.user.msg.UserAccountMsgNotificationService;
|
import com.yeshi.fanli.service.inter.user.vip.UserLevelUpgradedNotifyService;
|
import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;
|
import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
|
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 {
|
|
@Resource
|
private UserVIPInfoMapper userVIPInfoMapper;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private UserVipConfigService userVipConfigService;
|
|
@Lazy
|
@Resource
|
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;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void addUserVIPInfo(UserVIPInfo info) throws UserVIPInfoException {
|
if (info.getId() == null) {
|
throw new UserVIPInfoException(1, "信息不完整");
|
}
|
UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKey(info.getId());
|
if (userInfo != null) {
|
throw new UserVIPInfoException(1, "信息已存在");
|
}
|
// 初始化状态
|
info.setState(UserVIPInfo.STATE_INVALID);
|
info.setCreateTime(new Date());
|
userVIPInfoMapper.insert(info);
|
}
|
|
|
@Override
|
public boolean isVIP(Long uid) {
|
return isVIP(uid, System.currentTimeMillis());
|
}
|
|
@Override
|
public boolean isVIP(Long uid, Long time) {
|
UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKey(uid);
|
if (userInfo != null && userInfo.getState() == UserVIPInfo.STATE_SUCCESS
|
&& userInfo.getSuccessTime().getTime() < time)
|
return true;
|
else
|
return false;
|
}
|
|
@Override
|
public UserVIPInfo selectByUid(Long uid) {
|
UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKey(uid);
|
return userInfo;
|
}
|
|
@Override
|
public Map<Long, Boolean> listByUids(List<Long> uids) {
|
if (uids == null || uids.size() == 0)
|
return new HashMap<>();
|
List<UserVIPInfo> infoList = userVIPInfoMapper.listByUids(uids);
|
// 整理数据
|
Map<Long, Boolean> map = new HashMap<>();
|
if (infoList != null)
|
for (UserVIPInfo info : infoList)
|
if (info != null && info.getState() == UserVIPInfo.STATE_SUCCESS)
|
map.put(info.getId(), true);
|
else
|
map.put(info.getId(), false);
|
for (Long uid : uids) {
|
if (map.get(uid) == null)
|
map.put(uid, false);
|
}
|
return map;
|
}
|
|
|
@Override
|
public List<UserVIPInfo> listQuery(int page, int count, String key, Integer state) {
|
return userVIPInfoMapper.listQuery((page - 1) * count, count, key, state);
|
}
|
|
@Override
|
public long countQuery(String key, Integer state) {
|
return userVIPInfoMapper.countQuery(key, state);
|
}
|
|
|
@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, "请先升级为高级会员");
|
}
|
|
if (!verifyVip(uid))
|
throw new UserVIPInfoException(1, "不满足升级条件");
|
|
UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKeyForUpdate(uid);
|
if (userInfo == null) {
|
userInfo = new UserVIPInfo();
|
userInfo.setId(uid);
|
addUserVIPInfo(userInfo);
|
}
|
|
if (userInfo.getState() != UserVIPInfo.STATE_INVALID)
|
throw new UserVIPInfoException(2, "系统已收到你的超级会员升级申请，将会尽快完成审核");
|
|
UserVIPInfo info = new UserVIPInfo();
|
info.setId(userInfo.getId());
|
info.setApplyTime(new Date());
|
info.setState(UserVIPInfo.STATE_VERIFING);
|
info.setUpdateTime(new Date());
|
userVIPInfoMapper.updateByPrimaryKeySelective(info);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void passVIPApply(Long uid) throws UserVIPInfoException {
|
UserVIPInfo userVIPInfo = userVIPInfoMapper.selectByPrimaryKeyForUpdate(uid);
|
if (userVIPInfo == null) {
|
throw new UserVIPInfoException(1, "用户信息不存在");
|
}
|
if (userVIPInfo.getState() != UserVIPInfo.STATE_VERIFING) {
|
throw new UserVIPInfoException(2, "申请未处于审核状态");
|
}
|
|
UserVIPPreInfo latestProcess = userVIPPreInfoService.getLatestProcessInfo(uid);
|
if (latestProcess == null || latestProcess.getProcess() != UserVIPPreInfo.PROCESS_2) {
|
throw new UserVIPInfoException(1, "该用户还不是高级会员");
|
}
|
|
if (!verifyVip(uid))
|
throw new UserVIPInfoException(1, "系统验证：不满足升级条件");
|
|
// 额外信息
|
UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
|
if (userInfoExtra == null)
|
throw new UserVIPInfoException(1, "用户信息不存在");
|
|
Date upgradeTime = new Date();
|
// 通过超级会员
|
UserVIPInfo info = new UserVIPInfo();
|
info.setId(userVIPInfo.getId());
|
info.setSuccessTime(upgradeTime);
|
info.setState(UserVIPInfo.STATE_SUCCESS);
|
info.setUpdateTime(upgradeTime);
|
userVIPInfoMapper.updateByPrimaryKeySelective(info);
|
|
// 升级弹框提示
|
UserLevelUpgradedNotify notify = new UserLevelUpgradedNotify();
|
notify.setUid(uid);
|
notify.setFromLevel(UserLevelEnum.highVIP);
|
notify.setToLevel(UserLevelEnum.superVIP);
|
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);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
/**
|
* 验证是否符合VIP
|
* @param uid
|
* @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);
|
|
// 有效粉丝
|
int doneFirst = 0;
|
int doneSecond = 0;
|
UserInviteValidNum userInviteValidNum = userInviteValidNumService.selectByPrimaryKey(uid);
|
if (userInviteValidNum != null) {
|
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");
|
if (!StringUtil.isNullOrEmpty(zigou)) {
|
limitZiGou = 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 = "分享订单";
|
} else if (doneFirst >= limitFirst && doneSecond >= limitSecond) {
|
item = "邀请粉丝";
|
}
|
return item;
|
}
|
|
|
/**
|
* 验证是否符合VIP
|
* @param uid
|
* @return
|
*/
|
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);
|
|
// 有效粉丝
|
int doneFirst = 0;
|
int doneSecond = 0;
|
UserInviteValidNum userInviteValidNum = userInviteValidNumService.selectByPrimaryKey(uid);
|
if (userInviteValidNum != null) {
|
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");
|
if (!StringUtil.isNullOrEmpty(zigou)) {
|
limitZiGou = 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;
|
}
|
return false;
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void rejectVIPApply(Long uid, String reason) throws UserVIPInfoException {
|
UserVIPInfo userInfo = userVIPInfoMapper.selectByPrimaryKeyForUpdate(uid);
|
if (userInfo == null) {
|
throw new UserVIPInfoException(1, "用户信息不存在");
|
}
|
if (userInfo.getState() != UserVIPInfo.STATE_VERIFING) {
|
throw new UserVIPInfoException(2, "申请未处于审核状态");
|
}
|
|
UserVIPInfo info = new UserVIPInfo();
|
info.setId(userInfo.getId());
|
info.setState(UserVIPInfo.STATE_INVALID);
|
info.setUpdateTime(new Date());
|
userVIPInfoMapper.updateByPrimaryKeySelective(info);
|
|
// 消息
|
userAccountMsgNotificationService.vipUpgradeFail(uid, reason);
|
}
|
|
}
|
