package com.yeshi.fanli.service.impl.user;
|
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.core.task.TaskExecutor;
|
import org.springframework.stereotype.Service;
|
|
import com.yeshi.fanli.dao.mybatis.user.TokenRecordMapper;
|
import com.yeshi.fanli.dto.msg.MsgInviteContentDTO;
|
import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO;
|
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinGiveRecord;
|
import com.yeshi.fanli.entity.bus.user.TokenRecord;
|
import com.yeshi.fanli.entity.bus.user.TokenRecord.TokenTypeEnum;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCoupon;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
|
import com.yeshi.fanli.entity.system.SystemCoupon;
|
import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
|
import com.yeshi.fanli.exception.tlj.UserTaoLiJinOriginException;
|
import com.yeshi.fanli.exception.user.TokenRecordException;
|
import com.yeshi.fanli.exception.user.UserInfoExtraException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.SystemCouponService;
|
import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinGiveRecordService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService;
|
import com.yeshi.fanli.service.inter.user.TokenRecordService;
|
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TokenUtil;
|
import com.yeshi.fanli.vo.msg.TokenVO;
|
|
@Service
|
public class TokenRecordServiceImpl implements TokenRecordService {
|
|
@Resource(name = "taskExecutor")
|
private TaskExecutor executor;
|
|
@Resource
|
private TokenRecordMapper tokenRecordMapper;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
@Lazy
|
private UserSystemCouponService userSystemCouponService;
|
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Resource
|
private UserTaoLiJinGiveRecordService userTaoLiJinGiveRecordService;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private UserSystemCouponRecordService userSystemCouponRecordService;
|
|
@Resource
|
private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService;
|
|
@Resource
|
private UserTaoLiJinOriginService userTaoLiJinOriginService;
|
|
@Resource
|
private UserOtherMsgNotificationService userOtherMsgNotificationService;
|
|
@Lazy
|
@Resource
|
private IntegralGetService integralGetService;
|
|
@Resource
|
private SystemCouponService systemCouponService;
|
|
@Resource
|
private UserInviteMsgNotificationService userInviteMsgNotificationService;
|
|
|
@Override
|
public void insertSelective(TokenRecord record) {
|
record.setCreateTime(new Date());
|
record.setUpdateTime(new Date());
|
tokenRecordMapper.insertSelective(record);
|
}
|
|
|
@Override
|
public void updateByPrimaryKeySelective(TokenRecord record) {
|
tokenRecordMapper.updateByPrimaryKeySelective(record);
|
}
|
|
@Override
|
public TokenRecord getNearByTypeAndIdentify(String type, String identify) {
|
return tokenRecordMapper.getNearByTypeAndIdentify(type, identify);
|
}
|
|
@Override
|
public TokenVO discernToken(String token, Long uid) throws TokenRecordException {
|
// 解析口令
|
String parseToken = TokenUtil.parseToken(token);
|
if (StringUtil.isNullOrEmpty(parseToken))
|
throw new TokenRecordException(1, "未发现口令");
|
|
TokenRecord rokenRecord = tokenRecordMapper.getByToken(parseToken);
|
if (rokenRecord == null)
|
throw new TokenRecordException(1, "口令不存在");
|
|
Long uidToken = rokenRecord.getUid();
|
if (uid != null && uidToken != null && uid.longValue() == uidToken.longValue())
|
throw new TokenRecordException(1, "不能自己赠送给自己");
|
|
Date now = new Date();
|
Date endTimeToken = rokenRecord.getEndTime();
|
Integer stateTtoken = rokenRecord.getState();
|
if (endTimeToken != null && endTimeToken.getTime() < now.getTime()
|
|| (stateTtoken != null && stateTtoken == 1) || StringUtil.isNullOrEmpty(rokenRecord.getIdentify()))
|
throw new TokenRecordException(1, "口令已失效");
|
|
|
Integer num = 1;
|
Integer type = 0;
|
boolean state = false;
|
List<String> tips = new ArrayList<String>();
|
String identify = rokenRecord.getIdentify();
|
|
TokenTypeEnum tokenType = rokenRecord.getType();
|
if (tokenType == TokenTypeEnum.freeCoupon) {
|
type = 10;
|
UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService
|
.selectByPrimaryKey(Long.parseLong(identify));
|
if (giveRecord == null)
|
throw new TokenRecordException(1, "赠送记录不存在");
|
|
Date endTime = giveRecord.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime())
|
throw new TokenRecordException(1, "赠送记录已过期");
|
|
// 用户券信息
|
UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(giveRecord.getCouponId());
|
if (userCoupon == null || userCoupon.getGive() == null || !userCoupon.getGive())
|
throw new TokenRecordException(1, "券不存在或非赠送状态");
|
|
if (userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) {
|
tips.add("哎呀，这张免单券已失效了！");
|
} else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) {
|
tips.add("哎呀，这张免单券已被领取了！");
|
} else if (userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) {
|
if (uid == null || uid <= 0)
|
throw new TokenRecordException(1001, "温馨提示，[免单券]需要登录后领取");
|
|
state = true;
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null || StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) {
|
tips.add("确认领取后，你将成为赠送者的一级队员；");
|
tips.add("获赠的免单券，需要激活后才能使用，详情参见免单券激活规则；");
|
tips.add("成功领取后，请到“我的-福利中心”查看。");
|
} else {
|
tips.add("获赠的免单券，需要激活后才能使用，详情参见免单券激活规则；");
|
tips.add("成功领取后，请到“我的-福利中心”查看。");
|
}
|
} else {
|
throw new TokenRecordException(1, "口令已失效");
|
}
|
} else if (tokenType == TokenTypeEnum.rebatePercentCoupon) {
|
type = 11;
|
|
// 赠送记录
|
UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService
|
.selectByPrimaryKey(Long.parseLong(identify));
|
if (giveRecord == null)
|
throw new TokenRecordException(1, "赠送记录不存在");
|
|
Date endTime = giveRecord.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime())
|
throw new TokenRecordException(1, "赠送记录已过期");
|
|
UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(giveRecord.getCouponId());
|
if (userCoupon == null || userCoupon.getGive() == null || !userCoupon.getGive())
|
throw new TokenRecordException(1, "券不存在或非赠送状态");
|
|
|
if (userCoupon.getState() == UserSystemCoupon.STATE_OVERDUE) {
|
tips.add("哎呀，这张返利奖励券已失效了！");
|
} else if (userCoupon.getState() == UserSystemCoupon.STATE_END_USE) {
|
tips.add("哎呀，这张返利奖励券已被领取了！");
|
} else if (userCoupon.getState() == UserSystemCoupon.STATE_IN_USE) {
|
if (uid == null || uid <= 0)
|
throw new TokenRecordException(1001, "温馨提示，[返利奖励券]需要登录后领取");
|
|
state = true;
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null || StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) {
|
tips.add("确认领取后，你将成为赠送者的一级队员；");
|
tips.add("板栗快省奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；");
|
tips.add("成功领取后，请到“我的-福利中心”中查看。");
|
} else {
|
tips.add("板栗快省奖励券，可用于“已到账”的返利订单，在返利的基础上再获得一定比例的返利；");
|
tips.add("成功领取后，请到“我的-福利中心”中查看。");
|
}
|
} else {
|
throw new TokenRecordException(1, "口令已失效");
|
}
|
} else if (tokenType == TokenTypeEnum.taoLiJin) {
|
type = 12;
|
|
UserTaoLiJinGiveRecord giveRecord = userTaoLiJinGiveRecordService.selectByPrimaryKey(Long.parseLong(identify));
|
if (giveRecord == null)
|
throw new TokenRecordException(1, "口令已失效");
|
|
BigDecimal amount = giveRecord.getAmount();
|
num = Integer.parseInt(amount.setScale(0).toString());
|
|
if(giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_OVERDUE) {
|
tips.add("哎呀，推广红包已失效了！");
|
} else if (giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_RECEIVE) {
|
tips.add("哎呀，推广红包已被领取了！");
|
} else if (giveRecord.getState() == UserTaoLiJinGiveRecord.STATE_INIT) {
|
if (uid == null || uid <= 0)
|
throw new TokenRecordException(1001, "温馨提示，[推广红包]需要登录后领取");
|
state = true;
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null || StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) {
|
tips.add("确认领取后，你将成为赠送者的一级队员；");
|
tips.add("推广红包，可分享爆款商品，让分享订单成单率更高；");
|
tips.add("成功领取后，请到“我的-推广红包”中查看。");
|
} else {
|
tips.add("推广红包，可分享爆款商品，让分享订单成单率更高；");
|
tips.add("成功领取后，请到“我的-推广红包”中查看。");
|
}
|
} else {
|
throw new TokenRecordException(1, "口令失效");
|
}
|
} else {
|
throw new TokenRecordException(1, "无对应类型");
|
}
|
|
String nickName = null;
|
String portrait = null;
|
Long inviteId = rokenRecord.getUid();
|
if (inviteId != null) {
|
UserInfo inviteUser = userInfoService.selectByPKey(inviteId);
|
if (inviteUser != null) {
|
nickName = inviteUser.getNickName();
|
portrait = inviteUser.getPortrait();
|
}
|
}
|
|
if (StringUtil.isNullOrEmpty(nickName))
|
nickName = Constant.systemCommonConfig.getDefaultNickName() + inviteId;
|
|
if (StringUtil.isNullOrEmpty(portrait))
|
portrait = Constant.systemCommonConfig.getDefaultPortrait();
|
|
if (nickName.length() > 6) {
|
nickName = nickName.substring(0, 6) + "...";
|
}
|
|
TokenVO tokenVO = new TokenVO();
|
tokenVO.setAmount(num);
|
tokenVO.setToken(parseToken);
|
tokenVO.setNickName(nickName + "赠送");
|
tokenVO.setPortrait(portrait);
|
tokenVO.setTips(tips);
|
tokenVO.setState(state);
|
tokenVO.setType(type);
|
return tokenVO;
|
}
|
|
|
|
@Override
|
public String receiveToken(String token, Long uid) throws TokenRecordException {
|
if (uid == null || uid <= 0)
|
throw new TokenRecordException(1, "用户未登录");
|
|
if (StringUtil.isNullOrEmpty(token))
|
throw new TokenRecordException(1, "口令不能为空");
|
|
TokenRecord rokenRecord = tokenRecordMapper.getByToken(token);
|
if (rokenRecord == null)
|
throw new TokenRecordException(1, "口令已失效");
|
|
Long uidToken = rokenRecord.getUid();
|
if (uidToken != null && uid.longValue() == uidToken.longValue())
|
throw new TokenRecordException(1, "不能自己赠送给自己");
|
|
Date now = new Date();
|
Date endTimeToken = rokenRecord.getEndTime();
|
if (endTimeToken != null && endTimeToken.getTime() < now.getTime())
|
throw new TokenRecordException(1, "口令已失效");
|
|
Integer stateTtoken = rokenRecord.getState();
|
if (stateTtoken != null && stateTtoken == 1)
|
throw new TokenRecordException(1, "口令已失效");
|
|
String identify = rokenRecord.getIdentify();
|
if (StringUtil.isNullOrEmpty(identify))
|
throw new TokenRecordException(1, "口令标识不存在");
|
|
Long giveUid = rokenRecord.getUid();
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null)
|
throw new TokenRecordException(1, "用户信息缺失");
|
|
String msg = "领取成功";
|
TokenTypeEnum tokenType = rokenRecord.getType();
|
if (tokenType == TokenTypeEnum.freeCoupon) {
|
|
// 赠送记录
|
UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService
|
.selectByPrimaryKey(Long.parseLong(identify));
|
if (giveRecord == null)
|
throw new TokenRecordException(1, "赠送记录不存在");
|
|
Date endTime = giveRecord.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime())
|
throw new TokenRecordException(1, "赠送记录已过期");
|
|
UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(giveRecord.getCouponId());
|
if (userCoupon == null || userCoupon.getGive() == null || !userCoupon.getGive()
|
|| userCoupon.getState() != UserSystemCoupon.STATE_IN_USE)
|
throw new TokenRecordException(1, "该券不存在或非赠送");
|
|
UserSystemCoupon userSystemCoupon= null;
|
try {
|
userSystemCoupon = userSystemCouponService.insertUserCoupon(uid, CouponTypeEnum.freeCoupon.name(),
|
UserSystemCoupon.SOURCE_GIVE, null);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
throw new TokenRecordException(1, "领取失败");
|
}
|
|
// 更新状态
|
Date date = new Date();
|
userCoupon.setId(userCoupon.getId());
|
userCoupon.setState(UserSystemCoupon.STATE_END_USE);
|
userCoupon.setUseTime(date);
|
userCoupon.setUpdateTime(date);
|
userSystemCouponService.updateByPrimaryKeySelective(userCoupon);
|
|
// 更新使用记录
|
UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(userCoupon.getId());
|
if (useRecord != null) {
|
UserSystemCouponRecord updateuseRecord = new UserSystemCouponRecord();
|
updateuseRecord.setId(useRecord.getId());
|
updateuseRecord.setState(UserSystemCouponRecord.STATE_SUCCESS);
|
updateuseRecord.setUpdateTime(new Date());
|
userSystemCouponRecordService.updateByPrimaryKeySelective(updateuseRecord);
|
}
|
|
// 更新赠送记录
|
UserSystemCouponGiveRecord updateGiveRecord = new UserSystemCouponGiveRecord();
|
updateGiveRecord.setId(giveRecord.getId());
|
updateGiveRecord.setReceiveUid(uid);
|
updateGiveRecord.setReceiveTime(new Date());
|
updateGiveRecord.setState(UserSystemCouponGiveRecord.STATE_RECEIVE);
|
if (userSystemCoupon != null) {
|
updateGiveRecord.setReceiveId(userSystemCoupon.getId());
|
}
|
userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateGiveRecord);
|
|
integralGetService.addGiveFreeCoupon(giveUid);
|
|
msg = "领取成功[免单券]成功，请到[我的-福利中心]中查看";
|
// 消息 + 队员
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
boolean addTeam = addInviteTeam(uid, giveUid, userInfoExtra);
|
String beiZhu = "无";
|
if (addTeam)
|
beiZhu = "领取人已经成为你的一级队员";
|
|
String userName = "无";
|
UserInfo user = userInfoService.selectByPKey(uid);
|
if (user != null && !StringUtil.isNullOrEmpty(user.getNickName()))
|
userName = user.getNickName();
|
|
MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();
|
msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON);
|
msgOther.setTitle("赠送免单券");
|
msgOther.setGiveType("你赠送的免单券被成功领取");
|
msgOther.setReceiveInfo("昵称: ：" + userName + " ID：" + uid);
|
msgOther.setGiveTime(sd.format(giveRecord.getGiveTime()));
|
msgOther.setReceiveTime(sd.format(new Date()));
|
userOtherMsgNotificationService.tokenGiveMsg(giveUid, beiZhu, msgOther);
|
|
// 激活邀请信息
|
if (addTeam)
|
addInviteMsg(uid, giveUid, "免单券");
|
}
|
});
|
} else if (tokenType == TokenTypeEnum.rebatePercentCoupon) {
|
// 赠送记录
|
UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService
|
.selectByPrimaryKey(Long.parseLong(identify));
|
if (giveRecord == null)
|
throw new TokenRecordException(1, "赠送记录不存在");
|
|
Date endTime = giveRecord.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime())
|
throw new TokenRecordException(1, "赠送记录已过期");
|
|
UserSystemCoupon userCoupon = userSystemCouponService.selectByPrimaryKey(giveRecord.getCouponId());
|
if (userCoupon == null || userCoupon.getGive() == null || !userCoupon.getGive()
|
|| userCoupon.getState() != UserSystemCoupon.STATE_IN_USE)
|
throw new TokenRecordException(1, "该券不存在或非赠送");
|
|
SystemCoupon systemCoupon = userCoupon.getSystemCoupon();
|
if (systemCoupon == null)
|
throw new TokenRecordException(1, "该券不存在");
|
|
systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
|
if (systemCoupon == null)
|
throw new TokenRecordException(1, "该券不存在");
|
|
UserSystemCoupon userSystemCoupon= null;
|
try {
|
userSystemCoupon = userSystemCouponService.insertUserCoupon(uid, CouponTypeEnum.rebatePercentCoupon.name(),
|
UserSystemCoupon.SOURCE_GIVE, systemCoupon.getPercent());
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
throw new TokenRecordException(1, "领取失败");
|
}
|
|
// 更新状态
|
Date date = new Date();
|
userCoupon.setId(userCoupon.getId());
|
userCoupon.setState(UserSystemCoupon.STATE_END_USE);
|
userCoupon.setUseTime(date);
|
userCoupon.setUpdateTime(date);
|
userSystemCouponService.updateByPrimaryKeySelective(userCoupon);
|
|
// 更新使用记录
|
UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(userCoupon.getId());
|
if (useRecord != null) {
|
UserSystemCouponRecord updateuseRecord = new UserSystemCouponRecord();
|
updateuseRecord.setId(useRecord.getId());
|
updateuseRecord.setState(UserSystemCouponRecord.STATE_SUCCESS);
|
updateuseRecord.setUpdateTime(new Date());
|
userSystemCouponRecordService.updateByPrimaryKeySelective(updateuseRecord);
|
}
|
|
// 更新赠送记录
|
UserSystemCouponGiveRecord updateGiveRecord = new UserSystemCouponGiveRecord();
|
updateGiveRecord.setId(giveRecord.getId());
|
updateGiveRecord.setReceiveUid(uid);
|
updateGiveRecord.setReceiveTime(new Date());
|
updateGiveRecord.setState(UserSystemCouponGiveRecord.STATE_RECEIVE);
|
if (userSystemCoupon != null) {
|
updateGiveRecord.setReceiveId(userSystemCoupon.getId());
|
}
|
userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateGiveRecord);
|
|
integralGetService.addGiveRebateCoupon(giveUid);
|
|
msg = "领取成功[返利奖励券]成功，请到[我的-福利中心]中查看";
|
// 消息 + 队员
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
boolean addTeam = addInviteTeam(uid, giveUid, userInfoExtra);
|
String beiZhu = "无";
|
if (addTeam)
|
beiZhu = "领取人已经成为你的一级队员";
|
|
String userName = "无";
|
UserInfo user = userInfoService.selectByPKey(uid);
|
if (user != null && !StringUtil.isNullOrEmpty(user.getNickName()))
|
userName = user.getNickName();
|
|
MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();
|
msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON);
|
msgOther.setTitle("赠送奖励券");
|
msgOther.setGiveType("你赠送的奖励券被成功领取");
|
msgOther.setReceiveInfo("昵称： " + userName + " ID：" + uid);
|
msgOther.setGiveTime(sd.format(giveRecord.getGiveTime()));
|
msgOther.setReceiveTime(sd.format(new Date()));
|
userOtherMsgNotificationService.tokenGiveMsg(giveUid, beiZhu, msgOther);
|
|
// 激活邀请信息
|
if (addTeam)
|
addInviteMsg(uid, giveUid, "返利奖励券");
|
}
|
});
|
} else if (tokenType == TokenTypeEnum.taoLiJin) {
|
UserTaoLiJinGiveRecord giveRecord = userTaoLiJinGiveRecordService
|
.selectByPrimaryKey(Long.parseLong(identify));
|
if (giveRecord == null || giveRecord.getState() != UserTaoLiJinGiveRecord.STATE_INIT)
|
throw new TokenRecordException(1, "赠送记录失效或已被领取");
|
|
Date endTime = giveRecord.getEndTime();
|
if (endTime != null && endTime.getTime() < now.getTime())
|
throw new TokenRecordException(1, "推广红包已失效了");
|
|
BigDecimal amount = giveRecord.getAmount();
|
try {
|
// 领取
|
userTaoLiJinOriginService.receiveFriendsGive(uid, amount);
|
|
// 更新记录
|
UserTaoLiJinGiveRecord updateRecord = new UserTaoLiJinGiveRecord();
|
updateRecord.setId(Long.parseLong(identify));
|
updateRecord.setReceiveTime(new Date());
|
updateRecord.setReceiveUid(uid);
|
updateRecord.setState(UserTaoLiJinGiveRecord.STATE_RECEIVE);
|
userTaoLiJinGiveRecordService.updateByPrimaryKeySelective(updateRecord);
|
|
integralGetService.addGiveTaoLiJin(giveUid);
|
|
msg = "领取成功[推广红包]成功，请到[我的-推广红包]中查看";
|
|
// 消息 + 队员
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
boolean addTeam = addInviteTeam(uid, giveUid, userInfoExtra);
|
String beiZhu = "无";
|
if (addTeam)
|
beiZhu = "领取人已经成为你的一级队员";
|
|
String userName = "无";
|
UserInfo user = userInfoService.selectByPKey(uid);
|
if (user != null && !StringUtil.isNullOrEmpty(user.getNickName()))
|
userName = user.getNickName();
|
|
MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();
|
msgOther.setType(MsgOtherGiveContentDTO.TYEP_TLJ);
|
msgOther.setTitle("赠送推广红包");
|
msgOther.setGiveType("你赠送的推广红包被成功领取");
|
msgOther.setReceiveInfo("昵称：" + userName + " ID：" + uid);
|
msgOther.setGiveTime(sd.format(giveRecord.getGiveTime()));
|
msgOther.setReceiveTime(sd.format(new Date()));
|
userOtherMsgNotificationService.tokenGiveMsg(giveUid, beiZhu, msgOther);
|
|
// 激活邀请信息
|
if (addTeam)
|
addInviteMsg(uid, giveUid, amount.setScale(2) + "元推广红包");
|
}
|
});
|
} catch (UserTaoLiJinOriginException e) {
|
e.printStackTrace();
|
}
|
} else {
|
throw new TokenRecordException(1, "无对应类型");
|
}
|
|
return msg;
|
}
|
|
/**
|
* 未激活邀请码： 上下级关系确立
|
*
|
* @param uid
|
* @param giveUid
|
* @param userInfoExtra
|
* @return
|
*/
|
public boolean addInviteTeam(Long uid, Long giveUid, UserInfoExtra userInfoExtra) {
|
boolean invite = false;
|
if (StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) {
|
UserInfoExtra userInfoExtraGive = userInfoExtraService.getUserInfoExtra(giveUid);
|
if (userInfoExtraGive != null) {
|
String inviteCode = userInfoExtraGive.getInviteCode();
|
if (!StringUtil.isNullOrEmpty(inviteCode)) {
|
try {
|
userInfoExtraService.activateInviteCode(uid, inviteCode);
|
invite = true;
|
} catch (UserInfoExtraException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
return invite;
|
}
|
|
|
private void addInviteMsg(Long uid, Long giveUid, String giftName) {
|
try {
|
UserInfo user = userInfoService.selectByPKey(giveUid);
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
MsgInviteContentDTO msgInvite = new MsgInviteContentDTO();
|
msgInvite.setTitle("邀请消息");
|
msgInvite.setState("成功激活邀请");
|
msgInvite.setCode("你的邀请码：" + userInfoExtra.getInviteCode());
|
msgInvite.setInviter("昵称："+user.getNickName());
|
msgInvite.setMode("成功领取邀请人的" + giftName);
|
userInviteMsgNotificationService.receiveGift(uid, "邀请关系一旦确立无法更改 ", msgInvite);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
|
@Override
|
public List<TokenRecord> overdueList(int count) {
|
return tokenRecordMapper.overdueList(count);
|
}
|
|
|
@Override
|
public void overdue(List<TokenRecord> list) {
|
if (list == null || list.size() == 0)
|
return;
|
Date date = new Date();
|
for (TokenRecord tokenRecord: list) {
|
tokenRecord.setState(1);
|
tokenRecord.setUpdateTime(date);
|
tokenRecordMapper.updateByPrimaryKeySelective(tokenRecord);
|
}
|
}
|
}
|
